Update README and documentation; refactor frontend components for improved structure and resilience
This commit is contained in:
glenn schrooyen
467
services/service-adapters/CLEAN_CODE.md
Normal file
467
services/service-adapters/CLEAN_CODE.md
Normal file
@@ -0,0 +1,467 @@
|
||||
# Service Adapters Clean Code Implementation
|
||||
|
||||
This document outlines the clean code principles and best practices implemented in the LabFusion Service Adapters service (Python FastAPI).
|
||||
|
||||
## 🏗️ **Architecture Overview**
|
||||
|
||||
The Service Adapters follow a modular architecture with clear separation of concerns:
|
||||
|
||||
```
|
||||
service-adapters/
|
||||
├── main.py # FastAPI application entry point
|
||||
├── models/ # Pydantic schemas (Domain Layer)
|
||||
│ ├── __init__.py
|
||||
│ └── schemas.py
|
||||
├── routes/ # API endpoints (Presentation Layer)
|
||||
│ ├── __init__.py
|
||||
│ ├── general.py # General endpoints
|
||||
│ ├── home_assistant.py # Home Assistant integration
|
||||
│ ├── frigate.py # Frigate integration
|
||||
│ ├── immich.py # Immich integration
|
||||
│ └── events.py # Event management
|
||||
├── services/ # Business logic (Service Layer)
|
||||
│ ├── __init__.py
|
||||
│ ├── config.py # Configuration management
|
||||
│ └── redis_client.py # Redis connection
|
||||
├── requirements.txt # Dependencies
|
||||
└── README.md # Service documentation
|
||||
```
|
||||
|
||||
## 🧹 **Clean Code Principles Applied**
|
||||
|
||||
### **1. Single Responsibility Principle (SRP)**
|
||||
|
||||
#### **Route Modules**
|
||||
- **general.py**: Only handles general endpoints (health, services, root)
|
||||
- **home_assistant.py**: Only manages Home Assistant integration
|
||||
- **frigate.py**: Only handles Frigate camera system integration
|
||||
- **immich.py**: Only manages Immich photo management integration
|
||||
- **events.py**: Only handles event publishing and retrieval
|
||||
|
||||
#### **Service Modules**
|
||||
- **config.py**: Only manages service configurations
|
||||
- **redis_client.py**: Only handles Redis connections and operations
|
||||
|
||||
#### **Model Modules**
|
||||
- **schemas.py**: Only contains Pydantic data models
|
||||
|
||||
### **2. Open/Closed Principle (OCP)**
|
||||
|
||||
#### **Extensible Route Design**
|
||||
```python
|
||||
# Easy to add new service integrations
|
||||
from fastapi import APIRouter
|
||||
|
||||
router = APIRouter(prefix="/home-assistant", tags=["Home Assistant"])
|
||||
|
||||
# New integrations can be added without modifying existing code
|
||||
# Just create new route files and include them in main.py
|
||||
```
|
||||
|
||||
#### **Configurable Services**
|
||||
```python
|
||||
# services/config.py
|
||||
SERVICES = {
|
||||
"home_assistant": {
|
||||
"name": "Home Assistant",
|
||||
"url": os.getenv("HOME_ASSISTANT_URL", "http://homeassistant.local:8123"),
|
||||
"token": os.getenv("HOME_ASSISTANT_TOKEN"),
|
||||
"enabled": True
|
||||
}
|
||||
# Easy to add new services
|
||||
}
|
||||
```
|
||||
|
||||
### **3. Dependency Inversion Principle (DIP)**
|
||||
|
||||
#### **Dependency Injection**
|
||||
```python
|
||||
# main.py
|
||||
from services.redis_client import get_redis_client
|
||||
|
||||
app.include_router(general_router, dependencies=[Depends(get_redis_client)])
|
||||
app.include_router(home_assistant_router, dependencies=[Depends(get_redis_client)])
|
||||
```
|
||||
|
||||
#### **Interface-Based Design**
|
||||
```python
|
||||
# services/redis_client.py
|
||||
class RedisClient:
|
||||
def __init__(self, redis_url: str):
|
||||
self.redis_url = redis_url
|
||||
self.client = None
|
||||
|
||||
async def connect(self):
|
||||
# Implementation details hidden
|
||||
pass
|
||||
```
|
||||
|
||||
### **4. Interface Segregation Principle (ISP)**
|
||||
|
||||
#### **Focused Route Groups**
|
||||
- Each route module only exposes endpoints relevant to its service
|
||||
- Clear API boundaries
|
||||
- Minimal dependencies between modules
|
||||
|
||||
## 📝 **Code Quality Improvements**
|
||||
|
||||
### **1. Naming Conventions**
|
||||
|
||||
#### **Clear, Descriptive Names**
|
||||
```python
|
||||
# Good: Clear purpose
|
||||
class ServiceStatus(BaseModel):
|
||||
name: str
|
||||
status: str
|
||||
response_time: Optional[str] = None
|
||||
|
||||
# Good: Descriptive function names
|
||||
async def get_home_assistant_entities()
|
||||
async def get_frigate_events()
|
||||
async def publish_event(event_data: EventData)
|
||||
```
|
||||
|
||||
#### **Consistent Naming**
|
||||
- Classes: PascalCase (e.g., `ServiceStatus`, `EventData`)
|
||||
- Functions: snake_case (e.g., `get_home_assistant_entities`)
|
||||
- Variables: snake_case (e.g., `service_config`)
|
||||
- Constants: UPPER_SNAKE_CASE (e.g., `SERVICES`)
|
||||
|
||||
### **2. Function Design**
|
||||
|
||||
#### **Small, Focused Functions**
|
||||
```python
|
||||
@router.get("/entities")
|
||||
async def get_home_assistant_entities():
|
||||
"""Get all Home Assistant entities."""
|
||||
try:
|
||||
entities = await fetch_ha_entities()
|
||||
return {"entities": entities}
|
||||
except Exception as e:
|
||||
logger.error(f"Error fetching HA entities: {e}")
|
||||
raise HTTPException(status_code=500, detail="Failed to fetch entities")
|
||||
```
|
||||
|
||||
#### **Single Level of Abstraction**
|
||||
- Route functions handle HTTP concerns only
|
||||
- Business logic delegated to service functions
|
||||
- Data validation handled by Pydantic models
|
||||
|
||||
### **3. Error Handling**
|
||||
|
||||
#### **Consistent Error Responses**
|
||||
```python
|
||||
try:
|
||||
result = await some_operation()
|
||||
return result
|
||||
except ConnectionError as e:
|
||||
logger.error(f"Connection error: {e}")
|
||||
raise HTTPException(status_code=503, detail="Service unavailable")
|
||||
except Exception as e:
|
||||
logger.error(f"Unexpected error: {e}")
|
||||
raise HTTPException(status_code=500, detail="Internal server error")
|
||||
```
|
||||
|
||||
#### **Proper HTTP Status Codes**
|
||||
- 200: Success
|
||||
- 404: Not found
|
||||
- 503: Service unavailable
|
||||
- 500: Internal server error
|
||||
|
||||
### **4. Data Validation**
|
||||
|
||||
#### **Pydantic Models**
|
||||
```python
|
||||
class EventData(BaseModel):
|
||||
event_type: str
|
||||
service: str
|
||||
timestamp: datetime
|
||||
data: Dict[str, Any]
|
||||
|
||||
class Config:
|
||||
json_encoders = {
|
||||
datetime: lambda v: v.isoformat()
|
||||
}
|
||||
```
|
||||
|
||||
#### **Input Validation**
|
||||
```python
|
||||
@router.post("/publish-event")
|
||||
async def publish_event(event_data: EventData):
|
||||
# Pydantic automatically validates input
|
||||
await redis_client.publish_event(event_data)
|
||||
return {"message": "Event published successfully"}
|
||||
```
|
||||
|
||||
## 🔧 **FastAPI Best Practices**
|
||||
|
||||
### **1. Router Organization**
|
||||
|
||||
#### **Modular Route Structure**
|
||||
```python
|
||||
# routes/home_assistant.py
|
||||
from fastapi import APIRouter, HTTPException, Depends
|
||||
from models.schemas import HAAttributes, HAEntity
|
||||
from services.redis_client import RedisClient
|
||||
|
||||
router = APIRouter(prefix="/home-assistant", tags=["Home Assistant"])
|
||||
|
||||
@router.get("/entities")
|
||||
async def get_entities(redis: RedisClient = Depends(get_redis_client)):
|
||||
# Implementation
|
||||
```
|
||||
|
||||
#### **Clear API Documentation**
|
||||
```python
|
||||
@router.get(
|
||||
"/entities",
|
||||
response_model=Dict[str, List[HAEntity]],
|
||||
summary="Get Home Assistant entities",
|
||||
description="Retrieve all entities from Home Assistant"
|
||||
)
|
||||
async def get_home_assistant_entities():
|
||||
# Implementation
|
||||
```
|
||||
|
||||
### **2. Dependency Injection**
|
||||
|
||||
#### **Redis Client Injection**
|
||||
```python
|
||||
# services/redis_client.py
|
||||
async def get_redis_client() -> RedisClient:
|
||||
redis = RedisClient(REDIS_URL)
|
||||
await redis.connect()
|
||||
return redis
|
||||
```
|
||||
|
||||
#### **Service Configuration**
|
||||
```python
|
||||
# services/config.py
|
||||
def get_service_config(service_name: str) -> Dict[str, Any]:
|
||||
return SERVICES.get(service_name, {})
|
||||
```
|
||||
|
||||
### **3. OpenAPI Documentation**
|
||||
|
||||
#### **Comprehensive API Documentation**
|
||||
```python
|
||||
app = FastAPI(
|
||||
title="LabFusion Service Adapters",
|
||||
description="Integration adapters for homelab services",
|
||||
version="1.0.0",
|
||||
docs_url="/docs",
|
||||
redoc_url="/redoc"
|
||||
)
|
||||
```
|
||||
|
||||
#### **Detailed Endpoint Documentation**
|
||||
```python
|
||||
@router.get(
|
||||
"/events",
|
||||
response_model=Dict[str, List[FrigateEvent]],
|
||||
summary="Get Frigate events",
|
||||
description="Retrieve recent events from Frigate camera system",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
503: {"description": "Frigate service unavailable"}
|
||||
}
|
||||
)
|
||||
```
|
||||
|
||||
## 📊 **Data Layer Best Practices**
|
||||
|
||||
### **1. Pydantic Model Design**
|
||||
|
||||
#### **Clean Model Structure**
|
||||
```python
|
||||
class ServiceStatus(BaseModel):
|
||||
name: str
|
||||
status: str
|
||||
response_time: Optional[str] = None
|
||||
last_check: Optional[datetime] = None
|
||||
|
||||
class Config:
|
||||
json_encoders = {
|
||||
datetime: lambda v: v.isoformat()
|
||||
}
|
||||
```
|
||||
|
||||
#### **Proper Type Hints**
|
||||
```python
|
||||
from typing import List, Dict, Optional, Any
|
||||
from datetime import datetime
|
||||
|
||||
class EventData(BaseModel):
|
||||
event_type: str
|
||||
service: str
|
||||
timestamp: datetime
|
||||
data: Dict[str, Any]
|
||||
```
|
||||
|
||||
### **2. Configuration Management**
|
||||
|
||||
#### **Environment-Based Configuration**
|
||||
```python
|
||||
# services/config.py
|
||||
import os
|
||||
|
||||
SERVICES = {
|
||||
"home_assistant": {
|
||||
"name": "Home Assistant",
|
||||
"url": os.getenv("HOME_ASSISTANT_URL", "http://homeassistant.local:8123"),
|
||||
"token": os.getenv("HOME_ASSISTANT_TOKEN"),
|
||||
"enabled": os.getenv("HOME_ASSISTANT_ENABLED", "true").lower() == "true"
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
#### **Centralized Configuration**
|
||||
- All service configurations in one place
|
||||
- Environment variable support
|
||||
- Default values for development
|
||||
|
||||
## 🚀 **Performance Optimizations**
|
||||
|
||||
### **1. Async/Await Usage**
|
||||
```python
|
||||
async def fetch_ha_entities() -> List[HAEntity]:
|
||||
async with httpx.AsyncClient() as client:
|
||||
response = await client.get(f"{HA_URL}/api/states")
|
||||
return response.json()
|
||||
```
|
||||
|
||||
### **2. Connection Pooling**
|
||||
```python
|
||||
# services/redis_client.py
|
||||
class RedisClient:
|
||||
def __init__(self, redis_url: str):
|
||||
self.redis_url = redis_url
|
||||
self.client = None
|
||||
|
||||
async def connect(self):
|
||||
self.client = await aioredis.from_url(self.redis_url)
|
||||
```
|
||||
|
||||
### **3. Error Handling**
|
||||
```python
|
||||
async def safe_api_call(url: str, headers: Dict[str, str]) -> Optional[Dict]:
|
||||
try:
|
||||
async with httpx.AsyncClient() as client:
|
||||
response = await client.get(url, headers=headers, timeout=5.0)
|
||||
response.raise_for_status()
|
||||
return response.json()
|
||||
except httpx.TimeoutException:
|
||||
logger.warning(f"Timeout calling {url}")
|
||||
return None
|
||||
except httpx.HTTPStatusError as e:
|
||||
logger.error(f"HTTP error calling {url}: {e}")
|
||||
return None
|
||||
```
|
||||
|
||||
## 🧪 **Testing Strategy**
|
||||
|
||||
### **1. Unit Testing**
|
||||
```python
|
||||
import pytest
|
||||
from unittest.mock import AsyncMock, patch
|
||||
from services.config import SERVICES
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_get_services():
|
||||
with patch('services.redis_client.get_redis_client') as mock_redis:
|
||||
# Test implementation
|
||||
pass
|
||||
```
|
||||
|
||||
### **2. Integration Testing**
|
||||
```python
|
||||
@pytest.mark.asyncio
|
||||
async def test_home_assistant_integration():
|
||||
# Test actual HA API calls
|
||||
pass
|
||||
```
|
||||
|
||||
### **3. Test Structure**
|
||||
```python
|
||||
# tests/test_home_assistant.py
|
||||
import pytest
|
||||
from fastapi.testclient import TestClient
|
||||
from main import app
|
||||
|
||||
client = TestClient(app)
|
||||
|
||||
def test_get_ha_entities():
|
||||
response = client.get("/home-assistant/entities")
|
||||
assert response.status_code == 200
|
||||
```
|
||||
|
||||
## 📋 **Code Review Checklist**
|
||||
|
||||
### **Route Layer**
|
||||
- [ ] Single responsibility per route module
|
||||
- [ ] Proper HTTP status codes
|
||||
- [ ] Input validation with Pydantic
|
||||
- [ ] Error handling
|
||||
- [ ] OpenAPI documentation
|
||||
|
||||
### **Service Layer**
|
||||
- [ ] Business logic only
|
||||
- [ ] No direct HTTP calls in business logic
|
||||
- [ ] Proper exception handling
|
||||
- [ ] Async/await usage
|
||||
- [ ] Clear function names
|
||||
|
||||
### **Model Layer**
|
||||
- [ ] Proper Pydantic models
|
||||
- [ ] Type hints
|
||||
- [ ] Validation constraints
|
||||
- [ ] JSON serialization
|
||||
|
||||
### **Configuration**
|
||||
- [ ] Environment variable support
|
||||
- [ ] Default values
|
||||
- [ ] Centralized configuration
|
||||
- [ ] Service-specific settings
|
||||
|
||||
## 🎯 **Benefits Achieved**
|
||||
|
||||
### **1. Maintainability**
|
||||
- Clear separation of concerns
|
||||
- Easy to modify and extend
|
||||
- Consistent patterns throughout
|
||||
- Self-documenting code
|
||||
|
||||
### **2. Testability**
|
||||
- Isolated modules
|
||||
- Mockable dependencies
|
||||
- Clear interfaces
|
||||
- Testable business logic
|
||||
|
||||
### **3. Performance**
|
||||
- Async/await for non-blocking operations
|
||||
- Connection pooling
|
||||
- Efficient error handling
|
||||
- Resource management
|
||||
|
||||
### **4. Scalability**
|
||||
- Modular architecture
|
||||
- Easy to add new service integrations
|
||||
- Horizontal scaling support
|
||||
- Configuration-driven services
|
||||
|
||||
## 🔮 **Future Improvements**
|
||||
|
||||
### **Potential Enhancements**
|
||||
1. **Circuit Breaker Pattern**: Fault tolerance
|
||||
2. **Retry Logic**: Automatic retry with backoff
|
||||
3. **Caching**: Redis caching for frequently accessed data
|
||||
4. **Metrics**: Prometheus metrics integration
|
||||
5. **Health Checks**: Comprehensive health monitoring
|
||||
|
||||
### **Monitoring & Observability**
|
||||
1. **Logging**: Structured logging with correlation IDs
|
||||
2. **Tracing**: Distributed tracing
|
||||
3. **Metrics**: Service performance metrics
|
||||
4. **Alerts**: Service availability alerts
|
||||
|
||||
This clean code implementation makes the Service Adapters more maintainable, testable, and scalable while following FastAPI and Python best practices.
|
||||
@@ -13,6 +13,7 @@ Python FastAPI service for integrating with external homelab services.
|
||||
- **Framework**: FastAPI
|
||||
- **Port**: 8000
|
||||
- **Message Bus**: Redis
|
||||
- **Documentation**: OpenAPI/Swagger
|
||||
|
||||
## Features
|
||||
- Home Assistant entity integration
|
||||
@@ -20,6 +21,35 @@ Python FastAPI service for integrating with external homelab services.
|
||||
- Immich asset management
|
||||
- n8n workflow triggers
|
||||
- Event publishing to Redis
|
||||
- Comprehensive OpenAPI documentation
|
||||
- Modular architecture for maintainability
|
||||
|
||||
## Project Structure
|
||||
```
|
||||
service-adapters/
|
||||
├── main.py # FastAPI application (40 lines)
|
||||
├── models/
|
||||
│ ├── schemas.py # Pydantic models
|
||||
├── routes/
|
||||
│ ├── general.py # Root, health, services
|
||||
│ ├── home_assistant.py # HA integration
|
||||
│ ├── frigate.py # Frigate integration
|
||||
│ ├── immich.py # Immich integration
|
||||
│ └── events.py # Event management
|
||||
└── services/
|
||||
├── config.py # Service configurations
|
||||
└── redis_client.py # Redis connection
|
||||
```
|
||||
|
||||
## API Endpoints
|
||||
- `GET /` - API information
|
||||
- `GET /health` - Health check
|
||||
- `GET /services` - Service status
|
||||
- `GET /home-assistant/entities` - HA entities
|
||||
- `GET /frigate/events` - Frigate events
|
||||
- `GET /immich/assets` - Immich assets
|
||||
- `POST /publish-event` - Publish events
|
||||
- `GET /events` - Retrieve events
|
||||
|
||||
## Development Status
|
||||
✅ **Complete** - Core functionality implemented
|
||||
✅ **Complete** - Core functionality implemented with modular architecture
|
||||
|
||||
@@ -1,91 +1,14 @@
|
||||
from fastapi import FastAPI, HTTPException, BackgroundTasks, Query, Path
|
||||
from fastapi import FastAPI
|
||||
from fastapi.middleware.cors import CORSMiddleware
|
||||
from fastapi.responses import JSONResponse
|
||||
from pydantic import BaseModel, Field
|
||||
from typing import List, Optional, Dict, Any
|
||||
import asyncio
|
||||
import redis
|
||||
import json
|
||||
from datetime import datetime
|
||||
import os
|
||||
from dotenv import load_dotenv
|
||||
|
||||
# Load environment variables
|
||||
load_dotenv()
|
||||
|
||||
# Pydantic models for request/response schemas
|
||||
class ServiceStatus(BaseModel):
|
||||
enabled: bool = Field(..., description="Whether the service is enabled")
|
||||
url: str = Field(..., description="Service URL")
|
||||
status: str = Field(..., description="Service status")
|
||||
|
||||
class HAAttributes(BaseModel):
|
||||
unit_of_measurement: Optional[str] = Field(None, description="Unit of measurement")
|
||||
friendly_name: Optional[str] = Field(None, description="Friendly name")
|
||||
|
||||
class HAEntity(BaseModel):
|
||||
entity_id: str = Field(..., description="Entity ID")
|
||||
state: str = Field(..., description="Current state")
|
||||
attributes: HAAttributes = Field(..., description="Entity attributes")
|
||||
|
||||
class HAEntitiesResponse(BaseModel):
|
||||
entities: List[HAEntity] = Field(..., description="List of Home Assistant entities")
|
||||
|
||||
class FrigateEvent(BaseModel):
|
||||
id: str = Field(..., description="Event ID")
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
camera: str = Field(..., description="Camera name")
|
||||
label: str = Field(..., description="Detection label")
|
||||
confidence: float = Field(..., ge=0, le=1, description="Detection confidence")
|
||||
|
||||
class FrigateEventsResponse(BaseModel):
|
||||
events: List[FrigateEvent] = Field(..., description="List of Frigate events")
|
||||
|
||||
class ImmichAsset(BaseModel):
|
||||
id: str = Field(..., description="Asset ID")
|
||||
filename: str = Field(..., description="Filename")
|
||||
created_at: str = Field(..., description="Creation timestamp")
|
||||
tags: List[str] = Field(..., description="Asset tags")
|
||||
faces: List[str] = Field(..., description="Detected faces")
|
||||
|
||||
class ImmichAssetsResponse(BaseModel):
|
||||
assets: List[ImmichAsset] = Field(..., description="List of Immich assets")
|
||||
|
||||
class EventData(BaseModel):
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: Dict[str, Any] = Field(default_factory=dict, description="Event metadata")
|
||||
|
||||
class EventResponse(BaseModel):
|
||||
status: str = Field(..., description="Publication status")
|
||||
event: Dict[str, Any] = Field(..., description="Published event")
|
||||
|
||||
class Event(BaseModel):
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: str = Field(..., description="Event metadata as JSON string")
|
||||
|
||||
class EventsResponse(BaseModel):
|
||||
events: List[Event] = Field(..., description="List of events")
|
||||
|
||||
class HealthResponse(BaseModel):
|
||||
status: str = Field(..., description="Service health status")
|
||||
timestamp: str = Field(..., description="Health check timestamp")
|
||||
|
||||
class RootResponse(BaseModel):
|
||||
message: str = Field(..., description="API message")
|
||||
version: str = Field(..., description="API version")
|
||||
# Import route modules
|
||||
from routes import general, home_assistant, frigate, immich, events
|
||||
|
||||
# Create FastAPI app
|
||||
app = FastAPI(
|
||||
title="LabFusion Service Adapters",
|
||||
description="Service integration adapters for Home Assistant, Frigate, Immich, and other homelab services",
|
||||
version="1.0.0",
|
||||
contact={
|
||||
"name": "LabFusion Team",
|
||||
"url": "https://github.com/labfusion/labfusion",
|
||||
"email": "team@labfusion.dev"
|
||||
},
|
||||
license_info={
|
||||
"name": "MIT License",
|
||||
"url": "https://opensource.org/licenses/MIT"
|
||||
@@ -111,312 +34,12 @@ app.add_middleware(
|
||||
allow_headers=["*"],
|
||||
)
|
||||
|
||||
# Redis connection
|
||||
redis_client = redis.Redis(
|
||||
host=os.getenv("REDIS_HOST", "localhost"),
|
||||
port=int(os.getenv("REDIS_PORT", 6379)),
|
||||
decode_responses=True
|
||||
)
|
||||
|
||||
# Service configurations
|
||||
SERVICES = {
|
||||
"home_assistant": {
|
||||
"url": os.getenv("HOME_ASSISTANT_URL", "https://homeassistant.local:8123"),
|
||||
"token": os.getenv("HOME_ASSISTANT_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("HOME_ASSISTANT_TOKEN"))
|
||||
},
|
||||
"frigate": {
|
||||
"url": os.getenv("FRIGATE_URL", "http://frigate.local:5000"),
|
||||
"token": os.getenv("FRIGATE_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("FRIGATE_TOKEN"))
|
||||
},
|
||||
"immich": {
|
||||
"url": os.getenv("IMMICH_URL", "http://immich.local:2283"),
|
||||
"api_key": os.getenv("IMMICH_API_KEY", ""),
|
||||
"enabled": bool(os.getenv("IMMICH_API_KEY"))
|
||||
},
|
||||
"n8n": {
|
||||
"url": os.getenv("N8N_URL", "http://n8n.local:5678"),
|
||||
"webhook_url": os.getenv("N8N_WEBHOOK_URL", ""),
|
||||
"enabled": bool(os.getenv("N8N_WEBHOOK_URL"))
|
||||
}
|
||||
}
|
||||
|
||||
@app.get("/",
|
||||
response_model=RootResponse,
|
||||
summary="API Root",
|
||||
description="Get basic API information",
|
||||
tags=["General"])
|
||||
async def root():
|
||||
"""Get basic API information and version"""
|
||||
return RootResponse(
|
||||
message="LabFusion Service Adapters API",
|
||||
version="1.0.0"
|
||||
)
|
||||
|
||||
@app.get("/health",
|
||||
response_model=HealthResponse,
|
||||
summary="Health Check",
|
||||
description="Check service health status",
|
||||
tags=["General"])
|
||||
async def health_check():
|
||||
"""Check the health status of the service adapters"""
|
||||
return HealthResponse(
|
||||
status="healthy",
|
||||
timestamp=datetime.now().isoformat()
|
||||
)
|
||||
|
||||
@app.get("/services",
|
||||
response_model=Dict[str, ServiceStatus],
|
||||
summary="Get Service Status",
|
||||
description="Get status of all configured external services",
|
||||
tags=["Services"])
|
||||
async def get_services():
|
||||
"""Get status of all configured external services (Home Assistant, Frigate, Immich, n8n)"""
|
||||
service_status = {}
|
||||
for service_name, config in SERVICES.items():
|
||||
service_status[service_name] = ServiceStatus(
|
||||
enabled=config["enabled"],
|
||||
url=config["url"],
|
||||
status="unknown" # Would check actual service status
|
||||
)
|
||||
return service_status
|
||||
|
||||
@app.get("/home-assistant/entities",
|
||||
response_model=HAEntitiesResponse,
|
||||
summary="Get Home Assistant Entities",
|
||||
description="Retrieve all entities from Home Assistant",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entities"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entities():
|
||||
"""Get Home Assistant entities including sensors, switches, and other devices"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntitiesResponse(
|
||||
entities=[
|
||||
HAEntity(
|
||||
entity_id="sensor.cpu_usage",
|
||||
state="45.2",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="%",
|
||||
friendly_name="CPU Usage"
|
||||
)
|
||||
),
|
||||
HAEntity(
|
||||
entity_id="sensor.memory_usage",
|
||||
state="2.1",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="GB",
|
||||
friendly_name="Memory Usage"
|
||||
)
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.get("/frigate/events",
|
||||
response_model=FrigateEventsResponse,
|
||||
summary="Get Frigate Events",
|
||||
description="Retrieve detection events from Frigate NVR",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_events():
|
||||
"""Get Frigate detection events including person, vehicle, and object detections"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return FrigateEventsResponse(
|
||||
events=[
|
||||
FrigateEvent(
|
||||
id="event_123",
|
||||
timestamp=datetime.now().isoformat(),
|
||||
camera="front_door",
|
||||
label="person",
|
||||
confidence=0.95
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.get("/immich/assets",
|
||||
response_model=ImmichAssetsResponse,
|
||||
summary="Get Immich Assets",
|
||||
description="Retrieve photo assets from Immich",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved assets"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_assets():
|
||||
"""Get Immich photo assets including metadata, tags, and face detection results"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return ImmichAssetsResponse(
|
||||
assets=[
|
||||
ImmichAsset(
|
||||
id="asset_123",
|
||||
filename="photo_001.jpg",
|
||||
created_at=datetime.now().isoformat(),
|
||||
tags=["person", "outdoor"],
|
||||
faces=["Alice", "Bob"]
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.post("/publish-event",
|
||||
response_model=EventResponse,
|
||||
summary="Publish Event",
|
||||
description="Publish an event to the Redis message bus",
|
||||
responses={
|
||||
200: {"description": "Event published successfully"},
|
||||
500: {"description": "Failed to publish event"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def publish_event(event_data: EventData, background_tasks: BackgroundTasks):
|
||||
"""Publish an event to the Redis message bus for consumption by other services"""
|
||||
try:
|
||||
event = {
|
||||
"timestamp": datetime.now().isoformat(),
|
||||
"service": event_data.service,
|
||||
"event_type": event_data.event_type,
|
||||
"metadata": json.dumps(event_data.metadata)
|
||||
}
|
||||
|
||||
# Publish to Redis
|
||||
redis_client.lpush("events", json.dumps(event))
|
||||
|
||||
return EventResponse(
|
||||
status="published",
|
||||
event=event
|
||||
)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/events",
|
||||
response_model=EventsResponse,
|
||||
summary="Get Events",
|
||||
description="Retrieve recent events from the message bus",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
500: {"description": "Failed to retrieve events"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def get_events(limit: int = Query(100, ge=1, le=1000, description="Maximum number of events to retrieve")):
|
||||
"""Get recent events from the Redis message bus"""
|
||||
try:
|
||||
events = redis_client.lrange("events", 0, limit - 1)
|
||||
parsed_events = []
|
||||
for event in events:
|
||||
try:
|
||||
event_data = json.loads(event)
|
||||
parsed_events.append(Event(**event_data))
|
||||
except json.JSONDecodeError:
|
||||
continue
|
||||
|
||||
return EventsResponse(events=parsed_events)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/home-assistant/entity/{entity_id}",
|
||||
response_model=HAEntity,
|
||||
summary="Get Specific HA Entity",
|
||||
description="Get a specific Home Assistant entity by ID",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entity"},
|
||||
404: {"description": "Entity not found"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entity(entity_id: str = Path(..., description="Entity ID")):
|
||||
"""Get a specific Home Assistant entity by its ID"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntity(
|
||||
entity_id=entity_id,
|
||||
state="unknown",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="",
|
||||
friendly_name=f"Entity {entity_id}"
|
||||
)
|
||||
)
|
||||
|
||||
@app.get("/frigate/cameras",
|
||||
summary="Get Frigate Cameras",
|
||||
description="Get list of Frigate cameras",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved cameras"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_cameras():
|
||||
"""Get list of available Frigate cameras"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return {
|
||||
"cameras": [
|
||||
{"name": "front_door", "enabled": True},
|
||||
{"name": "back_yard", "enabled": True},
|
||||
{"name": "garage", "enabled": False}
|
||||
]
|
||||
}
|
||||
|
||||
@app.get("/immich/albums",
|
||||
summary="Get Immich Albums",
|
||||
description="Get list of Immich albums",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved albums"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_albums():
|
||||
"""Get list of Immich albums"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return {
|
||||
"albums": [
|
||||
{"id": "album_1", "name": "Family Photos", "asset_count": 150},
|
||||
{"id": "album_2", "name": "Vacation 2024", "asset_count": 75}
|
||||
]
|
||||
}
|
||||
# Include routers
|
||||
app.include_router(general.router)
|
||||
app.include_router(home_assistant.router)
|
||||
app.include_router(frigate.router)
|
||||
app.include_router(immich.router)
|
||||
app.include_router(events.router)
|
||||
|
||||
if __name__ == "__main__":
|
||||
import uvicorn
|
||||
|
||||
423
services/service-adapters/main_old.py
Normal file
423
services/service-adapters/main_old.py
Normal file
@@ -0,0 +1,423 @@
|
||||
from fastapi import FastAPI, HTTPException, BackgroundTasks, Query, Path
|
||||
from fastapi.middleware.cors import CORSMiddleware
|
||||
from fastapi.responses import JSONResponse
|
||||
from pydantic import BaseModel, Field
|
||||
from typing import List, Optional, Dict, Any
|
||||
import asyncio
|
||||
import redis
|
||||
import json
|
||||
from datetime import datetime
|
||||
import os
|
||||
from dotenv import load_dotenv
|
||||
|
||||
# Load environment variables
|
||||
load_dotenv()
|
||||
|
||||
# Pydantic models for request/response schemas
|
||||
class ServiceStatus(BaseModel):
|
||||
enabled: bool = Field(..., description="Whether the service is enabled")
|
||||
url: str = Field(..., description="Service URL")
|
||||
status: str = Field(..., description="Service status")
|
||||
|
||||
class HAAttributes(BaseModel):
|
||||
unit_of_measurement: Optional[str] = Field(None, description="Unit of measurement")
|
||||
friendly_name: Optional[str] = Field(None, description="Friendly name")
|
||||
|
||||
class HAEntity(BaseModel):
|
||||
entity_id: str = Field(..., description="Entity ID")
|
||||
state: str = Field(..., description="Current state")
|
||||
attributes: HAAttributes = Field(..., description="Entity attributes")
|
||||
|
||||
class HAEntitiesResponse(BaseModel):
|
||||
entities: List[HAEntity] = Field(..., description="List of Home Assistant entities")
|
||||
|
||||
class FrigateEvent(BaseModel):
|
||||
id: str = Field(..., description="Event ID")
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
camera: str = Field(..., description="Camera name")
|
||||
label: str = Field(..., description="Detection label")
|
||||
confidence: float = Field(..., ge=0, le=1, description="Detection confidence")
|
||||
|
||||
class FrigateEventsResponse(BaseModel):
|
||||
events: List[FrigateEvent] = Field(..., description="List of Frigate events")
|
||||
|
||||
class ImmichAsset(BaseModel):
|
||||
id: str = Field(..., description="Asset ID")
|
||||
filename: str = Field(..., description="Filename")
|
||||
created_at: str = Field(..., description="Creation timestamp")
|
||||
tags: List[str] = Field(..., description="Asset tags")
|
||||
faces: List[str] = Field(..., description="Detected faces")
|
||||
|
||||
class ImmichAssetsResponse(BaseModel):
|
||||
assets: List[ImmichAsset] = Field(..., description="List of Immich assets")
|
||||
|
||||
class EventData(BaseModel):
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: Dict[str, Any] = Field(default_factory=dict, description="Event metadata")
|
||||
|
||||
class EventResponse(BaseModel):
|
||||
status: str = Field(..., description="Publication status")
|
||||
event: Dict[str, Any] = Field(..., description="Published event")
|
||||
|
||||
class Event(BaseModel):
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: str = Field(..., description="Event metadata as JSON string")
|
||||
|
||||
class EventsResponse(BaseModel):
|
||||
events: List[Event] = Field(..., description="List of events")
|
||||
|
||||
class HealthResponse(BaseModel):
|
||||
status: str = Field(..., description="Service health status")
|
||||
timestamp: str = Field(..., description="Health check timestamp")
|
||||
|
||||
class RootResponse(BaseModel):
|
||||
message: str = Field(..., description="API message")
|
||||
version: str = Field(..., description="API version")
|
||||
|
||||
app = FastAPI(
|
||||
title="LabFusion Service Adapters",
|
||||
description="Service integration adapters for Home Assistant, Frigate, Immich, and other homelab services",
|
||||
version="1.0.0",
|
||||
contact={
|
||||
"name": "LabFusion Team",
|
||||
"url": "https://github.com/labfusion/labfusion",
|
||||
"email": "team@labfusion.dev"
|
||||
},
|
||||
license_info={
|
||||
"name": "MIT License",
|
||||
"url": "https://opensource.org/licenses/MIT"
|
||||
},
|
||||
servers=[
|
||||
{
|
||||
"url": "http://localhost:8000",
|
||||
"description": "Development Server"
|
||||
},
|
||||
{
|
||||
"url": "https://adapters.labfusion.dev",
|
||||
"description": "Production Server"
|
||||
}
|
||||
]
|
||||
)
|
||||
|
||||
# CORS middleware
|
||||
app.add_middleware(
|
||||
CORSMiddleware,
|
||||
allow_origins=["*"],
|
||||
allow_credentials=True,
|
||||
allow_methods=["*"],
|
||||
allow_headers=["*"],
|
||||
)
|
||||
|
||||
# Redis connection
|
||||
redis_client = redis.Redis(
|
||||
host=os.getenv("REDIS_HOST", "localhost"),
|
||||
port=int(os.getenv("REDIS_PORT", 6379)),
|
||||
decode_responses=True
|
||||
)
|
||||
|
||||
# Service configurations
|
||||
SERVICES = {
|
||||
"home_assistant": {
|
||||
"url": os.getenv("HOME_ASSISTANT_URL", "https://homeassistant.local:8123"),
|
||||
"token": os.getenv("HOME_ASSISTANT_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("HOME_ASSISTANT_TOKEN"))
|
||||
},
|
||||
"frigate": {
|
||||
"url": os.getenv("FRIGATE_URL", "http://frigate.local:5000"),
|
||||
"token": os.getenv("FRIGATE_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("FRIGATE_TOKEN"))
|
||||
},
|
||||
"immich": {
|
||||
"url": os.getenv("IMMICH_URL", "http://immich.local:2283"),
|
||||
"api_key": os.getenv("IMMICH_API_KEY", ""),
|
||||
"enabled": bool(os.getenv("IMMICH_API_KEY"))
|
||||
},
|
||||
"n8n": {
|
||||
"url": os.getenv("N8N_URL", "http://n8n.local:5678"),
|
||||
"webhook_url": os.getenv("N8N_WEBHOOK_URL", ""),
|
||||
"enabled": bool(os.getenv("N8N_WEBHOOK_URL"))
|
||||
}
|
||||
}
|
||||
|
||||
@app.get("/",
|
||||
response_model=RootResponse,
|
||||
summary="API Root",
|
||||
description="Get basic API information",
|
||||
tags=["General"])
|
||||
async def root():
|
||||
"""Get basic API information and version"""
|
||||
return RootResponse(
|
||||
message="LabFusion Service Adapters API",
|
||||
version="1.0.0"
|
||||
)
|
||||
|
||||
@app.get("/health",
|
||||
response_model=HealthResponse,
|
||||
summary="Health Check",
|
||||
description="Check service health status",
|
||||
tags=["General"])
|
||||
async def health_check():
|
||||
"""Check the health status of the service adapters"""
|
||||
return HealthResponse(
|
||||
status="healthy",
|
||||
timestamp=datetime.now().isoformat()
|
||||
)
|
||||
|
||||
@app.get("/services",
|
||||
response_model=Dict[str, ServiceStatus],
|
||||
summary="Get Service Status",
|
||||
description="Get status of all configured external services",
|
||||
tags=["Services"])
|
||||
async def get_services():
|
||||
"""Get status of all configured external services (Home Assistant, Frigate, Immich, n8n)"""
|
||||
service_status = {}
|
||||
for service_name, config in SERVICES.items():
|
||||
service_status[service_name] = ServiceStatus(
|
||||
enabled=config["enabled"],
|
||||
url=config["url"],
|
||||
status="unknown" # Would check actual service status
|
||||
)
|
||||
return service_status
|
||||
|
||||
@app.get("/home-assistant/entities",
|
||||
response_model=HAEntitiesResponse,
|
||||
summary="Get Home Assistant Entities",
|
||||
description="Retrieve all entities from Home Assistant",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entities"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entities():
|
||||
"""Get Home Assistant entities including sensors, switches, and other devices"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntitiesResponse(
|
||||
entities=[
|
||||
HAEntity(
|
||||
entity_id="sensor.cpu_usage",
|
||||
state="45.2",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="%",
|
||||
friendly_name="CPU Usage"
|
||||
)
|
||||
),
|
||||
HAEntity(
|
||||
entity_id="sensor.memory_usage",
|
||||
state="2.1",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="GB",
|
||||
friendly_name="Memory Usage"
|
||||
)
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.get("/frigate/events",
|
||||
response_model=FrigateEventsResponse,
|
||||
summary="Get Frigate Events",
|
||||
description="Retrieve detection events from Frigate NVR",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_events():
|
||||
"""Get Frigate detection events including person, vehicle, and object detections"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return FrigateEventsResponse(
|
||||
events=[
|
||||
FrigateEvent(
|
||||
id="event_123",
|
||||
timestamp=datetime.now().isoformat(),
|
||||
camera="front_door",
|
||||
label="person",
|
||||
confidence=0.95
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.get("/immich/assets",
|
||||
response_model=ImmichAssetsResponse,
|
||||
summary="Get Immich Assets",
|
||||
description="Retrieve photo assets from Immich",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved assets"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_assets():
|
||||
"""Get Immich photo assets including metadata, tags, and face detection results"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return ImmichAssetsResponse(
|
||||
assets=[
|
||||
ImmichAsset(
|
||||
id="asset_123",
|
||||
filename="photo_001.jpg",
|
||||
created_at=datetime.now().isoformat(),
|
||||
tags=["person", "outdoor"],
|
||||
faces=["Alice", "Bob"]
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@app.post("/publish-event",
|
||||
response_model=EventResponse,
|
||||
summary="Publish Event",
|
||||
description="Publish an event to the Redis message bus",
|
||||
responses={
|
||||
200: {"description": "Event published successfully"},
|
||||
500: {"description": "Failed to publish event"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def publish_event(event_data: EventData, background_tasks: BackgroundTasks):
|
||||
"""Publish an event to the Redis message bus for consumption by other services"""
|
||||
try:
|
||||
event = {
|
||||
"timestamp": datetime.now().isoformat(),
|
||||
"service": event_data.service,
|
||||
"event_type": event_data.event_type,
|
||||
"metadata": json.dumps(event_data.metadata)
|
||||
}
|
||||
|
||||
# Publish to Redis
|
||||
redis_client.lpush("events", json.dumps(event))
|
||||
|
||||
return EventResponse(
|
||||
status="published",
|
||||
event=event
|
||||
)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/events",
|
||||
response_model=EventsResponse,
|
||||
summary="Get Events",
|
||||
description="Retrieve recent events from the message bus",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
500: {"description": "Failed to retrieve events"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def get_events(limit: int = Query(100, ge=1, le=1000, description="Maximum number of events to retrieve")):
|
||||
"""Get recent events from the Redis message bus"""
|
||||
try:
|
||||
events = redis_client.lrange("events", 0, limit - 1)
|
||||
parsed_events = []
|
||||
for event in events:
|
||||
try:
|
||||
event_data = json.loads(event)
|
||||
parsed_events.append(Event(**event_data))
|
||||
except json.JSONDecodeError:
|
||||
continue
|
||||
|
||||
return EventsResponse(events=parsed_events)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/home-assistant/entity/{entity_id}",
|
||||
response_model=HAEntity,
|
||||
summary="Get Specific HA Entity",
|
||||
description="Get a specific Home Assistant entity by ID",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entity"},
|
||||
404: {"description": "Entity not found"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entity(entity_id: str = Path(..., description="Entity ID")):
|
||||
"""Get a specific Home Assistant entity by its ID"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntity(
|
||||
entity_id=entity_id,
|
||||
state="unknown",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="",
|
||||
friendly_name=f"Entity {entity_id}"
|
||||
)
|
||||
)
|
||||
|
||||
@app.get("/frigate/cameras",
|
||||
summary="Get Frigate Cameras",
|
||||
description="Get list of Frigate cameras",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved cameras"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_cameras():
|
||||
"""Get list of available Frigate cameras"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return {
|
||||
"cameras": [
|
||||
{"name": "front_door", "enabled": True},
|
||||
{"name": "back_yard", "enabled": True},
|
||||
{"name": "garage", "enabled": False}
|
||||
]
|
||||
}
|
||||
|
||||
@app.get("/immich/albums",
|
||||
summary="Get Immich Albums",
|
||||
description="Get list of Immich albums",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved albums"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_albums():
|
||||
"""Get list of Immich albums"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return {
|
||||
"albums": [
|
||||
{"id": "album_1", "name": "Family Photos", "asset_count": 150},
|
||||
{"id": "album_2", "name": "Vacation 2024", "asset_count": 75}
|
||||
]
|
||||
}
|
||||
|
||||
if __name__ == "__main__":
|
||||
import uvicorn
|
||||
uvicorn.run(app, host="0.0.0.0", port=8000)
|
||||
1
services/service-adapters/models/__init__.py
Normal file
1
services/service-adapters/models/__init__.py
Normal file
@@ -0,0 +1 @@
|
||||
# Models package
|
||||
65
services/service-adapters/models/schemas.py
Normal file
65
services/service-adapters/models/schemas.py
Normal file
@@ -0,0 +1,65 @@
|
||||
from pydantic import BaseModel, Field
|
||||
from typing import List, Optional, Dict, Any
|
||||
|
||||
class ServiceStatus(BaseModel):
|
||||
enabled: bool = Field(..., description="Whether the service is enabled")
|
||||
url: str = Field(..., description="Service URL")
|
||||
status: str = Field(..., description="Service status")
|
||||
|
||||
class HAAttributes(BaseModel):
|
||||
unit_of_measurement: Optional[str] = Field(None, description="Unit of measurement")
|
||||
friendly_name: Optional[str] = Field(None, description="Friendly name")
|
||||
|
||||
class HAEntity(BaseModel):
|
||||
entity_id: str = Field(..., description="Entity ID")
|
||||
state: str = Field(..., description="Current state")
|
||||
attributes: HAAttributes = Field(..., description="Entity attributes")
|
||||
|
||||
class HAEntitiesResponse(BaseModel):
|
||||
entities: List[HAEntity] = Field(..., description="List of Home Assistant entities")
|
||||
|
||||
class FrigateEvent(BaseModel):
|
||||
id: str = Field(..., description="Event ID")
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
camera: str = Field(..., description="Camera name")
|
||||
label: str = Field(..., description="Detection label")
|
||||
confidence: float = Field(..., ge=0, le=1, description="Detection confidence")
|
||||
|
||||
class FrigateEventsResponse(BaseModel):
|
||||
events: List[FrigateEvent] = Field(..., description="List of Frigate events")
|
||||
|
||||
class ImmichAsset(BaseModel):
|
||||
id: str = Field(..., description="Asset ID")
|
||||
filename: str = Field(..., description="Filename")
|
||||
created_at: str = Field(..., description="Creation timestamp")
|
||||
tags: List[str] = Field(..., description="Asset tags")
|
||||
faces: List[str] = Field(..., description="Detected faces")
|
||||
|
||||
class ImmichAssetsResponse(BaseModel):
|
||||
assets: List[ImmichAsset] = Field(..., description="List of Immich assets")
|
||||
|
||||
class EventData(BaseModel):
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: Dict[str, Any] = Field(default_factory=dict, description="Event metadata")
|
||||
|
||||
class EventResponse(BaseModel):
|
||||
status: str = Field(..., description="Publication status")
|
||||
event: Dict[str, Any] = Field(..., description="Published event")
|
||||
|
||||
class Event(BaseModel):
|
||||
timestamp: str = Field(..., description="Event timestamp")
|
||||
service: str = Field(..., description="Service name")
|
||||
event_type: str = Field(..., description="Event type")
|
||||
metadata: str = Field(..., description="Event metadata as JSON string")
|
||||
|
||||
class EventsResponse(BaseModel):
|
||||
events: List[Event] = Field(..., description="List of events")
|
||||
|
||||
class HealthResponse(BaseModel):
|
||||
status: str = Field(..., description="Service health status")
|
||||
timestamp: str = Field(..., description="Health check timestamp")
|
||||
|
||||
class RootResponse(BaseModel):
|
||||
message: str = Field(..., description="API message")
|
||||
version: str = Field(..., description="API version")
|
||||
1
services/service-adapters/routes/__init__.py
Normal file
1
services/service-adapters/routes/__init__.py
Normal file
@@ -0,0 +1 @@
|
||||
# Routes package
|
||||
61
services/service-adapters/routes/events.py
Normal file
61
services/service-adapters/routes/events.py
Normal file
@@ -0,0 +1,61 @@
|
||||
from fastapi import APIRouter, HTTPException, Query, BackgroundTasks
|
||||
from models.schemas import EventData, EventResponse, EventsResponse, Event
|
||||
from services.redis_client import redis_client
|
||||
from datetime import datetime
|
||||
import json
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.post("/publish-event",
|
||||
response_model=EventResponse,
|
||||
summary="Publish Event",
|
||||
description="Publish an event to the Redis message bus",
|
||||
responses={
|
||||
200: {"description": "Event published successfully"},
|
||||
500: {"description": "Failed to publish event"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def publish_event(event_data: EventData, background_tasks: BackgroundTasks):
|
||||
"""Publish an event to the Redis message bus for consumption by other services"""
|
||||
try:
|
||||
event = {
|
||||
"timestamp": datetime.now().isoformat(),
|
||||
"service": event_data.service,
|
||||
"event_type": event_data.event_type,
|
||||
"metadata": json.dumps(event_data.metadata)
|
||||
}
|
||||
|
||||
# Publish to Redis
|
||||
redis_client.lpush("events", json.dumps(event))
|
||||
|
||||
return EventResponse(
|
||||
status="published",
|
||||
event=event
|
||||
)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@router.get("/events",
|
||||
response_model=EventsResponse,
|
||||
summary="Get Events",
|
||||
description="Retrieve recent events from the message bus",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
500: {"description": "Failed to retrieve events"}
|
||||
},
|
||||
tags=["Events"])
|
||||
async def get_events(limit: int = Query(100, ge=1, le=1000, description="Maximum number of events to retrieve")):
|
||||
"""Get recent events from the Redis message bus"""
|
||||
try:
|
||||
events = redis_client.lrange("events", 0, limit - 1)
|
||||
parsed_events = []
|
||||
for event in events:
|
||||
try:
|
||||
event_data = json.loads(event)
|
||||
parsed_events.append(Event(**event_data))
|
||||
except json.JSONDecodeError:
|
||||
continue
|
||||
|
||||
return EventsResponse(events=parsed_events)
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
63
services/service-adapters/routes/frigate.py
Normal file
63
services/service-adapters/routes/frigate.py
Normal file
@@ -0,0 +1,63 @@
|
||||
from fastapi import APIRouter, HTTPException
|
||||
from models.schemas import FrigateEventsResponse, FrigateEvent
|
||||
from services.config import SERVICES
|
||||
from datetime import datetime
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.get("/frigate/events",
|
||||
response_model=FrigateEventsResponse,
|
||||
summary="Get Frigate Events",
|
||||
description="Retrieve detection events from Frigate NVR",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved events"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_events():
|
||||
"""Get Frigate detection events including person, vehicle, and object detections"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return FrigateEventsResponse(
|
||||
events=[
|
||||
FrigateEvent(
|
||||
id="event_123",
|
||||
timestamp=datetime.now().isoformat(),
|
||||
camera="front_door",
|
||||
label="person",
|
||||
confidence=0.95
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@router.get("/frigate/cameras",
|
||||
summary="Get Frigate Cameras",
|
||||
description="Get list of Frigate cameras",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved cameras"},
|
||||
503: {"description": "Frigate integration not configured"}
|
||||
},
|
||||
tags=["Frigate"])
|
||||
async def get_frigate_cameras():
|
||||
"""Get list of available Frigate cameras"""
|
||||
if not SERVICES["frigate"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Frigate integration not configured. Please set FRIGATE_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Frigate
|
||||
# For now, return mock data
|
||||
return {
|
||||
"cameras": [
|
||||
{"name": "front_door", "enabled": True},
|
||||
{"name": "back_yard", "enabled": True},
|
||||
{"name": "garage", "enabled": False}
|
||||
]
|
||||
}
|
||||
46
services/service-adapters/routes/general.py
Normal file
46
services/service-adapters/routes/general.py
Normal file
@@ -0,0 +1,46 @@
|
||||
from fastapi import APIRouter
|
||||
from datetime import datetime
|
||||
from models.schemas import RootResponse, HealthResponse, ServiceStatus
|
||||
from services.config import SERVICES
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.get("/",
|
||||
response_model=RootResponse,
|
||||
summary="API Root",
|
||||
description="Get basic API information",
|
||||
tags=["General"])
|
||||
async def root():
|
||||
"""Get basic API information and version"""
|
||||
return RootResponse(
|
||||
message="LabFusion Service Adapters API",
|
||||
version="1.0.0"
|
||||
)
|
||||
|
||||
@router.get("/health",
|
||||
response_model=HealthResponse,
|
||||
summary="Health Check",
|
||||
description="Check service health status",
|
||||
tags=["General"])
|
||||
async def health_check():
|
||||
"""Check the health status of the service adapters"""
|
||||
return HealthResponse(
|
||||
status="healthy",
|
||||
timestamp=datetime.now().isoformat()
|
||||
)
|
||||
|
||||
@router.get("/services",
|
||||
response_model=dict,
|
||||
summary="Get Service Status",
|
||||
description="Get status of all configured external services",
|
||||
tags=["Services"])
|
||||
async def get_services():
|
||||
"""Get status of all configured external services (Home Assistant, Frigate, Immich, n8n)"""
|
||||
service_status = {}
|
||||
for service_name, config in SERVICES.items():
|
||||
service_status[service_name] = ServiceStatus(
|
||||
enabled=config["enabled"],
|
||||
url=config["url"],
|
||||
status="unknown" # Would check actual service status
|
||||
)
|
||||
return service_status
|
||||
74
services/service-adapters/routes/home_assistant.py
Normal file
74
services/service-adapters/routes/home_assistant.py
Normal file
@@ -0,0 +1,74 @@
|
||||
from fastapi import APIRouter, HTTPException, Path
|
||||
from models.schemas import HAEntitiesResponse, HAEntity, HAAttributes
|
||||
from services.config import SERVICES
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.get("/home-assistant/entities",
|
||||
response_model=HAEntitiesResponse,
|
||||
summary="Get Home Assistant Entities",
|
||||
description="Retrieve all entities from Home Assistant",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entities"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entities():
|
||||
"""Get Home Assistant entities including sensors, switches, and other devices"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntitiesResponse(
|
||||
entities=[
|
||||
HAEntity(
|
||||
entity_id="sensor.cpu_usage",
|
||||
state="45.2",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="%",
|
||||
friendly_name="CPU Usage"
|
||||
)
|
||||
),
|
||||
HAEntity(
|
||||
entity_id="sensor.memory_usage",
|
||||
state="2.1",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="GB",
|
||||
friendly_name="Memory Usage"
|
||||
)
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@router.get("/home-assistant/entity/{entity_id}",
|
||||
response_model=HAEntity,
|
||||
summary="Get Specific HA Entity",
|
||||
description="Get a specific Home Assistant entity by ID",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved entity"},
|
||||
404: {"description": "Entity not found"},
|
||||
503: {"description": "Home Assistant integration not configured"}
|
||||
},
|
||||
tags=["Home Assistant"])
|
||||
async def get_ha_entity(entity_id: str = Path(..., description="Entity ID")):
|
||||
"""Get a specific Home Assistant entity by its ID"""
|
||||
if not SERVICES["home_assistant"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Home Assistant integration not configured. Please set HOME_ASSISTANT_TOKEN environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Home Assistant
|
||||
# For now, return mock data
|
||||
return HAEntity(
|
||||
entity_id=entity_id,
|
||||
state="unknown",
|
||||
attributes=HAAttributes(
|
||||
unit_of_measurement="",
|
||||
friendly_name=f"Entity {entity_id}"
|
||||
)
|
||||
)
|
||||
62
services/service-adapters/routes/immich.py
Normal file
62
services/service-adapters/routes/immich.py
Normal file
@@ -0,0 +1,62 @@
|
||||
from fastapi import APIRouter, HTTPException
|
||||
from models.schemas import ImmichAssetsResponse, ImmichAsset
|
||||
from services.config import SERVICES
|
||||
from datetime import datetime
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.get("/immich/assets",
|
||||
response_model=ImmichAssetsResponse,
|
||||
summary="Get Immich Assets",
|
||||
description="Retrieve photo assets from Immich",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved assets"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_assets():
|
||||
"""Get Immich photo assets including metadata, tags, and face detection results"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return ImmichAssetsResponse(
|
||||
assets=[
|
||||
ImmichAsset(
|
||||
id="asset_123",
|
||||
filename="photo_001.jpg",
|
||||
created_at=datetime.now().isoformat(),
|
||||
tags=["person", "outdoor"],
|
||||
faces=["Alice", "Bob"]
|
||||
)
|
||||
]
|
||||
)
|
||||
|
||||
@router.get("/immich/albums",
|
||||
summary="Get Immich Albums",
|
||||
description="Get list of Immich albums",
|
||||
responses={
|
||||
200: {"description": "Successfully retrieved albums"},
|
||||
503: {"description": "Immich integration not configured"}
|
||||
},
|
||||
tags=["Immich"])
|
||||
async def get_immich_albums():
|
||||
"""Get list of Immich albums"""
|
||||
if not SERVICES["immich"]["enabled"]:
|
||||
raise HTTPException(
|
||||
status_code=503,
|
||||
detail="Immich integration not configured. Please set IMMICH_API_KEY environment variable."
|
||||
)
|
||||
|
||||
# This would make actual API calls to Immich
|
||||
# For now, return mock data
|
||||
return {
|
||||
"albums": [
|
||||
{"id": "album_1", "name": "Family Photos", "asset_count": 150},
|
||||
{"id": "album_2", "name": "Vacation 2024", "asset_count": 75}
|
||||
]
|
||||
}
|
||||
1
services/service-adapters/services/__init__.py
Normal file
1
services/service-adapters/services/__init__.py
Normal file
@@ -0,0 +1 @@
|
||||
# Services package
|
||||
29
services/service-adapters/services/config.py
Normal file
29
services/service-adapters/services/config.py
Normal file
@@ -0,0 +1,29 @@
|
||||
import os
|
||||
from dotenv import load_dotenv
|
||||
|
||||
# Load environment variables
|
||||
load_dotenv()
|
||||
|
||||
# Service configurations
|
||||
SERVICES = {
|
||||
"home_assistant": {
|
||||
"url": os.getenv("HOME_ASSISTANT_URL", "https://homeassistant.local:8123"),
|
||||
"token": os.getenv("HOME_ASSISTANT_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("HOME_ASSISTANT_TOKEN"))
|
||||
},
|
||||
"frigate": {
|
||||
"url": os.getenv("FRIGATE_URL", "http://frigate.local:5000"),
|
||||
"token": os.getenv("FRIGATE_TOKEN", ""),
|
||||
"enabled": bool(os.getenv("FRIGATE_TOKEN"))
|
||||
},
|
||||
"immich": {
|
||||
"url": os.getenv("IMMICH_URL", "http://immich.local:2283"),
|
||||
"api_key": os.getenv("IMMICH_API_KEY", ""),
|
||||
"enabled": bool(os.getenv("IMMICH_API_KEY"))
|
||||
},
|
||||
"n8n": {
|
||||
"url": os.getenv("N8N_URL", "http://n8n.local:5678"),
|
||||
"webhook_url": os.getenv("N8N_WEBHOOK_URL", ""),
|
||||
"enabled": bool(os.getenv("N8N_WEBHOOK_URL"))
|
||||
}
|
||||
}
|
||||
9
services/service-adapters/services/redis_client.py
Normal file
9
services/service-adapters/services/redis_client.py
Normal file
@@ -0,0 +1,9 @@
|
||||
import redis
|
||||
import os
|
||||
|
||||
# Redis connection
|
||||
redis_client = redis.Redis(
|
||||
host=os.getenv("REDIS_HOST", "localhost"),
|
||||
port=int(os.getenv("REDIS_PORT", 6379)),
|
||||
decode_responses=True
|
||||
)
|
||||
Reference in New Issue
Block a user