Feature: Add periodic cleanup for old database triggers, timezone-aware datetime

Author: Akashyr

state_manager/.dockerignore

@@ -0,0 +1,32 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*.pyo
+*.pyd
+*.so
+
+# C extensions
+*.egg
+*.egg-info
+.eggs
+
+# Virtual environments
+.venv/
+
+# Git, CI and editor config
+.git/
+.github/
+.vscode/
+
+# Logs and temp files
+*.log
+
+# Other
+.env
+Dockerfile 
+tests/
+pytest.ini
+.pytest_cache/
+.coverage
+.coverage.*
+coverage.xml

state_manager/.gitignore

@@ -0,0 +1,66 @@
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+*.so
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# Virtual Environment
+venv/
+env/
+ENV/
+.env
+.venv/
+
+# IDE
+.vscode/
+*.swp
+*.swo
+.idea/
+*.iws
+*.iml
+*.ipr
+
+
+# Local development
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+# Database
+*.db
+*.sqlite3
+
+# OS generated files
+.DS_Store
+.DS_Store?
+._*
+.Spotlight-V100
+.Trashes
+ehthumbs.db
+Thumbs.db
+
+#logs 
+*.log
+logs/*.*
+!logs/.gitkeep
+
+# local files
+files/
+!files/.gitkeep

state_manager/.python-version

@@ -0,0 +1 @@
+3.12

state_manager/Dockerfile

@@ -0,0 +1,14 @@
+FROM python:3.12-slim-bookworm
+COPY --from=ghcr.io/astral-sh/uv:latest /uv /uvx /bin/
+
+WORKDIR /api-server
+
+COPY pyproject.toml uv.lock ./
+
+RUN uv sync --locked
+
+COPY . .
+
+EXPOSE 8000
+
+CMD ["uv", "run", "run.py", "--mode", "production", "--workers", "4"]

state_manager/README.md

@@ -0,0 +1 @@
+# Config module for State Manager

state_manager/__init__.py

@@ -0,0 +1,47 @@
+"""
+CORS configuration for the State Manager API
+"""
+import os
+from typing import List
+
+def get_cors_origins() -> List[str]:
+    """
+    Get CORS origins from environment variables or use defaults
+    """
+    # Get origins from environment variable
+    cors_origins = os.getenv("CORS_ORIGINS", "")
+    
+    if cors_origins:
+        # Split by comma and strip whitespace
+        return [origin.strip() for origin in cors_origins.split(",") if origin.strip()]
+    
+    # Default origins for development
+    return [
+        "http://localhost:3000",  # Next.js frontend
+        "http://localhost:3001",  # Alternative frontend port
+        "http://127.0.0.1:3000",  # Alternative localhost
+        "http://127.0.0.1:3001",  # Alternative localhost port
+    ]
+
+def get_cors_config():
+    """
+    Get CORS configuration
+    """
+    return {
+        "allow_origins": get_cors_origins(),
+        "allow_credentials": True,
+        "allow_methods": ["GET", "POST", "PUT", "DELETE", "OPTIONS", "PATCH"],
+        "allow_headers": [
+            "Accept",
+            "Accept-Language",
+            "Content-Language",
+            "Content-Type",
+            "X-API-Key",
+            "Authorization",
+            "X-Requested-With",
+            "X-Exosphere-Request-ID",
+        ],
+        "expose_headers": [  
+            "X-Exosphere-Request-ID",  
+        ],
+    }

state_manager/app/__init__.py

@@ -0,0 +1,48 @@
+import os
+from pydantic import BaseModel, Field
+from dotenv import load_dotenv
+
+load_dotenv()
+
+class Settings(BaseModel):
+    """Application settings loaded from environment variables."""
+    
+    # MongoDB Configuration
+    mongo_uri: str = Field(..., description="MongoDB connection URI")
+    mongo_database_name: str = Field(default="exosphere-state-manager", description="MongoDB database name")
+    state_manager_secret: str = Field(..., description="Secret key for API authentication")
+    secrets_encryption_key: str = Field(..., description="Key for encrypting secrets")
+    trigger_workers: int = Field(default=1, description="Number of workers to run the trigger cron")
+    
+    # Cleanup / Retention Configs
+    trigger_retention_days: int = Field(default=30, description="How many days to retain old triggers")
+    cleanup_interval_minutes: int = Field(default=60, description="Interval (minutes) between cleanup runs")
+    
+    @classmethod
+    def from_env(cls) -> "Settings":
+        return cls(
+            mongo_uri=os.getenv("MONGO_URI"),  # type: ignore
+            mongo_database_name=os.getenv("MONGO_DATABASE_NAME", "exosphere-state-manager"),  # type: ignore
+            state_manager_secret=os.getenv("STATE_MANAGER_SECRET"),  # type: ignore
+            secrets_encryption_key=os.getenv("SECRETS_ENCRYPTION_KEY"),  # type: ignore
+            trigger_workers=int(os.getenv("TRIGGER_WORKERS", 1)),  # type: ignore
+
+            # NEW CONFIGS
+            trigger_retention_days=int(os.getenv("TRIGGER_RETENTION_DAYS", 30)),  # type: ignore
+            cleanup_interval_minutes=int(os.getenv("CLEANUP_INTERVAL_MINUTES", 60))  # type: ignore
+        )
+
+
+# Global settings instance - will be updated when get_settings() is called
+_settings = None
+
+
+def get_settings() -> Settings:
+    """Get the global settings instance, reloading from environment if needed."""
+    global _settings
+    _settings = Settings.from_env()
+    return _settings
+
+
+# Initialize settings
+settings = get_settings()