wieerwill/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2025-05-01 04:35:46 +00:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

Merge branch 'staging' into develop
Some checks are pending
CI / build (push) Waiting to run
Details
CI / svelte-check (push) Blocked by required conditions
Details
CI / formatting (push) Blocked by required conditions
Details
CI / test (push) Blocked by required conditions
Details
CI / uitest (push) Waiting to run
Details
CI / uitest-pg (push) Waiting to run
Details
CI / uitest-qms (push) Waiting to run
Details
CI / uitest-workspaces (push) Waiting to run
Details
CI / docker-build (push) Blocked by required conditions
Details
CI / dist-build (push) Blocked by required conditions
Details

Browse Source 
Signed-off-by: Andrey Sobolev <haiodo@gmail.com>
This commit is contained in:
Andrey Sobolev 2025-02-14 00:31:42 +07:00
commit 07e9c88287
No known key found for this signature in database
GPG Key ID: BD80F68D68D8F7F2
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/server/src/client.ts
View File

@ -224,7 +224,9 @@ export class ClientSession implements Session {
this.useCompression this.useCompression
) )
} else { } else {
void handleSend(ctx, socket, { result: tx }, 1024 * 1024, this.binaryMode, this.useCompression) void handleSend(ctx, socket, { result: tx }, 1024 * 1024, this.binaryMode, this.useCompression).catch((err) => {
ctx.error('failed to broadcast', err)
})
} }
} }

12
server/server/src/sessionManager.ts
View File

@ -227,7 +227,9 @@ class TSessionManager implements SessionManager {
this.ctx.warn('session hang, closing...', { wsId, user: s[1].session.getUser() }) this.ctx.warn('session hang, closing...', { wsId, user: s[1].session.getUser() })
// Force close workspace if only one client and it hang. // Force close workspace if only one client and it hang.
void this.close(this.ctx, s[1].socket, wsId) void this.close(this.ctx, s[1].socket, wsId).catch((err) => {
this.ctx.error('failed to close', err)
})
continue continue
} }
if ( if (
@ -617,7 +619,9 @@ class TSessionManager implements SessionManager {
function send (): void { function send (): void {
for (const session of sessions) { for (const session of sessions) {
try { try {
void sendResponse(ctx, session.session, session.socket, { result: tx }) void sendResponse(ctx, session.session, session.socket, { result: tx }).catch((err) => {
ctx.error('failed to send', err)
})
} catch (err: any) { } catch (err: any) {
Analytics.handleError(err) Analytics.handleError(err)
ctx.error('error during send', { error: err }) ctx.error('error during send', { error: err })
@ -1242,7 +1246,9 @@ export function startSessionManager (
shutdown: opt.serverFactory( shutdown: opt.serverFactory(
sessions, sessions,
(rctx, service, ws, msg, workspace) => { (rctx, service, ws, msg, workspace) => {
void sessions.handleRequest(rctx, service, ws, msg, workspace) void sessions.handleRequest(rctx, service, ws, msg, workspace).catch((err) => {
ctx.error('failed to handle request', err)
})
}, },
ctx, ctx,
opt.pipelineFactory, opt.pipelineFactory,