import { makeObservable } from "mobx"; // services import { IssueArchiveService, IssueService } from "services/issue"; // types import { IIssueDetail } from "./root.store"; import { TIssue } from "@plane/types"; export interface IIssueStoreActions { // actions fetchIssue: (workspaceSlug: string, projectId: string, issueId: string, isArchived?: boolean) => Promise; updateIssue: (workspaceSlug: string, projectId: string, issueId: string, data: Partial) => Promise; removeIssue: (workspaceSlug: string, projectId: string, issueId: string) => Promise; addIssueToCycle: (workspaceSlug: string, projectId: string, cycleId: string, issueIds: string[]) => Promise; removeIssueFromCycle: (workspaceSlug: string, projectId: string, cycleId: string, issueId: string) => Promise; addIssueToModule: (workspaceSlug: string, projectId: string, moduleId: string, issueIds: string[]) => Promise; removeIssueFromModule: ( workspaceSlug: string, projectId: string, moduleId: string, issueId: string ) => Promise; } export interface IIssueStore extends IIssueStoreActions { // helper methods getIssueById: (issueId: string) => TIssue | undefined; } export class IssueStore implements IIssueStore { // root store rootIssueDetailStore: IIssueDetail; // services issueService; issueArchiveService; constructor(rootStore: IIssueDetail) { makeObservable(this, {}); // root store this.rootIssueDetailStore = rootStore; // services this.issueService = new IssueService(); this.issueArchiveService = new IssueArchiveService(); } // helper methods getIssueById = (issueId: string) => { if (!issueId) return undefined; return this.rootIssueDetailStore.rootIssueStore.issues.getIssueById(issueId) ?? undefined; }; // actions fetchIssue = async (workspaceSlug: string, projectId: string, issueId: string, isArchived = false) => { try { const query = { expand: "state,assignees,labels,parent", }; let issue: any; if (isArchived) issue = await this.issueArchiveService.retrieveArchivedIssue(workspaceSlug, projectId, issueId); else issue = await this.issueService.retrieve(workspaceSlug, projectId, issueId, query); if (!issue) throw new Error("Issue not found"); this.rootIssueDetailStore.rootIssueStore.issues.addIssue([issue]); // store handlers from issue detail // parent if (issue && issue?.parent && issue?.parent?.id) this.rootIssueDetailStore.rootIssueStore.issues.addIssue([issue?.parent]); // assignees // labels // state // issue reactions this.rootIssueDetailStore.reaction.fetchReactions(workspaceSlug, projectId, issueId); // fetch issue links this.rootIssueDetailStore.link.fetchLinks(workspaceSlug, projectId, issueId); // fetch issue attachments this.rootIssueDetailStore.attachment.fetchAttachments(workspaceSlug, projectId, issueId); // fetch issue activity this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueId); // fetch issue comments this.rootIssueDetailStore.comment.fetchComments(workspaceSlug, projectId, issueId); // fetch issue subscription this.rootIssueDetailStore.subscription.fetchSubscriptions(workspaceSlug, projectId, issueId); // fetch sub issues this.rootIssueDetailStore.subIssues.fetchSubIssues(workspaceSlug, projectId, issueId); // fetch issue relations this.rootIssueDetailStore.relation.fetchRelations(workspaceSlug, projectId, issueId); // fetching states // TODO: check if this function is required this.rootIssueDetailStore.rootIssueStore.state.fetchProjectStates(workspaceSlug, projectId); return issue; } catch (error) { throw error; } }; updateIssue = async (workspaceSlug: string, projectId: string, issueId: string, data: Partial) => { const issue = await this.rootIssueDetailStore.rootIssueStore.projectIssues.updateIssue( workspaceSlug, projectId, issueId, data ); await this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueId); return issue; }; removeIssue = async (workspaceSlug: string, projectId: string, issueId: string) => this.rootIssueDetailStore.rootIssueStore.projectIssues.removeIssue(workspaceSlug, projectId, issueId); addIssueToCycle = async (workspaceSlug: string, projectId: string, cycleId: string, issueIds: string[]) => { const cycle = await this.rootIssueDetailStore.rootIssueStore.cycleIssues.addIssueToCycle( workspaceSlug, projectId, cycleId, issueIds ); if (issueIds && issueIds.length > 0) await this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueIds[0]); return cycle; }; removeIssueFromCycle = async (workspaceSlug: string, projectId: string, cycleId: string, issueId: string) => { const cycle = await this.rootIssueDetailStore.rootIssueStore.cycleIssues.removeIssueFromCycle( workspaceSlug, projectId, cycleId, issueId ); await this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueId); return cycle; }; addIssueToModule = async (workspaceSlug: string, projectId: string, moduleId: string, issueIds: string[]) => { const _module = await this.rootIssueDetailStore.rootIssueStore.moduleIssues.addIssueToModule( workspaceSlug, projectId, moduleId, issueIds ); if (issueIds && issueIds.length > 0) await this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueIds[0]); return _module; }; removeIssueFromModule = async (workspaceSlug: string, projectId: string, moduleId: string, issueId: string) => { const _module = await this.rootIssueDetailStore.rootIssueStore.moduleIssues.removeIssueFromModule( workspaceSlug, projectId, moduleId, issueId ); await this.rootIssueDetailStore.activity.fetchActivities(workspaceSlug, projectId, issueId); return _module; }; }