theater 0.3.14

use anyhow::{Context, Result};
use serde::{Deserialize, Serialize};
use sha1::{Digest, Sha1};
use std::fs as std_fs;
use std::future::Future;
use std::io::Write as StdWrite;
use std::path::{Path, PathBuf};
use tokio::fs;
use tokio::io::AsyncWriteExt;
use tracing::debug;
use wasmtime::component::{ComponentType, Lift, Lower};

use crate::utils;

/// A reference to content in the store
#[derive(Clone, Debug, PartialEq, Eq, Hash, Serialize, Deserialize, ComponentType, Lift, Lower)]
#[component(record)]
pub struct ContentRef {
    hash: String,
}

// implement display for ContentRef
impl std::fmt::Display for ContentRef {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        write!(f, "{}", self.hash)
    }
}

impl ContentRef {
    /// Create a new ContentRef from a hash
    pub fn new(hash: String) -> Self {
        Self { hash }
    }

    #[allow(clippy::should_implement_trait)]
    pub fn from_str(hash: &str) -> Self {
        Self::new(hash.to_string())
    }

    /// Get the hash as a string
    pub fn hash(&self) -> &str {
        &self.hash
    }

    /// Create a ContentRef by hashing content
    pub fn from_content(content: &[u8]) -> Self {
        let mut hasher = Sha1::new();
        hasher.update(content);
        let hash = hasher.finalize();
        let hash_str = hex::encode(hash);
        Self { hash: hash_str }
    }

    /// Convert to a path for storage within a base directory
    pub fn to_path(&self, base_path: &Path) -> PathBuf {
        base_path.join("data").join(&self.hash)
    }

    /// Check if content exists in the store
    pub async fn exists(&self, base_path: &Path) -> bool {
        let path = self.to_path(base_path);
        fs::try_exists(&path).await.unwrap_or(false)
    }

    /// Check if content exists in the store (synchronous version)
    pub fn exists_sync(&self, base_path: &Path) -> bool {
        let path = self.to_path(base_path);
        std_fs::exists(&path).unwrap_or(false)
    }

    /// Store content in the filesystem and ensure it exists
    pub async fn store_content(&self, base_path: &Path, content: &[u8]) -> Result<()> {
        let path = self.to_path(base_path);

        // Check if content already exists
        if !fs::try_exists(&path).await.unwrap_or(false) {
            // Create parent directories if they don't exist
            if let Some(parent) = path.parent() {
                fs::create_dir_all(parent)
                    .await
                    .context("Failed to create parent directories")?;
            }

            // Write content to file
            let mut file = fs::File::create(&path)
                .await
                .context("Failed to create content file")?;
            file.write_all(content)
                .await
                .context("Failed to write content")?;
            debug!("Stored content with hash: {}", self.hash());
        } else {
            debug!("Content already exists: {}", self.hash());
        }

        Ok(())
    }

    /// Store content in the filesystem synchronously
    pub fn store_content_sync(&self, base_path: &Path, content: &[u8]) -> Result<()> {
        let path = self.to_path(base_path);

        // Check if content already exists
        if !std_fs::exists(&path).unwrap_or(false) {
            // Create parent directories if they don't exist
            if let Some(parent) = path.parent() {
                std_fs::create_dir_all(parent).context("Failed to create parent directories")?;
            }

            // Write content to file synchronously
            let mut file = std_fs::File::create(&path).context("Failed to create content file")?;
            file.write_all(content).context("Failed to write content")?;
            debug!("Stored content with hash: {}", self.hash());
        } else {
            debug!("Content already exists: {}", self.hash());
        }

        Ok(())
    }

    /// Retrieve content from the filesystem
    pub async fn get_content(&self, base_path: &Path) -> Result<Vec<u8>> {
        debug!("Base path: {:?}", base_path);
        let path = self.to_path(base_path);
        debug!("Getting content at path: {:?}", path);
        fs::read(&path)
            .await
            .with_context(|| format!("Failed to read content at path: {:?}", path))
    }
}

