make it work

1 files changed, 391 insertions, 0 deletions

diff --git a/server/index.js b/server/index.js
new file mode 100644
index 0000000..8812cb2
--- /dev/null
+++ b/server/index.js
@@ -0,0 +1,391 @@
+import puppeteer from "@cloudflare/puppeteer";
+
+export default {
+  /*
+    Fetch event handler, this function will be called whenever a request is made to the worker.
+    The function will parse the request and return a response based on the request path.
+
+    @param {Request} request - the incoming request object
+    @param {Environment} environment - the environment object
+    @param {Context} context - the context object
+
+    @returns {Response} a new Response object
+  */
+  async fetch(request, environment, context) {
+    const url = new URL(request.url);
+
+    if (url.hostname === "api.zue.dev")
+      return Response.redirect(
+        `https://zue.dev/api/${url.pathname}${url.search}`,
+        301
+      );
+
+    if (url.hostname === "96.zue.dev")
+      return Response.redirect(`https://zue.dev/96/${url.pathname}`, 301);
+
+    if (url.hostname === "about.zue.dev")
+      return Response.redirect(`https://zue.dev/about/${url.pathname}`, 301);
+
+    if (url.hostname === "bbg.zue.dev")
+      return Response.redirect(`https://zue.dev/bbg/${url.pathname}`, 301);
+
+    if (url.pathname.startsWith("/api")) {
+      const pathname = url.pathname.replace("/api", "");
+
+      // modify Response to handle CORS defaults
+      class Response extends globalThis.Response {
+        constructor(body, init) {
+          super(body, init);
+          this.headers.set("Access-Control-Allow-Origin", "*");
+          this.headers.set("Access-Control-Allow-Methods", "*");
+          this.headers.set("Access-Control-Allow-Headers", "*");
+        }
+      }
+
+      switch (pathname) {
+        case "/":
+          return (() => {
+            return new Response(
+              JSON.stringify({
+                message: "Hello, World! :3",
+                random: `${Math.random()}`,
+              }),
+              {
+                headers: {
+                  "Access-Control-Allow-Origin": "*",
+                  "Content-Type": "application/json",
+                },
+              }
+            );
+          })();
+        case "/status":
+          return (() => {
+            const url = new URL(request.url);
+            const service = url.searchParams.get("service");
+
+            const acceptedServices = [
+              "dns",
+              "load-balancer",
+              "cdn",
+              "functions",
+              "mysql-cluster",
+              "mongodb-cluster",
+              "redis-cluster",
+              "elasticsearch-cluster",
+              "git-connector",
+              "job-runners",
+              "container-registry",
+              "kubernetes-cluster",
+              "bare-metal-servers",
+              "game-server-api",
+              "anti-ddos-protection",
+              "anti-cheat-api",
+            ];
+
+            if (acceptedServices.includes(service))
+              return new Response(
+                JSON.stringify({
+                  status: "ok",
+                  service,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            return new Response(
+              JSON.stringify({
+                error: `service not found`,
+              }),
+              {
+                headers: {
+                  "Access-Control-Allow-Origin": "*",
+                  "Content-Type": "application/json",
+                },
+              }
+            );
+          })();
+        case "/96/twitch/streaming":
+          return (async () => {
+            /*
+              Checks if a twitch channel is live by fetching the "live" preview image of the channel,
+              if the image is fetched successfully, then the channel is live, otherwise it's offline.
+
+              @param {string} channel - the twitch channel name
+              @returns {boolean} true if the channel is live, false otherwise
+            */
+            async function isTwitchChannelLive(channel) {
+              // construct preview image url with channel name
+              const livePreviewUrl = `https://static-cdn.jtvnw.net/previews-ttv/live_user_${channel}-320x180.jpg`;
+
+              // fetch the preview image, don't follow redirects
+              const response = await fetch(livePreviewUrl, {
+                redirect: "manual",
+              });
+
+              // check if the image was fetched successfully
+              return response.ok;
+            }
+
+            const url = new URL(request.url);
+            const channel = url.searchParams.get("channel");
+
+            if (!channel)
+              return new Response(
+                JSON.stringify({
+                  error: `channel not provided`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            const whitelist = [
+              "zuedev",
+              ...[
+                "vtsweets",
+                "bunnibana",
+                "yayjaybae",
+                "justawoney",
+                "tygiwygi",
+              ],
+            ];
+
+            if (!whitelist.includes(channel))
+              return new Response(
+                JSON.stringify({
+                  error: `channel not whitelisted`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            const channelLive = await isTwitchChannelLive(channel);
+
+            if (channelLive)
+              return new Response(
+                JSON.stringify({
+                  status: "live",
+                  channel,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            return new Response(
+              JSON.stringify({
+                status: "offline",
+              }),
+              {
+                headers: {
+                  "Access-Control-Allow-Origin": "*",
+                  "Content-Type": "application/json",
+                },
+              }
+            );
+          })();
+        case "/96/youtube/latest-video":
+          return (async () => {
+            const url = new URL(request.url);
+            const channelHandle = url.searchParams.get("channelHandle");
+
+            if (!channelHandle)
+              return new Response(
+                JSON.stringify({
+                  error: `channel not provided`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            const channelHandleWhitelist = ["@vtsweets"];
+
+            if (!channelHandleWhitelist.includes(channelHandle))
+              return new Response(
+                JSON.stringify({
+                  error: `channel not allowed`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            let API_Key;
+
+            try {
+              API_Key = await environment.GOOGLE_API_KEY_UNRESTRICTED.get();
+            } catch (error) {
+              API_Key = environment.GOOGLE_API_KEY_UNRESTRICTED;
+            }
+
+            if (!API_Key)
+              return new Response(
+                JSON.stringify({
+                  error: `API Key not found`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+
+            const youtubeChannelsListResponse = await fetch(
+              `https://www.googleapis.com/youtube/v3/channels?part=contentDetails&forHandle=${channelHandle}&key=${API_Key}`
+            );
+
+            const youtubeChannelsList =
+              await youtubeChannelsListResponse.json();
+
+            if (youtubeChannelsList.items.length === 0) {
+              return new Response(
+                JSON.stringify({
+                  error: `channel not found`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+            }
+
+            const uploadsPlaylistId =
+              youtubeChannelsList.items[0].contentDetails.relatedPlaylists
+                .uploads;
+
+            const youtubePlaylistItemsList = await fetch(
+              `https://www.googleapis.com/youtube/v3/playlistItems?part=snippet&playlistId=${uploadsPlaylistId}&maxResults=1&key=${API_Key}`
+            );
+
+            const youtubePlaylistItemsListData =
+              await youtubePlaylistItemsList.json();
+
+            if (youtubePlaylistItemsListData.items.length === 0) {
+              return new Response(
+                JSON.stringify({
+                  error: `no videos found in the channel`,
+                }),
+                {
+                  headers: {
+                    "Access-Control-Allow-Origin": "*",
+                    "Content-Type": "application/json",
+                  },
+                }
+              );
+            }
+
+            return new Response(
+              youtubePlaylistItemsListData.items[0].snippet.resourceId.videoId
+            );
+          })();
+        case "/browser-rendering/screenshot":
+          return (async () => {
+            const { searchParams } = new URL(request.url);
+            const url = searchParams.get("url");
+            const type = searchParams.get("type") || "webp";
+            const fullPage = searchParams.get("fullPage") !== null;
+            const width = parseInt(searchParams.get("width"), 10) || 1920;
+            const height = parseInt(searchParams.get("height"), 10) || 1080;
+            const delay = parseInt(searchParams.get("delay"), 10) || 0;
+
+            if (!url)
+              return router.respond({
+                error: "URL parameter is required",
+              });
+
+            if (!/^https?:\/\//.test(url))
+              return router.respond({
+                error: "Invalid URL format",
+              });
+
+            const browser = await puppeteer.launch(environment.MYBROWSER);
+            const page = await browser.newPage();
+            await page.setViewport({ width, height });
+            await page.goto(url, {
+              waitUntil: "networkidle2",
+            });
+            if (delay > 0) {
+              await new Promise((resolve) => setTimeout(resolve, delay));
+            }
+            const screenshot = await page.screenshot({
+              type,
+              fullPage,
+            });
+            await browser.close();
+
+            return new Response(screenshot, {
+              headers: {
+                "content-type": `image/${type}`,
+              },
+            });
+          })();
+        default:
+          return new Response(
+            JSON.stringify({
+              error: `path not found`,
+            }),
+            {
+              headers: {
+                "Access-Control-Allow-Origin": "*",
+                "Content-Type": "application/json",
+              },
+            }
+          );
+      }
+    }
+
+    return environment.ASSETS.fetch(request);
+  },
+
+  /*
+    Email event handler, this function will be called whenever an email is sent to the worker.
+    The function will parse the email message and forward it to a specified email address.
+
+    @param {Message} message - the incoming email message object
+    @param {Environment} environment - the environment object
+    @param {Context} context - the context object
+
+    @returns {void}
+  */
+  async email(message, environment, context) {
+    message.forward("alex@zue.dev");
+  },
+
+  /*
+    Scheduled event handler, this function will be called whenever a scheduled event is triggered.
+    The function will perform a task and return a response based on the task outcome.
+
+    @param {Event} event - the incoming event object
+    @param {Environment} environment - the environment object
+    @param {Context} context - the context object
+
+    @returns {void}
+  */
+  async scheduled(event, environment, context) {
+    console.log("Scheduled event triggered!");
+  },
+};