agent-sessions 0.3.0

use crate::{Agent, LineErrorKind};
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use serde_json::Value;

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct HistoryEntry {
    pub session_id: Option<String>,
    pub text: Option<String>,
    pub at: Option<DateTime<Utc>>,
    /// Native integer timestamp: milliseconds for Claude, seconds for Codex.
    /// Retained even when outside the representable datetime range.
    pub timestamp: Option<i64>,
    pub project: Option<String>,
    pub invalid_fields: Vec<String>,
}
pub fn history_entry(agent: Agent, v: &Value, strict: bool) -> Result<HistoryEntry, LineErrorKind> {
    let mut invalid_fields: Vec<String> = Vec::new();
    if !v.is_object() {
        invalid_fields.push("record".into());
    }
    let (id_key, text_key, time_key) = match agent {
        Agent::ClaudeCode => ("sessionId", "display", "timestamp"),
        Agent::Codex => ("session_id", "text", "ts"),
        _ => {
            return Err(LineErrorKind::InvalidField(
                "unsupported history format".into(),
            ));
        }
    };
    let mut field = |key: &str| match v.get(key) {
        None | Some(Value::Null) => None,
        Some(Value::String(s)) => Some(s.clone()),
        _ => {
            invalid_fields.push(key.into());
            None
        }
    };
    let session_id = field(id_key);
    let text = field(text_key);
    let project = field("project");
    let at = match v.get(time_key) {
        None | Some(Value::Null) => None,
        Some(t) => {
            let at = t.as_i64().and_then(|n| match agent {
                Agent::ClaudeCode => DateTime::from_timestamp_millis(n),
                Agent::Codex => DateTime::from_timestamp(n, 0),
                _ => None,
            });
            if at.is_none() {
                invalid_fields.push(time_key.into());
            }
            at
        }
    };
    if strict && let Some(key) = invalid_fields.first() {
        return Err(LineErrorKind::InvalidField(key.clone()));
    }
    Ok(HistoryEntry {
        session_id,
        text,
        at,
        timestamp: v.get(time_key).and_then(Value::as_i64),
        project,
        invalid_fields,
    })
}