diaryx_core 1.0.1

//! Sync handler for processing remote CRDT updates.
//!
//! This module provides `SyncHandler`, which handles the side effects of remote
//! CRDT updates including writing files to disk with merged metadata. It serves
//! as the single source of truth for sync logic, replacing TypeScript-side processing.
//!
//! # Doc-ID Based Architecture
//!
//! With the doc-ID based CRDT, files are keyed by stable UUIDs rather than paths.
//! This simplifies sync significantly:
//!
//! - **Renames become trivial**: A rename is just a `filename` property update,
//!   not a delete+create. The `renames` parameter becomes optional/empty.
//!
//! - **Path derivation**: The handler derives filesystem paths from doc_ids by
//!   walking the `part_of` parent chain and joining filenames.
//!
//! - **Stable body sync**: Body documents are keyed by doc_id, so they remain
//!   stable across renames without needing migration.

use std::path::{Path, PathBuf};
use std::sync::RwLock;

use serde::{Deserialize, Serialize};
use ts_rs::TS;

use super::body_doc_manager::BodyDocManager;
use super::types::FileMetadata;
use crate::error::Result;
use crate::fs::{AsyncFileSystem, FileSystemEvent};
use crate::metadata_writer;
use crate::path_utils::normalize_sync_path;

/// Configuration for guest mode sync.
///
/// Guests need special path handling to isolate their storage from the host.
#[derive(Debug, Clone, Default, Serialize, Deserialize, TS)]
#[ts(export, export_to = "bindings/")]
pub struct GuestConfig {
    /// The join code for the share session.
    pub join_code: String,

    /// If true, prefix paths with guest/{join_code}/ for OPFS storage.
    /// If false (in-memory storage), paths are used as-is.
    pub uses_opfs: bool,
}

/// Handler for sync side effects.
///
/// The SyncHandler is responsible for processing remote CRDT updates and
/// performing the necessary disk writes. It handles:
/// - Writing updated file metadata and body to disk after remote updates
/// - Merging CRDT metadata with disk metadata (CRDT wins, disk as fallback)
/// - Guest path prefixing for isolated storage
/// - Emitting FileSystemEvents for UI updates
pub struct SyncHandler<FS: AsyncFileSystem> {
    fs: FS,
    /// Workspace root directory for converting canonical paths to absolute paths.
    /// When set, canonical paths (e.g., "Archive/file.md") are resolved relative to this root.
    /// When not set, paths are used as-is (relative to current working directory).
    workspace_root: RwLock<Option<PathBuf>>,
    /// Guest configuration, if operating in guest mode.
    guest_config: RwLock<Option<GuestConfig>>,
    /// Optional callback for emitting filesystem events.
    event_callback: Option<Box<dyn Fn(&FileSystemEvent) + Send + Sync>>,
}

impl<FS: AsyncFileSystem> SyncHandler<FS> {
    /// Create a new SyncHandler with the given filesystem.
    pub fn new(fs: FS) -> Self {
        Self {
            fs,
            workspace_root: RwLock::new(None),
            guest_config: RwLock::new(None),
            event_callback: None,
        }
    }

    /// Set the workspace root directory.
    ///
    /// When set, canonical paths (e.g., "Archive/file.md") are resolved relative
    /// to this root when writing to disk. This is essential for Tauri/native apps
    /// where files should be written to a specific workspace directory, not the
    /// current working directory.
    pub fn set_workspace_root(&self, root: PathBuf) {
        log::trace!("[SyncHandler] Setting workspace root: {:?}", root);
        let mut wr = self.workspace_root.write().unwrap();
        *wr = Some(root);
    }

    /// Get the workspace root directory, if set.
    pub fn get_workspace_root(&self) -> Option<PathBuf> {
        self.workspace_root.read().unwrap().clone()
    }

    /// Set the event callback for emitting filesystem events.
    pub fn set_event_callback(&mut self, callback: Box<dyn Fn(&FileSystemEvent) + Send + Sync>) {
        self.event_callback = Some(callback);
    }

    /// Configure guest mode.
    ///
    /// In guest mode, storage paths are prefixed with `guest/{join_code}/`
    /// when using OPFS, or used as-is for in-memory storage.
    pub fn configure_guest(&self, config: Option<GuestConfig>) {
        let mut gc = self.guest_config.write().unwrap();
        *gc = config;
    }

    /// Check if we're in guest mode.
    pub fn is_guest(&self) -> bool {
        self.guest_config.read().unwrap().is_some()
    }

