feat: DiscordREST implementation

Still needs rate limiting etc

DiscordConfig/index.ts

@@ -0,0 +1,32 @@
+import { tag } from "@effect-ts/system/Has"
+import * as T from "@effect-ts/core/Effect"
+
+const VERSION = 9
+
+export interface DiscordConfig {
+  _tag: "DiscordConfig"
+  token: string
+  rest: {
+    baseUrl: string
+  }
+}
+export const DiscordConfig = tag<DiscordConfig>()
+
+export interface MakeOpts {
+  token: string
+  rest?: {
+    baseUrl?: string
+  }
+}
+
+export const make = ({ token, rest }: MakeOpts): DiscordConfig => ({
+  _tag: "DiscordConfig",
+  token,
+  rest: {
+    baseUrl: `https://discord.com/api/v${VERSION}`,
+    ...(rest ?? {}),
+  },
+})
+
+export const token = T.accessService(DiscordConfig)(({ token }) => token)
+export const rest = T.accessService(DiscordConfig)(({ rest }) => rest)

DiscordREST/http.ts

@@ -1,7 +1,15 @@
 import * as T from "@effect-ts/core/Effect"
 import * as Axios from "axios"
+import { RESTError, Response } from "./types"
 
 export const request =
-  <A>(axios: Axios.AxiosInstance) =>
-  (config: Axios.AxiosRequestConfig) =>
-    T.tryCatchPromise(() => axios.request<A>(config), onReject)
+  (axios: Axios.AxiosInstance) =>
+  <A>(config: Axios.AxiosRequestConfig): Response<A> =>
+    T.tryCatchPromise<RESTError, A>(
+      () => axios.request<A>(config).then((r) => r.data),
+      (err) => ({
+        _tag: "http",
+        code: (err as Axios.AxiosError).response!.status,
+        body: (err as Axios.AxiosError).response?.data,
+      }),
+    )

DiscordREST/index.ts

@@ -0,0 +1,81 @@
+import * as T from "@effect-ts/core/Effect"
+import { tag } from "@effect-ts/system/Has"
+import Axios, { AxiosInstance, AxiosRequestConfig, Method } from "axios"
+import * as Config from "../DiscordConfig"
+import { createRoutes, Endpoints } from "../types"
+import * as Http from "./http"
+
+export interface DiscordREST extends Endpoints<AxiosRequestConfig> {
+  _tag: "DiscordREST"
+  axios: AxiosInstance
+}
+export const DiscordREST = tag<DiscordREST>()
+
+interface FormData {
+  append: (key: string, value: unknown) => void
+  getHeaders: () => Record<string, string>
+}
+
+const make = T.gen(function* (_) {
+  const token = yield* _(Config.token)
+  const config = yield* _(Config.rest)
+
+  const axios = Axios.create({
+    baseURL: config.baseUrl,
+    headers: {
+      Authorization: `Bot ${token}`,
+    },
+  })
+  const request = Http.request(axios)
+  const routes = createRoutes<AxiosRequestConfig>(
+    ({ method, url, params = {}, options = {} }) => {
+      const hasBody = method !== "GET" && method !== "DELETE"
+      let hasFormData = false
+
+      if (typeof options.data?.append === "function") {
+        hasFormData = true
+        ;(options.data as FormData).append(
+          "payload_json",
+          JSON.stringify(params),
+        )
+      }
+
+      const qsParams = hasBody
+        ? options.params
+        : {
+            ...(options.params || {}),
+            ...params,
+          }
+      const data =
+        hasFormData || !hasBody
+          ? options.data
+          : {
+              ...(options.data || {}),
+              ...params,
+            }
+
+      const config = {
+        ...options,
+        headers: {
+          ...(options.headers || {}),
+          ...(hasFormData ? data.getHeaders() : {}),
+        },
+        method: method as Method,
+        url,
+        params: qsParams,
+        data,
+      }
+      return request(config)
+    },
+  )
+
+  const rest: DiscordREST = {
+    _tag: "DiscordREST",
+    axios,
+    ...routes,
+  }
+
+  return rest
+})
+
+export const LiveDiscordREST = T.toLayer(DiscordREST)(make)

tsconfig.json

@@ -9,7 +9,7 @@
     "preserveSymlinks": true,
     "moduleResolution": "node",
     "module": "CommonJS",
-    "lib": ["es2020"],
+    "lib": ["ESNext"],
     "sourceMap": true,
     "declaration": true,
     "strict": true,

types.ts

@@ -426,7 +426,7 @@ export interface BulkDeleteMessageParams {
   /** an array of message ids to delete (2-100) */
   messages: Snowflake[]
 }
-export interface BulkOverwriteGuildApplicationCommandBulkApplicationCommandParams {
+export interface BulkOverwriteGuildApplicationCommandParams {
   /** application command id, if known */
   id: Snowflake
   /** 1-32 character name */