use std::fs::OpenOptions;
use std::io::{BufRead, BufReader, Write};
use std::path::{Path, PathBuf};
use super::format::{make_persisted, parse_entry};
use super::traits::{AgentMessage, EntryType, MessageRole};
#[derive(Clone, Debug, Default, serde::Serialize, serde::Deserialize)]
pub struct SessionHeader {
pub source: String,
#[serde(default, skip_serializing_if = "Option::is_none")]
pub user: Option<String>,
#[serde(default, skip_serializing_if = "Option::is_none")]
pub model: Option<String>,
#[serde(default, skip_serializing_if = "std::collections::HashMap::is_empty")]
pub extra: std::collections::HashMap<String, String>,
}
pub struct Session<M: AgentMessage> {
messages: Vec<M>,
session_file: PathBuf,
session_id: String,
last_uuid: Option<String>,
max_history: usize,
}
impl<M: AgentMessage> Session<M> {
pub fn new(session_dir: &str, max_history: usize) -> std::io::Result<Self> {
Self::new_with_header(session_dir, max_history, None)
}
pub fn new_with_header(
session_dir: &str,
max_history: usize,
header: Option<SessionHeader>,
) -> std::io::Result<Self> {
std::fs::create_dir_all(session_dir)?;
let session_id = uuid::Uuid::now_v7().to_string();
let session_file = PathBuf::from(format!("{}/{}.jsonl", session_dir, session_id));
if let Some(header) = header {
let header_entry = serde_json::json!({
"type": "header",
"sessionId": &session_id,
"timestamp": super::time::now_iso(),
"source": header.source,
"user": header.user,
"model": header.model,
"extra": if header.extra.is_empty() { None } else { Some(&header.extra) },
});
let mut f = OpenOptions::new()
.create(true)
.append(true)
.open(&session_file)?;
let _ = writeln!(
f,
"{}",
serde_json::to_string(&header_entry).unwrap_or_default()
);
}
Ok(Self {
messages: Vec::new(),
session_file,
session_id,
last_uuid: None,
max_history,
})
}
pub fn resume(path: &Path, _session_dir: &str, max_history: usize) -> Self {
let (messages, session_id, last_uuid) = Self::load_file(path);
Self {
messages,
session_file: path.to_path_buf(),
session_id,
last_uuid,
max_history,
}
}
pub fn resume_last(session_dir: &str, max_history: usize) -> Option<Self> {
let last = Self::find_last_session(session_dir)?;
Some(Self::resume(&last, session_dir, max_history))
}
pub fn push(&mut self, role: <M as AgentMessage>::Role, content: String) -> &M {
let msg = M::new(role, content);
self.messages.push(msg);
self.persist_last();
self.messages.last().expect("just pushed")
}
pub fn push_msg(&mut self, msg: M) {
self.messages.push(msg);
self.persist_last();
}
pub fn messages(&self) -> &[M] {
&self.messages
}
pub fn messages_mut(&mut self) -> &mut Vec<M> {
&mut self.messages
}
pub fn is_empty(&self) -> bool {
self.messages.is_empty()
}
pub fn len(&self) -> usize {
self.messages.len()
}
pub fn session_file(&self) -> &Path {
&self.session_file
}
pub fn session_id(&self) -> &str {
&self.session_id
}
pub fn trim(&mut self) -> usize {
if self.messages.len() <= self.max_history {
return 0;
}
let system_msgs: Vec<M> = self
.messages
.iter()
.filter(|m| m.role().is_system())
.cloned()
.collect();
let non_system: Vec<M> = self
.messages
.iter()
.filter(|m| !m.role().is_system())
.cloned()
.collect();
let keep = self.max_history.saturating_sub(system_msgs.len());
let skip = non_system.len().saturating_sub(keep);
if skip == 0 {
return 0;
}
let mut trimmed = system_msgs;
trimmed.push(M::new(
<M as AgentMessage>::Role::system(),
format!("[{} earlier messages trimmed]", skip),
));
let kept: Vec<M> = non_system.into_iter().skip(skip).collect();
let mut extra_skip = 0;
for msg in &kept {
if msg.role().is_tool() {
extra_skip += 1;
} else {
break;
}
}
trimmed.extend(kept.into_iter().skip(extra_skip));
self.messages = trimmed;
skip + extra_skip
}
fn persist_last(&mut self) {
let Some(msg) = self.messages.last() else {
return;
};
let Some(entry_type) = EntryType::parse(msg.role().as_str()) else {
return;
};
let persisted = make_persisted(
entry_type,
msg.content(),
&self.session_id,
self.last_uuid.as_deref(),
);
self.last_uuid = Some(persisted.uuid.clone());
let Ok(json) = serde_json::to_string(&persisted) else {
return;
};
let Ok(mut f) = OpenOptions::new()
.create(true)
.append(true)
.open(&self.session_file)
else {
return;
};
let _ = writeln!(f, "{}", json);
}
fn load_file(path: &Path) -> (Vec<M>, String, Option<String>) {
let Ok(file) = std::fs::File::open(path) else {
return (vec![], uuid::Uuid::now_v7().to_string(), None);
};
let mut messages = Vec::new();
let mut session_id = None;
let mut last_uuid = None;
for line in BufReader::new(file).lines().map_while(Result::ok) {
let Ok(value) = serde_json::from_str::<serde_json::Value>(&line) else {
continue;
};
if let Some(sid) = value["sessionId"].as_str() {
session_id = Some(sid.to_string());
}
if let Some(uid) = value["uuid"].as_str() {
last_uuid = Some(uid.to_string());
}
if let Some((entry_type, content)) = parse_entry(&value) {
messages.push(M::new(
entry_type.into_role::<<M as AgentMessage>::Role>(),
content,
));
}
}
let sid = session_id.unwrap_or_else(|| {
path.file_stem()
.and_then(|s| s.to_str())
.map(String::from)
.unwrap_or_else(|| uuid::Uuid::now_v7().to_string())
});
(messages, sid, last_uuid)
}
fn find_last_session(dir: &str) -> Option<PathBuf> {
let mut entries: Vec<_> = std::fs::read_dir(dir)
.ok()?
.filter_map(|e| e.ok())
.filter(|e| e.path().extension().is_some_and(|ext| ext == "jsonl"))
.collect();
entries.sort_by_key(|e| e.file_name());
entries.last().map(|e| e.path())
}
}