Store last seen id & add reset method

This commit is contained in:
Andras Schmelczer 2024-12-15 11:52:56 +00:00
parent 0fce63d760
commit 48d407cf1e
No known key found for this signature in database
GPG key ID: FC8F2C3D3D1A718C

View file

@ -9,11 +9,14 @@ import {
interface StoredDatabase { interface StoredDatabase {
documents: Map<RelativePath, DocumentMetadata>; documents: Map<RelativePath, DocumentMetadata>;
settings: SyncSettings; settings: SyncSettings;
lastSeenUpdateId: VaultUpdateId | undefined;
} }
export class Database { export class Database {
private _documents: Map<RelativePath, DocumentMetadata> = new Map(); private _documents: Map<RelativePath, DocumentMetadata> = new Map();
private _settings: SyncSettings; private _settings: SyncSettings;
private _lastSeenUpdateId: VaultUpdateId | undefined;
private onSettingsChangeHandlers: Array<(settings: SyncSettings) => void> = private onSettingsChangeHandlers: Array<(settings: SyncSettings) => void> =
[]; [];
@ -34,7 +37,7 @@ export class Database {
} }
Logger.getInstance().debug( Logger.getInstance().debug(
`Loaded documents ${JSON.stringify( `Loaded documents: ${JSON.stringify(
Object.fromEntries(this._documents.entries()), Object.fromEntries(this._documents.entries()),
null, null,
2 2
@ -48,7 +51,13 @@ export class Database {
); );
Logger.getInstance().debug( Logger.getInstance().debug(
`Loaded settings ${JSON.stringify(this._settings, null, 2)}` `Loaded settings: ${JSON.stringify(this._settings, null, 2)}`
);
this._lastSeenUpdateId = initialState.lastSeenUpdateId;
Logger.getInstance().debug(
`Loaded last seen update id: ${this._lastSeenUpdateId}`
); );
} }
@ -85,6 +94,23 @@ export class Database {
await this.setSettings(this._settings); await this.setSettings(this._settings);
} }
public getLastSeenUpdateId(): VaultUpdateId | undefined {
return this._lastSeenUpdateId;
}
public async setLastSeenUpdateId(
value: VaultUpdateId | undefined
): Promise<void> {
this._lastSeenUpdateId = value;
await this.save();
}
public async resetSyncState(): Promise<void> {
this._documents = new Map();
this._lastSeenUpdateId = 0;
await this.save();
}
public async setDocument({ public async setDocument({
relativePath, relativePath,
parentVersionId, parentVersionId,
@ -135,6 +161,7 @@ export class Database {
await this.saveData({ await this.saveData({
documents: Object.fromEntries(this._documents.entries()), documents: Object.fromEntries(this._documents.entries()),
settings: this._settings, settings: this._settings,
lastSeenUpdateId: this._lastSeenUpdateId,
}); });
} }
} }