phase 4 added additional http-api endpoints

Author: jaschadub

symbiont/client.py

@@ -38,8 +38,14 @@
     # Agent DSL models
     DslCompileRequest,
     DslCompileResponse,
+    EndpointMetrics,
     # System models
     HealthResponse,
+    # Phase 4 HTTP Endpoint Management models
+    HttpEndpointCreateRequest,
+    HttpEndpointInfo,
+    HttpEndpointResponse,
+    HttpEndpointUpdateRequest,
     HttpInputCreateRequest,
     HttpInputServerInfo,
     HttpInputUpdateRequest,
@@ -1281,3 +1287,106 @@ def count_vectors(self, collection_name: str) -> int:
         """
         response = self._request("GET", f"vectors/collections/{collection_name}/count")
         return response.json()["count"]
+
+    # =============================================================================
+    # Phase 4 HTTP Endpoint Management Methods
+    # =============================================================================
+
+    def create_http_endpoint(self, endpoint_request: Union[HttpEndpointCreateRequest, Dict[str, Any]]) -> HttpEndpointResponse:
+        """Create a new HTTP endpoint.
+
+        Args:
+            endpoint_request: HTTP endpoint creation request
+
+        Returns:
+            HttpEndpointResponse: Endpoint creation result
+        """
+        if isinstance(endpoint_request, dict):
+            endpoint_request = HttpEndpointCreateRequest(**endpoint_request)
+
+        response = self._request("POST", "endpoints", json=endpoint_request.model_dump())
+        return HttpEndpointResponse(**response.json())
+
+    def list_http_endpoints(self) -> List[HttpEndpointInfo]:
+        """List all HTTP endpoints.
+
+        Returns:
+            List[HttpEndpointInfo]: List of endpoint information
+        """
+        response = self._request("GET", "endpoints")
+        return [HttpEndpointInfo(**endpoint) for endpoint in response.json()]
+
+    def update_http_endpoint(self, endpoint_request: Union[HttpEndpointUpdateRequest, Dict[str, Any]]) -> HttpEndpointResponse:
+        """Update an existing HTTP endpoint.
+
+        Args:
+            endpoint_request: HTTP endpoint update request
+
+        Returns:
+            HttpEndpointResponse: Endpoint update result
+        """
+        if isinstance(endpoint_request, dict):
+            endpoint_request = HttpEndpointUpdateRequest(**endpoint_request)
+
+        response = self._request("PUT", f"endpoints/{endpoint_request.endpoint_id}", json=endpoint_request.model_dump())
+        return HttpEndpointResponse(**response.json())
+
+    def delete_http_endpoint(self, endpoint_id: str) -> Dict[str, Any]:
+        """Delete an HTTP endpoint.
+
+        Args:
+            endpoint_id: The endpoint identifier
+
+        Returns:
+            Dict[str, Any]: Deletion confirmation
+        """
+        response = self._request("DELETE", f"endpoints/{endpoint_id}")
+        return response.json()
+
+    def get_http_endpoint(self, endpoint_id: str) -> HttpEndpointInfo:
+        """Get information about a specific HTTP endpoint.
+
+        Args:
+            endpoint_id: The endpoint identifier
+
+        Returns:
+            HttpEndpointInfo: Endpoint information
+        """
+        response = self._request("GET", f"endpoints/{endpoint_id}")
+        return HttpEndpointInfo(**response.json())
+
+    def get_endpoint_metrics(self, endpoint_id: str) -> EndpointMetrics:
+        """Get metrics for a specific HTTP endpoint.
+
+        Args:
+            endpoint_id: The endpoint identifier
+
+        Returns:
+            EndpointMetrics: Endpoint metrics information
+        """
+        response = self._request("GET", f"endpoints/{endpoint_id}/metrics")
+        return EndpointMetrics(**response.json())
+
+    def enable_http_endpoint(self, endpoint_id: str) -> Dict[str, Any]:
+        """Enable/activate an HTTP endpoint.
+
+        Args:
+            endpoint_id: The endpoint identifier
+
+        Returns:
+            Dict[str, Any]: Operation confirmation
+        """
+        response = self._request("POST", f"endpoints/{endpoint_id}/enable")
+        return response.json()
+
+    def disable_http_endpoint(self, endpoint_id: str) -> Dict[str, Any]:
+        """Disable/deactivate an HTTP endpoint.
+
+        Args:
+            endpoint_id: The endpoint identifier
+
+        Returns:
+            Dict[str, Any]: Operation confirmation
+        """
+        response = self._request("POST", f"endpoints/{endpoint_id}/disable")
+        return response.json()

symbiont/exceptions.py

@@ -165,3 +165,121 @@ def __init__(self, message: str = "Memory retrieval error", memory_id: str = Non
         """
         super().__init__(message)
         self.memory_id = memory_id
