Webhooks

import { PaymentClient } from '@fundkit/core';
import { HoneyCoin } from '@fundkit/honeycoin';
import { EasyPay } from '@fundkit/easypay';

const honeycoin = new HoneyCoin({
  apiKey: process.env.HONEYCOIN_API_KEY!,
  publicKey: process.env.HONEYCOIN_PUBLIC_KEY!,
});

const easypay = new EasyPay({
  apiKey: process.env.EASYPAY_SECRET!,
  clientId: process.env.EASYPAY_CLIENT_ID!,
});

const client = new PaymentClient({
apiKey: process.env.FUNDKIT_API_KEY!,
providers: [honeycoin, easypay],
environment: 'sandbox',
webhook: {
url: 'https://api.myapp.com/webhooks/fundkit',
secret: process.env.WEBHOOK_SECRET!,
},
});

{
"event": "transaction_completed" | "transaction_failed" | "transaction_pending",
  "data": {
"transactionId": "string",
"transactionType": "COLLECTION" | "PAYOUT",
"amount": "string",
"currency": "string",
"operator": "string",
"accountNumber": "string",
"externalId": "string",
"environment": "sandbox" | "production"
  }
}

class WebhookTester {
  private webhookUrl: string;
  private secret: string;

  constructor(webhookUrl: string, secret: string) {
    this.webhookUrl = webhookUrl;
    this.secret = secret;
  }

  async sendTestWebhook(eventType: string, data: any) {
    const timestamp = Math.floor(Date.now() / 1000).toString();
    const payload = JSON.stringify({
      event: eventType,
      data: data,
    });

    const signature = this.generateSignature(payload, timestamp);

    const response = await fetch(this.webhookUrl, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'X-Webhook-Signature': `sha256=${signature}`,
        'X-Webhook-Timestamp': timestamp,
      },
      body: payload,
    });

    console.log('Test webhook response:', response.status);
    return response;
  }

  private generateSignature(payload: string, timestamp: string): string {
    return crypto.createHmac('sha256', this.secret).update(`${timestamp}.${payload}`).digest('hex');
  }

  async testTransactionCompleted(externalId: string) {
    return this.sendTestWebhook('transaction_completed', {
      transactionId: `tx_${Date.now()}_${externalId}`,
      transactionType: 'COLLECTION',
      amount: '10000',
      currency: 'UGX',
      operator: 'mtn',
      accountNumber: '256701234567',
      externalId: externalId,
      environment: 'sandbox',
    });
  }

  async testTransactionFailed(externalId: string) {
    return this.sendTestWebhook('transaction_failed', {
      transactionId: `tx_${Date.now()}_${externalId}`,
      transactionType: 'COLLECTION',
      amount: '10000',
      currency: 'UGX',
      operator: 'mtn',
      accountNumber: '256701234567',
      externalId: externalId,
      environment: 'sandbox',
    });
  }

  async testTransactionPending(externalId: string) {
    return this.sendTestWebhook('transaction_pending', {
      transactionId: `tx_${Date.now()}_${externalId}`,
      transactionType: 'COLLECTION',
      amount: '10000',
      currency: 'UGX',
      operator: 'mtn',
      accountNumber: '256701234567',
      externalId: externalId,
      environment: 'sandbox',
    });
  }
}

// Usage
const tester = new WebhookTester('http://localhost:3000/webhooks/test', 'test_webhook_secret');

await tester.testTransactionCompleted('test_order_123');
await tester.testTransactionFailed('test_order_456');
await tester.testTransactionPending('test_order_789');