Hyperscale APIs with
Sub-12ms Edge Delivery

// Initialize Synapse Client with auto-verification
import { SynapseClient } from '@synapse/sdk';

const synapse = new SynapseClient({
  apiKey: process.env.SYNAPSE_API_KEY,
  signingSecret: process.env.SYNAPSE_WEBHOOK_SECRET,
});

// Verify inbound webhook signature & dispatch to handler
app.post('/api/webhooks', async (req, res) => {
  const event = synapse.webhooks.constructEvent({
    payload: req.rawBody,
    signature: req.headers['x-synapse-signature'],
    toleranceSeconds: 300 // Anti-replay guarantee
  });

  console.log(`Verified event received: ${event.id}`);
  res.status(200).json({ received: true });
});

# 1. Search for failed deliveries over the last 2 hours
$ synapse events search --status=500 --since=2h

Found 142 failed deliveries across destination: https://api.client.internal/hook

# 2. Trigger zero-downtime bulk replay with rate throttling
$ synapse events replay \
    --query="status:500 AND created_at > now-2h" \
    --rate-limit=50/sec \
    --target="https://api.client.internal/hook"

[Synapse Engine] Replaying batch 1/3 (50 items)... 200 OK
[Synapse Engine] Replaying batch 2/3 (50 items)... 200 OK
[Synapse Engine] Replaying batch 3/3 (42 items)... 200 OK
✔ Replay completed successfully. 142/142 recovered.

# High-throughput asynchronous receiver in Python
from synapse import SynapseWebhook
from fastapi import FastAPI, Request, HTTPException

app = FastAPI()
webhook_guard = SynapseWebhook(secret="whsec_prod_9918")

@app.post("/v1/vital-stream")
async def receive_vitals(request: Request):
    payload = await request.body()
    signature = request.headers.get("X-Synapse-Signature")

    if not webhook_guard.verify(payload, signature):
        raise HTTPException(status_code=401, detail="Invalid signature")

    return {"status": "acknowledged", "edge_latency_ms": 11.2}