1
app.post('/webhooks/koywe', express.raw({type: 'application/json'}), async (req, res) => {
2
  // Convertir body raw a string una vez
3
  const rawBody = req.body.toString();
4
  
5
  // Verificar firma con body string
6
  const signature = req.headers['koywe-signature'];
7
  if (!verifySignature(rawBody, signature, process.env.KOYWE_WEBHOOK_SECRET)) {
8
    return res.status(401).send('Firma inválida');
9
  }
10
  
11
  // Parsear JSON desde string
12
  const event = JSON.parse(rawBody);
13
  
14
  switch (event.type) {
15
    case 'order.processing':
16
      console.log('Payout procesando:', event.data.orderId);
17
      // Actualizar estado interno
18
      await updatePayoutStatus(event.data.externalId, 'processing');
19
      break;
20
      
21
    case 'order.completed':
22
      console.log('Payout completado:', event.data.orderId);
23
      // Marcar como pagado en tu sistema
24
      await markInvoiceAsPaid(event.data.externalId);
25
      await notifyProvider(event.data.externalId);
26
      break;
27
      
28
    case 'order.failed':
29
      console.log('Payout fallido:', event.data.orderId);
30
      // Manejar fallo
31
      await handlePayoutFailure(event.data.externalId, event.data.errorMessage);
32
      break;
33
  }
34
  
35
  res.status(200).send('OK');
36
});

1
async function waitForPayoutCompletion(token, orgId, merchantId, orderId, maxAttempts = 20) {
2
  for (let i = 0; i < maxAttempts; i++) {
3
    const order = await axios.get(
4
      `https://api-sandbox.koywe.com/api/v1/organizations/${orgId}/merchants/${merchantId}/orders/${orderId}`,
5
      { headers: { 'Authorization': `Bearer ${token}` } }
6
    );
7
    
8
    const status = order.data.status;
9
    console.log(`Intento ${i + 1}: Estado = ${status}`);
10
    
11
    if (status === 'COMPLETED') {
12
      console.log('✓ Payout completado exitosamente');
13
      return order.data;
14
    }
15
    
16
    if (status === 'FAILED') {
17
      throw new Error(`Payout fallido: ${order.data.errorMessage}`);
18
    }
19
    
20
    // Esperar 5 segundos antes de verificar nuevamente
21
    await new Promise(resolve => setTimeout(resolve, 5000));
22
  }
23
  
24
  throw new Error('Tiempo de espera agotado');
25
}

1
async function completePayoutFlow() {
2
  try {
3
    // 1. Autenticar
4
    const token = await authenticate(apiKey, secret);
5
    console.log('✓ Autenticado');
6
    
7
    // 2. Verificar saldo
8
    const balance = await getBalance(token, orgId, merchantId, 'COP');
9
    if (balance.availableBalance < 500000) {
10
      throw new Error('Saldo insuficiente');
11
    }
12
    console.log(`✓ Saldo suficiente: ${balance.availableBalance} COP`);
13
    
14
    // 3. Crear/obtener contacto de proveedor
15
    const provider = await createProviderContact(token, orgId, merchantId, {
16
      email: 'proveedor@ejemplo.com',
17
      fullName: 'Servicios ABC SAS',
18
      country: 'CO',
19
      documentType: 'NIT',
20
      documentNumber: '900123456-1',
21
      businessType: 'COMPANY'
22
    });
23
    console.log('✓ Proveedor creado:', provider.id);
24
    
25
    // 4. Agregar cuenta bancaria
26
    const bankAccount = await addProviderBankAccount(
27
      token, orgId, merchantId, provider.id,
28
      {
29
        country: 'CO',
30
        currency: 'COP',
31
        bankCode: 'BANCOLOMBIA',
32
        accountNumber: '1234567890',
33
        accountType: 'checking',
34
        holderName: 'Servicios ABC SAS'
35
      }
36
    );
37
    console.log('✓ Cuenta bancaria agregada:', bankAccount.id);
38
    
39
    // 5. Crear payout
40
    const payout = await createPayoutOrder(token, orgId, merchantId, {
41
      currency: 'COP',
42
      amount: 500000,
43
      contactId: provider.id,
44
      destinationAccountId: bankAccount.id,
45
      description: 'Pago por Factura #INV-001',
46
      externalId: `payout-${Date.now()}`
47
    });
48
    console.log('✓ Payout creado:', payout.id);
49
    console.log('  Estado:', payout.status);
50
    
51
    // 6. Esperar confirmación (o confiar en webhooks)
52
    console.log('Esperando completación...');
53
    const completed = await waitForPayoutCompletion(
54
      token, orgId, merchantId, payout.id
55
    );
56
    
57
    console.log('✓ Payout completado exitosamente!');
58
    console.log('  ID de Orden:', completed.id);
59
    console.log('  Monto:', completed.amountIn, completed.originCurrencySymbol);
60
    
61
    return completed;
62
    
63
  } catch (error) {
64
    console.error('Error en flujo de payout:', error.message);
65
    throw error;
66
  }
67
}
68
69
// Ejecutar
70
await completePayoutFlow();