From c23c29234cc5979e7c117b6df0fb0c6dd3444215 Mon Sep 17 00:00:00 2001
From: Yash Maheshwari <yashmaheshwari551@gmail.com>
Date: Mon, 12 Aug 2024 14:30:11 +0530
Subject: [PATCH] Implemented: support to run a group from the list page(#199)

---
 src/components/GroupActionsPopover.vue | 75 ++++++++++++++++++++++++--
 1 file changed, 72 insertions(+), 3 deletions(-)

diff --git a/src/components/GroupActionsPopover.vue b/src/components/GroupActionsPopover.vue
index ef7cff4..c2e95d0 100644
--- a/src/components/GroupActionsPopover.vue
+++ b/src/components/GroupActionsPopover.vue
@@ -2,7 +2,7 @@
   <ion-content>
     <ion-list>
       <ion-list-header>{{ group.groupName }}</ion-list-header>
-      <ion-item button>
+      <ion-item button @click="runNow">
         <ion-icon slot="start" :icon="flashOutline" />
         {{ translate("Run now") }}
       </ion-item>
@@ -20,6 +20,7 @@
 
 <script setup lang="ts">
 import {
+  alertController,
   IonContent,
   IonIcon,
   IonItem,
@@ -29,13 +30,16 @@ import {
 } from "@ionic/vue";
 import { flashOutline, pauseOutline, playOutline } from 'ionicons/icons'
 import { translate } from "@/i18n"
-import { defineProps } from "vue"
+import { computed, defineProps } from "vue"
 import { OrderRoutingService } from "@/services/RoutingService";
 import { hasError, showToast } from "@/utils";
 import logger from "@/logger";
-import store from "@/store";
+import { useStore } from "vuex";
+
+const store = useStore()
 
 const props = defineProps(["group"])
+const isOmsConnectionExist = computed(() => store.getters["util/isOmsConnectionExist"])
 
 async function updateGroupStatus(paused: string) {
   let routingGroups = [];
@@ -59,4 +63,69 @@ async function updateGroupStatus(paused: string) {
 
   popoverController.dismiss({ routingGroups });
 }
+
+async function runNow() {
+  // If this is the first time then we are fetching the omsConnection status, as if the value of isOmsConnectionExist value is a boolean it means we have previously fetched the connection status
+  if(typeof isOmsConnectionExist.value !== "boolean") {
+    await store.dispatch("util/checkOmsConnectionStatus")
+  }
+
+  if(!isOmsConnectionExist.value) {
+    return;
+  }
+
+  const scheduleAlert = await alertController
+    .create({
+      header: translate("Run now"),
+      message: translate("Running this schedule now will not replace this schedule. A copy of this schedule will be created and run immediately. You may not be able to reverse this action."),
+      buttons: [
+        {
+          text: translate("Cancel"),
+          role: "cancel",
+        },
+        {
+          text: translate("Run now"),
+          handler: async () => {
+            popoverController.dismiss()
+
+            const job = props.group?.schedule || {}
+            // Checking that if we already have the job schedule before calling runNow, because if the job scheduler is not present then runNow action can't be performed
+            // If the scheduler for the job is available then we will have jobName, if not then first scheduling the job in draft status just to create a routing schedule and then calling runNow action
+            if(!job.jobName) {
+              const payload = {
+                routingGroupId: props.group.routingGroupId,
+                paused: "Y",  // passing Y as we just need to configure the scheduler and do not need to schedule it in active state
+              }
+
+              try {
+                const resp = await OrderRoutingService.scheduleBrokering(payload)
+                if(hasError(resp)) {
+                  throw resp.data
+                }
+                // Updating jobName as if the user again clicks the runNow button then in that we don't want to call the scheduleBrokering service
+                job.jobName = resp.data.jobName
+              } catch(err) {
+                logger.error(err)
+                return;
+              }
+            }
+
+            try {
+              const resp = await OrderRoutingService.runNow(props.group.routingGroupId)
+              if(!hasError(resp) && resp.data.jobRunId) {
+                showToast(translate("Service has been scheduled"))
+              } else {
+                throw resp.data
+              }
+            } catch(err) {
+              showToast(translate("Failed to schedule service"))
+              logger.error(err)
+            }
+          }
+        }
+      ]
+    });
+
+  return scheduleAlert.present();
+}
 </script> 
\ No newline at end of file