Method load_jhistory

crates/devsql/src/engine.rs:347–406

(&mut self)

    }

    fn load_jhistory(&mut self) -> Result<()> {
        self.conn.execute(
            "CREATE TABLE IF NOT EXISTS jhistory (
                rowid INTEGER PRIMARY KEY,
                session_id TEXT,
                ts INTEGER,
                text TEXT,
                display TEXT,
                timestamp INTEGER
            )",
            [],
        )?;
        self.conn.execute(
            "CREATE VIEW IF NOT EXISTS codex_history AS SELECT * FROM jhistory",
            [],
        )?;

        let jhistory_path = self.codex_data_dir.join("history.jsonl");
        if !jhistory_path.exists() {
            return Ok(());
        }

        let content = std::fs::read_to_string(&jhistory_path)?;
        for line in content.lines() {
            if let Ok(entry) = serde_json::from_str::<Value>(line) {
                let text = entry
                    .get("text")
                    .or_else(|| entry.get("display"))
                    .and_then(json_value_as_string)
                    .unwrap_or_default();

                let session_id = entry
                    .get("session_id")
                    .or_else(|| entry.get("sessionId"))
                    .and_then(json_value_as_string)
                    .unwrap_or_default();

                let ts = entry
                    .get("ts")
                    .and_then(json_number_as_i64)
                    .or_else(|| {
                        entry
                            .get("timestamp")
                            .and_then(json_number_as_i64)
                            .map(normalize_ts_seconds)
                    })
                    .unwrap_or(0);

                let timestamp = ts.saturating_mul(1000);

                self.conn.execute(
                    "INSERT INTO jhistory (session_id, ts, text, display, timestamp)
                     VALUES (?1, ?2, ?3, ?4, ?5)",
                    params![session_id, ts, text.clone(), text, timestamp],
                )?;
            }
        }