/// A label that references content in the store
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct Label {
    name: String,
}

impl Label {
    /// Create a new label
    pub fn new(name: String) -> Self {
        Self { name }
    }

    /// Create a label from a string
    #[allow(clippy::should_implement_trait)]
    pub fn from_str(name: &str) -> Self {
        Self::new(name.to_string())
    }

    /// Get the label name
    pub fn name(&self) -> &str {
        &self.name
    }

    /// Convert to a path for storage within a base directory
    pub fn to_path(&self, base_path: &Path) -> PathBuf {
        base_path.join("labels").join(&self.name)
    }

    /// Check if the label exists
    pub async fn exists(&self, base_path: &Path) -> bool {
        let path = self.to_path(base_path);
        fs::try_exists(&path).await.unwrap_or(false)
    }

    /// Get the ContentRef associated with this label, if any
    pub async fn get_content_ref(&self, base_path: &Path) -> Result<Option<ContentRef>> {
        let path = self.to_path(base_path);

        // If label doesn't exist, return None
        if !fs::try_exists(&path).await.unwrap_or(false) {
            return Ok(None);
        }

        // Read and parse label file
        let content = fs::read_to_string(&path)
            .await
            .context("Failed to read label file")?;

        let content_hash = content.trim();
        if content_hash.is_empty() {
            return Ok(None);
        }

        // Return a single content reference
        let content_ref = ContentRef::new(content_hash.to_string());
        Ok(Some(content_ref))
    }

    /// Set the ContentRef for this label
    pub async fn set_content_ref(&self, base_path: &Path, content_ref: &ContentRef) -> Result<()> {
        let path = self.to_path(base_path);

        // Create parent directories if they don't exist
        if let Some(parent) = path.parent() {
            fs::create_dir_all(parent)
                .await
                .context("Failed to create label parent directories")?;
        }

        // Write the content ref hash to the label file
        fs::write(&path, content_ref.hash())
            .await
            .context("Failed to write label file")?;

        debug!(
            "Set content {} for label '{}'",
            content_ref.hash(),
            self.name
        );

        Ok(())
    }

    /// Remove this label
    pub async fn remove(&self, base_path: &Path) -> Result<()> {
        let path = self.to_path(base_path);

        // If label doesn't exist, do nothing
        if !fs::try_exists(&path).await.unwrap_or(false) {
            debug!("Label does not exist: {}", self.name);
            return Ok(());
        }

        // Remove label file
        fs::remove_file(&path)
            .await
            .context("Failed to remove label file")?;

        debug!("Removed label: {}", self.name);
        Ok(())
    }
}

// display for Label
impl std::fmt::Display for Label {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        write!(f, "{}", self.name)
    }
}

#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub struct ContentStore {
    pub id: String,
    /// Custom base path for the store. If None, uses the default theater home location.
    #[serde(skip)]
    custom_base_path: Option<PathBuf>,
}

impl Default for ContentStore {
    fn default() -> Self {
        Self::new()
    }
}

impl ContentStore {
    /// Create a new store with the default base path
    pub fn new() -> Self {
        let id = uuid::Uuid::new_v4().to_string();
        Self {
            id,
            custom_base_path: None,
        }
    }

    /// Create a new store with a custom base path
    pub fn new_with_base_path(base_path: PathBuf) -> Self {
        let id = uuid::Uuid::new_v4().to_string();
        Self {
            id,
            custom_base_path: Some(base_path),
        }
    }

    pub fn new_named_store(id: &str) -> Self {
        ContentStore::from_id(id)
    }

    pub fn from_id(id: &str) -> Self {
        Self {
            id: id.to_string(),
            custom_base_path: None,
        }
    }

    /// Create a store from ID with a custom base path
    pub fn from_id_with_base_path(id: &str, base_path: PathBuf) -> Self {
        Self {
            id: id.to_string(),
            custom_base_path: Some(base_path),
        }
    }

