| @@ -8,7 +8,7 @@ import ( | |||||
| ) | ) | ||||
| func BucketListUserBuckets(ctx CommandContext) error { | func BucketListUserBuckets(ctx CommandContext) error { | ||||
| userID := cdssdk.UserID(0) | |||||
| userID := cdssdk.UserID(1) | |||||
| buckets, err := ctx.Cmdline.Svc.BucketSvc().GetUserBuckets(userID) | buckets, err := ctx.Cmdline.Svc.BucketSvc().GetUserBuckets(userID) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -29,7 +29,7 @@ func BucketListUserBuckets(ctx CommandContext) error { | |||||
| } | } | ||||
| func BucketCreateBucket(ctx CommandContext, bucketName string) error { | func BucketCreateBucket(ctx CommandContext, bucketName string) error { | ||||
| userID := cdssdk.UserID(0) | |||||
| userID := cdssdk.UserID(1) | |||||
| bucketID, err := ctx.Cmdline.Svc.BucketSvc().CreateBucket(userID, bucketName) | bucketID, err := ctx.Cmdline.Svc.BucketSvc().CreateBucket(userID, bucketName) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -41,7 +41,7 @@ func BucketCreateBucket(ctx CommandContext, bucketName string) error { | |||||
| } | } | ||||
| func BucketDeleteBucket(ctx CommandContext, bucketID cdssdk.BucketID) error { | func BucketDeleteBucket(ctx CommandContext, bucketID cdssdk.BucketID) error { | ||||
| userID := cdssdk.UserID(0) | |||||
| userID := cdssdk.UserID(1) | |||||
| err := ctx.Cmdline.Svc.BucketSvc().DeleteBucket(userID, bucketID) | err := ctx.Cmdline.Svc.BucketSvc().DeleteBucket(userID, bucketID) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -8,7 +8,7 @@ import ( | |||||
| ) | ) | ||||
| func CacheMovePackage(ctx CommandContext, packageID cdssdk.PackageID, nodeID cdssdk.NodeID) error { | func CacheMovePackage(ctx CommandContext, packageID cdssdk.PackageID, nodeID cdssdk.NodeID) error { | ||||
| taskID, err := ctx.Cmdline.Svc.CacheSvc().StartCacheMovePackage(0, packageID, nodeID) | |||||
| taskID, err := ctx.Cmdline.Svc.CacheSvc().StartCacheMovePackage(1, packageID, nodeID) | |||||
| if err != nil { | if err != nil { | ||||
| return fmt.Errorf("start cache moving package: %w", err) | return fmt.Errorf("start cache moving package: %w", err) | ||||
| } | } | ||||
| @@ -8,7 +8,7 @@ import ( | |||||
| ) | ) | ||||
| func StorageLoadPackage(ctx CommandContext, packageID cdssdk.PackageID, storageID cdssdk.StorageID) error { | func StorageLoadPackage(ctx CommandContext, packageID cdssdk.PackageID, storageID cdssdk.StorageID) error { | ||||
| nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageLoadPackage(0, packageID, storageID) | |||||
| nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageLoadPackage(1, packageID, storageID) | |||||
| if err != nil { | if err != nil { | ||||
| return fmt.Errorf("start loading package to storage: %w", err) | return fmt.Errorf("start loading package to storage: %w", err) | ||||
| } | } | ||||
| @@ -31,7 +31,7 @@ func StorageLoadPackage(ctx CommandContext, packageID cdssdk.PackageID, storageI | |||||
| } | } | ||||
| func StorageCreatePackage(ctx CommandContext, bucketID cdssdk.BucketID, name string, storageID cdssdk.StorageID, path string) error { | func StorageCreatePackage(ctx CommandContext, bucketID cdssdk.BucketID, name string, storageID cdssdk.StorageID, path string) error { | ||||
| nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageCreatePackage(0, bucketID, name, storageID, path, nil) | |||||
| nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageCreatePackage(1, bucketID, name, storageID, path, nil) | |||||
| if err != nil { | if err != nil { | ||||
| return fmt.Errorf("start storage uploading package: %w", err) | return fmt.Errorf("start storage uploading package: %w", err) | ||||
| } | } | ||||