import EventEmitter from "../../EventEmitter.js"; import RoomSummary from "./summary.js"; import RoomPersister from "./persister.js"; import Timeline from "./timeline.js"; export default class Room extends EventEmitter { constructor(roomId, storage, emitCollectionChange) { super(); this._roomId = roomId; this._storage = storage; this._summary = new RoomSummary(roomId); this._persister = new RoomPersister(roomId); this._emitCollectionChange = emitCollectionChange; this._timeline = null; } persistSync(roomResponse, membership, txn) { const summaryChanged = this._summary.applySync(roomResponse, membership, txn); const newTimelineEntries = this._persister.persistSync(roomResponse, txn); return {summaryChanged, newTimelineEntries}; } emitSync({summaryChanged, newTimelineEntries}) { if (summaryChanged) { this.emit("change"); (this._emitCollectionChange)(this); } if (this._timeline) { this._timeline.appendLiveEntries(newTimelineEntries); } } load(summary, txn) { this._summary.load(summary); return this._persister.load(txn); } get name() { return this._summary.name; } get id() { return this._roomId; } async openTimeline() { if (this._timeline) { throw new Error("not dealing with load race here for now"); } this._timeline = new Timeline({ roomId: this.id, storage: this._storage, closeCallback: () => this._timeline = null, }); await this._timeline.load(); return this._timeline; } }