import {makeAutoObservable, runInAction} from 'mobx' import {RootStoreModel} from '../root-store' import {bundleAsync} from 'lib/async/bundle' import {cleanError} from 'lib/strings/errors' import {FeedSourceModel} from '../content/feed-source' import {track} from 'lib/analytics/analytics' export class SavedFeedsModel { // state isLoading = false isRefreshing = false hasLoaded = false error = '' // data all: FeedSourceModel[] = [] constructor(public rootStore: RootStoreModel) { makeAutoObservable( this, { rootStore: false, }, {autoBind: true}, ) } get hasContent() { return this.all.length > 0 } get hasError() { return this.error !== '' } get isEmpty() { return this.hasLoaded && !this.hasContent } get pinned() { return this.all.filter(feed => feed.isPinned) } get unpinned() { return this.all.filter(feed => !feed.isPinned) } get pinnedFeedNames() { return this.pinned.map(f => f.displayName) } // public api // = clear() { this.all = [] } /** * Refresh the preferences then reload all feed infos */ refresh = bundleAsync(async () => { this._xLoading(true) try { await this.rootStore.preferences.sync() const uris = dedup( this.rootStore.preferences.pinnedFeeds.concat( this.rootStore.preferences.savedFeeds, ), ) const feeds = uris.map(uri => new FeedSourceModel(this.rootStore, uri)) await Promise.all(feeds.map(f => f.setup())) runInAction(() => { this.all = feeds this._updatePinSortOrder() }) this._xIdle() } catch (e: any) { this._xIdle(e) } }) async reorderPinnedFeeds(feeds: FeedSourceModel[]) { this._updatePinSortOrder(feeds.map(f => f.uri)) await this.rootStore.preferences.setSavedFeeds( this.rootStore.preferences.savedFeeds, feeds.filter(feed => feed.isPinned).map(feed => feed.uri), ) } async movePinnedFeed(item: FeedSourceModel, direction: 'up' | 'down') { const pinned = this.rootStore.preferences.pinnedFeeds.slice() const index = pinned.indexOf(item.uri) if (index === -1) { return } if (direction === 'up' && index !== 0) { ;[pinned[index], pinned[index - 1]] = [pinned[index - 1], pinned[index]] } else if (direction === 'down' && index < pinned.length - 1) { ;[pinned[index], pinned[index + 1]] = [pinned[index + 1], pinned[index]] } this._updatePinSortOrder(pinned.concat(this.unpinned.map(f => f.uri))) await this.rootStore.preferences.setSavedFeeds( this.rootStore.preferences.savedFeeds, pinned, ) track('CustomFeed:Reorder', { name: item.displayName, uri: item.uri, index: pinned.indexOf(item.uri), }) } // state transitions // = _xLoading(isRefreshing = false) { this.isLoading = true this.isRefreshing = isRefreshing this.error = '' } _xIdle(err?: any) { this.isLoading = false this.isRefreshing = false this.hasLoaded = true this.error = cleanError(err) if (err) { this.rootStore.log.error('Failed to fetch user feeds', err) } } // helpers // = _updatePinSortOrder(order?: string[]) { order ??= this.rootStore.preferences.pinnedFeeds.concat( this.rootStore.preferences.savedFeeds, ) this.all.sort((a, b) => { return order!.indexOf(a.uri) - order!.indexOf(b.uri) }) } } function dedup(strings: string[]): string[] { return Array.from(new Set(strings)) }