From 1985ffdbe9adfe40b945a3e46ce704d39799dfbc Mon Sep 17 00:00:00 2001
From: Alexis <35.alexis.pele@gmail.com>
Date: Sat, 24 Aug 2024 22:34:51 +0200
Subject: [PATCH] Added realtime subcription to calendar page

---
 pages/i/world/[id].vue              | 59 ++++++++++++++++++++++++++++-
 supabase/migrations/202401_init.sql |  3 ++
 2 files changed, 61 insertions(+), 1 deletion(-)

diff --git a/pages/i/world/[id].vue b/pages/i/world/[id].vue
index 0119727..3e228fe 100644
--- a/pages/i/world/[id].vue
+++ b/pages/i/world/[id].vue
@@ -1,13 +1,16 @@
 <script lang="ts" setup>
+import type { RealtimeChannel } from '@supabase/supabase-js'
 import { PhPlus } from '@phosphor-icons/vue';
 import type { World } from '~/models/World';
+import type { Calendar } from '~/models/CalendarConfig';
 
+const supabase = useSupabaseClient()
 const route = useRoute()
 const id = route.params.id
 
 const { data: res, pending } = await useFetch('/api/worlds/query', { query: { id, full: true } })
 
-const world = res.value?.data as World
+const world = ref<World>(res.value?.data as World)
 
 useHead({
   title: 'Profil'
@@ -30,6 +33,60 @@ const alertModalOpened = ref<boolean>(false)
 function handleDialogClose() {
   alertModalOpened.value = false
 }
+
+/**
+ * === Calendar subscriptions ===
+ */
+
+/** Active calendar channel */
+let calendarChannel: RealtimeChannel
+
+/** Handles calendar insertion realtime events */
+function handleInsertedCalendar(newCalendar: Calendar) {
+  try {
+    world.value.calendars?.push(newCalendar)
+  } catch (err) {
+    console.log(err)
+  }
+}
+
+/** Handles calendar deletion realtime events */
+function handleDeletedCalendar(id: number) {
+  try {
+    world.value.calendars?.splice(world.value.calendars.findIndex(c => c.id === id))
+  } catch (err) {
+    console.log(err)
+  }
+}
+
+onMounted(() => {
+  calendarChannel = supabase.channel('custom-insert-channel')
+    .on(
+      'postgres_changes',
+      { event: '*', schema: 'public', table: 'calendars' },
+      (payload) => {
+        switch (payload.eventType) {
+          case 'INSERT':
+            handleInsertedCalendar(payload.new as Calendar)
+            break
+
+          case 'DELETE':
+            handleDeletedCalendar(payload.old.id)
+            break
+
+          default:
+            console.log('Unknown event has been triggered. This should not happen unless Supabase added one somehow.')
+            break
+        }
+      }
+    )
+    .subscribe()
+})
+
+onUnmounted(() => {
+  // Unsubscribe from realtime
+  supabase.removeChannel(calendarChannel)
+})
 </script>
 
 <template>
diff --git a/supabase/migrations/202401_init.sql b/supabase/migrations/202401_init.sql
index dcdfcad..746cf05 100644
--- a/supabase/migrations/202401_init.sql
+++ b/supabase/migrations/202401_init.sql
@@ -160,6 +160,9 @@ alter table public.calendar_events enable row level security;
 alter table public.calendar_event_categories enable row level security;
 alter table public.calendar_event_categories_links enable row level security;
 
+-- Add realtime
+alter publication supabase_realtime add table calendars;
+
 -- User policies
 create policy "Allow logged-in read access" on public.users for select using ( auth.role() = 'authenticated' );
 create policy "Allow individual insert access" on public.users for insert with check ( auth.uid() = id );