import { connection } from "next/server";

import {
  createRedisEventResponse,
  eventsUnavailableResponse,
} from "@/lib/events/redis-stream";

export async function GET(request: Request) {
  await connection();
  try {
    return await createRedisEventResponse("directory", request.signal);
  } catch {
    return eventsUnavailableResponse();
  }
}