1use std::collections::{BTreeMap, BTreeSet};
4use std::fs;
5use std::path::{Component, Path, PathBuf};
6use std::sync::Arc;
7
8use anyhow::{Context, Result, bail};
9use serde::{Deserialize, Serialize};
10
11use crate::config::{
12 Config, HarnessKind, ProjectRepository, TargetTemplate, atomic_write, data_dir, validate_id,
13};
14use crate::credentials::CredentialSyncSignal;
15use crate::relay::{
16 RELAY_EVENT_GENESIS_DIGEST, RelayOperationalState, SequencedEvent, WorkerEvent,
17};
18use crate::subagent::SubagentRecord;
19use crate::targets::{AdditionalMount, validate_additional_mounts};
20
21pub const STATE_VERSION: u32 = 1;
22
23mod session_move;
24pub use session_move::*;
25
26#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
27#[serde(rename_all = "kebab-case")]
28pub enum SessionState {
29 Provisioning,
30 Running,
31 Disconnected,
32 Checkpointing,
33 Closing,
34 Destroying,
35 #[serde(alias = "archived")]
38 Stopped,
39 Lost,
40 Error,
41 DestroyedWithDataLoss,
42}
43
44#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
47#[serde(rename_all = "kebab-case")]
48pub enum SessionTransitionKind {
49 Starting,
50 Resuming,
51 Moving,
52 Stopping,
53 Destroying,
54}
55
56impl SessionTransitionKind {
57 pub const fn label(self) -> &'static str {
58 match self {
59 Self::Starting => "Starting",
60 Self::Resuming => "Resuming",
61 Self::Moving => "Moving",
62 Self::Stopping => "Stopping",
63 Self::Destroying => "Destroying",
64 }
65 }
66
67 pub fn for_session(state: SessionState, operation: Option<Self>) -> Option<Self> {
68 operation.or_else(|| state.transition_kind())
69 }
70}
71
72#[cfg(test)]
73mod transition_tests {
74 use super::{SessionState, SessionTransitionKind};
75
76 #[test]
77 fn operation_ownership_hides_intermediate_move_states_but_not_ordinary_live_work() {
78 for state in [
79 SessionState::Stopped,
80 SessionState::Running,
81 SessionState::Disconnected,
82 ] {
83 assert_eq!(
84 SessionTransitionKind::for_session(state, Some(SessionTransitionKind::Moving)),
85 Some(SessionTransitionKind::Moving)
86 );
87 assert_eq!(SessionTransitionKind::for_session(state, None), None);
88 }
89 assert_eq!(SessionState::Checkpointing.transition_kind(), None);
90 assert_eq!(
91 SessionState::Closing.transition_kind(),
92 Some(SessionTransitionKind::Stopping)
93 );
94 }
95}
96
97#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
99#[serde(tag = "state", rename_all = "snake_case")]
100pub enum MaterializedExecutionState {
101 #[default]
102 Idle,
103 Running {
104 started_at_ms: i64,
105 },
106 Closing,
107 Closed,
108}
109
110pub use crate::transcript::{TerminalOutputRecord, TranscriptBody, TranscriptItem};
111
112#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
117#[serde(rename_all = "snake_case")]
118pub enum QueuedCommandKind {
119 #[default]
120 Prompt,
121 SetConfig {
122 key: String,
123 value: String,
124 },
125}
126
127impl QueuedCommandKind {
128 pub fn is_prompt(&self) -> bool {
129 matches!(self, Self::Prompt)
130 }
131}
132
133pub fn config_command_text(key: &str, value: &str) -> String {
136 if key == "fast-mode" {
137 "/fast".to_owned()
138 } else {
139 format!("/{key} {value}")
140 }
141}
142
143#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
144#[serde(deny_unknown_fields)]
145pub struct MaterializedQueuedPrompt {
146 pub command_id: String,
147 #[serde(default, skip_serializing_if = "QueuedCommandKind::is_prompt")]
148 pub kind: QueuedCommandKind,
149 pub content: Vec<serde_json::Value>,
150 pub queued_at_ms: i64,
151 #[serde(default, skip_serializing_if = "Option::is_none")]
155 pub accepted_ordinal: Option<u64>,
156}
157
158#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
161#[serde(deny_unknown_fields)]
162pub struct MaterializedTurn {
163 pub command_id: String,
164 #[serde(default, skip_serializing_if = "Option::is_none")]
165 pub accepted_ordinal: Option<u64>,
166 pub turn_start_position: u64,
169 pub started_at_ms: i64,
170}
171
172#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
174#[serde(tag = "kind", rename_all = "snake_case")]
175pub enum TurnOutcomeKind {
176 Completed { stop_reason: String },
178 Rejected { message: String },
180 Interrupted { message: String },
182}
183
184#[derive(Debug, Clone, Copy, PartialEq, Eq)]
185pub enum PromptCompletion {
186 Finished,
187 Cancelled,
188 QuotaLimit,
189 Error,
190}
191
192pub fn classify_prompt_completion(stop_reason: &str) -> PromptCompletion {
194 let normalized = stop_reason
195 .chars()
196 .filter(|character| *character != '_' && *character != '-')
197 .flat_map(char::to_lowercase)
198 .collect::<String>();
199 match normalized.as_str() {
200 "endturn" => PromptCompletion::Finished,
201 "cancelled" | "canceled" => PromptCompletion::Cancelled,
202 "quotalimit" => PromptCompletion::QuotaLimit,
203 _ if crate::relay::is_capacity_stop_reason(stop_reason) => PromptCompletion::QuotaLimit,
204 _ => PromptCompletion::Error,
205 }
206}
207
208#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
210#[serde(deny_unknown_fields)]
211pub struct MaterializedTurnOutcome {
212 #[serde(default, skip_serializing_if = "Option::is_none")]
213 pub diagnostic: Option<crate::diagnostic::TurnDiagnostic>,
214
215 #[serde(default, skip_serializing_if = "Option::is_none")]
216 pub usage: Option<crate::usage::TokenUsage>,
217 pub command_id: String,
218 #[serde(default, skip_serializing_if = "Option::is_none")]
219 pub accepted_ordinal: Option<u64>,
220 #[serde(default, skip_serializing_if = "Option::is_none")]
221 pub turn_start_position: Option<u64>,
222 pub completed_ordinal: u64,
223 pub completed_at_ms: i64,
224 pub outcome: TurnOutcomeKind,
225}
226
227#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
229#[serde(deny_unknown_fields)]
230pub struct MaterializedSession {
231 pub session_id: String,
232 pub applied_event_ordinal: u64,
233 pub applied_event_digest: String,
234 pub last_activity_at_ms: Option<i64>,
237 pub execution: MaterializedExecutionState,
238 #[serde(default, skip_serializing_if = "Option::is_none")]
239 pub session_title: Option<String>,
240 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
241 pub configuration: BTreeMap<String, serde_json::Value>,
242 #[serde(default, skip_serializing_if = "Vec::is_empty")]
243 pub transcript: Vec<Arc<TranscriptItem>>,
246 #[serde(default, skip_serializing_if = "Vec::is_empty")]
247 pub queued_prompts: Vec<MaterializedQueuedPrompt>,
248 #[serde(default, skip_serializing_if = "Vec::is_empty")]
251 pub pending_elicitations: Vec<crate::elicitation::ElicitationRequest>,
252 #[serde(default, skip_serializing_if = "Option::is_none")]
254 pub active_turn: Option<MaterializedTurn>,
255 #[serde(default, skip_serializing_if = "Option::is_none")]
258 pub last_turn_outcome: Option<MaterializedTurnOutcome>,
259}
260
261#[derive(Debug, Clone, PartialEq, Eq)]
264pub struct MaterializedSessionSummary {
265 pub session_id: String,
266 pub applied_event_ordinal: u64,
267 pub last_activity_at_ms: Option<i64>,
268 pub execution: MaterializedExecutionState,
269 pub session_title: Option<String>,
270 pub last_agent_message: Option<String>,
271 pub last_user_message: Option<String>,
272 pub last_agent_message_follows_last_user: bool,
275 pub agent_message_latest_content_ordinals: Vec<u64>,
276 pub session_restart_event_ordinals: Vec<u64>,
277}
278
279impl MaterializedSession {
280 pub fn empty(session_id: impl Into<String>) -> Self {
281 Self {
282 session_id: session_id.into(),
283 applied_event_ordinal: 0,
284 applied_event_digest: RELAY_EVENT_GENESIS_DIGEST.into(),
285 last_activity_at_ms: None,
286 execution: MaterializedExecutionState::Idle,
287 session_title: None,
288 configuration: BTreeMap::new(),
289 transcript: Vec::new(),
290 queued_prompts: Vec::new(),
291 pending_elicitations: Vec::new(),
292 active_turn: None,
293 last_turn_outcome: None,
294 }
295 }
296
297 pub fn last_activity_at_ms(&self) -> Option<i64> {
298 self.last_activity_at_ms
299 }
300
301 pub fn resolved_title(&self) -> Option<String> {
307 self.session_title
308 .as_deref()
309 .and_then(normalize_session_title)
310 .or_else(|| {
311 self.transcript.iter().find_map(|item| {
312 let TranscriptBody::User { content } = &item.body else {
313 return None;
314 };
315 provisional_session_title(&crate::transcript::materialized_content_text(
316 content,
317 ))
318 })
319 })
320 .or_else(|| {
321 self.queued_prompts
322 .iter()
323 .filter(|prompt| prompt.kind.is_prompt())
324 .find_map(|prompt| {
325 provisional_session_title(&crate::transcript::materialized_content_text(
326 &prompt.content,
327 ))
328 })
329 })
330 }
331
332 pub fn unread_agent_messages_after(&self, viewed_through_event_ordinal: u64) -> u64 {
333 self.transcript
334 .iter()
335 .filter(|item| {
336 item.latest_content_event_ordinal
337 .is_some_and(|ordinal| ordinal > viewed_through_event_ordinal)
338 && item.is_nonempty_agent_message()
339 })
340 .count() as u64
341 }
342
343 pub fn unread_session_restarts_after(&self, viewed_through_event_ordinal: u64) -> u64 {
344 self.transcript
345 .iter()
346 .filter(|item| {
347 item.position > viewed_through_event_ordinal && item.is_session_restart()
348 })
349 .count() as u64
350 }
351
352 pub fn validate(&self) -> Result<()> {
353 validate_id("session", &self.session_id)?;
354 validate_relay_event_frontier(
355 self.applied_event_ordinal,
356 &self.applied_event_digest,
357 "materialized session event frontier",
358 )?;
359 if self
360 .session_title
361 .as_ref()
362 .is_some_and(|title| title.trim().is_empty())
363 {
364 bail!("materialized session has an empty title");
365 }
366 let mut item_ids = BTreeSet::new();
367 for item in &self.transcript {
368 item.validate(self.applied_event_ordinal)?;
369 if !item_ids.insert(item.stable_id.as_str()) {
370 bail!(
371 "materialized transcript contains duplicate item {:?}",
372 item.stable_id
373 );
374 }
375 }
376 let mut command_ids = BTreeSet::new();
377 for prompt in &self.queued_prompts {
378 if prompt.command_id.trim().is_empty() {
379 bail!("materialized prompt queue has an empty command id");
380 }
381 if !command_ids.insert(prompt.command_id.as_str()) {
382 bail!(
383 "materialized prompt queue contains duplicate command {:?}",
384 prompt.command_id
385 );
386 }
387 if let QueuedCommandKind::SetConfig { key, value } = &prompt.kind
388 && (key.trim().is_empty() || value.trim().is_empty())
389 {
390 bail!(
391 "materialized queued configuration change {:?} is incomplete",
392 prompt.command_id
393 );
394 }
395 }
396 Ok(())
397 }
398}
399
400#[derive(Debug, Clone, PartialEq)]
404pub struct ManagedSessionSnapshot {
405 pub materialized: MaterializedSession,
406 pub window: ProjectionWindow,
409 pub operational: RelayOperationalState,
410 pub latest_credential_sync_signal: Option<CredentialSyncSignal>,
414 pub worker_build: Option<String>,
419 pub subagent_requests: Vec<crate::subagent::SubagentToolRequest>,
421 pub subagent_results: Vec<crate::subagent::SubagentToolResult>,
423}
424
425#[derive(Debug, Clone, PartialEq, Eq)]
437pub struct ProjectionWindow {
438 pub omitted_items: usize,
440 pub provisional_title: Option<String>,
442 pub latest_turn_start_position: Option<u64>,
446}
447
448impl ProjectionWindow {
449 #[must_use]
451 pub fn of(session: &MaterializedSession) -> Self {
452 Self {
453 omitted_items: 0,
454 provisional_title: session.transcript.iter().find_map(|item| {
455 let TranscriptBody::User { content } = &item.body else {
456 return None;
457 };
458 provisional_session_title(&crate::transcript::materialized_content_text(content))
459 }),
460 latest_turn_start_position: session
461 .transcript
462 .iter()
463 .rev()
464 .find(|item| item.is_turn_start())
465 .map(|item| item.position),
466 }
467 }
468}
469
470impl ManagedSessionSnapshot {
471 #[must_use]
476 pub fn resolved_title(&self) -> Option<String> {
477 self.materialized
478 .session_title
479 .as_deref()
480 .and_then(normalize_session_title)
481 .or_else(|| self.window.provisional_title.clone())
482 .or_else(|| {
483 self.materialized
484 .queued_prompts
485 .iter()
486 .filter(|prompt| prompt.kind.is_prompt())
487 .find_map(|prompt| {
488 provisional_session_title(&crate::transcript::materialized_content_text(
489 &prompt.content,
490 ))
491 })
492 })
493 }
494
495 #[must_use]
500 pub fn latest_completed_turn_ordinal(&self) -> Option<u64> {
501 if self.materialized.execution != MaterializedExecutionState::Idle {
502 return None;
503 }
504 self.window.latest_turn_start_position
505 }
506}
507
508#[derive(Debug, Clone)]
510pub struct RecoveryObservation {
511 pub session: SessionRecord,
512 pub config: Config,
513 pub latest_completed_turn_ordinal: Option<u64>,
514 pub execution: MaterializedExecutionState,
515 pub checkpoint_safe: bool,
519}
520
521pub fn latest_completed_turn_ordinal(session: &MaterializedSession) -> Option<u64> {
526 if session.execution != MaterializedExecutionState::Idle {
527 return None;
528 }
529 session
530 .transcript
531 .iter()
532 .rev()
533 .find(|item| item.is_turn_start())
534 .map(|item| item.position)
535}
536
537pub fn validate_relay_event_digest(digest: &str, name: &str) -> Result<()> {
538 if digest.len() != 64
539 || !digest
540 .bytes()
541 .all(|byte| byte.is_ascii_digit() || (b'a'..=b'f').contains(&byte))
542 {
543 bail!("{name} must be a lowercase SHA-256 digest");
544 }
545 Ok(())
546}
547
548pub fn validate_relay_event_frontier(ordinal: u64, digest: &str, name: &str) -> Result<()> {
549 validate_relay_event_digest(digest, name)?;
550 if (ordinal == 0) != (digest == RELAY_EVENT_GENESIS_DIGEST) {
551 bail!("{name} has inconsistent ordinal {ordinal} and digest {digest}");
552 }
553 Ok(())
554}
555
556fn is_false(value: &bool) -> bool {
557 !*value
558}
559
560impl SessionState {
561 pub const fn transition_kind(self) -> Option<SessionTransitionKind> {
564 match self {
565 Self::Provisioning => Some(SessionTransitionKind::Starting),
566 Self::Closing => Some(SessionTransitionKind::Stopping),
567 Self::Destroying => Some(SessionTransitionKind::Destroying),
568 _ => None,
569 }
570 }
571
572 pub const fn is_active(self) -> bool {
576 matches!(
577 self,
578 Self::Provisioning
579 | Self::Running
580 | Self::Disconnected
581 | Self::Checkpointing
582 | Self::Closing
583 | Self::Destroying
584 | Self::Error
585 )
586 }
587}
588
589#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
590#[serde(tag = "kind", rename_all = "kebab-case")]
591pub enum PodmanWorkspaceLocator {
592 #[default]
593 ContainerLayer,
594 Volume {
595 name: String,
596 },
597 HostPath {
598 path: PathBuf,
599 helper: Vec<String>,
600 resource: String,
601 },
602}
603
604#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
605#[serde(tag = "kind", rename_all = "kebab-case")]
606pub enum TargetLocator {
607 LocalBare {
608 worker_root: PathBuf,
609 },
610 LocalPodman {
611 container_id: String,
612 #[serde(default)]
613 workspace_storage: PodmanWorkspaceLocator,
614 },
615 LocalDocker {
616 container_id: String,
617 },
618 AppleContainer {
619 container_id: String,
620 },
621 AwsEc2 {
622 instance_id: String,
623 #[serde(default, skip_serializing_if = "Option::is_none")]
624 address: Option<String>,
625 },
626 SshBare {
627 host: String,
628 workspace: PathBuf,
629 #[serde(default, skip_serializing_if = "Option::is_none")]
630 worker_id: Option<String>,
631 },
632 SshPodman {
633 host: String,
634 container_id: String,
635 #[serde(default)]
636 workspace_storage: PodmanWorkspaceLocator,
637 },
638 SshDocker {
639 host: String,
640 container_id: String,
641 },
642}
643
644#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
645#[serde(tag = "kind", rename_all = "kebab-case")]
646pub enum ManagedWorktreeTarget {
647 Local,
648 Ssh {
649 destination: String,
650 #[serde(default, skip_serializing_if = "Vec::is_empty")]
651 ssh_args: Vec<String>,
652 },
653}
654
655#[derive(Debug, Default, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
657#[serde(deny_unknown_fields)]
658pub struct ManagedWorktreeOptions {
659 pub available: bool,
660 pub default_create: bool,
661}
662
663#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
664#[serde(deny_unknown_fields)]
665pub struct ManagedWorktree {
666 pub source_project_directory: PathBuf,
667 pub source_repository: PathBuf,
668 pub worktree_root: PathBuf,
669 pub branch: String,
670 pub target: ManagedWorktreeTarget,
671 #[serde(default, skip_serializing_if = "Option::is_none")]
675 pub base_commit: Option<String>,
676}
677
678impl ManagedWorktree {
679 fn validate(&self, session_id: &str, project_directory: Option<&Path>) -> Result<()> {
680 for (label, path) in [
681 ("source project directory", &self.source_project_directory),
682 ("source repository", &self.source_repository),
683 ("worktree root", &self.worktree_root),
684 ] {
685 if !path.is_absolute() || path.components().any(|part| part == Component::ParentDir) {
686 bail!("managed worktree {label} must be an absolute safe path");
687 }
688 }
689 if !self
690 .source_project_directory
691 .starts_with(&self.source_repository)
692 {
693 bail!("managed worktree source directory is outside its repository");
694 }
695 let expected_root = self
696 .source_repository
697 .join(".mj")
698 .join("worktrees")
699 .join(session_id);
700 if self.worktree_root != expected_root {
701 bail!("managed worktree root does not match the session-owned path");
702 }
703 if self.branch != format!("mj/{session_id}") {
704 bail!("managed worktree branch does not match the session id");
705 }
706 let relative = self
707 .source_project_directory
708 .strip_prefix(&self.source_repository)
709 .expect("source relationship checked above");
710 if project_directory != Some(self.worktree_root.join(relative).as_path()) {
711 bail!("session project directory does not match its managed worktree");
712 }
713 match &self.target {
714 ManagedWorktreeTarget::Local => {}
715 ManagedWorktreeTarget::Ssh { destination, .. } if destination.trim().is_empty() => {
716 bail!("managed SSH worktree has an empty destination")
717 }
718 ManagedWorktreeTarget::Ssh { .. } => {}
719 }
720 Ok(())
721 }
722}
723
724#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
725#[serde(tag = "kind", rename_all = "kebab-case")]
726pub enum SessionResourceAllocation {
727 Container {
728 cpus: u64,
729 memory_bytes: u64,
730 },
731 AwsEc2 {
732 instance_type: String,
733 vcpus: u64,
734 memory_bytes: u64,
735 },
736}
737
738impl SessionResourceAllocation {
739 pub fn validate(&self) -> Result<()> {
740 match self {
741 Self::Container { cpus, memory_bytes } if *cpus == 0 || *memory_bytes == 0 => {
742 bail!("container resource allocation must have non-zero CPU and memory")
743 }
744 Self::AwsEc2 {
745 instance_type,
746 vcpus,
747 memory_bytes,
748 } if instance_type.trim().is_empty() || *vcpus == 0 || *memory_bytes == 0 => {
749 bail!("EC2 resource allocation must have an instance type, CPU, and memory")
750 }
751 _ => Ok(()),
752 }
753 }
754}
755
756pub fn allocation_cpus(allocation: &SessionResourceAllocation) -> u64 {
758 match allocation {
759 SessionResourceAllocation::Container { cpus, .. } => *cpus,
760 SessionResourceAllocation::AwsEc2 { vcpus, .. } => *vcpus,
761 }
762}
763
764pub fn allocation_memory(allocation: &SessionResourceAllocation) -> u64 {
766 match allocation {
767 SessionResourceAllocation::Container { memory_bytes, .. }
768 | SessionResourceAllocation::AwsEc2 { memory_bytes, .. } => *memory_bytes,
769 }
770}
771
772impl TargetLocator {
773 fn validate(&self, session_id: &str) -> Result<()> {
774 match self {
775 Self::LocalBare { worker_root } => {
776 if !worker_root.is_absolute()
777 || worker_root
778 .components()
779 .any(|part| part == Component::ParentDir)
780 || !worker_root.ends_with(session_id)
781 {
782 bail!(
783 "local bare worker root must be an absolute safe path ending in the session id"
784 );
785 }
786 }
787 Self::LocalPodman { container_id, .. }
788 | Self::LocalDocker { container_id }
789 | Self::AppleContainer { container_id }
790 | Self::SshPodman { container_id, .. }
791 | Self::SshDocker { container_id, .. }
792 if container_id.trim().is_empty() =>
793 {
794 bail!("target locator has an empty container id")
795 }
796 Self::AwsEc2 { instance_id, .. } if instance_id.trim().is_empty() => {
797 bail!("target locator has an empty AWS instance id")
798 }
799 Self::SshBare {
800 host, workspace, ..
801 } => {
802 if host.trim().is_empty() {
803 bail!("bare SSH target locator has an empty host");
804 }
805 if workspace.as_os_str().is_empty()
806 || workspace
807 .components()
808 .any(|part| part == Component::ParentDir)
809 || !workspace.ends_with(session_id)
810 {
811 bail!("bare SSH target locator must be a safe path ending in the session id");
812 }
813 }
814 Self::SshPodman { host, .. } if host.trim().is_empty() => {
815 bail!("SSH Podman target locator has an empty host")
816 }
817 Self::SshDocker { host, .. } if host.trim().is_empty() => {
818 bail!("SSH Docker target locator has an empty host")
819 }
820 _ => {}
821 }
822 Ok(())
823 }
824}
825
826#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
827#[serde(deny_unknown_fields)]
828pub struct CheckpointMetadata {
829 pub archive_path: PathBuf,
830 pub sha256: String,
832 pub created_at: String,
833 pub event_frontier: u64,
834}
835
836impl CheckpointMetadata {
837 fn validate(&self) -> Result<()> {
838 if self.archive_path.as_os_str().is_empty() {
839 bail!("checkpoint archive path is empty");
840 }
841 if self.sha256.len() != 64
842 || !self
843 .sha256
844 .bytes()
845 .all(|byte| byte.is_ascii_hexdigit() && !byte.is_ascii_uppercase())
846 {
847 bail!("checkpoint SHA-256 must be 64 lowercase hexadecimal characters");
848 }
849 if self.created_at.trim().is_empty() {
850 bail!("checkpoint timestamp is empty");
851 }
852 Ok(())
853 }
854}
855
856#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
857#[serde(deny_unknown_fields)]
858pub struct SessionRecord {
859 pub id: String,
860 #[serde(default = "default_session_workspace_id")]
865 pub workspace_id: String,
866 pub title: String,
867 pub harness_kind: HarnessKind,
868 pub last_profile: String,
869 pub bundle_id: String,
870 #[serde(default, skip_serializing_if = "Option::is_none")]
872 pub project_directory: Option<PathBuf>,
873 #[serde(default, skip_serializing_if = "Option::is_none")]
875 pub managed_worktree: Option<ManagedWorktree>,
876 #[serde(default, skip_serializing_if = "Option::is_none")]
878 pub create_managed_worktree: Option<bool>,
879 #[serde(default, skip_serializing_if = "Option::is_none")]
882 pub mjolnir_subagents: Option<bool>,
883 pub target_template_id: String,
884 #[serde(default, skip_serializing_if = "Option::is_none")]
885 pub resource_allocation: Option<SessionResourceAllocation>,
886 #[serde(default, skip_serializing_if = "Vec::is_empty")]
887 pub additional_mounts: Vec<AdditionalMount>,
888 #[serde(default, skip_serializing_if = "Option::is_none")]
891 pub container_cpus: Option<String>,
892 #[serde(default, skip_serializing_if = "Option::is_none")]
895 pub container_memory: Option<String>,
896 pub state: SessionState,
897 #[serde(default, skip_serializing_if = "is_false")]
900 pub archived: bool,
901 #[serde(default, skip_serializing_if = "Option::is_none")]
902 pub target: Option<TargetLocator>,
903 #[serde(default, skip_serializing_if = "Option::is_none")]
904 pub native_session_id: Option<String>,
905 #[serde(default, skip_serializing_if = "Option::is_none")]
906 pub acp_session_title: Option<String>,
907 #[serde(default, skip_serializing_if = "Option::is_none")]
908 pub session_title_override: Option<String>,
909 pub created_at: String,
910 pub updated_at: String,
911 #[serde(default, alias = "detached_after_event_ordinal")]
912 pub viewed_through_event_ordinal: u64,
913 #[serde(default, skip_serializing_if = "String::is_empty")]
916 pub draft_input: String,
917 #[serde(default, skip_serializing_if = "Option::is_none")]
918 pub last_error: Option<String>,
919 #[serde(default, skip_serializing_if = "Option::is_none")]
920 pub last_checkpoint_error: Option<String>,
921 #[serde(default, skip_serializing_if = "Option::is_none")]
922 pub checkpoint: Option<CheckpointMetadata>,
923}
924
925#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
926#[serde(deny_unknown_fields)]
927pub struct HostContainerSize {
928 pub cpus: u64,
929 pub memory_bytes: u64,
930}
931
932fn default_session_workspace_id() -> String {
933 crate::workspace::DEFAULT_WORKSPACE_ID.to_owned()
934}
935
936impl SessionRecord {
937 pub fn configuration_issue(&self, config: &Config) -> Option<String> {
940 if !self.state.is_active() {
941 return None;
942 }
943 let mut issues = Vec::new();
944 match config.profiles.get(&self.last_profile) {
945 None => issues.push(format!("missing profile {:?}", self.last_profile)),
946 Some(profile) if profile.kind != self.harness_kind => issues.push(format!(
947 "expects {:?}, but profile {:?} is {:?}",
948 self.harness_kind, self.last_profile, profile.kind
949 )),
950 Some(_) => {}
951 }
952 if self.project_directory.is_none() && !config.bundles.contains_key(&self.bundle_id) {
953 issues.push(format!("missing bundle {:?}", self.bundle_id));
954 }
955 if !config.targets.contains_key(&self.target_template_id) {
956 issues.push(format!(
957 "missing target template {:?}",
958 self.target_template_id
959 ));
960 }
961 (!issues.is_empty()).then(|| format!(
962 "Session {:?} needs configuration repair: {}. Restore these entries in config.toml, then retry. Run mj setup to rediscover installed profiles and targets; existing sessions are preserved.",
963 self.id, issues.join("; ")
964 ))
965 }
966
967 pub fn validate_configuration(&self, config: &Config) -> Result<()> {
968 if let Some(issue) = self.configuration_issue(config) {
969 bail!("{issue}");
970 }
971 Ok(())
972 }
973
974 pub fn display_title(&self) -> &str {
976 self.session_title_override
977 .as_deref()
978 .or(self.acp_session_title.as_deref())
979 .unwrap_or(&self.id)
980 }
981
982 pub fn project_name(&self, config: &Config) -> String {
987 if let Some(worktree) = &self.managed_worktree {
988 return path_leaf(&worktree.source_repository);
989 }
990 if let Some(project_directory) = &self.project_directory {
991 return path_leaf(project_directory);
992 }
993 self.bundle_source_name(config)
994 }
995
996 pub fn project_target(&self, config: &Config, target_id: &str) -> String {
1000 if !matches!(
1001 config.targets.get(target_id),
1002 Some(TargetTemplate::LocalBare | TargetTemplate::SshBare { .. })
1003 ) {
1004 return target_id.to_owned();
1005 }
1006 self.managed_worktree
1007 .as_ref()
1008 .map(|worktree| &worktree.source_project_directory)
1009 .or(self.project_directory.as_ref())
1010 .and_then(|path| path.file_name())
1011 .map_or_else(
1012 || target_id.to_owned(),
1013 |directory| format!("{target_id}/{}", directory.to_string_lossy()),
1014 )
1015 }
1016
1017 pub fn project_source(&self, config: &Config) -> ProjectSourceIdentity {
1022 if let Some(worktree) = &self.managed_worktree {
1023 return ProjectSourceIdentity::path(&worktree.source_repository, None);
1024 }
1025 if let Some(project_directory) = &self.project_directory {
1026 let remote = match &self.target {
1027 Some(TargetLocator::SshBare { host, .. }) => Some(host.as_str()),
1028 _ => None,
1029 };
1030 return ProjectSourceIdentity::path(project_directory, remote);
1031 }
1032 self.bundle_source_identity(config)
1033 .unwrap_or_else(|| ProjectSourceIdentity {
1034 key: format!("bundle:{}", self.bundle_id),
1035 short: path_leaf(Path::new(&self.bundle_id)),
1036 full: self.bundle_id.clone(),
1037 })
1038 }
1039
1040 fn bundle_source_name(&self, config: &Config) -> String {
1043 self.bundle_source_identity(config)
1044 .map(|source| source.short)
1045 .unwrap_or_else(|| path_leaf(Path::new(&self.bundle_id)))
1046 }
1047
1048 fn bundle_source_identity(&self, config: &Config) -> Option<ProjectSourceIdentity> {
1051 let bundle = config.bundles.get(&self.bundle_id)?;
1052 let sources = bundle
1053 .repositories
1054 .iter()
1055 .map(repository_source_identity)
1056 .collect::<Option<Vec<_>>>()?;
1057 ProjectSourceIdentity::bundle(sources)
1058 }
1059
1060 pub fn compare_by_creation(&self, other: &Self) -> std::cmp::Ordering {
1064 self.creation_order_key().cmp(&other.creation_order_key())
1065 }
1066
1067 pub fn creation_order_key(&self) -> (bool, Option<i64>, &str) {
1069 let timestamp = created_at_seconds(&self.created_at);
1070 (timestamp.is_none(), timestamp, &self.id)
1071 }
1072
1073 fn validate(&self, map_id: &str) -> Result<()> {
1074 validate_id("session", &self.id)?;
1075 if self.id != map_id {
1076 bail!(
1077 "session map key {map_id:?} does not match record id {:?}",
1078 self.id
1079 );
1080 }
1081 validate_id("workspace", &self.workspace_id)?;
1082 validate_id("profile", &self.last_profile)?;
1083 validate_id("bundle", &self.bundle_id)?;
1084 if let Some(project_directory) = &self.project_directory
1085 && (!project_directory.is_absolute()
1086 || project_directory
1087 .components()
1088 .any(|part| part == Component::ParentDir))
1089 {
1090 bail!("session {:?} has an unsafe project directory", self.id);
1091 }
1092 if let Some(managed_worktree) = &self.managed_worktree {
1093 managed_worktree.validate(&self.id, self.project_directory.as_deref())?;
1094 }
1095 validate_id("target template", &self.target_template_id)?;
1096 if let Some(allocation) = &self.resource_allocation {
1097 allocation.validate()?;
1098 }
1099 validate_additional_mounts(&self.additional_mounts)?;
1100 if self.title.trim().is_empty() {
1101 bail!("session {:?} has an empty title", self.id);
1102 }
1103 if self
1104 .acp_session_title
1105 .as_ref()
1106 .is_some_and(|title| title.trim().is_empty())
1107 || self
1108 .session_title_override
1109 .as_ref()
1110 .is_some_and(|title| title.trim().is_empty())
1111 {
1112 bail!("session {:?} has an empty display title", self.id);
1113 }
1114 if self.created_at.trim().is_empty() || self.updated_at.trim().is_empty() {
1115 bail!("session {:?} has an empty timestamp", self.id);
1116 }
1117 if let Some(target) = &self.target {
1118 target.validate(&self.id)?;
1119 }
1120 if let Some(checkpoint) = &self.checkpoint {
1121 checkpoint.validate()?;
1122 }
1123 Ok(())
1124 }
1125}
1126
1127fn repository_source_identity(repository: &ProjectRepository) -> Option<ProjectSourceIdentity> {
1128 repository
1129 .github
1130 .as_deref()
1131 .and_then(ProjectSourceIdentity::git_remote)
1132 .or_else(|| {
1133 repository
1134 .local
1135 .as_deref()
1136 .map(|path| ProjectSourceIdentity::path(path, None))
1137 })
1138}
1139
1140#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord)]
1141pub struct ProjectSourceIdentity {
1142 pub key: String,
1143 pub short: String,
1144 pub full: String,
1145}
1146
1147impl ProjectSourceIdentity {
1148 pub fn bundle(mut sources: Vec<Self>) -> Option<Self> {
1150 if sources.is_empty() {
1151 return None;
1152 }
1153 sources.sort_by(|left, right| {
1154 left.key
1155 .cmp(&right.key)
1156 .then_with(|| left.full.cmp(&right.full))
1157 .then_with(|| left.short.cmp(&right.short))
1158 });
1159 sources.dedup_by(|left, right| left.key == right.key);
1160 if sources.len() == 1 {
1161 return sources.pop();
1162 }
1163 let keys = sources
1164 .iter()
1165 .map(|source| source.key.clone())
1166 .collect::<Vec<_>>();
1167 let key = serde_json::to_string(&keys).ok()?;
1168 Some(Self {
1169 key: format!("bundle:{key}"),
1170 short: sources
1171 .iter()
1172 .map(|source| source.short.as_str())
1173 .collect::<Vec<_>>()
1174 .join(" + "),
1175 full: sources
1176 .iter()
1177 .map(|source| source.full.as_str())
1178 .collect::<Vec<_>>()
1179 .join(" + "),
1180 })
1181 }
1182
1183 pub fn git_remote(source: &str) -> Option<Self> {
1186 if let Some(normalized) = normalize_github_source(source) {
1187 let short = normalized
1188 .rsplit_once('/')
1189 .map_or(normalized.as_str(), |(_, repository)| repository)
1190 .to_owned();
1191 return Some(Self {
1192 key: format!("github:{}", normalized.to_lowercase()),
1193 short,
1194 full: normalized,
1195 });
1196 }
1197 let normalized = source.trim().trim_end_matches('/').trim_end_matches(".git");
1198 if normalized.is_empty() {
1199 return None;
1200 }
1201 let short = normalized
1202 .rsplit(['/', ':'])
1203 .find(|part| !part.is_empty())
1204 .unwrap_or(normalized)
1205 .to_owned();
1206 Some(Self {
1207 key: format!("git:{}", normalized.to_lowercase()),
1208 short,
1209 full: normalized.to_owned(),
1210 })
1211 }
1212
1213 pub fn path(path: &Path, remote: Option<&str>) -> Self {
1215 let normalized = path.components().collect::<PathBuf>();
1216 let path_text = normalized.to_string_lossy().into_owned();
1217 let full = remote.map_or_else(|| path_text.clone(), |host| format!("{host}:{path_text}"));
1218 let key = remote.map_or_else(
1219 || format!("path:{path_text}"),
1220 |host| format!("path:{}:{path_text}", host.to_lowercase()),
1221 );
1222 Self {
1223 key,
1224 short: path_leaf(path),
1225 full,
1226 }
1227 }
1228}
1229
1230fn normalize_github_source(source: &str) -> Option<String> {
1231 let source = source.trim();
1232 let path = source
1233 .strip_prefix("https://github.com/")
1234 .or_else(|| source.strip_prefix("http://github.com/"))
1235 .or_else(|| source.strip_prefix("git@github.com:"))
1236 .or_else(|| source.strip_prefix("ssh://git@github.com/"))
1237 .or_else(|| {
1238 (!source.contains("://") && !source.contains('@') && !source.contains(':'))
1239 .then_some(source)
1240 })?
1241 .trim_end_matches(".git");
1242 let mut parts = path.split('/');
1243 let owner = parts.next()?;
1244 let repository = parts.next()?;
1245 (!owner.is_empty() && !repository.is_empty() && parts.next().is_none())
1246 .then(|| format!("{owner}/{repository}"))
1247}
1248
1249fn path_leaf(path: &Path) -> String {
1251 path.file_name()
1252 .unwrap_or(path.as_os_str())
1253 .to_string_lossy()
1254 .into_owned()
1255}
1256
1257fn created_at_seconds(timestamp: &str) -> Option<i64> {
1258 chrono::DateTime::parse_from_rfc3339(timestamp)
1259 .ok()
1260 .map(|timestamp| timestamp.timestamp())
1261}
1262
1263#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
1264#[serde(deny_unknown_fields)]
1265pub struct State {
1266 pub version: u32,
1267 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
1268 pub sessions: BTreeMap<String, SessionRecord>,
1269 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
1272 pub subagents: BTreeMap<String, SubagentRecord>,
1273 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
1275 pub mount_history: BTreeMap<String, Vec<PathBuf>>,
1276 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
1278 pub container_sizes: BTreeMap<String, HostContainerSize>,
1279}
1280
1281impl Default for State {
1282 fn default() -> Self {
1283 Self {
1284 version: STATE_VERSION,
1285 sessions: BTreeMap::new(),
1286 subagents: BTreeMap::new(),
1287 mount_history: BTreeMap::new(),
1288 container_sizes: BTreeMap::new(),
1289 }
1290 }
1291}
1292
1293impl State {
1294 pub fn validate(&self) -> Result<()> {
1295 if self.version != STATE_VERSION {
1296 bail!(
1297 "unsupported Mjolnir state version {}; expected {STATE_VERSION}",
1298 self.version
1299 );
1300 }
1301 for (id, session) in &self.sessions {
1302 session.validate(id)?;
1303 }
1304 for (child_id, subagent) in &self.subagents {
1305 if child_id != &subagent.child_session_id {
1306 bail!("sub-agent key {child_id:?} does not match its child session id");
1307 }
1308 if child_id == &subagent.parent_session_id {
1309 bail!("sub-agent {child_id:?} cannot be its own parent");
1310 }
1311 if !self.sessions.contains_key(child_id) {
1312 bail!("sub-agent {child_id:?} has no child session");
1313 }
1314 if !self.sessions.contains_key(&subagent.parent_session_id) {
1315 bail!(
1316 "sub-agent {child_id:?} has unknown parent {:?}",
1317 subagent.parent_session_id
1318 );
1319 }
1320 if self.subagents.contains_key(&subagent.parent_session_id) {
1321 bail!("sub-agent {child_id:?} cannot belong to another sub-agent");
1322 }
1323 if subagent.task_name.trim().is_empty()
1324 || subagent.profile_id.trim().is_empty()
1325 || subagent.request_key.trim().is_empty()
1326 {
1327 bail!("sub-agent {child_id:?} has incomplete relationship metadata");
1328 }
1329 if subagent.working_directory.is_absolute()
1330 || subagent
1331 .working_directory
1332 .components()
1333 .any(|component| component == Component::ParentDir)
1334 {
1335 bail!("sub-agent {child_id:?} has an unsafe working directory");
1336 }
1337 }
1338 for (host, sources) in &self.mount_history {
1339 if host.trim().is_empty() {
1340 bail!("mount history contains an empty host key");
1341 }
1342 if sources.iter().any(|source| !source.is_absolute()) {
1343 bail!("mount history for {host:?} contains a non-absolute source path");
1344 }
1345 }
1346 for (host, size) in &self.container_sizes {
1347 if host.trim().is_empty() {
1348 bail!("container size history contains an empty host key");
1349 }
1350 if size.cpus == 0 || size.memory_bytes == 0 {
1351 bail!("container size history for {host:?} contains a zero value");
1352 }
1353 if size.cpus > i64::MAX as u64 || size.memory_bytes > i64::MAX as u64 {
1354 bail!("container size history for {host:?} exceeds SQLite integer range");
1355 }
1356 }
1357 Ok(())
1358 }
1359
1360 pub fn remember_mount_sources(&mut self, host: &str, mounts: &[AdditionalMount]) {
1361 if mounts.is_empty() {
1362 return;
1363 }
1364 let sources = self.mount_history.entry(host.to_owned()).or_default();
1365 for mount in mounts.iter().rev() {
1366 sources.retain(|source| source != &mount.source);
1367 sources.insert(0, mount.source.clone());
1368 }
1369 sources.truncate(20);
1370 }
1371
1372 pub fn remember_container_size(&mut self, host: &str, size: HostContainerSize) {
1373 self.container_sizes.insert(host.to_owned(), size);
1374 }
1375
1376 pub fn project_directories(&self, host: &str) -> &[PathBuf] {
1377 self.mount_history
1378 .get(&project_history_key(host))
1379 .map(Vec::as_slice)
1380 .unwrap_or_default()
1381 }
1382
1383 pub fn remember_project_directory(&mut self, host: &str, directory: &Path) {
1384 let key = project_history_key(host);
1385 let directories = self.mount_history.entry(key).or_default();
1386 directories.retain(|existing| existing != directory);
1387 directories.insert(0, directory.to_path_buf());
1388 directories.truncate(20);
1389 }
1390
1391 pub fn destroy_stopped_session(&mut self, session_id: &str) -> Result<SessionRecord> {
1392 let session = self
1393 .sessions
1394 .get(session_id)
1395 .with_context(|| format!("unknown session {session_id}"))?;
1396 if session.state.is_active() {
1397 bail!("refusing to destroy active session {session_id}");
1398 }
1399 Ok(self
1400 .sessions
1401 .remove(session_id)
1402 .expect("session checked above"))
1403 }
1404
1405 pub fn destroy_session_force(&mut self, session_id: &str) -> Result<SessionRecord> {
1411 self.sessions
1412 .get(session_id)
1413 .with_context(|| format!("unknown session {session_id}"))?;
1414 Ok(self
1415 .sessions
1416 .remove(session_id)
1417 .expect("session checked above"))
1418 }
1419
1420 pub fn validate_setup_update(&self, before: &Config, after: &Config) -> Result<()> {
1423 for session in self
1424 .sessions
1425 .values()
1426 .filter(|session| session.state.is_active())
1427 {
1428 let protected = if let Some(profile) = before.profiles.get(&session.last_profile) {
1429 let mut comparable = profile.clone();
1430 if let Some(updated) = after.profiles.get(&session.last_profile) {
1431 comparable.enabled = updated.enabled;
1432 }
1433 profile.kind == session.harness_kind
1435 && after.profiles.get(&session.last_profile) != Some(&comparable)
1436 } else {
1437 false
1438 };
1439 let bundle_changed = session.project_directory.is_none()
1440 && before
1441 .bundles
1442 .get(&session.bundle_id)
1443 .is_some_and(|bundle| after.bundles.get(&session.bundle_id) != Some(bundle));
1444 let target_changed =
1445 before
1446 .targets
1447 .get(&session.target_template_id)
1448 .is_some_and(|target| {
1449 after.targets.get(&session.target_template_id) != Some(target)
1450 });
1451 if protected || bundle_changed || target_changed {
1452 bail!(
1453 "Setup would change configuration used by active session {:?}. Keep its profile {:?}, bundle {:?}, and target {:?}; add a separate entry for new settings, or stop the session before editing its configuration.",
1454 session.id,
1455 session.last_profile,
1456 session.bundle_id,
1457 session.target_template_id
1458 );
1459 }
1460 }
1461 Ok(())
1462 }
1463
1464 pub fn validate_against_config(&self, config: &Config) -> Result<()> {
1466 self.validate()?;
1467 config.validate()?;
1468 for session in self.sessions.values() {
1469 session.validate_configuration(config)?;
1470 }
1471 Ok(())
1472 }
1473
1474 pub fn load_from(path: &Path) -> Result<Self> {
1475 Self::load_json_from(path)
1476 }
1477
1478 pub fn load_json_from(path: &Path) -> Result<Self> {
1479 if !path.exists() {
1480 return Ok(Self::default());
1481 }
1482 let body =
1483 fs::read(path).with_context(|| format!("read Mjolnir state {}", path.display()))?;
1484 let state: Self = serde_json::from_slice(&body)
1485 .with_context(|| format!("parse Mjolnir state {}", path.display()))?;
1486 state.validate()?;
1487 Ok(state)
1488 }
1489
1490 pub fn save_to(&self, path: &Path) -> Result<()> {
1491 self.validate()?;
1492 let body = serde_json::to_vec_pretty(self).context("serialize Mjolnir state")?;
1493 atomic_write(path, &body)
1494 }
1495}
1496
1497fn project_history_key(host: &str) -> String {
1498 format!("project:{host}")
1499}
1500
1501pub fn state_path() -> PathBuf {
1502 data_dir().join("state.json")
1503}
1504
1505pub fn new_session_id() -> Result<String> {
1507 let mut random = [0u8; 16];
1508 getrandom::fill(&mut random)
1509 .map_err(|error| anyhow::anyhow!("generate Mjolnir session id: {error}"))?;
1510 let mut encoded = String::with_capacity(32);
1511 for byte in random {
1512 use std::fmt::Write as _;
1513 write!(encoded, "{byte:02x}").expect("writing to a String cannot fail");
1514 }
1515 Ok(encoded)
1516}
1517
1518pub fn harness_session_title(events: &[SequencedEvent]) -> Option<String> {
1520 events.iter().rev().find_map(|event| {
1521 let WorkerEvent::Adapter { payload, .. } = &event.event else {
1522 return None;
1523 };
1524 let crate::acp::RuntimeEvent::SessionUpdate { update } =
1525 serde_json::from_value(payload.clone()).ok()?
1526 else {
1527 return None;
1528 };
1529 let kind = update
1530 .get("sessionUpdate")
1531 .and_then(serde_json::Value::as_str)?;
1532 let title = match kind {
1533 "session_info_update" | "session_title" => {
1534 update.get("title").and_then(serde_json::Value::as_str)
1535 }
1536 _ => None,
1537 }?;
1538 normalize_session_title(title)
1539 })
1540}
1541
1542pub fn normalize_session_title(title: &str) -> Option<String> {
1543 let normalized = crate::relay::strip_hidden_prompt_context(title)
1544 .split_whitespace()
1545 .collect::<Vec<_>>()
1546 .join(" ");
1547 (!normalized.is_empty()).then_some(normalized)
1548}
1549
1550pub fn provisional_session_title(prompt: &str) -> Option<String> {
1556 const MAX_TITLE_CHARS: usize = 64;
1557
1558 let normalized = normalize_session_title(prompt)?;
1559 if normalized.chars().count() <= MAX_TITLE_CHARS {
1560 return Some(normalized);
1561 }
1562
1563 let mut truncated = normalized
1564 .chars()
1565 .take(MAX_TITLE_CHARS - 1)
1566 .collect::<String>();
1567 if let Some(boundary) = truncated.rfind(char::is_whitespace) {
1568 truncated.truncate(boundary);
1569 }
1570 truncated.push('…');
1571 Some(truncated)
1572}
1573
1574pub fn short_id(id: &str) -> &str {
1575 id.get(..8).unwrap_or(id)
1576}
1577
1578#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
1579pub struct RecoveryCandidate {
1580 pub session_id: String,
1581 pub target_template_id: String,
1582 pub locator: TargetLocator,
1583 pub ownership: Option<crate::worker_launch::WorkerOwnership>,
1584}
1585
1586#[derive(Debug, Clone, Default, serde::Serialize, serde::Deserialize)]
1587pub struct RecoveryScan {
1588 pub candidates: Vec<RecoveryCandidate>,
1589 pub warnings: Vec<String>,
1590}
1591
1592#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
1593#[serde(deny_unknown_fields)]
1594pub struct ResumeRepositorySourceReceipt {
1595 pub session_id: String,
1596 pub bundle_id: String,
1597 pub checkpoint_sha256: String,
1598 pub repositories: Vec<crate::config::ProjectRepository>,
1599}
1600
1601#[cfg(test)]
1602mod tests {
1603 use super::*;
1604 use crate::config::{
1605 CONFIG_VERSION, ContainerTemplate, HarnessProfile, ProjectBundle, ProjectRepository,
1606 TargetTemplate,
1607 };
1608
1609 fn user_item(position: u64, text: &str) -> Arc<TranscriptItem> {
1610 Arc::new(TranscriptItem {
1611 stable_id: format!("user:{position}"),
1612 position,
1613 latest_content_event_ordinal: None,
1614 created_at_ms: 1_000,
1615 last_changed_at_ms: 1_000,
1616 body: TranscriptBody::User {
1617 content: vec![serde_json::json!({"type": "text", "text": text})],
1618 },
1619 })
1620 }
1621
1622 fn agent_item(position: u64) -> Arc<TranscriptItem> {
1623 Arc::new(TranscriptItem {
1624 stable_id: format!("agent:{position}"),
1625 position,
1626 latest_content_event_ordinal: Some(position),
1627 created_at_ms: 1_000,
1628 last_changed_at_ms: 1_000,
1629 body: TranscriptBody::Agent {
1630 chunks: vec![serde_json::json!({
1631 "content": {"type": "text", "text": "working"},
1632 "messageId": "answer"
1633 })],
1634 streaming: false,
1635 },
1636 })
1637 }
1638
1639 fn snapshot(session: MaterializedSession, window: ProjectionWindow) -> ManagedSessionSnapshot {
1640 ManagedSessionSnapshot {
1641 materialized: session,
1642 window,
1643 worker_build: None,
1644 subagent_requests: Vec::new(),
1645 subagent_results: Vec::new(),
1646 operational: serde_json::from_value(serde_json::json!({
1647 "session_id": "session-1",
1648 "execution": "idle",
1649 "latest_ordinal": 0,
1650 "latest_digest": crate::relay::RELAY_EVENT_GENESIS_DIGEST,
1651 "acknowledged_through": 0,
1652 "acknowledged_digest": crate::relay::RELAY_EVENT_GENESIS_DIGEST,
1653 "recovery_floor_ordinal": 0,
1654 "recovery_floor_digest": crate::relay::RELAY_EVENT_GENESIS_DIGEST,
1655 "native_session_id": null,
1656 "agent_capabilities": null,
1657 "agent_info": null,
1658 "config_options": [],
1659 "available_commands": [],
1660 "config": {},
1661 "active_prompt": null,
1662 "queued_prompts": [],
1663 "checkpoint_barrier": null,
1664 "checkpoint_ready": null,
1665 }))
1666 .expect("an idle operational state"),
1667 latest_credential_sync_signal: None,
1668 }
1669 }
1670
1671 #[test]
1675 fn a_windowed_projection_answers_the_same_title_and_turn_as_a_whole_one() {
1676 let mut whole = MaterializedSession::empty("session-1");
1677 whole.transcript = vec![
1678 user_item(1, "build the relay"),
1679 agent_item(2),
1680 agent_item(3),
1681 user_item(4, "now test it"),
1682 agent_item(5),
1683 ];
1684 let complete = snapshot(whole.clone(), ProjectionWindow::of(&whole));
1685
1686 let mut windowed_session = whole.clone();
1689 windowed_session.transcript = whole.transcript[3..].to_vec();
1690 let mut windowed = snapshot(windowed_session, ProjectionWindow::of(&whole));
1691 windowed.window.omitted_items = 3;
1692
1693 assert_eq!(
1694 complete.resolved_title().as_deref(),
1695 Some("build the relay")
1696 );
1697 assert_eq!(windowed.resolved_title(), complete.resolved_title());
1698 assert_eq!(complete.latest_completed_turn_ordinal(), Some(4));
1699 assert_eq!(
1700 windowed.latest_completed_turn_ordinal(),
1701 complete.latest_completed_turn_ordinal()
1702 );
1703 }
1704
1705 #[test]
1708 fn a_running_session_reports_no_completed_turn() {
1709 let mut session = MaterializedSession::empty("session-1");
1710 session.transcript = vec![user_item(1, "build it")];
1711 session.execution = MaterializedExecutionState::Running { started_at_ms: 1 };
1712 let window = ProjectionWindow::of(&session);
1713
1714 assert_eq!(
1715 snapshot(session, window).latest_completed_turn_ordinal(),
1716 None
1717 );
1718 }
1719
1720 #[test]
1721 fn fast_mode_configuration_uses_its_user_facing_toggle_command() {
1722 assert_eq!(config_command_text("fast-mode", "on"), "/fast");
1723 assert_eq!(config_command_text("fast-mode", "off"), "/fast");
1724 assert_eq!(config_command_text("model", "sol"), "/model sol");
1725 }
1726
1727 fn sample_state() -> State {
1728 let session = SessionRecord {
1729 mjolnir_subagents: None,
1730 create_managed_worktree: None,
1731 workspace_id: crate::workspace::DEFAULT_WORKSPACE_ID.to_owned(),
1732 archived: false,
1733 container_cpus: None,
1734 container_memory: None,
1735 id: "0123456789abcdef".into(),
1736 title: "Build Hel".into(),
1737 harness_kind: HarnessKind::Codex,
1738 last_profile: "codex-1".into(),
1739 bundle_id: "hel".into(),
1740 project_directory: None,
1741 managed_worktree: None,
1742 target_template_id: "podman".into(),
1743 resource_allocation: None,
1744 additional_mounts: vec![AdditionalMount {
1745 source: PathBuf::from("/home/test/cache"),
1746 destination: PathBuf::from("/mnt/cache"),
1747 read_only: false,
1748 }],
1749 state: SessionState::Running,
1750 target: Some(TargetLocator::LocalPodman {
1751 container_id: "afb67d".into(),
1752 workspace_storage: Default::default(),
1753 }),
1754 native_session_id: Some("native-1".into()),
1755 acp_session_title: Some("Build Hel".into()),
1756 session_title_override: None,
1757 created_at: "2026-08-09T12:00:00Z".into(),
1758 updated_at: "2026-08-09T12:01:00Z".into(),
1759 viewed_through_event_ordinal: 0,
1760 draft_input: String::new(),
1761 last_error: None,
1762 last_checkpoint_error: None,
1763 checkpoint: Some(CheckpointMetadata {
1764 archive_path: PathBuf::from("sessions/0123456789abcdef.hel.zip"),
1765 sha256: "a".repeat(64),
1766 created_at: "2026-08-09T12:01:00Z".into(),
1767 event_frontier: 42,
1768 }),
1769 };
1770 State {
1771 version: STATE_VERSION,
1772 sessions: BTreeMap::from([(session.id.clone(), session)]),
1773 subagents: BTreeMap::new(),
1774 mount_history: BTreeMap::from([(
1775 "local".into(),
1776 vec![PathBuf::from("/home/test/cache")],
1777 )]),
1778 container_sizes: BTreeMap::new(),
1779 }
1780 }
1781
1782 fn sample_config() -> Config {
1783 Config {
1784 advanced: Default::default(),
1785 version: CONFIG_VERSION,
1786 sessions_side: Default::default(),
1787 show_stopped_sessions: false,
1788 newer_config_version: None,
1789 spinner: Default::default(),
1790 theme: Default::default(),
1791 phone: Default::default(),
1792 review: Default::default(),
1793 subagents: Default::default(),
1794 legacy_startup: (),
1795 profiles: BTreeMap::from([(
1796 "codex-1".into(),
1797 HarnessProfile {
1798 enabled: true,
1799 context_window_bytes: None,
1800 kind: HarnessKind::Codex,
1801 home: PathBuf::from("/home/test/.codex"),
1802 environment: BTreeMap::new(),
1803 },
1804 )]),
1805 bundles: BTreeMap::from([(
1806 "hel".into(),
1807 ProjectBundle {
1808 primary_repo: "hel".into(),
1809 repositories: vec![ProjectRepository {
1810 id: "hel".into(),
1811 github: Some("BrokkAi/hel".into()),
1812 local: None,
1813 destination: PathBuf::from("hel"),
1814 git_ref: None,
1815 }],
1816 },
1817 )]),
1818 targets: BTreeMap::from([(
1819 "podman".into(),
1820 TargetTemplate::LocalPodman {
1821 container: ContainerTemplate {
1822 image: "ubuntu:24.04".into(),
1823 pull_policy: Default::default(),
1824 platform: None,
1825 cpus: None,
1826 memory: None,
1827 environment: BTreeMap::new(),
1828 workspace_storage: Default::default(),
1829 },
1830 },
1831 )]),
1832 }
1833 }
1834
1835 fn sample_session() -> SessionRecord {
1836 sample_state()
1837 .sessions
1838 .remove("0123456789abcdef")
1839 .expect("sample session")
1840 }
1841
1842 #[test]
1843 fn session_records_written_before_container_overrides_still_load() {
1844 let session = sample_session();
1845 let mut json = serde_json::to_value(&session).expect("serialize session");
1846 let object = json.as_object_mut().expect("session object");
1847 assert!(object.remove("container_cpus").is_none());
1848 assert!(object.remove("container_memory").is_none());
1849
1850 let loaded: SessionRecord = serde_json::from_value(json).expect("load older session");
1851 assert_eq!(loaded.container_cpus, None);
1852 assert_eq!(loaded.container_memory, None);
1853 assert_eq!(loaded, session);
1854
1855 let mut edited = session.clone();
1856 edited.container_cpus = Some("4".into());
1857 edited.container_memory = Some("8g".into());
1858 let round_tripped: SessionRecord =
1859 serde_json::from_str(&serde_json::to_string(&edited).expect("serialize"))
1860 .expect("reload edited session");
1861 assert_eq!(round_tripped, edited);
1862 }
1863
1864 #[test]
1865 fn container_size_history_rejects_invalid_keys_and_values() {
1866 let mut state = State::default();
1867 state.container_sizes.insert(
1868 String::new(),
1869 HostContainerSize {
1870 cpus: 8,
1871 memory_bytes: 32,
1872 },
1873 );
1874 assert!(
1875 state
1876 .validate()
1877 .unwrap_err()
1878 .to_string()
1879 .contains("empty host")
1880 );
1881
1882 state.container_sizes = BTreeMap::from([(
1883 "local".into(),
1884 HostContainerSize {
1885 cpus: 0,
1886 memory_bytes: 32,
1887 },
1888 )]);
1889 assert!(state.validate().unwrap_err().to_string().contains("zero"));
1890 }
1891
1892 #[test]
1893 fn project_name_prefers_a_worktree_source_then_a_project_directory_then_the_bundle() {
1894 let mut config = sample_config();
1895 config
1896 .bundles
1897 .get_mut("hel")
1898 .expect("bundle")
1899 .repositories
1900 .push(ProjectRepository {
1901 id: "docs".into(),
1902 github: Some("BrokkAi/docs".into()),
1903 local: None,
1904 destination: PathBuf::from("documentation"),
1905 git_ref: None,
1906 });
1907 let mut session = sample_session();
1908
1909 assert_eq!(session.project_name(&config), "docs + hel");
1910
1911 session.project_directory = Some(PathBuf::from("/home/test/Projects/raw-project"));
1912 assert_eq!(session.project_name(&config), "raw-project");
1913
1914 session.project_directory = Some(PathBuf::from(
1915 "/home/test/Projects/source/.mj/worktrees/0123456789abcdef",
1916 ));
1917 session.managed_worktree = Some(ManagedWorktree {
1918 source_project_directory: PathBuf::from("/home/test/Projects/source"),
1919 source_repository: PathBuf::from("/home/test/Projects/source"),
1920 worktree_root: PathBuf::from(
1921 "/home/test/Projects/source/.mj/worktrees/0123456789abcdef",
1922 ),
1923 branch: "mj/0123456789abcdef".into(),
1924 target: ManagedWorktreeTarget::Local,
1925 base_commit: None,
1926 });
1927 assert_eq!(session.project_name(&config), "source");
1928 }
1929
1930 #[test]
1931 fn bundle_project_name_uses_the_primary_github_repository_name() {
1932 let mut config = sample_config();
1933 config.bundles.insert(
1934 "bifrost".into(),
1935 ProjectBundle {
1936 primary_repo: "bifrost".into(),
1937 repositories: vec![ProjectRepository {
1938 id: "bifrost".into(),
1939 github: Some("BrokkAi/bifrost-dev".into()),
1940 local: None,
1941 destination: PathBuf::from("bifrost"),
1942 git_ref: None,
1943 }],
1944 },
1945 );
1946 let mut session = sample_session();
1947 session.bundle_id = "bifrost".into();
1948
1949 assert_eq!(session.project_name(&config), "bifrost-dev");
1950 assert_eq!(
1951 session.project_source(&config),
1952 ProjectSourceIdentity {
1953 key: "github:brokkai/bifrost-dev".into(),
1954 short: "bifrost-dev".into(),
1955 full: "BrokkAi/bifrost-dev".into(),
1956 }
1957 );
1958 }
1959
1960 #[test]
1961 fn bundle_project_name_uses_a_local_source_or_bundle_id_fallback() {
1962 let mut config = sample_config();
1963 config.bundles.insert(
1964 "local-bundle".into(),
1965 ProjectBundle {
1966 primary_repo: "local".into(),
1967 repositories: vec![ProjectRepository {
1968 id: "local".into(),
1969 github: None,
1970 local: Some(PathBuf::from("/home/test/Projects/bifrost-dev")),
1971 destination: PathBuf::from("bifrost"),
1972 git_ref: None,
1973 }],
1974 },
1975 );
1976 let mut session = sample_session();
1977 session.bundle_id = "local-bundle".into();
1978
1979 assert_eq!(session.project_name(&config), "bifrost-dev");
1980 assert_eq!(
1981 session.project_source(&config),
1982 ProjectSourceIdentity {
1983 key: "path:/home/test/Projects/bifrost-dev".into(),
1984 short: "bifrost-dev".into(),
1985 full: "/home/test/Projects/bifrost-dev".into(),
1986 }
1987 );
1988
1989 session.bundle_id = "missing-bundle".into();
1990 assert_eq!(session.project_name(&config), "missing-bundle");
1991 assert_eq!(
1992 session.project_source(&config),
1993 ProjectSourceIdentity {
1994 key: "bundle:missing-bundle".into(),
1995 short: "missing-bundle".into(),
1996 full: "missing-bundle".into(),
1997 }
1998 );
1999
2000 let mut other_missing = session.clone();
2001 other_missing.bundle_id = "another-missing-bundle".into();
2002 assert_ne!(
2003 session.project_source(&config).key,
2004 other_missing.project_source(&config).key
2005 );
2006 }
2007
2008 #[test]
2009 fn project_target_adds_the_raw_project_name_only_for_bare_targets() {
2010 let mut config = sample_config();
2011 config
2012 .targets
2013 .insert("localhost".into(), TargetTemplate::LocalBare);
2014 let mut session = sample_session();
2015 session.project_directory = Some(PathBuf::from("/mnt/optane/bifrost-fird"));
2016
2017 assert_eq!(session.project_target(&config, "podman"), "podman");
2018 assert_eq!(
2019 session.project_target(&config, "localhost"),
2020 "localhost/bifrost-fird"
2021 );
2022 assert_eq!(
2023 session.project_target(&config, "retired-target"),
2024 "retired-target"
2025 );
2026 }
2027
2028 #[test]
2029 fn project_source_uses_bundle_repository_and_ignores_managed_worktree_destinations() {
2030 let config = sample_config();
2031 let mut session = sample_session();
2032 let source = session.project_source(&config);
2033 assert_eq!(source.key, "github:brokkai/hel");
2034 assert_eq!(source.short, "hel");
2035 assert_eq!(source.full, "BrokkAi/hel");
2036 assert_eq!(
2037 ProjectSourceIdentity::git_remote("git@github.com:BrokkAi/bifrost-dev.git"),
2038 ProjectSourceIdentity::git_remote("https://github.com/BrokkAi/bifrost-dev.git")
2039 );
2040 assert_ne!(
2041 ProjectSourceIdentity::git_remote("BrokkAi/bifrost-dev"),
2042 ProjectSourceIdentity::git_remote("OtherOrg/bifrost-dev")
2043 );
2044
2045 session.project_directory = Some(PathBuf::from(
2046 "/home/test/Projects/source/.mj/worktrees/0123456789abcdef",
2047 ));
2048 session.managed_worktree = Some(ManagedWorktree {
2049 source_project_directory: PathBuf::from("/home/test/Projects/source/crate"),
2050 source_repository: PathBuf::from("/home/test/Projects/source"),
2051 worktree_root: PathBuf::from(
2052 "/home/test/Projects/source/.mj/worktrees/0123456789abcdef",
2053 ),
2054 branch: "mj/0123456789abcdef".into(),
2055 target: ManagedWorktreeTarget::Local,
2056 base_commit: None,
2057 });
2058 let source = session.project_source(&config);
2059 assert_eq!(source.short, "source");
2060 assert_eq!(source.full, "/home/test/Projects/source");
2061 assert!(!source.full.contains(".mj/worktrees"));
2062 }
2063
2064 #[test]
2065 fn single_repository_bundle_uses_the_standalone_repository_identity() {
2066 let mut config = sample_config();
2067 let shared_bundle = config.bundles["hel"].clone();
2068 config.bundles.insert("other".into(), shared_bundle);
2069
2070 let first = sample_session();
2071 let mut second = first.clone();
2072 second.bundle_id = "other".into();
2073
2074 assert_eq!(
2075 config.bundles["hel"].primary_repo,
2076 config.bundles["other"].primary_repo
2077 );
2078 let first_source = first.project_source(&config);
2079 let second_source = second.project_source(&config);
2080 let standalone = ProjectSourceIdentity::git_remote("BrokkAi/hel").unwrap();
2081 assert_eq!(first_source, standalone);
2082 assert_eq!(second_source, standalone);
2083 }
2084
2085 #[test]
2086 fn multi_repository_bundles_include_all_repositories_in_sorted_identity_order() {
2087 let mut config = sample_config();
2088 let primary = config.bundles["hel"].repositories[0].clone();
2089 let secondary = ProjectRepository {
2090 id: "docs".into(),
2091 github: Some("BrokkAi/docs".into()),
2092 local: None,
2093 destination: PathBuf::from("docs"),
2094 git_ref: None,
2095 };
2096 config.bundles.insert(
2097 "with-docs".into(),
2098 ProjectBundle {
2099 primary_repo: primary.id.clone(),
2100 repositories: vec![primary.clone(), secondary.clone()],
2101 },
2102 );
2103 let mut session = sample_session();
2104 session.bundle_id = "with-docs".into();
2105
2106 assert_eq!(session.project_name(&config), "docs + hel");
2107 assert_eq!(
2108 session.project_source(&config),
2109 ProjectSourceIdentity {
2110 key: "bundle:[\"github:brokkai/docs\",\"github:brokkai/hel\"]".into(),
2111 short: "docs + hel".into(),
2112 full: "BrokkAi/docs + BrokkAi/hel".into(),
2113 }
2114 );
2115
2116 let mut other_secondary = secondary;
2117 other_secondary.github = Some("OtherOrg/docs".into());
2118 config.bundles.insert(
2119 "with-other-docs".into(),
2120 ProjectBundle {
2121 primary_repo: primary.id.clone(),
2122 repositories: vec![primary, other_secondary],
2123 },
2124 );
2125 let mut other_session = session.clone();
2126 other_session.bundle_id = "with-other-docs".into();
2127 assert_ne!(
2128 session.project_source(&config).key,
2129 other_session.project_source(&config).key
2130 );
2131 }
2132
2133 #[test]
2134 fn multi_repository_bundle_identity_ignores_repository_order_and_primary_selection() {
2135 let mut config = sample_config();
2136 let primary = config.bundles["hel"].repositories[0].clone();
2137 let secondary = ProjectRepository {
2138 id: "docs".into(),
2139 github: Some("BrokkAi/docs".into()),
2140 local: None,
2141 destination: PathBuf::from("docs"),
2142 git_ref: None,
2143 };
2144 config.bundles.insert(
2145 "first-order".into(),
2146 ProjectBundle {
2147 primary_repo: primary.id.clone(),
2148 repositories: vec![primary.clone(), secondary.clone()],
2149 },
2150 );
2151 config.bundles.insert(
2152 "second-order".into(),
2153 ProjectBundle {
2154 primary_repo: secondary.id.clone(),
2155 repositories: vec![secondary, primary],
2156 },
2157 );
2158
2159 let mut first = sample_session();
2160 first.bundle_id = "first-order".into();
2161 let mut second = first.clone();
2162 second.bundle_id = "second-order".into();
2163 assert_eq!(
2164 first.project_source(&config),
2165 second.project_source(&config)
2166 );
2167 }
2168
2169 #[test]
2170 fn duplicate_repository_sources_collapse_to_the_single_repository_identity() {
2171 let mut config = sample_config();
2172 let primary = config.bundles["hel"].repositories[0].clone();
2173 let duplicate = ProjectRepository {
2174 id: "hel-copy".into(),
2175 github: primary.github.clone(),
2176 local: None,
2177 destination: PathBuf::from("hel-copy"),
2178 git_ref: None,
2179 };
2180 config.bundles.insert(
2181 "duplicate".into(),
2182 ProjectBundle {
2183 primary_repo: primary.id.clone(),
2184 repositories: vec![primary, duplicate],
2185 },
2186 );
2187 let mut session = sample_session();
2188 session.bundle_id = "duplicate".into();
2189
2190 let source = session.project_source(&config);
2191 assert_eq!(
2192 source,
2193 ProjectSourceIdentity::git_remote("BrokkAi/hel").unwrap()
2194 );
2195 }
2196
2197 #[test]
2198 fn unresolved_bundle_repository_uses_the_bundle_fallback() {
2199 let mut config = sample_config();
2200 config.bundles.insert(
2201 "incomplete".into(),
2202 ProjectBundle {
2203 primary_repo: "broken".into(),
2204 repositories: vec![ProjectRepository {
2205 id: "broken".into(),
2206 github: None,
2207 local: None,
2208 destination: PathBuf::from("broken"),
2209 git_ref: None,
2210 }],
2211 },
2212 );
2213 let mut session = sample_session();
2214 session.bundle_id = "incomplete".into();
2215
2216 assert_eq!(session.project_name(&config), "incomplete");
2217 assert_eq!(
2218 session.project_source(&config),
2219 ProjectSourceIdentity {
2220 key: "bundle:incomplete".into(),
2221 short: "incomplete".into(),
2222 full: "incomplete".into(),
2223 }
2224 );
2225 }
2226
2227 #[test]
2228 fn sessions_order_by_creation_time_and_fall_back_to_the_id() {
2229 let older = sample_session();
2230 let mut newer = sample_session();
2231 newer.id = "0000000000000001".into();
2232 newer.created_at = "2026-08-09T13:00:00Z".into();
2233 let mut unparsable = sample_session();
2234 unparsable.id = "0000000000000002".into();
2235 unparsable.created_at = "not a timestamp".into();
2236 let mut same_time = sample_session();
2237 same_time.id = "zzzzzzzzzzzzzzzz".into();
2238
2239 let mut sessions = [&unparsable, &newer, &same_time, &older];
2240 sessions.sort_by(|left, right| left.compare_by_creation(right));
2241
2242 assert_eq!(
2243 sessions
2244 .iter()
2245 .map(|session| &session.id)
2246 .collect::<Vec<_>>(),
2247 [&older.id, &same_time.id, &newer.id, &unparsable.id]
2248 );
2249 }
2250
2251 #[test]
2252 fn retired_checkpoint_and_detach_cursor_names_are_rejected() {
2253 let session_id = "0123456789abcdef";
2254
2255 let mut old_checkpoint = serde_json::to_value(sample_state()).unwrap();
2256 let checkpoint = old_checkpoint["sessions"][session_id]["checkpoint"]
2257 .as_object_mut()
2258 .unwrap();
2259 let frontier = checkpoint.remove("event_frontier").unwrap();
2260 checkpoint.insert("event_sequence".into(), frontier);
2261 assert!(serde_json::from_value::<State>(old_checkpoint).is_err());
2262
2263 let mut old_detach_cursor = serde_json::to_value(sample_state()).unwrap();
2264 let session = old_detach_cursor["sessions"][session_id]
2265 .as_object_mut()
2266 .unwrap();
2267 let ordinal = session.remove("viewed_through_event_ordinal").unwrap();
2268 session.insert("last_viewed_event_sequence".into(), ordinal);
2269 assert!(serde_json::from_value::<State>(old_detach_cursor).is_err());
2270 }
2271
2272 #[test]
2273 fn detached_cursor_field_loads_as_the_viewed_cursor() {
2274 let session_id = "0123456789abcdef";
2275 let mut legacy = serde_json::to_value(sample_state()).unwrap();
2276 let session = legacy["sessions"][session_id].as_object_mut().unwrap();
2277 let ordinal = session.remove("viewed_through_event_ordinal").unwrap();
2278 session.insert("detached_after_event_ordinal".into(), ordinal);
2279
2280 let loaded: State = serde_json::from_value(legacy).unwrap();
2281 assert_eq!(
2282 loaded.sessions[session_id].viewed_through_event_ordinal,
2283 sample_state().sessions[session_id].viewed_through_event_ordinal
2284 );
2285 }
2286
2287 #[test]
2288 fn state_written_before_drafts_loads_with_an_empty_draft() {
2289 let session_id = "0123456789abcdef";
2290 let mut without_draft = serde_json::to_value(sample_state()).unwrap();
2291 let session = without_draft["sessions"][session_id]
2292 .as_object_mut()
2293 .unwrap();
2294 session.remove("draft_input");
2295
2296 let state = serde_json::from_value::<State>(without_draft).unwrap();
2297 assert_eq!(state.sessions[session_id].draft_input, "");
2298 }
2299
2300 #[test]
2301 fn json_state_round_trip_is_atomic() {
2302 let directory = tempfile::tempdir().unwrap();
2303 let path = directory.path().join("nested/state.json");
2304 let state = sample_state();
2305 state.save_to(&path).unwrap();
2306 assert_eq!(State::load_from(&path).unwrap(), state);
2307 assert!(
2308 fs::read_dir(directory.path().join("nested"))
2309 .unwrap()
2310 .all(|entry| {
2311 !entry
2312 .unwrap()
2313 .file_name()
2314 .to_string_lossy()
2315 .ends_with(".tmp")
2316 })
2317 );
2318 }
2319
2320 #[test]
2321 fn mount_history_keeps_unique_recent_sources_per_host() {
2322 let mut state = State::default();
2323 state.remember_mount_sources(
2324 "builder.example.test",
2325 &[
2326 AdditionalMount {
2327 source: "/srv/first".into(),
2328 destination: "/mnt/first".into(),
2329 read_only: false,
2330 },
2331 AdditionalMount {
2332 source: "/srv/second".into(),
2333 destination: "/mnt/second".into(),
2334 read_only: false,
2335 },
2336 ],
2337 );
2338 state.remember_mount_sources(
2339 "builder.example.test",
2340 &[AdditionalMount {
2341 source: "/srv/first".into(),
2342 destination: "/mnt/again".into(),
2343 read_only: false,
2344 }],
2345 );
2346
2347 assert_eq!(
2348 state.mount_history["builder.example.test"],
2349 vec![PathBuf::from("/srv/first"), PathBuf::from("/srv/second")]
2350 );
2351 }
2352
2353 #[test]
2354 fn materialized_activity_watermark_does_not_regress_when_detail_is_removed() {
2355 let mut materialized = MaterializedSession::empty("session-1");
2356 assert_eq!(materialized.last_activity_at_ms(), None);
2357
2358 materialized.execution = MaterializedExecutionState::Running { started_at_ms: 300 };
2359 materialized.transcript.push(Arc::new(TranscriptItem {
2360 stable_id: "system:1".into(),
2361 position: 1,
2362 latest_content_event_ordinal: None,
2363 created_at_ms: 350,
2364 last_changed_at_ms: 400,
2365 body: TranscriptBody::System {
2366 text: "working".into(),
2367 },
2368 }));
2369 materialized.queued_prompts.push(MaterializedQueuedPrompt {
2370 accepted_ordinal: None,
2371 command_id: "prompt-2".into(),
2372 kind: QueuedCommandKind::Prompt,
2373 content: Vec::new(),
2374 queued_at_ms: 500,
2375 });
2376 materialized.last_activity_at_ms = Some(500);
2377 assert_eq!(materialized.last_activity_at_ms(), Some(500));
2378
2379 materialized.queued_prompts.clear();
2380 assert_eq!(materialized.last_activity_at_ms(), Some(500));
2381 materialized.transcript.clear();
2382 assert_eq!(materialized.last_activity_at_ms(), Some(500));
2383 materialized.execution = MaterializedExecutionState::Idle;
2384 assert_eq!(materialized.last_activity_at_ms(), Some(500));
2385 }
2386
2387 #[test]
2390 fn shared_transcript_items_serialize_as_plain_items() {
2391 let mut materialized = MaterializedSession::empty("session-1");
2392 materialized.applied_event_ordinal = 1;
2393 materialized.applied_event_digest = "a".repeat(64);
2394 let item = Arc::new(TranscriptItem {
2395 stable_id: "system:1".into(),
2396 position: 1,
2397 latest_content_event_ordinal: None,
2398 created_at_ms: 10,
2399 last_changed_at_ms: 10,
2400 body: TranscriptBody::System {
2401 text: "started".into(),
2402 },
2403 });
2404 materialized.transcript.push(Arc::clone(&item));
2407 let mut second = TranscriptItem::clone(&item);
2408 second.stable_id = "system:2".into();
2409 materialized.transcript.push(Arc::new(second));
2410 materialized.validate().unwrap();
2411
2412 let encoded = serde_json::to_value(&materialized).unwrap();
2413 assert_eq!(encoded["transcript"][0]["stable_id"], "system:1");
2414 assert_eq!(encoded["transcript"][0]["body"]["kind"], "system");
2415 assert_eq!(encoded["transcript"][0]["body"]["text"], "started");
2416 assert_eq!(encoded["transcript"][1]["stable_id"], "system:2");
2417
2418 let restored: MaterializedSession = serde_json::from_value(encoded).unwrap();
2419 assert_eq!(restored, materialized);
2420 }
2421
2422 #[test]
2423 fn materialized_event_frontier_requires_the_matching_digest_kind() {
2424 let mut materialized = MaterializedSession::empty("session-1");
2425 materialized.validate().unwrap();
2426
2427 materialized.applied_event_ordinal = 1;
2428 assert!(
2429 materialized
2430 .validate()
2431 .unwrap_err()
2432 .to_string()
2433 .contains("inconsistent ordinal")
2434 );
2435
2436 materialized.applied_event_digest = "A".repeat(64);
2437 assert!(
2438 materialized
2439 .validate()
2440 .unwrap_err()
2441 .to_string()
2442 .contains("lowercase SHA-256")
2443 );
2444 }
2445
2446 #[test]
2447 fn project_directory_history_is_recent_and_isolated_per_remote_host() {
2448 let mut state = State::default();
2449 state.remember_project_directory("builder-a", Path::new("/srv/one"));
2450 state.remember_project_directory("builder-a", Path::new("/srv/two"));
2451 state.remember_project_directory("builder-a", Path::new("/srv/one"));
2452 state.remember_project_directory("builder-b", Path::new("/work/other"));
2453
2454 assert_eq!(
2455 state.project_directories("builder-a"),
2456 [PathBuf::from("/srv/one"), PathBuf::from("/srv/two")]
2457 );
2458 assert_eq!(
2459 state.project_directories("builder-b"),
2460 [PathBuf::from("/work/other")]
2461 );
2462 }
2463
2464 #[test]
2465 fn setup_protects_active_dependencies_but_allows_additions_repairs_and_defaults() {
2466 let state = sample_state();
2467 let before = sample_config();
2468 let session = state.sessions.values().next().unwrap();
2469 for section in ["profile", "bundle", "target"] {
2470 let mut after = before.clone();
2471 match section {
2472 "profile" => {
2473 after.profiles.remove(&session.last_profile);
2474 }
2475 "bundle" => {
2476 after.bundles.remove(&session.bundle_id);
2477 }
2478 _ => {
2479 after.targets.remove(&session.target_template_id);
2480 }
2481 }
2482 assert!(
2483 state
2484 .validate_setup_update(&before, &after)
2485 .unwrap_err()
2486 .to_string()
2487 .contains("active session")
2488 );
2489 state.validate_setup_update(&after, &before).unwrap();
2491 }
2492 let mut after = before.clone();
2493 after.profiles.get_mut(&session.last_profile).unwrap().home = PathBuf::from("/new/home");
2494 assert!(state.validate_setup_update(&before, &after).is_err());
2495 let mut after = before.clone();
2496 after
2497 .profiles
2498 .get_mut(&session.last_profile)
2499 .unwrap()
2500 .enabled = false;
2501 after.advanced.show_stopped_sessions = !before.advanced.show_stopped_sessions;
2502 after.targets.insert(
2503 "alternative".into(),
2504 crate::config::TargetTemplate::LocalBare,
2505 );
2506 state.validate_setup_update(&before, &after).unwrap();
2507 let mut stopped = state.clone();
2508 stopped.sessions.values_mut().next().unwrap().state = SessionState::Stopped;
2509 stopped
2510 .validate_setup_update(&before, &Config::default())
2511 .unwrap();
2512 }
2513
2514 #[test]
2515 fn configuration_repair_reports_all_missing_entries_and_clears_after_restoration() {
2516 let state = sample_state();
2517 let session = state.sessions.values().next().unwrap();
2518 let mut config = sample_config();
2519 config.profiles.clear();
2520 config.bundles.clear();
2521 config.targets.clear();
2522 let issue = session.configuration_issue(&config).unwrap();
2523 assert!(issue.contains("missing profile"));
2524 assert!(issue.contains("missing bundle"));
2525 assert!(issue.contains("missing target template"));
2526 assert!(issue.contains("config.toml"));
2527 assert!(session.configuration_issue(&sample_config()).is_none());
2528 let mut raw = session.clone();
2529 raw.project_directory = Some(PathBuf::from("/project"));
2530 let mut config = sample_config();
2531 config.bundles.clear();
2532 assert!(raw.configuration_issue(&config).is_none());
2533 let mut stopped = session.clone();
2534 stopped.state = SessionState::Stopped;
2535 assert!(stopped.configuration_issue(&Config::default()).is_none());
2536 }
2537
2538 #[test]
2539 fn active_state_validates_references_and_harness_kind() {
2540 let state = sample_state();
2541 state.validate_against_config(&sample_config()).unwrap();
2542
2543 let mut config = sample_config();
2544 config.profiles.get_mut("codex-1").unwrap().kind = HarnessKind::Claude;
2545 assert!(
2546 state
2547 .validate_against_config(&config)
2548 .unwrap_err()
2549 .to_string()
2550 .contains("expects Codex")
2551 );
2552 }
2553
2554 #[test]
2557 fn the_stopped_state_reads_the_retired_archived_name_and_writes_the_new_one() {
2558 assert_eq!(
2559 serde_json::from_str::<SessionState>("\"archived\"").unwrap(),
2560 SessionState::Stopped
2561 );
2562 assert_eq!(
2563 serde_json::from_str::<SessionState>("\"stopped\"").unwrap(),
2564 SessionState::Stopped
2565 );
2566 assert_eq!(
2567 serde_json::to_string(&SessionState::Stopped).unwrap(),
2568 "\"stopped\""
2569 );
2570 assert!(!SessionState::Stopped.is_active());
2571 }
2572
2573 #[test]
2576 fn the_archived_flag_defaults_off_and_is_omitted_when_it_is_off() {
2577 let mut state = sample_state();
2578 let session = state.sessions.values_mut().next().unwrap();
2579 assert!(!session.archived);
2580 let json = serde_json::to_string(&*session).unwrap();
2581 assert!(!json.contains("archived"), "{json}");
2582
2583 session.archived = true;
2584 let json = serde_json::to_string(&*session).unwrap();
2585 assert!(json.contains("\"archived\":true"), "{json}");
2586 assert!(
2587 serde_json::from_str::<SessionRecord>(&json)
2588 .unwrap()
2589 .archived
2590 );
2591 }
2592
2593 #[test]
2594 fn stopped_session_does_not_pin_renamed_config_entries() {
2595 let mut state = sample_state();
2596 state.sessions.values_mut().next().unwrap().state = SessionState::Stopped;
2597 state.validate_against_config(&Config::default()).unwrap();
2598 }
2599
2600 #[test]
2601 fn only_inactive_sessions_can_be_removed_from_the_archive() {
2602 let mut state = sample_state();
2603 assert!(
2604 state
2605 .destroy_stopped_session("0123456789abcdef")
2606 .unwrap_err()
2607 .to_string()
2608 .contains("active session")
2609 );
2610 assert!(state.sessions.contains_key("0123456789abcdef"));
2611
2612 state.sessions.values_mut().next().unwrap().state = SessionState::Stopped;
2613 let removed = state.destroy_stopped_session("0123456789abcdef").unwrap();
2614 assert_eq!(removed.id, "0123456789abcdef");
2615 assert!(state.sessions.is_empty());
2616 }
2617
2618 #[test]
2619 fn force_removal_permits_an_active_session() {
2620 let mut state = sample_state();
2621 let removed = state.destroy_session_force("0123456789abcdef").unwrap();
2622 assert_eq!(removed.id, "0123456789abcdef");
2623 assert!(state.sessions.is_empty());
2624 assert!(
2625 state
2626 .destroy_session_force("0123456789abcdef")
2627 .unwrap_err()
2628 .to_string()
2629 .contains("unknown session")
2630 );
2631 }
2632
2633 #[test]
2634 fn harness_title_prefers_the_newest_session_info_update() {
2635 let events = vec![
2636 SequencedEvent {
2637 seq: 1,
2638 recorded_at_ms: None,
2639 request_id: None,
2640 event: WorkerEvent::Adapter {
2641 kind: "session_update".into(),
2642 payload: serde_json::json!({
2643 "type": "session_update",
2644 "update": {
2645 "sessionUpdate": "session_info_update",
2646 "title": "First title"
2647 }
2648 }),
2649 },
2650 },
2651 SequencedEvent {
2652 seq: 2,
2653 recorded_at_ms: None,
2654 request_id: None,
2655 event: WorkerEvent::Adapter {
2656 kind: "session_update".into(),
2657 payload: serde_json::json!({
2658 "type": "session_update",
2659 "update": {
2660 "sessionUpdate": "session_summary",
2661 "summary": " Build the dashboard "
2662 }
2663 }),
2664 },
2665 },
2666 ];
2667
2668 assert_eq!(
2669 harness_session_title(&events).as_deref(),
2670 Some("First title")
2671 );
2672 }
2673
2674 #[test]
2675 fn extension_session_title_is_cleaned_without_losing_available_text() {
2676 let first_prompt = format!("{}overflow", "word ".repeat(20));
2677 let expected = first_prompt.trim().to_string();
2678 let events = vec![
2679 SequencedEvent {
2680 seq: 1,
2681 recorded_at_ms: None,
2682 request_id: Some("prompt-1".into()),
2683 event: WorkerEvent::PromptAccepted {
2684 request_id: "prompt-1".into(),
2685 text: format!(" {first_prompt}\n"),
2686 attachments: vec![],
2687 },
2688 },
2689 SequencedEvent {
2690 seq: 2,
2691 recorded_at_ms: None,
2692 request_id: None,
2693 event: WorkerEvent::Adapter {
2694 kind: "session_update".into(),
2695 payload: serde_json::json!({
2696 "type": "session_update",
2697 "update": {
2698 "sessionUpdate": "session_title",
2699 "title": first_prompt
2700 }
2701 }),
2702 },
2703 },
2704 ];
2705
2706 assert_eq!(
2707 harness_session_title(&events).as_deref(),
2708 Some(expected.as_str())
2709 );
2710 }
2711
2712 #[test]
2713 fn first_prompt_is_not_used_as_an_acp_session_title() {
2714 let events = vec![SequencedEvent {
2715 seq: 1,
2716 recorded_at_ms: None,
2717 request_id: Some("prompt-1".into()),
2718 event: WorkerEvent::PromptAccepted {
2719 request_id: "prompt-1".into(),
2720 text: "Do not use me as a title".into(),
2721 attachments: vec![],
2722 },
2723 }];
2724
2725 assert_eq!(harness_session_title(&events), None);
2726 }
2727
2728 #[test]
2729 fn provisional_title_is_cleaned_and_bounded() {
2730 assert_eq!(
2731 provisional_session_title(concat!(
2732 "<mj-project-memory>private</mj-project-memory> ",
2733 " fix the flaky\nresume test "
2734 ))
2735 .as_deref(),
2736 Some("fix the flaky resume test")
2737 );
2738
2739 let prompt = format!("{}overflow", "word ".repeat(20));
2740 assert_eq!(
2741 provisional_session_title(&prompt).as_deref(),
2742 Some(format!("{}word…", "word ".repeat(11)).as_str())
2743 );
2744 }
2745
2746 #[test]
2747 fn harness_title_elides_hidden_context_instead_of_naming_the_session_from_it() {
2748 let titled = |title: &str| SequencedEvent {
2749 seq: 1,
2750 recorded_at_ms: None,
2751 request_id: None,
2752 event: WorkerEvent::Adapter {
2753 kind: "session_update".into(),
2754 payload: serde_json::json!({
2755 "type": "session_update",
2756 "update": {
2757 "sessionUpdate": "session_title",
2758 "title": title
2759 }
2760 }),
2761 },
2762 };
2763
2764 assert_eq!(
2765 harness_session_title(&[titled(concat!(
2766 "<mj-project-memory>private</mj-project-memory> ",
2767 "Visible session name"
2768 ))])
2769 .as_deref(),
2770 Some("Visible session name")
2771 );
2772 assert_eq!(
2773 harness_session_title(&[titled("<mj-project-memory>truncated")]),
2774 None
2775 );
2776 }
2777
2778 #[test]
2779 fn harness_titles_are_normalized_to_one_complete_line() {
2780 let events = vec![SequencedEvent {
2781 seq: 1,
2782 recorded_at_ms: None,
2783 request_id: None,
2784 event: WorkerEvent::Adapter {
2785 kind: "session_update".into(),
2786 payload: serde_json::json!({
2787 "type": "session_update",
2788 "update": {
2789 "sessionUpdate": "session_title",
2790 "title": "first\nsecond\tthird fourth fifth sixth seventh eighth ninth tenth eleventh twelfth thirteenth"
2791 }
2792 }),
2793 },
2794 }];
2795
2796 assert_eq!(
2797 harness_session_title(&events).as_deref(),
2798 Some(
2799 "first second third fourth fifth sixth seventh eighth ninth tenth eleventh twelfth thirteenth"
2800 )
2801 );
2802 }
2803
2804 #[test]
2805 fn locator_rejects_parent_traversal() {
2806 let mut state = sample_state();
2807 state.sessions.values_mut().next().unwrap().target = Some(TargetLocator::SshBare {
2808 host: "builder".into(),
2809 workspace: PathBuf::from("~/hel/../other"),
2810 worker_id: None,
2811 });
2812 assert!(
2813 state
2814 .validate()
2815 .unwrap_err()
2816 .to_string()
2817 .contains("safe path ending")
2818 );
2819 }
2820
2821 #[test]
2822 fn generated_session_ids_are_valid_and_distinct() {
2823 let first = new_session_id().unwrap();
2824 let second = new_session_id().unwrap();
2825 validate_id("session", &first).unwrap();
2826 assert_eq!(first.len(), 32);
2827 assert_ne!(first, second);
2828 }
2829}