remem-ai 0.6.24

Local-first coding agent memory for Claude Code and OpenAI Codex
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

use anyhow::Result;
use rusqlite::{params, Connection};

use super::{WorkStream, WorkStreamStatus};

const SELECT_FIELDS: &str =
    "SELECT id, project, title, description, status, progress, next_action, blockers,
                                    created_at_epoch, updated_at_epoch, completed_at_epoch
                             FROM workstreams";

pub fn query_active_workstreams(conn: &Connection, project: &str) -> Result<Vec<WorkStream>> {
    let sql = format!(
        "{} WHERE status = 'active'
              AND merged_into_workstream_id IS NULL
              AND ((owner_scope = 'repo' AND owner_key = ?1)
                   OR (owner_scope = 'repo' AND target_project = ?1)
                   OR (owner_scope = 'workstream' AND target_project = ?1)
                   OR (owner_scope IS NULL AND project = ?1))
              ORDER BY updated_at_epoch DESC, id ASC",
        SELECT_FIELDS
    );
    let mut stmt = conn.prepare(&sql)?;
    let rows = stmt.query_map(params![project], map_workstream_row)?;
    crate::db::query::collect_rows(rows)
}

pub fn query_workstreams(
    conn: &Connection,
    project: &str,
    status_filter: Option<&str>,
) -> Result<Vec<WorkStream>> {
    let (sql, filter_val) = if let Some(status) = status_filter {
        (
            format!(
                "{} WHERE status = ?2
                      AND merged_into_workstream_id IS NULL
                      AND ((owner_scope = 'repo' AND owner_key = ?1)
                           OR (owner_scope = 'repo' AND target_project = ?1)
                           OR (owner_scope = 'workstream' AND target_project = ?1)
                           OR (owner_scope IS NULL AND project = ?1))
                      ORDER BY updated_at_epoch DESC, id ASC",
                SELECT_FIELDS
            ),
            Some(status.to_string()),
        )
    } else {
        (
            format!(
                "{} WHERE merged_into_workstream_id IS NULL
                      AND ((owner_scope = 'repo' AND owner_key = ?1)
                           OR (owner_scope = 'repo' AND target_project = ?1)
                           OR (owner_scope = 'workstream' AND target_project = ?1)
                           OR (owner_scope IS NULL AND project = ?1))
                      ORDER BY updated_at_epoch DESC, id ASC",
                SELECT_FIELDS
            ),
            None,
        )
    };

    let mut stmt = conn.prepare(&sql)?;
    let rows = if let Some(ref status) = filter_val {
        stmt.query_map(params![project, status], map_workstream_row)?
    } else {
        stmt.query_map(params![project], map_workstream_row)?
    };
    crate::db::query::collect_rows(rows)
}

pub(crate) fn map_workstream_row(row: &rusqlite::Row) -> rusqlite::Result<WorkStream> {
    let status_str: String = row.get(4)?;
    Ok(WorkStream {
        id: row.get(0)?,
        project: row.get(1)?,
        title: row.get(2)?,
        description: row.get(3)?,
        status: WorkStreamStatus::from_db(&status_str),
        progress: row.get(5)?,
        next_action: row.get(6)?,
        blockers: row.get(7)?,
        created_at_epoch: row.get(8)?,
        updated_at_epoch: row.get(9)?,
        completed_at_epoch: row.get(10)?,
    })
}