chore: init webhook data store

web/services/webhook.service.ts

@@ -26,7 +26,7 @@ export class WebhookService extends APIService {
       });
   }
 
-  async createWebhook(workspaceSlug: string, data: {}): Promise<IWebhook> {
+  async createWebhook(workspaceSlug: string, data: Partial<IWebhook>): Promise<IWebhook> {
     return this.post(`/api/workspaces/${workspaceSlug}/webhooks/`, data)
       .then((response) => response?.data)
       .catch((error) => {
@@ -34,7 +34,7 @@ export class WebhookService extends APIService {
       });
   }
 
-  async updateWebhook(workspaceSlug: string, webhookId: string, data: {}): Promise<IWebhook> {
+  async updateWebhook(workspaceSlug: string, webhookId: string, data: Partial<IWebhook>): Promise<IWebhook> {
     return this.patch(`/api/workspaces/${workspaceSlug}/webhooks/${webhookId}/`, data)
       .then((response) => response?.data)
       .catch((error) => {

web/store/dataMaps/index.ts

@@ -1,11 +1,14 @@
+import { IWebhookData, WebhookData } from "./webhook.data.store";
 import { IWorkspaceData, WorkspaceData } from "./workspace.data.store";
 
 export class DataStore {
   workspace: IWorkspaceData;
+  webhook: IWebhookData;
 
   constructor() {
     this.workspace = new WorkspaceData(this);
+    this.webhook = new WebhookData(this);
   }
 
-  resetOnSignout() {}
+  resetOnSignOut() {}
 }

web/store/dataMaps/webhook.data.store.ts

@@ -0,0 +1,54 @@
+import { action, makeObservable, observable } from "mobx";
+import { computedFn } from "mobx-utils";
+import { set } from "lodash";
+// store
+import { DataStore } from ".";
+import { WebhookModel } from "store/webhook.store";
+// types
+import { IWebhook } from "@plane/types";
+
+export interface IWebhookData {
+  // observables
+  webhookMap: Record<string, WebhookModel>;
+  // actions
+  addWebhook: (webhooks: IWebhook) => void;
+  deleteWebhook: (webhookId: string) => void;
+  getWebhookById: (webhookId: string) => WebhookModel | undefined;
+}
+
+export class WebhookData implements IWebhookData {
+  // observables
+  webhookMap: Record<string, WebhookModel> = {};
+  // data store
+  dataStore;
+
+  constructor(_dataStore: DataStore) {
+    makeObservable(this, {
+      // observables
+      webhookMap: observable,
+      // actions
+      addWebhook: action,
+      deleteWebhook: action,
+    });
+    this.dataStore = _dataStore;
+  }
+
+  /**
+   * @description add a webhook to the webhook map
+   * @param {IWebhook} webhook
+   */
+  addWebhook = (webhook: IWebhook) => set(this.webhookMap, [webhook.id], new WebhookModel(webhook, this.dataStore));
+
+  /**
+   * @description delete a webhook from the webhook map
+   * @param {string} webhookId
+   */
+  deleteWebhook = (webhookId: string) => delete this.webhookMap[webhookId];
+
+  /**
+   * @description get a webhook model by its id
+   * @param {string} webhookId
+   * @returns {WebhookModel | undefined} webhook model
+   */
+  getWebhookById = computedFn((webhookId: string) => this.webhookMap[webhookId]);
+}

web/store/dataMaps/workspace.data.store.ts

@@ -1,37 +1,55 @@
-import { makeObservable, observable } from "mobx";
-import { WorkspaceModel } from "store/workspace.store";
-import { DataStore } from ".";
-import { IWorkspace } from "@plane/types";
+import { action, makeObservable, observable } from "mobx";
+import { computedFn } from "mobx-utils";
 import { set } from "lodash";
+// store
+import { DataStore } from ".";
+import { WorkspaceModel } from "store/workspace.store";
+// types
+import { IWorkspace } from "@plane/types";
 
 export interface IWorkspaceData {
+  // observables
   workspaceMap: Record<string, WorkspaceModel>;
-
+  // actions
   addWorkspace: (workspaces: IWorkspace) => void;
   deleteWorkspace: (workspaceId: string) => void;
-  getWorkspacebyId: (workspaceId: string) => WorkspaceModel | undefined;
+  getWorkspaceById: (workspaceId: string) => WorkspaceModel | undefined;
 }
 
 export class WorkspaceData implements IWorkspaceData {
+  // observables
   workspaceMap: Record<string, WorkspaceModel> = {};
-
   // data store
   dataStore;
 
   constructor(_dataStore: DataStore) {
     makeObservable(this, {
+      // observables
       workspaceMap: observable,
+      // actions
+      addWorkspace: action,
+      deleteWorkspace: action,
     });
     this.dataStore = _dataStore;
   }
 
-  addWorkspace = (workspace: IWorkspace) => {
+  /**
+   * @description add a workspace to the workspace map
+   * @param {IWorkspace} workspace
+   */
+  addWorkspace = (workspace: IWorkspace) =>
     set(this.workspaceMap, [workspace.id], new WorkspaceModel(workspace, this.dataStore));
-  };
 
-  deleteWorkspace = (workspaceId: string) => {
-    delete this.workspaceMap[workspaceId];
-  };
+  /**
+   * @description delete a workspace from the workspace map
+   * @param {string} workspaceId
+   */
+  deleteWorkspace = (workspaceId: string) => delete this.workspaceMap[workspaceId];
 
-  getWorkspacebyId = (workspaceId: string) => this.workspaceMap[workspaceId];
+  /**
+   * @description get a workspace model by its id
+   * @param {string} workspaceId
+   * @returns {WorkspaceModel | undefined} workspace model
+   */
+  getWorkspaceById = computedFn((workspaceId: string) => this.workspaceMap[workspaceId]);
 }

web/store/root.store.ts

@@ -12,5 +12,5 @@ export class RootStore {
     this.user = new UserModel(this.data);
   }
 
-  resetOnSignout() {}
+  resetOnSignOut() {}
 }

web/store/user.store.ts

@@ -26,14 +26,14 @@ export class UserModel implements IUserModel {
   }
 
   /**
-   * get workspace info from the array of workspaces in the store using workspace slug
-   * @param workspaceSlug
+   * @description get workspace info from the array of workspaces in the store using workspace slug
+   * @param {string} workspaceSlug
    */
   getWorkspaceBySlug = (workspaceSlug: string) =>
     Object.values(this.workspaces ?? {})?.find((w) => w.slug == workspaceSlug) || null;
 
   /**
-   * fetch user workspaces from API
+   * @description fetch user workspaces from API
    */
   fetchWorkspaces = async () => {
     const workspaceResponse = await this.workspaceService.userWorkspaces();
@@ -48,8 +48,8 @@ export class UserModel implements IUserModel {
   };
 
   /**
-   * create workspace using the workspace data
-   * @param data
+   * @description create workspace using the workspace data
+   * @param {Partial<IWorkspace>} data
    */
   createWorkspace = async (data: Partial<IWorkspace>) =>
     await this.workspaceService.createWorkspace(data).then((response) => {
@@ -61,8 +61,8 @@ export class UserModel implements IUserModel {
     });
 
   /**
-   * delete workspace using the workspace slug
-   * @param workspaceSlug
+   * @description delete workspace using the workspace slug
+   * @param {string} workspaceSlug
    */
   deleteWorkspace = async (workspaceSlug: string) =>
     await this.workspaceService.deleteWorkspace(workspaceSlug).then(() => {

web/store/webhook.store.ts

@@ -97,11 +97,11 @@ export class WebhookModel implements IWebhookModel {
 
   /**
    * @description update a webhook using the data
-   * @param workspaceSlug
-   * @param data
+   * @param {string} workspaceSlug
+   * @param {Partial<IWebhook>} data
    */
   updateWebhook = async (workspaceSlug: string, data: Partial<IWebhook>) => {
-    const originalData = { ...this };
+    const originalData = this.asJSON;
     // optimistically update the store
     runInAction(() => {
       Object.entries(data).forEach(([key, value]) => {

web/store/workspace.store.ts

@@ -3,8 +3,10 @@ import set from "lodash/set";
 import { DataStore } from "./dataMaps";
 // services
 import { WorkspaceService } from "services/workspace.service";
+import { WebhookService } from "services/webhook.service";
 // types
-import { IUser, IWorkspace } from "@plane/types";
+import { IUser, IWebhook, IWorkspace } from "@plane/types";
+import { IWebhookModel } from "./webhook.store";
 
 export interface IWorkspaceModel {
   // model observables
@@ -21,13 +23,20 @@ export interface IWorkspaceModel {
   url: string;
   updated_at: Date;
   updated_by: string;
+  // data maps
+  webhooks: Record<string, IWebhookModel>;
   // computed
-  toJSON: IWorkspace;
-  // actions
+  asJSON: IWorkspace;
+  // workspace actions
   updateWorkspace: (data: Partial<IWorkspace>) => Promise<IWorkspace>;
+  // webhook actions
+  fetchWebhooks: () => Promise<IWebhook[]>;
+  createWebhook: (data: Partial<IWebhook>) => Promise<IWebhook>;
+  deleteWebhook: (webhookId: string) => Promise<void>;
 }
 
 export class WorkspaceModel implements IWorkspaceModel {
+  // model observables
   created_at: Date;
   created_by: string;
   id: string;
@@ -41,10 +50,13 @@ export class WorkspaceModel implements IWorkspaceModel {
   updated_at: Date;
   updated_by: string;
   url: string;
+  // data maps
+  webhooks: Record<string, IWebhookModel> = {};
   // root store
   dataStore;
   // services
   workspaceService;
+  webhookService;
 
   constructor(workspace: IWorkspace, _dataStore: DataStore) {
     makeObservable(this, {
@@ -62,14 +74,21 @@ export class WorkspaceModel implements IWorkspaceModel {
       updated_at: observable.ref,
       updated_by: observable.ref,
       url: observable.ref,
+      // data maps
+      webhooks: observable,
       // computed
-      toJSON: computed,
-      // actions
+      asJSON: computed,
+      // workspace actions
       updateWorkspace: action,
+      // webhook actions
+      fetchWebhooks: action,
+      createWebhook: action,
+      deleteWebhook: action,
     });
     this.dataStore = _dataStore;
     // services
     this.workspaceService = new WorkspaceService();
+    this.webhookService = new WebhookService();
 
     this.created_at = workspace.created_at;
     this.created_by = workspace.created_by;
@@ -89,7 +108,7 @@ export class WorkspaceModel implements IWorkspaceModel {
   /**
    * @description returns the workspace data in JSON format
    */
-  get toJSON() {
+  get asJSON() {
     return {
       created_at: this.created_at,
       created_by: this.created_by,
@@ -109,10 +128,10 @@ export class WorkspaceModel implements IWorkspaceModel {
 
   /**
    * @description update workspace using the new workspace data
-   * @param data
+   * @param {Partial<IWorkspace>} data
    */
   updateWorkspace = async (data: Partial<IWorkspace>) => {
-    const originalData = { ...this };
+    const originalData = this.asJSON;
     // optimistically update the store
     runInAction(() => {
       Object.entries(data).forEach(([key, value]) => {
@@ -133,4 +152,47 @@ export class WorkspaceModel implements IWorkspaceModel {
       throw error;
     }
   };
+
+  // webhook actions
+
+  /**
+   * @description fetch all the webhooks of the workspace
+   */
+  fetchWebhooks = async () => {
+    const webhooksResponse = await this.webhookService.fetchWebhooksList(this.slug);
+
+    runInAction(() => {
+      webhooksResponse.forEach((webhook) => {
+        this.dataStore.webhook.addWebhook(webhook);
+        set(this.webhooks, [webhook.id], this.dataStore.webhook.webhookMap[webhook.id]);
+      });
+    });
+
+    return webhooksResponse;
+  };
+
+  /**
+   * @description create webhook using the webhook data
+   * @param {Partial<IWebhook>} data
+   */
+  createWebhook = async (data: Partial<IWebhook>) =>
+    await this.webhookService.createWebhook(this.slug, data).then((response) => {
+      runInAction(() => {
+        this.dataStore.webhook.addWebhook(response);
+        set(this.webhooks, [response.id], this.dataStore.webhook.webhookMap[response.id]);
+      });
+      return response;
+    });
+
+  /**
+   * @description delete a webhook using webhook id
+   * @param {string} webhookId
+   */
+  deleteWebhook = async (webhookId: string) =>
+    await this.webhookService.deleteWebhook(this.slug, webhookId).then(() => {
+      this.dataStore.webhook.deleteWebhook(webhookId);
+      runInAction(() => {
+        delete this.webhooks[webhookId];
+      });
+    });
 }