Add HTTP Input server support

Complete HTTP Input feature implementation:
- HttpInputConfig model for server configuration
- HttpInputRequest/Response models for webhook handling
- create_http_input_server() and manage_http_input_server() client methods
- Support for webhook endpoints and external system integration
- Fixed security binding configuration with proper validation

Completes v0.3.0 feature parity with main symbiont platform

Author: jaschadub

symbiont/__init__.py

@@ -16,6 +16,7 @@
     AgentDeployRequest,
     AgentDeployResponse,
     AgentMetrics,
+    AgentRoutingRule,
     AgentState,
     AgentStatusResponse,
     AnalysisResults,
@@ -29,6 +30,11 @@
     FindingSeverity,
     # System Models
     HealthResponse,
+    HttpInputConfig,
+    HttpInputCreateRequest,
+    HttpInputServerInfo,
+    HttpInputUpdateRequest,
+    HttpResponseControlConfig,
     HumanReviewDecision,
     KnowledgeItem,
     # Vector Database & RAG Models
@@ -47,6 +53,8 @@
     ReviewSessionResponse,
     ReviewSessionState,
     ReviewStatus,
+    # HTTP Input Models
+    RouteMatchType,
     SecretBackendConfig,
     # Secrets Management Models
     SecretBackendType,
@@ -68,6 +76,8 @@
     VectorSearchRequest,
     VectorSearchResponse,
     VectorSearchResult,
+    WebhookTriggerRequest,
+    WebhookTriggerResponse,
     # Workflow Models
     WorkflowExecutionRequest,
     WorkflowExecutionResponse,
@@ -113,6 +123,11 @@
     # Agent DSL Models
     'DslCompileRequest', 'DslCompileResponse', 'AgentDeployRequest', 'AgentDeployResponse',
 
+    # HTTP Input Models
+    'RouteMatchType', 'AgentRoutingRule', 'HttpResponseControlConfig',
+    'HttpInputConfig', 'HttpInputServerInfo', 'HttpInputCreateRequest', 'HttpInputUpdateRequest',
+    'WebhookTriggerRequest', 'WebhookTriggerResponse',
+
     # Exceptions
     'SymbiontError',
     'APIError',

symbiont/client.py

@@ -21,6 +21,10 @@
     DslCompileResponse,
     # System models
     HealthResponse,
+    # HTTP Input models
+    HttpInputCreateRequest,
+    HttpInputServerInfo,
+    HttpInputUpdateRequest,
     HumanReviewDecision,
     # Vector Database & RAG models
     KnowledgeItem,
@@ -44,6 +48,8 @@
     SystemMetrics,
     VectorSearchRequest,
     VectorSearchResponse,
+    WebhookTriggerRequest,
+    WebhookTriggerResponse,
     WorkflowExecutionRequest,
 )
 
