stateset_embedded/
edi_documents.rs

1//! EDI document operations (trading-partner document tracking).
2
3use stateset_core::{
4    CreateEdiDocument, EdiAggregateSummary, EdiDocument, EdiDocumentFilter, EdiDocumentId,
5    EdiStatus, Result,
6};
7use stateset_db::{Database, DatabaseCapability};
8use std::sync::Arc;
9
10/// EDI document operations.
11pub struct EdiDocuments {
12    db: Arc<dyn Database>,
13}
14
15impl std::fmt::Debug for EdiDocuments {
16    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
17        f.debug_struct("EdiDocuments").finish_non_exhaustive()
18    }
19}
20
21impl EdiDocuments {
22    pub(crate) fn new(db: Arc<dyn Database>) -> Self {
23        Self { db }
24    }
25
26    /// Whether EDI documents are supported by the active backend.
27    #[must_use]
28    pub fn is_supported(&self) -> bool {
29        self.db.supports_capability(DatabaseCapability::EdiDocuments)
30    }
31
32    fn ensure(&self) -> Result<()> {
33        self.db.ensure_capability(DatabaseCapability::EdiDocuments)
34    }
35
36    /// Create / ingest an EDI document.
37    pub fn create(&self, input: CreateEdiDocument) -> Result<EdiDocument> {
38        self.ensure()?;
39        self.db.edi_documents().create(input)
40    }
41
42    /// Get a document by ID.
43    pub fn get(&self, id: EdiDocumentId) -> Result<Option<EdiDocument>> {
44        self.ensure()?;
45        self.db.edi_documents().get(id)
46    }
47
48    /// List documents with optional filtering.
49    pub fn list(&self, filter: EdiDocumentFilter) -> Result<Vec<EdiDocument>> {
50        self.ensure()?;
51        self.db.edi_documents().list(filter)
52    }
53
54    /// Update a document's status.
55    pub fn set_status(
56        &self,
57        id: EdiDocumentId,
58        status: EdiStatus,
59        error_message: Option<String>,
60    ) -> Result<EdiDocument> {
61        self.ensure()?;
62        self.db.edi_documents().set_status(id, status, error_message)
63    }
64
65    /// Aggregate summary across all documents.
66    pub fn summary(&self) -> Result<EdiAggregateSummary> {
67        self.ensure()?;
68        self.db.edi_documents().summary()
69    }
70}
stateset_embedded/edi_documents.rs

stateset_embedded/
edi_documents.rs
