feat: visualize a on-demand log widget (#99)

src/store/modules/dashboard.ts

@@ -114,7 +114,8 @@ export const dashboardStore = defineStore({
         type === "Trace" ||
         type === "Profile" ||
         type === "Log" ||
-        type === "Ebpf"
+        type === "Ebpf" ||
+        type === "DemandLog"
       ) {
         newItem.h = 36;
       }
@@ -170,7 +171,13 @@ export const dashboardStore = defineStore({
           showDepth: true,
         };
       }
-      if (type === "Trace" || type === "Profile" || type === "Log") {
+      if (
+        type === "Trace" ||
+        type === "Profile" ||
+        type === "Log" ||
+        type === "DemandLog" ||
+        type === "Ebpf"
+      ) {
         newItem.h = 32;
       }
       if (type === "Text") {

src/store/modules/demand-log.ts

@@ -0,0 +1,124 @@
+import { ElMessage } from "element-plus";
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import { defineStore } from "pinia";
+import { Instance } from "@/types/selector";
+import { store } from "@/store";
+import graphql from "@/graphql";
+import { AxiosResponse } from "axios";
+import { useAppStoreWithOut } from "@/store/modules/app";
+import { useSelectorStore } from "@/store/modules/selectors";
+import { Conditions, Log } from "@/types/demand-log";
+
+interface DemandLogState {
+  containers: Instance[];
+  instances: Instance[];
+  conditions: Conditions;
+  selectorStore: any;
+  logs: Log[];
+  loadLogs: boolean;
+  message: string;
+}
+
+export const demandLogStore = defineStore({
+  id: "demandLog",
+  state: (): DemandLogState => ({
+    containers: [{ label: "", value: "" }],
+    instances: [{ value: "", label: "" }],
+    conditions: {
+      container: "",
+      serviceInstanceId: "",
+      duration: useAppStoreWithOut().durationTime,
+    },
+    selectorStore: useSelectorStore(),
+    logs: [],
+    loadLogs: false,
+    message: "",
+  }),
+  actions: {
+    setLogCondition(data: Conditions) {
+      this.conditions = { ...this.conditions, ...data };
+    },
+    setLogs(logs: Log[], message?: string) {
+      this.logs = logs;
+      this.message = message || "";
+    },
+    async getInstances(id: string) {
+      const serviceId = this.selectorStore.currentService
+        ? this.selectorStore.currentService.id
+        : id;
+      const res: AxiosResponse = await graphql.query("queryInstances").params({
+        serviceId,
+        duration: useAppStoreWithOut().durationTime,
+      });
+
+      if (res.data.errors) {
+        return res.data;
+      }
+      this.instances = res.data.data.pods || [];
+      return res.data;
+    },
+    async getContainers(serviceInstanceId: string) {
+      if (!serviceInstanceId) {
+        return new Promise((resolve) =>
+          resolve({ errors: "No service instance" })
+        );
+      }
+      const condition = {
+        serviceInstanceId,
+      };
+      const res: AxiosResponse = await graphql
+        .query("fetchContainers")
+        .params({ condition });
+
+      if (res.data.errors) {
+        return res.data;
+      }
+      if (res.data.data.containers.errorReason) {
+        this.containers = [{ label: "", value: "" }];
+        return res.data;
+      }
+      this.containers = res.data.data.containers.containers.map((d: string) => {
+        return { label: d, value: d };
+      });
+      return res.data;
+    },
+    async getDemandLogs() {
+      this.loadLogs = true;
+      const res: AxiosResponse = await graphql
+        .query("fetchDemandPodLogs")
+        .params({ condition: this.conditions });
+      this.loadLogs = false;
+      if (res.data.errors) {
+        return res.data;
+      }
+      if (res.data.data.logs.errorReason) {
+        this.setLogs("", res.data.data.logs.errorReason);
+        return res.data;
+      }
+      const logs = res.data.data.logs.logs
+        .map((d: Log) => d.content)
+        .join("\n");
+      this.setLogs(logs);
+      return res.data;
+    },
+  },
+});
+
+export function useDemandLogStore(): any {
+  return demandLogStore(store);
+}