111 lines
3.8 KiB
JavaScript
111 lines
3.8 KiB
JavaScript
const { dateTime, secondsFormat, getPastDateTimeFromSeconds } = require('./dateTime')
|
|
const requestConfigHeader = require('./requestConfigHeader')
|
|
const flatten = require('flat')
|
|
const unflatten = require('flat').unflatten
|
|
const axios = require('axios')
|
|
const path = require('path')
|
|
const convertToIntegerIfNumber = require('./convertToIntegerIfNumber')
|
|
const sendMessageSocket = require('./sendMessageSocket')
|
|
|
|
async function journalingRequest(request, body, crmCallDuration, contact, crmAgent, crmPhone, authentication, test = {}) {
|
|
const { requestContentType, requestEncoding, requestType, responseType, url } = request
|
|
|
|
body = flatten(body)
|
|
|
|
let ignore = []
|
|
|
|
for (let key in body) {
|
|
|
|
const k = Object.keys(body).find(k => {
|
|
if (!ignore.includes(k) && k.includes('._prop') && k.replace('._prop', '._type') ==
|
|
key.replace('._prop', '._type')) {
|
|
ignore.push(key)
|
|
return true
|
|
}
|
|
}
|
|
)
|
|
|
|
if (k) {
|
|
const type = body[k.replace('._prop', '._type')]
|
|
const format = body[k.replace('._prop', '._format')]
|
|
|
|
const newKey = k.replace('._prop', '').replace('._type', '').replace('._format', '')
|
|
|
|
if (body[key] == 'crmCallDuration') {
|
|
switch (format) {
|
|
case 'hh:mm':
|
|
body[newKey] = secondsFormat(crmCallDuration, 'hh:mm')
|
|
break
|
|
case 'milliseconds':
|
|
body[newKey] = secondsFormat(crmCallDuration, 'milliseconds')
|
|
break
|
|
case 'seconds':
|
|
body[newKey] = secondsFormat(crmCallDuration, 'seconds')
|
|
break
|
|
}
|
|
}
|
|
else if (body[key] == 'crmCallDateTime') {
|
|
switch (format) {
|
|
case 'ISO8601':
|
|
body[newKey] = crmCallDuration ? getPastDateTimeFromSeconds(dateTime(), crmCallDuration) : dateTime()
|
|
break
|
|
}
|
|
}
|
|
else if (body[key] == 'crmContactId') {
|
|
body[newKey] = contact.contactId
|
|
}
|
|
else if (body[key] == 'crmAgent') {
|
|
body[newKey] = crmAgent
|
|
}
|
|
else if (body[key] == 'crmPhone') {
|
|
body[newKey] = crmPhone
|
|
}
|
|
|
|
const property = body[newKey] ? body[newKey] : body[key]
|
|
|
|
switch (type) {
|
|
case 'number':
|
|
body[newKey] = convertToIntegerIfNumber(property)
|
|
break
|
|
case 'string':
|
|
body[newKey] = `${property}`
|
|
break
|
|
case 'boolean':
|
|
body[newKey] = Boolean(property)
|
|
break
|
|
}
|
|
continue
|
|
}
|
|
|
|
switch (body[key]) {
|
|
case 'crmPhone':
|
|
body[key] = crmPhone
|
|
break
|
|
case 'crmContactId':
|
|
body[key] = contact.contactId
|
|
break
|
|
case 'crmAgent':
|
|
body[key] = crmAgent
|
|
break
|
|
case 'crmCallDuration':
|
|
body[key] = crmCallDuration
|
|
break
|
|
}
|
|
|
|
}
|
|
|
|
const data = unflatten(body)
|
|
|
|
const { type, userName, passWord, token, crmClientId } = authentication
|
|
|
|
const config = await requestConfigHeader(url, crmPhone, requestType, requestContentType, type, userName, passWord, token, crmClientId, data)
|
|
|
|
if (test?.testing && test?.companyId && test?.msg) {
|
|
sendMessageSocket({ companyId: test.companyId, status: 'processing', data: { request: config, msg: test.msg } })
|
|
}
|
|
// console.log('JOURNALING CONFIG: ', config)
|
|
|
|
const res = await axios(config)
|
|
}
|
|
|
|
module.exports = journalingRequest |