Genie 1171/story/create template system

.coderabbit.yaml

@@ -7,14 +7,14 @@ reviews:
   high_level_summary: true
 
   path_filters:
-    - "multi-agents/**"
+    - "multi-agent/**"
     - "backend/**"
     - "ui/**"
 
   instructions: |
     This repository represents an agentic AI system with a modular, layered architecture.
 
-    Each of the main directories (multi-agents/, backend/, ui/) contains README.md and ARCHITECTURE.md files
+    Each of the main directories (multi-agent/, backend/, ui/) contains README.md and ARCHITECTURE.md files
     that define architectural intent, responsibilities, and boundaries.
 
     These documents should be treated as the source of truth.

multi-agent/actions/providers/mcp/get_tools_names/get_tools_names.py

@@ -1,5 +1,5 @@
 from typing import List, Optional, Dict, Any
-from pydantic import BaseModel, HttpUrl
+from pydantic import BaseModel, HttpUrl, Field
 from actions.common.base_action import BaseAction
 from actions.common.action_models import BaseActionInput, BaseActionOutput, ActionType
 from elements.providers.mcp_server_client.mcp_server_client import McpServerClient
@@ -11,6 +11,10 @@
 class GetToolsNamesInput(BaseActionInput):
     """Input for MCP tools discovery"""
     sse_endpoint: HttpUrl
+    bearer_token: Optional[str] = Field(
+        default=None,
+        description="Bearer token for MCP server authentication"
+    )
 
 
 class GetToolsNamesOutput(BaseActionOutput):
@@ -50,8 +54,13 @@ async def execute(self, input_data: GetToolsNamesInput,
             Discovery result with tool names and count
         """
         try:
-            # Create client and discover tools
-            client = McpServerClient(input_data.sse_endpoint)
+            # Build headers from bearer_token if provided
+            headers = None
+            if input_data.bearer_token:
+                headers = {"Authorization": f"Bearer {input_data.bearer_token}"}
+
+            # Create client and discover tools with auth headers
+            client = McpServerClient(input_data.sse_endpoint, headers=headers)
 
             async with client:
                 tools = await client.tools.get_tools()

multi-agent/actions/providers/mcp/validate_connection/validate_connection.py

@@ -8,19 +8,24 @@
 import time
 from typing import Optional, Dict, Any
 
-from pydantic import HttpUrl
+from pydantic import HttpUrl, Field
 
 from actions.common.base_action import BaseAction
 from actions.common.action_models import BaseActionInput, BaseActionOutput, ActionType
 from elements.providers.mcp_server_client.mcp_server_client import McpServerClient
 from elements.providers.mcp_server_client.identifiers import Identifier
 from core.enums import ResourceCategory
+from core.field_hints import SecretHint
 
 
 # Input/Output models for this action
 class ValidateConnectionInput(BaseActionInput):
     """Input for MCP connection validation"""
     sse_endpoint: HttpUrl
+    bearer_token: Optional[str] = Field(
+        default=None,
+        description="Bearer token for MCP server authentication"
+    )
 
 
 class ValidateConnectionOutput(BaseActionOutput):
@@ -96,8 +101,13 @@ async def execute(
         start_time = time.time()
 
         try:
-            # Create client and test connection
-            client = McpServerClient(input_data.sse_endpoint)
+            # Build headers from bearer_token if provided
+            headers = None
+            if input_data.bearer_token:
+                headers = {"Authorization": f"Bearer {input_data.bearer_token}"}
+
+            # Create client and test connection with auth headers
+            client = McpServerClient(input_data.sse_endpoint, headers=headers)
 
             async with client:
                 # Test connection by listing tools with timeout

multi-agent/api/flask/endpoints/__init__.py

@@ -8,6 +8,7 @@
 from api.flask.endpoints.health import health_bp
 from api.flask.endpoints.shares import shares_bp
 from api.flask.endpoints.statistics import statistics_bp
+from api.flask.endpoints.templates import templates_bp
 
 
 def register_all_endpoints(app):
@@ -22,6 +23,7 @@ def register_all_endpoints(app):
         {"bp": actions_bp, "parent": 'actions', "route": ''},
         {"bp": shares_bp, "parent": 'shares', "route": ''},
         {"bp": statistics_bp, "parent": 'statistics', "route": ''},
+        {"bp": templates_bp, "parent": 'templates', "route": ''},
     ]
 
     # register all other blueprints in the app

multi-agent/api/flask/endpoints/blueprints.py

@@ -194,6 +194,7 @@ def remove_blueprint(blueprint_id):
     """
     Delete a blueprint by its ID.
     """
+    # TODO: Add authorization check - verify user has permission to delete this blueprint
     try:
         svc = current_app.container.blueprint_service