bb-plane-fork/apps/space/store/members.store.ts

/**
 * Copyright (c) 2023-present Plane Software, Inc. and contributors
 * SPDX-License-Identifier: AGPL-3.0-only
 * See the LICENSE file for details.
 */

import { set } from "lodash-es";
import { action, computed, makeObservable, observable, runInAction } from "mobx";
// plane imports
import { SitesMemberService } from "@plane/services";
import type { TPublicMember } from "@/types/member";
import type { RootStore } from "./root.store";

export interface IIssueMemberStore {
  // observables
  members: TPublicMember[] | undefined;
  // computed actions
  getMemberById: (memberId: string | undefined) => TPublicMember | undefined;
  getMembersByIds: (memberIds: string[]) => TPublicMember[];
  // fetch actions
  fetchMembers: (anchor: string) => Promise<TPublicMember[]>;
}

export class MemberStore implements IIssueMemberStore {
  memberMap: Record<string, TPublicMember> = {};
  memberService: SitesMemberService;
  rootStore: RootStore;

  constructor(_rootStore: RootStore) {
    makeObservable(this, {
      // observables
      memberMap: observable,
      // computed
      members: computed,
      // fetch action
      fetchMembers: action,
    });
    this.memberService = new SitesMemberService();
    this.rootStore = _rootStore;
  }

  get members() {
    return Object.values(this.memberMap);
  }

  getMemberById = (memberId: string | undefined) => (memberId ? this.memberMap[memberId] : undefined);

  getMembersByIds = (memberIds: string[]) => {
    const currMembers = [];
    for (const memberId of memberIds) {
      const member = this.getMemberById(memberId);
      if (member) {
        currMembers.push(member);
      }
    }

    return currMembers;
  };

  fetchMembers = async (anchor: string) => {
    try {
      const membersResponse = await this.memberService.list(anchor);
      runInAction(() => {
        this.memberMap = {};
        for (const member of membersResponse) {
          set(this.memberMap, [member.member], member);
        }
      });
      return membersResponse;
    } catch (error) {
      console.error("Failed to fetch members:", error);
      return [];
    }
  };
}