feat: save page updates (#1965)

* feat: save page updates 

* test: write test for page and yjs

* docs: update page readme 

---------

Co-authored-by: kim <kim.phanhoang@epfl.ch>

Author: pyphilia

package.json

@@ -120,7 +120,6 @@
     "url-http": "1.3.0",
     "uuid": "11.1.0",
     "ws": "8.18.1",
-    "y-leveldb": "0.2.0",
     "y-protocols": "1.0.6",
     "yazl": "3.3.1",
     "yjs": "13.6.27"
@@ -175,7 +174,8 @@
     "ts-node": "10.9.2",
     "typescript": "5.8.3",
     "vitest": "3.2.3",
-    "wait-for-expect": "3.0.2"
+    "wait-for-expect": "3.0.2",
+    "y-websocket": "3.0.0"
   },
   "resolutions": {
     "sodium-native": "4.2.0"

src/app.ts

@@ -2,6 +2,7 @@
 // should not be reimported in any other files !
 import 'reflect-metadata';
 
+import fws from '@fastify/websocket';
 import type { FastifyInstance } from 'fastify';
 import fp from 'fastify-plugin';
 
@@ -20,6 +21,15 @@ import tagPlugin from './services/tag/tag.controller';
 import websocketsPlugin from './services/websockets/websocket.controller';
 
 export default async function (instance: FastifyInstance): Promise<void> {
+  const { log } = instance;
+
+  await instance.register(fws, {
+    errorHandler: (error, conn, _req, _reply) => {
+      log.error(`graasp-websockets: an error occured: ${error}\n\tDestroying connection`);
+      conn.terminate();
+    },
+  });
+
   await instance
     .register(fp(swaggerPlugin))
     .register(fp(schemaRegisterPlugin))

src/drizzle/0010_page-update.sql

@@ -0,0 +1,8 @@
+DROP TABLE "page" CASCADE;--> statement-breakpoint
+CREATE TABLE "page_update" (
+	"item_id" uuid NOT NULL,
+	"update" "bytea" NOT NULL,
+	"clock" integer NOT NULL
+);--> statement-breakpoint
+ALTER TABLE "page_update" ADD CONSTRAINT "FK_page_update_item_id" FOREIGN KEY ("item_id") REFERENCES "public"."item"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
+CREATE INDEX "IDX_page_item_id" ON "page_update" USING btree ("item_id" uuid_ops);

src/drizzle/customTypes.ts

@@ -18,3 +18,9 @@ export const customNumeric = customType<{ data: number; driverData: string }>({
     return +value;
   },
 });
+
+export const binaryHash = customType<{ data: Uint8Array; driverData: Buffer }>({
+  dataType() {
+    return 'bytea';
+  },
+});