overleaf/services/web/frontend/js/features/ide-react/editor/open-documents.ts

// Migrated from static methods of Document in Document.js

import { Document } from '@/features/ide-react/editor/document'
import { debugConsole } from '@/utils/debugging'
import { Socket } from '@/features/ide-react/connection/types/socket'
import { IdeEventEmitter } from '@/features/ide-react/create-ide-event-emitter'
import { EventLog } from '@/features/ide-react/editor/event-log'
import EditorWatchdogManager from '@/features/ide-react/connection/editor-watchdog-manager'

export class OpenDocuments {
  private openDocs = new Map<string, Document>()

  // eslint-disable-next-line no-useless-constructor
  constructor(
    private readonly socket: Socket,
    private readonly globalEditorWatchdogManager: EditorWatchdogManager,
    private readonly events: IdeEventEmitter,
    private readonly eventLog: EventLog
  ) {}

  getDocument(docId: string) {
    // Try to clean up existing docs before reopening them. If the doc has no
    // buffered ops then it will be deleted by _cleanup() and a new instance
    // of the document created below. This prevents us trying to follow the
    // joinDoc:existing code path on an existing doc that doesn't have any
    // local changes and getting an error if its version is too old.
    if (this.openDocs.has(docId)) {
      debugConsole.log(
        `[getDocument] Cleaning up existing document instance for ${docId}`
      )
      this.openDocs.get(docId)?.cleanUp()
    }
    if (!this.openDocs.has(docId)) {
      debugConsole.log(
        `[getDocument] Creating new document instance for ${docId}`
      )
      this.createDoc(docId)
    } else {
      debugConsole.log(
        `[getDocument] Returning existing document instance for ${docId}`
      )
    }
    return this.openDocs.get(docId)
  }

  private createDoc(docId: string) {
    const doc = new Document(
      docId,
      this.socket,
      this.globalEditorWatchdogManager,
      this.events,
      this.eventLog
    )
    this.openDocs.set(docId, doc)
    doc.on('detach', () => {
      debugConsole.log(
        `[detach] Removing document with ID (${docId}) from openDocs`
      )
      doc.off('detach')
      this.openDocs.delete(docId)
    })
  }

  hasUnsavedChanges() {
    for (const doc of this.openDocs.values()) {
      if (doc.hasBufferedOps()) {
        return true
      }
    }
    return false
  }

  flushAll() {
    for (const doc of this.openDocs.values()) {
      doc.flush()
    }
  }

  unsavedDocIds() {
    const ids = []
    for (const [docId, doc] of this.openDocs) {
      if (!doc.pollSavedStatus()) {
        ids.push(docId)
      }
    }
    return ids
  }
}