forked from github/plane
105 lines
3.1 KiB
TypeScript
105 lines
3.1 KiB
TypeScript
import set from "lodash/set";
|
|
import isEmpty from "lodash/isEmpty";
|
|
// store
|
|
import { action, makeObservable, observable, runInAction } from "mobx";
|
|
import { computedFn } from "mobx-utils";
|
|
// types
|
|
import { TIssue } from "@plane/types";
|
|
|
|
export type IIssueStore = {
|
|
// observables
|
|
issuesMap: Record<string, TIssue>; // Record defines issue_id as key and TIssue as value
|
|
// actions
|
|
addIssue(issues: TIssue[]): void;
|
|
updateIssue(issueId: string, issue: Partial<TIssue>): void;
|
|
removeIssue(issueId: string): void;
|
|
// helper methods
|
|
getIssueById(issueId: string): undefined | TIssue;
|
|
getIssuesByIds(issueIds: string[]): undefined | Record<string, TIssue>; // Record defines issue_id as key and TIssue as value
|
|
};
|
|
|
|
export class IssueStore implements IIssueStore {
|
|
// observables
|
|
issuesMap: { [issue_id: string]: TIssue } = {};
|
|
|
|
constructor() {
|
|
makeObservable(this, {
|
|
// observable
|
|
issuesMap: observable,
|
|
// actions
|
|
addIssue: action,
|
|
updateIssue: action,
|
|
removeIssue: action,
|
|
});
|
|
}
|
|
|
|
// actions
|
|
/**
|
|
* @description This method will add issues to the issuesMap
|
|
* @param {TIssue[]} issues
|
|
* @returns {void}
|
|
*/
|
|
addIssue = (issues: TIssue[]) => {
|
|
if (issues && issues.length <= 0) return;
|
|
runInAction(() => {
|
|
issues.forEach((issue) => {
|
|
if (!this.issuesMap[issue.id]) set(this.issuesMap, issue.id, issue);
|
|
});
|
|
});
|
|
};
|
|
|
|
/**
|
|
* @description This method will update the issue in the issuesMap
|
|
* @param {string} issueId
|
|
* @param {Partial<TIssue>} issue
|
|
* @returns {void}
|
|
*/
|
|
updateIssue = (issueId: string, issue: Partial<TIssue>) => {
|
|
if (!issue || !issueId || isEmpty(this.issuesMap) || !this.issuesMap[issueId]) return;
|
|
runInAction(() => {
|
|
Object.keys(issue).forEach((key) => {
|
|
set(this.issuesMap, [issueId, key], issue[key as keyof TIssue]);
|
|
});
|
|
});
|
|
};
|
|
|
|
/**
|
|
* @description This method will remove the issue from the issuesMap
|
|
* @param {string} issueId
|
|
* @returns {void}
|
|
*/
|
|
removeIssue = (issueId: string) => {
|
|
if (!issueId || isEmpty(this.issuesMap) || !this.issuesMap[issueId]) return;
|
|
runInAction(() => {
|
|
delete this.issuesMap[issueId];
|
|
});
|
|
};
|
|
|
|
// helper methods
|
|
/**
|
|
* @description This method will return the issue from the issuesMap
|
|
* @param {string} issueId
|
|
* @returns {TIssue | undefined}
|
|
*/
|
|
getIssueById = computedFn((issueId: string) => {
|
|
if (!issueId || isEmpty(this.issuesMap) || !this.issuesMap[issueId]) return undefined;
|
|
return this.issuesMap[issueId];
|
|
});
|
|
|
|
/**
|
|
* @description This method will return the issues from the issuesMap
|
|
* @param {string[]} issueIds
|
|
* @returns {Record<string, TIssue> | undefined}
|
|
*/
|
|
getIssuesByIds = computedFn((issueIds: string[]) => {
|
|
if (!issueIds || issueIds.length <= 0 || isEmpty(this.issuesMap)) return undefined;
|
|
const filteredIssues: { [key: string]: TIssue } = {};
|
|
Object.values(this.issuesMap).forEach((issue) => {
|
|
if (issueIds.includes(issue.id)) {
|
|
filteredIssues[issue.id] = issue;
|
|
}
|
|
});
|
|
return isEmpty(filteredIssues) ? undefined : filteredIssues;
|
|
});
|
|
}
|