feat: add FastList option to CloudSyncTask

Add fast_list support for Cloud Sync Tasks, enabling rclone's --fast-list
flag (fewer transactions in exchange for more memory). The fast_list option
is stored inside the attributes JSON object in the TrueNAS API.

Closes #8

Co-Authored-By: Mircea-Pavel ANTON <contact@mirceanton.com>
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 3 people

cloudsync_service.go

@@ -37,6 +37,7 @@ type CloudSyncTask struct {
 	BWLimit            []BwLimit
 	FollowSymlinks     bool
 	CreateEmptySrcDirs bool
+	FastList           bool
 	Enabled            bool
 	Encryption         bool
 	EncryptionPassword string
@@ -59,6 +60,7 @@ type CreateCloudSyncTaskOpts struct {
 	BWLimit            []BwLimit
 	FollowSymlinks     bool
 	CreateEmptySrcDirs bool
+	FastList           bool
 	Enabled            bool
 	Encryption         bool
 	EncryptionPassword string
@@ -305,9 +307,12 @@ func taskOptsToParams(opts CreateCloudSyncTaskOpts) map[string]any {
 		},
 	}
 
-	if opts.Attributes != nil {
-		params["attributes"] = opts.Attributes
+	attrs := opts.Attributes
+	if attrs == nil {
+		attrs = map[string]any{}
 	}
+	attrs["fast_list"] = opts.FastList
+	params["attributes"] = attrs
 
 	if opts.Encryption {
 		params["encryption_password"] = opts.EncryptionPassword
@@ -362,6 +367,10 @@ func taskFromResponse(resp CloudSyncTaskResponse) CloudSyncTask {
 	if len(resp.Attributes) > 0 {
 		var attrs map[string]any
 		if err := json.Unmarshal(resp.Attributes, &attrs); err == nil {
+			if fl, ok := attrs["fast_list"].(bool); ok {
+				task.FastList = fl
+				delete(attrs, "fast_list")
+			}
 			task.Attributes = attrs
 		}
 	}

cloudsync_service_conversion_test.go

@@ -222,7 +222,7 @@ func TestTaskOptsToParams_NoOptionalFields(t *testing.T) {
 	if _, ok := params["encryption_salt"]; ok {
 		t.Error("unexpected encryption_salt when encryption=false")
 	}
-	// No bwlimit, exclude, include, attributes
+	// No bwlimit, exclude, include
 	if _, ok := params["bwlimit"]; ok {
 		t.Error("unexpected bwlimit when empty")
 	}
@@ -232,8 +232,73 @@ func TestTaskOptsToParams_NoOptionalFields(t *testing.T) {
 	if _, ok := params["include"]; ok {
 		t.Error("unexpected include when empty")
 	}
-	if _, ok := params["attributes"]; ok {
-		t.Error("unexpected attributes when nil")
+	// Attributes should still be present with fast_list even when Attributes is nil
+	attrs, ok := params["attributes"].(map[string]any)
+	if !ok {
+		t.Fatal("expected attributes map in params")
+	}
+	if attrs["fast_list"] != false {
+		t.Errorf("expected fast_list=false in attributes, got %v", attrs["fast_list"])
+	}
+}
+
+func TestTaskOptsToParams_FastList(t *testing.T) {
+	opts := CreateCloudSyncTaskOpts{
+		Description:  "FastList Task",
+		Path:         "/mnt/tank",
+		CredentialID: 1,
+		Direction:    "PUSH",
+		TransferMode: "SYNC",
+		FastList:     true,
+		Schedule: Schedule{
+			Minute: "*",
+			Hour:   "*",
+			Dom:    "*",
+			Month:  "*",
+			Dow:    "*",
+		},
+	}
+
+	params := taskOptsToParams(opts)
+
+	attrs, ok := params["attributes"].(map[string]any)
+	if !ok {
+		t.Fatal("expected attributes map in params")
+	}
+	if attrs["fast_list"] != true {
+		t.Errorf("expected fast_list=true in attributes, got %v", attrs["fast_list"])
+	}
+}
+
+func TestTaskOptsToParams_FastList_MergesWithExistingAttributes(t *testing.T) {
+	opts := CreateCloudSyncTaskOpts{
+		Description:  "Merge Task",
+		Path:         "/mnt/tank",
+		CredentialID: 1,
+		Direction:    "PUSH",
+		TransferMode: "SYNC",
+		FastList:     true,
+		Attributes:   map[string]any{"bucket": "my-bucket"},
+		Schedule: Schedule{
+			Minute: "*",
+			Hour:   "*",
+			Dom:    "*",
+			Month:  "*",
+			Dow:    "*",
+		},
+	}
+
+	params := taskOptsToParams(opts)
+
+	attrs, ok := params["attributes"].(map[string]any)
+	if !ok {
+		t.Fatal("expected attributes map in params")
+	}
+	if attrs["bucket"] != "my-bucket" {
+		t.Errorf("expected bucket=my-bucket, got %v", attrs["bucket"])
+	}
+	if attrs["fast_list"] != true {
+		t.Errorf("expected fast_list=true in attributes, got %v", attrs["fast_list"])
 	}
 }
 
@@ -289,6 +354,44 @@ func TestTaskFromResponse_NullAttributes(t *testing.T) {
 	}
 }
 
+func TestTaskFromResponse_FastList(t *testing.T) {
+	resp := CloudSyncTaskResponse{
+		ID:          1,
+		Description: "Test",
+		Credentials: CloudSyncTaskCredentialRef{ID: 1},
+		Attributes:  json.RawMessage(`{"bucket": "my-bucket", "fast_list": true}`),
+		Schedule:    ScheduleResponse{Minute: "*", Hour: "*", Dom: "*", Month: "*", Dow: "*"},
+	}
+
+	task := taskFromResponse(resp)
+	if !task.FastList {
+		t.Error("expected FastList=true")
+	}
+	// fast_list should be removed from the Attributes map
+	if _, ok := task.Attributes["fast_list"]; ok {
+		t.Error("fast_list should be removed from Attributes map")
+	}
+	// Other attributes should be preserved
+	if task.Attributes["bucket"] != "my-bucket" {
+		t.Errorf("expected bucket=my-bucket, got %v", task.Attributes["bucket"])
+	}
+}
+
+func TestTaskFromResponse_FastListFalse(t *testing.T) {
+	resp := CloudSyncTaskResponse{
+		ID:          1,
+		Description: "Test",
+		Credentials: CloudSyncTaskCredentialRef{ID: 1},
+		Attributes:  json.RawMessage(`{"bucket": "b"}`),
+		Schedule:    ScheduleResponse{Minute: "*", Hour: "*", Dom: "*", Month: "*", Dow: "*"},
+	}
+
+	task := taskFromResponse(resp)
+	if task.FastList {
+		t.Error("expected FastList=false when not in attributes")
+	}
+}
+
 func TestNewCloudSyncService(t *testing.T) {
 	mock := &mockAsyncCaller{}
 	v := Version{Major: 25, Minor: 4}