Webhook Events

app.post('/webhooks/ark', express.raw({ type: 'application/json' }), async (req, res) => {
  // Verify signature first (see full example in guide)
  const signature = req.headers['x-ark-signature'];
  const isValid = await verifySignature(req.body.toString(), signature);

  if (!isValid) {
    return res.status(401).send('Invalid signature');
  }

  const { event, timestamp, uuid, payload } = JSON.parse(req.body);

  // Acknowledge receipt immediately
  res.status(200).send('OK');

  // Process event asynchronously
  processWebhookEvent(event, payload, uuid);
});

post '/webhooks/ark' do
  # Verify signature first (see full example in guide)
  signature = request.env['HTTP_X_ARK_SIGNATURE']
  payload = request.body.read

  halt 401, 'Invalid signature' unless verify_signature(payload, signature)

  event = JSON.parse(payload)

  # Acknowledge receipt immediately, process async
  process_webhook_event(event['event'], event['payload'], event['uuid'])

  'OK'
end

import Ark from 'ark';

const client = new Ark();

const result = await client.webhooks.test('whk_abc123', {
  event: 'MessageSent',
});

console.log(`Success: ${result.data.success}`);
console.log(`Status code: ${result.data.statusCode}`);

require "ark_email"

client = ArkEmail::Client.new

result = client.webhooks.test("whk_abc123", event: "MessageSent")

puts "Success: #{result.data.success}"
puts "Status code: #{result.data.status_code}"

client := ark.NewClient()

result, _ := client.Webhooks.Test(ctx, "whk_abc123", ark.WebhookTestParams{
    Event: ark.String("MessageSent"),
})

fmt.Printf("Success: %v\n", result.Data.Success)
fmt.Printf("Status code: %d\n", result.Data.StatusCode)

curl -X POST https://api.arkhq.io/v1/webhooks/{webhookId}/test \
  -H "Authorization: Bearer $ARK_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"event": "MessageSent"}'