opencrabs 0.3.54

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
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

//! Repository Module
//!
//! Repository pattern implementations for database access.

pub mod channel_message;
pub mod cron_job;
pub mod cron_job_run;
pub mod feedback_ledger;
pub mod file;
pub mod message;
pub mod pending_request;
pub mod plan;
pub mod project;
pub mod recent_paths;
pub mod session;
pub mod tool_execution;
pub mod usage_ledger;

pub use channel_message::{ChannelMessageRepository, TopicSummary};
pub use cron_job::CronJobRepository;
pub use cron_job_run::CronJobRunRepository;
pub use feedback_ledger::FeedbackLedgerRepository;
pub use file::FileRepository;
pub use message::MessageRepository;
pub use pending_request::PendingRequestRepository;
pub use plan::PlanRepository;
pub use project::ProjectRepository;
pub use recent_paths::RecentPathsRepository;
pub use session::{SessionListOptions, SessionRepository};
pub use tool_execution::ToolExecutionRepository;
pub use usage_ledger::UsageLedgerRepository;

use anyhow::Result;

/// Repository trait for common database operations
#[async_trait::async_trait]
pub trait Repository<T> {
    /// Find entity by ID
    async fn find_by_id(&self, id: &str) -> Result<Option<T>>;

    /// Create a new entity
    async fn create(&self, entity: &T) -> Result<()>;

    /// Update an existing entity
    async fn update(&self, entity: &T) -> Result<()>;

    /// Delete an entity by ID
    async fn delete(&self, id: &str) -> Result<()>;

    /// List all entities
    async fn list(&self) -> Result<Vec<T>>;
}