Gig economy

Cycle = 1 semaine
J1-J7  : paiements clients collectés, balance crypto grossit
J7 23h : cron déclenche le payroll
       → calcule {prestataire → montant dû} depuis votre DB
       → une boucle de payouts unitaires (un par prestataire)
       → webhook payout.confirmed/failed → marque comme payé
       → re-essai manuel des échecs

// cron job — chaque lundi 23h
import { izipay } from './lib/izipay';

async function runWeeklyPayroll(week: string) {
  // 1. Calculer les dus (en crypto déjà préparée côté votre app)
  const ledger = await db.query(`
    SELECT driver_id, driver_wallet, SUM(net_to_driver) AS amount_crypto
    FROM trips
    WHERE week = $1 AND payout_status = 'pending'
    GROUP BY driver_id, driver_wallet
    ORDER BY amount_crypto DESC
  `, [week]);

  // 2. Un payout unitaire par prestataire
  for (const row of ledger) {
    await izipay.payouts.create({
      destinationAddress: row.driver_wallet,
      assetCode: 'USDT.TRC20',
      amount: row.amount_crypto.toString(),
      idempotencyKey: `payroll-${week}-${row.driver_id}`,
      note: `Payroll ${week} - driver ${row.driver_id}`,
    });
  }
}

case 'payout.confirmed': {
  await db.trips.markPaid({
    izipayPayoutId: event.data.payoutId,
    txHash: event.data.txHash,
  });
  break;
}
case 'payout.failed': {
  await db.trips.markFailed({
    izipayPayoutId: event.data.payoutId,
    reason: event.data.failureReason,
  });
  // Notif au prestataire
  break;
}

for (const line of lines) {
  await izipay.payouts.createInternal({
    assetCode: 'USDT.TRC20',
    amount: line.amount,
    destinationType: 'internal_email',
    destinationEmail: line.driverEmail,
    idempotencyKey: `payroll-${week}-${line.driverId}`,
    note: `Semaine ${week}`,
  });
}