import {makeAutoObservable, runInAction} from 'mobx' import {RootStoreModel} from './root-store' import {FeedModel} from './feed-view' import {MembershipsViewModel} from './memberships-view' import {NotificationsViewModel} from './notifications-view' import {isObj, hasProp} from '../lib/type-guards' export class MeModel { did: string = '' handle: string = '' displayName: string = '' description: string = '' avatar: string = '' notificationCount: number = 0 memberships?: MembershipsViewModel mainFeed: FeedModel notifications: NotificationsViewModel constructor(public rootStore: RootStoreModel) { makeAutoObservable( this, {rootStore: false, serialize: false, hydrate: false}, {autoBind: true}, ) this.mainFeed = new FeedModel(this.rootStore, 'home', { algorithm: 'reverse-chronological', }) this.notifications = new NotificationsViewModel(this.rootStore, {}) } clear() { this.did = '' this.handle = '' this.displayName = '' this.description = '' this.avatar = '' this.notificationCount = 0 this.memberships = undefined } serialize(): unknown { return { did: this.did, handle: this.handle, displayName: this.displayName, description: this.description, avatar: this.avatar, } } hydrate(v: unknown) { if (isObj(v)) { let did, handle, displayName, description, avatar if (hasProp(v, 'did') && typeof v.did === 'string') { did = v.did } if (hasProp(v, 'handle') && typeof v.handle === 'string') { handle = v.handle } if (hasProp(v, 'displayName') && typeof v.displayName === 'string') { displayName = v.displayName } if (hasProp(v, 'description') && typeof v.description === 'string') { description = v.description } if (hasProp(v, 'avatar') && typeof v.avatar === 'string') { avatar = v.avatar } if (did && handle) { this.did = did this.handle = handle this.displayName = displayName || '' this.description = description || '' this.avatar = avatar || '' } } } async load() { const sess = this.rootStore.session if (sess.hasSession && sess.data) { this.did = sess.data.did || '' this.handle = sess.data.handle const profile = await this.rootStore.api.app.bsky.actor.getProfile({ actor: this.did, }) runInAction(() => { if (profile?.data) { this.displayName = profile.data.displayName || '' this.description = profile.data.description || '' this.avatar = profile.data.avatar || '' } else { this.displayName = '' this.description = '' this.avatar = '' } }) this.mainFeed = new FeedModel(this.rootStore, 'home', { algorithm: 'reverse-chronological', }) this.notifications = new NotificationsViewModel(this.rootStore, {}) this.memberships = new MembershipsViewModel(this.rootStore, { actor: this.did, }) await Promise.all([ this.memberships?.setup().catch(e => { console.error('Failed to setup memberships model', e) }), this.mainFeed.setup().catch(e => { console.error('Failed to setup main feed model', e) }), this.notifications.setup().catch(e => { console.error('Failed to setup notifications model', e) }), ]) } else { this.clear() } } clearNotificationCount() { this.notificationCount = 0 } async fetchStateUpdate() { const res = await this.rootStore.api.app.bsky.notification.getCount() runInAction(() => { const newNotifications = this.notificationCount !== res.data.count this.notificationCount = res.data.count if (newNotifications) { // trigger pre-emptive fetch on new notifications this.notifications.refresh() } }) } async refreshMemberships() { return this.memberships?.refresh() } }