import { errorResponse } from "@/lib/security/http";
import { limitRequest, trustedClientAddress } from "@/lib/security/rate-limit";
import { connection } from "next/server";

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

export async function GET(request: Request) {
  await connection();
  try {
    await limitRequest("stream-open", trustedClientAddress(request.headers), 60);
    return await createRedisEventResponse("directory", request.signal);
  } catch (cause) {
    return errorResponse(cause);
  }
}