Real-time social media webhooks across every platform

import Aether from "aether";

const aether = new Aether({ apiKey: process.env.AETHER_API_KEY });

// Register your webhook endpoint once — covers all platforms
const webhook = await aether.webhooks.create({
  url: "https://your-app.com/hooks/aether",
  events: [
    "post.published",
    "post.failed",
    "comment.created",
    "message.created",
  ],
});
// → { id: "wh_xyz", url: "...", events: [...], secret: "whsec_..." }
// Store the secret — you'll use it to verify incoming payloads

import { createHmac, timingSafeEqual } from "crypto";

// Verify the webhook signature on every incoming request
function verifyAetherWebhook(
  rawBody: string,
  signature: string,
  secret: string,
): boolean {
  const expected = `sha256=${createHmac("sha256", secret).update(rawBody).digest("hex")}`;
  return timingSafeEqual(Buffer.from(expected), Buffer.from(signature));
}

// Next.js App Router example
export async function POST(req: Request) {
  const rawBody = await req.text();
  const signature = req.headers.get("x-aether-signature") ?? "";

  if (!verifyAetherWebhook(rawBody, signature, process.env.WEBHOOK_SECRET!)) {
    return new Response("Unauthorized", { status: 401 });
  }

  const payload = JSON.parse(rawBody);

  switch (payload.event) {
    case "post.published": {
      const { postId, platform, platformPostId, platformPostUrl } = payload.data;
      // Update your DB, notify users, trigger downstream workflows
      await db.posts.update({ where: { id: postId }, data: { platformPostId, platformPostUrl } });
      break;
    }
    case "post.failed": {
      const { postId, platform, error } = payload.data;
      await notifyOwner(postId, `Post failed on ${platform}: ${error.message}`);
      break;
    }
    case "message.created": {
      const { messageId, platform, from, text } = payload.data;
      // Route to AI inbox agent, support queue, etc.
      await inboxQueue.add({ messageId, platform, from, text });
      break;
    }
  }

  return new Response("OK", { status: 200 });
}

// Example: post.published payload
{
  "event": "post.published",
  "webhookId": "wh_abc123",
  "deliveredAt": "2026-06-15T09:00:14Z",
  "data": {
    "postId": "post_xyz789",
    "platform": "instagram",
    "profileId": "ig_abc123",
    "platformPostId": "17890123456789",
    "platformPostUrl": "https://www.instagram.com/p/ABC123/",
    "publishedAt": "2026-06-15T09:00:12Z"
  }
}

// Example: post.failed payload
{
  "event": "post.failed",
  "webhookId": "wh_abc123",
  "deliveredAt": "2026-06-15T09:00:45Z",
  "data": {
    "postId": "post_xyz789",
    "platform": "tiktok",
    "profileId": "tt_xyz789",
    "error": {
      "code": "68002",
      "message": "Permission denied: missing video.publish scope",
      "retryable": false
    },
    "retriesExhausted": 5
  }
}