Cloud Integration

let input = VolumeAddCloudInput {
    service: CloudServiceType::S3,
    display_name: "My Bucket".to_string(),
    config: CloudStorageConfig::S3 {
        bucket: "my-bucket".to_string(),
        region: "us-west-2".to_string(),
        access_key_id: "...".to_string(),
        secret_access_key: "...".to_string(),
        endpoint: None,
    },
};

dispatcher.execute_library_action::<VolumeAddCloudAction>(input, ctx).await?;

s3://my-bucket/photos/vacation.jpg
gdrive://My Drive/Documents/contract.pdf
onedrive://Documents/budget.xlsx
dropbox://Apps/Spacedrive/backup.zip
azblob://container/data/export.csv
gcs://bucket/logs/app.log

pub enum SdPath {
    Physical {
        device_slug: String,  // URL-safe device identifier
        path: PathBuf,
    },
    Cloud {
        service: CloudServiceType,  // S3, GoogleDrive, etc.
        identifier: String,          // Bucket/drive/container name
        path: String,                // Path within the service
    },
    Content {
        content_id: Uuid,
    },
}

let credential_manager = CloudCredentialManager::new(library_key_manager);
credential_manager
    .store_credential(library_id, &volume_fingerprint, &credential)
    .await?;

// Quick scan for navigation
let path = SdPath::from_uri_with_context(
    "s3://my-bucket/",
    &context
).await?;

let config = IndexerJobConfig::ui_navigation(path, IndexMode::Shallow);

// Deep scan with content identification
let path = SdPath::from_uri_with_context(
    "s3://my-bucket/",
    &context
).await?;

let config = IndexerJobConfig::new(path, IndexMode::Content);

// Copy from cloud to local
let src = SdPath::from_uri_with_context(
    "gdrive://Work/photos/vacation.jpg",
    &context
).await?;

let dst = SdPath::from_uri_with_context(
    "local://macbook/backup/",
    &context
).await?;

let input = FileCopyInput::new(vec![src], dst);
let result = dispatcher.execute_library_action::<FileCopyAction>(
    input,
    session_context
).await?;

// Move between cloud services
let src = SdPath::from_uri_with_context(
    "s3://archive/report.pdf",
    &context
).await?;

let dst = SdPath::from_uri_with_context(
    "gdrive://Work/documents/",
    &context
).await?;

let job = FileCopyJob::new(
    SdPathBatch::new(vec![src]),
    dst
).with_move(true);

library.jobs().dispatch(job).await?;

// Add cloud volume as backup destination
let backup_volume = volume_manager
    .add_cloud_volume(CloudServiceType::S3, backup_credentials)
    .await?;

// Create backup job
let src = SdPath::from_uri_with_context(
    "local://macbook/Users/james/Documents/important/",
    &context
).await?;

let dst = SdPath::from_uri_with_context(
    "s3://backup-bucket/backups/",
    &context
).await?;

let backup_job = FileCopyJob::new(
    SdPathBatch::new(vec![src]),
    dst
).with_options(CopyOptions {
    preserve_timestamps: true,
    verify_checksum: true,
    ..Default::default()
});

library.jobs().dispatch(backup_job).await?;

// Search includes cloud volumes automatically
let results = search_manager
    .search("vacation photos")
    .across_all_volumes()
    .await?;

// Move old projects to cloud archive
let src = SdPath::from_uri_with_context(
    "local://macbook/Users/james/projects/MyVideoProject",
    &context
).await?;

let dst = SdPath::from_uri_with_context(
    "s3://archive/projects/archived/",
    &context
).await?;

let move_job = FileCopyJob::new(src, dst).with_move(true);

// Schedule regular archival
scheduler.add_recurring_job(move_job, Schedule::Weekly);