| import { seedScene, validateScene } from "../shared/scene.mjs"; |
| import { readFile, writeFile, rename } from "node:fs/promises"; |
| import { validateCapturePlan } from "../shared/capture-boundary.mjs"; |
| import { withKnownAssemblies } from "../shared/transforms.mjs"; |
| import { reconcileBehaviors } from "../shared/behaviors.mjs"; |
| async function createSceneStore(appRuntime) { |
| let state = { revision: 0, scene: seedScene(), source: "sample", updatedAt: ( new Date()).toISOString(), savedAt: null, saveMode: null }; |
| try { |
| const saved = JSON.parse(await readFile(appRuntime.sceneLocation.file, "utf8")); |
| validateScene(saved.scene); |
| if (saved.capturePlan) validateCapturePlan(saved.capturePlan); |
| state = { ...saved, savedAt: saved.savedAt || saved.updatedAt, saveMode: saved.saveMode || "auto" }; |
| } catch (error) { |
| if (appRuntime.sceneLocation.id) throw error; |
| if (error.code !== "ENOENT") console.warn("Saved scene invalid; using sample:", error.message); |
| } |
| const history = []; |
| const clients = new Set(); |
| const assembled = withKnownAssemblies(state.scene); |
| if (JSON.stringify(assembled) !== JSON.stringify(state.scene)) { |
| state = { ...state, scene: assembled, revision: state.revision + 1 }; |
| await persistScene(state); |
| } |
| let mutationBusy = false; |
| const broadcast = () => { |
| for (const res of clients) res.write(`data: ${JSON.stringify(state)} |
| |
| `); |
| }; |
| async function persistScene(next) { |
| await writeFile(appRuntime.sceneLocation.temporary, JSON.stringify(next, null, 2)); |
| await rename(appRuntime.sceneLocation.temporary, appRuntime.sceneLocation.file); |
| } |
| async function commit(scene, source, recordHistory = true, metadata = state, beforePersist, productionReady = false) { |
| if (mutationBusy) throw new Error("Scene is saving. Try again shortly."); |
| mutationBusy = true; |
| try { |
| scene = reconcileBehaviors(scene); |
| if ("productionReady" in scene) scene = { ...scene, productionReady }; |
| validateScene(scene); |
| const now = ( new Date()).toISOString(), next = { ...metadata, revision: state.revision + 1, scene, source, updatedAt: now, savedAt: now, saveMode: "auto" }; |
| if (beforePersist) await beforePersist(); |
| await persistScene(next); |
| if (recordHistory) { |
| history.push(structuredClone(state)); |
| if (history.length > 30) history.shift(); |
| } |
| state = next; |
| broadcast(); |
| return state; |
| } finally { |
| mutationBusy = false; |
| } |
| } |
| async function saveCurrentScene(revision) { |
| revisionCheck(revision); |
| if (mutationBusy) throw new Error("Scene is saving. Try again shortly."); |
| mutationBusy = true; |
| try { |
| const next = { ...state, savedAt: ( new Date()).toISOString(), saveMode: "manual" }; |
| await persistScene(next); |
| state = next; |
| broadcast(); |
| return state; |
| } finally { |
| mutationBusy = false; |
| } |
| } |
| function revisionCheck(revision) { |
| if (revision !== state.revision) throw new Error("Scene changed. Retry using the current version."); |
| } |
| function selectionCheck(ids) { |
| if (!Array.isArray(ids) || ids.length > 180 || ids.some((id) => typeof id !== "string" || !state.scene.objects.some((o) => o.id === id))) throw new Error("Selection contains an invalid object"); |
| } |
| return { get state() { |
| return state; |
| }, get mutationBusy() { |
| return mutationBusy; |
| }, history, clients, broadcast, commit, saveCurrentScene, revisionCheck, selectionCheck }; |
| } |
| export { |
| createSceneStore |
| }; |
|
|
