apxtri/objects
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'main' of https://gitea.ndda.fr/apxtri/objects

Browse Source
This commit is contained in:
philc
2025-08-01 09:38:56 +02:00
parent 8965547896 e4501f112e
commit ad27f1edba
1 changed files with 15 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
wco/apx/apx.js
View File

@@ -520,19 +520,19 @@ apx.ready(apx.update); //2nd param optional=> true mean does not wait same if ap
apx.indexedDB = apx.indexedDB || {};
apx.indexedDB.set = async (db, storeName, keyPath, key, value) => {
apx.indexedDB.set = async (db, storeName, value) => {
return new Promise((resolve, reject) => {
const request = indexedDB.open(db, 1);
request.onupgradeneeded = (event) => {
const db = event.target.result;
if (window.threadsObj) {
for (const threadId of Object.keys(window.threadsObj)) {
if (!db.objectStoreNames.contains(threadId)) {
db.createObjectStore(threadId, { keyPath: keyPath });
};
if (!db.objectStoreNames.contains("threads")) {
db.createObjectStore("threads", { keyPath: "uuid" });
};
if (!db.objectStoreNames.contains("messages")) {
db.createObjectStore("messages", { keyPath: "privatriid" });
};
};
@@ -546,7 +546,7 @@ apx.indexedDB.set = async (db, storeName, keyPath, key, value) => {
const transaction = db.transaction(storeName, "readwrite");
const store = transaction.objectStore(storeName);
const putRequest = store.put({ timestamp: key, value: value });
const putRequest = store.put(value);
putRequest.onsuccess = () => resolve();
putRequest.onerror = (error) => reject(error);
};
@@ -555,35 +555,22 @@ apx.indexedDB.set = async (db, storeName, keyPath, key, value) => {
});
};
apx.indexedDB.get = async (db, storeName, keyPath, key) => {
apx.indexedDB.get = async (db, storeName, key) => {
return new Promise((resolve, reject) => {
const request = indexedDB.open(db, 1);
request.onupgradeneeded = (event) => {
const db = event.target.result;
if (window.threadsObj) {
for (const threadId of Object.keys(window.threadsObj)) {
if (!db.objectStoreNames.contains(threadId)) {
db.createObjectStore(threadId, { keyPath: keyPath });
};
};
};
};
request.onsuccess = (event) => {
const db = event.target.result;
if (!db.objectStoreNames.contains(storeName)) {
return resolve(null);
};
}
const transaction = db.transaction(storeName, "readonly");
const store = transaction.objectStore(storeName);
const getRequest = store.get(key);
getRequest.onsuccess = () => {
resolve(getRequest.result ? getRequest.result.value : null);
resolve(getRequest.result || null);
};
getRequest.onerror = () => resolve(null);
@@ -593,22 +580,10 @@ apx.indexedDB.get = async (db, storeName, keyPath, key) => {
});
};
apx.indexedDB.del = async (db, storeName, keyPath, key) => {
apx.indexedDB.del = async (db, storeName, key) => {
return new Promise((resolve, reject) => {
const request = indexedDB.open(db, 1);
request.onupgradeneeded = (event) => {
const db = event.target.result;
if (window.threadsObj) {
for (const threadId of Object.keys(window.threadsObj)) {
if (!db.objectStoreNames.contains(threadId)) {
db.createObjectStore(threadId, { keyPath: keyPath });
};
};
};
};
request.onsuccess = (event) => {
const db = event.target.result;