Class SessionContent

packages/core/src/collections/session-content.ts:28–141

import { SQLCollection } from "../database/sql-collection.js";

export class SessionContent implements ICollection {
  name = "sessioncontent";
  readonly collection: SQLCollection<"sessioncontent", SessionContentItem>;
  constructor(private readonly db: Database) {
    this.collection = new SQLCollection(
      db.sql,
      db.transaction,
      "sessioncontent",
      db.eventManager,
      db.sanitizer
    );
  }

  async init() {
    await this.collection.init();
  }

  async add<TLocked extends boolean>(
    sessionId: string,
    content: Partial<NoteContent<TLocked>> & { title?: string; noteId: string },
    locked?: TLocked
  ) {
    if (!sessionId || !content) return;
    // const data =
    //   locked || isCipher(content.data)
    //     ? content.data
    //     :  await this.db.compressor().compress(content.data);
    const sessionContentItemId = makeSessionContentId(sessionId);
    const sessionContentExists = await this.collection.exists(
      sessionContentItemId
    );
    const sessionItem: Partial<SessionContentItem> = {
      type: "sessioncontent",
      id: sessionContentItemId,
      compressed: false,
      localOnly: true,
      locked: locked || false,
      dateCreated: Date.now(),
      dateModified: Date.now()
    };

    if (content.data && content.type) {
      sessionItem.data = content.data;
      sessionItem.contentType = content.type;

      if (typeof content.title !== "string" && !sessionContentExists) {
        const note = await this.db.notes.note(content.noteId);
        sessionItem.title = note?.title;
      }
    }

    if (content.title) {
      sessionItem.title = content.title;

      if (!content.data && !content.type && !sessionContentExists) {
        const note = await this.db.notes.note(content.noteId);
        if (note?.contentId) {
          const noteContent = await this.db.content.get(note?.contentId);