ui: add activity status summary

artefactual-labs · Nov 11, 2019 · d14768e · d14768e
1 parent 53e258f
commit d14768e
Showing 1 changed file with 81 additions and 4 deletions.
diff --git a/ui/src/views/CollectionWorkflow.vue b/ui/src/views/CollectionWorkflow.vue
@@ -10,9 +10,30 @@
       <dl>
         <dt>Status</dt>
         <dd><b-badge>{{ history.status }}</b-badge></dd>
+        <dt>Activity summary</dt>
+        <dd>
+          <table class="table table-bordered table-hover table-sm">
+            <thead class="thead">
+              <tr>
+                <th scope="col">Name</th>
+                <th scope="col">Started</th>
+                <th scope="col">Duration (seconds)</th>
+                <th scope="col">Status</th>
+              </tr>
+            </thead>
+            <tbody>
+              <tr v-for="(item, index) in activities" v-bind:key="index">
+                <td scope="row">{{ item.name }}</td>
+                <td>{{ item.started | formatEpoch }}</td>
+                <td>{{ item.duration }}</td>
+                <td><CollectionStatusBadge :status="item.status"/></td>
+              </tr>
+            </tbody>
+          </table>
+        </dd>
         <dt>History</dt>
         <dd>
-          <table class="table table-bordered table-hover">
+          <table class="table table-bordered table-hover table-sm">
             <thead class="thead">
               <tr>
                 <th scope="col">ID</th>
@@ -22,8 +43,8 @@
               </tr>
             </thead>
             <tbody>
-              <tr v-for="item in history.history.slice().reverse()" v-bind:key="item.id" @click="view(item)">
-                <th scope="row">{{ item.id }}</th>
+              <tr v-for="item in history.history.slice().reverse()" v-bind:key="item.id">
+                <td scope="row">{{ item.id }}</td>
                 <td>{{ item.type }}</td>
                 <td>{{ item.details.timestamp | formatEpoch }}</td>
                 <td>{{ renderDetails(item) }}</td>
@@ -39,13 +60,19 @@
 <script lang="ts">
 import { Component, Prop, Provide, Vue } from 'vue-property-decorator';
 import { EnduroCollectionClient } from '../main';
+import CollectionStatusBadge from '@/components/CollectionStatusBadge.vue';
 import { CollectionShowResponseBody, CollectionWorkflowResponseBody, EnduroCollectionWorkflowHistoryResponseBody } from '../client/src';
 
-@Component
+@Component({
+  components: {
+    CollectionStatusBadge,
+  },
+})
 export default class CollectionWorkflow extends Vue {
 
   private collection: any = {};
   private history: any = {history: []};
+  private activities: any = {};
   private name: string = '';
 
   private mounted() {
@@ -75,9 +102,57 @@ export default class CollectionWorkflow extends Vue {
   private loadHistory() {
     return EnduroCollectionClient.collectionWorkflow({id: +this.$route.params.id}).then((response: CollectionWorkflowResponseBody) => {
       this.history = response;
+      this.processHistory();
     });
   }
 
+  private processHistory() {
+    const ignoredActivities = [
+      'internalSessionCreationActivity',
+      'internalSessionCompletionActivity',
+    ];
+    for (const event of this.history.history) {
+      const details = event.details;
+      if (event.type === 'ActivityTaskScheduled') {
+        const attrs = details.activityTaskScheduledEventAttributes;
+        const name = attrs.activityType.name;
+        if (ignoredActivities.includes(name)) {
+          continue;
+        }
+        this.activities[event.id] = {
+          name,
+          status: 'in progress',
+          attempts: 0,
+          started: details.timestamp,
+        };
+      } else if (event.type === 'ActivityTaskStarted') {
+        const attrs = details.activityTaskStartedEventAttributes;
+        if (attrs.scheduledEventId in this.activities) {
+          const item = this.activities[attrs.scheduledEventId];
+          item.attempts = attrs.attempt + 1;
+        }
+      } else if (event.type === 'ActivityTaskFailed') {
+        const attrs = details.activityTaskFailedEventAttributes;
+        if (attrs.scheduledEventId in this.activities) {
+          const item = this.activities[attrs.scheduledEventId];
+          item.status = 'error';
+          item.completed = details.timestamp;
+          item.duration = (item.completed - item.started) / 1000000000;
+          item.duration = item.duration.toFixed(2);
+        }
+      } else if (event.type === 'ActivityTaskCompleted') {
+        const attrs = details.activityTaskCompletedEventAttributes;
+        if (attrs.scheduledEventId in this.activities) {
+          const item = this.activities[attrs.scheduledEventId];
+          item.status = 'done';
+          item.completed = details.timestamp;
+          item.duration = (item.completed - item.started) / 1000000000;
+          item.duration = item.duration.toFixed(2);
+        }
+      }
+    }
+  }
+
   private renderDetails(event: EnduroCollectionWorkflowHistoryResponseBody): string {
     let ret = '';
 
@@ -88,6 +163,8 @@ export default class CollectionWorkflow extends Vue {
     const attrs: any = event.details;
     if (event.type === 'ActivityTaskScheduled') {
       ret = 'Activity: ' + attrs.activityTaskScheduledEventAttributes.activityType.name;
+    } else if (event.type === 'ActivityTaskFailed') {
+      ret = 'Error: ' + window.atob(attrs.activityTaskFailedEventAttributes.details);
     } else if (event.type === 'DecisionTaskScheduled') {
       const attempt: number = parseInt(attrs.decisionTaskScheduledEventAttributes.attempt, 10) + 1;
       ret = 'Attempts: ' + attempt;