aboutsummaryrefslogtreecommitdiff
path: root/projects/www/server/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'projects/www/server/index.js')
-rw-r--r--projects/www/server/index.js376
1 files changed, 0 insertions, 376 deletions
diff --git a/projects/www/server/index.js b/projects/www/server/index.js
deleted file mode 100644
index c8230ec..0000000
--- a/projects/www/server/index.js
+++ /dev/null
@@ -1,376 +0,0 @@
-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.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!");
- },
-};
generated by cgit v1.2.3 (git 2.25.1) at 2026-06-21 20:32:47 +0000