Method load_transcripts

crates/devsql/src/engine.rs:161–254

(&mut self)

    }

    fn load_transcripts(&mut self) -> Result<()> {
        self.conn.execute(
            "CREATE TABLE IF NOT EXISTS transcripts (
                rowid INTEGER PRIMARY KEY,
                type TEXT,
                content TEXT,
                tool_name TEXT,
                session_id TEXT,
                _source_file TEXT,
                _session_id TEXT,
                _project TEXT,
                _agent_id TEXT,
                timestamp TEXT,
                model TEXT,
                usage_input_tokens INTEGER,
                usage_output_tokens INTEGER,
                usage_cache_read_input_tokens INTEGER,
                usage_cache_creation_input_tokens INTEGER,
                usage_ephemeral_5m_input_tokens INTEGER,
                usage_ephemeral_1h_input_tokens INTEGER,
                usage_service_tier TEXT
            )",
            [],
        )?;

        let Some(config) = self.ccql_config() else {
            return Ok(());
        };

        let tx = self.conn.transaction()?;
        {
            let mut stmt = tx.prepare(
                "INSERT INTO transcripts (type, content, tool_name, session_id,
                    _source_file, _session_id, _project, _agent_id, timestamp,
                    model, usage_input_tokens, usage_output_tokens,
                    usage_cache_read_input_tokens, usage_cache_creation_input_tokens,
                    usage_ephemeral_5m_input_tokens, usage_ephemeral_1h_input_tokens,
                    usage_service_tier)
                 VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8, ?9, ?10, ?11, ?12, ?13, ?14, ?15, ?16, ?17)",
            )?;

            for file in discover_transcript_files(&config) {
                let content = match std::fs::read_to_string(&file.path) {
                    Ok(c) => c,
                    Err(_) => continue,
                };

                for line in content.lines() {
                    let Ok(entry) = serde_json::from_str::<Value>(line) else {
                        continue;
                    };

                    let msg_type = entry.get("type").and_then(|v| v.as_str()).unwrap_or("");
                    let msg_content = entry
                        .get("content")
                        .and_then(|v| v.as_str())
                        .or_else(|| entry.get("message").and_then(|v| v.as_str()))
                        .unwrap_or("");