summaryrefslogtreecommitdiff
path: root/apps/web/src/services/storage/migrations/version-manager.ts
blob: 879498ced42f5ffbd78286243e3736d25ff6203c (plain) (blame)
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
import { IndexedDBAdapter } from "@/services/storage/indexeddb-adapter";

type StorageVersionRecord = {
	version: number;
	inProgress?: {
		from: number;
		to: number;
	};
};

const DEFAULT_DB_NAME = "video-editor-meta";
const DEFAULT_STORE_NAME = "storage-version";
const DEFAULT_DB_VERSION = 1;
const STORAGE_VERSION_KEY = "storage-version";

export class StorageVersionManager {
	private adapter: IndexedDBAdapter<StorageVersionRecord>;

	constructor({
		dbName = DEFAULT_DB_NAME,
		storeName = DEFAULT_STORE_NAME,
		version = DEFAULT_DB_VERSION,
	}: {
		dbName?: string;
		storeName?: string;
		version?: number;
	} = {}) {
		this.adapter = new IndexedDBAdapter<StorageVersionRecord>(
			dbName,
			storeName,
			version,
		);
	}

	async getVersion(): Promise<number> {
		const record = await this.adapter.get(STORAGE_VERSION_KEY);
		return record?.version ?? 0;
	}

	async getVersionRecord(): Promise<StorageVersionRecord | null> {
		return this.adapter.get(STORAGE_VERSION_KEY);
	}

	async setVersion({ version }: { version: number }): Promise<void> {
		const record = await this.getVersionRecord();
		const inProgress = record?.inProgress;
		await this.adapter.set(STORAGE_VERSION_KEY, {
			version,
			...(inProgress ? { inProgress } : {}),
		});
	}

	async setInProgress({
		from,
		to,
	}: {
		from: number;
		to: number;
	}): Promise<void> {
		const record = await this.getVersionRecord();
		const version = record?.version ?? 0;
		await this.adapter.set(STORAGE_VERSION_KEY, {
			version,
			inProgress: { from, to },
		});
	}

	async clearInProgress(): Promise<void> {
		const record = await this.getVersionRecord();
		const version = record?.version ?? 0;
		await this.adapter.set(STORAGE_VERSION_KEY, { version });
	}
}