    /// Get the storage path for a canonical path.
    ///
    /// Converts a canonical path (relative to workspace root) to an absolute
    /// storage path on disk.
    ///
    /// - If workspace_root is set: returns workspace_root.join(canonical_path)
    /// - For guests using OPFS: prefixes with `guest/{join_code}/`
    /// - Otherwise: returns the path as-is (relative to cwd)
    pub fn get_storage_path(&self, canonical_path: &str) -> PathBuf {
        let canonical_path = normalize_sync_path(canonical_path);
        let gc = self.guest_config.read().unwrap();
        let base_path = match &*gc {
            Some(config) if config.uses_opfs => {
                PathBuf::from(format!("guest/{}/{}", config.join_code, canonical_path))
            }
            _ => PathBuf::from(canonical_path),
        };

        // If workspace root is set, resolve the path relative to it
        let wr = self.workspace_root.read().unwrap();
        match &*wr {
            Some(root) => root.join(&base_path),
            None => base_path,
        }
    }

    /// Get the canonical path from a storage path.
    ///
    /// Converts an absolute or storage path to a workspace-relative canonical path.
    /// - Strips the workspace root prefix if set (e.g., `/Users/adam/diaryx/README.md` → `README.md`)
    /// - Strips the `guest/{join_code}/` prefix if present for OPFS guests
    pub fn get_canonical_path(&self, storage_path: &str) -> String {
        use std::path::Path;

        // Strip workspace root if set
        let stripped = {
            let wr = self.workspace_root.read().unwrap();
            if let Some(root) = &*wr {
                Path::new(storage_path)
                    .strip_prefix(root)
                    .map(|p| p.to_string_lossy().to_string())
                    .unwrap_or_else(|_| storage_path.to_string())
            } else {
                storage_path.to_string()
            }
        };

        // Strip guest prefix if in guest mode
        let gc = self.guest_config.read().unwrap();
        let stripped = if let Some(config) = &*gc
            && config.uses_opfs
        {
            let prefix = format!("guest/{}/", config.join_code);
            if stripped.starts_with(&prefix) {
                stripped[prefix.len()..].to_string()
            } else {
                stripped
            }
        } else {
            stripped
        };

        normalize_sync_path(&stripped)
    }

    /// Emit a filesystem event to the registered callback.
    fn emit_event(&self, event: FileSystemEvent) {
        if let Some(ref cb) = self.event_callback {
            cb(&event);
        }
    }

