Send notifications with Next.js

"use server";

import Courier from "@trycourier/courier";

const courier = new Courier();

export async function sendWelcome(userId: string, plan: string) {
  const { requestId } = await courier.send.message(
    {
      message: {
        template: "welcome",
        to: { user_id: userId },
        data: { plan },
      },
    },
    { idempotencyKey: `welcome-${userId}` }
  );

  return requestId;
}

// app/api/courier/token/route.ts
import Courier from "@trycourier/courier";

export async function GET() {
  // Read the user id from your own session (NextAuth, Clerk, Supabase, a cookie).
  // Never take it from the request.
  const userId = "sarah-bennett";

  const client = new Courier({ apiKey: process.env.COURIER_API_KEY });

  const { token } = await client.auth.issueToken({
    scope: `user_id:${userId} inbox:read:messages inbox:write:events`,
    // Always set this. Omitting it mints a token that never expires.
    expires_in: "1 day",
  });

  return Response.json({ userId, token });
}

// components/courier-inbox.tsx
"use client";

import { useEffect, useRef } from "react";
import { CourierInbox, useCourier } from "@trycourier/courier-react";

export function Inbox() {
  const courier = useCourier();
  const signedIn = useRef(false);

  useEffect(() => {
    if (signedIn.current) return;
    signedIn.current = true;

    fetch("/api/courier/token")
      .then((response) => response.json())
      .then((body) => courier.shared.signIn({ userId: body.userId, jwt: body.token }));
  }, [courier]);

  return <CourierInbox />;
}