Kieran/snort
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bugfix oldest

Browse Source
This commit is contained in:
Kieran 2023-09-05 15:26:04 +01:00
parent 5fed053a73
commit 0f635ec877
No known key found for this signature in database
GPG Key ID: DE71CEB3925BE941
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/app/src/Cache/FollowsFeed.ts
View File

@ -58,7 +58,7 @@ export class FollowsFeedCache extends RefreshFeedCache<TaggedNostrEvent> {
.delete(); .delete();
const oldest = await this.table?.orderBy("created_at").first(); const oldest = await this.table?.orderBy("created_at").first();
this.#oldest = oldest?.created_at ?? unixNow() - MaxCacheWindow; this.#oldest = oldest?.created_at;
this.notifyChange(latest?.map(a => this.key(a)) ?? []); this.notifyChange(latest?.map(a => this.key(a)) ?? []);
debug(this.name)(`Loaded %d/%d in %d ms`, latest?.length ?? 0, keys.length, (unixNowMs() - start).toLocaleString()); debug(this.name)(`Loaded %d/%d in %d ms`, latest?.length ?? 0, keys.length, (unixNowMs() - start).toLocaleString());
@ -112,6 +112,8 @@ export class FollowsFeedCache extends RefreshFeedCache<TaggedNostrEvent> {
* Backfill cache based on follows list * Backfill cache based on follows list
*/ */
async backFillIfMissing(system: SystemInterface, keys: Array<string>) { async backFillIfMissing(system: SystemInterface, keys: Array<string>) {
if(!this.#oldest) return;
const start = unixNowMs(); const start = unixNowMs();
const everything = await this.table?.toArray(); const everything = await this.table?.toArray();
if ((everything?.length ?? 0) > 0) { if ((everything?.length ?? 0) > 0) {