import { observable, action, makeObservable, runInAction, autorun } from "mobx"; // services import { ProjectService } from "services/project"; import { WorkspaceService } from "services/workspace.service"; // helpers import { handleIssueQueryParamsByLayout } from "helpers/issue.helper"; // types import { RootStore } from "../root"; import { IIssue, IIssueFilterOptions, TStaticViewTypes } from "types"; export interface IGlobalViewIssuesStore { // states loader: boolean; error: any | null; // observables viewIssues: { [viewId: string]: IIssue[]; }; // actions fetchViewIssues: (workspaceSlug: string, viewId: string, filters: IIssueFilterOptions) => Promise; fetchStaticIssues: (workspaceSlug: string, type: TStaticViewTypes) => Promise; } export class GlobalViewIssuesStore implements IGlobalViewIssuesStore { // states loader: boolean = false; error: any | null = null; // observables viewIssues: { [viewId: string]: IIssue[]; } = {}; // root store rootStore; // services projectService; workspaceService; constructor(_rootStore: RootStore) { makeObservable(this, { // states loader: observable.ref, error: observable.ref, // observables viewIssues: observable.ref, // actions fetchViewIssues: action, fetchStaticIssues: action, }); this.rootStore = _rootStore; this.projectService = new ProjectService(); this.workspaceService = new WorkspaceService(); autorun(() => { const workspaceSlug = this.rootStore.workspace.workspaceSlug; const globalViewId = this.rootStore.globalViews.globalViewId; if ( workspaceSlug && globalViewId && this.rootStore.globalViewFilters.storedFilters[globalViewId] && this.rootStore.issueFilter.userDisplayFilters ) this.fetchViewIssues(workspaceSlug, globalViewId, this.rootStore.globalViewFilters.storedFilters[globalViewId]); }); } computedFilter = (filters: any, filteredParams: any) => { const computedFilters: any = {}; Object.keys(filters).map((key) => { if (filters[key] != undefined && filteredParams.includes(key)) computedFilters[key] = typeof filters[key] === "string" || typeof filters[key] === "boolean" ? filters[key] : filters[key].join(","); }); return computedFilters; }; fetchViewIssues = async (workspaceSlug: string, viewId: string, filters: IIssueFilterOptions) => { try { runInAction(() => { this.loader = true; }); const displayFilters = this.rootStore.workspaceFilter.workspaceDisplayFilters; let filteredRouteParams: any = { priority: filters?.priority || undefined, project: filters?.project || undefined, state_group: filters?.state_group || undefined, state: filters?.state || undefined, assignees: filters?.assignees || undefined, created_by: filters?.created_by || undefined, labels: filters?.labels || undefined, start_date: filters?.start_date || undefined, target_date: filters?.target_date || undefined, order_by: displayFilters?.order_by || "-created_at", type: displayFilters?.type || undefined, sub_issue: false, }; const filteredParams = handleIssueQueryParamsByLayout("spreadsheet", "my_issues"); if (filteredParams) filteredRouteParams = this.computedFilter(filteredRouteParams, filteredParams); const response = await this.workspaceService.getViewIssues(workspaceSlug, filteredRouteParams); runInAction(() => { this.loader = false; this.viewIssues = { ...this.viewIssues, [viewId]: response as IIssue[], }; }); return response; } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); throw error; } }; fetchStaticIssues = async (workspaceSlug: string, type: TStaticViewTypes) => { try { runInAction(() => { this.loader = true; }); const workspaceMemberResponse = await this.rootStore.workspaceFilter.fetchUserWorkspaceFilters(workspaceSlug); const displayFilters = workspaceMemberResponse.view_props.display_filters; let filteredRouteParams: any = { order_by: displayFilters?.order_by || "-created_at", type: displayFilters?.type || undefined, sub_issue: false, }; const filteredParams = handleIssueQueryParamsByLayout("spreadsheet", "my_issues"); if (filteredParams) filteredRouteParams = this.computedFilter(filteredRouteParams, filteredParams); const currentUser = this.rootStore.user.currentUser; if (type === "assigned" && currentUser) filteredRouteParams.assignees = currentUser.id; if (type === "created" && currentUser) filteredRouteParams.created_by = currentUser.id; if (type === "subscribed" && currentUser) filteredRouteParams.subscriber = currentUser.id; const response = await this.workspaceService.getViewIssues(workspaceSlug, filteredRouteParams); runInAction(() => { this.loader = false; this.viewIssues = { ...this.viewIssues, [type]: response as IIssue[], }; }); return response; } catch (error) { runInAction(() => { this.loader = false; this.error = error; }); throw error; } }; }