Add YouTube webhooks and Google Calendar webhooks

.env.example

@@ -150,7 +150,7 @@ NOTION_REDIRECT_URI=http://localhost:8080/auth/oauth/notion/callback/
 # JSON dictionary format for webhook secrets
 # Generate secure random strings: openssl rand -base64 32
 # Format: WEBHOOK_SECRETS='{"service_name":"secret_key",...}'
-# 
+#
 # To enable webhooks for a service:
 # 1. Generate a secure secret: openssl rand -base64 32
 # 2. Add it to this JSON dictionary

backend/area_project/celery.py

@@ -57,12 +57,31 @@ def get_beat_schedule():
         },
         "check-gmail-actions": {
             "task": "automations.check_gmail_actions",
-            "schedule": 180.0,  # Every 3 minutes (no webhook support yet)
+            "schedule": 180.0,  # Every 3 minutes (polling fallback)
         },
+        # Google Calendar: Webhooks enabled, polling disabled
+        # "check-google-calendar-actions": {
+        #     "task": "automations.check_google_calendar_actions",
+        #     "schedule": 180.0,  # Every 3 minutes (polling fallback)
+        # },
+        # YouTube: Webhooks enabled, polling disabled
+        # "check-youtube-actions": {
+        #     "task": "automations.check_youtube_actions",
+        #     "schedule": 300.0,  # Every 5 minutes (polling fallback)
+        # },
         "check-weather-actions": {
             "task": "automations.check_weather_actions",
             "schedule": 300.0,  # Every 5 minutes (no webhook support)
         },
+        # Google Push Notification (Watch) Management
+        "renew-google-watches": {
+            "task": "automations.renew_google_watches",
+            "schedule": 3600.0,  # Every hour - auto-renew expiring watches
+        },
+        "setup-youtube-watches": {
+            "task": "automations.setup_youtube_watches",
+            "schedule": 7200.0,  # Every 2 hours - ensure YouTube subscriptions active
+        },
         "collect-execution-metrics": {
             "task": "automations.collect_execution_metrics",
             "schedule": crontab(minute=0),  # Every hour
@@ -112,17 +131,6 @@ def get_beat_schedule():
         else:
             print("✅ [CELERY BEAT] PROD: GitHub webhooks active, polling disabled")
 
-        if not webhook_secrets.get("twitch"):
-            schedule["check-twitch-actions"] = {
-                "task": "automations.check_twitch_actions",
-                "schedule": 60.0,  # Every minute
-            }
-            print(
-                "⚠️  [CELERY BEAT] PROD: Twitch polling enabled (webhook not configured)"
-            )
-        else:
-            print("✅ [CELERY BEAT] PROD: Twitch webhooks active, polling disabled")
-
         if not webhook_secrets.get("slack"):
             schedule["check-slack-actions"] = {
                 "task": "automations.check_slack_actions",
@@ -141,6 +149,10 @@ def get_beat_schedule():
         }
         print("✅ [CELERY BEAT] Notion polling enabled (every 5 minutes)")
 
+        # Google services: Webhooks active
+        print("✅ [CELERY BEAT] Google Calendar webhooks active, polling disabled")
+        print("✅ [CELERY BEAT] YouTube webhooks active, polling disabled")
+
     return schedule
 
 

backend/area_project/settings/base.py

@@ -213,6 +213,8 @@
             "https://www.googleapis.com/auth/gmail.modify",
             "https://www.googleapis.com/auth/calendar.readonly",
             "https://www.googleapis.com/auth/calendar.events",
+            "https://www.googleapis.com/auth/youtube.readonly",
+            "https://www.googleapis.com/auth/youtube.force-ssl",
         ],
         "requires_refresh": True,
     },
@@ -347,6 +349,28 @@
     logger.debug(f"Raw value: {webhook_secrets_raw[:50]}...")
     WEBHOOK_SECRETS = {}
 
+# =============================================================================
+# GOOGLE PUSH NOTIFICATIONS (WEBHOOKS)
+# =============================================================================
+# Configuration for Gmail, Calendar, and YouTube webhooks
+GMAIL_WEBHOOK_ENABLED = os.getenv("GMAIL_WEBHOOK_ENABLED", "false").lower() == "true"
+CALENDAR_WEBHOOK_ENABLED = (
+    os.getenv("CALENDAR_WEBHOOK_ENABLED", "false").lower() == "true"
+)
+YOUTUBE_WEBHOOK_ENABLED = (
+    os.getenv("YOUTUBE_WEBHOOK_ENABLED", "false").lower() == "true"
+)
+
+# Webhook URLs (must be set in environment variables)
+GMAIL_WEBHOOK_URL = os.getenv("GMAIL_WEBHOOK_URL", "")
+CALENDAR_WEBHOOK_URL = os.getenv("CALENDAR_WEBHOOK_URL", "")
+YOUTUBE_WEBHOOK_URL = os.getenv("YOUTUBE_WEBHOOK_URL", "")
+
+# Watch renewal interval (in seconds) - default 6 days
+GOOGLE_WATCH_RENEWAL_INTERVAL = int(
+    os.getenv("GOOGLE_WATCH_RENEWAL_INTERVAL", "518400")
+)
+
 # Security Settings (base - extended per environment)
 SECURE_BROWSER_XSS_FILTER = True
 SECURE_CONTENT_TYPE_NOSNIFF = True
@@ -530,6 +554,11 @@
 # In production: https://your-frontend-domain.com
 FRONTEND_URL = os.getenv("FRONTEND_URL", "http://localhost:5173")
 
+# Backend URL for webhook callbacks
+# In development: http://localhost:8000
+# In production: https://your-backend-domain.com
+BACKEND_URL = os.getenv("BACKEND_URL", "http://localhost:8000")
+
 # CORS Configuration
 # Base allowed origins (extended per environment)
 CORS_ALLOWED_ORIGINS = [