    pub fn id(&self) -> &str {
        &self.id
    }

    pub fn base_path(&self) -> PathBuf {
        if let Some(ref custom) = self.custom_base_path {
            custom.join(&self.id)
        } else {
            let theater_home = utils::get_theater_home();
            PathBuf::from(&theater_home).join("store").join(&self.id)
        }
    }

    /// Store content and return its ContentRef
    pub async fn store(&self, content: Vec<u8>) -> ContentRef {
        let content_ref = ContentRef::from_content(&content);
        let _ = content_ref.store_content(&self.base_path(), &content).await;
        content_ref
    }

    /// Store content synchronously and return its ContentRef
    pub fn store_sync(&self, content: Vec<u8>) -> Result<ContentRef> {
        let content_ref = ContentRef::from_content(&content);
        content_ref.store_content_sync(&self.base_path(), &content)?;
        Ok(content_ref)
    }

    /// Retrieve content by its reference
    pub async fn get(&self, content_ref: &ContentRef) -> Result<Vec<u8>> {
        debug!("Getting content with hash: {}", content_ref.hash());
        content_ref.get_content(&self.base_path()).await
    }

    /// Check if content exists
    pub async fn exists(&self, content_ref: &ContentRef) -> bool {
        content_ref.exists(&self.base_path()).await
    }

    /// Attach a label to content (replaces any existing content at that label)
    pub async fn label(&self, label: &Label, content_ref: &ContentRef) -> Result<()> {
        // Ensure content exists before labeling
        if !content_ref.exists(&self.base_path()).await {
            return Err(anyhow::anyhow!(
                "Content does not exist: {}",
                content_ref.hash()
            ));
        }

        label.set_content_ref(&self.base_path(), content_ref).await
    }

    pub async fn replace_content_at_label(
        &self,
        label: &Label,
        content: Vec<u8>,
    ) -> Result<ContentRef> {
        let content_ref = ContentRef::from_content(&content);

        // Store the content
        content_ref
            .store_content(&self.base_path(), &content)
            .await?;

        // Update the label
        label
            .set_content_ref(&self.base_path(), &content_ref)
            .await?;

        debug!("Replaced content in label '{}'", label);

        Ok(content_ref)
    }

    pub async fn replace_at_label(&self, label: &Label, content_ref: &ContentRef) -> Result<()> {
        // Ensure content exists before labeling
        if !content_ref.exists(&self.base_path()).await {
            return Err(anyhow::anyhow!(
                "Content does not exist: {}",
                content_ref.hash()
            ));
        }

        label
            .set_content_ref(&self.base_path(), content_ref)
            .await?;

        debug!("Replaced content in label '{}'", label);

        Ok(())
    }

    /// Get content reference by label
    pub async fn get_by_label(&self, label: &Label) -> Result<Option<ContentRef>> {
        label.get_content_ref(&self.base_path()).await
    }

    /// Get content by label
    pub async fn get_content_by_label(&self, label: &Label) -> Result<Option<Vec<u8>>> {
        if let Some(content_ref) = label.get_content_ref(&self.base_path()).await? {
            let content = content_ref.get_content(&self.base_path()).await?;
            Ok(Some(content))
        } else {
            Ok(None)
        }
    }

    pub async fn store_at_label(&self, label: &Label, content: Vec<u8>) -> Result<ContentRef> {
        let content_ref = ContentRef::from_content(&content);

        // Store the content
        content_ref
            .store_content(&self.base_path(), &content)
            .await?;

        // Create and set the label
        label
            .set_content_ref(&self.base_path(), &content_ref)
            .await?;

        Ok(content_ref)
    }

    /// Remove a label
    pub async fn remove_label(&self, label: &Label) -> Result<()> {
        label.remove(&self.base_path()).await
    }

