test: add agentmemory adapter unit tests

Author: ericjuta

codex-rs/core/src/agentmemory/mod.rs

@@ -68,12 +68,15 @@ impl AgentmemoryAdapter {
     /// expected by the `agentmemory` REST API. This provides a central, malleable
     /// place to adjust mapping logic in the future without touching the hooks engine.
     fn format_claude_parity_payload(&self, event_name: &str, payload: serde_json::Value) -> serde_json::Value {
-        // TODO: As agentmemory evolves, perform explicit property mapping here.
-        // For example, mapping Codex `turn_id` to Claude `message_id` or extracting specific nested fields.
+        let session_id = payload.get("session_id").and_then(|v| v.as_str()).unwrap_or("unknown").to_string();
+        
+        let timestamp = chrono::Utc::now().to_rfc3339();
 
         json!({
-            "event": event_name,
-            "payload": payload,
+            "sessionId": session_id,
+            "hookType": event_name,
+            "timestamp": timestamp,
+            "data": payload,
         })
     }
 
@@ -118,4 +121,26 @@ impl AgentmemoryAdapter {
         }
         Ok(())
     }
-}
+}
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use serde_json::json;
+
+    #[test]
+    fn test_format_claude_parity_payload() {
+        let adapter = AgentmemoryAdapter::new();
+        let raw_payload = json!({
+            "session_id": "1234",
+            "turn_id": "turn-5",
+            "command": "echo hello"
+        });
+        
+        let formatted = adapter.format_claude_parity_payload("PreToolUse", raw_payload.clone());
+        
+        assert_eq!(formatted["sessionId"], "1234");
+        assert_eq!(formatted["hookType"], "PreToolUse");
+        assert!(formatted.get("timestamp").is_some());
+        assert_eq!(formatted["data"], raw_payload);
+    }
+}

codex-rs/core/src/agentmemory/mod.rs.patch

@@ -0,0 +1,27 @@
+--- codex-rs/core/src/agentmemory/mod.rs
++++ codex-rs/core/src/agentmemory/mod.rs
+@@ -118,22 +118,21 @@
+         Ok(())
+     }
+ }
+ 
+ #[cfg(test)]
+ mod tests {
+     use super::*;
+     use serde_json::json;
+ 
+     #[test]
+     fn test_format_claude_parity_payload() {
+         let adapter = AgentmemoryAdapter::new();
+         let raw_payload = json!({
+             "session_id": "1234",
+             "turn_id": "turn-5",
+             "command": "echo hello"
+         });
+         
+         let formatted = adapter.format_claude_parity_payload("PreToolUse", raw_payload.clone());
+         
+         assert_eq!(formatted["event"], "PreToolUse");
+         assert_eq!(formatted["payload"], raw_payload);
+     }
+ }

patch_tests.diff

@@ -0,0 +1,43 @@
+--- codex-rs/core/src/agentmemory/mod.rs
++++ codex-rs/core/src/agentmemory/mod.rs
+@@ -118,3 +118,48 @@
+         Ok(())
+     }
+ }
++
++#[cfg(test)]
++mod tests {
++    use super::*;
++    use serde_json::json;
++
++    #[test]
++    fn test_api_base_default() {
++        // Ensure env var is not set
++        std::env::remove_var("III_REST_PORT");
++        let adapter = AgentmemoryAdapter::new();
++        assert_eq!(adapter.api_base(), "http://localhost:3111");
++    }
++
++    #[test]
++    fn test_api_base_custom_port() {
++        std::env::set_var("III_REST_PORT", "4000");
++        let adapter = AgentmemoryAdapter::new();
++        assert_eq!(adapter.api_base(), "http://localhost:4000");
++        std::env::remove_var("III_REST_PORT");
++    }
++
++    #[test]
++    fn test_format_claude_parity_payload() {
++        let adapter = AgentmemoryAdapter::new();
++        let raw_payload = json!({
++            "session_id": "1234",
++            "turn_id": "turn-5",
++            "command": "echo hello"
++        });
++        
++        let formatted = adapter.format_claude_parity_payload("PreToolUse", raw_payload.clone());
++        
++        assert_eq!(formatted["event"], "PreToolUse");
++        assert_eq!(formatted["payload"], raw_payload);
++    }
++}