    /// Handle remote metadata updates by writing files to disk.
    ///
    /// This method processes a list of updated files from a remote sync and:
    /// 1. Handles renames first (moves files to preserve body content)
    /// 2. For each non-renamed file, merges CRDT metadata with disk metadata
    /// 3. Gets body content from the BodyDocManager
    /// 4. Writes the file to disk with merged frontmatter
    /// 5. Emits appropriate FileSystemEvents
    ///
    /// Files marked as deleted are removed from disk.
    ///
    /// # Arguments
    /// * `files` - List of (canonical_path, metadata) tuples from the CRDT
    /// * `renames` - List of (old_path, new_path) for detected renames
    /// * `body_manager` - Manager for per-file body CRDTs
    /// * `write_to_disk` - If true, perform disk writes; if false, only emit events
    pub async fn handle_remote_metadata_update(
        &self,
        files: Vec<(String, FileMetadata)>,
        renames: Vec<(String, String)>,
        body_manager: Option<&BodyDocManager>,
        write_to_disk: bool,
    ) -> Result<usize> {
        let mut synced_count = 0;

        // Track which renames actually succeeded (old file existed and was moved)
        let mut successful_old_paths: std::collections::HashSet<String> =
            std::collections::HashSet::new();
        let mut successful_new_paths: std::collections::HashSet<String> =
            std::collections::HashSet::new();

        // Handle renames first - handle all four cases based on file existence
        for (old_canonical, new_canonical) in &renames {
            let old_storage = self.get_storage_path(old_canonical);
            let new_storage = self.get_storage_path(new_canonical);

            if !write_to_disk {
                // Not writing to disk, just emit events and track the rename
                successful_old_paths.insert(old_canonical.clone());
                successful_new_paths.insert(new_canonical.clone());
                self.emit_event(FileSystemEvent::file_renamed(
                    old_storage,
                    new_storage.clone(),
                ));
                synced_count += 1;
                continue;
            }

            let old_exists = self.fs.exists(&old_storage).await;
            let new_exists = self.fs.exists(&new_storage).await;

            match (old_exists, new_exists) {
                (true, false) => {
                    // Normal case: old exists, new doesn't - perform the rename
                    log::debug!(
                        "SyncHandler: Renaming file {:?} -> {:?}",
                        old_storage,
                        new_storage
                    );

                    // Ensure parent directory exists
                    if let Some(parent) = new_storage.parent()
                        && let Err(e) = self.fs.create_dir_all(parent).await
                    {
                        log::warn!(
                            "SyncHandler: Failed to create parent directory for {:?}: {}",
                            new_storage,
                            e
                        );
                    }

                    // Mark sync write to prevent CRDT feedback loop
                    self.fs.mark_sync_write_start(&old_storage);
                    self.fs.mark_sync_write_start(&new_storage);

                    if let Err(e) = self.fs.move_file(&old_storage, &new_storage).await {
                        log::warn!(
                            "SyncHandler: Failed to rename {:?} -> {:?}: {}",
                            old_storage,
                            new_storage,
                            e
                        );
                        self.fs.mark_sync_write_end(&old_storage);
                        self.fs.mark_sync_write_end(&new_storage);
                    } else {
                        self.fs.mark_sync_write_end(&old_storage);
                        self.fs.mark_sync_write_end(&new_storage);

                        // Track this rename as successful
                        successful_old_paths.insert(old_canonical.clone());
                        successful_new_paths.insert(new_canonical.clone());

                        self.emit_event(FileSystemEvent::file_renamed(
                            old_storage,
                            new_storage.clone(),
                        ));
                        synced_count += 1;

                        // Update frontmatter with new metadata after rename
                        if let Some((_, metadata)) = files.iter().find(|(p, _)| p == new_canonical)
                        {
                            let metadata_json = serde_json::to_value(metadata)
                                .unwrap_or(serde_json::Value::Object(Default::default()));

                            // Read existing body content
                            let body: String =
                                self.read_disk_body(&new_storage).await.unwrap_or_default();

                            self.fs.mark_sync_write_start(&new_storage);
                            if let Err(e) =
                                metadata_writer::write_file_with_metadata_and_canonical_path(
                                    &self.fs,
                                    &new_storage,
                                    &metadata_json,
                                    &body,
                                    Some(new_canonical),
                                )
                                .await
                            {
                                log::warn!(
                                    "SyncHandler: Failed to update metadata after rename {:?}: {}",
                                    new_storage,
                                    e
                                );
                            }
                            self.fs.mark_sync_write_end(&new_storage);
                        }
                    }
                }
                (false, true) => {
                    // Already renamed: old doesn't exist, new does - just update metadata
                    log::debug!(
                        "SyncHandler: File already renamed {:?} -> {:?}, updating metadata",
                        old_storage,
                        new_storage
                    );

                    // Track as successful rename for the files loop
                    successful_old_paths.insert(old_canonical.clone());
                    successful_new_paths.insert(new_canonical.clone());

                    // Emit event for UI consistency
                    self.emit_event(FileSystemEvent::file_renamed(
                        old_storage,
                        new_storage.clone(),
                    ));
                    synced_count += 1;

                    // Update frontmatter with new metadata
                    if let Some((_, metadata)) = files.iter().find(|(p, _)| p == new_canonical) {
                        let metadata_json = serde_json::to_value(metadata)
                            .unwrap_or(serde_json::Value::Object(Default::default()));

                        // Read existing body content
                        let body: String =
                            self.read_disk_body(&new_storage).await.unwrap_or_default();

                        self.fs.mark_sync_write_start(&new_storage);
                        if let Err(e) =
                            metadata_writer::write_file_with_metadata_and_canonical_path(
                                &self.fs,
                                &new_storage,
                                &metadata_json,
                                &body,
                                Some(new_canonical),
                            )
                            .await
                        {
                            log::warn!(
                                "SyncHandler: Failed to update metadata for {:?}: {}",
                                new_storage,
                                e
                            );
                        }
                        self.fs.mark_sync_write_end(&new_storage);
                    }
                }
                (true, true) => {
                    // Conflict: both exist - delete old, keep new
                    log::debug!(
                        "SyncHandler: Rename conflict, both exist {:?} -> {:?}, deleting old",
                        old_storage,
                        new_storage
                    );

                    self.fs.mark_sync_write_start(&old_storage);
                    if let Err(e) = self.fs.delete_file(&old_storage).await {
                        log::warn!(
                            "SyncHandler: Failed to delete old file {:?}: {}",
                            old_storage,
                            e
                        );
                    }
                    self.fs.mark_sync_write_end(&old_storage);

                    // Track as successful rename
                    successful_old_paths.insert(old_canonical.clone());
                    successful_new_paths.insert(new_canonical.clone());

                    self.emit_event(FileSystemEvent::file_renamed(
                        old_storage,
                        new_storage.clone(),
                    ));
                    synced_count += 1;
                }
                (false, false) => {
                    // Both paths are transiently missing on disk.
                    //
                    // Still treat this as a logical rename so downstream consumers
                    // (UI path remapping, active-entry tracking) receive FileRenamed.
                    // The files loop below will materialize the new path from metadata/body.
                    log::debug!(
                        "SyncHandler: Logical rename with transiently missing paths {:?} -> {:?}",
                        old_storage,
                        new_storage
                    );

                    successful_old_paths.insert(old_canonical.clone());
                    successful_new_paths.insert(new_canonical.clone());

                    self.emit_event(FileSystemEvent::file_renamed(
                        old_storage,
                        new_storage.clone(),
                    ));
                    synced_count += 1;
                }
            }
        }

        for (canonical_path, crdt_metadata) in files {
            // Skip OLD paths from SUCCESSFUL renames (they're deleted, handled by the rename move)
            if successful_old_paths.contains(&canonical_path) {
                continue;
            }

            // For SUCCESSFUL renamed NEW paths, the file was already moved, so just update metadata
            let is_renamed_new_path = successful_new_paths.contains(&canonical_path);

            let storage_path = self.get_storage_path(&canonical_path);

            if crdt_metadata.deleted {
                // File was deleted - remove from filesystem if it exists
                let file_exists = write_to_disk && self.fs.exists(&storage_path).await;

                if file_exists {
                    log::debug!("SyncHandler: Deleting file from disk: {:?}", storage_path);
                    if let Err(e) = self.fs.delete_file(&storage_path).await {
                        log::warn!(
                            "SyncHandler: Failed to delete file {:?}: {}",
                            storage_path,
                            e
                        );
                    }
                } else {
                    log::debug!(
                        "SyncHandler: File already deleted or doesn't exist: {:?}",
                        storage_path
                    );
                }

                // Always emit FileDeleted event for UI consistency, even if file
                // doesn't exist on disk (may have been deleted by another client)
                self.emit_event(FileSystemEvent::file_deleted(storage_path.clone()));
                synced_count += 1;
            } else {
                // File exists - merge metadata and write to disk
                // Use get_or_create to ensure the body doc is loaded from storage if it exists,
                // or created fresh if it doesn't. This fixes the bug where body docs that exist
                // in storage but aren't loaded in memory would return empty string.
                let body = if let Some(manager) = body_manager {
                    let doc = manager.get_or_create(&canonical_path);
                    doc.get_body()
                } else {
                    String::new()
                };

                // Try to read existing disk content for metadata merging
                let final_metadata = if write_to_disk && self.fs.exists(&storage_path).await {
                    match self.read_disk_frontmatter(&storage_path).await {
                        Ok(disk_fm) => self.merge_metadata(&crdt_metadata, Some(&disk_fm)),
                        Err(_) => crdt_metadata.clone(),
                    }
                } else {
                    crdt_metadata.clone()
                };

                // Preserve disk body if CRDT body is empty and disk has content
                let final_body = if body.is_empty() && write_to_disk {
                    match self.read_disk_body(&storage_path).await {
                        Ok(disk_body) if !disk_body.is_empty() => {
                            log::debug!(
                                "SyncHandler: Preserving disk body for {} ({} chars)",
                                canonical_path,
                                disk_body.len()
                            );
                            disk_body
                        }
                        _ => body,
                    }
                } else {
                    body
                };

                // Write file to disk
                if write_to_disk {
                    let metadata_json = serde_json::to_value(&final_metadata)
                        .unwrap_or(serde_json::Value::Object(Default::default()));

                    // Mark sync write start to prevent CRDT feedback loop
                    // When CrdtFs sees this marker, it will skip generating a new CRDT update
                    self.fs.mark_sync_write_start(&storage_path);

                    if let Err(e) = metadata_writer::write_file_with_metadata_and_canonical_path(
                        &self.fs,
                        &storage_path,
                        &metadata_json,
                        &final_body,
                        Some(&canonical_path),
                    )
                    .await
                    {
                        // Clear marker even on failure
                        self.fs.mark_sync_write_end(&storage_path);
                        log::warn!(
                            "SyncHandler: Failed to write file {:?}: {}",
                            storage_path,
                            e
                        );
                        continue;
                    }

                    // Clear sync write marker
                    self.fs.mark_sync_write_end(&storage_path);
                    log::debug!("SyncHandler: Wrote file to disk: {:?}", storage_path);
                }

                // Emit appropriate event
                let metadata_json = serde_json::to_value(&final_metadata).ok();
                if is_renamed_new_path {
                    // File was renamed - emit MetadataChanged since file already exists
                    if let Some(fm) = metadata_json {
                        self.emit_event(FileSystemEvent::metadata_changed(
                            storage_path.clone(),
                            fm,
                        ));
                    }
                } else {
                    // New file - emit FileCreated
                    self.emit_event(FileSystemEvent::file_created_with_metadata(
                        storage_path.clone(),
                        metadata_json,
                        None,
                    ));
                }

                synced_count += 1;
            }
        }

        Ok(synced_count)
    }

