mirror of
https://github.com/pchuan98/codex.git
synced 2026-07-01 00:31:56 +08:00
nit: telepathy to chronicle in tests (#18652)
This commit is contained in:
committed by
GitHub
Unverified
parent
be4fe9f9b2
commit
ff6a5804d2
@@ -155,31 +155,31 @@ mod tests {
|
||||
let codex_home = TempDir::new().expect("create temp codex home");
|
||||
let memory_root = codex_home.path().join("memories");
|
||||
let extensions_root = memory_extensions_root(&memory_root);
|
||||
let telepathy_resources = extensions_root.join("telepathy/resources");
|
||||
tokio::fs::create_dir_all(&telepathy_resources)
|
||||
let chronicle_resources = extensions_root.join("chronicle/resources");
|
||||
tokio::fs::create_dir_all(&chronicle_resources)
|
||||
.await
|
||||
.expect("create telepathy resources");
|
||||
.expect("create chronicle resources");
|
||||
tokio::fs::write(
|
||||
extensions_root.join("telepathy/instructions.md"),
|
||||
extensions_root.join("chronicle/instructions.md"),
|
||||
"instructions",
|
||||
)
|
||||
.await
|
||||
.expect("write telepathy instructions");
|
||||
.expect("write chronicle instructions");
|
||||
|
||||
let now = DateTime::from_naive_utc_and_offset(
|
||||
NaiveDateTime::parse_from_str("2026-04-14T12-00-00", FILENAME_TS_FORMAT)
|
||||
.expect("parse now"),
|
||||
Utc,
|
||||
);
|
||||
let old_file = telepathy_resources.join("2026-04-06T11-59-59-abcd-10min-old.md");
|
||||
let old_file = chronicle_resources.join("2026-04-06T11-59-59-abcd-10min-old.md");
|
||||
let exact_cutoff_file =
|
||||
telepathy_resources.join("2026-04-07T12-00-00-abcd-10min-cutoff.md");
|
||||
let recent_file = telepathy_resources.join("2026-04-08T12-00-00-abcd-10min-recent.md");
|
||||
let invalid_file = telepathy_resources.join("not-a-timestamp.md");
|
||||
chronicle_resources.join("2026-04-07T12-00-00-abcd-10min-cutoff.md");
|
||||
let recent_file = chronicle_resources.join("2026-04-08T12-00-00-abcd-10min-recent.md");
|
||||
let invalid_file = chronicle_resources.join("not-a-timestamp.md");
|
||||
for file in [&old_file, &exact_cutoff_file, &recent_file, &invalid_file] {
|
||||
tokio::fs::write(file, "resource")
|
||||
.await
|
||||
.expect("write telepathy resource");
|
||||
.expect("write chronicle resource");
|
||||
}
|
||||
|
||||
let ignored_resources = extensions_root.join("ignored/resources");
|
||||
@@ -200,11 +200,11 @@ mod tests {
|
||||
.collect::<Vec<_>>(),
|
||||
vec![
|
||||
RemovedExtensionResource {
|
||||
extension: "telepathy".to_string(),
|
||||
extension: "chronicle".to_string(),
|
||||
resource_path: "resources/2026-04-06T11-59-59-abcd-10min-old.md".to_string(),
|
||||
},
|
||||
RemovedExtensionResource {
|
||||
extension: "telepathy".to_string(),
|
||||
extension: "chronicle".to_string(),
|
||||
resource_path: "resources/2026-04-07T12-00-00-abcd-10min-cutoff.md".to_string(),
|
||||
},
|
||||
]
|
||||
|
||||
@@ -64,11 +64,11 @@ fn build_consolidation_prompt_includes_removed_extension_resources() {
|
||||
std::fs::create_dir_all(temp.path().join("memories_extensions")).unwrap();
|
||||
let removed_extension_resources = vec![
|
||||
RemovedExtensionResource {
|
||||
extension: "telepathy".to_string(),
|
||||
extension: "chronicle".to_string(),
|
||||
resource_path: "resources/2026-04-06T11-59-59-abcd-10min-old.md".to_string(),
|
||||
},
|
||||
RemovedExtensionResource {
|
||||
extension: "telepathy".to_string(),
|
||||
extension: "chronicle".to_string(),
|
||||
resource_path: "resources/2026-04-07T12-00-00-abcd-10min-cutoff.md".to_string(),
|
||||
},
|
||||
];
|
||||
@@ -81,7 +81,7 @@ fn build_consolidation_prompt_includes_removed_extension_resources() {
|
||||
|
||||
assert!(prompt.contains("Memory extension resources removed by retention pruning:"));
|
||||
assert!(prompt.contains("- retention window: 7 days"));
|
||||
assert!(prompt.contains("- extension: telepathy"));
|
||||
assert!(prompt.contains("- extension: chronicle"));
|
||||
assert!(prompt.contains(" - resources/2026-04-06T11-59-59-abcd-10min-old.md"));
|
||||
assert!(prompt.contains(" - resources/2026-04-07T12-00-00-abcd-10min-cutoff.md"));
|
||||
assert!(prompt.contains("extension-specific deletion diff"));
|
||||
|
||||
@@ -1005,21 +1005,21 @@ mod phase2 {
|
||||
"stage-1 success should enqueue global consolidation"
|
||||
);
|
||||
|
||||
let telepathy_resources = config
|
||||
let chronicle_resources = config
|
||||
.codex_home
|
||||
.join("memories_extensions/telepathy/resources");
|
||||
tokio::fs::create_dir_all(&telepathy_resources)
|
||||
.join("memories_extensions/chronicle/resources");
|
||||
tokio::fs::create_dir_all(&chronicle_resources)
|
||||
.await
|
||||
.expect("create telepathy resources");
|
||||
.expect("create chronicle resources");
|
||||
tokio::fs::write(
|
||||
config
|
||||
.codex_home
|
||||
.join("memories_extensions/telepathy/instructions.md"),
|
||||
.join("memories_extensions/chronicle/instructions.md"),
|
||||
"instructions",
|
||||
)
|
||||
.await
|
||||
.expect("write telepathy instructions");
|
||||
let old_file = telepathy_resources.join(format!(
|
||||
.expect("write chronicle instructions");
|
||||
let old_file = chronicle_resources.join(format!(
|
||||
"{}-abcd-10min-old.md",
|
||||
(Utc::now() - ChronoDuration::days(8)).format("%Y-%m-%dT%H-%M-%S")
|
||||
));
|
||||
|
||||
@@ -175,11 +175,11 @@ async fn memories_startup_phase2_prunes_old_extension_resources_and_reports_them
|
||||
)
|
||||
.await?;
|
||||
|
||||
let telepathy_resources = home.path().join("memories_extensions/telepathy/resources");
|
||||
tokio::fs::create_dir_all(&telepathy_resources).await?;
|
||||
let chronicle_resources = home.path().join("memories_extensions/chronicle/resources");
|
||||
tokio::fs::create_dir_all(&chronicle_resources).await?;
|
||||
tokio::fs::write(
|
||||
home.path()
|
||||
.join("memories_extensions/telepathy/instructions.md"),
|
||||
.join("memories_extensions/chronicle/instructions.md"),
|
||||
"instructions",
|
||||
)
|
||||
.await?;
|
||||
@@ -187,9 +187,9 @@ async fn memories_startup_phase2_prunes_old_extension_resources_and_reports_them
|
||||
"{}-abcd-10min-old.md",
|
||||
(now - ChronoDuration::days(8)).format("%Y-%m-%dT%H-%M-%S")
|
||||
);
|
||||
let old_file = telepathy_resources.join(&old_file_name);
|
||||
let old_file = chronicle_resources.join(&old_file_name);
|
||||
tokio::fs::write(&old_file, "old resource").await?;
|
||||
let recent_file = telepathy_resources.join(format!(
|
||||
let recent_file = chronicle_resources.join(format!(
|
||||
"{}-abcd-10min-recent.md",
|
||||
(now - ChronoDuration::days(6)).format("%Y-%m-%dT%H-%M-%S")
|
||||
));
|
||||
@@ -218,7 +218,7 @@ async fn memories_startup_phase2_prunes_old_extension_resources_and_reports_them
|
||||
"expected retention window in prompt: {prompt}"
|
||||
);
|
||||
assert!(
|
||||
prompt.contains("- extension: telepathy"),
|
||||
prompt.contains("- extension: chronicle"),
|
||||
"expected extension name in prompt: {prompt}"
|
||||
);
|
||||
assert!(
|
||||
@@ -251,11 +251,11 @@ async fn memories_startup_phase2_processes_old_extension_resources_without_stage
|
||||
.await?;
|
||||
|
||||
let now = Utc::now();
|
||||
let telepathy_resources = home.path().join("memories_extensions/telepathy/resources");
|
||||
tokio::fs::create_dir_all(&telepathy_resources).await?;
|
||||
let chronicle_resources = home.path().join("memories_extensions/chronicle/resources");
|
||||
tokio::fs::create_dir_all(&chronicle_resources).await?;
|
||||
tokio::fs::write(
|
||||
home.path()
|
||||
.join("memories_extensions/telepathy/instructions.md"),
|
||||
.join("memories_extensions/chronicle/instructions.md"),
|
||||
"instructions",
|
||||
)
|
||||
.await?;
|
||||
@@ -263,7 +263,7 @@ async fn memories_startup_phase2_processes_old_extension_resources_without_stage
|
||||
"{}-abcd-10min-old.md",
|
||||
(now - ChronoDuration::days(8)).format("%Y-%m-%dT%H-%M-%S")
|
||||
);
|
||||
let old_file = telepathy_resources.join(&old_file_name);
|
||||
let old_file = chronicle_resources.join(&old_file_name);
|
||||
tokio::fs::write(&old_file, "old resource").await?;
|
||||
|
||||
let phase2 = mount_sse_once(
|
||||
|
||||
Reference in New Issue
Block a user