Page MenuHomePhorge
Files F32167729

D7189.1765053710.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D7189.1765053710.diff
View Options

diff --git a/web/database/database-module-provider.js b/web/database/database-module-provider.js
new file mode 100644
--- /dev/null
+++ b/web/database/database-module-provider.js
@@ -0,0 +1,85 @@
+// @flow
+
+import { DATABASE_WORKER_PATH, SQLJS_FILE_PATH } from './utils/constants.js';
+import WorkerConnectionProxy from './utils/WorkerConnectionProxy.js';
+import { workerRequestMessageTypes } from '../types/worker-types.js';
+import type {
+ WorkerRequestMessage,
+ WorkerResponseMessage,
+} from '../types/worker-types.js';
+
+declare var sqljsFilename: string;
+declare var supportSqlite: string;
+
+const databaseStatuses = Object.freeze({
+ notSupported: 'NOT_SUPPORTED',
+ initSuccess: 'INIT_SUCCESS',
+ initInProgress: 'INIT_IN_PROGRESS',
+ initError: 'INIT_ERROR',
+});
+
+type DatabaseStatus = $Values<typeof databaseStatuses>;
+
+class DatabaseModule {
+ worker: SharedWorker;
+ workerProxy: WorkerConnectionProxy;
+ initPromise: Promise<void>;
+ status: DatabaseStatus;
+
+ constructor() {
+ if (supportSqlite !== 'true') {
+ this.status = databaseStatuses.notSupported;
+ }
+ this.worker = new SharedWorker(DATABASE_WORKER_PATH);
+ this.worker.onerror = this.onError;
+ this.workerProxy = new WorkerConnectionProxy(
+ this.worker.port,
+ this.onError,
+ );
+ this.status = databaseStatuses.initInProgress;
+
+ const origin = window.location.origin;
+
+ // can not await in constructor - starting a promise
+ this.initPromise = this.workerProxy
+ .scheduleOnWorker({
+ type: workerRequestMessageTypes.INIT,
+ sqljsFilePath: `${origin}${SQLJS_FILE_PATH}`,
+ sqljsFilename,
+ })
+ .then(() => {
+ this.status = databaseStatuses.initSuccess;
+ console.info('Database initialization success');
+ })
+ .catch(error => {
+ this.status = databaseStatuses.initError;
+ console.error(`Database initialization failure`, error);
+ });
+ }
+
+ onError: (error: Error) => void = error => {
+ console.error(error);
+ };
+
+ async schedule(
+ payload: WorkerRequestMessage,
+ ): Promise<?WorkerResponseMessage> {
+ if (this.status === databaseStatuses.notSupported) {
+ throw new Error('Database not supported');
+ }
+
+ if (this.status === databaseStatuses.initInProgress) {
+ await this.initPromise;
+ }
+
+ if (this.status === databaseStatuses.initError) {
+ throw new Error('Database could not be initialized');
+ }
+
+ return this.workerProxy.scheduleOnWorker(payload);
+ }
+}
+
+const databaseModule: DatabaseModule = new DatabaseModule();
+
+export { databaseModule };
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
@@ -4,3 +4,6 @@
export const SQLITE_ENCRYPTION_KEY = 'encryptionKey';
export const CURRENT_USER_ID_KEY = 'current_user_id';
+
+export const DATABASE_WORKER_PATH = '/worker/database';
+export const SQLJS_FILE_PATH = '/compiled/webworkers';

File Metadata

Mime Type
text/plain
Expires
Sat, Dec 6, 8:41 PM (22 h, 31 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5840713
Default Alt Text
D7189.1765053710.diff (2 KB)

Event Timeline