    /// Handle a remote body update by writing the body to disk.
    ///
    /// # Arguments
    /// * `canonical_path` - The canonical path of the file
    /// * `body` - The new body content
    /// * `crdt_metadata` - Optional metadata to use for the frontmatter
    pub async fn handle_remote_body_update(
        &self,
        canonical_path: &str,
        body: &str,
        crdt_metadata: Option<&FileMetadata>,
    ) -> Result<()> {
        // Skip temporary files created by the metadata writer's safe write process
        // These files should never be processed from remote updates
        if crate::fs::is_temp_file(canonical_path) {
            log::debug!(
                "[SyncHandler] Skipping remote body update for temporary file: {}",
                canonical_path
            );
            return Ok(());
        }

        let storage_path = self.get_storage_path(canonical_path);
        log::info!(
            "[SyncHandler] handle_remote_body_update START: canonical_path='{}', storage_path='{:?}', body_len={}, body_preview='{}'",
            canonical_path,
            storage_path,
            body.len(),
            body.chars().take(100).collect::<String>()
        );

        // Get or construct metadata for frontmatter
        let metadata = if let Some(m) = crdt_metadata {
            m.clone()
        } else if self.fs.exists(&storage_path).await {
            // Try to read existing frontmatter
            self.read_disk_frontmatter(&storage_path)
                .await
                .unwrap_or_default()
        } else {
            FileMetadata::default()
        };

        // Merge with disk metadata if CRDT metadata provided
        let final_metadata = if crdt_metadata.is_some() && self.fs.exists(&storage_path).await {
            match self.read_disk_frontmatter(&storage_path).await {
                Ok(disk_fm) => self.merge_metadata(&metadata, Some(&disk_fm)),
                Err(_) => metadata,
            }
        } else {
            metadata
        };

        let metadata_json = serde_json::to_value(&final_metadata)
            .unwrap_or(serde_json::Value::Object(Default::default()));

        // Mark sync write start to prevent CRDT feedback loop
        self.fs.mark_sync_write_start(&storage_path);

        let write_result = metadata_writer::write_file_with_metadata_and_canonical_path(
            &self.fs,
            &storage_path,
            &metadata_json,
            body,
            Some(canonical_path),
        )
        .await;

        // Clear sync write marker (even on failure)
        self.fs.mark_sync_write_end(&storage_path);

        if let Err(ref e) = write_result {
            log::error!(
                "[SyncHandler] handle_remote_body_update FAILED: canonical_path='{}', error='{}'",
                canonical_path,
                e
            );
        } else {
            log::info!(
                "[SyncHandler] handle_remote_body_update SUCCESS: canonical_path='{}', storage_path='{:?}', body_len={}",
                canonical_path,
                storage_path,
                body.len()
            );
        }

        write_result?;

        // NOTE: We do NOT emit ContentsChanged here. The caller (sync_manager::handle_body_message)
        // emits a single ContentsChanged event. Emitting here caused duplicate notifications.

        Ok(())
    }

