rooms and connection hook

frontend/src/lib/liveblocks/index.ts

@@ -13,6 +13,8 @@ export * from "./useHistory";
 export * from "./useErrorListener";
 export * from "./useEventListener";
 export * from "./useBroadcastEvent";
+export * from "./useRooms";
+export * from "./useConnectionStatus"
 /**
  * These components were built to (mostly) match the
  * liveblocks-react library

frontend/src/lib/liveblocks/useConnectionStatus.ts

@@ -0,0 +1,28 @@
+import { onDestroy } from "svelte";
+import { writable, type Writable } from "svelte/store";
+import { useRoom } from "./useRoom";
+
+
+enum ConnectionStatus {
+  "closed" = "closed",
+  "authenticating" = "authenticating",
+  "unavailable" = "unavailable",
+  "failed" = "failed",
+  "open" = "open",
+  "connecting" = "connecting",
+}
+type TConnectionStatus = keyof typeof ConnectionStatus
+
+export function useConnectionStatus(): Writable<TConnectionStatus> {
+  const room = useRoom();
+  const statusStorage = writable<TConnectionStatus>(ConnectionStatus.closed);
+
+  const unsubscribeConnection = room.subscribe("connection", (status: TConnectionStatus) => {
+    statusStorage.set(status);
+  });
+  onDestroy(() => {
+    unsubscribeConnection();
+  });
+
+  return statusStorage;
+}

frontend/src/lib/liveblocks/useRooms.ts

@@ -0,0 +1,23 @@
+import { onDestroy } from "svelte";
+import { writable, type Writable } from "svelte/store";
+import type { RoomResponse } from '$lib/types';
+import { PUBLIC_API_BASE } from '$env/static/public';
+
+const INTERVAL = 3000
+
+export function useRooms(): Writable<RoomResponse[]> {
+  const roomsStorage = writable<RoomResponse[]>([]);
+
+  const interval = setInterval(
+    () => {
+      refreshRooms().then((rooms) => roomsStorage.set(rooms))
+    }, INTERVAL);
+
+  onDestroy(() => {
+    clearInterval(interval);
+  });
+  return roomsStorage
+}
+async function refreshRooms() {
+  return fetch(PUBLIC_API_BASE + '/rooms').then((res) => res.json());
+}