-
-
- Scan with your other device :
-
-
-
-
-
-
-
-
-
-
-
- Scan your other device :
-
-
-
-
-
-
Or
-
-
-
-
-
-
-
-
-
+
+
Scan with your other device :
+
+
+
+
+
+
+
+
+
+
Scan your other device :
+
+
+
+
+
Or
+
+
+
+
+
-
-
+
+
Process Selection
+
+
+
diff --git a/src/scanner.js b/src/scanner.js
index fe4d1c2..ff048c0 100644
--- a/src/scanner.js
+++ b/src/scanner.js
@@ -1,16 +1,13 @@
-function onScanSuccess(decodedText, decodedResult) {
- // handle the scanned code as you like, for example:
- console.log(`Code matched = ${decodedText}`, decodedResult);
- }
-
- function onScanFailure(error) {
- // handle scan failure, usually better to ignore and keep scanning.
- // for example:
- console.warn(`Code scan error = ${error}`);
- }
-
- let html5QrcodeScanner = new Html5QrcodeScanner(
- "reader",
- { fps: 10, qrbox: {width: 250, height: 250} },
- /* verbose= */ false);
- html5QrcodeScanner.render(onScanSuccess, onScanFailure);
\ No newline at end of file
+function onScanSuccess(decodedText, decodedResult) {
+ // handle the scanned code as you like, for example:
+ console.log(`Code matched = ${decodedText}`, decodedResult);
+}
+
+function onScanFailure(error) {
+ // handle scan failure, usually better to ignore and keep scanning.
+ // for example:
+ console.warn(`Code scan error = ${error}`);
+}
+
+let html5QrcodeScanner = new Html5QrcodeScanner('reader', { fps: 10, qrbox: { width: 250, height: 250 } }, /* verbose= */ false);
+html5QrcodeScanner.render(onScanSuccess, onScanFailure);
diff --git a/src/service-workers/database.worker.js b/src/service-workers/database.worker.js
index b956440..fa75692 100644
--- a/src/service-workers/database.worker.js
+++ b/src/service-workers/database.worker.js
@@ -1,58 +1,60 @@
-import Database from '../services/database.service';
-
-self.addEventListener('install', (event) => {
- event.waitUntil(self.skipWaiting()); // Activate worker immediately
-});
-
-self.addEventListener('activate', (event) => {
- event.waitUntil(self.clients.claim()); // Become available to all pages
-});
-
-// Event listener for messages from clients
-self.addEventListener('message', async (event) => {
- const data = event.data;
- const db = await Database.getInstance();
-
- if (data.type === 'ADD_OBJECT') {
- try {
- const { storeName, object, key } = data.payload;
- const db = await openDatabase();
- const tx = db.transaction(storeName, 'readwrite');
- const store = tx.objectStore(storeName);
- console.log("🚀 ~ self.addEventListener ~ store:", store, storeName, key, object)
- await store.put(object);
- event.ports[0].postMessage({ status: 'success', message: 'Object added or replaced successfully' });
- } catch(error) {
- event.ports[0].postMessage({ status: 'error', message: error.message });
- }
- }
-
- if (data.type === 'GET_OBJECT') {
- const { storeName, key } = data.payload;
- const db = await openDatabase();
- const tx = db.transaction(storeName, 'readonly');
- const store = tx.objectStore(storeName);
- const result = await store.get(key);
-
- event.ports[0].postMessage({ type: 'GET_OBJECT_RESULT', payload: result });
- }
-
-});
-
-async function openDatabase() {
- return new Promise((resolve, reject) => {
- const request = indexedDB.open('4nk', 1);
- request.onerror = (event) => {
- reject(request.error);
- };
- request.onsuccess = (event) => {
- resolve(request.result);
- };
- request.onupgradeneeded = (event) => {
- const db = event.target.result;
- if (!db.objectStoreNames.contains('wallet')) {
- db.createObjectStore('wallet', { keyPath: 'pre_id' });
- }
- };
- });
-}
\ No newline at end of file
+import Database from '../services/database.service';
+
+self.addEventListener('install', (event) => {
+ event.waitUntil(self.skipWaiting()); // Activate worker immediately
+});
+
+self.addEventListener('activate', (event) => {
+ event.waitUntil(self.clients.claim()); // Become available to all pages
+});
+
+// Event listener for messages from clients
+self.addEventListener('message', async (event) => {
+ const data = event.data;
+ const db = await Database.getInstance();
+
+ if (data.type === 'ADD_OBJECT') {
+ try {
+ const { storeName, object, key } = data.payload;
+ const db = await openDatabase();
+ const tx = db.transaction(storeName, 'readwrite');
+ const store = tx.objectStore(storeName);
+ await store.put(object);
+ event.ports[0].postMessage({ status: 'success', message: 'Object added or replaced successfully' });
+ } catch (error) {
+ event.ports[0].postMessage({ status: 'error', message: error.message });
+ }
+ }
+
+ if (data.type === 'GET_OBJECT') {
+ const { storeName, key } = data.payload;
+ const db = await openDatabase();
+ const tx = db.transaction(storeName, 'readonly');
+ const store = tx.objectStore(storeName);
+ const result = await new Promise((resolve, reject) => {
+ const getRequest = store.get(key);
+ getRequest.onsuccess = (event) => resolve(getRequest.result);
+ getRequest.onerror = (event) => reject(getRequest.error);
+ });
+
+ event.ports[0].postMessage({ type: 'GET_OBJECT_RESULT', payload: result });
+ }
+});
+
+async function openDatabase() {
+ return new Promise((resolve, reject) => {
+ const request = indexedDB.open('4nk', 1);
+ request.onerror = (event) => {
+ reject(request.error);
+ };
+ request.onsuccess = (event) => {
+ resolve(request.result);
+ };
+ request.onupgradeneeded = (event) => {
+ const db = event.target.result;
+ if (!db.objectStoreNames.contains('wallet')) {
+ db.createObjectStore('wallet', { keyPath: 'pre_id' });
+ }
+ };
+ });
+}
diff --git a/src/services/database.service.ts b/src/services/database.service.ts
index ad242a3..5749806 100644
--- a/src/services/database.service.ts
+++ b/src/services/database.service.ts
@@ -15,21 +15,18 @@ class Database {
AnkProcess: {
name: 'process',
options: { keyPath: 'id' },
- indices: [
- {
- name: 'by_name',
- keyPath: 'name',
- options: {
- unique: true,
- },
- },
- ],
+ indices: [],
},
AnkMessages: {
name: 'messages',
options: { keyPath: 'id' },
indices: [],
},
+ AnkProcessData: {
+ name: 'process-data',
+ options: { keyPath: 'id' },
+ indices: [],
+ },
};
// Private constructor to prevent direct instantiation from outside
@@ -105,6 +102,8 @@ class Database {
this.serviceWorkerRegistration = registration;
+ this.checkForUpdates();
+
// Set up the message channels
this.messageChannel.port1.onmessage = this.handleAddObjectResponse;
this.messageChannelForGet.port1.onmessage = this.handleGetObjectResponse;
@@ -115,6 +114,23 @@ class Database {
}
}
}
+
+ private async checkForUpdates() {
+ if (this.serviceWorkerRegistration) {
+ // Check for updates to the service worker
+ try {
+ await this.serviceWorkerRegistration.update();
+
+ // If there's a new worker waiting, activate it immediately
+ if (this.serviceWorkerRegistration.waiting) {
+ this.serviceWorkerRegistration.waiting.postMessage({ type: 'SKIP_WAITING' });
+ }
+ } catch (error) {
+ console.error('Error checking for service worker updates:', error);
+ }
+ }
+ }
+
private handleAddObjectResponse = (event: MessageEvent) => {
console.log('Received response from service worker (ADD_OBJECT):', event.data);
};
diff --git a/src/services/service.ts b/src/services/service.ts
index 4951bbb..edb9d56 100644
--- a/src/services/service.ts
+++ b/src/services/service.ts
@@ -226,7 +226,7 @@ export default class Services {
localStorage.setItem(msg.id.toString(), JSON.stringify(msg));
const db = await Database.getInstance();
db.addObject({
- storeName: 'process',
+ storeName: 'messages',
object: { id: msg.id.toString(), msg },
key: msg.id.toString(),
});