stores/notifications_store.ts

notifications_store.ts

class NotificationsStore {
  @observable notificationsById: mobx.ObservableMap<Notification>;

  static initialize(notifications: Notification[]): NotificationsStore {
    const notificationsById = mobx.asMap(_.keyBy(notifications, 'id'));
    return new NotificationsStore(notificationsById);
  }

  @computed get unreadNotifications(): Notification[] {
    return _(this.notificationsById.values())
      .reject(notification => notification.read)
      .sortBy('time')
      .reverse()
      .value();
  }

  @computed get readNotifications(): Notification[] {
    return _(this.notificationsById.values())
      .filter(notification => notification.read)
      .sortBy('time')
      .reverse()
      .value();
    }

  @action markNotificationAsRead = (notification: Notification): Promise<void> => {
      return $.ajax(`/notifications/${notification.id}`, {
        method: 'PATCH',
        data: {
          read: true,
        },
      }).done(() => {
        notification.read = true;
      });
  }

  private constructor(notificationsById: mobx.ObservableMap<Notification>) {
    this.notificationsById = notificationsById;
  }
}