Merge branch 'realtime' into 'master'

feat: realtime updates for study spaces and reports

See merge request gk1623/drp-48!29

Co-authored-by: Gleb Koval <gleb@koval.net>

src/lib/components/Feedback.svelte

@@ -33,6 +33,11 @@
                 tags: newStudySpaceData.tags
             })
             .eq("id", newStudySpaceData.id ?? "");
+        await supabase.channel("study_space_updates").send({
+            type: "broadcast",
+            event: "study_space_updated",
+            payload: { id: newStudySpaceData.id }
+        });
         invalidate("db:study_spaces");
         if (feedbackUpload) return alert(`Error submitting feedback: ${feedbackUpload.message}`);
         else alert("Feedback submitted successfully!");

src/lib/components/Report.svelte

@@ -29,6 +29,12 @@
             .select()
             .single();
 
+        await supabase.channel("report_updates").send({
+            type: "broadcast",
+            event: "reports_updated",
+            payload: { study_space_id: studySpaceId }
+        });
+
         if (reportUploadError)
             return alert(`Error submitting report: ${reportUploadError.message}`);
         else alert("Report submitted successfully!");

src/routes/+layout.svelte

@@ -17,7 +17,16 @@
                 invalidate("supabase:auth");
             }
         });
-        return () => data.subscription.unsubscribe();
+        const spacesChannel = supabase
+            .channel("study_space_updates")
+            .on("broadcast", { event: "study_space_updated" }, () => {
+                invalidate("db:study_spaces");
+            })
+            .subscribe();
+        return () => {
+            data.subscription.unsubscribe();
+            spacesChannel.unsubscribe();
+        };
     });
     $effect(() => {
         if (route.id === "/filter") {

src/routes/space/[id]/edit/+page.svelte

@@ -207,6 +207,13 @@
                 .insert(genTimings(studySpaceInsert.id));
             if (hoursErr) return alert(`Error saving opening times: ${hoursErr.message}`);
         }
+        await supabase.channel("study_space_updates").send({
+            type: "broadcast",
+            event: "study_space_updated",
+            payload: {
+                study_space_id: studySpaceInsert.id
+            }
+        });
         alert("Thank you for your contribution!");
         // Redirect to the new study space page
         await goto(`/space/${studySpaceInsert.id}`, {

src/routes/space/reports/+page.svelte

@@ -5,6 +5,7 @@
     const { data } = $props();
     const { reports, supabase } = $derived(data);
     import { invalidate } from "$app/navigation";
+    import { onMount } from "svelte";
 
     let deleting = $state(false);
 
@@ -18,6 +19,16 @@
             return alert(`Error submitting report: ${reportDeleteError.message}`);
         else alert("Report deleted successfully!");
     }
+
+    onMount(() => {
+        const reportsChannel = supabase
+            .channel("report_updates")
+            .on("broadcast", { event: "reports_updated" }, () => {
+                invalidate("db:reports");
+            })
+            .subscribe();
+        return () => reportsChannel.unsubscribe();
+    });
 </script>
 
 <Navbar>