cognitum-one 0.2.1

//! Vector-store resource — `/api/v1/store/*`.

use crate::error::Error;
use crate::seed::client::SeedClient;
use crate::seed::config::CallOptions;
use crate::seed::models::{StoreIngest, StoreIngestAck, StoreQuery, StoreQueryResult, StoreStatus};

/// Vector store endpoints.
pub struct StoreResource<'c> {
    pub(crate) client: &'c SeedClient,
}

impl<'c> StoreResource<'c> {
    /// `GET /api/v1/store/status` (allowlisted read).
    pub async fn status(&self) -> Result<StoreStatus, Error> {
        self.client.request_get("/store/status").await
    }

    /// [`Self::status`] with per-call [`CallOptions`] overrides.
    pub async fn status_with(&self, opts: CallOptions) -> Result<StoreStatus, Error> {
        self.client.request_get_opts("/store/status", &opts).await
    }

    /// `POST /api/v1/store/query` — read-with-body. Attested idempotent
    /// per ADR-0005 §"Caller-attested idempotency": safe to retry.
    pub async fn query(&self, req: StoreQuery) -> Result<StoreQueryResult, Error> {
        self.client.request_post("/store/query", &req, true).await
    }

    /// [`Self::query`] with per-call [`CallOptions`] overrides.
    pub async fn query_with(
        &self,
        req: StoreQuery,
        opts: CallOptions,
    ) -> Result<StoreQueryResult, Error> {
        self.client
            .request_post_opts("/store/query", &req, true, &opts)
            .await
    }

    /// `POST /api/v1/store/ingest` — mutating; NOT idempotent.
    pub async fn ingest(&self, req: StoreIngest) -> Result<StoreIngestAck, Error> {
        self.client.request_post("/store/ingest", &req, false).await
    }

    /// [`Self::ingest`] with per-call [`CallOptions`] overrides.
    pub async fn ingest_with(
        &self,
        req: StoreIngest,
        opts: CallOptions,
    ) -> Result<StoreIngestAck, Error> {
        self.client
            .request_post_opts("/store/ingest", &req, false, &opts)
            .await
    }
}