aboutsummaryrefslogtreecommitdiffstats
path: root/src/features/workspaces/store.js
blob: a2997a0d2e7e0c9afdc62cd63d6e525d05b47317 (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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
import { observable, reaction, action } from 'mobx';
import Store from '../../stores/lib/Store';
import CachedRequest from '../../stores/lib/CachedRequest';
import Workspace from './models/Workspace';
import { matchRoute } from '../../helpers/routing-helpers';
import workspaceActions from './actions';

const debug = require('debug')('Franz:feature:workspaces');

export default class WorkspacesStore extends Store {
  @observable allWorkspacesRequest = new CachedRequest(this.api, 'getUserWorkspaces');

  constructor(stores, api, actions, state) {
    super(stores, api, actions);
    this.state = state;
  }

  setup() {
    debug('fetching workspaces');
    this.allWorkspacesRequest.execute();

    /**
     * Update the state workspaces array when workspaces request has results.
     */
    reaction(
      () => this.allWorkspacesRequest.result,
      workspaces => this._setWorkspaces(workspaces),
    );
    /**
     * Update the loading state when workspace request is executing.
     */
    reaction(
      () => this.allWorkspacesRequest.isExecuting,
      isExecuting => this._setIsLoading(isExecuting),
    );
    /**
     * Update the state with the workspace to be edited when route matches.
     */
    reaction(
      () => ({
        pathname: this.stores.router.location.pathname,
        workspaces: this.state.workspaces,
      }),
      ({ pathname }) => {
        const match = matchRoute('/settings/workspaces/edit/:id', pathname);
        if (match) {
          this.state.workspaceBeingEdited = this._getWorkspaceById(match.id);
        }
      },
    );

    workspaceActions.edit.listen(this._edit);
    workspaceActions.create.listen(this._create);
    workspaceActions.delete.listen(this._delete);
    workspaceActions.update.listen(this._update);
    workspaceActions.activate.listen(this._setActiveWorkspace);
    workspaceActions.deactivate.listen(this._deactivateActiveWorkspace);
  }

  _getWorkspaceById = id => this.state.workspaces.find(w => w.id === id);

  @action _setWorkspaces = (workspaces) => {
    debug('setting user workspaces', workspaces.slice());
    this.state.workspaces = workspaces.map(data => new Workspace(data));
  };

  @action _setIsLoading = (isLoading) => {
    this.state.isLoading = isLoading;
  };

  @action _edit = ({ workspace }) => {
    this.stores.router.push(`/settings/workspaces/edit/${workspace.id}`);
  };

  @action _create = async ({ name }) => {
    try {
      const result = await this.api.createWorkspace(name);
      const workspace = new Workspace(result);
      this.state.workspaces.push(workspace);
      this._edit({ workspace });
    } catch (error) {
      throw error;
    }
  };

  @action _delete = async ({ workspace }) => {
    try {
      await this.api.deleteWorkspace(workspace);
      this.state.workspaces.remove(workspace);
      this.stores.router.push('/settings/workspaces');
    } catch (error) {
      throw error;
    }
  };

  @action _update = async ({ workspace }) => {
    try {
      await this.api.updateWorkspace(workspace);
      const localWorkspace = this.state.workspaces.find(ws => ws.id === workspace.id);
      Object.assign(localWorkspace, workspace);
      this.stores.router.push('/settings/workspaces');
    } catch (error) {
      throw error;
    }
  };

  @action _setActiveWorkspace = ({ workspace }) => {
    this.state.activeWorkspace = workspace;
  };

  @action _deactivateActiveWorkspace = () => {
    this.state.activeWorkspace = null;
  };
}