Merged release/2024-11-22 into feature/IO-3000-messaging-sockets-migrationv2

hasura/metadata/cron_triggers.yaml

@@ -6,6 +6,15 @@
   headers:
     - name: x-imex-auth
       value_from_env: DATAPUMP_AUTH
+- name: Chatter Data Pump
+  webhook: '{{HASURA_API_URL}}/data/chatter'
+  schedule: 45 5 * * *
+  include_in_metadata: true
+  payload: {}
+  headers:
+    - name: x-imex-auth
+      value_from_env: DATAPUMP_AUTH
+  comment: ""
 - name: Claimscorp Data Pump
   webhook: '{{HASURA_API_URL}}/data/cc'
   schedule: 30 6 * * *

server/data/chatter.js

@@ -109,7 +109,8 @@ async function processBatch(shopsToProcess, start, end, allChatterObjects, allEr
           lastname: j.ownr_co_nm ? j.ownr_co_nm : j.ownr_ln,
           transaction_id: j.ro_number,
           email: j.ownr_ea,
-          phone_number: j.ownr_ph1
+          phone_number: j.ownr_ph1,
+          transaction_time: (j.actual_delivery && moment(j.actual_delivery).tz(bodyshop.timezone).format("YYYYMMDD-HHmm")) || ""
         };
       });
       allChatterObjects.push(...chatterObject);

server/graphql-client/queries.js

@@ -861,6 +861,7 @@ exports.CHATTER_QUERY = `query CHATTER_EXPORT($start: timestamptz, $bodyshopid:
     timezone
   }
   jobs(where: {_and: [{converted: {_eq: true}}, {actual_delivery: {_gt: $start}}, {actual_delivery: {_lte: $end}}, {shopid: {_eq: $bodyshopid}}, {_or: [{ownr_ph1: {_is_null: false}}, {ownr_ea: {_is_null: false}}]}]}) {
+    actual_delivery
     id
     created_at
     ro_number