QFIX: User status (#7601)

Signed-off-by: Andrey Sobolev <haiodo@gmail.com>

server/core/src/types.ts

@@ -553,6 +553,13 @@ export interface Session {
     query: DocumentQuery<T>,
     options?: FindOptions<T>
   ) => Promise<void>
+  findAllRaw: <T extends Doc>(
+    ctx: MeasureContext,
+    pipeline: Pipeline,
+    _class: Ref<Class<T>>,
+    query: DocumentQuery<T>,
+    options?: FindOptions<T>
+  ) => Promise<FindResult<T>>
   searchFulltext: (ctx: ClientSessionCtx, query: SearchQuery, options: SearchOptions) => Promise<void>
   tx: (ctx: ClientSessionCtx, tx: Tx) => Promise<void>
   loadChunk: (ctx: ClientSessionCtx, domain: Domain, idx?: number) => Promise<void>

server/server/src/sessionManager.ts

@@ -716,21 +716,38 @@ class TSessionManager implements SessionManager {
       const user = pipeline.context.modelDb.getAccountByEmail(session.getUser())
       if (user === undefined) return
 
-      const status = (await pipeline.findAll(ctx, core.class.UserStatus, { user: user._id }, { limit: 1 }))[0]
+      const clientCtx: ClientSessionCtx = {
+        requestId: undefined,
+        pipeline,
+        sendResponse: async (msg) => {
+          // No response
+        },
+        ctx,
+        sendError: async (msg, error: Status) => {
+          // Assume no error send
+        },
+        sendPong: () => {}
+      }
+      const status = (
+        await session.findAllRaw(ctx, pipeline, core.class.UserStatus, { user: user._id }, { limit: 1 })
+      )[0]
       const txFactory = new TxFactory(user._id, true)
       if (status === undefined) {
         const tx = txFactory.createTxCreateDoc(core.class.UserStatus, core.space.Space, {
           online,
           user: user._id
         })
-        await pipeline.tx(ctx, [tx])
+        await session.tx(clientCtx, tx)
       } else if (status.online !== online) {
         const tx = txFactory.createTxUpdateDoc(status._class, status.space, status._id, {
           online
         })
-        await pipeline.tx(ctx, [tx])
+        await session.tx(clientCtx, tx)
+      }
+    } catch (err: any) {
+      ctx.error('failed to set status', { err })
+      Analytics.handleError(err)
     }
-    } catch {}
   }
 
   async close (ctx: MeasureContext, ws: ConnectionSocket, wsid: string): Promise<void> {