1 files changed, 128 insertions, 0 deletions

diff --git a/src/features/announcements/store.js b/src/features/announcements/store.js
new file mode 100644
index 000000000..0bebf29fd
--- /dev/null
+++ b/src/features/announcements/store.js
@@ -0,0 +1,128 @@
+import {
+  action,
+  computed,
+  observable,
+  reaction,
+} from 'mobx';
+import semver from 'semver';
+import localStorage from 'mobx-localstorage';
+
+import { FeatureStore } from '../utils/FeatureStore';
+import { getAnnouncementRequest, getChangelogRequest, getCurrentVersionRequest } from './api';
+import { announcementActions } from './actions';
+import { createActionBindings } from '../utils/ActionBinding';
+import { createReactions } from '../../stores/lib/Reaction';
+
+const LOCAL_STORAGE_KEY = 'announcements';
+
+const debug = require('debug')('Franz:feature:announcements:store');
+
+export class AnnouncementsStore extends FeatureStore {
+  @observable targetVersion = null;
+
+  @observable isAnnouncementVisible = false;
+
+  @observable isFeatureActive = false;
+
+  @computed get changelog() {
+    return getChangelogRequest.result;
+  }
+
+  @computed get announcement() {
+    return getAnnouncementRequest.result;
+  }
+
+  @computed get settings() {
+    return localStorage.getItem(LOCAL_STORAGE_KEY) || {};
+  }
+
+  @computed get lastSeenAnnouncementVersion() {
+    return this.settings.lastSeenAnnouncementVersion || null;
+  }
+
+  @computed get currentVersion() {
+    return getCurrentVersionRequest.result;
+  }
+
+  @computed get isNewUser() {
+    return this.stores.settings.stats.appStarts <= 1;
+  }
+
+  async start(stores, actions) {
+    debug('AnnouncementsStore::start');
+    this.stores = stores;
+    this.actions = actions;
+    getCurrentVersionRequest.execute();
+
+    this._registerActions(createActionBindings([
+      [announcementActions.show, this._showAnnouncement],
+    ]));
+
+    this._reactions = createReactions([
+      this._fetchAnnouncements,
+      this._showAnnouncementToUsersWhoUpdatedApp,
+    ]);
+    this._registerReactions(this._reactions);
+    this.isFeatureActive = true;
+  }
+
+  stop() {
+    super.stop();
+    debug('AnnouncementsStore::stop');
+    this.isFeatureActive = false;
+    this.isAnnouncementVisible = false;
+  }
+
+  // ======= HELPERS ======= //
+
+  _updateSettings = (changes) => {
+    localStorage.setItem(LOCAL_STORAGE_KEY, {
+      ...this.settings,
+      ...changes,
+    });
+  };
+
+  // ======= ACTIONS ======= //
+
+  @action _showAnnouncement = ({ targetVersion } = {}) => {
+    this.targetVersion = targetVersion || this.currentVersion;
+    this.isAnnouncementVisible = true;
+    this.actions.service.blurActive();
+    this._updateSettings({
+      lastSeenAnnouncementVersion: this.currentVersion,
+    });
+    const dispose = reaction(
+      () => this.stores.services.active,
+      () => {
+        this._hideAnnouncement();
+        dispose();
+      },
+    );
+  };
+
+  @action _hideAnnouncement() {
+    this.isAnnouncementVisible = false;
+  }
+
+  // ======= REACTIONS ========
+
+  _showAnnouncementToUsersWhoUpdatedApp = () => {
+    const { announcement, isNewUser } = this;
+    // Check if there is an announcement and on't show announcements to new users
+    if (!announcement || isNewUser) return;
+
+    // Check if the user has already used current version (= has seen the announcement)
+    const { currentVersion, lastSeenAnnouncementVersion } = this;
+    if (semver.gt(currentVersion, lastSeenAnnouncementVersion)) {
+      debug(`${currentVersion} < ${lastSeenAnnouncementVersion}: announcement is shown`);
+      this._showAnnouncement();
+    }
+  };
+
+  _fetchAnnouncements = () => {
+    const targetVersion = this.targetVersion || this.currentVersion;
+    if (!targetVersion) return;
+    getChangelogRequest.execute(targetVersion);
+    getAnnouncementRequest.execute(targetVersion);
+  }
+}