Adds durable object for Supabase

package.json

@@ -1,6 +1,7 @@
 {
 	"name": "aibtcdev-api-cache",
 	"version": "0.0.1",
+	"type": "module",
 	"private": true,
 	"scripts": {
 		"deploy": "wrangler deploy",
@@ -12,5 +13,8 @@
 		"@cloudflare/workers-types": "^4.20241106.0",
 		"typescript": "^5.5.2",
 		"wrangler": "^3.60.3"
+	},
+	"dependencies": {
+		"@supabase/supabase-js": "^2.46.1"
 	}
 }

src/config.ts

@@ -1,15 +1,41 @@
-export const APP_CONFIG = {
-	// supported services for API caching
-	// each entry is a durable object that handles requests
-	SUPPORTED_SERVICES: ['/hiro-api'],
-	// VALUES BELOW CAN BE OVERRIDDEN BY DURABLE OBJECTS
-	// default cache TTL used for KV
-	CACHE_TTL: 900, // 15 minutes
-	// default rate limiting settings
-	MAX_REQUESTS_PER_INTERVAL: 30, // no more than 30 requests
-	INTERVAL_MS: 15000, // in a span of 15 seconds
-	MAX_RETRIES: 3, // max retries for failed fetches
-	RETRY_DELAY: 1000, // multiplied by retry attempt number
-	// how often to warm the cache, should be shorter than the cache TTL
-	ALARM_INTERVAL_MS: 300000, // 5 minutes
-};
+import { Env } from '../worker-configuration';
+
+export class AppConfig {
+  private static instance: AppConfig;
+  private env: Env;
+
+  private constructor(env: Env) {
+    this.env = env;
+  }
+
+  public static getInstance(env?: Env): AppConfig {
+    if (!AppConfig.instance && env) {
+      AppConfig.instance = new AppConfig(env);
+    } else if (!AppConfig.instance) {
+      throw new Error('AppConfig must be initialized with environment variables first');
+    }
+    return AppConfig.instance;
+  }
+
+  public getConfig() {
+
+    return {
+      // supported services for API caching
+      // each entry is a durable object that handles requests
+      SUPPORTED_SERVICES: ['/hiro-api', '/supabase'],
+      // VALUES BELOW CAN BE OVERRIDDEN BY DURABLE OBJECTS
+      // default cache TTL used for KV
+      CACHE_TTL: 900, // 15 minutes
+      // default rate limiting settings
+      MAX_REQUESTS_PER_INTERVAL: 30, // no more than 30 requests
+      INTERVAL_MS: 15000, // in a span of 15 seconds
+      MAX_RETRIES: 3, // max retries for failed fetches
+      RETRY_DELAY: 1000, // multiplied by retry attempt number
+      // how often to warm the cache, should be shorter than the cache TTL
+      ALARM_INTERVAL_MS: 300000, // 5 minutes
+      // environment variables
+      SUPABASE_URL: this.env.SUPABASE_URL,
+      SUPABASE_SERVICE_KEY: this.env.SUPABASE_SERVICE_KEY,
+    };
+  }
+}

src/durable-objects/hiro-api-do.ts

@@ -1,19 +1,19 @@
 import { DurableObject } from 'cloudflare:workers';
 import { Env } from '../../worker-configuration';
-import { APP_CONFIG } from '../config';
+import { AppConfig } from '../config';
 import { RateLimitedFetcher } from '../rate-limiter';
 
 /**
  * Durable Object class for the Hiro API
  */
 export class HiroApiDO extends DurableObject<Env> {
 	// can override values here for all endpoints
-	private readonly CACHE_TTL: number = APP_CONFIG.CACHE_TTL;
-	private readonly MAX_REQUESTS_PER_MINUTE = APP_CONFIG.MAX_REQUESTS_PER_INTERVAL;
-	private readonly INTERVAL_MS = APP_CONFIG.INTERVAL_MS;
-	private readonly MAX_RETRIES = APP_CONFIG.MAX_RETRIES;
-	private readonly RETRY_DELAY = APP_CONFIG.RETRY_DELAY;
-	private readonly ALARM_INTERVAL_MS = APP_CONFIG.ALARM_INTERVAL_MS;
+	private readonly CACHE_TTL: number;
+	private readonly MAX_REQUESTS_PER_MINUTE: number;
+	private readonly INTERVAL_MS: number;
+	private readonly MAX_RETRIES: number;
+	private readonly RETRY_DELAY: number;
+	private readonly ALARM_INTERVAL_MS: number;
 	// settings specific to this Durable Object
 	private readonly BASE_API_URL: string = 'https://api.hiro.so';
 	private readonly BASE_PATH: string = '/hiro-api';
@@ -49,6 +49,18 @@ export class HiroApiDO extends DurableObject<Env> {
 		super(ctx, env);
 		this.ctx = ctx;
 		this.env = env;
+
+		// Initialize AppConfig with environment
+		const config = AppConfig.getInstance(env).getConfig();
+
+		// Set configuration values
+		this.CACHE_TTL = config.CACHE_TTL;
+		this.MAX_REQUESTS_PER_MINUTE = config.MAX_REQUESTS_PER_INTERVAL;
+		this.INTERVAL_MS = config.INTERVAL_MS;
+		this.MAX_RETRIES = config.MAX_RETRIES;
+		this.RETRY_DELAY = config.RETRY_DELAY;
+		this.ALARM_INTERVAL_MS = config.ALARM_INTERVAL_MS;
+
 		this.fetcher = new RateLimitedFetcher(
 			this.env,
 			this.BASE_API_URL,