import { Client, GatewayIntentBits } from 'discord.js'

// discord.js が wss://gateway.discord.gg へ outbound WebSocket を張る
const client = new Client({
  intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildMessages],
})

client.on('messageCreate', async (message) => {
  // Discord → OpenClaw auto-reply パイプラインへハンドオフ
  const msgContext = normalizeToMsgContext(message)
  await autoReplyPipeline.handle(msgContext)
})

// ローカル → Discord サーバーへの outbound 接続
client.login(botToken)

import { App } from '@slack/bolt'

// Socket Mode: ローカル → Slack API へ outbound WebSocket を張る
const app = new App({
  token: process.env.SLACK_BOT_TOKEN,
  appToken: process.env.SLACK_APP_TOKEN,
  socketMode: true, // HTTPサーバーではなくWebSocket接続を使う
})

app.message(async ({ message, say }) => {
  // Slack → OpenClaw auto-reply パイプラインへハンドオフ
  const msgContext = normalizeToMsgContext(message)
  await autoReplyPipeline.handle(msgContext)
})

// ローカル → Slack API への outbound 接続を開始
await app.start()

import makeWASocket, { useMultiFileAuthState } from '@whiskeysockets/baileys'

// セッション情報をファイルに永続化（2回目以降はQR不要）
const { state, saveCreds } = await useMultiFileAuthState('./auth')

// ローカル → WhatsApp サーバーへ outbound WebSocket を張る
const sock = makeWASocket({ auth: state })
sock.ev.on('creds.update', saveCreds)

// 初回接続時はQRコードをターミナルに表示
sock.ev.on('connection.update', ({ qr }) => {
  if (qr) printQRCode(qr)
})

sock.ev.on('messages.upsert', async ({ messages }) => {
  // WhatsApp → OpenClaw auto-reply パイプラインへハンドオフ
  const msgContext = normalizeToMsgContext(messages[0])
  await autoReplyPipeline.handle(msgContext)
})

import { Bot } from 'grammy'

// Bot Token で Telegram Bot API に接続
const bot = new Bot(process.env.TELEGRAM_BOT_TOKEN)

bot.on('message:text', async (ctx) => {
  // Telegram → OpenClaw auto-reply パイプラインへハンドオフ
  const msgContext = normalizeToMsgContext(ctx.message)
  await autoReplyPipeline.handle(msgContext)
})

// long polling 開始: ローカル → Telegram API へ getUpdates を送り続ける
bot.start()

// signal-cli が別プロセスで Signal サーバーと通信（outbound）
// OpenClaw は signal-cli の REST API（localhost:8080）経由でやり取り

const SIGNAL_CLI_API = 'http://localhost:8080/api/v1'

// signal-cli の receive エンドポイントをポーリング
const pollMessages = async () => {
  const res = await fetch(`${SIGNAL_CLI_API}/receive/${phoneNumber}`)
  const messages = await res.json()

  for (const msg of messages) {
    const msgContext = normalizeToMsgContext(msg)
    await autoReplyPipeline.handle(msgContext)
  }
}

setInterval(pollMessages, 1000)

import { execSync } from 'child_process'

// Gateway は localhost のみにバインド（外部から直接アクセス不可）
const GATEWAY_HOST = '127.0.0.1'
const GATEWAY_PORT = 18789

// Tailscale Serve: tailnet 内の他デバイスからアクセス可能にする
// tailscale serve --bg https+insecure://127.0.0.1:18789
execSync(`tailscale serve --bg https+insecure://${GATEWAY_HOST}:${GATEWAY_PORT}`)

// Tailscale Funnel: インターネット全体に公開（Webhook 受信用）
// tailscale funnel --bg https+insecure://127.0.0.1:18789
execSync(`tailscale funnel --bg https+insecure://${GATEWAY_HOST}:${GATEWAY_PORT}`)

// Google Chat / Teams の Webhook URL:
// https://your-node.tailnet.ts.net/googlechat

// Embeddedモード: Gateway プロセス内で直接エージェントを実行
const runEmbeddedPiAgent = async (msgContext: MsgContext) => {
  const messages = buildPrompt(msgContext)
  const response = await llm.chat(messages) // LLM API 呼び出し
  const toolCalls = response.toolCalls ?? []

  for (const call of toolCalls) {
    const result = await executeTool(call) // bash, fs 等のツール実行
    messages.push({ role: 'tool', content: result })
  }

  return await llm.chat(messages) // 最終応答
}

// RPCモード: 別プロセスのエージェントへ WebSocket でリレー
// const ws = new WebSocket('ws://localhost:18790/agent')
// ws.send(JSON.stringify(msgContext))

import { spawn } from 'child_process'
import * as pty from 'node-pty'

// execツール: 単発コマンド実行
const execTool = (command: string): Promise<string> => {
  return new Promise((resolve, reject) => {
    const proc = spawn('bash', ['-c', command])
    let output = ''
    proc.stdout.on('data', (data) => {
      output += data
    })
    proc.stderr.on('data', (data) => {
      output += data
    })
    proc.on('close', () => resolve(output))
  })
}

// bashツール: 対話的シェルセッション（node-pty で擬似ターミナル）
const bashSession = pty.spawn('bash', [], {
  name: 'xterm-256color',
  cols: 120,
  rows: 30,
})

// ファイル操作: Node.js の fs モジュールで直接読み書き
// import { readFile, writeFile } from 'fs/promises'

// ノードが公開するケイパビリティ
enum Permission {
  case appleScript      // Automation権限
  case notifications    // 通知
  case accessibility    // アクセシビリティ
  case screenRecording  // 画面録画
  case microphone       // マイク
  case speechRecognition // 音声認識
  case camera           // カメラ
  case location         // 位置情報
}