| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475 |
- // 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)
- })
- }
- private docsArray() {
- return Array.from(this.openDocs.values())
- }
- hasUnsavedChanges() {
- return this.docsArray().some(doc => doc.hasBufferedOps())
- }
- flushAll() {
- return this.docsArray().map(doc => doc.flush())
- }
- }
|