New document is being created on reconnect

[hamza512b]

We are using hocuspocus as show in the following snippet, however, for some reason a new yjs document are being created when someone connects. We are sending the same document name from frontend too. Anyone having same issue?

function serializeYDoc(doc) {
  return Buffer.from(Y.encodeStateAsUpdate(doc));
}

function deserializeToYDoc(snapshot) {
  const doc = new Y.Doc();
  Y.applyUpdate(doc, new Uint8Array(snapshot));

  return doc;
}

function createInitialDocTemplate() {
  return new Y.Doc();
}

async function saveToDatabase(document, user) {
  try {
    const update = serializeYDoc(document);
    const existingDocument = await seatingSchema(user.dbID).findOne({
      eventID: user.eventID,
    });

    if (existingDocument) {
      existingDocument.snapshot = update;
      await existingDocument.save();
    } else {
      const newDocument = seatingSchema(user.dbID)({
        eventID: user.eventID,
        snapshot: update,
      });
      await newDocument.save();
    }
  } catch (error) {
    logger.warn("Error saving document:", {
      error,
      user,
    });
  }
}

async function loadFromDatabase(user) {
  try {
    await ClientDB.InitClientDBConnection(user.dbID);
    const existingDocument = await seatingSchema(user.dbID).findOne({
      eventID: user.eventID,
    });

    if (existingDocument) {
      return deserializeToYDoc(existingDocument.snapshot);
    }

    return createInitialDocTemplate();
  } catch (error) {
    logger.warn("Error loading document:", {
      error,
      user,
    });
    return null;
  }
}

const HocuspocusServer = Server.configure({
  async onAuthenticate({ token, documentName }) {
    let accessToken = token;
    if (!accessToken) throw new Error("Auth Error");

    const decoded = verify(accessToken);
    const user = decoded.user;

    if (documentName?.toString() !== user.eventID) {
      throw new Error("Auth Error");
    }

    return {
      user,
    };
  },
  async onStoreDocument(data) {
    if (!data.context.user) throw new Error("Auth Error");
    if (data.documentName !== data.context.user.eventID)
      throw new Error("Auth Error");
    saveToDatabase(data.document, data.context.user);
  },

  async onLoadDocument(data) {
    if (!data.context.user) throw new Error("Auth Error");
    if (data.documentName !== data.context.user.eventID)
      throw new Error("Auth Error");

    const document = await loadFromDatabase(data.context.user);
    return document;
  },

  extensions: [new ExtensionLogger()],
});