+
+
+# =============================================================================
+# Phase 3 Vector Database Exception Classes
+# =============================================================================
+
+class VectorDatabaseError(SymbiontError):
+    """Base exception for vector database errors."""
+    pass
+
+
+class QdrantConnectionError(VectorDatabaseError):
+    """Raised when Qdrant connection operations fail."""
+
+    def __init__(self, message: str = "Qdrant connection error", host: str = None):
+        """Initialize the QdrantConnectionError.
+
+        Args:
+            message: Error message describing the connection failure.
+            host: Optional Qdrant host that failed to connect.
+        """
+        super().__init__(message)
+        self.host = host
+
+
+class CollectionNotFoundError(VectorDatabaseError):
+    """Raised when a vector collection is not found."""
+
+    def __init__(self, message: str = "Vector collection not found", collection_name: str = None):
+        """Initialize the CollectionNotFoundError.
+
+        Args:
+            message: Error message describing the collection error.
+            collection_name: Optional collection name that was not found.
+        """
+        super().__init__(message, 404)
+        self.collection_name = collection_name
+
+
+class EmbeddingError(SymbiontError):
+    """Raised when embedding generation operations fail."""
+
+    def __init__(self, message: str = "Embedding generation error", model: str = None):
+        """Initialize the EmbeddingError.
+
+        Args:
+            message: Error message describing the embedding failure.
+            model: Optional embedding model that failed.
+        """
+        super().__init__(message)
+        self.model = model
+
+
+# =============================================================================
+# Phase 4 HTTP Endpoint Management Exception Classes
+# =============================================================================
+
+class EndpointError(SymbiontError):
+    """Base exception for HTTP endpoint management errors."""
+    pass
+
+
+class EndpointNotFoundError(EndpointError):
+    """Raised when an HTTP endpoint is not found."""
+
+    def __init__(self, message: str = "HTTP endpoint not found", endpoint_id: str = None):
+        """Initialize the EndpointNotFoundError.
+
+        Args:
+            message: Error message describing the endpoint error.
+            endpoint_id: Optional endpoint ID that was not found.
+        """
+        super().__init__(message, 404)
+        self.endpoint_id = endpoint_id
+
+
+class EndpointConflictError(EndpointError):
+    """Raised when an HTTP endpoint creation conflicts with existing endpoints."""
+
+    def __init__(self, message: str = "HTTP endpoint conflict", path: str = None, method: str = None):
+        """Initialize the EndpointConflictError.
+
+        Args:
+            message: Error message describing the endpoint conflict.
+            path: Optional endpoint path that conflicts.
+            method: Optional HTTP method that conflicts.
+        """
+        super().__init__(message, 409)
+        self.path = path
+        self.method = method
+
+
+class EndpointConfigurationError(EndpointError):
+    """Raised when HTTP endpoint configuration is invalid."""
+
+    def __init__(self, message: str = "Invalid endpoint configuration", config_field: str = None):
+        """Initialize the EndpointConfigurationError.
+
+        Args:
+            message: Error message describing the configuration issue.
+            config_field: Optional configuration field that is invalid.
+        """
+        super().__init__(message, 400)
+        self.config_field = config_field
+
+
+class EndpointRateLimitError(EndpointError):
+    """Raised when an HTTP endpoint rate limit is exceeded."""
+
+    def __init__(self, message: str = "Endpoint rate limit exceeded", endpoint_id: str = None):
+        """Initialize the EndpointRateLimitError.
+
+        Args:
+            message: Error message describing the rate limit violation.
+            endpoint_id: Optional endpoint ID that exceeded the rate limit.
+        """
+        super().__init__(message, 429)
+        self.endpoint_id = endpoint_id

symbiont/models.py

@@ -874,8 +874,6 @@ class EmbeddingRequest(BaseModel):
     model: str = Field("default", description="Embedding model to use")
     collection_name: Optional[str] = Field(None, description="Target collection")
     metadata: Optional[List[Dict[str, Any]]] = Field(None, description="Metadata for each text")
-
-
 class EmbeddingResponse(BaseModel):
     """Response from embedding generation."""
     embeddings: List[List[float]] = Field(..., description="Generated embeddings")
@@ -884,3 +882,99 @@ class EmbeddingResponse(BaseModel):
     token_count: Optional[int] = Field(None, description="Total token count processed")
 
 
