Creepso/webstreamr-github
1
0
Fork 0
Code Issues 27 Pull requests 7 Projects Releases 240 Packages Wiki Activity Actions

fix(source): make cache prop static

Browse source
This commit is contained in:
WebStreamr 2025-09-03 12:48:21 +00:00
parent 5547fd5486
commit 5ea34f66dd
No known key found for this signature in database
1 changed files with 6 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/source/Source.ts
View file

@ -25,21 +25,17 @@ export abstract class Source {
public abstract readonly baseUrl: string;
private readonly sourceResultCache: Cacheable;
public constructor() {
this.sourceResultCache = new Cacheable({
primary: new Keyv({ store: new CacheableMemory({ lruSize: 1024, ttl: this.ttl }) }),
secondary: new Keyv(new KeyvSqlite(`sqlite://${getCacheDir()}/webstreamr-source-cache.sqlite`)),
});
}
private static readonly sourceResultCache = new Cacheable({
primary: new Keyv({ store: new CacheableMemory({ lruSize: 1024 }) }),
secondary: new Keyv(new KeyvSqlite(`sqlite://${getCacheDir()}/webstreamr-source-cache.sqlite`)),
});
protected abstract handleInternal(ctx: Context, type: ContentType, id: Id): Promise<(SourceResult[])>;
public async handle(ctx: Context, type: ContentType, id: Id): Promise<(SourceResult[])> {
const cacheKey = `${this.id}_${id.toString()}`;
let sourceResults = (await this.sourceResultCache.get<SourceResult[]>(cacheKey))
let sourceResults = (await Source.sourceResultCache.get<SourceResult[]>(cacheKey))
?.map(sourceResult => ({ ...sourceResult, url: new URL(sourceResult.url) }));
if (!sourceResults) {
@ -53,7 +49,7 @@ export abstract class Source {
}
}
await this.sourceResultCache.set<SourceResult[]>(cacheKey, sourceResults);
await Source.sourceResultCache.set<SourceResult[]>(cacheKey, sourceResults, this.ttl);
}
return sourceResults.filter(sourceResult => sourceResult.countryCode in ctx.config);