feat(session-viewer): hide subagent sessions, add FTS5 search, pagination, and loop commands

Cargo.toml

@@ -59,11 +59,10 @@ machineid-rs = "1.2.4"
 mockito = "1.7.2"
 nom = "8.0.0"
 nu-ansi-term = "0.50.1"
-posthog-rs = "0.7.0"
+posthog-rs = "0.12.0"
 pretty_assertions = "1.4.1"
 proc-macro2 = "1.0"
 quote = "1.0"
-reedline = "0.48.0"
 rustyline = "18.0.0"
 regex = "1.12.3"
 reqwest = { version = "0.12.23", features = [
@@ -121,9 +120,8 @@ whoami = "2.1.0"
 fnv_rs = "0.4.3"
 merge = { version = "0.2", features = ["derive"] }
 hex = "0.4.3"
-rmcp = { version = "0.10.0", features = [
+rmcp = { version = "1.0.0", features = [
     "client",
-    "transport-sse-client-reqwest",
     "transport-child-process",
     "transport-streamable-http-client-reqwest",
     "auth",
@@ -135,7 +133,7 @@ gray_matter = "0.3.2"
 num-format = "0.4"
 humantime = "2.1.0"
 dashmap = "7.0.0-rc2"
-async-openai = { version = "0.34.0", default-features = false, features = ["response-types"] } # Using only types, not the API client - reduces dependencies
+async-openai = { version = "0.41.0", default-features = false, features = ["response-types"] } # Using only types, not the API client - reduces dependencies
 gix = "0.84"
 google-cloud-auth = "1.8.0" # Google Cloud authentication with automatic token refresh
 

crates/forge_api/src/api.rs

@@ -79,6 +79,25 @@ pub trait API: Sync + Send {
     /// Returns an error if the operation fails
     async fn delete_conversation(&self, conversation_id: &ConversationId) -> Result<()>;
 
+    /// Lists all subagent conversations for a given parent conversation
+    async fn get_subagents(
+        &self,
+        parent_id: &ConversationId,
+    ) -> Result<Vec<Conversation>>;
+
+    /// Lists all top-level (parent) conversations, excluding subagents
+    async fn get_parent_conversations(
+        &self,
+        limit: Option<usize>,
+    ) -> Result<Vec<Conversation>>;
+
+    /// Lists conversations by source (e.g., "interactive", "headless", "forge-p")
+    async fn get_conversations_by_source(
+        &self,
+        source: &str,
+        limit: Option<usize>,
+    ) -> Result<Vec<Conversation>>;
+
     /// Renames a conversation by setting its title
     ///
     /// # Arguments

crates/forge_api/src/forge_api.rs

@@ -192,6 +192,40 @@ impl<
         self.services.delete_conversation(conversation_id).await
     }
 
+    async fn get_subagents(
+        &self,
+        parent_id: &ConversationId,
+    ) -> Result<Vec<Conversation>> {
+        Ok(self
+            .services
+            .get_conversations_by_parent(parent_id)
+            .await?
+            .unwrap_or_default())
+    }
+
+    async fn get_parent_conversations(
+        &self,
+        limit: Option<usize>,
+    ) -> Result<Vec<Conversation>> {
+        Ok(self
+            .services
+            .get_parent_conversations(limit)
+            .await?
+            .unwrap_or_default())
+    }
+
+    async fn get_conversations_by_source(
+        &self,
+        source: &str,
+        limit: Option<usize>,
+    ) -> Result<Vec<Conversation>> {
+        Ok(self
+            .services
+            .get_conversations_by_source(source, limit)
+            .await?
+            .unwrap_or_default())
+    }
+
     async fn rename_conversation(
         &self,
         conversation_id: &ConversationId,

crates/forge_app/src/agent_executor.rs

@@ -45,6 +45,7 @@ impl<S: Services + EnvironmentInfra<Config = forge_config::ForgeConfig>> AgentEx
         task: String,
         ctx: &ToolCallContext,
         conversation_id: Option<ConversationId>,
+        parent_id: Option<ConversationId>,
     ) -> anyhow::Result<ToolOutput> {
         ctx.send_tool_input(
             TitleFormat::debug(format!(
@@ -66,9 +67,15 @@ impl<S: Services + EnvironmentInfra<Config = forge_config::ForgeConfig>> AgentEx
             // Create context with agent initiator since it's spawned by a parent agent
             // This is crucial for GitHub Copilot billing optimization
             let context = forge_domain::Context::default().initiator("agent".to_string());
-            let conversation = Conversation::generate()
+            let mut conversation = Conversation::generate()
                 .title(task.clone())
                 .context(context.clone());
+            if let Some(parent) = parent_id {
+                conversation.parent_id = Some(parent);
+            }
+            if let Some(source) = ctx.source() {
+                conversation.source = Some(source.to_string());
+            }
             self.services
                 .conversation_service()
                 .upsert_conversation(conversation.clone())

crates/forge_app/src/dto/anthropic/response.rs

@@ -34,6 +34,8 @@ impl From<Model> for forge_domain::Model {
             || value.id.contains("claude-sonnet")
             || value.id.contains("claude-opus")
             || value.id.contains("claude-haiku")
+            || value.id.contains("claude-mythos")
+            || value.id.contains("claude-fable")
         {
             vec![
                 forge_domain::InputModality::Text,
@@ -77,6 +79,11 @@ impl From<Model> for forge_domain::Model {
 ///   header
 /// - Legacy models may have different context lengths
 fn get_context_length(model_id: &str) -> Option<u64> {
+    // Claude Mythos / Fable models (1M context)
+    if model_id.starts_with("claude-mythos") || model_id.starts_with("claude-fable") {
+        return Some(1_000_000);
+    }
+
     // Current models (200K context)
     if model_id.starts_with("claude-sonnet-4-5-")
         || model_id.starts_with("claude-haiku-4-5-")

crates/forge_app/src/dto/openai/transformers/minimax.rs

@@ -4,38 +4,45 @@ use crate::dto::openai::Request;
 
 /// Transformer that applies minimax-specific parameter adjustments
 ///
-/// Minimax M2 models require specific temperature, top_p, and top_k values
+/// Minimax models require specific temperature, top_p, and top_k values
 /// for optimal performance:
 /// - Temperature: 1.0
 /// - Top P: 0.95
-/// - Top K: 40 (for m2.1), 20 (for other m2 models)
+/// - Top K: 40 (for m2.1), 20 (for all other models including M2, M2.5, M2.7,
+///   M3)
+///
+/// These parameters are based on official MiniMax evaluation methodology
+/// (see VideoMMMU, Video-MME benchmarks in M3 blog post).
 pub struct SetMinimaxParams;
 
 impl Transformer for SetMinimaxParams {
     type Value = Request;
 
     fn transform(&mut self, mut request: Self::Value) -> Self::Value {
-        // Check if model is a minimax-m2 model
         let model_id = request
             .model
             .as_ref()
             .map(|m| m.as_str().to_lowercase())
             .unwrap_or_default();
 
-        if !model_id.contains("minimax-m2") {
+        // Match MiniMax model patterns (minimax-m2, minimax-m3, etc.)
+        let is_minimax = model_id.contains("minimax-m2") || model_id.contains("minimax-m3");
+
+        if !is_minimax {
             return request;
         }
 
-        // Set temperature to 1.0 for minimax-m2 models
+        // Set temperature to 1.0 for minimax models
         request.temperature = Some(1.0);
 
-        // Set top_p to 0.95 for minimax-m2 models
+        // Set top_p to 0.95 for minimax models
         request.top_p = Some(0.95);
 
         // Set top_k based on model variant
         if model_id.contains("minimax-m2.1") {
             request.top_k = Some(40);
         } else {
+            // M2, M2.5, M2.7, M3 all use top_k = 20
             request.top_k = Some(20);
         }
 
@@ -145,4 +152,37 @@ mod tests {
         assert_eq!(actual.top_p, fixture.top_p);
         assert_eq!(actual.top_k, fixture.top_k);
     }
+
+    #[test]
+    fn test_minimax_m3_sets_parameters() {
+        let fixture = create_request_fixture("minimax-m3");
+        let mut transformer = SetMinimaxParams;
+        let actual = transformer.transform(fixture);
+
+        assert_eq!(actual.temperature, Some(1.0));
+        assert_eq!(actual.top_p, Some(0.95));
+        assert_eq!(actual.top_k, Some(20)); // M3 uses same config as M2.7
+    }
+
+    #[test]
+    fn test_minimax_m3_case_insensitive() {
+        let fixture = create_request_fixture("MiniMax-M3");
+        let mut transformer = SetMinimaxParams;
+        let actual = transformer.transform(fixture);
+
+        assert_eq!(actual.temperature, Some(1.0));
+        assert_eq!(actual.top_p, Some(0.95));
+        assert_eq!(actual.top_k, Some(20)); // M3 uses same config as M2.7
+    }
+
+    #[test]
+    fn test_minimax_m3_bedrock_provider_id() {
+        let fixture = create_request_fixture("minimax.minimax-m3");
+        let mut transformer = SetMinimaxParams;
+        let actual = transformer.transform(fixture);
+
+        assert_eq!(actual.temperature, Some(1.0));
+        assert_eq!(actual.top_p, Some(0.95));
+        assert_eq!(actual.top_k, Some(20)); // M3 uses same config as M2.7
+    }
 }

crates/forge_app/src/fmt/todo_fmt.rs

@@ -21,7 +21,7 @@ fn format_todo_line(todo: &Todo, line_style: TodoLineStyle) -> String {
         TodoStatus::Completed => "󰄵",
         TodoStatus::InProgress => "󰄗",
         TodoStatus::Pending => "󰄱",
-        TodoStatus::Cancelled => "󰅙",
+        TodoStatus::Cancelled => "",
     };
 
     let content = match todo.status {

crates/forge_app/src/lib.rs

@@ -20,7 +20,7 @@ mod operation;
 mod orch;
 #[cfg(test)]
 mod orch_spec;
-mod retry;
+pub mod retry;
 mod search_dedup;
 mod services;
 mod set_conversation_id;

crates/forge_app/src/orch.rs

@@ -262,8 +262,14 @@ impl<S: AgentService + EnvironmentInfra<Config = forge_config::ForgeConfig>> Orc
 
         // Retrieve the number of requests allowed per tick.
         let max_requests_per_turn = self.agent.max_requests_per_turn;
-        let tool_context =
-            ToolCallContext::new(self.conversation.metrics.clone()).sender(self.sender.clone());
+        let tool_context = {
+            let mut ctx = ToolCallContext::new(self.conversation.metrics.clone())
+                .sender(self.sender.clone());
+            ctx.set_conversation_id(Some(self.conversation.id));
+            ctx.set_parent_id(self.conversation.parent_id);
+            ctx.set_source(self.conversation.source.clone());
+            ctx
+        };
 
         while !should_yield {
             // Set context for the current loop iteration

crates/forge_app/src/services.rs

@@ -257,6 +257,25 @@ pub trait ConversationService: Send + Sync {
 
     /// Permanently deletes a conversation
     async fn delete_conversation(&self, conversation_id: &ConversationId) -> anyhow::Result<()>;
+
+    /// Find all subagent conversations for a given parent
+    async fn get_conversations_by_parent(
+        &self,
+        parent_id: &ConversationId,
+    ) -> anyhow::Result<Option<Vec<Conversation>>>;
+
+    /// Find all top-level conversations (those without a parent)
+    async fn get_parent_conversations(
+        &self,
+        limit: Option<usize>,
+    ) -> anyhow::Result<Option<Vec<Conversation>>>;
+
+    /// Find conversations by source (e.g., "interactive", "headless", "forge-p")
+    async fn get_conversations_by_source(
+        &self,
+        source: &str,
+        limit: Option<usize>,
+    ) -> anyhow::Result<Option<Vec<Conversation>>>;
 }
 
 #[async_trait::async_trait]
@@ -634,6 +653,34 @@ impl<I: Services> ConversationService for I {
             .delete_conversation(conversation_id)
             .await
     }
+
+    async fn get_conversations_by_parent(
+        &self,
+        parent_id: &ConversationId,
+    ) -> anyhow::Result<Option<Vec<Conversation>>> {
+        self.conversation_service()
+            .get_conversations_by_parent(parent_id)
+            .await
+    }
+
+    async fn get_parent_conversations(
+        &self,
+        limit: Option<usize>,
+    ) -> anyhow::Result<Option<Vec<Conversation>>> {
+        self.conversation_service()
+            .get_parent_conversations(limit)
+            .await
+    }
+
+    async fn get_conversations_by_source(
+        &self,
+        source: &str,
+        limit: Option<usize>,
+    ) -> anyhow::Result<Option<Vec<Conversation>>> {
+        self.conversation_service()
+            .get_conversations_by_source(source, limit)
+            .await
+    }
 }
 #[async_trait::async_trait]
 impl<I: Services> ProviderService for I {

crates/forge_app/src/tool_registry.rs

@@ -110,6 +110,7 @@ impl<S: Services + EnvironmentInfra<Config = forge_config::ForgeConfig>> ToolReg
                 let executor = self.agent_executor.clone();
                 let session_id = task_input.session_id.clone();
                 let agent_id = task_input.agent_id.clone();
+                let parent_id = context.conversation_id();
                 // Parse session_id into ConversationId if present
                 let conversation_id = session_id
                     .map(|id| forge_domain::ConversationId::parse(&id))
@@ -120,9 +121,10 @@ impl<S: Services + EnvironmentInfra<Config = forge_config::ForgeConfig>> ToolReg
                 let outputs = join_all(task_input.tasks.into_iter().map(|task| {
                     let agent_id = agent_id.clone();
                     let executor = executor.clone();
+                    let parent_id = parent_id;
                     async move {
                         executor
-                            .execute(AgentId::new(&agent_id), task, context, conversation_id)
+                            .execute(AgentId::new(&agent_id), task, context, conversation_id, parent_id)
                             .await
                     }
                 }))
@@ -169,13 +171,15 @@ impl<S: Services + EnvironmentInfra<Config = forge_config::ForgeConfig>> ToolReg
             let agent_input = AgentInput::try_from(&input)?;
             let executor = self.agent_executor.clone();
             let agent_name = input.name.as_str().to_string();
+            let parent_id = context.conversation_id();
             // NOTE: Agents should not timeout
             let outputs = join_all(agent_input.tasks.into_iter().map(|task| {
                 let agent_name = agent_name.clone();
                 let executor = executor.clone();
+                let parent_id = parent_id;
                 async move {
                     executor
-                        .execute(AgentId::new(&agent_name), task, context, None)
+                        .execute(AgentId::new(&agent_name), task, context, None, parent_id)
                         .await
                 }
             }))