diff --git a/server/collaboration/ConnectionLimitExtension.ts b/server/collaboration/ConnectionLimitExtension.ts index 3bb4e4017..3077009d9 100644 --- a/server/collaboration/ConnectionLimitExtension.ts +++ b/server/collaboration/ConnectionLimitExtension.ts @@ -1,6 +1,6 @@ import { Extension, - onConnectPayload, + connectedPayload, onDisconnectPayload, } from "@hocuspocus/server"; import env from "@server/env"; @@ -41,10 +41,10 @@ export class ConnectionLimitExtension implements Extension { } /** - * onConnect hook - * @param data The connect payload + * connected hook + * @param data The connected payload */ - onConnect({ documentName, socketId }: withContext) { + connected({ documentName, socketId }: withContext) { const connections = this.connectionsByDocument.get(documentName) || new Set(); if (connections?.size >= env.COLLABORATION_MAX_CLIENTS_PER_DOCUMENT) { diff --git a/server/collaboration/LoggerExtension.ts b/server/collaboration/LoggerExtension.ts index 473f2a464..d6540267c 100644 --- a/server/collaboration/LoggerExtension.ts +++ b/server/collaboration/LoggerExtension.ts @@ -1,8 +1,9 @@ import { - onConnectPayload, onDisconnectPayload, onLoadDocumentPayload, Extension, + connectedPayload, + onConnectPayload, } from "@hocuspocus/server"; import Logger from "@server/logging/Logger"; import { withContext } from "./types"; @@ -18,6 +19,13 @@ export default class LoggerExtension implements Extension { Logger.info("multiplayer", `New connection to "${data.documentName}"`); } + async connected(data: withContext) { + Logger.info( + "multiplayer", + `Authenticated connection to "${data.documentName}"` + ); + } + async onDisconnect(data: withContext) { Logger.info("multiplayer", `Closed connection to "${data.documentName}"`, { userId: data.context.user?.id, diff --git a/server/collaboration/MetricsExtension.ts b/server/collaboration/MetricsExtension.ts index b5ee6c26c..1b73749f8 100644 --- a/server/collaboration/MetricsExtension.ts +++ b/server/collaboration/MetricsExtension.ts @@ -1,9 +1,9 @@ import { onChangePayload, - onConnectPayload, onDisconnectPayload, onLoadDocumentPayload, Extension, + connectedPayload, } from "@hocuspocus/server"; import Metrics from "@server/logging/Metrics"; import { withContext } from "./types"; @@ -28,7 +28,7 @@ export default class MetricsExtension implements Extension { }); } - async onConnect({ documentName, instance }: withContext) { + async connected({ documentName, instance }: withContext) { Metrics.increment("collaboration.connect", { documentName, });