feat: ensure memory commands pass through to agentmemory natively without bridging

This implements PR 7 of the agentmemory replacement spec.
It routes the legacy UpdateMemories and DropMemories operations directly
to the agentmemory adapter when configured. The interactive TUI slash
commands and CLI debug commands (like `codex debug clear-memories`)
will now gracefully flush the agentmemory instance instead of
the native Codex database.

Author: ericjuta

codex-rs/cli/src/main.rs

@@ -1095,6 +1095,13 @@ async fn run_debug_clear_memories_command(
     let config =
         Config::load_with_cli_overrides_and_harness_overrides(cli_kv_overrides, overrides).await?;
 
+    if config.memories.backend == codex_core::config::types::MemoryBackend::Agentmemory {
+        let adapter = codex_core::agentmemory::AgentmemoryAdapter::new();
+        adapter.drop_memories().await.map_err(anyhow::Error::msg)?;
+        println!("Cleared Agentmemory store.");
+        return Ok(());
+    }
+
     let state_path = state_db_path(config.sqlite_home.as_path());
     let mut cleared_state_db = false;
     if tokio::fs::try_exists(&state_path).await? {

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

@@ -44,4 +44,16 @@ impl AgentmemoryAdapter {
         // The payload will typically be a hook request (e.g. `PostToolUseRequest`).
         // This is a stub for future PRs.
     }
+
+    /// Asynchronously triggers a memory refresh/update operation in `agentmemory`.
+    pub async fn update_memories(&self) -> Result<(), String> {
+        // TODO: Call agentmemory's sync/refresh endpoint.
+        Ok(())
+    }
+
+    /// Asynchronously drops/clears the memory store in `agentmemory`.
+    pub async fn drop_memories(&self) -> Result<(), String> {
+        // TODO: Call agentmemory's clear/drop endpoint.
+        Ok(())
+    }
 }

codex-rs/core/src/codex.rs

@@ -5064,6 +5064,29 @@ mod handlers {
     }
 
     pub async fn drop_memories(sess: &Arc<Session>, config: &Arc<Config>, sub_id: String) {
+        if config.memories.backend == crate::config::types::MemoryBackend::Agentmemory {
+            let adapter = crate::agentmemory::AgentmemoryAdapter::new();
+            if let Err(e) = adapter.drop_memories().await {
+                sess.send_event_raw(Event {
+                    id: sub_id,
+                    msg: EventMsg::Error(ErrorEvent {
+                        message: format!("Agentmemory clear failed: {e}"),
+                        codex_error_info: Some(CodexErrorInfo::Other),
+                    }),
+                })
+                .await;
+                return;
+            }
+            sess.send_event_raw(Event {
+                id: sub_id,
+                msg: EventMsg::Warning(WarningEvent {
+                    message: "Cleared Agentmemory contents.".to_string(),
+                }),
+            })
+            .await;
+            return;
+        }
+
         let mut errors = Vec::new();
 
         if let Some(state_db) = sess.services.state_db.as_deref() {
@@ -5112,6 +5135,29 @@ mod handlers {
             state.session_configuration.session_source.clone()
         };
 
+        if config.memories.backend == crate::config::types::MemoryBackend::Agentmemory {
+            let adapter = crate::agentmemory::AgentmemoryAdapter::new();
+            if let Err(e) = adapter.update_memories().await {
+                sess.send_event_raw(Event {
+                    id: sub_id.clone(),
+                    msg: EventMsg::Error(ErrorEvent {
+                        message: format!("Agentmemory sync failed: {e}"),
+                        codex_error_info: Some(CodexErrorInfo::Other),
+                    }),
+                })
+                .await;
+                return;
+            }
+            sess.send_event_raw(Event {
+                id: sub_id.clone(),
+                msg: EventMsg::Warning(WarningEvent {
+                    message: "Agentmemory sync triggered.".to_string(),
+                }),
+            })
+            .await;
+            return;
+        }
+
         if config.memories.backend == crate::config::types::MemoryBackend::Native {
             crate::memories::start_memories_startup_task(sess, Arc::clone(config), &session_source);
         }

codex-rs/tui/src/bottom_pane/chat_composer.rs

@@ -409,6 +409,7 @@ pub(crate) struct ChatComposer {
     realtime_conversation_enabled: bool,
     audio_device_selection_enabled: bool,
     windows_degraded_sandbox_active: bool,
+    agentmemory_enabled: bool,
     status_line_value: Option<Line<'static>>,
     status_line_enabled: bool,
     // Agent label injected into the footer's contextual row when multi-agent mode is active.
@@ -448,6 +449,7 @@ impl ChatComposer {
             realtime_conversation_enabled: self.realtime_conversation_enabled,
             audio_device_selection_enabled: self.audio_device_selection_enabled,
             allow_elevate_sandbox: self.windows_degraded_sandbox_active,
+            agentmemory_enabled: self.agentmemory_enabled,
         }
     }
 
@@ -533,6 +535,7 @@ impl ChatComposer {
             realtime_conversation_enabled: false,
             audio_device_selection_enabled: false,
             windows_degraded_sandbox_active: false,
+            agentmemory_enabled: false,
             status_line_value: None,
             status_line_enabled: false,
             active_agent_label: None,
@@ -662,6 +665,10 @@ impl ChatComposer {
     pub fn set_windows_degraded_sandbox_active(&mut self, enabled: bool) {
         self.windows_degraded_sandbox_active = enabled;
     }
+
+    pub fn set_agentmemory_enabled(&mut self, enabled: bool) {
+        self.agentmemory_enabled = enabled;
+    }
     fn layout_areas(&self, area: Rect) -> [Rect; 4] {
         let footer_props = self.footer_props();
         let footer_hint_height = self
@@ -3500,6 +3507,7 @@ impl ChatComposer {
                             realtime_conversation_enabled,
                             audio_device_selection_enabled,
                             windows_degraded_sandbox_active: self.windows_degraded_sandbox_active,
+                            agentmemory_enabled: self.agentmemory_enabled,
                         },
                     );
                     command_popup.on_composer_text_change(first_line.to_string());

codex-rs/tui/src/bottom_pane/command_popup.rs

@@ -44,6 +44,7 @@ pub(crate) struct CommandPopupFlags {
     pub(crate) realtime_conversation_enabled: bool,
     pub(crate) audio_device_selection_enabled: bool,
     pub(crate) windows_degraded_sandbox_active: bool,
+    pub(crate) agentmemory_enabled: bool,
 }
 
 impl From<CommandPopupFlags> for slash_commands::BuiltinCommandFlags {
@@ -57,6 +58,7 @@ impl From<CommandPopupFlags> for slash_commands::BuiltinCommandFlags {
             realtime_conversation_enabled: value.realtime_conversation_enabled,
             audio_device_selection_enabled: value.audio_device_selection_enabled,
             allow_elevate_sandbox: value.windows_degraded_sandbox_active,
+            agentmemory_enabled: value.agentmemory_enabled,
         }
     }
 }

codex-rs/tui/src/bottom_pane/mod.rs

@@ -302,6 +302,11 @@ impl BottomPane {
         self.request_redraw();
     }
 
+    pub fn set_agentmemory_enabled(&mut self, enabled: bool) {
+        self.composer.set_agentmemory_enabled(enabled);
+        self.request_redraw();
+    }
+
     pub fn set_collaboration_mode_indicator(
         &mut self,
         indicator: Option<CollaborationModeIndicator>,

codex-rs/tui/src/bottom_pane/slash_commands.rs

@@ -20,6 +20,7 @@ pub(crate) struct BuiltinCommandFlags {
     pub(crate) realtime_conversation_enabled: bool,
     pub(crate) audio_device_selection_enabled: bool,
     pub(crate) allow_elevate_sandbox: bool,
+    pub(crate) agentmemory_enabled: bool,
 }
 
 /// Return the built-ins that should be visible/usable for the current input.
@@ -37,6 +38,7 @@ pub(crate) fn builtins_for_input(flags: BuiltinCommandFlags) -> Vec<(&'static st
         .filter(|(_, cmd)| flags.personality_command_enabled || *cmd != SlashCommand::Personality)
         .filter(|(_, cmd)| flags.realtime_conversation_enabled || *cmd != SlashCommand::Realtime)
         .filter(|(_, cmd)| flags.audio_device_selection_enabled || *cmd != SlashCommand::Settings)
+        .filter(|(_, cmd)| !flags.agentmemory_enabled || !matches!(*cmd, SlashCommand::MemoryDrop | SlashCommand::MemoryUpdate))
         .collect()
 }
 

codex-rs/tui/src/chatwidget.rs

@@ -3833,6 +3833,9 @@ impl ChatWidget {
         widget.bottom_pane.set_voice_transcription_enabled(
             widget.config.features.enabled(Feature::VoiceTranscription),
         );
+        widget.bottom_pane.set_agentmemory_enabled(
+            widget.config.memories.backend == codex_core::config::types::MemoryBackend::Agentmemory
+        );
         widget
             .bottom_pane
             .set_realtime_conversation_enabled(widget.realtime_conversation_enabled());
@@ -4037,6 +4040,9 @@ impl ChatWidget {
         widget.bottom_pane.set_voice_transcription_enabled(
             widget.config.features.enabled(Feature::VoiceTranscription),
         );
+        widget.bottom_pane.set_agentmemory_enabled(
+            widget.config.memories.backend == codex_core::config::types::MemoryBackend::Agentmemory
+        );
         widget
             .bottom_pane
             .set_realtime_conversation_enabled(widget.realtime_conversation_enabled());
@@ -4233,6 +4239,9 @@ impl ChatWidget {
         widget.bottom_pane.set_voice_transcription_enabled(
             widget.config.features.enabled(Feature::VoiceTranscription),
         );
+        widget.bottom_pane.set_agentmemory_enabled(
+            widget.config.memories.backend == codex_core::config::types::MemoryBackend::Agentmemory
+        );
         widget
             .bottom_pane
             .set_realtime_conversation_enabled(widget.realtime_conversation_enabled());