Class FileSystemStorage

src/lib/FileSystemStorage.ts:11–193

const nextRequestId = (): string => `fss_${++requestIdCounter}_${Date.now()}`;

export class FileSystemStorage implements StorageInterface {
	private bridge: DesktopBridge;
	private _config: Record<string, unknown> = {};

	private _callbacks = {
		create: [] as Array<(key: string, value: unknown) => void>,
		update: [] as Array<(key: string, value: unknown) => void>,
		delete: [] as Array<(key: string, value: unknown) => void>,
	};

	private _transformations: Record<string, { id: string; get?: ((key: string, value: unknown) => unknown) | null; set?: ((key: string, value: unknown) => unknown) | null }> = {};

	private _pendingRequests = new Map<string, { resolve: (data: unknown) => void; reject: (error: Error) => void }>();

	private _upgradeCallbacks: Array<{ oldVersion: string; newVersion: string; callback: (...args: unknown[]) => Promise<void> }> = [];

	constructor(bridge: DesktopBridge) {
		this.bridge = bridge;

		this.bridge.on('monogatari:storage-response', (raw: unknown) => {
			const response = raw as { requestId: string; data?: unknown; error?: string };
			const pending = this._pendingRequests.get(response.requestId);

			if (pending) {
				this._pendingRequests.delete(response.requestId);

				if (response.error) {
					pending.reject(new Error(response.error));
				} else {
					pending.resolve(response.data);
				}
			}
		});
	}

	private sendRequest(channel: string, payload: Record<string, unknown>): Promise<unknown> {
		const requestId = nextRequestId();

		return new Promise((resolve, reject) => {
			this._pendingRequests.set(requestId, { resolve, reject });
			this.bridge.send(channel, { ...payload, requestId });
		});
	}

	private applyGetTransformations(key: string, value: unknown): unknown {
		let result = value;

		for (const transformation of Object.values(this._transformations)) {
			if (transformation.get) {
				result = transformation.get(key, result);
			}
		}

		return result;
	}

	private applySetTransformations(key: string, value: unknown): unknown {
		let result = value;