Ads Webhook Events

// Register a webhook endpoint via the SDK
const webhook = await client.webhooks.create({
  url: 'https://yourapp.com/webhooks/ads',
  events: [
    'eventzr.ads.campaign.launched.v1',
    'eventzr.ads.conversion.tracked.v1',
    'eventzr.ads.billing.low_balance.v1',
  ],
  secret: 'whsec_your_signing_secret_here',
  active: true,
});

console.log('Webhook ID:', webhook.data.id);

// List registered webhooks
const webhooks = await client.webhooks.list();

// Update webhook
await client.webhooks.update(webhook.data.id, {
  events: ['*'], // Subscribe to all events
});

// Delete webhook
await client.webhooks.delete(webhook.data.id);

import { createHmac, timingSafeEqual } from 'crypto';
import type { Request, Response } from 'express';

const WEBHOOK_SECRET = process.env.ADS_WEBHOOK_SECRET!;

function verifySignature(payload: string, signature: string): boolean {
  const expected = createHmac('sha256', WEBHOOK_SECRET)
    .update(payload, 'utf8')
    .digest('hex');

  const sig = Buffer.from(signature, 'hex');
  const exp = Buffer.from(expected, 'hex');

  if (sig.length !== exp.length) return false;
  return timingSafeEqual(sig, exp);
}

// Express webhook handler
app.post('/webhooks/ads', express.raw({ type: 'application/json' }), (req: Request, res: Response) => {
  const signature = req.headers['x-eventzr-signature'] as string;
  const timestamp = req.headers['x-eventzr-timestamp'] as string;

  // 1. Reject if timestamp is older than 5 minutes (replay protection)
  const eventTime = parseInt(timestamp, 10);
  const now = Math.floor(Date.now() / 1000);
  if (Math.abs(now - eventTime) > 300) {
    return res.status(400).json({ error: 'Timestamp too old' });
  }

  // 2. Verify HMAC signature
  const payload = req.body.toString('utf8');
  if (!verifySignature(payload, signature)) {
    return res.status(401).json({ error: 'Invalid signature' });
  }

  // 3. Process the event
  const event = JSON.parse(payload);
  handleAdsEvent(event);

  // 4. Respond with 200 to acknowledge receipt
  return res.status(200).json({ received: true });
});

import { KafkaBrokerModule } from '@eventzr/kafka';

@Module({
  imports: [
    KafkaBrokerModule.forConsumer({
      groupId: 'your-app-ads-consumer',
      topics: [
        'eventzr.ads.impression.tracked.v1',
        'eventzr.ads.conversion.tracked.v1',
      ],
    }),
  ],
})
export class AdsEventsModule {}

// Consumer handler
@Injectable()
export class AdsEventConsumer {
  @KafkaHandler('eventzr.ads.impression.tracked.v1')
  async handleImpression(event: CloudEvent<ImpressionData>): Promise<void> {
    // Process impression event at scale
    await this.analyticsService.recordImpression(event.data);
  }

  @KafkaHandler('eventzr.ads.conversion.tracked.v1')
  async handleConversion(event: CloudEvent<ConversionData>): Promise<void> {
    // Process conversion for attribution
    await this.attributionService.attribute(event.data);
  }
}