paceflow 0.2.4

Local-first CLI that turns AI coding session history and git metadata into engineering analytics.
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

pub mod claude;
pub mod codex;
pub mod cursor;
pub mod opencode;
pub mod utils;

use anyhow::Result;
use rusqlite::Connection;
use std::path::PathBuf;

use crate::ingest_progress::IngestProgressObserver;

#[derive(Debug, Clone)]
pub enum ProviderSessionPlan {
    Claude { session_files: Vec<PathBuf> },
    Codex { session_files: Vec<PathBuf> },
    Cursor { composer_keys: Vec<String> },
    Opencode { db_paths: Vec<PathBuf> },
}

impl ProviderSessionPlan {
    pub fn item_count(&self) -> usize {
        match self {
            Self::Claude { session_files } => session_files.len(),
            Self::Codex { session_files } => session_files.len(),
            Self::Cursor { composer_keys } => composer_keys.len(),
            Self::Opencode { db_paths } => db_paths.len(),
        }
    }
}

#[derive(Debug, Clone, Copy)]
pub enum Provider {
    Claude,
    Codex,
    Cursor,
    Opencode,
}

impl Provider {
    pub fn name(&self) -> &str {
        match self {
            Self::Claude => "claude",
            Self::Codex => "codex",
            Self::Cursor => "cursor",
            Self::Opencode => "opencode",
        }
    }

    pub fn plan_session_work(&self) -> Result<ProviderSessionPlan> {
        match self {
            Self::Claude => Ok(ProviderSessionPlan::Claude {
                session_files: claude::plan_session_files()?,
            }),
            Self::Codex => Ok(ProviderSessionPlan::Codex {
                session_files: codex::plan_session_files()?,
            }),
            Self::Cursor => Ok(ProviderSessionPlan::Cursor {
                composer_keys: cursor::plan_composer_rows()?,
            }),
            Self::Opencode => Ok(ProviderSessionPlan::Opencode {
                db_paths: opencode::plan_db_files()?,
            }),
        }
    }

    /// Ingest all sessions from this provider into `db`. Returns number of fact rows written.
    pub fn ingest(
        &self,
        db: &Connection,
        plan: &ProviderSessionPlan,
        verbose: bool,
        progress: Option<&mut dyn IngestProgressObserver>,
    ) -> Result<usize> {
        match (self, plan) {
            (Self::Claude, ProviderSessionPlan::Claude { session_files }) => {
                claude::ingest_planned_sessions(db, session_files, verbose, progress)
            }
            (Self::Codex, ProviderSessionPlan::Codex { session_files }) => {
                codex::ingest_planned_sessions(db, session_files, verbose, progress)
            }
            (Self::Cursor, ProviderSessionPlan::Cursor { composer_keys }) => {
                cursor::ingest_planned_sessions(db, composer_keys, verbose, progress)
            }
            (Self::Opencode, ProviderSessionPlan::Opencode { db_paths }) => {
                opencode::ingest_planned_sessions(db, db_paths, verbose, progress)
            }
            _ => anyhow::bail!("provider plan mismatch for {}", self.name()),
        }
    }
}

/// Central registry — add one line here when a new provider is implemented.
pub fn all_providers() -> Vec<Provider> {
    vec![
        Provider::Claude,
        Provider::Codex,
        Provider::Cursor,
        Provider::Opencode,
    ]
}