Method observe

crates/ccql/src/datasources/transcript.rs:197–259

Fold one transcript record into the aggregate.

(&mut self, json: &serde_json::Value)

impl SessionAggregate {
    /// Fold one transcript record into the aggregate.
    pub fn observe(&mut self, json: &serde_json::Value) {
        let get_str = |key: &str| json.get(key).and_then(|v| v.as_str()).map(String::from);

        if let Some(ts) = get_str("timestamp") {
            // ISO 8601 timestamps compare correctly as strings
            if self
                .first_timestamp
                .as_deref()
                .is_none_or(|f| ts.as_str() < f)
            {
                self.first_timestamp = Some(ts.clone());
            }
            if self
                .last_timestamp
                .as_deref()
                .is_none_or(|l| ts.as_str() > l)
            {
                self.last_timestamp = Some(ts);
            }
        }
        if self.cwd.is_none() {
            self.cwd = get_str("cwd");
        }
        if self.git_branch.is_none() {
            self.git_branch = get_str("gitBranch");
        }
        if let Some(version) = get_str("version") {
            self.version = Some(version); // last seen wins
        }

        match json.get("type").and_then(|t| t.as_str()) {
            Some("user") => self.user_message_count += 1,
            Some("assistant") => {
                self.assistant_message_count += 1;
                if let Some(usage) = json.get("message").and_then(|m| m.get("usage")) {
                    let tok = |key: &str| {
                        usage
                            .get(key)
                            .and_then(serde_json::Value::as_i64)
                            .unwrap_or(0)
                    };
                    self.total_input_tokens += tok("input_tokens");
                    self.total_output_tokens += tok("output_tokens");
                    self.total_cache_read_input_tokens += tok("cache_read_input_tokens");
                    self.total_cache_creation_input_tokens += tok("cache_creation_input_tokens");
                }
            }
            Some("ai-title") => {
                if let Some(title) = get_str("aiTitle") {
                    self.title = Some(title);
                }
            }
            Some("pr-link") => {
                if let Some(url) = get_str("prUrl") {
                    self.pr_url = Some(url);
                }
                if let Some(n) = json.get("prNumber").and_then(serde_json::Value::as_i64) {
                    self.pr_number = Some(n);