Page MenuHomePhorge
Files F33120223

D7289.1768490327.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D7289.1768490327.diff
View Options

diff --git a/web/database/utils/constants.js b/web/database/utils/constants.js
--- a/web/database/utils/constants.js
+++ b/web/database/utils/constants.js
@@ -5,8 +5,6 @@
export const CURRENT_USER_ID_KEY = 'current_user_id';
-export const DB_PERSIST_THROTTLE_WAIT_MS = 300;
-
export const DATABASE_WORKER_PATH = '/worker/database';
export const SQLJS_FILE_PATH = '/compiled/webworkers';
diff --git a/web/database/worker/db-worker.js b/web/database/worker/db-worker.js
--- a/web/database/worker/db-worker.js
+++ b/web/database/worker/db-worker.js
@@ -1,7 +1,6 @@
// @flow
import localforage from 'localforage';
-import _throttle from 'lodash/throttle.js';
import initSqlJs, { type SqliteDatabase } from 'sql.js';
import type {
@@ -34,7 +33,6 @@
} from '../queries/storage-engine-queries.js';
import {
CURRENT_USER_ID_KEY,
- DB_PERSIST_THROTTLE_WAIT_MS,
SQLITE_CONTENT,
SQLITE_ENCRYPTION_KEY,
} from '../utils/constants.js';
@@ -56,6 +54,9 @@
let sqliteDb: ?SqliteDatabase = null;
let encryptionKey: ?CryptoKey = null;
+let persistNeeded: boolean = false;
+let persistInProgress: boolean = false;
+
async function initDatabase(sqljsFilePath: string, sqljsFilename: ?string) {
encryptionKey = await localforage.getItem(SQLITE_ENCRYPTION_KEY);
if (!encryptionKey) {
@@ -133,6 +134,7 @@
}
async function persist() {
+ persistInProgress = true;
if (!sqliteDb) {
throw new Error('Database not initialized');
}
@@ -147,9 +149,14 @@
}
const encryptedData = await encryptDatabaseFile(dbData, encryptionKey);
await localforage.setItem(SQLITE_CONTENT, encryptedData);
-}
-const throttledPersist = _throttle(persist, DB_PERSIST_THROTTLE_WAIT_MS);
+ if (persistNeeded) {
+ persistNeeded = false;
+ persist();
+ } else {
+ persistInProgress = false;
+ }
+}
async function processAppRequest(
message: WorkerRequestMessage,
@@ -224,7 +231,14 @@
}
if (workerWriteRequests.includes(message.type)) {
- throttledPersist();
+ if (persistInProgress) {
+ // persist process is running, it will need to be scheduled again
+ persistNeeded = true;
+ } else {
+ // persist process is not running, scheduling for the first time
+ persist();
+ }
+
return;
}

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 15, 3:18 PM (13 h, 17 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5938538
Default Alt Text
D7289.1768490327.diff (2 KB)

Event Timeline