    /// Merge CRDT metadata with disk metadata.
    ///
    /// CRDT values take precedence. Disk values are used as fallback only when
    /// CRDT values are `None` (not set). An explicitly set empty array `Some([])`
    /// is NOT replaced with disk values, as this represents an intentional deletion.
    pub fn merge_metadata(&self, crdt: &FileMetadata, disk: Option<&FileMetadata>) -> FileMetadata {
        let disk = match disk {
            Some(d) => d,
            None => return crdt.clone(),
        };

        FileMetadata {
            // Filename from CRDT takes precedence, fall back to disk if empty
            filename: if crdt.filename.is_empty() {
                disk.filename.clone()
            } else {
                crdt.filename.clone()
            },
            title: crdt.title.clone().or_else(|| disk.title.clone()),
            part_of: crdt.part_of.clone().or_else(|| disk.part_of.clone()),
            // Only fall back to disk if crdt.contents is None (not set).
            // Some([]) means explicitly cleared and should not be overwritten.
            contents: match &crdt.contents {
                None => disk.contents.clone(),
                Some(_) => crdt.contents.clone(),
            },
            attachments: if crdt.attachments.is_empty() {
                disk.attachments.clone()
            } else {
                crdt.attachments.clone()
            },
            deleted: crdt.deleted,
            // Only fall back to disk if crdt.audience is None (not set).
            // Some([]) means explicitly cleared and should not be overwritten.
            audience: match &crdt.audience {
                None => disk.audience.clone(),
                Some(_) => crdt.audience.clone(),
            },
            description: crdt
                .description
                .clone()
                .or_else(|| disk.description.clone()),
            extra: if crdt.extra.is_empty() {
                disk.extra.clone()
            } else {
                crdt.extra.clone()
            },
            modified_at: crdt.modified_at,
        }
    }

