123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
// START FILE FOR REST PROCESSimport { dotenv } from "./deps.ts";import { BASE_URL, createRestManager } from "../mod.ts";
dotenv({ export: true, path: `${Deno.cwd()}/.env` });
const token = Deno.env.get("DISCORD_TOKEN");if (!token) throw new Error("Token was not provided.");
const REST_AUTHORIZATION_KEY = Deno.env.get("PROXY_REST_SECRET");const PROXY_REST_URL = Deno.env.get("PROXY_REST_URL");const REST_PORT = Number(PROXY_REST_URL?.substring(PROXY_REST_URL.lastIndexOf(":") + 1)) ?? 8080;
// CREATES THE FUNCTIONALITY FOR MANAGING THE REST REQUESTSconst rest = createRestManager({  token,  secretKey: REST_AUTHORIZATION_KEY,  customUrl: PROXY_REST_URL,  // debug: console.log,});
// START LISTENING TO THE URL(localhost)const server = Deno.listen({ port: REST_PORT });console.log(  `HTTP webserver running.  Access it at: ${PROXY_REST_URL}`,);
// Connections to the server will be yielded up as an async iterable.for await (const conn of server) {  // In order to not be blocking, we need to handle each connection individually  // in its own async function.  handleRequest(conn);}
async function handleRequest(conn: Deno.Conn) {  // This "upgrades" a network connection into an HTTP connection.  const httpConn = Deno.serveHttp(conn);  // Each request sent over the HTTP connection will be yielded as an async  // iterator from the HTTP connection.  for await (const requestEvent of httpConn) {    if (      !REST_AUTHORIZATION_KEY ||      REST_AUTHORIZATION_KEY !==        requestEvent.request.headers.get("AUTHORIZATION")    ) {      return requestEvent.respondWith(        new Response(JSON.stringify({ error: "Invalid authorization key." }), {          status: 401,        }),      );    }
    try {      const text = await requestEvent.request.text();      const json = text ? JSON.parse(text) : undefined;
      const result = await rest.runMethod(        rest,        requestEvent.request.method as RequestMethod,        `${BASE_URL}${          requestEvent.request.url.substring(            `http://localhost:${REST_PORT}`.length,          )        }`,        json,      );
      if (result) {        requestEvent.respondWith(          new Response(JSON.stringify(result), {            status: 200,          }),        );      } else {        requestEvent.respondWith(          new Response(undefined, {            status: 204,          }),        );      }    } catch (error) {      console.log("CATCH", requestEvent.request.url, requestEvent.request.method, requestEvent.request.body, error);      requestEvent.respondWith(        new Response(JSON.stringify(error), {          status: error.code,        }),      );    }  }}
type RequestMethod = "POST" | "PUT" | "DELETE" | "PATCH";