add web_apps to moose ls and dev MCP

Author: onelesd

apps/framework-cli/src/cli/commands.rs

@@ -141,7 +141,7 @@ pub enum Commands {
     Ps {},
     /// View Moose primitives & infrastructure
     Ls {
-        /// Filter by infrastructure type (tables, streams, ingestion, sql_resource, consumption)
+        /// Filter by infrastructure type (tables, streams, ingestion, sql_resource, consumption, workflows, web_apps)
         #[arg(long)]
         _type: Option<String>,
 

apps/framework-cli/src/cli/routines/ls.rs

@@ -8,6 +8,7 @@ use crate::framework::core::infrastructure::api_endpoint::{APIType, ApiEndpoint}
 use crate::framework::core::infrastructure::function_process::FunctionProcess;
 use crate::framework::core::infrastructure::topic::Topic;
 use crate::framework::core::infrastructure::topic_sync_process::TopicToTableSyncProcess;
+use crate::framework::core::infrastructure::web_app::WebApp;
 use crate::framework::core::infrastructure_map::InfrastructureMap;
 use crate::framework::scripts::Workflow;
 use crate::{
@@ -260,6 +261,36 @@ impl From<Workflow> for WorkflowInfo {
     }
 }
 
+#[derive(Debug, Serialize)]
+pub struct WebAppInfo {
+    pub name: String,
+    pub mount_path: String,
+}
+
+impl From<WebApp> for WebAppInfo {
+    fn from(value: WebApp) -> Self {
+        Self {
+            name: value.name,
+            mount_path: value.mount_path,
+        }
+    }
+}
+
+impl ResourceInfo for Vec<WebAppInfo> {
+    fn show(&self) {
+        show_table(
+            "Web Apps".to_string(),
+            vec!["name".to_string(), "mount_path".to_string()],
+            self.iter()
+                .map(|app| vec![app.name.clone(), app.mount_path.clone()])
+                .collect(),
+        )
+    }
+    fn to_json_string(&self) -> Result<String, Error> {
+        serde_json::to_string_pretty(&self)
+    }
+}
+
 #[derive(Debug, Serialize)]
 pub struct ResourceListing {
     pub tables: Vec<TableInfo>,
@@ -269,6 +300,7 @@ pub struct ResourceListing {
     pub consumption_apis: Vec<ConsumptionApiInfo>,
     pub stream_transformations: Vec<StreamTransformationInfo>,
     pub workflows: Vec<WorkflowInfo>,
+    pub web_apps: Vec<WebAppInfo>,
 }
 
 impl ResourceInfo for ResourceListing {
@@ -280,6 +312,7 @@ impl ResourceInfo for ResourceListing {
         self.consumption_apis.show();
         self.stream_transformations.show();
         self.workflows.show();
+        self.web_apps.show();
     }
 
     fn to_json_string(&self) -> Result<String, Error> {
@@ -351,6 +384,12 @@ pub async fn ls_dmv2(
             .filter(|api| name.is_none_or(|name| api.name().contains(name)))
             .map(|w| w.into())
             .collect(),
+        web_apps: infra_map
+            .web_apps
+            .into_values()
+            .filter(|app| name.is_none_or(|n| app.name.contains(n)))
+            .map(|w| w.into())
+            .collect(),
     };
     let listing: &dyn ResourceInfo = match _type {
         None => &resources,
@@ -360,6 +399,7 @@ pub async fn ls_dmv2(
         Some("sql_resource") => &resources.sql_resources,
         Some("consumption") => &resources.consumption_apis,
         Some("workflows") => &resources.workflows,
+        Some("web_apps") => &resources.web_apps,
         _ => {
             return Err(RoutineFailure::error(Message::new(
                 "Unknown".to_string(),

apps/framework-cli/src/mcp/tools/infra_map.rs

@@ -16,7 +16,7 @@ use crate::infrastructure::redis::redis_client::RedisClient;
 /// Valid component types for filtering
 /// Note: block_db_processes and consumption_api_web_server are single structs, not collections,
 /// so they are not included in this list yet. They can be added when they become HashMaps.
-const VALID_COMPONENT_TYPES: [&str; 10] = [
+const VALID_COMPONENT_TYPES: [&str; 11] = [
     "topics",
     "api_endpoints",
     "tables",
@@ -27,6 +27,7 @@ const VALID_COMPONENT_TYPES: [&str; 10] = [
     "orchestration_workers",
     "sql_resources",
     "workflows",
+    "web_apps",
 ];
 
 /// Valid format options
@@ -122,7 +123,7 @@ pub fn tool_definition() -> Tool {
     Tool {
         name: "get_infra_map".into(),
         description: Some(
-            "Retrieve and explore the Moose infrastructure map. Access all infrastructure components including tables, topics, API endpoints, sync processes, function processes, orchestration workers, SQL resources, and workflows. Filter by component type and search with regex patterns.".into()
+            "Retrieve and explore the Moose infrastructure map. Access all infrastructure components including tables, topics, API endpoints, sync processes, function processes, orchestration workers, SQL resources, workflows, and web apps. Filter by component type and search with regex patterns.".into()
         ),
         input_schema: Arc::new(schema.as_object().unwrap().clone()),
         annotations: None,
@@ -449,6 +450,14 @@ fn format_summary(
             component_type_filter,
             show_all,
         ),
+        process_component_summary(
+            "web_apps",
+            "Web Apps",
+            &infra_map.web_apps,
+            search,
+            component_type_filter,
+            show_all,
+        ),
     ];
 
     // Append all non-empty component sections
@@ -559,6 +568,13 @@ fn format_detailed(
                 component_type_filter,
                 show_all,
             )?,
+            process_component_detailed(
+                "web_apps",
+                &infra_map.web_apps,
+                search,
+                component_type_filter,
+                show_all,
+            )?,
         ];
 
         // Add all non-empty components to the filtered map
@@ -600,6 +616,7 @@ mod tests {
         assert!(is_valid_component_type("tables"));
         assert!(is_valid_component_type("api_endpoints"));
         assert!(is_valid_component_type("workflows"));
+        assert!(is_valid_component_type("web_apps"));
 
         assert!(!is_valid_component_type("invalid"));
         assert!(!is_valid_component_type(""));