    /// Read frontmatter from a disk file and convert to FileMetadata.
    async fn read_disk_frontmatter(&self, path: &Path) -> Result<FileMetadata> {
        let content = self.fs.read_to_string(path).await?;
        let parsed = crate::frontmatter::parse_or_empty(&content)?;

        // Convert IndexMap<String, Value> to FileMetadata
        let fm = &parsed.frontmatter;

        // Helper to parse the frontmatter "updated" value into a timestamp (ms)
        fn parse_updated_value(value: &serde_yaml::Value) -> Option<i64> {
            if let Some(num) = value.as_i64() {
                return Some(num);
            }

            if let Some(num) = value.as_f64() {
                return Some(num as i64);
            }

            if let Some(raw) = value.as_str() {
                if let Ok(num) = raw.parse::<i64>() {
                    return Some(num);
                }

                if let Ok(parsed) = chrono::DateTime::parse_from_rfc3339(raw) {
                    return Some(parsed.timestamp_millis());
                }
            }

            None
        }

        // Extract filename from path
        let filename = path
            .file_name()
            .and_then(|n| n.to_str())
            .unwrap_or("")
            .to_string();

        Ok(FileMetadata {
            filename,
            title: fm.get("title").and_then(|v| v.as_str()).map(String::from),
            part_of: fm.get("part_of").and_then(|v| v.as_str()).map(String::from),
            contents: fm.get("contents").and_then(|v| {
                v.as_sequence().map(|seq| {
                    seq.iter()
                        .filter_map(|v| v.as_str().map(String::from))
                        .collect()
                })
            }),
            attachments: fm
                .get("attachments")
                .and_then(|v| {
                    v.as_sequence().map(|seq| {
                        seq.iter()
                            .filter_map(|v| {
                                // Handle both string and object formats
                                v.as_str().map(|s| super::types::BinaryRef {
                                    path: s.to_string(),
                                    source: "local".to_string(),
                                    hash: String::new(),
                                    mime_type: String::new(),
                                    size: 0,
                                    uploaded_at: None,
                                    deleted: false,
                                })
                            })
                            .collect()
                    })
                })
                .unwrap_or_default(),
            deleted: fm.get("deleted").and_then(|v| v.as_bool()).unwrap_or(false),
            audience: fm.get("audience").and_then(|v| {
                v.as_sequence().map(|seq| {
                    seq.iter()
                        .filter_map(|v| v.as_str().map(String::from))
                        .collect()
                })
            }),
            description: fm
                .get("description")
                .and_then(|v| v.as_str())
                .map(String::from),
            extra: std::collections::HashMap::new(), // TODO: Parse extra fields
            // Read 'updated' from frontmatter if present, otherwise use current time
            modified_at: fm
                .get("updated")
                .and_then(parse_updated_value)
                .unwrap_or_else(|| chrono::Utc::now().timestamp_millis()),
        })
    }

    /// Read body content from a disk file.
    async fn read_disk_body(&self, path: &Path) -> Result<String> {
        let content = self.fs.read_to_string(path).await?;
        let parsed = crate::frontmatter::parse_or_empty(&content)?;
        Ok(parsed.body)
    }

