feat: create supabase lib and actions files

app/(dashboard)/actions.ts

@@ -0,0 +1 @@
+'use server'

app/(root)/actions.ts

@@ -0,0 +1 @@
+'use server'

lib/supabase/client.ts

@@ -0,0 +1,52 @@
+import { createBrowserClient } from '@supabase/ssr'
+
+const SUPABASE_URL = process.env.SUPABASE_URL
+const SUPABASE_ANON_KEY = process.env.SUPABASE_ANON_KEY
+
+if (!SUPABASE_URL || !SUPABASE_ANON_KEY) {
+  throw new Error('Missing Supabase environment variables')
+}
+
+const createClient = () => {
+  return createBrowserClient(SUPABASE_URL, SUPABASE_ANON_KEY)
+}
+
+const supabase = createClient()
+
+type HandleNewValueType = (payload: any) => void
+
+export const onInsertListener = ({
+  tableName,
+  handleNewValue
+}: {
+  tableName: string
+  handleNewValue: HandleNewValueType
+}) => {
+  return supabase
+    .channel(`public:${tableName}`)
+    .on('postgres_changes', { event: 'INSERT', schema: 'public', table: tableName }, (payload) =>
+      handleNewValue(payload.new)
+    )
+    .subscribe() as any
+}
+
+export const onDeleteListener = ({
+  tableName,
+  handleNewValue
+}: {
+  tableName: string
+  handleNewValue: HandleNewValueType
+}) => {
+  return supabase
+    .channel(`public:${tableName}`)
+    .on('postgres_changes', { event: 'DELETE', schema: 'public', table: tableName }, (payload) =>
+      handleNewValue(payload.old)
+    )
+    .subscribe() as any
+}
+
+export const removeListener = ({ listener }: { listener: any }) => {
+  supabase.removeChannel(supabase.channel(listener))
+}
+
+export { supabase }

lib/supabase/server.ts

@@ -0,0 +1,64 @@
+import { cookies } from 'next/headers'
+import { createServerClient } from '@supabase/ssr'
+
+const SUPABASE_URL = process.env.SUPABASE_URL
+const SUPABASE_ANON_KEY = process.env.SUPABASE_ANON_KEY
+
+if (!SUPABASE_URL || !SUPABASE_ANON_KEY) {
+  throw new Error('Missing Supabase environment variables')
+}
+
+type HandleNewValueType = (payload: any) => void
+
+const supabase = createServerClient(SUPABASE_URL, SUPABASE_ANON_KEY, {
+  cookies: {
+    getAll() {
+      return cookies().getAll()
+    },
+    setAll(cookiesToSet) {
+      try {
+        cookiesToSet.forEach(({ name, value, options }) => cookies().set(name, value, options))
+      } catch {
+        // The `setAll` method was called from a Server Component.
+        // This can be ignored if you have middleware refreshing
+        // user sessions.
+      }
+    }
+  }
+})
+
+export const onInsertListener = ({
+  tableName,
+  handleNewValue
+}: {
+  tableName: string
+  handleNewValue: HandleNewValueType
+}) => {
+  return supabase
+    .channel(`public:${tableName}`)
+    .on('postgres_changes', { event: 'INSERT', schema: 'public', table: tableName }, (payload) =>
+      handleNewValue(payload.new)
+    )
+    .subscribe() as any
+}
+
+export const onDeleteListener = ({
+  tableName,
+  handleNewValue
+}: {
+  tableName: string
+  handleNewValue: HandleNewValueType
+}) => {
+  return supabase
+    .channel(`public:${tableName}`)
+    .on('postgres_changes', { event: 'DELETE', schema: 'public', table: tableName }, (payload) =>
+      handleNewValue(payload.old)
+    )
+    .subscribe() as any
+}
+
+export const removeListener = ({ listener }: { listener: any }) => {
+  supabase.removeChannel(supabase.channel(listener))
+}
+
+export { supabase }

package.json

@@ -29,6 +29,8 @@
     "@radix-ui/react-slot": "^1.1.0",
     "@radix-ui/react-toast": "^1.2.1",
     "@radix-ui/react-tooltip": "^1.1.2",
+    "@supabase/ssr": "^0.5.1",
+    "@supabase/supabase-js": "^2.45.3",
     "chart.js": "^4.4.2",
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.1.1",