    /// Remove a specific content reference from a label
    /// If the content reference matches the one at the label, the label is removed
    pub async fn remove_from_label(&self, label: &Label, content_ref: &ContentRef) -> Result<()> {
        // If label doesn't exist, do nothing
        if !label.exists(&self.base_path()).await {
            debug!("Label does not exist: {}", label);
            return Ok(());
        }

        // Get the current content ref from the label
        if let Some(current_ref) = label.get_content_ref(&self.base_path()).await? {
            // If the current content ref matches the one we want to remove, remove the label
            if current_ref.hash() == content_ref.hash() {
                label.remove(&self.base_path()).await?;
                debug!(
                    "Removed label '{}' that pointed to content {}",
                    label,
                    content_ref.hash()
                );
            } else {
                debug!(
                    "Label '{}' does not point to content {}",
                    label,
                    content_ref.hash()
                );
            }
        }

        Ok(())
    }

    /// List all labels recursively, including nested directories
    /// Returns paths relative to the labels directory
    pub async fn list_labels(&self) -> Result<Vec<String>> {
        let labels_dir = self.base_path().join("labels");

        // Ensure labels directory exists
        if !fs::try_exists(&labels_dir).await.unwrap_or(false) {
            return Ok(Vec::new());
        }

        let mut result = Vec::new();
        self.collect_labels_recursive(&labels_dir, &labels_dir, &mut result)
            .await?;

        Ok(result)
    }

    /// Helper method to recursively collect labels
    #[allow(clippy::only_used_in_recursion)]
    fn collect_labels_recursive<'a>(
        &'a self,
        base_path: &'a Path,
        current_path: &'a Path,
        result: &'a mut Vec<String>,
    ) -> std::pin::Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>> {
        Box::pin(async move {
            let mut entries = fs::read_dir(current_path)
                .await
                .with_context(|| format!("Failed to read directory: {:?}", current_path))?;

            while let Some(entry) = entries.next_entry().await? {
                let path = entry.path();

                if let Ok(file_type) = entry.file_type().await {
                    if file_type.is_file() {
                        // It's a file/label, so add it to our results
                        if let Ok(rel_path) = path.strip_prefix(base_path) {
                            if let Some(rel_path_str) = rel_path.to_str() {
                                result.push(rel_path_str.to_string());
                            }
                        }
                    } else if file_type.is_dir() {
                        // It's a directory, so recursively collect labels from it
                        self.collect_labels_recursive(base_path, &path, result)
                            .await?;
                    }
                }
            }

            Ok(())
        })
    }

    /// List all content references in the store
    pub async fn list_all_content(&self) -> Result<Vec<ContentRef>> {
        let data_dir = self.base_path().join("data");

        // Ensure data directory exists
        if !fs::try_exists(&data_dir).await.unwrap_or(false) {
            return Ok(Vec::new());
        }

        let mut entries = fs::read_dir(&data_dir)
            .await
            .context("Failed to read data directory")?;

        let mut refs = Vec::new();
        while let Some(entry) = entries.next_entry().await? {
            if let Ok(file_type) = entry.file_type().await {
                if file_type.is_file() {
                    if let Some(name) = entry.file_name().to_str() {
                        refs.push(ContentRef::new(name.to_string()));
                    }
                }
            }
        }

        Ok(refs)
    }

    /// Calculate total size of all content in the store
    pub async fn calculate_total_size(&self) -> Result<u64> {
        let refs = self.list_all_content().await?;
        let mut total_size = 0;

        for content_ref in refs {
            let path = content_ref.to_path(&self.base_path());
            if let Ok(metadata) = fs::metadata(&path).await {
                total_size += metadata.len();
            }
        }

        Ok(total_size)
    }

    pub async fn label_exists(&self, label: Label) -> Result<bool> {
        let path = label.to_path(&self.base_path());
        debug!("Checking if label exists at path: {:?}", path);
        if fs::try_exists(&path).await.unwrap_or(false) {
            Ok(true)
        } else {
            Ok(false)
        }
    }
}