+# =============================================================================
+# Phase 4 HTTP Endpoint Management Models
+# =============================================================================
+
+class HttpMethod(str, Enum):
+    """HTTP method enumeration."""
+    GET = "GET"
+    POST = "POST"
+    PUT = "PUT"
+    DELETE = "DELETE"
+    PATCH = "PATCH"
+    HEAD = "HEAD"
+    OPTIONS = "OPTIONS"
+
+
+class EndpointStatus(str, Enum):
+    """HTTP endpoint status enumeration."""
+    ACTIVE = "active"
+    INACTIVE = "inactive"
+    MAINTENANCE = "maintenance"
+    ERROR = "error"
+
+
+class HttpEndpointCreateRequest(BaseModel):
+    """Request to create a new HTTP endpoint."""
+    path: str = Field(..., description="Endpoint path")
+    method: HttpMethod = Field(..., description="HTTP method")
+    agent_id: str = Field(..., description="Agent to handle requests")
+    description: Optional[str] = Field(None, description="Endpoint description")
+    auth_required: bool = Field(True, description="Whether authentication is required")
+    rate_limit: Optional[int] = Field(None, description="Rate limit per minute")
+    timeout_seconds: int = Field(30, description="Request timeout in seconds")
+    middleware: List[str] = Field(default_factory=list, description="Middleware to apply")
+    metadata: Dict[str, Any] = Field(default_factory=dict, description="Additional endpoint metadata")
+
+
+class HttpEndpointUpdateRequest(BaseModel):
+    """Request to update an existing HTTP endpoint."""
+    endpoint_id: str = Field(..., description="Endpoint identifier")
+    path: Optional[str] = Field(None, description="Endpoint path")
+    method: Optional[HttpMethod] = Field(None, description="HTTP method")
+    agent_id: Optional[str] = Field(None, description="Agent to handle requests")
+    description: Optional[str] = Field(None, description="Endpoint description")
+    auth_required: Optional[bool] = Field(None, description="Whether authentication is required")
+    rate_limit: Optional[int] = Field(None, description="Rate limit per minute")
+    timeout_seconds: Optional[int] = Field(None, description="Request timeout in seconds")
+    status: Optional[EndpointStatus] = Field(None, description="Endpoint status")
+    middleware: Optional[List[str]] = Field(None, description="Middleware to apply")
+    metadata: Optional[Dict[str, Any]] = Field(None, description="Additional endpoint metadata")
+
+
+class EndpointMetrics(BaseModel):
+    """HTTP endpoint metrics."""
+    endpoint_id: str = Field(..., description="Endpoint identifier")
+    total_requests: int = Field(..., description="Total number of requests")
+    successful_requests: int = Field(..., description="Number of successful requests")
+    failed_requests: int = Field(..., description="Number of failed requests")
+    average_response_time_ms: float = Field(..., description="Average response time in milliseconds")
+    max_response_time_ms: float = Field(..., description="Maximum response time in milliseconds")
+    min_response_time_ms: float = Field(..., description="Minimum response time in milliseconds")
+    requests_per_minute: float = Field(..., description="Current requests per minute rate")
+    error_rate_percent: float = Field(..., description="Error rate percentage")
+    last_request_at: Optional[datetime] = Field(None, description="Timestamp of last request")
+    uptime_seconds: int = Field(..., description="Endpoint uptime in seconds")
+
+
+class HttpEndpointInfo(BaseModel):
+    """HTTP endpoint information."""
+    endpoint_id: str = Field(..., description="Endpoint identifier")
+    path: str = Field(..., description="Endpoint path")
+    method: HttpMethod = Field(..., description="HTTP method")
+    agent_id: str = Field(..., description="Agent handling requests")
+    description: Optional[str] = Field(None, description="Endpoint description")
+    status: EndpointStatus = Field(..., description="Current endpoint status")
+    auth_required: bool = Field(..., description="Whether authentication is required")
+    rate_limit: Optional[int] = Field(None, description="Rate limit per minute")
+    timeout_seconds: int = Field(..., description="Request timeout in seconds")
+    middleware: List[str] = Field(default_factory=list, description="Applied middleware")
+    created_at: datetime = Field(..., description="Endpoint creation timestamp")
+    updated_at: datetime = Field(..., description="Last update timestamp")
+    created_by: str = Field(..., description="User who created the endpoint")
+    metrics: Optional[EndpointMetrics] = Field(None, description="Endpoint metrics")
+    metadata: Dict[str, Any] = Field(default_factory=dict, description="Additional endpoint metadata")
+
+
+class HttpEndpointResponse(BaseModel):
+    """Response from HTTP endpoint operations."""
+    endpoint_id: str = Field(..., description="Endpoint identifier")
+    status: str = Field(..., description="Operation status")
+    message: Optional[str] = Field(None, description="Operation message")
+    endpoint_info: Optional[HttpEndpointInfo] = Field(None, description="Endpoint information")
+    created_at: Optional[datetime] = Field(None, description="Creation timestamp")
+
+
+
+