Fastify

pnpm add @nexa-ed/node fastify

// server.ts
import Fastify from "fastify";
import { Readable } from "node:stream";
import { NexaClient, proxyProgressStream } from "@nexa-ed/node";
import { createWebhookHandler } from "@nexa-ed/node/fastify";
 
const app = Fastify({ logger: true });
const nexa = new NexaClient({
  apiKey: process.env.NEXA_API_KEY!,
  webhookSecret: process.env.NEXA_WEBHOOK_SECRET!,
});
 
// ── Body parsing ──────────────────────────────────────────────────────────────
//
// Fastify's default JSON parser transforms the body before your handler runs.
// We override it to deliver the raw string to the webhook handler.
//
// Scope this to just the webhook route with a plugin to avoid affecting
// other routes.
 
await app.register(async (webhookApp) => {
  webhookApp.addContentTypeParser(
    "application/json",
    { parseAs: "string" },
    (_req, body, done) => done(null, body),
  );
 
  webhookApp.post(
    "/webhooks/nexa",
    createWebhookHandler({
      webhookSecret: process.env.NEXA_WEBHOOK_SECRET!,
      onFileComplete: async (event) => {
        console.log("File processed:", event.fileId, "records:", event.recordCount);
      },
      onPaymentComplete: async (event) => {
        console.log("Payment confirmed:", event.reference);
      },
    }),
  );
});
 
// ── SSE progress proxy ────────────────────────────────────────────────────────
app.get<{ Params: { fileId: string } }>("/progress/:fileId", async (req, reply) => {
  reply.raw.writeHead(200, {
    "Content-Type": "text/event-stream",
    "Cache-Control": "no-cache",
    Connection: "keep-alive",
  });
 
  const stream = await proxyProgressStream(req.params.fileId, {
    apiKey: process.env.NEXA_API_KEY!,
  });
 
  Readable.fromWeb(stream).pipe(reply.raw);
  return reply;
});
 
// ── Submit a file ─────────────────────────────────────────────────────────────
app.post<{ Body: { fileUrl: string; fileId: string; userId?: string } }>(
  "/process",
  async (req) => {
    const { fileUrl, fileId, userId } = req.body;
    return nexa.files.submit({ fileUrl, fileId, userId });
  },
);
 
await app.listen({ port: 3000 });

app.addContentTypeParser(
  "application/json",
  { parseAs: "string" },
  (_req, body, done) => done(null, body),
);