Add deferred option

Author: polldo

cli/ota/upload.go

@@ -10,6 +10,7 @@ import (
 var uploadFlags struct {
 	deviceID string
 	file     string
+	deferred bool
 }
 
 func initUploadCommand() *cobra.Command {
@@ -22,6 +23,7 @@ func initUploadCommand() *cobra.Command {
 
 	uploadCommand.Flags().StringVarP(&uploadFlags.deviceID, "device-id", "d", "", "Device ID")
 	uploadCommand.Flags().StringVarP(&uploadFlags.file, "file", "", "", "Binary file (.bin) to be uploaded")
+	uploadCommand.Flags().BoolVar(&uploadFlags.deferred, "deferred", false, "Perform a deferred OTA. It can take up to 1 week.")
 
 	uploadCommand.MarkFlagRequired("device-id")
 	uploadCommand.MarkFlagRequired("file")

command/ota/upload.go

@@ -15,6 +15,7 @@ import (
 type UploadParams struct {
 	DeviceID string
 	File     string
+	Deferred bool
 }
 
 // Upload command is used to upload a firmware OTA,
@@ -51,7 +52,12 @@ func Upload(params *UploadParams) error {
 		return fmt.Errorf("%s: %w", "cannot open ota file", err)
 	}
 
-	err = iotClient.DeviceOTA(params.DeviceID, file)
+	expiration := 10
+	if params.Deferred {
+		expiration = 1000
+	}
+
+	err = iotClient.DeviceOTA(params.DeviceID, file, expiration)
 	if err != nil {
 		return err
 	}

internal/iot/client.go

@@ -15,7 +15,7 @@ type Client interface {
 	DeviceDelete(id string) error
 	DeviceList() ([]iotclient.ArduinoDevicev2, error)
 	DeviceShow(id string) (*iotclient.ArduinoDevicev2, error)
-	DeviceOTA(id string, file *os.File) error
+	DeviceOTA(id string, file *os.File, expireMins int) error
 	CertificateCreate(id, csr string) (*iotclient.ArduinoCompressedv2, error)
 	ThingCreate(thing *iotclient.Thing, force bool) (string, error)
 	ThingUpdate(id string, thing *iotclient.Thing, force bool) error
@@ -93,9 +93,9 @@ func (cl *client) DeviceShow(id string) (*iotclient.ArduinoDevicev2, error) {
 
 // DeviceOTA performs an OTA upload request to Arduino IoT Cloud, passing
 // the ID of the device to be updated and the actual file containing the OTA firmware.
-func (cl *client) DeviceOTA(id string, file *os.File) error {
+func (cl *client) DeviceOTA(id string, file *os.File, expireMins int) error {
 	opt := &iotclient.DevicesV2OtaUploadOpts{
-		ExpireInMins: optional.NewInt32(5),
+		ExpireInMins: optional.NewInt32(int32(expireMins)),
 	}
 	_, err := cl.api.DevicesV2OtaApi.DevicesV2OtaUpload(cl.ctx, id, file, opt)
 	if err != nil {