3c6006d04a
* fix: add lock unlock archive restore realtime sync * fix: show only after editor loads * fix: added strong types * fix: live events fixed * fix: remove unused vars and logs * fix: converted objects to enum * fix: error handling and removing the events in read only mode * fix: added check to only update if the image aspect ratio is not present already * fix: imports * fix: props order * revert: no need of these changes anymore * fix: updated type names * fix: order of things * fix: fixed types and renamed variables * fix: better typing for the real time updates * fix: trying multiplexing our socket connection * fix: multiplexing socket connection in read only editor as well * fix: remove single socket logic * fix: fixing the cleanup deps for the provider and localprovider * fix: add a better data structure for managing events * chore: refactored realtime events into hooks * feat: fetch page meta while focusing tabs * fix: cycling through items on slash command item in down arrow * fix: better naming convention for realtime events * fix: simplified localprovider initialization and cleaning * fix: types from ui * fix: abstracted away from exposing the provider directly * fix: coderabbit suggestions * regression: pass user in dependency array * fix: removed page action api calls by the other users the document is synced with * chore: removed unused imports
73 lines
2.3 KiB
TypeScript
73 lines
2.3 KiB
TypeScript
import { Server } from "@hocuspocus/server";
|
|
import { v4 as uuidv4 } from "uuid";
|
|
// lib
|
|
import { handleAuthentication } from "@/core/lib/authentication.js";
|
|
// extensions
|
|
import { getExtensions } from "@/core/extensions/index.js";
|
|
import {
|
|
DocumentCollaborativeEvents,
|
|
TDocumentEventsServer,
|
|
} from "@plane/editor/lib";
|
|
// editor types
|
|
import { TUserDetails } from "@plane/editor";
|
|
// types
|
|
import { type HocusPocusServerContext } from "@/core/types/common.js";
|
|
|
|
export const getHocusPocusServer = async () => {
|
|
const extensions = await getExtensions();
|
|
const serverName = process.env.HOSTNAME || uuidv4();
|
|
return Server.configure({
|
|
name: serverName,
|
|
onAuthenticate: async ({
|
|
requestHeaders,
|
|
context,
|
|
// user id used as token for authentication
|
|
token,
|
|
}) => {
|
|
let cookie: string | undefined = undefined;
|
|
let userId: string | undefined = undefined;
|
|
|
|
// Extract cookie (fallback to request headers) and userId from token (for scenarios where
|
|
// the cookies are not passed in the request headers)
|
|
try {
|
|
const parsedToken = JSON.parse(token) as TUserDetails;
|
|
userId = parsedToken.id;
|
|
cookie = parsedToken.cookie;
|
|
} catch (error) {
|
|
// If token parsing fails, fallback to request headers
|
|
console.error("Token parsing failed, using request headers:", error);
|
|
} finally {
|
|
// If cookie is still not found, fallback to request headers
|
|
if (!cookie) {
|
|
cookie = requestHeaders.cookie?.toString();
|
|
}
|
|
}
|
|
|
|
if (!cookie || !userId) {
|
|
throw new Error("Credentials not provided");
|
|
}
|
|
|
|
// set cookie in context, so it can be used throughout the ws connection
|
|
(context as HocusPocusServerContext).cookie = cookie;
|
|
|
|
try {
|
|
await handleAuthentication({
|
|
cookie,
|
|
userId,
|
|
});
|
|
} catch (error) {
|
|
throw Error("Authentication unsuccessful!");
|
|
}
|
|
},
|
|
async onStateless({ payload, document }) {
|
|
// broadcast the client event (derived from the server event) to all the clients so that they can update their state
|
|
const response =
|
|
DocumentCollaborativeEvents[payload as TDocumentEventsServer].client;
|
|
if (response) {
|
|
document.broadcastStateless(response);
|
|
}
|
|
},
|
|
extensions,
|
|
debounce: 10000,
|
|
});
|
|
};
|