Unify shared modules and increase API rate limits

- Symlink shared modules (footer, logger, health, status_webhook, http, retry)
- Update footer to use server icon instead of owner avatar
- Increase stats API rate limits for dashboard
- Update presence handler to use unified base class

Author: trippixn963

shared

@@ -0,0 +1 @@
+../shared

src/bot.py

@@ -9,18 +9,40 @@
 """
 
 import asyncio
+import os
 import discord
 from discord.ext import commands
 from typing import Optional
 
 from src.core.config import config, validate_config
+
+
+# =============================================================================
+# Guild Protection
+# =============================================================================
+
+def _get_authorized_guilds() -> set:
+    """Get authorized guild IDs from environment."""
+    guilds = set()
+    syria_id = os.getenv("GUILD_ID")
+    mods_id = os.getenv("MODS_GUILD_ID")
+    if syria_id:
+        guilds.add(int(syria_id))
+    if mods_id:
+        guilds.add(int(mods_id))
+    return guilds
+
+AUTHORIZED_GUILD_IDS = _get_authorized_guilds()
+
 from src.core.logger import log
 from src.services.tempvoice import TempVoiceService
 from src.services.sync_profile import ProfileSyncService
 from src.services.xp import XPService
 from src.services.xp import card as rank_card
 from src.services.stats_api import SyriaAPI
+from src.core.health import HealthCheckServer
 from src.services.status_webhook import get_status_service
+from src.services.backup import BackupScheduler
 from src.services.afk import AFKService
 from src.services.gallery import GalleryService
 from src.services.presence import PresenceHandler
@@ -62,6 +84,7 @@ def __init__(self) -> None:
         self.profile_sync: Optional[ProfileSyncService] = None
         self.xp_service: Optional[XPService] = None
         self.stats_api: Optional[SyriaAPI] = None
+        self.health_server: Optional[HealthCheckServer] = None
         self.status_webhook = None
         self.afk_service: Optional[AFKService] = None
         self.gallery_service: Optional[GalleryService] = None
@@ -73,6 +96,7 @@ def __init__(self) -> None:
         self.city_game_service: Optional[CityGameService] = None
         self.guide_service: Optional[GuideService] = None
         self.social_monitor: Optional[SocialMonitorService] = None
+        self.backup_scheduler: Optional[BackupScheduler] = None
 
     async def setup_hook(self) -> None:
         """Called when the bot is starting up."""
@@ -177,6 +201,58 @@ async def _on_app_command_error(
             ("ID", str(interaction.user.id)),
         ])
 
+    # =========================================================================
+    # Guild Protection
+    # =========================================================================
+
+    async def on_guild_join(self, guild: discord.Guild) -> None:
+        """Leave immediately if guild is not authorized."""
+        # Safety: Don't leave if authorized set is empty (misconfigured env)
+        if not AUTHORIZED_GUILD_IDS:
+            return
+        if guild.id not in AUTHORIZED_GUILD_IDS:
+            log.warning("Added To Unauthorized Guild - Leaving", [
+                ("Guild", guild.name),
+                ("ID", str(guild.id)),
+            ])
+            try:
+                await guild.leave()
+            except Exception as e:
+                log.error("Failed To Leave Unauthorized Guild", [
+                    ("Guild", guild.name),
+                    ("Error", str(e)),
+                ])
+
+    async def _leave_unauthorized_guilds(self) -> None:
+        """Leave any guilds not in AUTHORIZED_GUILD_IDS."""
+        # Safety: Don't leave any guilds if authorized set is empty (misconfigured env)
+        if not AUTHORIZED_GUILD_IDS:
+            log.warning("Guild Protection Skipped", [
+                ("Reason", "AUTHORIZED_GUILD_IDS is empty"),
+                ("Action", "Check GUILD_ID and MODS_GUILD_ID in .env"),
+            ])
+            return
+        unauthorized = [g for g in self.guilds if g.id not in AUTHORIZED_GUILD_IDS]
+        if not unauthorized:
+            return
+
+        log.tree("Leaving Unauthorized Guilds", [
+            ("Count", str(len(unauthorized))),
+        ], emoji="⚠️")
+
+        for guild in unauthorized:
+            try:
+                log.warning("Leaving Unauthorized Guild", [
+                    ("Guild", guild.name),
+                    ("ID", str(guild.id)),
+                ])
+                await guild.leave()
+            except Exception as e:
+                log.error("Failed To Leave Guild", [
+                    ("Guild", guild.name),
+                    ("Error", str(e)),
+                ])
+
     async def _init_services(self) -> None:
         """Initialize bot services."""
         log.tree("Services Init", [
@@ -190,6 +266,9 @@ async def _init_services(self) -> None:
                 ("Action", "Check environment variables"),
             ], emoji="🚨")
 
+        # Leave unauthorized guilds before initializing services
+        await self._leave_unauthorized_guilds()
+
         # Check database health first - critical for most services
         if not db.is_healthy:
             log.tree("CRITICAL: Database Unhealthy", [
@@ -227,6 +306,47 @@ async def _init_services(self) -> None:
         except Exception as e:
             log.error_tree("XP Service Init Failed", e)
 
+        # Health Check Server (unified)
+        try:
+            self.health_server = HealthCheckServer(self)
+
+            # Register database health callback
+            async def db_health() -> dict:
+                try:
+                    connected = db.is_healthy
+                    error = db.corruption_reason if not connected else None
+                    return {"connected": connected, "error": error}
+                except Exception as e:
+                    return {"connected": False, "error": str(e)}
+
+            self.health_server.register_db_health(db_health)
+
+            # Register system health callback
+            import psutil
+            _psutil_process = psutil.Process()
+
+            async def system_health() -> dict:
+                cpu_percent = psutil.cpu_percent(interval=None)
+                memory = psutil.virtual_memory()
+                disk = psutil.disk_usage("/")
+                bot_memory_mb = _psutil_process.memory_info().rss / (1024 * 1024)
+                return {
+                    "cpu_percent": cpu_percent,
+                    "memory_percent": memory.percent,
+                    "disk_percent": disk.percent,
+                    "disk_total_gb": round(disk.total / (1024 ** 3), 1),
+                    "disk_used_gb": round(disk.used / (1024 ** 3), 1),
+                    "bot_memory_mb": round(bot_memory_mb, 1),
+                    "threads": _psutil_process.num_threads(),
+                    "open_files": len(_psutil_process.open_files()),
+                }
+
+            self.health_server.register_system(system_health)
+            await self.health_server.start()
+            initialized.append("HealthServer")
+        except Exception as e:
+            log.error_tree("Health Server Init Failed", e)
+
         # Stats API
         try:
             self.stats_api = SyriaAPI(self)
@@ -238,14 +358,22 @@ async def _init_services(self) -> None:
         # Status Webhook
         if config.STATUS_WEBHOOK_URL:
             try:
-                self.status_webhook = get_status_service(config.STATUS_WEBHOOK_URL)
+                self.status_webhook = get_status_service(config.STATUS_WEBHOOK_URL, bot_name="SyriaBot")
                 self.status_webhook.set_bot(self)
                 await self.status_webhook.send_startup_alert()
                 await self.status_webhook.start_hourly_alerts()
                 initialized.append("StatusWebhook")
             except Exception as e:
                 log.error_tree("Status Webhook Init Failed", e)
 
+        # Backup Scheduler
+        try:
+            self.backup_scheduler = BackupScheduler()
+            await self.backup_scheduler.start()
+            initialized.append("Backup")
+        except Exception as e:
+            log.error_tree("Backup Scheduler Init Failed", e)
+
         # AFK Service
         try:
             self.afk_service = AFKService(self)
@@ -359,6 +487,13 @@ async def close(self) -> None:
             except Exception as e:
                 log.error_tree("Status Webhook Stop Error", e)
 
+        if self.backup_scheduler:
+            try:
+                await self.backup_scheduler.stop()
+                stopped.append("Backup")
+            except Exception as e:
+                log.error_tree("Backup Scheduler Stop Error", e)
+
         if self.stats_api:
             try:
                 await self.stats_api.stop()

src/core/config.py

@@ -113,6 +113,7 @@ class Config:
     MOD_ROLE_ID: int = _env_int("MOD_ROLE_ID")
     AUTO_ROLE_ID: int = _env_int("SYRIA_AUTO_ROLE")
     BOOSTER_ROLE_ID: int = _env_int("SYRIA_BOOSTER_ROLE")
+    DEAD_CHAT_ROLE_ID: int = _env_int("SYRIA_DEAD_CHAT_ROLE")
 
     # ==========================================================================
     # Channels
@@ -127,6 +128,7 @@ class Config:
     BANK_CHANNEL_ID: int = _env_int("SYRIA_BANK_CH")
     DEBATES_CHANNEL_ID: int = _env_int("SYRIA_DEBATES_CH")
     INBOX_CHANNEL_ID: int = _env_int("SYRIA_INBOX_CH")
+    GIVEAWAY_CHANNEL_ID: int = _env_int("SYRIA_GIVEAWAY_CH")
 
     # ==========================================================================
     # TempVoice
@@ -211,7 +213,7 @@ class Config:
     # ==========================================================================
     # Webhooks
     # ==========================================================================
-    STATUS_WEBHOOK_URL: str = _env("STATUS_WEBHOOK")
+    STATUS_WEBHOOK_URL: str = _env("STATUS_WEBHOOK_URL")
 
     # ==========================================================================
     # URLs

src/core/health.py

@@ -0,0 +1 @@
+/Users/johnhamwi/Developer/shared/health.py