    /// Read body content for a canonical path.
    ///
    /// This is used to populate body CRDTs with disk content before sync.
    /// The path is converted to storage path using guest config if set.
    pub async fn read_body_content(&self, canonical_path: &str) -> Result<String> {
        let storage_path = self.get_storage_path(canonical_path);
        self.read_disk_body(&storage_path).await
    }

    /// Check if a file exists at the given canonical path.
    pub async fn file_exists(&self, canonical_path: &str) -> bool {
        let storage_path = self.get_storage_path(canonical_path);
        self.fs.exists(&storage_path).await
    }

    /// Check if the filesystem already has a root index file.
    ///
    /// Used to distinguish hosts (who already have files on disk) from guests
    /// (whose in-memory FS starts empty). Returns true if `index.md` or `.`
    /// exists at the workspace root.
    pub async fn fs_has_root(&self) -> bool {
        let root_path = self.get_storage_path("index.md");
        self.fs.exists(&root_path).await
    }
}

impl<FS: AsyncFileSystem> std::fmt::Debug for SyncHandler<FS> {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let gc = self.guest_config.read().unwrap();
        f.debug_struct("SyncHandler")
            .field("guest_config", &*gc)
            .field("has_event_callback", &self.event_callback.is_some())
            .finish()
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::crdt::types::BinaryRef;
    use crate::fs::{FileSystemEvent, InMemoryFileSystem, SyncToAsyncFs};
    use std::sync::{Arc, Mutex};

    // Use SyncToAsyncFs wrapper which provides AsyncFileSystem for any SyncFileSystem
    type TestFs = SyncToAsyncFs<crate::fs::RealFileSystem>;

    fn create_test_handler() -> SyncHandler<TestFs> {
        SyncHandler::new(SyncToAsyncFs::new(crate::fs::RealFileSystem))
    }

    #[test]
    fn test_get_storage_path_host() {
        let handler = create_test_handler();

        // Host mode - no prefix, no workspace root
        let path = handler.get_storage_path("notes/hello.md");
        assert_eq!(path, PathBuf::from("notes/hello.md"));
    }

    #[test]
    fn test_get_storage_path_with_workspace_root() {
        let handler = create_test_handler();

        // Set workspace root
        handler.set_workspace_root(PathBuf::from("/Users/test/diaryx"));

        // Path should be relative to workspace root
        let path = handler.get_storage_path("notes/hello.md");
        assert_eq!(path, PathBuf::from("/Users/test/diaryx/notes/hello.md"));

        // Nested paths should also work
        let path = handler.get_storage_path("Archive/2024/journal.md");
        assert_eq!(
            path,
            PathBuf::from("/Users/test/diaryx/Archive/2024/journal.md")
        );
    }

    #[test]
    fn test_get_storage_path_guest_opfs() {
        let handler = create_test_handler();

        handler.configure_guest(Some(GuestConfig {
            join_code: "ABC123".to_string(),
            uses_opfs: true,
        }));

        let path = handler.get_storage_path("notes/hello.md");
        assert_eq!(path, PathBuf::from("guest/ABC123/notes/hello.md"));
    }

    #[test]
    fn test_get_storage_path_guest_memory() {
        let handler = create_test_handler();

        handler.configure_guest(Some(GuestConfig {
            join_code: "ABC123".to_string(),
            uses_opfs: false, // In-memory, no prefix
        }));

        let path = handler.get_storage_path("notes/hello.md");
        assert_eq!(path, PathBuf::from("notes/hello.md"));
    }

    #[test]
    fn test_get_canonical_path_guest_opfs() {
        let handler = create_test_handler();

        handler.configure_guest(Some(GuestConfig {
            join_code: "ABC123".to_string(),
            uses_opfs: true,
        }));

        let canonical = handler.get_canonical_path("guest/ABC123/notes/hello.md");
        assert_eq!(canonical, "notes/hello.md");

        // Path without prefix should be returned as-is
        let canonical = handler.get_canonical_path("notes/hello.md");
        assert_eq!(canonical, "notes/hello.md");
    }

