Function loader

apps/webapp/app/routes/tests.sse.stream.ts:6–40

({ request }: LoaderFunctionArgs)

import { sse } from "~/utils/sse.server";

export async function loader({ request }: LoaderFunctionArgs) {
  const url = new URL(request.url);
  const searchParams = Object.fromEntries(url.searchParams.entries());

  const options = z
    .object({
      minDelay: z.coerce.number().int(),
      maxDelay: z.coerce.number().int(),
      undefinedProbability: z.coerce.number().min(0).max(1).default(0.1),
    })
    .parse(searchParams);

  logger.debug("Test SSE stream", { options });

  let lastSignals = calculateChangeSignals(Date.now());

  return sse({
    request,
    run: async (send, stop) => {
      const result = await dateForUpdates(options);

      if (!result) {
        return stop();
      }

      const newSignals = calculateChangeSignals(result);

      if (lastSignals.ts !== newSignals.ts) {
        send({ data: JSON.stringify(newSignals) });
      }

      lastSignals = newSignals;
    },
  });
}

async function dateForUpdates(opts: {
  minDelay: number;