@kiina/salesforce/src/case.api.js

const {decode} = require('base64-arraybuffer');
const uuid = require('uuid');
const moment = require('moment-timezone');
const Logger = require('@kiina/logger');

const logger = new Logger('CASE-API');

class CaseApi {

  constructor(config, driver = require('nforce')) {
    this.__driver = driver;
    this.__config = config;
    this.__connection = this.__driver.createConnection(config);
  }

  static getInstance(config) {
    if(!this.instance) this.instance = new CaseApi(config);
    return this.instance;
  }

  authenticate() {
    const { username, password, securityToken } = this.__config;
    return new Promise((resolve, reject) => {
      this.__connection.authenticate({ username, password, securityToken }, (error, oauth) => {
        if (error) {
          logger.error('AuthenticationError:', error.stack);
          return reject(error);
        }
        else resolve(oauth);
      });
    });
  }

  __createCaseObject(args = {}) {
    return this.__driver.createSObject('Case', { ...args });
  }

  async __insertCase(sobject) {
    const oauth = await this.authenticate();
    return new Promise((resolve, reject) => {
      this.__connection.insert({ sobject, oauth }, (error, resp) => {
        if (error) {
          logger.error('InsertCaseError:', error.stack);
          return reject(error);
        }
        else resolve(resp);
      });
    });
  }

  __getCaseId(oauth, sessionId){
    let query = `SELECT caseID, ID, ChatKey, ownerID FROM LiveChatTranscript WHERE ChatKey = '${sessionId}' 
                 LIMIT 1`;
    return new Promise((resolve, reject) => {
      this.__connection.query({ query: query }, function(err, res) {
        logger.info("__getCaseId", res);
        if(err) {
          logger.error(err);
          return reject(err);
        }
        else {
          resolve(res.records[0]);
        }
      });
    });
  }

  __insertObject(oauth, caseID, tableName, data) {
    return new Promise((resolve, reject) => { 
      let sobject = this.__driver.createSObject(tableName, data);
      this.__connection.insert({sobject, oauth}, (err, resp) => {
        if(err) {
          logger.error('err:', err);
          reject(err);
        }
        resolve(resp.id);
      })
    });
  }

  async __insertFiles(oauth, caseID, fileObject, fileName) {
    fileObject = decode(fileObject);
    let att = {
      Name: fileName,
      ParentId: caseID,
      attachment: {
        fileName: fileName,
        body: fileObject
      }
    };
    return await this.__insertObject(oauth, caseID, 'Attachment', att);
  }

  async insertFiles(sessionId, filesObject, filesName) {
    const oauth = await this.authenticate();
    let caseID = await this.__getCaseId(oauth, sessionId);
    for(let file = 0; file < filesObject.length; file++){
      await this.__insertFiles(oauth, caseID._fields.caseid, filesObject[file], filesName[file]);
    }
  }

  async __saveNPS(oauth, caseID, ownerID, area, npsScore, name, client, RecordTypeId){
    let surveyId = uuid.v4();
    let att = {
      Name: name, //identify the area
      Caso_Associado__c: caseID,
      AreaNPS__c: area, //identify the area
      Nota_Atendimento__c: npsScore,
      Assessor_Atendente__c: ownerID,
      survey_id__c: surveyId, //generate uuid.v4
      RecordTypeId,
      NPS_Conta_Rico__r: {
        Numero_da_Conta_Rico__c: client.toString()
      },
      NPS_Data_de_resposta__c: moment().tz('America/Sao_Paulo').format() 
    };
    let respInsertObj = await this.__insertObject(oauth, caseID, 'NPS__c', att);
    console.log('respInsertObj', respInsertObj);
    return respInsertObj;
  }

  async saveNPS(sessionId, area, npsScore, name, client, RecordTypeId) {
    const oauth = await this.authenticate();
    let caseID = await this.__getCaseId(oauth, sessionId);
    let resp__saveNPS = await this.__saveNPS(oauth, caseID._fields.caseid, caseID._fields.ownerid, area, npsScore, name, client, RecordTypeId);
    console.log('resp__saveNPS', resp__saveNPS);
    return resp__saveNPS;
  }

  async __saveCSAT(oauth, npsScore, name, lastMessages, client, atendantId, RecordTypeId){
    let surveyId = uuid.v4();    
    let att = {
      Name: name, //identify the area
      Nota_Atendimento__c: npsScore,
      Assessor_Atendente__c: atendantId,
      survey_id__c: surveyId, //generate uuid.v4
      RecordTypeId,
      Comentario__c: lastMessages,
      NPS_Conta_Rico__r: {
        Numero_da_Conta_Rico__c: client.toString()
      },
      NPS_Data_de_resposta__c: moment().tz('America/Sao_Paulo').format()
    };
    return await this.__insertObject(oauth, null, 'NPS__c', att);
  }

  async saveCSAT(npsScore, name, lastMessages,client, atendantId, RecordTypeId ) {
    const oauth = await this.authenticate();
    this.__saveCSAT(oauth, npsScore, name, lastMessages, client, atendantId, RecordTypeId);
  }


  async createCase(sfCase) {
    sfCase = sfCase || {};
    sfCase = this.__createCaseObject(sfCase);
    await this.__insertCase(sfCase);
  }
}

module.exports = CaseApi;