Merge pull request #29 from geobrowser/space-events

Extend API

Author: nikgraf

apps/events/src/lib/assertExhaustive.ts

@@ -0,0 +1,3 @@
+export const assertExhaustive = (_value: never, message = 'Reached unexpected case in exhaustive switch'): never => {
+  throw new Error(message);
+};

apps/events/src/lib/counter.ts

@@ -1,21 +1,49 @@
 import { Button } from '@/components/ui/button';
+import { assertExhaustive } from '@/lib/assertExhaustive';
 import { createFileRoute } from '@tanstack/react-router';
-import { createIdentity, createSpace } from 'graph-framework';
+import * as Schema from 'effect/Schema';
+import type { EventMessage, RequestListSpaces, RequestSubscribeToSpace } from 'graph-framework';
+import { ResponseMessage, createIdentity, createSpace } from 'graph-framework';
 import { useEffect, useState } from 'react';
 
+const decodeResponseMessage = Schema.decodeUnknownEither(ResponseMessage);
+
 export const Route = createFileRoute('/playground')({
-  component: () => <Playground />,
+  component: () => <ChooseAccount />,
 });
 
-const Playground = () => {
+const App = ({ accountId }: { accountId: string }) => {
   const [websocketConnection, setWebsocketConnection] = useState<WebSocket>();
+  const [spaces, setSpaces] = useState<{ id: string }[]>([]);
 
   useEffect(() => {
-    const websocketConnection = new WebSocket(`ws://localhost:3030/`);
+    // temporary until we have a way to create accounts and authenticate them
+    const websocketConnection = new WebSocket(`ws://localhost:3030/?accountId=${accountId}`);
     setWebsocketConnection(websocketConnection);
 
     const onMessage = (event: MessageEvent) => {
       console.log('message received', event.data);
+      const data = JSON.parse(event.data);
+      const message = decodeResponseMessage(data);
+      if (message._tag === 'Right') {
+        const response = message.right;
+        switch (response.type) {
+          case 'list-spaces': {
+            setSpaces(response.spaces.map((space) => ({ id: space.id })));
+            break;
+          }
+          case 'space': {
+            console.log('space', response);
+            break;
+          }
+          case 'event': {
+            console.log('event', response);
+            break;
+          }
+          default:
+            assertExhaustive(response);
+        }
+      }
     };
     websocketConnection.addEventListener('message', onMessage);
 
@@ -41,19 +69,89 @@ const Playground = () => {
       websocketConnection.removeEventListener('close', onClose);
       websocketConnection.close();
     };
-  }, []);
+  }, [accountId]);
+
+  return (
+    <>
+      <div>
+        <Button
+          onClick={() => {
+            const identity = createIdentity();
+            const spaceEvent = createSpace({ author: identity });
+            const message: EventMessage = { type: 'event', event: spaceEvent };
+            websocketConnection?.send(JSON.stringify(message));
+          }}
+        >
+          Create space
+        </Button>
+
+        <Button
+          onClick={() => {
+            const message: RequestListSpaces = { type: 'list-spaces' };
+            websocketConnection?.send(JSON.stringify(message));
+          }}
+        >
+          List Spaces
+        </Button>
+      </div>
+      <h2>Spaces</h2>
+      <ul>
+        {spaces.map((space) => {
+          return (
+            <li key={space.id}>
+              <h3>{space.id}</h3>
+              <Button
+                onClick={() => {
+                  const message: RequestSubscribeToSpace = { type: 'subscribe-space', id: space.id };
+                  websocketConnection?.send(JSON.stringify(message));
+                }}
+              >
+                Get data and subscribe to Space
+              </Button>
+            </li>
+          );
+        })}
+      </ul>
+    </>
+  );
+};
+
+export const ChooseAccount = () => {
+  const [accountId, setAccountId] = useState<string | null>();
 
   return (
     <div>
+      <h1>Choose account</h1>
+      <Button
+        onClick={() => {
+          setAccountId('abc');
+        }}
+      >
+        `abc`
+      </Button>
+      <Button
+        onClick={() => {
+          setAccountId('cde');
+        }}
+      >
+        `cde`
+      </Button>
       <Button
         onClick={() => {
-          const identity = createIdentity();
-          const spaceEvent = createSpace({ author: identity });
-          websocketConnection?.send(JSON.stringify(spaceEvent));
+          setAccountId('def');
         }}
       >
-        Create space
+        `def`
       </Button>
+      Account: {accountId ? accountId : 'none'}
+      <hr />
+      {accountId && (
+        <App
+          // forcing a remount of the App component when the accountId changes
+          key={accountId}
+          accountId={accountId}
+        />
+      )}
     </div>
   );
 };

apps/events/src/lib/deserialize.ts

@@ -24,6 +24,7 @@
     "effect": "^3.10.12",
     "express": "^5.0.1",
     "graph-framework-space-events": "workspace:*",
+    "graph-framework-messages": "workspace:*",
     "ws": "^8.17.1"
   },
   "devDependencies": {

apps/events/src/lib/serialize.ts

@@ -0,0 +1,31 @@
+-- CreateTable
+CREATE TABLE "SpaceEvent" (
+    "id" TEXT NOT NULL PRIMARY KEY,
+    "event" TEXT NOT NULL,
+    "spaceId" TEXT NOT NULL,
+    CONSTRAINT "SpaceEvent_spaceId_fkey" FOREIGN KEY ("spaceId") REFERENCES "Space" ("id") ON DELETE RESTRICT ON UPDATE CASCADE
+);
+
+-- CreateTable
+CREATE TABLE "Space" (
+    "id" TEXT NOT NULL PRIMARY KEY
+);
+
+-- CreateTable
+CREATE TABLE "Account" (
+    "id" TEXT NOT NULL PRIMARY KEY
+);
+
+-- CreateTable
+CREATE TABLE "_AccountToSpace" (
+    "A" TEXT NOT NULL,
+    "B" TEXT NOT NULL,
+    CONSTRAINT "_AccountToSpace_A_fkey" FOREIGN KEY ("A") REFERENCES "Account" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
+    CONSTRAINT "_AccountToSpace_B_fkey" FOREIGN KEY ("B") REFERENCES "Space" ("id") ON DELETE CASCADE ON UPDATE CASCADE
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "_AccountToSpace_AB_unique" ON "_AccountToSpace"("A", "B");
+
+-- CreateIndex
+CREATE INDEX "_AccountToSpace_B_index" ON "_AccountToSpace"("B");

apps/events/src/routes/playground.tsx

@@ -18,6 +18,12 @@ model SpaceEvent {
 }
 
 model Space {
-  id     String       @id
-  events SpaceEvent[]
+  id      String       @id
+  events  SpaceEvent[]
+  members Account[]
+}
+
+model Account {
+  id     String  @id
+  spaces Space[]
 }

apps/server/package.json

@@ -0,0 +1,13 @@
+import { prisma } from '../prisma.js';
+
+type Params = {
+  accountId: string;
+};
+
+export const createAccount = async ({ accountId }: Params) => {
+  return await prisma.account.create({
+    data: {
+      id: accountId,
+    },
+  });
+};