Turn incoming webhooks into an API your workers can poll.

curl "https://api.hookbridge.io/v1/pull-endpoints/$ENDPOINT_ID/events?status=stored" \
  -H "Authorization: Bearer $HOOKBRIDGE_KEY"

# => {"data":[...],"meta":{"has_more":false,"next_cursor":""}}

import { HookBridge } from '@hookbridge/sdk';

const hookbridge = new HookBridge({ apiKey: process.env.HOOKBRIDGE_KEY });

const events = await hookbridge.listPullEvents(endpointId, {
  status: 'stored',
  eventType: 'order.created'
});

await hookbridge.ackPullEvents(endpointId, eventIds);

import os
from hookbridge import HookBridge

client = HookBridge(api_key=os.environ["HOOKBRIDGE_KEY"])

events = client.list_pull_events(
    endpoint_id, status="stored", event_type="order.created"
)
client.ack_pull_events(endpoint_id, event_ids)

import hookbridge "github.com/hookbridge/hookbridge-go/v2"

client, _ := hookbridge.NewClient(os.Getenv("HOOKBRIDGE_KEY"))

events, _ := client.ListPullEvents(ctx, endpointID,
    &hookbridge.PullEventsFilter{Status: &stored},
)

_, _ = client.AckPullEvents(ctx, endpointID, eventIDs)

require "hookbridge"

client = HookBridge.new(api_key: ENV["HOOKBRIDGE_KEY"])

events = client.list_pull_events(
  endpoint_id,
  status: "stored",
  event_type: "order.created"
)
client.ack_pull_events(endpoint_id, event_ids)

<?php
require 'vendor/autoload.php';
use HookBridge\HookBridge;

$client = new HookBridge(getenv('HOOKBRIDGE_KEY'));
$events = $client->listPullEvents($endpointId, 'stored', 'order.created');
$client->ackPullEvents($endpointId, $eventIds);