import { action, computed, observable, makeObservable, runInAction } from "mobx"; import { RootStore } from "../root"; // types import { IIssueLabels, IProject, IWorkspace, IWorkspaceMember } from "types"; // services import { WorkspaceService } from "services/workspace.service"; import { ProjectService } from "services/project"; import { IssueService, IssueLabelService } from "services/issue"; export interface IWorkspaceStore { // states loader: boolean; error: any | null; // observables workspaceSlug: string | null; workspaces: IWorkspace[] | undefined; labels: { [workspaceSlug: string]: IIssueLabels[] }; // workspaceSlug: labels[] // actions setWorkspaceSlug: (workspaceSlug: string) => void; getWorkspaceBySlug: (workspaceSlug: string) => IWorkspace | null; getWorkspaceLabelById: (workspaceSlug: string, labelId: string) => IIssueLabels | null; fetchWorkspaces: () => Promise; fetchWorkspaceLabels: (workspaceSlug: string) => Promise; // workspace write operations createWorkspace: (data: Partial) => Promise; updateWorkspace: (workspaceSlug: string, data: Partial) => Promise; deleteWorkspace: (workspaceSlug: string) => Promise; // computed currentWorkspace: IWorkspace | null; workspacesCreateByCurrentUser: IWorkspace[] | null; workspaceLabels: IIssueLabels[] | null; } export class WorkspaceStore implements IWorkspaceStore { // states loader: boolean = false; error: any | null = null; // observables workspaceSlug: string | null = null; workspaces: IWorkspace[] | undefined = []; projects: { [workspaceSlug: string]: IProject[] } = {}; // workspaceSlug: project[] labels: { [workspaceSlug: string]: IIssueLabels[] } = {}; members: { [workspaceSlug: string]: IWorkspaceMember[] } = {}; // services workspaceService; projectService; issueService; issueLabelService; // root store rootStore; constructor(_rootStore: RootStore) { makeObservable(this, { // states loader: observable.ref, error: observable.ref, // observables workspaceSlug: observable.ref, workspaces: observable.ref, labels: observable.ref, // actions setWorkspaceSlug: action, getWorkspaceBySlug: action, getWorkspaceLabelById: action, fetchWorkspaces: action, fetchWorkspaceLabels: action, // workspace write operations createWorkspace: action, updateWorkspace: action, deleteWorkspace: action, // computed currentWorkspace: computed, workspaceLabels: computed, }); this.rootStore = _rootStore; this.workspaceService = new WorkspaceService(); this.projectService = new ProjectService(); this.issueService = new IssueService(); this.issueLabelService = new IssueLabelService(); } /** * computed value of current workspace based on workspace id saved in the store */ get currentWorkspace() { if (!this.workspaceSlug) return null; return this.workspaces?.find((workspace) => workspace.slug === this.workspaceSlug) || null; } /** * computed value of all the workspaces created by the current logged in user */ get workspacesCreateByCurrentUser() { if (!this.workspaces) return null; const user = this.rootStore.user.currentUser; if (!user) return null; return this.workspaces.filter((w) => w.created_by === user?.id); } /** * computed value of workspace labels using the workspace slug from the store */ get workspaceLabels() { if (!this.workspaceSlug) return []; const _labels = this.labels?.[this.workspaceSlug]; return _labels && Object.keys(_labels).length > 0 ? _labels : []; } /** * set workspace slug in the store * @param workspaceSlug * @returns */ setWorkspaceSlug = (workspaceSlug: string) => (this.workspaceSlug = workspaceSlug); /** * fetch workspace info from the array of workspaces in the store. * @param workspaceSlug */ getWorkspaceBySlug = (workspaceSlug: string) => this.workspaces?.find((w) => w.slug == workspaceSlug) || null; /** * get workspace label information from the workspace labels * @param labelId * @returns */ getWorkspaceLabelById = (workspaceSlug: string, labelId: string) => this.labels?.[workspaceSlug].find((label) => label.id === labelId) || null; /** * fetch user workspaces from API */ fetchWorkspaces = async () => { try { this.loader = true; this.error = null; const workspaceResponse = await this.workspaceService.userWorkspaces(); runInAction(() => { this.workspaces = workspaceResponse; this.loader = false; this.error = null; }); return workspaceResponse; } catch (error) { console.log("Failed to fetch user workspaces in workspace store", error); runInAction(() => { this.loader = false; this.error = error; this.workspaces = []; }); throw error; } }; /** * fetch workspace labels using workspace slug * @param workspaceSlug */ fetchWorkspaceLabels = async (workspaceSlug: string) => { try { runInAction(() => { this.loader = true; this.error = null; }); const labelsResponse = await this.issueLabelService.getWorkspaceIssueLabels(workspaceSlug); runInAction(() => { this.labels = { ...this.labels, [workspaceSlug]: labelsResponse, }; this.loader = false; this.error = null; }); } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); } }; /** * create workspace using the workspace data * @param data */ createWorkspace = async (data: Partial) => { try { runInAction(() => { this.loader = true; this.error = null; }); const user = this.rootStore.user.currentUser ?? undefined; const response = await this.workspaceService.createWorkspace(data, user); runInAction(() => { this.loader = false; this.error = null; this.workspaces = [...(this.workspaces ?? []), response]; }); return response; } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); throw error; } }; /** * update workspace using the workspace slug and new workspace data * @param workspaceSlug * @param data */ updateWorkspace = async (workspaceSlug: string, data: Partial) => { const newWorkspaces = this.workspaces?.map((w) => (w.slug === workspaceSlug ? { ...w, ...data } : w)); try { runInAction(() => { this.loader = true; this.error = null; }); const user = this.rootStore.user.currentUser ?? undefined; const response = await this.workspaceService.updateWorkspace(workspaceSlug, data, user); runInAction(() => { this.loader = false; this.error = null; this.workspaces = newWorkspaces; }); return response; } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); throw error; } }; /** * delete workspace using the workspace slug * @param workspaceSlug */ deleteWorkspace = async (workspaceSlug: string) => { const newWorkspaces = this.workspaces?.filter((w) => w.slug !== workspaceSlug); try { runInAction(() => { this.loader = true; this.error = null; }); const user = this.rootStore.user.currentUser ?? undefined; await this.workspaceService.deleteWorkspace(workspaceSlug, user); runInAction(() => { this.loader = false; this.error = null; this.workspaces = newWorkspaces; }); } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); throw error; } }; }