diff options
Diffstat (limited to 'src/lib/api/feed/merge.ts')
-rw-r--r-- | src/lib/api/feed/merge.ts | 28 |
1 files changed, 10 insertions, 18 deletions
diff --git a/src/lib/api/feed/merge.ts b/src/lib/api/feed/merge.ts index 381159d18..a4391afb2 100644 --- a/src/lib/api/feed/merge.ts +++ b/src/lib/api/feed/merge.ts @@ -62,7 +62,7 @@ export class MergeFeedAPI implements FeedAPI { // always keep following topped up if (this.following.numReady < limit) { - promises.push(this.following.fetchNext(60)) + await this.following.fetchNext(60) } // pick the next feeds to sample from @@ -73,9 +73,13 @@ export class MergeFeedAPI implements FeedAPI { } // top up the feeds - for (const feed of feeds) { - if (feed.numReady < 5) { - promises.push(feed.fetchNext(10)) + const outOfFollows = + !this.following.hasMore && this.following.numReady < limit + if (this.params.mergeFeedEnabled || outOfFollows) { + for (const feed of feeds) { + if (feed.numReady < 5) { + promises.push(feed.fetchNext(10)) + } } } @@ -216,22 +220,10 @@ class MergeFeedSource_Custom extends MergeFeedSource { super(feedTuners) this.sourceInfo = { $type: 'reasonFeedSource', - displayName: feedUri.split('/').pop() || '', - uri: feedUriToHref(feedUri), + uri: feedUri, + href: feedUriToHref(feedUri), } this.minDate = new Date(Date.now() - POST_AGE_CUTOFF) - getAgent() - .app.bsky.feed.getFeedGenerator({ - feed: feedUri, - }) - .then( - res => { - if (this.sourceInfo) { - this.sourceInfo.displayName = res.data.view.displayName - } - }, - _err => {}, - ) } protected async _getFeed( |