File size: 1,585 Bytes
35743bd
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
import { buildConfigSyncEnvelope } from "@/lib/sync/bundle";
import { getSyncTokenFromRequest, markSyncTokenUsed, validateSyncToken } from "@/lib/sync/tokens";
import { createErrorResponse, createErrorResponseFromUnknown } from "@/lib/api/errorResponse";

function matchesEtag(request: Request, version: string) {
  const ifNoneMatch = request.headers.get("if-none-match");
  if (!ifNoneMatch) return false;
  const candidates = ifNoneMatch
    .split(",")
    .map((part) => part.trim())
    .filter(Boolean);
  return candidates.some((candidate) => candidate === version || candidate === `"${version}"`);
}

function responseHeaders(version: string) {
  return {
    etag: `"${version}"`,
    "x-config-version": version,
    "cache-control": "private, no-store",
  };
}

export async function GET(request: Request) {
  try {
    const rawToken = getSyncTokenFromRequest(request);
    const syncToken = await validateSyncToken(rawToken);
    if (!syncToken) {
      return createErrorResponse({
        status: 401,
        message: "Invalid sync token",
      });
    }

    const { version, bundle } = await buildConfigSyncEnvelope();
    await markSyncTokenUsed(syncToken);

    if (matchesEtag(request, version)) {
      return new Response(null, {
        status: 304,
        headers: responseHeaders(version),
      });
    }

    return Response.json(
      {
        version,
        bundle,
      },
      {
        headers: responseHeaders(version),
      }
    );
  } catch (error) {
    return createErrorResponseFromUnknown(error, "Failed to build sync bundle");
  }
}