    #[test]
    fn test_merge_metadata_crdt_wins() {
        let handler = create_test_handler();

        let crdt = FileMetadata {
            title: Some("CRDT Title".to_string()),
            description: Some("CRDT Desc".to_string()),
            ..Default::default()
        };

        let disk = FileMetadata {
            title: Some("Disk Title".to_string()),
            description: Some("Disk Desc".to_string()),
            part_of: Some("parent.md".to_string()),
            ..Default::default()
        };

        let merged = handler.merge_metadata(&crdt, Some(&disk));

        // CRDT values should win
        assert_eq!(merged.title, Some("CRDT Title".to_string()));
        assert_eq!(merged.description, Some("CRDT Desc".to_string()));
        // Disk fallback for missing CRDT values
        assert_eq!(merged.part_of, Some("parent.md".to_string()));
    }

    #[test]
    fn test_merge_metadata_disk_fallback_for_nulls() {
        let handler = create_test_handler();

        let crdt = FileMetadata {
            title: None,
            description: None,
            contents: None,
            ..Default::default()
        };

        let disk = FileMetadata {
            title: Some("Disk Title".to_string()),
            description: Some("Disk Desc".to_string()),
            contents: Some(vec!["child.md".to_string()]),
            ..Default::default()
        };

        let merged = handler.merge_metadata(&crdt, Some(&disk));

        // Disk values should be used as fallback
        assert_eq!(merged.title, Some("Disk Title".to_string()));
        assert_eq!(merged.description, Some("Disk Desc".to_string()));
        assert_eq!(merged.contents, Some(vec!["child.md".to_string()]));
    }

    #[test]
    fn test_merge_metadata_explicit_empty_array_not_overwritten() {
        let handler = create_test_handler();

        let crdt = FileMetadata {
            contents: Some(vec![]), // Explicitly cleared array
            attachments: vec![],    // Empty attachments (falls back to disk)
            ..Default::default()
        };

        let disk = FileMetadata {
            contents: Some(vec!["child.md".to_string()]),
            attachments: vec![BinaryRef {
                path: "image.png".to_string(),
                source: "local".to_string(),
                hash: "abc".to_string(),
                mime_type: "image/png".to_string(),
                size: 1024,
                uploaded_at: None,
                deleted: false,
            }],
            ..Default::default()
        };

        let merged = handler.merge_metadata(&crdt, Some(&disk));

        // Some([]) is an explicit clearing - should NOT fall back to disk
        // This enables proper sync of deletions from remote peers
        assert_eq!(merged.contents, Some(vec![]));
        // Empty Vec attachments still falls back to disk (no explicit clearing mechanism)
        assert_eq!(merged.attachments.len(), 1);
    }

    #[test]
    fn test_logical_rename_event_emitted_when_both_paths_missing() {
        let fs = SyncToAsyncFs::new(InMemoryFileSystem::new());
        let mut handler = SyncHandler::new(fs);

        let events: Arc<Mutex<Vec<FileSystemEvent>>> = Arc::new(Mutex::new(Vec::new()));
        let events_for_callback = Arc::clone(&events);
        handler.set_event_callback(Box::new(move |event| {
            events_for_callback.lock().unwrap().push(event.clone());
        }));

        let old_path = "new-entry.md".to_string();
        let new_path = "wow.md".to_string();

        // Simulate metadata that still carries both paths during a rename transition.
        // The old path must be skipped once rename semantics are known.
        let files = vec![
            (
                old_path.clone(),
                FileMetadata::with_filename("new-entry.md".to_string(), Some("New Entry".into())),
            ),
            (
                new_path.clone(),
                FileMetadata::with_filename("wow.md".to_string(), Some("wow".into())),
            ),
        ];
        let renames = vec![(old_path.clone(), new_path.clone())];

        let synced_count = futures_lite::future::block_on(
            handler.handle_remote_metadata_update(files, renames, None, true),
        )
        .unwrap();

        assert_eq!(synced_count, 2, "rename + new path should be counted");
        assert!(
            !futures_lite::future::block_on(handler.file_exists(&old_path)),
            "old path must not be recreated"
        );
        assert!(
            futures_lite::future::block_on(handler.file_exists(&new_path)),
            "new path should be materialized from metadata"
        );

        let events = events.lock().unwrap();
        assert!(
            events.iter().any(|event| matches!(
                event,
                FileSystemEvent::FileRenamed { old_path, new_path }
                    if old_path == &PathBuf::from("new-entry.md")
                        && new_path == &PathBuf::from("wow.md")
            )),
            "expected FileRenamed event for logical rename"
        );
        assert!(
            !events.iter().any(|event| matches!(
                event,
                FileSystemEvent::FileCreated { path, .. }
                    if path == &PathBuf::from("new-entry.md")
            )),
            "old path should not emit FileCreated after rename detection"
        );
    }
}