aboutsummaryrefslogtreecommitdiffstats
path: root/src/stores/FeaturesStore.ts
blob: 6167d0e22141c1e3cf9579f41b00df5e1c87eb9c (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import {
  action,
  computed,
  makeObservable,
  observable,
  runInAction,
} from 'mobx';
import type { Stores } from '../@types/stores.types';
import type { Actions } from '../actions/lib/actions';
import type { ApiInterface } from '../api';
import appearance from '../features/appearance';
import basicAuth from '../features/basicAuth';
import communityRecipes from '../features/communityRecipes';
import publishDebugInfo from '../features/publishDebugInfo';
import quickSwitch from '../features/quickSwitch';
import serviceProxy from '../features/serviceProxy';
import todos from '../features/todos';
import workspaces from '../features/workspaces';
import CachedRequest from './lib/CachedRequest';
import TypedStore from './lib/TypedStore';

export default class FeaturesStore extends TypedStore {
  @observable features = {};

  constructor(stores: Stores, api: ApiInterface, actions: Actions) {
    super(stores, api, actions);

    makeObservable(this);
  }

  @observable defaultFeaturesRequest = new CachedRequest(
    this.api.features,
    'default',
  );

  @observable featuresRequest = new CachedRequest(
    this.api.features,
    'features',
  );

  async setup(): Promise<void> {
    this.registerReactions([
      this._updateFeatures,
      this._monitorLoginStatus.bind(this),
    ]);

    await this.featuresRequest.promise;
    setTimeout(this._setupFeatures.bind(this), 1);
  }

  @computed get anonymousFeatures(): any {
    return this.defaultFeaturesRequest.execute().result || {};
  }

  _updateFeatures = (): void => {
    const features = {};
    if (this.stores.user.isLoggedIn) {
      let requestResult = {};
      try {
        requestResult = this.featuresRequest.execute().result;
      } catch (error) {
        console.error(error);
      }
      Object.assign(features, requestResult);
    }
    runInAction(
      action('FeaturesStore::_updateFeatures', () => {
        this.features = features;
      }),
    );
  };

  _monitorLoginStatus(): void {
    if (this.stores.user.isLoggedIn) {
      this.featuresRequest.invalidate({ immediately: true });
    } else {
      this.defaultFeaturesRequest.execute();
      this.defaultFeaturesRequest.invalidate({ immediately: true });
    }
  }

  _setupFeatures(): void {
    serviceProxy(this.stores);
    basicAuth();
    workspaces(this.stores, this.actions);
    quickSwitch();
    publishDebugInfo();
    communityRecipes(this.stores, this.actions);
    todos(this.stores, this.actions);
    appearance(this.stores);
  }
}