#!/usr/bin/env python3
"""
Service Request Handler for Cockpits

Cockpits can request services by writing to:
  /var/cockpit/service_requests/<project>/<action>-<service>.request

This watcher processes those requests and writes responses.

Usage from cockpit:
  echo '{"action":"start","service":"backend"}' > /var/cockpit/service_requests/musica/start-backend.request

Or use the helper script mounted in the container.
"""

import json
import os
import time
from pathlib import Path
from datetime import datetime
import logging

# Setup logging
logging.basicConfig(level=logging.INFO, format='%(asctime)s [%(levelname)s] %(message)s')
logger = logging.getLogger(__name__)

# Paths
REQUESTS_DIR = Path("/var/lib/luz-orchestrator/cockpits/service_requests")
REQUESTS_DIR.mkdir(parents=True, exist_ok=True)


def process_request(request_file: Path) -> dict:
    """Process a service request file."""
    try:
        content = request_file.read_text()
        req = json.loads(content)
    except Exception as e:
        return {"success": False, "error": f"Invalid request: {e}"}
    
    action = req.get("action")
    service = req.get("service")
    project = request_file.parent.name  # Directory name is project

    if not action:
        return {"success": False, "error": "Missing action"}

    # These actions don't need a service name
    if action not in ["status", "list"] and not service:
        return {"success": False, "error": "Missing service name for start/stop"}
    
    # Import and use service manager
    from service_manager import ServiceManager
    mgr = ServiceManager()
    
    if action == "start":
        result = mgr.start_service(project, service)
    elif action == "stop":
        result = mgr.stop_service(project, service)
    elif action == "status":
        result = mgr.status(project)
    elif action == "list":
        services = mgr.list_services(project)
        result = {"success": True, "services": services}
    else:
        result = {"success": False, "error": f"Unknown action: {action}"}
    
    return result


def process_all_requests():
    """Process all pending requests."""
    processed = 0
    
    for project_dir in REQUESTS_DIR.iterdir():
        if not project_dir.is_dir():
            continue
        
        for req_file in project_dir.glob("*.request"):
            logger.info(f"Processing: {req_file}")
            
            # Process the request
            result = process_request(req_file)
            
            # Write response
            response_file = req_file.with_suffix(".response")
            response_file.write_text(json.dumps({
                "result": result,
                "processed_at": datetime.now().isoformat()
            }, indent=2))
            
            # Remove the request file
            req_file.unlink()
            processed += 1
            
            logger.info(f"Processed: {req_file.name} -> {result.get('success', False)}")
    
    return processed


def run_watcher(interval: int = 5):
    """Run continuous watcher for service requests."""
    logger.info(f"Starting service request watcher (interval: {interval}s)")
    logger.info(f"Watching: {REQUESTS_DIR}")
    
    while True:
        try:
            processed = process_all_requests()
            if processed:
                logger.info(f"Processed {processed} requests")
        except Exception as e:
            logger.error(f"Error processing requests: {e}")
        
        time.sleep(interval)


if __name__ == "__main__":
    import sys
    
    if len(sys.argv) > 1 and sys.argv[1] == "daemon":
        interval = int(sys.argv[2]) if len(sys.argv) > 2 else 5
        run_watcher(interval)
    else:
        processed = process_all_requests()
        print(f"Processed {processed} requests")