Feat/2806 log sync catchup (#19)

* initial functions, still needs batching and tests

* pagination

* test coverage

* migrations

* fixed validation of user id

* remove deserializing testing code

* reorganize log-sync protocol to its own provider

Author: adrastaea

app/src/client/cli/prompts/community.prompt.ts

@@ -7,7 +7,7 @@ import {
   type GetCommunity,
   type GetCommunityResponse,
   type GeneratePublicKeysMessage,
-} from '../../../nest/communities/websocket/types/index.js'
+} from '../../../nest/websocket/handlers/types/index.js'
 import { createLogger } from '../../../nest/app/logger/logger.js'
 import { isBase64, isHexadecimal } from 'class-validator'
 import { DateTime } from 'luxon'

app/src/client/client-auth-conn.ts

@@ -17,8 +17,8 @@ import { Injectable } from '@nestjs/common'
 import { randomUUID } from 'crypto'
 import { createLogger } from '../nest/app/logger/logger.js'
 import { WebsocketClient } from './ws.client.js'
-import { AuthSyncMessage } from '../nest/communities/websocket/types/auth-sync.types.js'
-import { CommunityOperationStatus } from '../nest/communities/websocket/types/common.types.js'
+import { AuthSyncMessage } from '../nest/websocket/handlers/types/auth-sync.types.js'
+import { CommunityOperationStatus } from '../nest/websocket/handlers/types/common.types.js'
 import { WebsocketEvents } from '../nest/websocket/ws.types.js'
 import { ClientEvents } from './ws.client.events.js'
 import { QuietLogger } from '../nest/app/logger/types.js'

app/src/migrations/.snapshot-qss.json

@@ -66,6 +66,16 @@
           "length": -1,
           "mappedType": "string"
         },
+        "hashed_db_id": {
+          "name": "hashed_db_id",
+          "type": "varchar",
+          "unsigned": false,
+          "autoincrement": false,
+          "primary": false,
+          "nullable": true,
+          "length": -1,
+          "mappedType": "string"
+        },
         "entry": {
           "name": "entry",
           "type": "bytea",

app/src/migrations/Migration20251223192036.ts

@@ -0,0 +1,13 @@
+import { Migration } from '@mikro-orm/migrations'
+
+export class Migration20251223192036 extends Migration {
+  override async up(): Promise<void> {
+    this.addSql(
+      `alter table "log_entry_sync" add column "hashed_db_id" varchar null;`,
+    )
+  }
+
+  override async down(): Promise<void> {
+    this.addSql(`alter table "log_entry_sync" drop column "hashed_db_id";`)
+  }
+}

app/src/nest/communities/auth/auth.connection.ts

@@ -19,7 +19,7 @@ import * as uint8arrays from 'uint8arrays'
 import {
   type AuthSyncMessage,
   CommunityOperationStatus,
-} from '../websocket/types/index.js'
+} from '../../websocket/handlers/types/index.js'
 import type { QuietLogger } from '../../app/logger/types.js'
 import { type AuthConnectionConfig, AuthStatus } from './types.js'
 import EventEmitter from 'events'
@@ -101,6 +101,10 @@ export class AuthConnection extends EventEmitter {
     return this._status
   }
 
+  public get socketId(): string {
+    return this.config.socket.id
+  }
+
   /**
    * Start the auth sync connection and handle connection events
    */