From da851d223fa6eaec9d5acb3cd81e005dc1ca7541 Mon Sep 17 00:00:00 2001
From: Fine <fanxue0830@gmail.com>
Date: Thu, 11 Aug 2022 17:33:21 +0800
Subject: [PATCH] setup process selector

---
 src/store/modules/selectors.ts     |   6 ++
 src/views/dashboard/data.ts        |   5 ++
 src/views/dashboard/panel/Tool.vue | 111 ++++++++++++++++++++++++-----
 3 files changed, 103 insertions(+), 19 deletions(-)

diff --git a/src/store/modules/selectors.ts b/src/store/modules/selectors.ts
index 4c61dd6c..cad588c6 100644
--- a/src/store/modules/selectors.ts
+++ b/src/store/modules/selectors.ts
@@ -71,6 +71,12 @@ export const selectorStore = defineStore({
     setCurrentDestProcess(process: Nullable<Process>) {
       this.currentDestPod = process;
     },
+    setDestPods(pods: Array<Instance | Endpoint>) {
+      this.destPods = pods;
+    },
+    setDestProcesses(processes: Array<Process>) {
+      this.destPods = processes;
+    },
     async fetchLayers(): Promise<AxiosResponse> {
       const res: AxiosResponse = await graphql.query("queryLayers").params({});
 
diff --git a/src/views/dashboard/data.ts b/src/views/dashboard/data.ts
index c2a8830e..934d3d69 100644
--- a/src/views/dashboard/data.ts
+++ b/src/views/dashboard/data.ts
@@ -213,6 +213,11 @@ export const EndpointTools = [
   { name: "assignment", content: "Add Log", id: "addLog" },
   { name: "event", content: "Add Event", id: "addEvent" },
 ];
+export const ProcessTools = [
+  { name: "playlist_add", content: "Add Widget", id: "addWidget" },
+  { name: "all_inbox", content: "Add Tab", id: "addTab" },
+  { name: "library_books", content: "Add Text", id: "addText" },
+];
 export const ServiceRelationTools = [
   { name: "playlist_add", content: "Add Widget", id: "addWidget" },
   { name: "all_inbox", content: "Add Tab", id: "addTab" },
diff --git a/src/views/dashboard/panel/Tool.vue b/src/views/dashboard/panel/Tool.vue
index 8474241e..33f3f935 100644
--- a/src/views/dashboard/panel/Tool.vue
+++ b/src/views/dashboard/panel/Tool.vue
@@ -50,11 +50,11 @@ limitations under the License. -->
       <div class="selectors-item" v-if="key === 5">
         <span class="label"> $Process </span>
         <Selector
-          v-model="states.currentDestPod"
-          :options="selectorStore.destPods"
+          v-model="states.currentProcess"
+          :options="selectorStore.processes"
           size="small"
           placeholder="Select a data"
-          @change="changeDestPods"
+          @change="changeProcess"
           class="selectors"
         />
       </div>
@@ -91,11 +91,11 @@ limitations under the License. -->
       <div class="selectors-item" v-if="key === 5">
         <span class="label"> $DestinationProcess </span>
         <Selector
-          v-model="states.currentDestPod"
-          :options="selectorStore.destPods"
+          v-model="states.currentDestProcess"
+          :options="selectorStore.destProcesses"
           size="small"
           placeholder="Select a data"
-          @change="changeDestPods"
+          @change="changeDestProcess"
           class="selectors"
         />
       </div>
@@ -155,6 +155,7 @@ import {
   EndpointRelationTools,
   InstanceRelationTools,
   ServiceRelationTools,
+  ProcessTools,
 } from "../data";
 import { useSelectorStore } from "@/store/modules/selectors";
 import { ElMessage } from "element-plus";
@@ -175,16 +176,20 @@ const states = reactive<{
   key: number;
   currentService: string;
   currentPod: string;
+  currentProcess: string;
   currentDestService: string;
   currentDestPod: string;
+  currentDestProcess: string;
 }>({
   destService: "",
   destPod: "",
   key: 0,
   currentService: "",
   currentPod: "",
+  currentProcess: "",
   currentDestService: "",
   currentDestPod: "",
+  currentDestProcess: "",
 });
 const key = computed(() => {
   const type = EntityType.find(
@@ -346,14 +351,18 @@ async function getServices() {
     );
   }
   selectorStore.setCurrentService(s || null);
-  let d;
+  let d,
+    val = 1;
+  if (key.value === 5) {
+    val = 0;
+  }
   if (states.currentService) {
     d = (selectorStore.services || []).find(
       (d: { label: string }) => d.label === states.currentDestService
     );
   } else {
     d = (selectorStore.services || []).find(
-      (d: unknown, index: number) => index === 1
+      (d: unknown, index: number) => index === val
     );
   }
   selectorStore.setCurrentDestService(d || null);
@@ -377,7 +386,9 @@ async function getServices() {
   }
   states.currentDestService = selectorStore.currentDestService.value;
   if (
-    [EntityType[5].value, EntityType[6].value].includes(dashboardStore.entity)
+    [EntityType[5].value, EntityType[6].value, EntityType[7].value].includes(
+      dashboardStore.entity
+    )
   ) {
     fetchPods(dashboardStore.entity, selectorStore.currentDestService.id, true);
   }
@@ -409,19 +420,19 @@ function changeDestService(service: any) {
 }
 
 function changePods(pod: any) {
-  if (pod[0]) {
-    selectorStore.setCurrentPod(pod[0]);
-  } else {
-    selectorStore.setCurrentPod("");
-  }
+  selectorStore.setCurrentPod(pod[0] || null);
 }
 
 function changeDestPods(pod: any) {
-  if (pod[0]) {
-    selectorStore.setCurrentDestPod(pod[0]);
-  } else {
-    selectorStore.setCurrentDestPod(null);
-  }
+  selectorStore.setCurrentDestPod(pod[0] || null);
+}
+
+function changeDestProcess(pod: any) {
+  selectorStore.setCurrentDestProcess(pod[0] || null);
+}
+
+function changeProcess(pod: any) {
+  selectorStore.setCurrentProcess(pod[0] || null);
 }
 
 function changeMode() {
@@ -614,6 +625,65 @@ async function fetchPods(
         states.currentDestPod = selectorStore.currentDestPod.label;
       }
       break;
+    case EntityType[7].value:
+      resp = await selectorStore.getServiceInstances({ serviceId });
+      if (setPod) {
+        let p, m;
+        if (states.currentPod) {
+          p = selectorStore.pods.find(
+            (d: { label: string }) => d.label === states.currentPod
+          );
+        } else {
+          p = selectorStore.pods.find(
+            (d: { label: string }, index: number) => index === 0
+          );
+        }
+        selectorStore.setCurrentPod(p || null);
+        states.currentPod = selectorStore.currentPod.label;
+        selectorStore.setDestPods(selectorStore.pods || []);
+        if (states.currentDestPod) {
+          m = selectorStore.destPods.find(
+            (d: { label: string }) => d.label === states.currentDestPod
+          );
+        } else {
+          m = selectorStore.destPods.find(
+            (d: { label: string }, index: number) => index === 1
+          );
+        }
+        selectorStore.setCurrentDestPod(m || null);
+        states.currentDestPod = selectorStore.currentDestPod.label;
+      }
+      resp = await selectorStore.getProcesses({
+        instanceId: selectorStore.currentPod.id,
+        isRelation: true,
+      });
+      if (setPod) {
+        let p, m;
+        if (states.currentProcess) {
+          p = selectorStore.processes.find(
+            (d: { label: string }) => d.label === states.currentProcess
+          );
+        } else {
+          p = selectorStore.processes.find(
+            (d: { label: string }, index: number) => index === 0
+          );
+        }
+        selectorStore.setCurrentProcess(p || null);
+        states.currentProcess = selectorStore.currentProcess.label;
+        selectorStore.setDestProcesses(selectorStore.processes || []);
+        if (states.currentDestProcess) {
+          m = selectorStore.destProcesses.find(
+            (d: { label: string }) => d.label === states.currentDestProcess
+          );
+        } else {
+          m = selectorStore.destProcesses.find(
+            (d: { label: string }, index: number) => index === 1
+          );
+        }
+        selectorStore.setCurrentDestProcess(m || null);
+        states.currentDestProcess = selectorStore.currentDestProcess.label;
+      }
+      break;
     default:
       resp = {};
   }
@@ -644,6 +714,9 @@ function getTools() {
     case EntityType[6].value:
       toolIcons.value = EndpointRelationTools;
       break;
+    case EntityType[7].value:
+      toolIcons.value = ProcessTools;
+      break;
     default:
       toolIcons.value = AllTools;
   }