supabase service snippet

Author: SandroMaglione

supabase-service-in-effect/package.json

@@ -0,0 +1,14 @@
+{
+  "author": "Sandro Maglione <sandro@sandromaglione.com>",
+  "license": "MIT",
+  "scripts": {
+    "db-types": "supabase gen types typescript --project-id <project_id> --schema public > database/database.ts"
+  },
+  "devDependencies": {
+    "typescript": "^5.6.3"
+  },
+  "dependencies": {
+    "@supabase/supabase-js": "^2.46.1",
+    "effect": "^3.10.8"
+  }
+}

supabase-service-in-effect/pnpm-lock.yaml

@@ -0,0 +1,50 @@
+import * as _Supabase from "@supabase/supabase-js";
+import { Config, Context, Data, Effect, Layer, Redacted } from "effect";
+import type { Database } from "./database"; // 👈 Generated types
+
+interface SupabaseConfig {
+  readonly url: string;
+  readonly key: Redacted.Redacted;
+}
+
+class SupabaseError extends Data.TaggedError("SupabaseError")<
+  Readonly<{
+    error: _Supabase.PostgrestError;
+  }>
+> {}
+
+const make = ({ key, url }: SupabaseConfig) =>
+  Effect.gen(function* (_) {
+    const client = yield* Effect.sync(() =>
+      _Supabase.createClient<Database>(url, Redacted.value(key))
+    );
+
+    const query = <A>(
+      body: (
+        _: typeof client
+      ) => PromiseLike<_Supabase.PostgrestSingleResponse<A>>
+    ) =>
+      Effect.async<A, SupabaseError, never>((cb) => {
+        body(client).then(({ data, error }) => {
+          if (error) {
+            cb(Effect.fail(new SupabaseError({ error })));
+          } else {
+            cb(Effect.succeed(data));
+          }
+        });
+      });
+
+    return { query, client };
+  });
+
+export class Supabase extends Context.Tag("Supabase")<
+  Supabase,
+  Effect.Effect.Success<ReturnType<typeof make>>
+>() {
+  static readonly Live = (config: Config.Config.Wrap<SupabaseConfig>) =>
+    Config.unwrap(config).pipe(
+      Effect.flatMap(make),
+      Layer.effect(this),
+      Layer.orDie
+    );
+}

supabase-service-in-effect/src/Supabase.ts

@@ -0,0 +1,44 @@
+export type Json =
+  | string
+  | number
+  | boolean
+  | null
+  | { [key: string]: Json | undefined }
+  | Json[];
+
+export interface Database {
+  public: {
+    Tables: {
+      user: {
+        Row: {
+          created_at: string;
+          email: string;
+          id: string;
+        };
+        Insert: {
+          created_at?: string;
+          email: string;
+          id: string;
+        };
+        Update: {
+          created_at?: string;
+          email?: string;
+          id?: string;
+        };
+        Relationships: [];
+      };
+    };
+    Views: {
+      [_ in never]: never;
+    };
+    Functions: {
+      [_ in never]: never;
+    };
+    Enums: {
+      [_ in never]: never;
+    };
+    CompositeTypes: {
+      [_ in never]: never;
+    };
+  };
+}

supabase-service-in-effect/src/database.ts

@@ -0,0 +1,20 @@
+{
+  "compilerOptions": {
+    "esModuleInterop": true,
+    "skipLibCheck": true,
+    "target": "es2022",
+    "allowJs": true,
+    "resolveJsonModule": true,
+    "moduleDetection": "force",
+    "isolatedModules": true,
+    "verbatimModuleSyntax": true,
+    "strict": true,
+    "noUncheckedIndexedAccess": true,
+    "noImplicitOverride": true,
+    "module": "preserve",
+    "noEmit": true,
+    "lib": ["es2022"]
+  },
+  "include": ["**/*.ts", "**/*.tsx"],
+  "exclude": ["node_modules"]
+}