ashpie/swaf
1
0
Fork 0
Code Issues 22 Pull Requests Releases 11 Wiki Activity

Pass a whole Session to WebSocketListeners

Browse Source
This commit is contained in:
Alice Gaudon 2020-09-23 08:55:35 +02:00
parent 6305a69583
commit 79d3b51f90
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "wms-core", "name": "wms-core",
"version": "0.22.0-rc.15", "version": "0.22.0-rc.16",
"description": "Node web application framework and toolbelt.", "description": "Node web application framework and toolbelt.",
"repository": "https://gitlab.com/ArisuOngaku/wms-core", "repository": "https://gitlab.com/ArisuOngaku/wms-core",
"author": "Alice Gaudon <alice@gaudon.pro>", "author": "Alice Gaudon <alice@gaudon.pro>",

2
src/WebSocketListener.ts
View File

@ -15,5 +15,5 @@ export default abstract class WebSocketListener<T extends Application> {
public abstract path(): string; public abstract path(): string;
public abstract async handle(socket: WebSocket, request: IncomingMessage, session: Express.SessionData | null): Promise<void>; public abstract async handle(socket: WebSocket, request: IncomingMessage, session: Express.Session | null): Promise<void>;
} }

2
src/auth/magic_link/MagicLinkWebSocketListener.ts
View File

@ -13,7 +13,7 @@ export default class MagicLinkWebSocketListener extends WebSocketListener<any> {
} }
} }
async handle(socket: WebSocket, request: IncomingMessage, session: Express.SessionData | null): Promise<void> { async handle(socket: WebSocket, request: IncomingMessage, session: Express.Session | null): Promise<void> {
// Drop if requested without session // Drop if requested without session
if (!session) { if (!session) {
socket.close(1002, 'Session is required for this request.'); socket.close(1002, 'Session is required for this request.');

2
src/components/WebSocketServerComponent.ts
View File

@ -66,7 +66,7 @@ export default class WebSocketServerComponent extends ApplicationComponent<void>
session.id = sid; session.id = sid;
store.createSession(<Request>request, session); store.createSession(<Request>request, session);
listener.handle(socket, request, session).catch(err => { listener.handle(socket, request, <Express.Session>session).catch(err => {
Logger.error(err, 'Error in websocket listener.'); Logger.error(err, 'Error in websocket listener.');
}); });
}); });