Cherrypick server file

2024-02-22 11:57:31 +01:00 · 2024-02-22 11:57:31 +01:00 · 50156ee3f5
commit 50156ee3f5
parent 62c494d709
1 changed files with 112 additions and 0 deletions
--- a/scripts/server.ts
+++ b/scripts/server.ts
@ -0,0 +1,112 @@
+import http from "node:http"
+
+export class Server {
+    constructor(
+        port: number,
+        options: {
+            ignorePathPrefix?: string[]
+        },
+        handle: {
+            mustMatch: string | RegExp
+            mimetype: string
+            handle: (path: string) => Promise<string>
+        }[]
+    ) {
+        handle.push({
+            mustMatch: "",
+            mimetype: "text/html",
+            handle: async () => {
+                return `<html><body>Supported endpoints are <ul>${handle
+                    .filter((h) => h.mustMatch !== "")
+                    .map((h) => {
+                        let l = h.mustMatch
+                        if (typeof h.mustMatch === "string") {
+                            l = `<a href='${l}'>${l}</a>`
+                        }
+                        return "<li>" + l + "</li>"
+                    })
+                    .join("")}</ul></body></html>`
+            },
+        })
+        http.createServer(async (req: http.IncomingMessage, res) => {
+            try {
+                console.log(
+                    req.method + " " + req.url,
+                    "from:",
+                    req.headers.origin,
+                    new Date().toISOString()
+                )
+
+                const url = new URL(`http://127.0.0.1/` + req.url)
+                let path = url.pathname
+                while (path.startsWith("/")) {
+                    path = path.substring(1)
+                }
+                if (options?.ignorePathPrefix) {
+                    for (const toIgnore of options.ignorePathPrefix) {
+                        if (path.startsWith(toIgnore)) {
+                            path = path.substring(toIgnore.length + 1)
+                            break
+                        }
+                    }
+                }
+                const handler = handle.find((h) => {
+                    if (typeof h.mustMatch === "string") {
+                        return h.mustMatch === path
+                    }
+                    if (path.match(h.mustMatch)) {
+                        return true
+                    }
+                })
+
+                if (handler === undefined || handler === null) {
+                    res.writeHead(404, { "Content-Type": "text/html" })
+                    res.write("<html><body><p>Not found...</p></body></html>")
+                    res.end()
+                    return
+                }
+
+                res.setHeader(
+                    "Access-Control-Allow-Headers",
+                    "Origin, X-Requested-With, Content-Type, Accept"
+                )
+                res.setHeader("Access-Control-Allow-Origin", req.headers.origin ?? "*")
+                if (req.method === "OPTIONS") {
+                    res.setHeader(
+                        "Access-Control-Allow-Methods",
+                        "POST, GET, OPTIONS, DELETE, UPDATE"
+                    )
+                    res.writeHead(204, { "Content-Type": handler.mimetype })
+                    res.end()
+                    return
+                }
+                if (req.method === "POST" || req.method === "UPDATE") {
+                    return
+                }
+
+                if (req.method === "DELETE") {
+                    return
+                }
+
+                try {
+                    const result = await handler.handle(path)
+                    res.writeHead(200, { "Content-Type": handler.mimetype })
+                    res.write(result)
+                    res.end()
+                } catch (e) {
+                    console.error("Could not handle request:", e)
+                    res.writeHead(500)
+                    res.write(e)
+                    res.end()
+                }
+            } catch (e) {
+                console.error("FATAL:", e)
+                res.end()
+            }
+        }).listen(port)
+        console.log(
+            "Server is running on port " + port,
+            ". Supported endpoints are: " + handle.map((h) => h.mustMatch).join(", ")
+        )
+    }
+}