omk 0.5.0

A Rust runtime for Kimi CLI. Turns prompts into proof-backed engineering runs with gates, worktrees, and replay.
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

use anyhow::Result;

use super::types::SessionCost;

#[allow(async_fn_in_trait)]
/// Trait for cost storage backends.
///
/// Implementations may be file-based, in-memory, or remote.
/// The trait is object-safe-free; consumers use generics (`CostTracker<S>`).
pub trait CostSink {
    /// Persist the full list of session costs.
    async fn save(&self, costs: &[SessionCost]) -> Result<()>;

    /// Load the full list of session costs.
    async fn load(&self) -> Result<Vec<SessionCost>>;
}

/// In-memory cost sink for unit tests.
///
/// Stores data in a `tokio::sync::Mutex<Vec<SessionCost>>` so it can be shared
/// across async tasks without blocking the executor.
#[derive(Debug)]
pub struct InMemoryCostSink {
    inner: tokio::sync::Mutex<Vec<SessionCost>>,
}

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

impl InMemoryCostSink {
    pub fn new() -> Self {
        Self {
            inner: tokio::sync::Mutex::new(Vec::new()),
        }
    }
}

impl CostSink for InMemoryCostSink {
    async fn save(&self, costs: &[SessionCost]) -> Result<()> {
        let mut guard = self.inner.lock().await;
        guard.clear();
        guard.extend_from_slice(costs);
        Ok(())
    }

    async fn load(&self) -> Result<Vec<SessionCost>> {
        let guard = self.inner.lock().await;
        Ok(guard.clone())
    }
}