Replace axios with fetch

packages/bsky/package.json

@@ -41,7 +41,6 @@
     "@connectrpc/connect-express": "^1.1.4",
     "@connectrpc/connect-node": "^1.1.4",
     "@did-plc/lib": "^0.0.1",
-    "axios": "^0.27.2",
     "compression": "^1.7.4",
     "cors": "^2.8.5",
     "express": "^4.17.2",
@@ -77,6 +76,7 @@
     "@types/express-serve-static-core": "^4.17.36",
     "@types/pg": "^8.6.6",
     "@types/qs": "^6.9.7",
+    "axios": "^0.27.2",
     "jest": "^28.1.2",
     "ts-node": "^10.8.2",
     "typescript": "^5.6.3"

packages/bsky/src/revenueCat.ts

@@ -1,5 +1,3 @@
-import axios, { AxiosInstance } from 'axios'
-
 type Config = {
   apiKey: string
   url: string
@@ -15,26 +13,38 @@ type GetSubscriberResponse = {
 }
 
 export class RevenueCatClient {
+  private apiKey: string
+  private url: string
   private webhookAuthorization: string | undefined
-  private axios: AxiosInstance
 
   constructor({ apiKey, url, webhookAuthorization }: Config) {
-    this.axios = axios.create({
-      baseURL: url,
+    this.apiKey = apiKey
+    this.url = url
+    this.webhookAuthorization = webhookAuthorization
+  }
+
+  private async fetch<T extends object>(
+    path: string,
+    method: string = 'GET',
+  ): Promise<T> {
+    const res = await fetch(`${this.url}${path}`, {
+      method,
       headers: {
-        Authorization: `Bearer ${apiKey}`,
+        Authorization: `Bearer ${this.apiKey}`,
       },
     })
 
-    this.webhookAuthorization = webhookAuthorization
+    if (!res.ok) {
+      throw new Error(`Failed to fetch ${path}: ${res.statusText}`)
+    }
+
+    return res.json() as T
   }
 
   async getSubscriber(did: string): Promise<GetSubscriberResponse> {
-    const { data } = await this.axios.get(
+    return this.fetch<GetSubscriberResponse>(
       `/subscribers/${encodeURIComponent(did)}`,
     )
-
-    return data as GetSubscriberResponse
   }
 
   isWebhookAuthorizationValid(authorization: string | undefined): boolean {