Method pending_codex_compaction_summary_requests

src/global_db.rs:2878–2915

Returns Codex compaction summary nodes that still need an auxiliary Codex app-server summary.

(
        &self,
        session_id: Option<&str>,
        limit: usize,
    )

    /// Returns Codex compaction summary nodes that still need an auxiliary
    /// Codex app-server summary.
    pub async fn pending_codex_compaction_summary_requests(
        &self,
        session_id: Option<&str>,
        limit: usize,
    ) -> Result<Vec<PendingCodexCompactionSummary>, crate::sessions::lcm::LcmError> {
        let limit = limit.clamp(1, 100) as i64;
        let mut sql = String::from(
            "SELECT node_id, session_id
             FROM lcm_summary_nodes
             WHERE provider = 'codex'
               AND json_extract(metadata_json, '$.source') = 'codex_context_compacted'
               AND COALESCE(
                     json_extract(metadata_json, '$.tracedecay_summary_source'),
                     ''
                   ) <> 'codex_app_server'",
        );
        let mut query_params = vec![Value::Integer(limit)];
        if let Some(session_id) = session_id {
            sql.push_str(" AND session_id = ?2 ORDER BY depth DESC, created_at DESC LIMIT ?1");
            query_params.push(Value::Text(session_id.to_string()));
        } else {
            sql.push_str(" ORDER BY created_at DESC, depth DESC LIMIT ?1");
        }

        let mut rows = self.conn.query(&sql, query_params).await?;
        let mut pending = Vec::new();
        while let Some(row) = rows.next().await? {
            let node_id: String = row.get(0)?;
            let row_session_id: String = row.get(1)?;
            if let Some(request) = self
                .codex_compaction_summary_request_for_node(&node_id, &row_session_id)
                .await?
            {
                pending.push(PendingCodexCompactionSummary { node_id, request });
            }
        }
        Ok(pending)
    }

    async fn codex_compaction_summary_request_for_node(
        &self,