mirrors/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-05-06 06:12:59 +03:00
Code Issues Packages Projects Releases Wiki Activity

[codex-analytics] add protocol-native turn timestamps

Browse Source
This commit is contained in:
rhan-oai
2026-04-02 18:52:32 -07:00
parent 0bd31dc382
commit 3d1314ca03
23 changed files with 204 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
codex-rs/exec/src/event_processor_with_human_output_tests.rs
View File

@@ -157,6 +157,8 @@ fn turn_completed_recovers_final_message_from_turn_items() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: Turn {
id: "turn-1".to_string(),
items: vec![ThreadItem::AgentMessage {
@@ -201,6 +203,8 @@ fn turn_completed_overwrites_stale_final_message_from_turn_items() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: Turn {
id: "turn-1".to_string(),
items: vec![ThreadItem::AgentMessage {
@@ -246,6 +250,8 @@ fn turn_completed_preserves_streamed_final_message_when_turn_items_are_empty() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: Turn {
id: "turn-1".to_string(),
items: Vec::new(),
@@ -286,6 +292,8 @@ fn turn_failed_clears_stale_final_message() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: Turn {
id: "turn-1".to_string(),
items: Vec::new(),
@@ -327,6 +335,8 @@ fn turn_interrupted_clears_stale_final_message() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: Turn {
id: "turn-1".to_string(),
items: Vec::new(),

2
codex-rs/exec/src/event_processor_with_jsonl_output_tests.rs
View File

@@ -29,6 +29,8 @@ fn failed_turn_does_not_overwrite_output_last_message_file() {
let status = processor.process_server_notification(ServerNotification::TurnCompleted(
codex_app_server_protocol::TurnCompletedNotification {
thread_id: "thread-1".to_string(),
completed_at: 0,
duration_ms: None,
turn: codex_app_server_protocol::Turn {
id: "turn-1".to_string(),
items: Vec::new(),

1
codex-rs/exec/src/lib.rs
View File

@@ -717,6 +717,7 @@ async fn run_exec_session(args: ExecRunArgs) -> anyhow::Result<()> {
TurnStartedNotification {
thread_id: response.review_thread_id.clone(),
turn: response.turn.clone(),
created_at: 0,
},
));
let task_id = response.turn.id;

21
codex-rs/exec/tests/event_processor_with_json_output.rs
View File

@@ -145,6 +145,7 @@ fn turn_started_emits_turn_started_event() {
status: TurnStatus::InProgress,
error: None,
},
created_at: 0,
}));
assert_eq!(
@@ -1067,6 +1068,8 @@ fn plan_update_emits_started_then_updated_then_completed() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
assert_eq!(
@@ -1123,6 +1126,8 @@ fn plan_update_after_completion_starts_new_todo_list_with_new_id() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1202,6 +1207,8 @@ fn token_usage_update_is_emitted_on_turn_completion() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
assert_eq!(
@@ -1237,6 +1244,8 @@ fn turn_completion_recovers_final_message_from_turn_items() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1311,6 +1320,8 @@ fn turn_completion_reconciles_started_items_from_turn_items() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1368,6 +1379,8 @@ fn turn_completion_overwrites_stale_final_message_from_turn_items() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1408,6 +1421,8 @@ fn turn_completion_preserves_streamed_final_message_when_turn_items_are_empty()
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1456,6 +1471,8 @@ fn failed_turn_clears_stale_final_message() {
codex_error_info: None,
}),
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1479,6 +1496,8 @@ fn turn_completion_falls_back_to_final_plan_text() {
status: TurnStatus::Completed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
@@ -1527,6 +1546,8 @@ fn turn_failure_prefers_structured_error_message() {
status: TurnStatus::Failed,
error: None,
},
completed_at: 0,
duration_ms: None,
},
));
assert_eq!(