const { isObject } = require("lodash");

const jobUpdated = async (req, res) => {
  const { io, logger } = req;

  logger.log("job-update", "INFO", req.user?.email, null, {
    message: `Job updated event received from Hasura`,
    body: req?.body
  });

  if (!req?.body?.event?.data?.new || !isObject(req?.body?.event?.data?.new)) {
    logger.log("job-update-error", "ERROR", req.user?.email, null, {
      message: `Malformed Job Update request sent from Hasura`,
      body: req?.body
    });

    return res.json({
      status: "error",
      message: `Malformed Job Update request sent from Hasura`
    });
  }

  const updatedJob = req.body.event.data.new;
  const bodyshopID = updatedJob.shopid;

  // Emit the job-updated event only to the room corresponding to the bodyshop
  io.to(bodyshopID).emit("job-updated", updatedJob);

  return res.json({ message: "Job updated and event emitted" });
};

module.exports = jobUpdated;

// {
//   actual_completion: null,
//   actual_delivery: null,
//   actual_in: '2024-09-05T23:04:31.439+00:00',
//   adj_g_disc: 0,
//   adj_strdis: 0,
//   adj_towdis: 0,
//   adjustment_bottom_line: null,
//   agt_addr1: null,
//   agt_addr2: null,
//   agt_city: null,
//   agt_co_id: null,
//   agt_co_nm: null,
//   agt_ct_fn: null,
//   agt_ct_ln: null,
//   agt_ct_ph: null,
//   agt_ct_phx: null,
//   agt_ctry: null,
//   agt_ea: null,
//   agt_fax: null,
//   agt_faxx: null,
//   agt_lic_no: null,
//   agt_ph1: null,
//   agt_ph1x: null,
//   agt_ph2: null,
//   agt_ph2x: null,
//   agt_st: null,
//   agt_zip: null,
//   alt_transport: 'No car',
//   area_of_damage: { impact1: '19', impact2: '0102' },
//   asgn_date: '2024-08-06',
//   asgn_no: '72361166-99',
//   asgn_type: null,
//   auto_add_ats: false,
//   ca_bc_pvrt: null,
//   ca_customer_gst: 500,
//   ca_gst_registrant: true,
//   cat_no: null,
//   category: null,
//   cieca_pfl: {},
//   cieca_pfo: {},
//   cieca_pft: {},
//   cieca_stl: {
//     data: [
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object], [Object], [Object],
//       [Object]
//     ]
//   },
//   cieca_ttl: {
//     data: {
//       g_aa_amt: 0,
//       g_bett_amt: 0,
//       g_cust_amt: 0,
//       g_ded_amt: 0,
//       g_rpd_amt: 0,
//       g_tax: 854.37,
//       g_ttl_amt: 13721.35,
//       g_ttl_disc: 0,
//       g_upd_amt: 0,
//       gst_amt: 612.72,
//       n_ttl_amt: 13721.35,
//       prev_net: 0,
//       supp_amt: 958.53
//     }
//   },
//   ciecaid: '2273515',
//   class: null,
//   clm_addr1: null,
//   clm_addr2: null,
//   clm_city: null,
//   clm_ct_fn: null,
//   clm_ct_ln: null,
//   clm_ct_ph: null,
//   clm_ct_phx: null,
//   clm_ctry: null,
//   clm_ea: null,
//   clm_fax: null,
//   clm_faxx: null,
//   clm_no: '72361166-99',
//   clm_ofc_id: null,
//   clm_ofc_nm: null,
//   clm_ph1: null,
//   clm_ph1x: null,
//   clm_ph2: null,
//   clm_ph2x: null,
//   clm_st: null,
//   clm_title: null,
//   clm_total: 13721.3,
//   clm_zip: null,
//   comment: null,
//   completed_tasks: [],
//   converted: true,
//   created_at: '2024-09-05T22:50:11.37571+00:00',
//   cust_pr: 'C',
//   date_estimated: null,
//   date_exported: null,
//   date_invoiced: null,
//   date_last_contacted: null,
//   date_lost_sale: null,
//   date_next_contact: '2024-09-07T23:04:31.439+00:00',
//   date_open: '2024-09-05T22:50:12.083+00:00',
//   date_rentalresp: null,
//   date_repairstarted: null,
//   date_scheduled: '2024-09-05T23:04:12.182+00:00',
//   date_towin: null,
//   date_void: null,
//   ded_amt: 0,
//   ded_note: null,
//   ded_status: 'Y',
//   deliverchecklist: null,
//   depreciation_taxes: 0,
//   dms_allocation: null,
//   driveable: true,
//   employee_body: null,
//   employee_csr: null,
//   employee_prep: null,
//   employee_refinish: null,
//   est_addr1: null,
//   est_addr2: null,
//   est_city: null,
//   est_co_nm: null,
//   est_ct_fn: 'Monique',
//   est_ct_ln: 'Bruneau',
//   est_ctry: null,
//   est_ea: 'MONIQUE@STCAUTO.COM',
//   est_ph1: null,
//   est_st: null,
//   est_zip: null,
//   federal_tax_rate: 0.05,
//   g_bett_amt: 0,
//   id: '344fe1e0-4e0c-4f7b-9728-659c850d8192',
//   inproduction: true,
//   ins_addr1: null,
//   ins_addr2: null,
//   ins_city: null,
//   ins_co_id: null,
//   ins_co_nm: 'ICBC',
//   ins_ct_fn: null,
//   ins_ct_ln: null,
//   ins_ct_ph: null,
//   ins_ct_phx: null,
//   ins_ctry: null,
//   ins_ea: null,
//   ins_fax: null,
//   ins_faxx: null,
//   ins_memo: null,
//   ins_ph1: null,
//   ins_ph1x: null,
//   ins_ph2: null,
//   ins_ph2x: null,
//   ins_st: null,
//   ins_title: null,
//   ins_zip: null,
//   insd_addr1: null,
//   insd_addr2: null,
//   insd_city: null,
//   insd_co_nm: null,
//   insd_ctry: null,
//   insd_ea: null,
//   insd_fax: null,
//   insd_faxx: null,
//   insd_fn: null,
//   insd_ln: null,
//   insd_ph1: null,
//   insd_ph1x: null,
//   insd_ph2: null,
//   insd_ph2x: null,
//   insd_st: null,
//   insd_title: null,
//   insd_zip: null,
//   intakechecklist: {
//     addToProduction: true,
//     allow_text_message: false,
//     completed_at: '2024-09-05T23:04:31.439Z',
//     completed_by: 'allan@imex.dev',
//     form: [ [Object], [Object], [Object], [Object], [Object], [Object] ],
//     production_vars: {},
//     scheduled_completion: '2024-09-25T23:03:55.285Z',
//     scheduled_delivery: null
//   },
//   invoice_allocation: null,
//   invoice_date: null,
//   invoice_final_note: null,
//   iouparent: null,
//   job_totals: {
//     additional: {
//       additionalCostItems: [Array],
//       additionalCosts: [Object],
//       adjustments: [Object],
//       pvrt: [Object],
//       shipping: [Object],
//       storage: [Object],
//       total: [Object],
//       towing: [Object]
//     },
//     parts: { parts: [Object], sublets: [Object] },
//     rates: {
//       la1: [Object],
//       la2: [Object],
//       la3: [Object],
//       la4: [Object],
//       laa: [Object],
//       lab: [Object],
//       lad: [Object],
//       lae: [Object],
//       laf: [Object],
//       lag: [Object],
//       lam: [Object],
//       lar: [Object],
//       las: [Object],
//       lau: [Object],
//       mapa: [Object],
//       mash: [Object],
//       rates_subtotal: [Object],
//       subtotal: [Object]
//     },
//     totals: {
//       custPayable: [Object],
//       federal_tax: [Object],
//       local_tax: [Object],
//       net_repairs: [Object],
//       statePartsTax: [Object],
//       state_tax: [Object],
//       subtotal: [Object],
//       total_repairs: [Object]
//     }
//   },
//   kanbanparent: '-1',
//   kmin: null,
//   kmout: null,
//   labor_rate_desc: 'EST',
//   labor_rate_id: null,
//   lbr_adjustments: {},
//   local_tax_rate: null,
//   loss_cat: 'U',
//   loss_date: '2024-06-19',
//   loss_desc: 'Animal',
//   loss_of_use: null,
//   loss_type: 'A',
//   lost_sale_reason: null,
//   materials: {
//     mapa: { cal_maxdlr: 9999.99, cal_opcode: 'OP13' },
//     mash: { cal_maxdlr: 9999.99, cal_opcode: 'OP13' }
//   },
//   other_amount_payable: null,
//   owner_owing: 500,
//   ownerid: 'f392b24f-e828-47fa-bd17-2e5af8493147',
//   ownr_addr1: null,
//   ownr_addr2: null,
//   ownr_city: null,
//   ownr_co_nm: null,
//   ownr_ctry: null,
//   ownr_ea: null,
//   ownr_fax: null,
//   ownr_faxx: null,
//   ownr_fn: 'Neil',
//   ownr_ln: 'Leslie',
//   ownr_ph1: null,
//   ownr_ph1x: null,
//   ownr_ph2: null,
//   ownr_ph2x: null,
//   ownr_st: null,
//   ownr_title: null,
//   ownr_zip: null,
//   parts_tax_rates: {
//     CCC: {},
//     CCD: {},
//     CCDR: {},
//     CCF: {},
//     CCM: {},
//     PAA: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAA'
//     },
//     PAC: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAC'
//     },
//     PAG: {},
//     PAL: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAL'
//     },
//     PAM: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAM'
//     },
//     PAN: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAN'
//     },
//     PAO: {},
//     PAP: {},
//     PAR: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAR'
//     },
//     PAS: {
//       prt_discp: 0,
//       prt_mktyp: false,
//       prt_mkupp: 0,
//       prt_tax_in: true,
//       prt_tax_rt: 0.07,
//       prt_type: 'PAS'
//     },
//     PASL: {}
//   },
//   pay_amt: 0,
//   pay_chknm: '0',
//   pay_date: null,
//   pay_type: null,
//   payee_nms: null,
//   plate_no: 'B15717',
//   plate_st: 'MB',
//   po_number: null,
//   policy_no: '18292147',
//   production_vars: { note: 'testtsdsadsasdasdsadsdsadsd' },
//   qb_multiple_payers: null,
//   queued_for_parts: false,
//   rate_ats: null,
//   rate_la1: 0,
//   rate_la2: 0,
//   rate_la3: null,
//   rate_la4: 0,
//   rate_laa: 0,
//   rate_lab: 88.43,
//   rate_lad: null,
//   rate_lae: null,
//   rate_laf: 97.06,
//   rate_lag: 88.43,
//   rate_lam: 103.5,
//   rate_lar: 88.43,
//   rate_las: 88.43,
//   rate_lau: 0,
//   rate_ma2s: 0,
//   rate_ma2t: 0,
//   rate_ma3s: 0,
//   rate_mabl: null,
//   rate_macs: 0,
//   rate_mahw: 49.7,
//   rate_mapa: 56.67,
//   rate_mash: 7.23,
//   rate_matd: null,
//   referral_source: null,
//   referral_source_extra: null,
//   regie_number: null,
//   remove_from_ar: false,
//   ro_number: '10002',
//   scheduled_completion: '2024-09-25T23:03:55.285+00:00',
//   scheduled_delivery: null,
//   scheduled_in: '2024-09-05T22:00:55.2+00:00',
//   selling_dealer: null,
//   selling_dealer_contact: null,
//   servicing_dealer: null,
//   servicing_dealer_contact: null,
//   shopid: 'bfec8c8c-b7f1-49e0-be4c-524455f4e582',
//   special_coverage_policy: false,
//   state_tax_rate: null,
//   status: 'Repair Plan',
//   storage_payable: null,
//   suspended: false,
//   tax_lbr_rt: 0.07,
//   tax_levies_rt: 0.07,
//   tax_paint_mat_rt: 0.07,
//   tax_predis: 0,
//   tax_prethr: 0.07,
//   tax_pstthr: 0,
//   tax_registration_number: null,
//   tax_shop_mat_rt: 0.07,
//   tax_str_rt: 0.07,
//   tax_sub_rt: 0.07,
//   tax_thramt: 0,
//   tax_tow_rt: 0,
//   theft_ind: false,
//   tlos_ind: false,
//   towin: false,
//   towing_payable: null,
//   unit_number: null,
//   updated_at: '2024-09-12T19:25:48.492299+00:00',
//   v_color: 'Polished Metal Metal',
//   v_make_desc: 'Honda',
//   v_model_desc: 'Civic',
//   v_model_yr: '17',
//   v_vin: 'SHHFK7H20HU306419',
//   vehicleid: '811ba420-e9db-430b-b341-22e197c8dd0e',
//   voided: false
// }
// I have been hit, wewet
// job-transition-update-result {
//   type: 'DEBUG',
//   env: 'development',
//   user: null,
//   record: '344fe1e0-4e0c-4f7b-9728-659c850d8192',
//   insert_transitions_one: { id: '88e73841-247d-4e31-b31c-f1b2ca8364d9' },
//   update_transitions: { affected_rows: 1 }
// }