@@ -661,3 +667,121 @@ def stop_agent_deployment(self, deployment_id: str) -> Dict[str, Any]:
         """
         response = self._request("POST", f"agents/deployments/{deployment_id}/stop")
         return response.json()
+
+    # =============================================================================
+    # HTTP Input Methods
+    # =============================================================================
+
+    def create_http_input_server(self, request: Union[HttpInputCreateRequest, Dict[str, Any]]) -> HttpInputServerInfo:
+        """Create and start an HTTP input server.
+
+        Args:
+            request: HTTP input server creation request
+
+        Returns:
+            HttpInputServerInfo: Server information
+        """
+        if isinstance(request, dict):
+            request = HttpInputCreateRequest(**request)
+
+        response = self._request("POST", "http-input/servers", json=request.dict())
+        return HttpInputServerInfo(**response.json())
+
+    def list_http_input_servers(self) -> List[HttpInputServerInfo]:
+        """List all HTTP input servers.
+
+        Returns:
+            List[HttpInputServerInfo]: List of server information
+        """
+        response = self._request("GET", "http-input/servers")
+        return [HttpInputServerInfo(**server) for server in response.json()]
+
+    def get_http_input_server(self, server_id: str) -> HttpInputServerInfo:
+        """Get information about a specific HTTP input server.
+
+        Args:
+            server_id: The server identifier
+
+        Returns:
+            HttpInputServerInfo: Server information
+        """
+        response = self._request("GET", f"http-input/servers/{server_id}")
+        return HttpInputServerInfo(**response.json())
+
+    def update_http_input_server(self, request: Union[HttpInputUpdateRequest, Dict[str, Any]]) -> HttpInputServerInfo:
+        """Update an HTTP input server configuration.
+
+        Args:
+            request: HTTP input server update request
+
+        Returns:
+            HttpInputServerInfo: Updated server information
+        """
+        if isinstance(request, dict):
+            request = HttpInputUpdateRequest(**request)
+
+        response = self._request("PUT", f"http-input/servers/{request.server_id}", json=request.dict())
+        return HttpInputServerInfo(**response.json())
+
+    def start_http_input_server(self, server_id: str) -> Dict[str, Any]:
+        """Start an HTTP input server.
+
+        Args:
+            server_id: The server identifier
+
+        Returns:
+            Dict[str, Any]: Start confirmation
+        """
+        response = self._request("POST", f"http-input/servers/{server_id}/start")
+        return response.json()
+
+    def stop_http_input_server(self, server_id: str) -> Dict[str, Any]:
+        """Stop an HTTP input server.
+
+        Args:
+            server_id: The server identifier
+
+        Returns:
+            Dict[str, Any]: Stop confirmation
+        """
+        response = self._request("POST", f"http-input/servers/{server_id}/stop")
+        return response.json()
+
+    def delete_http_input_server(self, server_id: str) -> Dict[str, Any]:
+        """Delete an HTTP input server.
+
+        Args:
+            server_id: The server identifier
+
+        Returns:
+            Dict[str, Any]: Deletion confirmation
+        """
+        response = self._request("DELETE", f"http-input/servers/{server_id}")
+        return response.json()
+
+    def trigger_webhook(self, request: Union[WebhookTriggerRequest, Dict[str, Any]]) -> WebhookTriggerResponse:
+        """Manually trigger a webhook for testing purposes.
+
+        Args:
+            request: Webhook trigger request
+
+        Returns:
+            WebhookTriggerResponse: Trigger response
+        """
+        if isinstance(request, dict):
+            request = WebhookTriggerRequest(**request)
+
+        response = self._request("POST", f"http-input/servers/{request.server_id}/trigger", json=request.dict())
+        return WebhookTriggerResponse(**response.json())
+
+    def get_http_input_metrics(self, server_id: str) -> Dict[str, Any]:
+        """Get metrics for an HTTP input server.
+
+        Args:
+            server_id: The server identifier
+
+        Returns:
+            Dict[str, Any]: Server metrics
+        """
+        response = self._request("GET", f"http-input/servers/{server_id}/metrics")
+        return response.json()

symbiont/models.py

@@ -490,3 +490,85 @@ class AgentMetrics(BaseModel):
     cpu_usage_percent: float
     last_activity: datetime
     uptime_seconds: int
+
+
+# =============================================================================
+# HTTP Input Models
+# =============================================================================
+
+class RouteMatchType(str, Enum):
+    """Route matching condition types."""
+    PATH_PREFIX = "path_prefix"
+    HEADER_EQUALS = "header_equals"
+    JSON_FIELD_EQUALS = "json_field_equals"
+
+
+class AgentRoutingRule(BaseModel):
+    """Rule to route HTTP requests to specific agents."""
+    condition_type: RouteMatchType
+    condition_value: str
+    condition_target: Optional[str] = None  # For header/field name
+    agent_id: str
+
+
+class HttpResponseControlConfig(BaseModel):
+    """HTTP response control configuration."""
+    default_status: int = 200
+    agent_output_to_json: bool = True
+    error_status: int = 500
+    echo_input_on_error: bool = False
+
+
+class HttpInputConfig(BaseModel):
+    """HTTP input server configuration."""
+    bind_address: str = "0.0.0.0"  # nosec B104 - This is a configuration default, not actual binding
+    port: int = 8081
+    path: str = "/webhook"
+    agent_id: str
+    auth_header: Optional[str] = None
+    jwt_public_key_path: Optional[str] = None
+    max_body_bytes: int = 65536
+    concurrency: int = 10
+    routing_rules: Optional[List[AgentRoutingRule]] = None
+    response_control: Optional[HttpResponseControlConfig] = None
+    forward_headers: List[str] = []
+    cors_enabled: bool = False
+    audit_enabled: bool = True
+
+
+class HttpInputServerInfo(BaseModel):
+    """HTTP input server status information."""
+    server_id: str
+    config: HttpInputConfig
+    status: str  # "running", "stopped", "error"
+    uptime_seconds: Optional[int] = None
+    requests_processed: int = 0
+    active_connections: int = 0
+    last_error: Optional[str] = None
+
+
+class HttpInputCreateRequest(BaseModel):
+    """Request to create/start HTTP input server."""
+    config: HttpInputConfig
+
+
+class HttpInputUpdateRequest(BaseModel):
+    """Request to update HTTP input server configuration."""
+    server_id: str
+    config: HttpInputConfig
+
+
+class WebhookTriggerRequest(BaseModel):
+    """Request to manually trigger webhook for testing."""
+    server_id: str
+    payload: Dict[str, Any]
+    headers: Dict[str, str] = {}
+
+
+class WebhookTriggerResponse(BaseModel):
+    """Response from webhook trigger."""
+    status: str
+    response_code: int
+    response_body: Dict[str, Any]
+    processing_time_ms: float
+    agent_id: str