diff --git a/hasura/metadata/cron_triggers.yaml b/hasura/metadata/cron_triggers.yaml index ff7aef8d1..95157adaa 100644 --- a/hasura/metadata/cron_triggers.yaml +++ b/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 * * * diff --git a/server/data/chatter.js b/server/data/chatter.js index 8c3f8e634..993707c41 100644 --- a/server/data/chatter.js +++ b/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); diff --git a/server/graphql-client/queries.js b/server/graphql-client/queries.js index e5b83720d..405aeaaaa 100644 --- a/server/graphql-client/queries.js +++ b/server/graphql-client/queries.js @@ -840,6 +840,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