Streaming & Rate Limiting

curl -N https://hooksniff-api-1046140057667.europe-west1.run.app/v1/stream/deliveries \
  -H "Authorization: Bearer hr_live_YOUR_KEY" \
  -H "Accept: text/event-stream"

import { HookSniff } from 'hooksniff';

const hs = new HookSniff({ apiKey: 'hr_live_xxx' });

// Stream delivery events
const stream = hs.stream.subscribe({
  event_types: ['delivery.completed', 'delivery.failed'],
});

stream.on('event', (event) => {
  console.log(`[${event.event}] ${event.data.message_id}: ${event.data.status}`);
});

stream.on('error', (err) => {
  console.error('Stream error:', err);
  // Auto-reconnects with backoff
});

// Close when done
// stream.close();

curl -X POST https://hooksniff-api-1046140057667.europe-west1.run.app/v1/endpoints/EP_ID/rate-limit \
  -H "Authorization: Bearer hr_live_YOUR_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "algorithm": "token_bucket",
    "rate": 100,
    "period": 60
  }'
// → 100 requests per 60 seconds

// All SDKs handle 429 automatically with exponential backoff.
// But you can also handle it manually:

try {
  const endpoints = await hs.endpoint.list();
} catch (err) {
  if (err.statusCode === 429) {
    const retryAfter = parseInt(err.headers['retry-after']);
    console.log(`Rate limited. Retry after ${retryAfter}s`);
    await sleep(retryAfter * 1000);
    // Retry
  }
}