mnemara-core 0.6.0

use crate::error::Result;
use crate::model::{MemoryHistoricalState, MemoryQualityState, MemoryRecord};
use crate::query::{
    ChangefeedReport, ChangefeedRequest, CompactionReport, CompactionRequest, ExportRequest,
    GraphInspectionReport, GraphInspectionRequest, ImportReport, ImportRequest,
    IntegrityCheckReport, IntegrityCheckRequest, MaintenanceRunReport, MaintenanceRunRequest,
    RecallQuery, RecallResult, RepairReport, RepairRequest, SnapshotManifest, StoreStatsReport,
    StoreStatsRequest, SynthesisReport, SynthesisRequest, TimeTravelRecallRequest,
};
use async_trait::async_trait;
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
pub struct UpsertRequest {
    pub record: MemoryRecord,
    pub idempotency_key: Option<String>,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
pub struct BatchUpsertRequest {
    pub requests: Vec<UpsertRequest>,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct UpsertReceipt {
    pub record_id: String,
    pub deduplicated: bool,
    pub summary_refreshed: bool,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct DeleteRequest {
    pub tenant_id: String,
    pub namespace: String,
    pub record_id: String,
    pub hard_delete: bool,
    pub audit_reason: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct DeleteReceipt {
    pub record_id: String,
    pub tombstoned: bool,
    pub hard_deleted: bool,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct ArchiveRequest {
    pub tenant_id: String,
    pub namespace: String,
    pub record_id: String,
    pub dry_run: bool,
    pub audit_reason: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct ArchiveReceipt {
    pub record_id: String,
    pub previous_quality_state: MemoryQualityState,
    pub previous_historical_state: MemoryHistoricalState,
    pub quality_state: MemoryQualityState,
    pub historical_state: MemoryHistoricalState,
    pub changed: bool,
    pub dry_run: bool,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct SuppressRequest {
    pub tenant_id: String,
    pub namespace: String,
    pub record_id: String,
    pub dry_run: bool,
    pub audit_reason: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct SuppressReceipt {
    pub record_id: String,
    pub previous_quality_state: MemoryQualityState,
    pub previous_historical_state: MemoryHistoricalState,
    pub quality_state: MemoryQualityState,
    pub historical_state: MemoryHistoricalState,
    pub changed: bool,
    pub dry_run: bool,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct RecoverRequest {
    pub tenant_id: String,
    pub namespace: String,
    pub record_id: String,
    pub dry_run: bool,
    pub audit_reason: String,
    pub quality_state: MemoryQualityState,
    pub historical_state: Option<MemoryHistoricalState>,
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct RecoverReceipt {
    pub record_id: String,
    pub previous_quality_state: MemoryQualityState,
    pub previous_historical_state: MemoryHistoricalState,
    pub quality_state: MemoryQualityState,
    pub historical_state: MemoryHistoricalState,
    pub changed: bool,
    pub dry_run: bool,
}

#[async_trait]
pub trait MemoryStore: Send + Sync {
    fn backend_kind(&self) -> &'static str {
        "unknown"
    }

    async fn upsert(&self, request: UpsertRequest) -> Result<UpsertReceipt>;

    async fn batch_upsert(&self, request: BatchUpsertRequest) -> Result<Vec<UpsertReceipt>>;

    async fn recall(&self, query: RecallQuery) -> Result<RecallResult>;

    async fn recall_as_of(&self, request: TimeTravelRecallRequest) -> Result<RecallResult> {
        self.recall(request.query).await
    }

    async fn compact(&self, request: CompactionRequest) -> Result<CompactionReport>;

    async fn synthesize(&self, request: SynthesisRequest) -> Result<SynthesisReport>;

    async fn delete(&self, request: DeleteRequest) -> Result<DeleteReceipt>;

    async fn archive(&self, request: ArchiveRequest) -> Result<ArchiveReceipt>;

    async fn suppress(&self, request: SuppressRequest) -> Result<SuppressReceipt>;

    async fn recover(&self, request: RecoverRequest) -> Result<RecoverReceipt>;

    async fn snapshot(&self) -> Result<SnapshotManifest>;

    async fn stats(&self, request: StoreStatsRequest) -> Result<StoreStatsReport>;

    async fn inspect_graph(&self, request: GraphInspectionRequest)
    -> Result<GraphInspectionReport>;

    async fn changefeed(&self, _request: ChangefeedRequest) -> Result<ChangefeedReport> {
        Err(crate::Error::Unsupported(
            "changefeed is not supported by this memory store".to_string(),
        ))
    }

    async fn run_maintenance(
        &self,
        request: MaintenanceRunRequest,
    ) -> Result<MaintenanceRunReport> {
        let integrity_before = if request.run_integrity_check {
            Some(
                self.integrity_check(IntegrityCheckRequest {
                    tenant_id: request.tenant_id.clone(),
                    namespace: request.namespace.clone(),
                })
                .await?,
            )
        } else {
            None
        };

        let repair = if request.run_repair {
            Some(
                self.repair(RepairRequest {
                    tenant_id: request.tenant_id.clone(),
                    namespace: request.namespace.clone(),
                    dry_run: request.dry_run,
                    reason: request.reason.clone(),
                    remove_stale_idempotency_keys: request.remove_stale_idempotency_keys,
                    rebuild_missing_idempotency_keys: request.rebuild_missing_idempotency_keys,
                })
                .await?,
            )
        } else {
            None
        };

        let compaction = if request.run_compaction {
            if let Some(tenant_id) = &request.tenant_id {
                Some(
                    self.compact(crate::query::CompactionRequest {
                        tenant_id: tenant_id.clone(),
                        namespace: request.namespace.clone(),
                        dry_run: request.dry_run,
                        reason: request.reason.clone(),
                    })
                    .await?,
                )
            } else {
                None
            }
        } else {
            None
        };

        let synthesis = if request.run_synthesis {
            if let Some(tenant_id) = &request.tenant_id {
                Some(
                    self.synthesize(crate::query::SynthesisRequest {
                        tenant_id: tenant_id.clone(),
                        namespace: request.namespace.clone(),
                        dry_run: request.dry_run,
                        reason: request.reason.clone(),
                        ..crate::query::SynthesisRequest::default()
                    })
                    .await?,
                )
            } else {
                None
            }
        } else {
            None
        };

        let integrity_after = if request.run_integrity_check {
            Some(
                self.integrity_check(IntegrityCheckRequest {
                    tenant_id: request.tenant_id.clone(),
                    namespace: request.namespace.clone(),
                })
                .await?,
            )
        } else {
            None
        };

        Ok(MaintenanceRunReport {
            dry_run: request.dry_run,
            integrity_before,
            repair,
            compaction,
            synthesis,
            integrity_after,
        })
    }

    async fn integrity_check(&self, request: IntegrityCheckRequest)
    -> Result<IntegrityCheckReport>;

    async fn repair(&self, request: RepairRequest) -> Result<RepairReport>;

    async fn export(&self, request: ExportRequest) -> Result<crate::query::PortableStorePackage>;

    async fn import(&self, request: ImportRequest) -> Result<ImportReport>;
}