nostr/iris-messenger
1
0
Fork 0
mirror of https://github.com/irislib/iris-messenger.git synced 2024-09-16 16:23:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

indexeddb unique index fix

Browse Source
This commit is contained in:
Martti Malmi 2024-01-05 00:16:46 +02:00
parent 452456927a
commit a522e919c6
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/js/nostr/IndexedDB.ts
View File

@ -21,9 +21,10 @@ class MyDexie extends Dexie {
constructor() { constructor() {
super('iris'); super('iris');
this.version(5).stores({ this.version(6).stores({
events: 'id, pubkey, kind, created_at, [pubkey+kind]', // TODO use events multientry index for *tags
tags: 'id, eventId, [type+value]', events: "++id, pubkey, kind, created_at, [pubkey+kind]",
tags: "&[type+value+eventId], [type+value], eventId",
}); });
} }
} }
@ -119,13 +120,13 @@ const IndexedDB = {
.anyOf(authors) .anyOf(authors)
.limit(limit || 1000) .limit(limit || 1000)
.each(handleEvent); .each(handleEvent);
}, 1000), }, 100),
subscribeToEventIds: throttle(async function (this: typeof IndexedDB) { subscribeToEventIds: throttle(async function (this: typeof IndexedDB) {
const ids = [...this.subscribedEventIds]; const ids = [...this.subscribedEventIds];
this.subscribedEventIds.clear(); this.subscribedEventIds.clear();
await db.events.where('id').anyOf(ids).each(handleEvent); await db.events.where('id').anyOf(ids).each(handleEvent);
}, 1000), }, 100),
subscribeToTags: throttle(async function (this: typeof IndexedDB) { subscribeToTags: throttle(async function (this: typeof IndexedDB) {
const tagPairs = [...this.subscribedTags].map((tag) => tag.split('|')); const tagPairs = [...this.subscribedTags].map((tag) => tag.split('|'));
@ -136,7 +137,7 @@ const IndexedDB = {
.each((tag) => this.subscribedEventIds.add(tag.eventId)); .each((tag) => this.subscribedEventIds.add(tag.eventId));
await this.subscribeToEventIds(); await this.subscribeToEventIds();
}, 1000), }, 100),
async countEvents() { async countEvents() {
return await db.events.count(); return await db.events.count();