diff options
Diffstat (limited to 'src/state')
| -rw-r--r-- | src/state/models/feed-view.ts | 1 | ||||
| -rw-r--r-- | src/state/models/notifications-view.ts | 304 | ||||
| -rw-r--r-- | src/state/models/post.ts | 93 | ||||
| -rw-r--r-- | src/state/models/root-store.ts | 2 |
4 files changed, 400 insertions, 0 deletions
diff --git a/src/state/models/feed-view.ts b/src/state/models/feed-view.ts index 5264aa27e..e9405773c 100644 --- a/src/state/models/feed-view.ts +++ b/src/state/models/feed-view.ts @@ -110,6 +110,7 @@ export class FeedViewModel implements bsky.FeedView.Response { { rootStore: false, params: false, + _loadPromise: false, _loadMorePromise: false, _updatePromise: false, }, diff --git a/src/state/models/notifications-view.ts b/src/state/models/notifications-view.ts new file mode 100644 index 000000000..ef8f14996 --- /dev/null +++ b/src/state/models/notifications-view.ts @@ -0,0 +1,304 @@ +import {makeAutoObservable, runInAction} from 'mobx' +import {bsky} from '@adxp/mock-api' +import {RootStoreModel} from './root-store' +import {hasProp} from '../lib/type-guards' + +export class NotificationsViewItemModel + implements bsky.NotificationsView.Notification +{ + // ui state + _reactKey: string = '' + + // data + uri: string = '' + author: { + did: string + name: string + displayName: string + } = {did: '', name: '', displayName: ''} + record: any = {} + isRead: boolean = false + indexedAt: string = '' + + constructor( + public rootStore: RootStoreModel, + reactKey: string, + v: bsky.NotificationsView.Notification, + ) { + makeAutoObservable(this, {rootStore: false}) + this._reactKey = reactKey + this.copy(v) + } + + copy(v: bsky.NotificationsView.Notification) { + this.uri = v.uri + this.author = v.author + this.record = v.record + this.isRead = v.isRead + this.indexedAt = v.indexedAt + } + + get isLike() { + return ( + hasProp(this.record, '$type') && + this.record.$type === 'blueskyweb.xyz:Like' + ) + } + + get isRepost() { + return ( + hasProp(this.record, '$type') && + this.record.$type === 'blueskyweb.xyz:Repost' + ) + } + + get isReply() { + return ( + hasProp(this.record, '$type') && + this.record.$type === 'blueskyweb.xyz:Post' + ) + } + + get isFollow() { + return ( + hasProp(this.record, '$type') && + this.record.$type === 'blueskyweb.xyz:Follow' + ) + } + + get subjectUri() { + if ( + hasProp(this.record, 'subject') && + typeof this.record.subject === 'string' + ) { + return this.record.subject + } + return '' + } +} + +export class NotificationsViewModel implements bsky.NotificationsView.Response { + // state + isLoading = false + isRefreshing = false + hasLoaded = false + error = '' + params: bsky.NotificationsView.Params + _loadPromise: Promise<void> | undefined + _loadMorePromise: Promise<void> | undefined + _updatePromise: Promise<void> | undefined + + // data + notifications: NotificationsViewItemModel[] = [] + + constructor( + public rootStore: RootStoreModel, + params: bsky.NotificationsView.Params, + ) { + makeAutoObservable( + this, + { + rootStore: false, + params: false, + _loadPromise: false, + _loadMorePromise: false, + _updatePromise: false, + }, + {autoBind: true}, + ) + this.params = params + } + + get hasContent() { + return this.notifications.length !== 0 + } + + get hasError() { + return this.error !== '' + } + + get isEmpty() { + return this.hasLoaded && !this.hasContent + } + + get loadMoreCursor() { + if (this.hasContent) { + return this.notifications[this.notifications.length - 1].indexedAt + } + return undefined + } + + // public api + // = + + /** + * Load for first render + */ + async setup(isRefreshing = false) { + if (this._loadPromise) { + return this._loadPromise + } + await this._pendingWork() + this._loadPromise = this._initialLoad(isRefreshing) + await this._loadPromise + this._loadPromise = undefined + } + + /** + * Reset and load + */ + async refresh() { + return this.setup(true) + } + + /** + * Load more posts to the end of the notifications + */ + async loadMore() { + if (this._loadMorePromise) { + return this._loadMorePromise + } + await this._pendingWork() + this._loadMorePromise = this._loadMore() + await this._loadMorePromise + this._loadMorePromise = undefined + } + + /** + * Update content in-place + */ + async update() { + if (this._updatePromise) { + return this._updatePromise + } + await this._pendingWork() + this._updatePromise = this._update() + await this._updatePromise + this._updatePromise = undefined + } + + // state transitions + // = + + private _xLoading(isRefreshing = false) { + this.isLoading = true + this.isRefreshing = isRefreshing + this.error = '' + } + + private _xIdle(err: string = '') { + this.isLoading = false + this.isRefreshing = false + this.hasLoaded = true + this.error = err + } + + // loader functions + // = + + private async _pendingWork() { + if (this._loadPromise) { + await this._loadPromise + } + if (this._loadMorePromise) { + await this._loadMorePromise + } + if (this._updatePromise) { + await this._updatePromise + } + } + + private async _initialLoad(isRefreshing = false) { + this._xLoading(isRefreshing) + await new Promise(r => setTimeout(r, 250)) // DEBUG + try { + const res = (await this.rootStore.api.mainPds.view( + 'blueskyweb.xyz:NotificationsView', + this.params, + )) as bsky.NotificationsView.Response + this._replaceAll(res) + this._xIdle() + } catch (e: any) { + this._xIdle(`Failed to load notifications: ${e.toString()}`) + } + } + + private async _loadMore() { + this._xLoading() + await new Promise(r => setTimeout(r, 250)) // DEBUG + try { + const params = Object.assign({}, this.params, { + before: this.loadMoreCursor, + }) + const res = (await this.rootStore.api.mainPds.view( + 'blueskyweb.xyz:NotificationsView', + params, + )) as bsky.NotificationsView.Response + this._appendAll(res) + this._xIdle() + } catch (e: any) { + this._xIdle(`Failed to load notifications: ${e.toString()}`) + } + } + + private async _update() { + this._xLoading() + await new Promise(r => setTimeout(r, 250)) // DEBUG + let numToFetch = this.notifications.length + let cursor = undefined + try { + do { + const res = (await this.rootStore.api.mainPds.view( + 'blueskyweb.xyz:NotificationsView', + { + before: cursor, + limit: Math.min(numToFetch, 100), + }, + )) as bsky.NotificationsView.Response + if (res.notifications.length === 0) { + break // sanity check + } + this._updateAll(res) + numToFetch -= res.notifications.length + cursor = this.notifications[res.notifications.length - 1].indexedAt + console.log(numToFetch, cursor, res.notifications.length) + } while (numToFetch > 0) + this._xIdle() + } catch (e: any) { + this._xIdle(`Failed to update notifications: ${e.toString()}`) + } + } + + private _replaceAll(res: bsky.NotificationsView.Response) { + this.notifications.length = 0 + this._appendAll(res) + } + + private _appendAll(res: bsky.NotificationsView.Response) { + let counter = this.notifications.length + for (const item of res.notifications) { + this._append(counter++, item) + } + } + + private _append(keyId: number, item: bsky.NotificationsView.Notification) { + // TODO: validate .record + this.notifications.push( + new NotificationsViewItemModel(this.rootStore, `item-${keyId}`, item), + ) + } + + private _updateAll(res: bsky.NotificationsView.Response) { + for (const item of res.notifications) { + const existingItem = this.notifications.find( + // this find function has a key subtley- the indexedAt comparison + // the reason for this is reposts: they set the URI of the original post, not of the repost record + // the indexedAt time will be for the repost however, so we use that to help us + item2 => item.uri === item2.uri && item.indexedAt === item2.indexedAt, + ) + if (existingItem) { + existingItem.copy(item) + } + } + } +} diff --git a/src/state/models/post.ts b/src/state/models/post.ts new file mode 100644 index 000000000..463230101 --- /dev/null +++ b/src/state/models/post.ts @@ -0,0 +1,93 @@ +import {makeAutoObservable} from 'mobx' +import {bsky, AdxUri} from '@adxp/mock-api' +import {RootStoreModel} from './root-store' + +export type PostEntities = bsky.Post.Record['entities'] +export type PostReply = bsky.Post.Record['reply'] +export class PostModel implements bsky.Post.Record { + // state + isLoading = false + hasLoaded = false + error = '' + uri: string = '' + + // data + text: string = '' + entities?: PostEntities + reply?: PostReply + createdAt: string = '' + + constructor(public rootStore: RootStoreModel, uri: string) { + makeAutoObservable( + this, + { + rootStore: false, + uri: false, + }, + {autoBind: true}, + ) + this.uri = uri + } + + get hasContent() { + return this.createdAt !== '' + } + + get hasError() { + return this.error !== '' + } + + get isEmpty() { + return this.hasLoaded && !this.hasContent + } + + // public api + // = + + async setup() { + await this._load() + } + + // state transitions + // = + + private _xLoading() { + this.isLoading = true + this.error = '' + } + + private _xIdle(err: string = '') { + this.isLoading = false + this.hasLoaded = true + this.error = err + } + + // loader functions + // = + + private async _load() { + this._xLoading() + await new Promise(r => setTimeout(r, 250)) // DEBUG + try { + const urip = new AdxUri(this.uri) + const res = await this.rootStore.api.mainPds + .repo(urip.host, false) + .collection(urip.collection) + .get('Post', urip.recordKey) + if (!res.valid) { + throw new Error(res.error) + } + this._replaceAll(res.value) + this._xIdle() + } catch (e: any) { + this._xIdle(`Failed to load post: ${e.toString()}`) + } + } + + private _replaceAll(res: bsky.Post.Record) { + this.text = res.text + this.entities = res.entities + this.reply = res.reply + this.createdAt = res.createdAt + } +} diff --git a/src/state/models/root-store.ts b/src/state/models/root-store.ts index 7391a82bd..e05c86389 100644 --- a/src/state/models/root-store.ts +++ b/src/state/models/root-store.ts @@ -9,11 +9,13 @@ import {isObj, hasProp} from '../lib/type-guards' import {SessionModel} from './session' import {MeModel} from './me' import {FeedViewModel} from './feed-view' +import {NotificationsViewModel} from './notifications-view' export class RootStoreModel { session = new SessionModel() me = new MeModel(this) homeFeed = new FeedViewModel(this, {}) + notesFeed = new NotificationsViewModel(this, {}) constructor(public api: AdxClient) { makeAutoObservable(this, { |