import { action, computed, observable, makeObservable, runInAction } from "mobx"; // types import { ICycle, TCycleView, TCycleLayout, CycleDateCheckData, IIssue } from "types"; // mobx import { RootStore } from "../root"; // services import { ProjectService } from "services/project"; import { IssueService } from "services/issue"; import { CycleService } from "services/cycle.service"; import { getDateRangeStatus } from "helpers/date-time.helper"; export interface ICycleStore { loader: boolean; error: any | null; cycleView: TCycleView; cycleLayout: TCycleLayout; cycleId: string | null; cycles: { [projectId: string]: { [filterType: string]: ICycle[]; }; }; cycle_details: { [cycleId: string]: ICycle; }; active_cycle_issues: { [cycleId: string]: IIssue[]; }; // computed getCycleById: (cycleId: string) => ICycle | null; projectCycles: ICycle[] | null; projectCompletedCycles: ICycle[] | null; projectUpcomingCycles: ICycle[] | null; projectDraftCycles: ICycle[] | null; // actions setCycleView: (_cycleView: TCycleView) => void; setCycleLayout: (_cycleLayout: TCycleLayout) => void; setCycleId: (cycleId: string | null) => void; validateDate: (workspaceSlug: string, projectId: string, payload: CycleDateCheckData) => Promise; fetchCycles: ( workspaceSlug: string, projectId: string, params: "all" | "current" | "upcoming" | "draft" | "completed" | "incomplete" ) => Promise; fetchCycleWithId: (workspaceSlug: string, projectId: string, cycleId: string) => Promise; fetchActiveCycleIssues: (workspaceSlug: string, projectId: string, cycleId: string) => Promise; createCycle: (workspaceSlug: string, projectId: string, data: Partial) => Promise; patchCycle: (workspaceSlug: string, projectId: string, cycleId: string, data: Partial) => Promise; removeCycle: (workspaceSlug: string, projectId: string, cycleId: string) => Promise; addCycleToFavorites: (workspaceSlug: string, projectId: string, cycle: ICycle) => Promise; removeCycleFromFavorites: (workspaceSlug: string, projectId: string, cycle: ICycle) => Promise; } export class CycleStore implements ICycleStore { loader: boolean = false; error: any | null = null; cycleView: TCycleView = "all"; cycleLayout: TCycleLayout = "list"; cycleId: string | null = null; cycles: { [projectId: string]: { [filterType: string]: ICycle[]; }; } = {}; cycle_details: { [cycleId: string]: ICycle; } = {}; active_cycle_issues: { [cycleId: string]: IIssue[]; } = {}; // root store rootStore; // services projectService; issueService; cycleService; constructor(_rootStore: RootStore) { makeObservable(this, { loader: observable, error: observable.ref, cycleView: observable, cycleLayout: observable, cycleId: observable, cycles: observable.ref, cycle_details: observable.ref, active_cycle_issues: observable.ref, // computed projectCycles: computed, projectCompletedCycles: computed, projectUpcomingCycles: computed, projectDraftCycles: computed, // actions setCycleView: action, setCycleLayout: action, setCycleId: action, getCycleById: action, fetchCycles: action, fetchCycleWithId: action, fetchActiveCycleIssues: action, createCycle: action, removeCycle: action, addCycleToFavorites: action, removeCycleFromFavorites: action, }); this.rootStore = _rootStore; this.projectService = new ProjectService(); this.issueService = new IssueService(); this.cycleService = new CycleService(); } // computed get projectCycles() { const projectId = this.rootStore.project.projectId; if (!projectId) return null; return this.cycles[projectId]?.all || null; } get projectCompletedCycles() { const projectId = this.rootStore.project.projectId; if (!projectId) return null; return this.cycles[projectId]?.completed || null; } get projectUpcomingCycles() { const projectId = this.rootStore.project.projectId; if (!projectId) return null; return this.cycles[projectId]?.upcoming || null; } get projectDraftCycles() { const projectId = this.rootStore.project.projectId; if (!projectId) return null; return this.cycles[projectId]?.draft || null; } getCycleById = (cycleId: string) => this.cycle_details[cycleId] || null; // actions setCycleView = (_cycleView: TCycleView) => (this.cycleView = _cycleView); setCycleLayout = (_cycleLayout: TCycleLayout) => (this.cycleLayout = _cycleLayout); setCycleId = (cycleId: string | null) => (this.cycleId = cycleId); validateDate = async (workspaceSlug: string, projectId: string, payload: CycleDateCheckData) => { try { const response = await this.cycleService.cycleDateCheck(workspaceSlug, projectId, payload); return response; } catch (error) { console.log("Failed to validate cycle dates", error); throw error; } }; fetchCycles = async ( workspaceSlug: string, projectId: string, params: "all" | "current" | "upcoming" | "draft" | "completed" | "incomplete" ) => { try { this.loader = true; this.error = null; const cyclesResponse = await this.cycleService.getCyclesWithParams(workspaceSlug, projectId, params); if (this.cycleView === "active") this.fetchActiveCycleIssues(workspaceSlug, projectId, cyclesResponse[0].id); runInAction(() => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [params]: cyclesResponse }, }; this.loader = false; this.error = null; }); } catch (error) { console.error("Failed to fetch project cycles in project store", error); this.loader = false; this.error = error; } }; fetchCycleWithId = async (workspaceSlug: string, projectId: string, cycleId: string) => { try { const response = await this.cycleService.getCycleDetails(workspaceSlug, projectId, cycleId); runInAction(() => { this.cycle_details = { ...this.cycle_details, [response?.id]: response, }; }); return response; } catch (error) { console.log("Failed to fetch cycle detail from cycle store"); throw error; } }; fetchActiveCycleIssues = async (workspaceSlug: string, projectId: string, cycleId: string) => { try { const _cycleIssues = await this.cycleService.getCycleIssuesWithParams(workspaceSlug, projectId, cycleId, { priority: `urgent,high`, }); const _activeCycleIssues = { ...this.active_cycle_issues, [cycleId]: Object.values(_cycleIssues) as IIssue[], }; runInAction(() => { this.active_cycle_issues = _activeCycleIssues; }); return _activeCycleIssues; } catch (error) { console.log("error"); } }; createCycle = async (workspaceSlug: string, projectId: string, data: Partial) => { try { const response = await this.cycleService.createCycle(workspaceSlug, projectId, data); runInAction(() => { this.cycle_details = { ...this.cycle_details, [response?.id]: response, }; }); const _currentView = this.cycleView === "active" ? "current" : this.cycleView; this.fetchCycles(workspaceSlug, projectId, _currentView); return response; } catch (error) { console.log("Failed to create cycle from cycle store"); throw error; } }; patchCycle = async (workspaceSlug: string, projectId: string, cycleId: string, data: Partial) => { try { const _response = await this.cycleService.patchCycle(workspaceSlug, projectId, cycleId, data); const _cycleDetails = { ...this.cycle_details, [cycleId]: { ...this.cycle_details[cycleId], ..._response }, }; runInAction(() => { this.cycle_details = _cycleDetails; }); const _currentView = this.cycleView === "active" ? "current" : this.cycleView; this.fetchCycles(workspaceSlug, projectId, _currentView); return _response; } catch (error) { console.log("Failed to patch cycle from cycle store"); throw error; } }; removeCycle = async (workspaceSlug: string, projectId: string, cycleId: string) => { try { const _response = await this.cycleService.deleteCycle(workspaceSlug, projectId, cycleId); const _currentView = this.cycleView === "active" ? "current" : this.cycleView; runInAction(() => { ["all", "current", "completed", "upcoming", "draft"].forEach((view) => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [view]: this.cycles[projectId][view]?.filter((c) => c.id !== cycleId), }, }; }); }); this.fetchCycles(workspaceSlug, projectId, _currentView); return _response; } catch (error) { console.log("Failed to delete cycle from cycle store"); throw error; } }; addCycleToFavorites = async (workspaceSlug: string, projectId: string, cycle: ICycle) => { const cycleStatus = getDateRangeStatus(cycle.start_date, cycle.end_date); const statusCyclesList = this.cycles[projectId]?.[cycleStatus] ?? []; const allCyclesList = this.projectCycles ?? []; try { runInAction(() => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [cycleStatus]: statusCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: true }; return c; }), all: allCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: true }; return c; }), }, }; this.cycle_details = { ...this.cycle_details, [cycle.id]: { ...this.cycle_details[cycle.id], is_favorite: true }, }; }); // updating through api. const response = await this.cycleService.addCycleToFavorites(workspaceSlug, projectId, { cycle: cycle.id }); return response; } catch (error) { console.log("Failed to add cycle to favorites in the cycles store", error); // reset on error runInAction(() => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [cycleStatus]: statusCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: false }; return c; }), all: allCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: false }; return c; }), }, }; this.cycle_details = { ...this.cycle_details, [cycle.id]: { ...this.cycle_details[cycle.id], is_favorite: false }, }; }); throw error; } }; removeCycleFromFavorites = async (workspaceSlug: string, projectId: string, cycle: ICycle) => { const cycleStatus = getDateRangeStatus(cycle.start_date, cycle.end_date); const statusCyclesList = this.cycles[projectId]?.[cycleStatus] ?? []; const allCyclesList = this.projectCycles ?? []; try { runInAction(() => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [cycleStatus]: statusCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: false }; return c; }), all: allCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: false }; return c; }), }, }; this.cycle_details = { ...this.cycle_details, [cycle.id]: { ...this.cycle_details[cycle.id], is_favorite: false }, }; }); const response = await this.cycleService.removeCycleFromFavorites(workspaceSlug, projectId, cycle.id); return response; } catch (error) { console.log("Failed to remove cycle from favorites - Cycle Store", error); // reset on error runInAction(() => { this.cycles = { ...this.cycles, [projectId]: { ...this.cycles[projectId], [cycleStatus]: statusCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: true }; return c; }), all: allCyclesList?.map((c) => { if (c.id === cycle.id) return { ...c, is_favorite: true }; return c; }), }, }; this.cycle_details = { ...this.cycle_details, [cycle.id]: { ...this.cycle_details[cycle.id], is_favorite: true }, }; }); throw error; } }; }