adk-payments 0.6.0

Protocol-neutral agentic commerce and payment orchestration for ADK-Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use std::sync::Arc;

use adk_core::identity::AdkIdentity;
use adk_core::{Content, Result};
use adk_memory::{MemoryEntry, MemoryService};

use crate::domain::SafeTransactionSummary;
use crate::guardrail::redact_payment_content;

/// Indexes safe payment summaries into semantic memory.
pub struct PaymentMemoryIndex {
    memory_service: Arc<dyn MemoryService>,
}

impl PaymentMemoryIndex {
    /// Creates a new safe-summary memory indexer.
    #[must_use]
    pub fn new(memory_service: Arc<dyn MemoryService>) -> Self {
        Self { memory_service }
    }

    /// Indexes one safe transaction summary under a transaction-scoped memory session key.
    ///
    /// # Errors
    ///
    /// Returns an error if the underlying memory service rejects the write.
    pub async fn index_summary(
        &self,
        identity: &AdkIdentity,
        summary: &SafeTransactionSummary,
    ) -> Result<()> {
        let session_key = format!(
            "payments:{}:{}",
            identity.session_id.as_ref(),
            summary.transaction_id.as_str()
        );
        let entry = MemoryEntry {
            content: redact_payment_content(
                &Content::new("system").with_text(summary.transcript_text()),
            ),
            author: "adk-payments".to_string(),
            timestamp: summary.updated_at,
        };

        self.memory_service
            .add_session(
                identity.app_name.as_ref(),
                identity.user_id.as_ref(),
                &session_key,
                vec![entry],
            )
            .await
    }
}