Merged in release/2022-11-10 (pull request #624)

release/2022-11-10

Approved-by: Patrick Fic

hasura/metadata/tables.yaml

@@ -3769,6 +3769,27 @@
                 - active:
                     _eq: true
   event_triggers:
+    - name: job_status_transition
+      definition:
+        enable_manual: false
+        insert:
+          columns: '*'
+        update:
+          columns:
+            - status
+      retry_conf:
+        interval_sec: 10
+        num_retries: 0
+        timeout_sec: 60
+      webhook_from_env: HASURA_API_URL
+      headers:
+        - name: event-secret
+          value_from_env: EVENT_SECRET
+      request_transform:
+        query_params: {}
+        template_engine: Kriti
+        url: '{{$base_url}}/job/statustransition'
+        version: 2
     - name: jobs_arms
       definition:
         enable_manual: false

server.js

@@ -129,7 +129,7 @@ var job = require("./server/job/job");
 app.post("/job/totals", fb.validateFirebaseIdToken, job.totals);
 app.post(
   "/job/statustransition",
-  fb.validateFirebaseIdToken,
+  // fb.validateFirebaseIdToken,
   job.statustransition
 );
 app.post("/job/totalsssu", fb.validateFirebaseIdToken, job.totalsSsu);

server/job/job-status-transition.js

@@ -7,22 +7,29 @@ const logger = require("../utils/logger");
 // Dinero.defaultCurrency = "USD";
 // Dinero.globalLocale = "en-CA";
 Dinero.globalRoundingMode = "HALF_EVEN";
-
+const path = require("path");
-async function StatusTransition(req, res) {
+const client = require("../graphql-client/graphql-client").client;
-  const { jobid, value, bodyshopid } = req.body;
+require("dotenv").config({
-
+  path: path.resolve(
-  const BearerToken = req.headers.authorization;
+    process.cwd(),
-  logger.log("job-costing-start", "DEBUG", req.user.email, jobid, null);
+    `.env.${process.env.NODE_ENV || "development"}`
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+  ),
-    headers: {
-      Authorization: BearerToken,
-    },
 });
+async function StatusTransition(req, res) {
+  if (req.headers["event-secret"] !== process.env.EVENT_SECRET) {
+    res.status(403).send("Unauthorized");
+    return;
+  }
 
+  const {
+    id: jobid,
+    status: value,
+    shopid: bodyshopid,
+  } = req.body.event.data.new;
   try {
-    const { update_transitions } = await client
+    const { update_transitions } = await client.request(
-      .setHeaders({ Authorization: BearerToken })
+      queries.UPDATE_OLD_TRANSITION,
-      .request(queries.UPDATE_OLD_TRANSITION, {
+      {
         jobid: jobid,
         existingTransition: {
           end: new Date(),
@@ -30,7 +37,8 @@ async function StatusTransition(req, res) {
 
           //duration
         },
-      });
+      }
+    );
 
     let duration =
       update_transitions.affected_rows === 0
@@ -38,9 +46,7 @@ async function StatusTransition(req, res) {
         : new Date(update_transitions.returning[0].end) -
           new Date(update_transitions.returning[0].start);
 
-    const resp2 = await client
+    const resp2 = await client.request(queries.INSERT_NEW_TRANSITION, {
-      .setHeaders({ Authorization: BearerToken })
-      .request(queries.INSERT_NEW_TRANSITION, {
       oldTransitionId:
         update_transitions.affected_rows === 0
           ? null