chore/test: add more tests for frontend (#100)

* components to show general coverage for backend and frontend regardless of flags + ignore of test files
* regen of api stuff from spec + fixing eslint warnings
* custom toasts -> svelte-sonner toasts
* custom event source -> event-source-plus
* Double Cast Bypasses Type Safety in EventDetailsModal - fix
* `any[]` Type for Settings History, JSON.parse Without Try-Catch in Execution SSE (added schemas for sse endpoints)
* fixes

Author: HardMax71

.github/codecov.yml

@@ -21,3 +21,24 @@ flag_management:
       carryforward: true
     - name: frontend
       carryforward: true
+
+component_management:
+  individual_components:
+    - component_id: backend
+      name: Backend
+      paths:
+        - backend/app/**
+    - component_id: frontend
+      name: Frontend
+      paths:
+        - frontend/src/**
+
+ignore:
+  - "**/tests/**"
+  - "**/test/**"
+  - "**/__tests__/**"
+  - "**/test_*.py"
+  - "**/*_test.py"
+  - "**/*.test.ts"
+  - "**/*.spec.ts"
+  - "**/conftest.py"

README.md

@@ -26,11 +26,11 @@
   </a>
 </p>
 <p align="center">
-  <a href="https://app.codecov.io/gh/HardMax71/Integr8sCode">
-    <img src="https://img.shields.io/codecov/c/github/HardMax71/Integr8sCode?label=backend%20cov&logo=codecov" alt="Backend Coverage" />
+  <a href="https://app.codecov.io/gh/HardMax71/Integr8sCode/components?component=backend">
+    <img src="https://codecov.io/gh/HardMax71/Integr8sCode/branch/main/graph/badge.svg?component=backend" alt="Backend Coverage" />
   </a>
-  <a href="https://app.codecov.io/gh/HardMax71/Integr8sCode/flags?flag=frontend">
-    <img src="https://img.shields.io/codecov/c/github/HardMax71/Integr8sCode?flag=frontend&label=frontend%20cov&logo=codecov" alt="Frontend Coverage" />
+  <a href="https://app.codecov.io/gh/HardMax71/Integr8sCode/components?component=frontend">
+    <img src="https://codecov.io/gh/HardMax71/Integr8sCode/branch/main/graph/badge.svg?component=frontend" alt="Frontend Coverage" />
   </a>
 </p>
 <p align="center">

backend/app/api/routes/admin/events.py

@@ -4,7 +4,6 @@
 from dishka import FromDishka
 from dishka.integrations.fastapi import DishkaRoute
 from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException, Query
-from fastapi.encoders import jsonable_encoder
 from fastapi.responses import StreamingResponse
 
 from app.api.dependencies import admin_user
@@ -44,7 +43,7 @@ async def browse_events(request: EventBrowseRequest, service: FromDishka[AdminEv
         )
 
         return EventBrowseResponse(
-            events=[jsonable_encoder(event) for event in result.events],
+            events=result.events,
             total=result.total,
             skip=result.skip,
             limit=result.limit,
@@ -135,9 +134,9 @@ async def get_event_detail(event_id: str, service: FromDishka[AdminEventsService
             raise HTTPException(status_code=404, detail="Event not found")
 
         return EventDetailResponse(
-            event=jsonable_encoder(result.event),
-            related_events=[jsonable_encoder(e) for e in result.related_events],
-            timeline=[jsonable_encoder(e) for e in result.timeline],
+            event=result.event,
+            related_events=result.related_events,
+            timeline=result.timeline,
         )
 
     except HTTPException:

backend/app/api/routes/events.py

@@ -6,7 +6,6 @@
 from dishka import FromDishka
 from dishka.integrations.fastapi import DishkaRoute
 from fastapi import APIRouter, Depends, HTTPException, Query, Request
-from pydantic import TypeAdapter
 
 from app.api.dependencies import admin_user, current_user
 from app.core.correlation import CorrelationContext
@@ -21,7 +20,6 @@
     EventAggregationRequest,
     EventFilterRequest,
     EventListResponse,
-    EventResponse,
     EventStatistics,
     PublishEventRequest,
     PublishEventResponse,
@@ -33,8 +31,6 @@
 from app.services.kafka_event_service import KafkaEventService
 from app.settings import Settings
 
-_event_response_list_adapter: TypeAdapter[list[EventResponse]] = TypeAdapter(list[EventResponse])
-
 router = APIRouter(prefix="/events", tags=["events"], route_class=DishkaRoute)
 
 
@@ -66,7 +62,7 @@ async def get_execution_events(
         raise HTTPException(status_code=403, detail="Access denied")
 
     return EventListResponse(
-        events=_event_response_list_adapter.validate_python(result.events, from_attributes=True),
+        events=result.events,
         total=result.total,
         limit=limit,
         skip=skip,
@@ -97,7 +93,7 @@ async def get_user_events(
     )
 
     return EventListResponse(
-        events=_event_response_list_adapter.validate_python(result.events, from_attributes=True),
+        events=result.events,
         total=result.total,
         limit=limit,
         skip=skip,
@@ -134,7 +130,7 @@ async def query_events(
         raise HTTPException(status_code=403, detail="Cannot query other users' events")
 
     return EventListResponse(
-        events=_event_response_list_adapter.validate_python(result.events, from_attributes=True),
+        events=result.events,
         total=result.total,
         limit=result.limit,
         skip=result.skip,
@@ -161,7 +157,7 @@ async def get_events_by_correlation(
     )
 
     return EventListResponse(
-        events=_event_response_list_adapter.validate_python(result.events, from_attributes=True),
+        events=result.events,
         total=result.total,
         limit=limit,
         skip=skip,
@@ -190,7 +186,7 @@ async def get_current_request_events(
     )
 
     return EventListResponse(
-        events=_event_response_list_adapter.validate_python(result.events, from_attributes=True),
+        events=result.events,
         total=result.total,
         limit=limit,
         skip=skip,

backend/app/api/routes/execution.py

@@ -5,17 +5,15 @@
 from dishka import FromDishka
 from dishka.integrations.fastapi import DishkaRoute, inject
 from fastapi import APIRouter, Depends, Header, HTTPException, Path, Query, Request
-from pydantic import TypeAdapter
 
 from app.api.dependencies import admin_user, current_user
 from app.core.tracing import EventAttributes, add_span_attributes
 from app.core.utils import get_client_ip
 from app.domain.enums.events import EventType
 from app.domain.enums.execution import ExecutionStatus
 from app.domain.enums.user import UserRole
-from app.domain.events.typed import BaseEvent, EventMetadata
+from app.domain.events.typed import BaseEvent, DomainEvent, EventMetadata
 from app.domain.exceptions import DomainError
-from app.schemas_pydantic.events import EventResponse
 from app.schemas_pydantic.execution import (
     CancelExecutionRequest,
     CancelResponse,
@@ -36,8 +34,6 @@
 from app.services.kafka_event_service import KafkaEventService
 from app.settings import Settings
 
-_event_list_adapter: TypeAdapter[list[EventResponse]] = TypeAdapter(list[EventResponse])
-
 router = APIRouter(route_class=DishkaRoute, tags=["execution"])
 
 
@@ -234,18 +230,18 @@ async def retry_execution(
     return ExecutionResponse.model_validate(new_result)
 
 
-@router.get("/executions/{execution_id}/events", response_model=list[EventResponse])
+@router.get("/executions/{execution_id}/events", response_model=list[DomainEvent])
 async def get_execution_events(
         execution: Annotated[ExecutionInDB, Depends(get_execution_with_access)],
         event_service: FromDishka[EventService],
         event_types: list[EventType] | None = Query(None, description="Event types to filter"),
         limit: int = Query(100, ge=1, le=1000),
-) -> list[EventResponse]:
+) -> list[DomainEvent]:
     """Get all events for an execution."""
     events = await event_service.get_events_by_aggregate(
         aggregate_id=execution.execution_id, event_types=event_types, limit=limit
     )
-    return _event_list_adapter.validate_python([e.model_dump() for e in events])
+    return events
 
 
 @router.get("/user/executions", response_model=ExecutionListResponse)

backend/app/api/routes/sse.py

@@ -4,14 +4,19 @@
 from sse_starlette.sse import EventSourceResponse
 
 from app.domain.sse import SSEHealthDomain
-from app.schemas_pydantic.sse import ShutdownStatusResponse, SSEHealthResponse
+from app.schemas_pydantic.sse import (
+    ShutdownStatusResponse,
+    SSEExecutionEventData,
+    SSEHealthResponse,
+    SSENotificationEventData,
+)
 from app.services.auth_service import AuthService
 from app.services.sse.sse_service import SSEService
 
 router = APIRouter(prefix="/events", tags=["sse"], route_class=DishkaRoute)
 
 
-@router.get("/notifications/stream")
+@router.get("/notifications/stream", responses={200: {"model": SSENotificationEventData}})
 async def notification_stream(
     request: Request,
     sse_service: FromDishka[SSEService],
@@ -23,7 +28,7 @@ async def notification_stream(
     return EventSourceResponse(sse_service.create_notification_stream(user_id=current_user.user_id))
 
 
-@router.get("/executions/{execution_id}")
+@router.get("/executions/{execution_id}", responses={200: {"model": SSEExecutionEventData}})
 async def execution_events(
     execution_id: str, request: Request, sse_service: FromDishka[SSEService], auth_service: FromDishka[AuthService]
 ) -> EventSourceResponse:

backend/app/domain/events/typed.py

@@ -30,7 +30,15 @@ class EventMetadata(AvroBase):
 class BaseEvent(AvroBase):
     """Base fields for all domain events."""
 
-    model_config = ConfigDict(from_attributes=True)
+    # Pydantic marks fields with default/default_factory as optional in JSON Schema,
+    # which generates optional TypeScript types (e.g., `event_id?: string`).
+    # Since stored events always have these fields, we override the schema to mark them required.
+    # See: https://github.com/pydantic/pydantic/issues/7209
+    # See: https://github.com/pydantic/pydantic/discussions/6073
+    model_config = ConfigDict(
+        from_attributes=True,
+        json_schema_extra={"required": ["event_id", "event_type", "event_version", "timestamp", "metadata"]},
+    )
 
     event_id: str = Field(default_factory=lambda: str(uuid4()))
     event_type: EventType

backend/app/schemas_pydantic/admin_events.py

@@ -1,9 +1,11 @@
 from datetime import datetime
-from typing import Any, Dict, List
+from typing import Dict, List
 
 from pydantic import BaseModel, ConfigDict, Field, computed_field
 
 from app.domain.enums.events import EventType
+from app.domain.events.event_models import EventSummary
+from app.domain.events.typed import DomainEvent
 from app.schemas_pydantic.events import HourlyEventCountSchema
 from app.schemas_pydantic.execution import ExecutionResult
 
@@ -55,7 +57,7 @@ class EventReplayRequest(BaseModel):
 class EventBrowseResponse(BaseModel):
     """Response model for browsing events"""
 
-    events: List[Dict[str, Any]]
+    events: List[DomainEvent]
     total: int
     skip: int
     limit: int
@@ -64,9 +66,9 @@ class EventBrowseResponse(BaseModel):
 class EventDetailResponse(BaseModel):
     """Response model for event detail"""
 
-    event: Dict[str, Any]
-    related_events: List[Dict[str, Any]]
-    timeline: List[Dict[str, Any]]
+    event: DomainEvent
+    related_events: List[EventSummary]
+    timeline: List[EventSummary]
 
 
 class EventReplayResponse(BaseModel):
@@ -77,7 +79,7 @@ class EventReplayResponse(BaseModel):
     replay_correlation_id: str
     session_id: str | None = None
     status: str
-    events_preview: List[Dict[str, Any]] | None = None
+    events_preview: List[EventSummary] | None = None
 
 
 class EventReplayStatusResponse(BaseModel):

backend/app/schemas_pydantic/events.py

@@ -6,6 +6,7 @@
 
 from app.domain.enums.common import Environment, SortOrder
 from app.domain.enums.events import EventType
+from app.domain.events.typed import DomainEvent
 
 
 class HourlyEventCountSchema(BaseModel):
@@ -31,23 +32,21 @@ class EventMetadataResponse(BaseModel):
     environment: Environment = Environment.PRODUCTION
 
 
-class EventResponse(BaseModel):
-    """API response schema for events. Captures all event-specific fields via extra='allow'."""
+class EventSummaryResponse(BaseModel):
+    """Lightweight event summary for lists and related events display."""
 
-    model_config = ConfigDict(from_attributes=True, extra="allow")
+    model_config = ConfigDict(from_attributes=True)
 
     event_id: str
     event_type: EventType
-    event_version: str = "1.0"
     timestamp: datetime
     aggregate_id: str | None = None
-    metadata: EventMetadataResponse
 
 
 class EventListResponse(BaseModel):
     model_config = ConfigDict(from_attributes=True)
 
-    events: List[EventResponse]
+    events: List[DomainEvent]
     total: int
     limit: int
     skip: int

backend/app/schemas_pydantic/user.py

@@ -154,10 +154,10 @@ class RateLimitRuleResponse(BaseModel):
     """Response model for rate limit rule."""
 
     endpoint_pattern: str
-    group: str
+    group: EndpointGroup
     requests: int
     window_seconds: int
-    algorithm: str
+    algorithm: RateLimitAlgorithm
     burst_multiplier: float = 1.5
     priority: int = 0
     enabled: bool = True