Add list workflow executions page

#40

package.json

@@ -10,7 +10,7 @@
     "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs,.ts,.tsx,.cts,.mts --fix --ignore-path .gitignore",
     "generate-s3-client": "openapi --input https://clowm-staging.bi.denbi.de/api/s3proxy-service/openapi.json --output src/client/s3proxy --client axios",
     "generate-auth-client": "openapi --input https://clowm-staging.bi.denbi.de/api/auth-service/openapi.json --output src/client/auth --client axios",
-    "generate-workflow-client": "openapi --input https://clowm-staging.bi.denbi.de/api/workflow-service/openapi.json --output src/client/workflow --client axios"
+    "generate-workflow-client": "openapi --input http://localhost:9999/api/workflow-service/openapi.json --output src/client/workflow --client axios"
   },
   "dependencies": {
     "@aws-sdk/client-s3": "^3.290.0",

src/assets/main.css

@@ -19,12 +19,10 @@ body {
     cursor: pointer;
 }
 
-.helpTextCode > pre {
-    border: thin solid var(--bs-secondary);
-    border-radius: var(--bs-border-radius);
-    background: var(--bs-dark);
-    filter: brightness(0.9);
-    padding: 1rem;
-    margin: 1em 2em;
+pre {
+    backdrop-filter: brightness(1.4);
+    padding: .5rem;
     color: var(--bs-code-color);
+    width: fit-content;
+    min-width: 50%;
 }

src/client/workflow/models/WorkflowExecutionOut.ts

@@ -33,5 +33,9 @@ export type WorkflowExecutionOut = {
      * Status of the workflow execution
      */
     status: WorkflowExecutionStatus;
+    /**
+     * Id of the workflow
+     */
+    workflow_id: string;
 };
 

src/components/FontAwesomeIcon.vue

 <template>
-  <div
+  <span
     class="align-middle"
     :class="icon"
     :style="{
       color: props.fill,
     }"
-  ></div>
+  ></span>
 </template>
 
 <script setup lang="ts">

src/components/MarkdownRenderer.vue

@@ -7,7 +7,11 @@ const props = defineProps<{
   markdown: string;
 }>();
 
-const converter = new showdown.Converter();
+const converter = new showdown.Converter({
+  tables: true,
+  ghCodeBLocks: false,
+});
+converter.setFlavor("github");
 const outputHtml = computed(() => {
   const dirtyHTML = converter.makeHtml(props.markdown);
   return DOMPurify.sanitize(dirtyHTML);
@@ -18,4 +22,4 @@ const outputHtml = computed(() => {
   <div v-html="outputHtml"></div>
 </template>
 
-<style scoped></style>
+<style></style>

src/components/NavbarTop.vue

@@ -123,7 +123,11 @@ watch(
                 >
               </li>
               <li>
-                <a class="dropdown-item" href="#">Executions</a>
+                <router-link
+                  class="dropdown-item"
+                  :to="{ name: 'workflow-executions' }"
+                  >My Executions</router-link
+                >
               </li>
               <li
                 v-if="

src/components/parameter-schema/ParameterSchemaFormComponent.vue

@@ -8,6 +8,7 @@ import Ajv from "ajv";
 import type { ValidateFunction } from "ajv";
 import ParameterStringInput from "@/components/parameter-schema/form-mode/ParameterStringInput.vue";
 import { Toast } from "bootstrap";
+import { useRouter } from "vue-router";
 
 // Props
 // =============================================================================
@@ -21,6 +22,8 @@ const props = defineProps({
   },
 });
 
+const router = useRouter();
+
 // Bootstrap Elements
 // =============================================================================
 let errorToast: Toast | null = null;
@@ -142,7 +145,9 @@ function startWorkflow() {
         report_output_bucket: formState.report_bucket,
       })
         .then(() => {
-          console.log("Started Workflow");
+          router.push({
+            name: "workflow-executions",
+          });
         })
         .catch((err: ApiError) => {
           console.error(err);
@@ -354,4 +359,8 @@ onMounted(() => {
   </div>
 </template>
 
-<style scoped></style>
+<style scoped>
+div.card-body {
+  backdrop-filter: brightness(1.2);
+}
+</style>

src/components/parameter-schema/description-mode/ParameterDescription.vue

@@ -131,6 +131,6 @@ li:hover {
   background: var(--bs-secondary);
 }
 a:hover {
-  filter: brightness(0.8);
+  filter: brightness(1.2);
 }
 </style>

src/components/parameter-schema/form-mode/ParameterGroupForm.vue

@@ -176,7 +176,7 @@ watch(
 
 <style scoped>
 div.card-body {
-  filter: brightness(0.9);
+  backdrop-filter: brightness(1.2);
 }
 span.cursor-pointer:hover {
   color: var(--bs-info);

src/router/index.ts

@@ -28,6 +28,12 @@ const router = createRouter({
           name: "s3_keys",
           component: () => import("../views/object-storage/S3KeysView.vue"),
         },
+        {
+          path: "workflow-executions",
+          name: "workflow-executions",
+          component: () =>
+            import("../views/workflows/ListWorkflowExecutionsView.vue"),
+        },
         {
           path: "workflows",
           name: "workflows",

src/views/workflows/ListWorkflowExecutionsView.vue

+<script setup lang="ts">
+import FontAwesomeIcon from "@/components/FontAwesomeIcon.vue";
+import { onMounted, reactive, computed } from "vue";
+import type { WorkflowExecutionOut } from "@/client/workflow";
+import { useAuthStore } from "@/stores/auth";
+import {
+  WorkflowExecutionService,
+  WorkflowExecutionStatus,
+  WorkflowService,
+  WorkflowVersionService,
+} from "@/client/workflow";
+import dayjs from "dayjs";
+
+const userStore = useAuthStore();
+
+const executionsState = reactive<{
+  workflowMapping: Record<string, string>;
+  versionMapping: Record<string, string>;
+  workflowExecutions: WorkflowExecutionOut[];
+  loading: boolean;
+  mappingLoading: boolean;
+}>({
+  workflowMapping: {},
+  versionMapping: {},
+  workflowExecutions: [],
+  loading: true,
+  mappingLoading: true,
+});
+
+const statusToColorMapping = {
+  PENDING: "bg-warning",
+  SCHEDULED: "bg-warning",
+  RUNNING: "bg-info",
+  CANCELED: "bg-danger",
+  SUCCESS: "bg-success",
+  ERROR: "bg-danger",
+};
+
+const statusToIconMapping = {
+  PENDING: "fa-solid fa-circle-pause",
+  SCHEDULED: "fa-solid fa-circle-pause",
+  RUNNING: "fa-solid fa-circle-play",
+  CANCELED: "fa-solid fa-circle-xmark",
+  SUCCESS: "fa-solid fa-circle-check",
+  ERROR: "fa-solid fa-circle-xmark",
+};
+
+const sortedExecutions = computed<WorkflowExecutionOut[]>(() => {
+  const tempList = [...executionsState.workflowExecutions];
+  tempList.sort((a, b) => {
+    // sort by start time descending
+    const a_date = dayjs(a.start_time);
+    const b_date = dayjs(b.start_time);
+    return a_date.isBefore(b_date) ? 1 : -1;
+  });
+  return tempList;
+});
+
+// Functions
+// -----------------------------------------------------------------------------
+function updateExecutions() {
+  const listExecutionsPromise =
+    WorkflowExecutionService.workflowExecutionListWorkflowExecutions(
+      userStore.currentUID
+    )
+      .then((executions) => {
+        executionsState.workflowExecutions = executions;
+        return executions;
+      })
+      .finally(() => {
+        executionsState.loading = false;
+      });
+  listExecutionsPromise // construct mapping from workflow id to workflow name
+    .then((executions) =>
+      Promise.all(
+        // group all calls to the API
+        executions
+          .filter((execution) => execution.workflow_id) // filter undefined workflows
+          .filter(
+            (execution) =>
+              !executionsState.workflowMapping[execution.workflow_id]
+          )
+          .filter(
+            // filter unique workflows
+            (execution, index, array) =>
+              array.findIndex(
+                (val) => val.workflow_id === execution.workflow_id
+              ) === index
+          )
+          .map((execution) =>
+            WorkflowService.workflowGetWorkflow(execution.workflow_id)
+          )
+      )
+    )
+    .then((workflows) =>
+      workflows.forEach((workflow) => {
+        executionsState.workflowMapping[workflow.workflow_id] = workflow.name;
+      })
+    )
+    .finally(() => {
+      executionsState.mappingLoading = false;
+    });
+  listExecutionsPromise // construct mapping from version id to clear text version
+    .then((executions) =>
+      Promise.all(
+        // group all calls to the API
+        executions
+          .filter(
+            // filter undefined workflow versions
+            (execution) =>
+              execution.workflow_id && execution.workflow_version_id
+          )
+          .filter(
+            // filter already seen workflow versions
+            (version) => !executionsState.versionMapping[version.workflow_id]
+          )
+          .filter(
+            // filter unique workflow versions
+            (execution, index, array) =>
+              array.findIndex(
+                (val) =>
+                  val.workflow_version_id === execution.workflow_version_id
+              ) === index
+          )
+          .map((execution) =>
+            WorkflowVersionService.workflowVersionGetWorkflowVersion(
+              execution.workflow_version_id,
+              execution.workflow_id
+            )
+          )
+      )
+    )
+    .then((versions) =>
+      versions.forEach((version) => {
+        executionsState.versionMapping[version.git_commit_hash] =
+          version.version;
+      })
+    );
+}
+
+function workflowExecutionDeletable(status: WorkflowExecutionStatus): boolean {
+  return [
+    WorkflowExecutionStatus.ERROR,
+    WorkflowExecutionStatus.CANCELED,
+    WorkflowExecutionStatus.SUCCESS,
+  ].includes(status);
+}
+function workflowExecutionCancable(status: WorkflowExecutionStatus): boolean {
+  return [
+    WorkflowExecutionStatus.RUNNING,
+    WorkflowExecutionStatus.PENDING,
+    WorkflowExecutionStatus.SCHEDULED,
+  ].includes(status);
+}
+
+function deleteWorkflowExecution(executionId: string) {
+  WorkflowExecutionService.workflowExecutionDeleteWorkflowExecution(
+    executionId
+  ).then(() => {
+    executionsState.workflowExecutions =
+      executionsState.workflowExecutions.filter(
+        (execution) => execution.execution_id !== executionId
+      );
+  });
+}
+
+function cancelWorkflowExecution(executionId: string) {
+  WorkflowExecutionService.workflowExecutionCancelWorkflowExecution(
+    executionId
+  ).then(() => {
+    const index = executionsState.workflowExecutions.findIndex(
+      (execution) => execution.execution_id === executionId
+    );
+    if (index > -1) {
+      executionsState.workflowExecutions[index].status =
+        WorkflowExecutionStatus.CANCELED;
+      executionsState.workflowExecutions[index].end_time =
+        dayjs().toISOString();
+    }
+  });
+}
+
+onMounted(() => {
+  updateExecutions();
+});
+</script>
+
+<template>
+  <div class="row m-2 border-bottom border-light mb-4">
+    <h1 class="mb-2 text-light">My Workflow Executions</h1>
+  </div>
+  <table
+    class="table table-dark table-striped table-hover caption-top align-middle"
+  >
+    <caption>
+      Displaying
+      {{
+        executionsState.workflowExecutions.length
+      }}
+      Workflow Execution
+    </caption>
+    <thead>
+      <tr>
+        <th scope="col">Workflow</th>
+        <th scope="col">Status</th>
+        <th scope="col">Started</th>
+        <th scope="col">Ended</th>
+        <th scope="col"></th>
+      </tr>
+    </thead>
+    <tbody>
+      <template v-if="executionsState.loading">
+        <tr v-for="n in 5" :key="n">
+          <td class="placeholder-glow w-25">
+            <span class="placeholder col-6"></span>
+          </td>
+          <td class="placeholder-glow" style="width: 20%">
+            <span class="placeholder col-4"></span>
+          </td>
+          <td class="placeholder-glow" style="width: 20%">
+            <span class="placeholder col-6"></span>
+          </td>
+          <td class="placeholder-glow" style="width: 20%">
+            <span class="placeholder col-6"></span>
+          </td>
+          <td class="text-end">
+            <div
+              class="btn-group btn-group-sm dropdown-center dropdown-menu-start"
+            >
+              <button type="button" class="btn btn-secondary" disabled>
+                Details
+              </button>
+              <button
+                type="button"
+                class="btn btn-secondary dropdown-toggle dropdown-toggle-split"
+                disabled
+              >
+                <span class="visually-hidden">Toggle Dropdown</span>
+              </button>
+            </div>
+          </td>
+        </tr>
+      </template>
+      <template v-else>
+        <tr v-for="execution in sortedExecutions" :key="execution.execution_id">
+          <td
+            v-if="executionsState.mappingLoading"
+            class="placeholder-glow w-25"
+          >
+            <span class="placeholder col-6"></span>
+          </td>
+          <td v-else>
+            <span>{{
+              executionsState.workflowMapping[execution.workflow_id]
+            }}</span>
+            <span
+              >@{{
+                executionsState.versionMapping[execution.workflow_version_id]
+              }}</span
+            >
+          </td>
+          <td>
+            <span
+              class="rounded-pill py-1 px-2"
+              :class="statusToColorMapping[execution.status]"
+              ><font-awesome-icon
+                class="me-2"
+                :icon="statusToIconMapping[execution.status]"
+              />{{ execution.status }}</span
+            >
+          </td>
+          <td>{{ dayjs(execution.start_time).format("DD.MM.YYYY HH:mm") }}</td>
+          <td>
+            <template v-if="execution.end_time">
+              {{ dayjs(execution.end_time).format("DD.MM.YYYY HH:mm") }}
+            </template>
+            <template v-else> - </template>
+          </td>
+          <td class="text-end">
+            <div
+              class="btn-group btn-group-sm dropdown-center dropdown-menu-start"
+            >
+              <button type="button" class="btn btn-secondary">Details</button>
+              <button
+                type="button"
+                class="btn btn-secondary dropdown-toggle dropdown-toggle-split"
+                data-bs-toggle="dropdown"
+                aria-expanded="false"
+              >
+                <span class="visually-hidden">Toggle Dropdown</span>
+              </button>
+              <ul class="dropdown-menu dropdown-menu-dark">
+                <li v-if="workflowExecutionCancable(execution.status)">
+                  <button
+                    class="dropdown-item text-danger align-middle"
+                    type="button"
+                    @click="cancelWorkflowExecution(execution.execution_id)"
+                  >
+                    <font-awesome-icon icon="fa-solid fa-ban" />
+                    <span class="ms-1">Cancel</span>
+                  </button>
+                </li>
+                <li v-if="workflowExecutionDeletable(execution.status)">
+                  <button
+                    class="dropdown-item text-danger align-middle"
+                    type="button"
+                    @click="deleteWorkflowExecution(execution.execution_id)"
+                  >
+                    <font-awesome-icon icon="fa-solid fa-trash" />
+                    <span class="ms-1">Delete</span>
+                  </button>
+                </li>
+              </ul>
+            </div>
+            <!-- Show delete button when row is a folder -->
+          </td>
+        </tr>
+      </template>
+    </tbody>
+  </table>
+</template>
+
+<style scoped></style>