rho-coding-agent 1.48.0

A lightweight agent harness inspired by Pi
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

//! Cross-project session listing against the global session index.
//!
//! Reconciliation mechanics live in the index module; this module owns the
//! canonical global summary queries.

use std::path::Path;

use rusqlite::params;

use super::{open_index, reconcile_all_workspaces, summary_from_row, SessionSummary};

/// Lists sessions across every workspace under `session_root`.
///
/// Reconciles the global index against on-disk units in one pass, then reads
/// summaries from SQLite. This avoids the per-workspace sync loop that made
/// cross-project listing scale with workspace count instead of change count.
pub(in crate::session) fn list_all_sessions(
    session_root: &Path,
) -> anyhow::Result<Vec<SessionSummary>> {
    reconcile_all_workspaces(session_root)?;
    let connection = open_index(session_root)?;
    let connection = connection
        .lock()
        .expect("session index connection poisoned");
    let mut statement = connection.prepare(
        "select id, path, cwd, created_at, updated_at, message_count,
                title, first_user_message, last_user_message
         from (
             select id, path, cwd, created_at, updated_at, message_count,
                    title, first_user_message, last_user_message,
                    row_number() over (
                        partition by path
                        order by updated_at desc, cwd asc
                    ) as rn
             from sessions
         )
         where rn = 1
         order by updated_at desc, created_at desc, id asc",
    )?;
    let rows = statement.query_map([], summary_from_row)?;
    Ok(rows
        .collect::<rusqlite::Result<Vec<_>>>()?
        .into_iter()
        .filter(|summary| summary.path.exists())
        .collect())
}

/// Returns index summaries whose id starts with `id_prefix` (any workspace).
///
/// Does not scan the filesystem. Callers that need brand-new unindexed units
/// should use [`list_all_sessions`] or a workspace list.
pub(in crate::session) fn summaries_matching_id_prefix(
    session_root: &Path,
    id_prefix: &str,
) -> anyhow::Result<Vec<SessionSummary>> {
    let connection = open_index(session_root)?;
    let connection = connection
        .lock()
        .expect("session index connection poisoned");
    let mut statement = connection.prepare(
        "select id, path, cwd, created_at, updated_at, message_count,
                title, first_user_message, last_user_message
         from (
             select id, path, cwd, created_at, updated_at, message_count,
                    title, first_user_message, last_user_message,
                    row_number() over (
                        partition by path
                        order by updated_at desc, cwd asc
                    ) as rn
             from sessions
             where substr(id, 1, length(?1)) = ?1
         )
         where rn = 1
         order by updated_at desc, created_at desc, id asc",
    )?;
    let rows = statement.query_map(params![id_prefix], summary_from_row)?;
    Ok(rows
        .collect::<rusqlite::Result<Vec<_>>>()?
        .into_iter()
        .filter(|summary| summary.path.exists())
        .collect())
}