4nk/sdk_client
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix indexeddb

Browse Source
This commit is contained in:
Sosthene00 2024-04-17 09:12:12 +02:00
parent 8fb517c107
commit d6a473f6e9
2 changed files with 10 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/database.ts
View File

@ -4,32 +4,10 @@ class Database {
private dbName: string = '4nk'; private dbName: string = '4nk';
private dbVersion: number = 1; private dbVersion: number = 1;
private storeDefinitions = { private storeDefinitions = {
// SpClient: {
// name: "sp_client",
// options: {},
// indices: []
// },
// SpOutputs: {
// name: "sp_outputs",
// options: {'autoIncrement': true},
// indices: [{
// name: 'by_wallet_fingerprint',
// keyPath: 'wallet_fingerprint',
// options: {
// 'unique': false
// }
// }]
// },
AnkUser: { AnkUser: {
name: "user", name: "user",
options: {'keyPath': 'pre_id'}, options: {'keyPath': 'pre_id'},
indices: [{ indices: []
name: 'by_process',
keyPath: 'process',
options: {
'unique': false
}
}]
}, },
AnkSession: { AnkSession: {
name: "session", name: "session",
@ -92,11 +70,11 @@ class Database {
}); });
} }
public getDb(): IDBDatabase { public async getDb(): Promise<IDBDatabase> {
if (!this.db) { if (!this.db) {
throw new Error("Database not initialized"); await this.init();
} }
return this.db; return this.db!;
} }
public getStoreList(): {[key: string]: string} { public getStoreList(): {[key: string]: string} {

12
src/services.ts
View File

@ -39,7 +39,7 @@ class Services {
let isNew = false; let isNew = false;
try { try {
const indexedDB = await IndexedDB.getInstance(); const indexedDB = await IndexedDB.getInstance();
const db = indexedDB.getDb(); const db = await indexedDB.getDb();
let userListObject = await indexedDB.getAll<User>(db, indexedDB.getStoreList().AnkUser); let userListObject = await indexedDB.getAll<User>(db, indexedDB.getStoreList().AnkUser);
if (userListObject.length == 0) { if (userListObject.length == 0) {
isNew = true; isNew = true;
@ -97,7 +97,7 @@ class Services {
try { try {
const indexedDb = await IndexedDB.getInstance(); const indexedDb = await IndexedDB.getInstance();
const db = indexedDb.getDb(); const db = await indexedDb.getDb();
await indexedDb.writeObject(db, indexedDb.getStoreList().AnkUser, user, null); await indexedDb.writeObject(db, indexedDb.getStoreList().AnkUser, user, null);
} catch (error) { } catch (error) {
console.error("Failed to write user object :", error); console.error("Failed to write user object :", error);
@ -243,7 +243,7 @@ class Services {
public async addProcess(process: Process): Promise<void> { public async addProcess(process: Process): Promise<void> {
try { try {
const indexedDB = await IndexedDB.getInstance(); const indexedDB = await IndexedDB.getInstance();
const db = indexedDB.getDb(); const db = await indexedDB.getDb();
await indexedDB.writeObject(db, indexedDB.getStoreList().AnkProcess, process, null); await indexedDB.writeObject(db, indexedDB.getStoreList().AnkProcess, process, null);
} catch (error) { } catch (error) {
console.log('addProcess failed: ',error); console.log('addProcess failed: ',error);
@ -253,7 +253,7 @@ class Services {
public async getAllProcess(): Promise<Process[]> { public async getAllProcess(): Promise<Process[]> {
try { try {
const indexedDB = await IndexedDB.getInstance(); const indexedDB = await IndexedDB.getInstance();
const db = indexedDB.getDb(); const db = await indexedDB.getDb();
let processListObject = await indexedDB.getAll<Process>(db, indexedDB.getStoreList().AnkProcess); let processListObject = await indexedDB.getAll<Process>(db, indexedDB.getStoreList().AnkProcess);
return processListObject; return processListObject;
} catch (error) { } catch (error) {
@ -280,7 +280,7 @@ class Services {
let userProcessList: Process[] = []; let userProcessList: Process[] = [];
try { try {
const indexedDB = await IndexedDB.getInstance(); const indexedDB = await IndexedDB.getInstance();
const db = indexedDB.getDb(); const db = await indexedDB.getDb();
user = await indexedDB.getObject<User>(db, indexedDB.getStoreList().AnkUser, pre_id); user = await indexedDB.getObject<User>(db, indexedDB.getStoreList().AnkUser, pre_id);
} catch (error) { } catch (error) {
console.error('getAllUserProcess failed: ',error); console.error('getAllUserProcess failed: ',error);
@ -304,7 +304,7 @@ class Services {
public async getProcessByName(name: string): Promise<Process | null> { public async getProcessByName(name: string): Promise<Process | null> {
console.log('getProcessByName name: '+name); console.log('getProcessByName name: '+name);
const indexedDB = await IndexedDB.getInstance(); const indexedDB = await IndexedDB.getInstance();
const db = indexedDB.getDb(); const db = await indexedDB.getDb();
const process = await indexedDB.getFirstMatchWithIndex<Process>(db, indexedDB.getStoreList().AnkProcess, 'by_name', name); const process = await indexedDB.getFirstMatchWithIndex<Process>(db, indexedDB.getStoreList().AnkProcess, 'by_name', name);
console.log('getProcessByName process: '+process); console.log('getProcessByName process: '+process);