module.exports = {
  apps: [
    { name: "tsv-bot", script: "tsv/main.py", interpreter: "python3" },
    { name: "albaflow-bot", script: "albaflow/main.py", interpreter: "python3" },
  ]
};

module.exports = {
  apps: [
    // === TSV 4개 봇 ===
    {
      name: "tsv-monitoring",
      script: "tsv/monitoring/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      env: {
        DATABASE_URL: process.env.DATABASE_URL,
        ANTHROPIC_API_KEY: process.env.ANTHROPIC_API_KEY,
        DISCORD_TOKEN: process.env.TSV_DISCORD_TOKEN,
        LOG_LEVEL: "info",
      },
      max_memory_restart: "300M",
      autorestart: true,
      restart_delay: 5000,
      max_restarts: 5,
      min_uptime: "30s",
      log_date_format: "YYYY-MM-DD HH:mm:ss",
      error_file: "/var/log/pm2/tsv-monitoring-error.log",
      out_file: "/var/log/pm2/tsv-monitoring-out.log",
      merge_logs: true,
    },
    {
      name: "tsv-b2b",
      script: "tsv/b2b/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      env: { /* ... */ },
      max_memory_restart: "200M",
    },
    {
      name: "tsv-position-c",
      script: "tsv/position_c/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      cron_restart: "0 0 * * *",  // 매일 자정 재시작
      max_memory_restart: "200M",
    },
    {
      name: "tsv-faq",
      script: "tsv/faq/main.js",
      env: { /* ... */ },
      max_memory_restart: "300M",
    },

    // === AlbaFlow 4개 봇 ===
    {
      name: "albaflow-owner",
      script: "albaflow/owner/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      env: { /* ... */ },
      max_memory_restart: "300M",
    },
    {
      name: "albaflow-alba",
      script: "albaflow/alba/main.js",
      env: { /* ... */ },
      max_memory_restart: "300M",
    },
    {
      name: "albaflow-labor-law",
      script: "albaflow/labor_law/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      cron_restart: "0 0 * * *",
      max_memory_restart: "200M",
    },
    {
      name: "albaflow-store",
      script: "albaflow/store/main.py",
      interpreter: "/home/ubuntu/.venv/bin/python3",
      cron_restart: "0 9 * * *",  // 매일 09:00
      max_memory_restart: "200M",
    },

    // === viewLab 4개 봇 ===
    { name: "viewlab-dealer",   script: "viewlab/dealer/main.py",   interpreter: "python3", max_memory_restart: "300M" },
    { name: "viewlab-content",  script: "viewlab/content/main.py",  interpreter: "python3", max_memory_restart: "200M" },
    { name: "viewlab-customer", script: "viewlab/customer/main.js",                         max_memory_restart: "300M" },
    { name: "viewlab-store",    script: "viewlab/store/main.py",    interpreter: "python3", max_memory_restart: "200M" },
  ]
};

import redis.asyncio as redis
import json

class BotPubSub:
    def __init__(self):
        self.redis = redis.Redis(host='localhost', port=6379)

    async def publish(self, channel: str, message: dict):
        """이벤트 발행"""
        await self.redis.publish(channel, json.dumps(message))

    async def subscribe(self, channel: str, handler):
        """이벤트 구독"""
        pubsub = self.redis.pubsub()
        await pubsub.subscribe(channel)
        async for message in pubsub.listen():
            if message['type'] == 'message':
                data = json.loads(message['data'])
                await handler(data)

# --- 사용 예시 ---

# TSV 모니터링 봇: 이벤트 발행
await pubsub.publish("system_alert", {
    "type": "high_error_rate",
    "domain": "tsv",
    "severity": "warning"
})

# 운영자 알림 봇: 이벤트 구독 (모든 도메인 종합)
async def handle_alert(data):
    if data["severity"] == "warning":
        await send_discord_alert(data)

await pubsub.subscribe("system_alert", handle_alert)

cron_restart: "0 9 * * *",   // 봇 1 — 09:00
cron_restart: "5 9 * * *",   // 봇 2 — 09:05
cron_restart: "10 9 * * *",  // 봇 3 — 09:10
cron_restart: "15 9 * * *",  // 봇 4 — 09:15
// ... 5분 간격으로 배치