try this on render

sammynave · Jan 5, 2024 · 670b963 · 670b963
1 parent e574902
commit 670b963
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 8 deletions.
diff --git a/src/lib/server/websockets/features/offline/sync.ts b/src/lib/server/websockets/features/offline/sync.ts
@@ -109,6 +109,12 @@ export class Sync {
 
 			this.redisClient.publish(this.stream, data);
 		}
+
+		if (parsed.type === 'connected') {
+			console.log('connected', parsed);
+			this.pull(parsed.clientSiteId);
+			this.push(parsed.clientSiteId);
+		}
 	}
 
 	private merge(changes) {

diff --git a/src/routes/app/offline-first/sync-db-store.ts b/src/routes/app/offline-first/sync-db-store.ts
@@ -110,14 +110,18 @@ export function db({ databasePromise, wsPromise, serverSiteId, name }) {
 	databasePromise.then(async (database) => {
 		const ws = await wsPromise;
 		globalThis.addEventListener('online', async (event) => {
-			const result = await database.lastTrackedChangeFor(serverSiteId, 1);
-			const trackedVersion = result?.[0]?.[0] ?? 0;
-			await pushChangesSince({
-				database,
-				ws,
-				sinceVersion: trackedVersion,
-				serverSiteId
-			});
+			// Request update
+			ws.send(JSON.stringify({ type: 'connected', siteId: database.siteId }));
+
+			// // Send update
+			// const result = await database.lastTrackedChangeFor(serverSiteId, 1);
+			// const trackedVersion = result?.[0]?.[0] ?? 0;
+			// await pushChangesSince({
+			// 	database,
+			// 	ws,
+			// 	sinceVersion: trackedVersion,
+			// 	serverSiteId
+			// });
 		});
 	});