Sentinel

import asyncio
import aiohttp
import psutil
import pandas as pd
from datetime import datetime

async def health_monitor_daemon(threshold_cpu=90.0, error_spike_limit=50):
    """Background worker that monitors system vitals and APIs"""
    
    # 1. System & Log Scraping
    current_cpu = psutil.cpu_percent(interval=1)
    logs_df = fetch_recent_logs('checkout_service')
    error_500_count = len(logs_df[logs_df['status_code'] == 500])
    
    alerts = []
    if current_cpu > threshold_cpu:
        alerts.append(f"CRITICAL: Database CPU at {current_cpu}%")
    if error_500_count > error_spike_limit:
        alerts.append(f"FATAL: {error_500_count} HTTP 500 errors on Checkout API in last 5m.")
        
    # 2. Asynchronous Webhook Dispatching (Teams / Slack)
    if alerts:
        payload = {
            "text": "⚠️ SISTEMA IN SOFFERENZA ⚠️",
            "blocks": [
                {"type": "section", "text": {"type": "mrkdwn", "text": "\n".join(alerts)}},
                {"type": "context", "elements": [{"type": "plain_text", "text": str(datetime.now())}]}
            ]
        }
        
        async with aiohttp.ClientSession() as session:
            await session.post('https://hooks.slack.com/services/T0000/B000/XXXX', json=payload)
            print(f"[{datetime.now()}] Dispatching incidents to Engineering channel.")

    await asyncio.sleep(60) # Run every minute loop