const flatten = require('flat')
const unflatten = require('flat').unflatten
const axios = require('axios')
const CRM_Contact = require('../models/CRM_Contact')
const CRM_Ticket = require('../models/CRM_Ticket')
const { URL } = require('url')
const findProperty = require('./findProperty')
const CRM = require('../models/CRM')
const requestConfigHeader = require('./requestConfigHeader')
const sendEventTicketCreatedToSocket = require('./sendEventTicketCreatedToSocket')
const generateC4CServiceRequestDeepLinkBase64 = require('./generateC4CServiceRequestDeepLinkBase64')


async function createTicket(companyId, rest, authentication, crmPhone, crmFirstName = 'Username', crmLastName = 'Last name', crmEmail = '', test = {}, contact, crmAgent, saveTicket = true, dynamicBodyRequest = {}) {

    let ticketUrl = ''
    let crmContactId = contact.contactId

    let flow = contact?.flow
    let propertyKey

    switch (flow) {
        case 2:
            propertyKey = 'createTicketRecord2'
            break
        default:
            propertyKey = 'createTicketRecord'
            break
    }

    console.log('==============> propertyKey createTicketRecord2: ', propertyKey)

    let { request, body, response } = findProperty(rest, propertyKey)

    console.log('==============> crmContactId: ', crmContactId)
    console.log('==============> crmPhone: ', crmPhone)
    console.log("==============> contact?.flow: ", contact?.flow)


    const { requestContentType, requestEncoding, requestType, responseType, url } = request

    console.log('========> body1: ', JSON.stringify(body, null, 6))
    console.log("==========>createTicket contact: ", JSON.stringify(contact, null, 6))

    body = flatten(body)

    console.log('========> body2: ', JSON.stringify(body, null, 6))

    const mapping = {
        crmFirstName,
        crmLastName,
        crmPhone,
        crmEmail,
        crmContactId,
        crmAccountId: contact?.accountId
    }

    for (const prop in body) {
        if (mapping.hasOwnProperty(body[prop])) {
            const variable = mapping[body[prop]]
            if (variable) {
                body[prop] = variable
            } else {
                if (body[prop] == 'crmLastName' && !crmLastName) {
                    body[prop] = 'Username'
                }
                else
                    delete body[prop]
            }
        }
    }

    body = unflatten(body)

    console.log('========> body3: ', JSON.stringify(body, null, 6))

    const { type, userName, passWord, token, crmClientId, crmAccountId } = authentication

    //url, crmPhone, requestType, requestContentType, type, userName, passWord, token, crmClientId, data = '', ticketId = '', companyId
    let config = await requestConfigHeader(url, crmPhone, requestType, requestContentType, type, userName, passWord, token, crmClientId, body, '', companyId)

    if (test?.testing) {
        msg = `Tentanto criar ticket do numero ${crmPhone} no crm`
        sendMessageSocket({ companyId, status: 'processing', data: { request: config, msg } })
    }

    console.log('===============> createTicket: ', JSON.stringify(config, null, 6))

    console.log('===============> dynamicBodyRequest: ', JSON.stringify(dynamicBodyRequest, null, 6))

    if (dynamicBodyRequest && Object.keys(dynamicBodyRequest).length !== 0) {
        config.data = { ...config.data, ...dynamicBodyRequest }
        console.log('#####################')
        console.log('CREATE TICKET PAYLOAD UPDATED BY DYNAMIC BODY REQUEST: ', JSON.stringify(config, null, 6))
        console.log('#####################')
    }

    let resp

    try {

        console.log("========> createTicket PAYLOAD: ", JSON.stringify(config, null, 6))

        resp = await axios(config)

    } catch (error) {

        if (error.response) {
            console.error('==================> createTicket Erro na resposta da API:', {
                status: error.response.status,
                data: error.response.data,
            })
        }
        else if (error.request) {
            console.error('==================> createTicket Nenhuma resposta recebida da API:', error?.request)
        }
        else {
            console.error('==================> createTicket Erro ao configurar a request:', error?.message)
        }

        if (error?.response?.status == 404)
            return { error: 404 }
    }

    let { data } = resp

    data = flatten(data)

    let auxTicketId
    let auxTicketId2


    for (const prop in data) {

        const _prop = prop.replace(/^\d+\./, '').replace(/(?:^|\.)\d+\b/g, '')

        if (_prop == response?.id?.trim()) {
            auxTicketId = data[prop]
        }

        if (_prop == response?.objectId?.trim()) {
            auxTicketId2 = data[prop]
        }
    }

    console.log("========> createTicket auxTicketId: ", auxTicketId, " | auxTicketId2: ", auxTicketId2)

    if (auxTicketId && !test?.testing) {

        let contact2 = await CRM_Contact.findOne({ companyId, crmBaseURL: new URL(url).hostname, phone: crmPhone })

        if (!contact2) {
            const crm = await CRM.findOne({ companyId, crmBaseURL: new URL(url).hostname })
            contact2 = await CRM_Contact.create({ companyId, crm, crmBaseURL: new URL(url).hostname, contactId: contact.contactId, phone: crmPhone })
        }

        if (saveTicket) {
            const crm = await CRM.findOne({ companyId, crmBaseURL: new URL(url).hostname })
            await CRM_Ticket.create({ companyId, contact: contact2, ticketId: auxTicketId, ticketId2: auxTicketId2, crm })
        }

        if (url.includes("hubapi")) {
            ticketUrl = `https://app.hubspot.com/contacts/${crmAccountId}/ticket/${auxTicketId}`
        }
        else if (url.includes("c4codataapi")) {
            ticketUrl = `https://my365398.crm.ondemand.com/sap/ap/ui/clogin?saml2=disabled&app.component=%2fSAP_UI_CT%2fMain%2froot.uiccwoc&rootWindow=X&redirectUrl=%2fsap%2fpublic%2fbyd%2fruntime&supressAutoLogon=true&sap-ui-language=en_us#Nav/1/${generateC4CServiceRequestDeepLinkBase64(auxTicketId2)}`
        }

        sendEventTicketCreatedToSocket({ companyId, extension: crmAgent, ticketUrl: ticketUrl })

    }

    return { exist: true, ticketId: auxTicketId, ticketId2: auxTicketId2, phone: crmPhone, ticketUrl }

}

module.exports = createTicket