Aprovisionar WhatsApp para 100 clientes por API: crear, activar, suspender y cortar

async function activarCliente(clienteId) {
  const cliente = await db.clientes.buscar(clienteId);

  // 1. crea la instancia
  const inst = await wameAdmin.crearInstancia({
    nombre: `cliente-${cliente.id}`,
    // Un nombre legible ayuda el día que tengas que auditar la
    // factura consolidada y descubrir de quién es cada línea.
  });

  // 2. guarda la clave junto al cliente
  await db.clientes.actualizar(clienteId, {
    wame_instancia_id: inst.id,
    wame_key: cifrar(inst.key),
    canal_estado: 'esperando_conexion',
  });

  // 3. apunta el webhook a la URL DE ESTE cliente
  await wameAdmin.configurarWebhook(inst.key, {
    allowWebhook: true,
    webhookFormat: 'meta',
    webhookMessage: `https://tusistema.com/webhook/wame/${cliente.slug}/${cliente.webhookSecret}`,
  });

  return inst;
}

const { qr } = await wa.instance.connect();
// devuelve el QR para que el front de TU producto lo renderice

async function aplicarEstado(clienteId, nuevoEstado) {
  const c = await db.clientes.buscar(clienteId);
  if (!c.wame_key) return;

  switch (nuevoEstado) {
    case 'en_mora':
    case 'prueba_vencida':
      // Suspender, no eliminar: la reactivación después del pago
      // tiene que ser inmediata, y eliminar perdería la conexión.
      await wameAdmin.desactivar(c.wame_key);
      break;

    case 'activo':
      await wameAdmin.activar(c.wame_key);
      break;

    case 'baja':
      // Periodo de gracia antes de eliminar. Las bajas por error
      // ocurren, y eliminar es irreversible.
      await agendar('eliminar_instancia', { clienteId }, { enDias: 30 });
      break;
  }

  await db.clientes.actualizar(clienteId, { canal_estado: nuevoEstado });
}

// corre todos los días de madrugada
async function reconciliar() {
  const clientes = await db.clientes.conInstancia();
  const instancias = await wameAdmin.listarInstancias();
  const porClave = new Map(instancias.map((i) => [i.key, i]));

  const divergencias = [];

  for (const c of clientes) {
    const inst = porClave.get(descifrar(c.wame_key));

    if (!inst) {
      divergencias.push({ cliente: c.id, problema: 'instancia_desaparecida' });
      continue;
    }

    const deberiaEstarActiva = c.canal_estado === 'activo';
    if (inst.activa !== deberiaEstarActiva) {
      divergencias.push({
        cliente: c.id,
        problema: 'estado_divergente',
        contrato: c.canal_estado,
        instancia: inst.activa ? 'activa' : 'inactiva',
      });
      await aplicarEstado(c.id, c.canal_estado);   // corrige
    }
  }

  // Huérfanas: están en la factura y no le pertenecen a nadie
  const clavesConocidas = new Set(clientes.map((c) => descifrar(c.wame_key)));
  for (const i of instancias) {
    if (!clavesConocidas.has(i.key)) {
      divergencias.push({ problema: 'instancia_huerfana', key: i.key });
    }
  }

  if (divergencias.length) await avisarEquipo(divergencias);
}

async function verificarSalud() {
  const activos = await db.clientes.activos();

  for (const c of activos) {
    const info = await wa(c).instance.info();

    if (!info.conectada) {
      await registrarIncidente(c.id, 'desconectada');
      // Avísale al cliente ANTES de que lo note. Cambia por completo
      // la conversación: de "tu sistema está roto" a "vimos que se
      // cayó y ya lo estamos resolviendo".
      await notificarCliente(c, 'canal_desconectado');
    }
  }
}