feat: adjust hulylake client for storage adapter

.nvmrc

@@ -0,0 +1 @@
+v22

common/changes/@hcengineering/client-resources/feat-huylake-storage-adapter_2025-10-09-16-19.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@hcengineering/client-resources",
+      "comment": "fix formatting",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@hcengineering/client-resources"
+}

common/changes/@hcengineering/client/feat-huylake-storage-adapter_2025-10-09-16-19.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@hcengineering/client",
+      "comment": "fix formatting",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@hcengineering/client"
+}

common/changes/@hcengineering/hulylake-client/feat-huylake-storage-adapter_2025-10-09-16-19.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@hcengineering/hulylake-client",
+      "comment": "refactoring hulylake client to extract multi-workspace client",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@hcengineering/hulylake-client"
+}

packages/client-resources/src/__tests__/connection.test.ts

@@ -261,7 +261,7 @@ describe('MockWebSocket', () => {
 
     ws.send(pingConst)
 
-    await new Promise(resolve => setTimeout(resolve, 50))
+    await new Promise((resolve) => setTimeout(resolve, 50))
 
     expect(receivedMessage).toBe(pongConst)
 
@@ -290,7 +290,7 @@ describe('connect function', () => {
     mockWebSockets = []
 
     // Give time for all timers to clear
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
   })
 
   it('should establish connection', async () => {
@@ -311,13 +311,13 @@ describe('connect function', () => {
     expect(client).toBeDefined()
 
     // Wait for connection to establish
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     // Close connection immediately to prevent timers from continuing
     await client.close()
 
     // Wait for close to complete
-    await new Promise(resolve => setTimeout(resolve, 50))
+    await new Promise((resolve) => setTimeout(resolve, 50))
   })
 
   it('should handle transactions', async () => {
@@ -339,7 +339,7 @@ describe('connect function', () => {
     connections.push(client)
 
     // Wait for connection to establish
-    await new Promise(resolve => setTimeout(resolve, 150))
+    await new Promise((resolve) => setTimeout(resolve, 150))
 
     // Simulate a transaction from server
     const testTx: TxCreateDoc<Doc> = {
@@ -363,12 +363,12 @@ describe('connect function', () => {
 
     mockWs.simulateTransaction(testTx)
 
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     expect(txReceived).toBeDefined()
 
     // Close immediately after test
     await client.close()
-    await new Promise(resolve => setTimeout(resolve, 50))
+    await new Promise((resolve) => setTimeout(resolve, 50))
   })
 })

packages/client-resources/src/__tests__/integration.test.ts

@@ -186,7 +186,7 @@ export class MockClientConnection implements ClientConnection {
     }
     await this.transactions.tx(tx)
 
-    this.handlers.forEach(h => {
+    this.handlers.forEach((h) => {
       h(tx)
     })
 
@@ -246,7 +246,7 @@ export class MockClientConnection implements ClientConnection {
   }
 
   simulateTransaction (tx: Tx): void {
-    this.handlers.forEach(h => {
+    this.handlers.forEach((h) => {
       h(tx)
     })
   }
@@ -285,10 +285,7 @@ export async function createTestClient (initialTxes: Tx[] = []): Promise<{
 /**
  * Helper to create a test transaction
  */
-export function createTestTx (
-  objectClass: Ref<Class<Doc>> = core.class.Space,
-  attributes: any = {}
-): TxCreateDoc<Doc> {
+export function createTestTx (objectClass: Ref<Class<Doc>> = core.class.Space, attributes: any = {}): TxCreateDoc<Doc> {
   return {
     _id: generateId(),
     _class: core.class.TxCreateDoc,
@@ -339,7 +336,7 @@ describe('Client-Resources Integration Tests', () => {
 
     // The mock connection immediately notifies handlers when we call tx
     // So notifySpy should have been called
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     expect(notifySpy).toHaveBeenCalled()
 
@@ -525,17 +522,13 @@ describe('Client-Resources Integration Tests', () => {
     const tx2 = createTestTx(core.class.Space, { name: 'Space2' })
     const tx3 = createTestTx(core.class.Space, { name: 'Space3' })
 
-    await Promise.all([
-      client.tx(tx1),
-      client.tx(tx2),
-      client.tx(tx3)
-    ])
+    await Promise.all([client.tx(tx1), client.tx(tx2), client.tx(tx3)])
 
     connection.simulateTransaction(tx1)
     connection.simulateTransaction(tx2)
     connection.simulateTransaction(tx3)
 
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     expect(notifySpy.mock.calls.length).toBeGreaterThanOrEqual(3)
 

packages/client/src/__tests__/client.test.ts

@@ -185,7 +185,7 @@ class TestConnection implements ClientConnection {
     await this.transactions.tx(tx)
 
     // Notify handlers
-    this.handlers.forEach(h => {
+    this.handlers.forEach((h) => {
       h(tx)
     })
 
@@ -247,7 +247,7 @@ class TestConnection implements ClientConnection {
 
   // Simulate receiving transactions from server
   simulateTransaction (tx: Tx): void {
-    this.handlers.forEach(h => {
+    this.handlers.forEach((h) => {
       h(tx)
     })
   }
@@ -336,7 +336,7 @@ describe('Client Core Implementation', () => {
     testConnection.simulateTransaction(tx)
 
     // Wait for async operations
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     expect(notifySpy).toHaveBeenCalled()
   })
@@ -387,7 +387,11 @@ describe('Client Core Implementation', () => {
   it('should handle reconnection events', async () => {
     let eventReceived: ClientConnectEvent | undefined
 
-    const onConnectHandler = async (event: ClientConnectEvent, lastTx: string | undefined, data: any): Promise<void> => {
+    const onConnectHandler = async (
+      event: ClientConnectEvent,
+      lastTx: string | undefined,
+      data: any
+    ): Promise<void> => {
       eventReceived = event
     }
 
@@ -418,7 +422,7 @@ describe('Client Core Implementation', () => {
 
     testConnection.simulateTransaction(workspaceTx)
 
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     expect(notifySpy).toHaveBeenCalled()
   })
@@ -466,7 +470,7 @@ describe('Client Core Implementation', () => {
     // Simulate receiving the same transaction from remote
     testConnection.simulateTransaction(tx)
 
-    await new Promise(resolve => setTimeout(resolve, 100))
+    await new Promise((resolve) => setTimeout(resolve, 100))
 
     // Should still notify but skip model update
     expect(notifySpy).toHaveBeenCalled()