import { IdResolver } from "@atproto/identity";
import { NextRequest, NextResponse } from "next/server";
let idResolver = new IdResolver();

export async function GET(req: NextRequest) {
  const url = new URL(req.url);
  const params = {
    did: url.searchParams.get("did") ?? "",
    cid: url.searchParams.get("cid") ?? "",
  };
  if (!params.did || !params.cid)
    return new NextResponse(null, { status: 404 });

  let identity = await idResolver.did.resolve(params.did);
  let service = identity?.service?.find((f) => f.id === "#atproto_pds");
  if (!service) return new NextResponse(null, { status: 404 });
  const response = await fetch(
    `${service.serviceEndpoint}/xrpc/com.atproto.sync.getBlob?did=${params.did}&cid=${params.cid}`,
    {
      headers: {
        "Accept-Encoding": "gzip, deflate, br, zstd",
      },
    },
  );

  // Clone the response to modify headers
  const cachedResponse = new Response(response.body, response);

  // Set cache-control header to cache indefinitely
  cachedResponse.headers.set(
    "Cache-Control",
    "public, max-age=31536000, immutable, s-maxage=86400, stale-while-revalidate=604800",
  );
  cachedResponse.headers.set(
    "CDN-Cache-Control",
    "s-maxage=86400, stale-while-revalidate=86400",
  );

  return cachedResponse;
}