Repository navigation
Expand file tree
/
Copy pathdev-api.js
More file actions
71 lines (65 loc) · 1.8 KB
/
Copy pathdev-api.js
File metadata and controls
71 lines (65 loc) · 1.8 KB
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
import { handleApiRequest } from "./api-router.js";
import { jsonResponse } from "./http.js";
async function readRequestBody(request) {
const chunks = [];
for await (const chunk of request) chunks.push(Buffer.from(chunk));
return Buffer.concat(chunks);
}
function requestHeaders(incoming) {
const headers = new Headers();
for (const [name, value] of Object.entries(incoming.headers)) {
if (Array.isArray(value)) {
for (const item of value) headers.append(name, item);
} else if (value !== undefined) {
headers.set(name, value);
}
}
return headers;
}
function configureLocalApi(server) {
server.middlewares.use(async (incoming, outgoing, next) => {
const method = incoming.method ?? "GET";
const host = incoming.headers.host ?? "127.0.0.1";
const body = method === "GET" || method === "HEAD"
? undefined
: await readRequestBody(incoming);
const request = new Request(
new URL(incoming.url ?? "/", `http://${host}`),
{
method,
headers: requestHeaders(incoming),
body,
},
);
let response;
try {
response = await handleApiRequest(request, process.env);
} catch {
response = jsonResponse(
{
error: {
code: "INTERNAL_ERROR",
message: "SANDEVISTAN API failed",
},
},
{ status: 500 },
);
}
if (!response) {
next();
return;
}
outgoing.statusCode = response.status;
response.headers.forEach((value, name) => {
outgoing.setHeader(name, value);
});
outgoing.end(Buffer.from(await response.arrayBuffer()));
});
}
export function sandevistanDevApi() {
return {
name: "sandevistan-dev-api",
configureServer: configureLocalApi,
configurePreviewServer: configureLocalApi,
};
}