pub mod backend;
pub mod conflict;
pub mod error;
pub mod hash;
pub mod merkle;
pub mod state_db;
pub mod sync_engine;

#[cfg(feature = "server")]
pub mod config;

pub use error::SyncError;
pub use sync_engine::{SyncConfig, SyncEngine, SyncOutcome, TrackedFile};

use backend::local_fs::LocalFsSyncBackend;
use std::path::Path;

/// Convenience function: build a `SyncEngine<LocalFsSyncBackend>`, run `sync()`,
/// and return the outcome. Intended for Phase 3 testing with a local directory
/// acting as the "remote".
pub fn try_flush_if_online(
    store_path: &Path,
    passphrase: &[u8],
    backend_root: &Path,
) -> Result<SyncOutcome, SyncError> {
    let backend = LocalFsSyncBackend::new(backend_root);

    // Build tracked files list — for now we only track the tdo store.json
    let store_path = store_path.to_path_buf();
    let tracked = vec![TrackedFile {
        file_key: "tdo/store.json".to_string(),
        tool: "tdo".to_string(),
        relative_path: "store.json".to_string(),
        local_path: store_path,
    }];

    let db_path = saku_storage::device::saku_data_dir()
        .map_err(SyncError::DeviceId)?
        .join("sync.db");

    let config = SyncConfig {
        db_path,
        passphrase: passphrase.to_vec(),
        tracked_files: tracked,
    };

    let mut engine = SyncEngine::new(config, backend)?;
    engine.sync()
}

/// Convenience function: build a `SyncEngine<ServerSyncBackend>`, run `sync()`,
/// and return the outcome. Used when the server feature is enabled and configured.
#[cfg(feature = "server")]
pub fn try_flush_if_online_server(
    store_path: &std::path::Path,
    passphrase: &[u8],
    server_url: &str,
    device_id: &str,
) -> Result<SyncOutcome, SyncError> {
    let backend = backend::server::ServerSyncBackend::new(server_url, device_id)?;

    let tracked = vec![TrackedFile {
        file_key: "tdo/store.json".to_string(),
        tool: "tdo".to_string(),
        relative_path: "store.json".to_string(),
        local_path: store_path.to_path_buf(),
    }];

    let db_path = saku_storage::device::saku_data_dir()
        .map_err(SyncError::DeviceId)?
        .join("sync.db");

    let config = SyncConfig {
        db_path,
        passphrase: passphrase.to_vec(),
        tracked_files: tracked,
    };

    let mut engine = SyncEngine::new(config, backend)?;
    engine.sync()
}
