app2-api/modules/events/marketing_list.service.js

"use strict";

const eventInscriptionService = require("./events_inscriptions.service");
const marketing = require("../../helpers/sendinblue.helper");

////////////////////////////////////////////////////////////////////
// dataInscription {incription:{...}, event:{...}, reservation:{...}, user:{...}}
////////////////////////////////////////////////////////////////////
/*AHORA SE ALMACENA TODO EN UNA ÚNICA LISTA DE MAILCHIMP, QUE ES LA DEL EVENTO 
(si en un futuro se quiere tener listas independientes, bastaría con tratarlo aqui los campos de marketinglist de la reserva ...)
      if (dataInscription.inscription.reservationId)
          marketingListOfInscription = dataInscription.reservation.marketingList
      else if (dataInscription.inscription.overflowEventId)
          marketingListOfInscription = (await _getEvent(dataInscription.inscription.overflowEventId)).marketingList;
      else 
          marketingListOfInscription = dataInscription.event.marketingList;
*/
function _generateMarketingDTO(dataInscription) {
  console.log('entro _generateMarketingDTO >>> ', dataInscription);

  let { event, inscription, user, reservation } = dataInscription;
  let inscriptionDTO = {};
  //let inscription = dataInscription.inscription ? dataInscription.inscription : dataInscription;

  if (!event) {
    throw new Error('Falta datos del evento en la inscripción (_generateMarketingDTO)');
  }

  if (!event.marketing_list) {
    console.warn('Falta rellenar la lista de Sendinblue en el evento (_generateMarketingDTO)', event.name);
  }

  if (inscription) {
    inscriptionDTO.id = inscription.id;
    inscriptionDTO.source = inscription.source;
    inscriptionDTO.event_name = event.name ? event.name : "N/A";
    inscriptionDTO.event_date = event.init_date ? event.init_date : "N/A";
    inscriptionDTO.event_marketing_list = event ? event.marketing_list : null;
    inscriptionDTO.date_inscription = inscription.date;
    inscriptionDTO.code_ticket = inscription.code_ticket;
    inscriptionDTO.validated = inscription.validated;

    inscriptionDTO.reservation_code = reservation ? reservation.reservation_code : null;
    inscriptionDTO.color = reservation ? reservation.color : "darkgreen";
    inscriptionDTO.description = (reservation ? reservation.description : "Entrada").toUpperCase();
    inscriptionDTO.qrConfig = null;
    inscriptionDTO.qrCode = null;

    if (user) {
      //Era para mailchimp      
      ///        inscriptionDTO.marketing_memberId = inscription.marketing_memberId ? inscription.marketing_memberId : null;
      inscriptionDTO.email = user.email;
      inscriptionDTO.name = user.name;
      inscriptionDTO.surname = user.surname;
      inscriptionDTO.userId = user.id;
      inscriptionDTO.entity = reservation && reservation.Entity ? reservation.Entity.name : (user.Entity ? user.Entity.name : user.entityId);
    };

  }
  console.log('salgo>>>', inscriptionDTO);
  return inscriptionDTO;
}

function sleep(time) {
  return new Promise((resolve) => setTimeout(resolve, time));
}


async function _addMember(inscriptionDTO) {
  console.debug('>>>> _addMember', inscriptionDTO.email);
  console.debug('>>>> event_marketing_list', inscriptionDTO.event_marketing_list);
  //        console.debug(member);

  return new Promise(function (resolve, reject) {
    if (!inscriptionDTO.event_marketing_list) {
      // || !member.validated) {
      resolve(inscriptionDTO);
    } else {
      marketing
        .addMemberToList(inscriptionDTO.event_marketing_list, inscriptionDTO)
        .then(function (result) {
          resolve(result.ID);
        })
        .catch(function (error) {
          reject(error);
        });
    }
  });
}

async function _deleteMember(idLista, email) {
  console.debug(
    "Elimino miembro de la lista de marketing>>>>>>>>>>>>>>>>>>>>>>>>>>>>><<",
    email,
    idLista,
  );

  return new Promise(function (resolve, reject) {
    if (!idLista || !email) {
      resolve();
    } else {
      resolve(marketing.deleteMemberFromList(idLista, email));
    }
  });
}


async function addMarketingList(dataUser, dataInscription) {
  dataInscription.user = dataUser.userResult.user;
  return _addMember(_generateMarketingDTO(dataInscription));
}





async function syncronizeEventWithMarketingList(eventId) {
  let result = false;
  try {
    let inscriptionsToSync = await eventInscriptionService._getInscriptionsWithoutMemberId(eventId);


    for (var i = 0; i < inscriptionsToSync.length; i++) {
      const item = inscriptionsToSync[i].get({
        plain: true
      });
      //Adaptamos el objeto a lo que espera _generateMarketingDTO
      // dataInscription {incription:{...}, event:{...}, reservation:{...}, user:{...}}
      // en _getInscriptionsWithoutMemberId devuelve la inscripcion en el raiz
      item.inscription = item;
      sleep(1000 * i).then(function () {
        let inscriptionDTO = _addMember(_generateMarketingDTO(item));
        //                let marketingDTO = _generateMarketingDTO(item);
        //                console.log(marketingDTO)
        //                _deleteMember(marketingDTO.event_marketing_list, marketingDTO.email)
      });

    };

    result = true;
    return result;
  } catch (error) {
    console.log("No se ha podido _syncronizeEventWithMarketingList", error);
  }
}


function userToMarketingDTO(user) {
  const result = {};
  result.email = user.email ? user.email : '';
  result.name = user.name ? user.name : '';
  result.surname = user.surname ? user.surname : '';
  result.userId = user.id ? user.id : '';
  result.entity = user.Entity ? user.Entity.name : '';

  return result;
}


module.exports = {
  syncronizeEventWithMarketingList,
  addMarketingList,
  _deleteMember,
  _generateMarketingDTO,
  userToMarketingDTO,

};