1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
import { IndexedDBAdapter } from "@/services/storage/indexeddb-adapter";
import type { ProjectVersion } from "./types";
/**
* Persistence backend for project versions. The IndexedDB implementation is
* the production store (its own database, created lazily — the v31→v32
* migration stamps project records); the in-memory implementation backs
* unit tests.
*/
export interface VersionStore {
put({ version }: { version: ProjectVersion }): Promise<void>;
getAllForProject({
projectId,
}: {
projectId: string;
}): Promise<ProjectVersion[]>;
delete({ id }: { id: string }): Promise<void>;
deleteForProject({ projectId }: { projectId: string }): Promise<void>;
}
export class IndexedDBVersionStore implements VersionStore {
private adapter = new IndexedDBAdapter<ProjectVersion>({
dbName: "video-editor-project-versions",
storeName: "project-versions",
version: 1,
});
async put({ version }: { version: ProjectVersion }): Promise<void> {
await this.adapter.set({ key: version.id, value: version });
}
async getAllForProject({
projectId,
}: {
projectId: string;
}): Promise<ProjectVersion[]> {
const all = await this.adapter.getAll();
return all.filter(
(version) =>
typeof version === "object" &&
version !== null &&
version.projectId === projectId,
);
}
async delete({ id }: { id: string }): Promise<void> {
await this.adapter.remove(id);
}
async deleteForProject({ projectId }: { projectId: string }): Promise<void> {
const versions = await this.getAllForProject({ projectId });
await Promise.all(
versions.map((version) => this.adapter.remove(version.id)),
);
}
}
export class InMemoryVersionStore implements VersionStore {
private versions = new Map<string, ProjectVersion>();
async put({ version }: { version: ProjectVersion }): Promise<void> {
this.versions.set(version.id, version);
}
async getAllForProject({
projectId,
}: {
projectId: string;
}): Promise<ProjectVersion[]> {
return [...this.versions.values()].filter(
(version) => version.projectId === projectId,
);
}
async delete({ id }: { id: string }): Promise<void> {
this.versions.delete(id);
}
async deleteForProject({ projectId }: { projectId: string }): Promise<void> {
for (const version of this.versions.values()) {
if (version.projectId === projectId) {
this.versions.delete(version.id);
}
}
}
}
|
