faab68ace1aa9635dbad0ae26980094fe060b2d8
[motion-next.git] / server / components / import / cm / csv.js
1 const a830_0x5f34=['createdAt','Duplicate\x20Contact','findAll','all','exit','CSV\x20import\x20process\x20stopped!','where','str','CSV\x20parse\x20error','checkHopper','CmList','argv','outbound','cm_hopper_final','inspect','select','firstName\x20not\x20specified!','query','onlyIfOpen','message','phone\x20not\x20specified!','birthDate','generalCheckHopper','papaparse','finally','ContactId','field','Lists','createReadStream','cm_hopper','register','always','Missing\x20binding\x20parameters!','phone\x20NOT\x20IN\x20(?)','updatedAt','push','../../../mysqldb','squel','error','api','firstName','duplicate','insert','CSV\x20parsed\x20correctly!','split','phone\x20IS\x20NOT\x20NULL','moment','scheduledAt','Error\x20while\x20creating\x20contact:\x20','NOW()','cm_hopper_black','ListId\x20=\x20?','lodash','ListId','test','../../../api/cmContact/cmContact.socket','into','SIGINT','BlackLists','Missing\x20socket_timestamp\x20parameter!','length','pause','VoiceQueueId','isNil','calleridnum','parse','deletedAt\x20IS\x20NULL','resume','create','null','contact:csv_','find','../../../rediscache','info','resolve','toString','VoiceQueue','stringify','errors','id\x20IN\x20?','Campaign','zipObject','undefined','Error\x20executing\x20contact\x20csv\x20import:','email','fromQuery','cm_contacts','data','contact','map','dialCheckDuplicateType','Unable\x20to\x20delete\x20temp\x20file:','keys','cmContact,\x20%s,\x20%s','then','sequelize','emit','pick','index','from','phone','catch','YYYY-MM-DD','get','CampaignId','util','join'];(function(_0x35ea5a,_0x5f34fa){const _0x20f29f=function(_0x79fc6e){while(--_0x79fc6e){_0x35ea5a['push'](_0x35ea5a['shift']());}};_0x20f29f(++_0x5f34fa);}(a830_0x5f34,0x167));const a830_0x20f2=function(_0x35ea5a,_0x5f34fa){_0x35ea5a=_0x35ea5a-0x0;let _0x20f29f=a830_0x5f34[_0x35ea5a];return _0x20f29f;};const _0x34d6d9=a830_0x20f2;'use strict';const util=require(_0x34d6d9('0x43')),_=require(_0x34d6d9('0xe')),fs=require('fs'),squel=require(_0x34d6d9('0x6a')),Papa=require(_0x34d6d9('0x5c')),moment=require(_0x34d6d9('0x8')),db=require(_0x34d6d9('0x69'))['db'],logger=require('../../../config/logger')(_0x34d6d9('0x1')),{getSocket}=require(_0x34d6d9('0x22')),socket=getSocket();require(_0x34d6d9('0x11'))[_0x34d6d9('0x63')](socket);let FILEPATH,FIELDS,LISTID,COMPANYID,DUPLICATES,SOCKET_TIMESTAMP;try{if(!process[_0x34d6d9('0x50')][0x2]||process[_0x34d6d9('0x50')][0x2]===_0x34d6d9('0x2c')||process[_0x34d6d9('0x50')][0x2]===_0x34d6d9('0x1f'))throw new Error('Missing\x20filepath\x20parameter!');FILEPATH=process[_0x34d6d9('0x50')][0x2];if(!process[_0x34d6d9('0x50')][0x3]||process[_0x34d6d9('0x50')][0x3]===_0x34d6d9('0x2c')||process[_0x34d6d9('0x50')][0x3]===_0x34d6d9('0x1f')||!process['argv'][0x4]||process[_0x34d6d9('0x50')][0x4]===_0x34d6d9('0x2c')||process['argv'][0x4]===_0x34d6d9('0x1f'))throw new Error(_0x34d6d9('0x65'));FIELDS=_[_0x34d6d9('0x2b')](process[_0x34d6d9('0x50')][0x3][_0x34d6d9('0x6')](','),process['argv'][0x4][_0x34d6d9('0x6')](','));if(!process[_0x34d6d9('0x50')][0x5]||process['argv'][0x5]===_0x34d6d9('0x2c')||process[_0x34d6d9('0x50')][0x5]===_0x34d6d9('0x1f'))throw new Error('Missing\x20ListId\x20parameter!');LISTID=process[_0x34d6d9('0x50')][0x5],COMPANYID=process[_0x34d6d9('0x50')][0x6]&&process[_0x34d6d9('0x50')][0x6]!==_0x34d6d9('0x2c')&&process[_0x34d6d9('0x50')][0x6]!==_0x34d6d9('0x1f')?process[_0x34d6d9('0x50')][0x6]:null,DUPLICATES=process[_0x34d6d9('0x50')][0x7]&&process[_0x34d6d9('0x50')][0x7]!==_0x34d6d9('0x2c')&&process[_0x34d6d9('0x50')][0x7]!==_0x34d6d9('0x1f')?process[_0x34d6d9('0x50')][0x7]:null;if(!process[_0x34d6d9('0x50')][0x8]||process[_0x34d6d9('0x50')][0x8]===_0x34d6d9('0x2c')||process[_0x34d6d9('0x50')][0x8]===_0x34d6d9('0x1f'))throw new Error(_0x34d6d9('0x15'));SOCKET_TIMESTAMP=process[_0x34d6d9('0x50')][0x8];}catch(a830_0x79fc6e){logger[_0x34d6d9('0x0')](a830_0x79fc6e),endCsv();}let total=0x0,success=0x0,errors=0x0,duplicates=0x0,rows=[],hopperContacts='',promises=[];function handleCheckRowError(_0x242b96,_0x35ee47,_0x42fb1d,_0x12e465){const _0x524e5e=_0x34d6d9,_0xf1ab41={'message':_0x35ee47};return _0xf1ab41[_0x242b96]=!![],_0x42fb1d&&(_0xf1ab41[_0x524e5e('0x32')]=_0x42fb1d),_0x12e465&&(_0xf1ab41[_0x524e5e('0x3c')]=_0x12e465),_0xf1ab41;}function isEmail(_0x29a537){const _0x9405fd=_0x34d6d9;return/^([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22))*\x40([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d))*$/[_0x9405fd('0x10')](_0x29a537);}function checkRow(_0x3111d9,_0x476187,_0x35c5cc){return new Promise(function(_0x1aad77,_0x30090b){const _0x1e9aef=a830_0x20f2;if(_[_0x1e9aef('0x19')](_0x3111d9))return _0x30090b(handleCheckRowError(_0x1e9aef('0x0'),'The\x20row\x20is\x20empty\x20or\x20the\x20number\x20of\x20parameters\x20does\x20not\x20match\x20the\x20columns!',null,_0x35c5cc));if(_0x3111d9[_0x1e9aef('0x28')]&&_0x3111d9[_0x1e9aef('0x28')][_0x1e9aef('0x16')]){const _0x3c3f68=_[_0x1e9aef('0x33')](_0x3111d9[_0x1e9aef('0x28')],'message')[_0x1e9aef('0x44')](';');return _0x30090b(handleCheckRowError(_0x1e9aef('0x0'),_0x3c3f68,null,_0x35c5cc));}const _0x1dd361={};for(const _0x5e9e0c in FIELDS){typeof FIELDS[_0x5e9e0c]!==_0x1e9aef('0x2c')&&FIELDS[_0x5e9e0c]&&(_0x1dd361[_0x5e9e0c]=_0x3111d9['data'][0x0][FIELDS[_0x5e9e0c]]||_0x3111d9[_0x1e9aef('0x31')][0x0]['\ufeff'+FIELDS[_0x5e9e0c]]);}if(!_0x1dd361[_0x1e9aef('0x2')])return _0x30090b(handleCheckRowError('error',_0x1e9aef('0x55'),null,_0x35c5cc));if(!_0x1dd361[_0x1e9aef('0x3e')])return _0x30090b(handleCheckRowError(_0x1e9aef('0x0'),_0x1e9aef('0x59'),null,_0x35c5cc));if(_0x1dd361[_0x1e9aef('0x5a')]){const _0x26667b=moment(_0x1dd361['birthDate'],_0x1e9aef('0x40'));if(!_0x26667b['isValid']())return _0x30090b(handleCheckRowError(_0x1e9aef('0x0'),'birthDate\x20format\x20is\x20invalid,\x20YYYY-MM-DD\x20format\x20is\x20supported!',null,_0x35c5cc));}if(_0x1dd361[_0x1e9aef('0x2e')]){if(!isEmail(_0x1dd361[_0x1e9aef('0x2e')]))return _0x30090b(handleCheckRowError(_0x1e9aef('0x0'),'email\x20format\x20is\x20not\x20valid!',null,_0x35c5cc));}_0x1dd361['ListId']=LISTID,_0x1dd361['CompanyId']=COMPANYID||undefined;if(DUPLICATES&&DUPLICATES[_0x1e9aef('0x16')]&&_0x476187){const _0x246f17={};for(let _0x3b66b6=0x0,_0x46b754=DUPLICATES[_0x1e9aef('0x16')];_0x3b66b6<_0x46b754;_0x3b66b6+=0x1){_0x246f17[DUPLICATES[_0x3b66b6]]=_0x1dd361[DUPLICATES[_0x3b66b6]];}const _0x189e79=_[_0x1e9aef('0x21')](_0x476187,_0x246f17);if(_0x189e79)return _0x30090b(handleCheckRowError('duplicate',_0x1e9aef('0x46'),_0x189e79,_0x35c5cc));}return db['CmContact'][_0x1e9aef('0x1e')](_0x1dd361,{'raw':!![],'hooks':![],'fields':_[_0x1e9aef('0x36')](_0x1dd361)})[_0x1e9aef('0x38')](function(_0x2c00d0){const _0x39c8cc=_0x1e9aef;return DUPLICATES&&DUPLICATES['length']&&_0x476187&&_0x476187['push'](_[_0x39c8cc('0x3b')](_0x1dd361,DUPLICATES)),hopperContacts+=(hopperContacts?',':'')+_0x2c00d0['id'],_0x1aad77();})[_0x1e9aef('0x3f')](function(_0x3f1e49){const _0x31ef4a=_0x1e9aef;return _0x30090b(handleCheckRowError(_0x31ef4a('0x0'),_0x31ef4a('0xa')+(_0x3f1e49[_0x31ef4a('0x58')]||JSON['stringify'](_0x3f1e49)),null,_0x35c5cc));});});}function checkHopper(){const _0x238491=_0x34d6d9;function _0x48cbff(){return function(_0x5f2c74){const _0x1fb731=a830_0x20f2;logger['error']('cmContact',_0x1fb731('0x4e'),util[_0x1fb731('0x53')](_0x5f2c74,{'showHidden':![],'depth':null}));};}const _0x3b1294=function(_0x45c9ad,_0x48f28b){const _0x412bad=a830_0x20f2,_0x432920=squel[_0x412bad('0x4')]()[_0x412bad('0x12')](_0x412bad('0x62'))[_0x412bad('0x2f')]([_0x412bad('0x3e'),_0x412bad('0x9'),_0x412bad('0x5e'),'ListId',_0x48f28b,_0x412bad('0x45'),_0x412bad('0x67')],squel[_0x412bad('0x54')]()[_0x412bad('0x5f')](_0x412bad('0x3e'),_0x412bad('0x3e'))[_0x412bad('0x5f')](_0x412bad('0xb'),'scheduledAt')[_0x412bad('0x5f')]('id',_0x412bad('0x5e'))[_0x412bad('0x5f')](LISTID[_0x412bad('0x25')](),_0x412bad('0xf'))[_0x412bad('0x5f')](_0x45c9ad['id'][_0x412bad('0x25')](),_0x48f28b)[_0x412bad('0x5f')]('NOW()','createdAt')['field']('NOW()','updatedAt')['from'](_0x412bad('0x30'))[_0x412bad('0x4b')](_0x412bad('0x1c'))[_0x412bad('0x4b')](_0x412bad('0xd'),LISTID[_0x412bad('0x25')]())['where'](_0x412bad('0x7'))[_0x412bad('0x4b')]('phone\x20NOT\x20IN\x20(?)',squel[_0x412bad('0x54')]()['field'](_0x412bad('0x3e'))[_0x412bad('0x3d')]('cm_hopper')[_0x412bad('0x4b')](_0x48f28b+'\x20=\x20?',_0x45c9ad['id'][_0x412bad('0x25')]())))[_0x412bad('0x25')]();return _0x432920;},_0x2bbb11=function(_0x10f5b2,_0x38f719){const _0x18edd3=a830_0x20f2,_0x55e0a7=squel['insert']()[_0x18edd3('0x12')](_0x18edd3('0x62'))[_0x18edd3('0x2f')]([_0x18edd3('0x3e'),_0x18edd3('0x9'),_0x18edd3('0x5e'),_0x18edd3('0xf'),_0x38f719,_0x18edd3('0x45'),_0x18edd3('0x67')],squel['select']()[_0x18edd3('0x5f')](_0x18edd3('0x3e'),'phone')[_0x18edd3('0x5f')](_0x18edd3('0xb'),_0x18edd3('0x9'))[_0x18edd3('0x5f')]('id','ContactId')[_0x18edd3('0x5f')](LISTID[_0x18edd3('0x25')](),_0x18edd3('0xf'))['field'](_0x10f5b2['id']['toString'](),_0x38f719)[_0x18edd3('0x5f')]('NOW()','createdAt')[_0x18edd3('0x5f')](_0x18edd3('0xb'),_0x18edd3('0x67'))[_0x18edd3('0x3d')](_0x18edd3('0x30'))[_0x18edd3('0x4b')](_0x18edd3('0x1c'))['where'](_0x18edd3('0xd'),LISTID['toString']())['where'](_0x18edd3('0x29'),squel[_0x18edd3('0x4c')](hopperContacts))[_0x18edd3('0x4b')](_0x18edd3('0x7'))[_0x18edd3('0x4b')]('phone\x20NOT\x20IN\x20(?)',squel[_0x18edd3('0x54')]()[_0x18edd3('0x5f')](_0x18edd3('0x1a'))[_0x18edd3('0x3d')](_0x18edd3('0x52'))['where'](_0x38f719+'\x20=\x20?',_0x10f5b2['id'][_0x18edd3('0x25')]()))[_0x18edd3('0x4b')](_0x18edd3('0x66'),squel['select']()[_0x18edd3('0x5f')](_0x18edd3('0x3e'))[_0x18edd3('0x3d')](_0x18edd3('0x62'))[_0x18edd3('0x4b')](_0x38f719+'\x20=\x20?',_0x10f5b2['id'][_0x18edd3('0x25')]())))[_0x18edd3('0x25')]();return _0x55e0a7;};function _0x201d56(_0x5bea03,_0x5dfe28){const _0x86b0e3=a830_0x20f2,_0x373211=squel[_0x86b0e3('0x4')]()[_0x86b0e3('0x12')](_0x86b0e3('0x62'))[_0x86b0e3('0x2f')](['phone','scheduledAt',_0x86b0e3('0x5e'),'ListId',_0x5dfe28,_0x86b0e3('0x45'),_0x86b0e3('0x67')],squel[_0x86b0e3('0x54')]()['field'](_0x86b0e3('0x3e'),'phone')[_0x86b0e3('0x5f')](_0x86b0e3('0xb'),'scheduledAt')[_0x86b0e3('0x5f')]('id',_0x86b0e3('0x5e'))[_0x86b0e3('0x5f')](LISTID['toString'](),_0x86b0e3('0xf'))[_0x86b0e3('0x5f')](_0x5bea03['id'][_0x86b0e3('0x25')](),_0x5dfe28)[_0x86b0e3('0x5f')]('NOW()',_0x86b0e3('0x45'))[_0x86b0e3('0x5f')](_0x86b0e3('0xb'),_0x86b0e3('0x67'))['from']('cm_contacts')[_0x86b0e3('0x4b')](_0x86b0e3('0x1c'))['where']('ListId\x20=\x20?',LISTID[_0x86b0e3('0x25')]())[_0x86b0e3('0x4b')]('id\x20IN\x20?',squel[_0x86b0e3('0x4c')](hopperContacts))['where'](_0x86b0e3('0x7')))[_0x86b0e3('0x25')]();return _0x373211;}function _0x1b3264(_0x12d7d1,_0x19c4de){const _0x1ddc5c=a830_0x20f2,_0x3a2ac8=squel[_0x1ddc5c('0x4')]()[_0x1ddc5c('0x12')](_0x1ddc5c('0xc'))['fromQuery']([_0x1ddc5c('0x3e'),_0x1ddc5c('0x5e'),_0x1ddc5c('0xf'),_0x19c4de,_0x1ddc5c('0x45'),_0x1ddc5c('0x67')],squel[_0x1ddc5c('0x54')]()[_0x1ddc5c('0x5f')](_0x1ddc5c('0x3e'),'phone')[_0x1ddc5c('0x5f')]('id','ContactId')[_0x1ddc5c('0x5f')](LISTID[_0x1ddc5c('0x25')](),_0x1ddc5c('0xf'))[_0x1ddc5c('0x5f')](_0x12d7d1['id'][_0x1ddc5c('0x25')](),_0x19c4de)[_0x1ddc5c('0x5f')](_0x1ddc5c('0xb'),_0x1ddc5c('0x45'))['field'](_0x1ddc5c('0xb'),_0x1ddc5c('0x67'))['from']('cm_contacts')['where'](_0x1ddc5c('0x1c'))[_0x1ddc5c('0x4b')](_0x1ddc5c('0xd'),LISTID[_0x1ddc5c('0x25')]())[_0x1ddc5c('0x4b')](_0x1ddc5c('0x29'),squel['str'](hopperContacts))[_0x1ddc5c('0x4b')]('phone\x20IS\x20NOT\x20NULL'))['toString']();return _0x3a2ac8;}return db['VoiceQueue'][_0x238491('0x47')]({'where':{'type':_0x238491('0x51')},'attributes':['id','dialCheckDuplicateType'],'include':[{'model':db[_0x238491('0x4f')],'as':_0x238491('0x60'),'where':{'id':LISTID}}]})[_0x238491('0x38')](function(_0x3dcdc2){const _0x1e21f9=_0x238491,_0x120bf8=[];if(_0x3dcdc2)for(let _0x545e12=0x0,_0x217c7e;_0x545e12<_0x3dcdc2[_0x1e21f9('0x16')];_0x545e12+=0x1){_0x217c7e=_0x3dcdc2[_0x545e12]['get']({'plain':!![]});switch(_0x217c7e[_0x1e21f9('0x34')]){case _0x1e21f9('0x64'):_0x120bf8[_0x1e21f9('0x68')](db[_0x1e21f9('0x39')][_0x1e21f9('0x56')](_0x2bbb11(_0x217c7e,_0x1e21f9('0x18')))['then'](function(){})[_0x1e21f9('0x3f')](_0x48cbff()));break;case'onlyIfOpen':_0x120bf8[_0x1e21f9('0x68')](db['sequelize'][_0x1e21f9('0x56')](_0x3b1294(_0x217c7e,_0x1e21f9('0x18')))[_0x1e21f9('0x38')](function(){})[_0x1e21f9('0x3f')](_0x48cbff()));break;default:_0x120bf8[_0x1e21f9('0x68')](db[_0x1e21f9('0x39')][_0x1e21f9('0x56')](_0x201d56(_0x217c7e,'VoiceQueueId'))[_0x1e21f9('0x38')](function(){})[_0x1e21f9('0x3f')](_0x48cbff()));}}return _0x120bf8;})[_0x238491('0x48')]()['then'](function(){const _0x512690=_0x238491;return db[_0x512690('0x26')][_0x512690('0x47')]({'where':{'type':'outbound'},'attributes':['id'],'include':[{'model':db[_0x512690('0x4f')],'as':_0x512690('0x14'),'where':{'id':LISTID}}]})['then'](function(_0x159094){const _0x10a048=_0x512690,_0x4c7156=[];if(_0x159094)for(let _0x1a4be1=0x0,_0x19e17a;_0x1a4be1<_0x159094[_0x10a048('0x16')];_0x1a4be1+=0x1){_0x19e17a=_0x159094[_0x1a4be1][_0x10a048('0x41')]({'plain':!![]}),_0x4c7156['push'](db[_0x10a048('0x39')][_0x10a048('0x56')](_0x1b3264(_0x19e17a,'VoiceQueueId'))['then'](function(){})['catch'](_0x48cbff()));}return _0x4c7156;})[_0x512690('0x48')]();})[_0x238491('0x38')](function(){const _0x3e78c9=_0x238491;return db[_0x3e78c9('0x2a')][_0x3e78c9('0x47')]({'attributes':['id','dialCheckDuplicateType'],'include':[{'model':db[_0x3e78c9('0x4f')],'as':_0x3e78c9('0x60'),'where':{'id':LISTID}}]})[_0x3e78c9('0x38')](function(_0x3206d8){const _0x1a1096=_0x3e78c9,_0x6f4632=[];if(_0x3206d8)for(let _0x1bbbfe=0x0,_0x1cf0a2;_0x1bbbfe<_0x3206d8[_0x1a1096('0x16')];_0x1bbbfe+=0x1){_0x1cf0a2=_0x3206d8[_0x1bbbfe][_0x1a1096('0x41')]({'plain':!![]});switch(_0x1cf0a2[_0x1a1096('0x34')]){case _0x1a1096('0x64'):_0x6f4632['push'](db['sequelize'][_0x1a1096('0x56')](_0x2bbb11(_0x1cf0a2,_0x1a1096('0x42')))[_0x1a1096('0x38')](function(){})['catch'](_0x48cbff()));break;case _0x1a1096('0x57'):_0x6f4632['push'](db[_0x1a1096('0x39')][_0x1a1096('0x56')](_0x3b1294(_0x1cf0a2,_0x1a1096('0x42')))['then'](function(){})['catch'](_0x48cbff()));break;default:_0x6f4632[_0x1a1096('0x68')](db[_0x1a1096('0x39')][_0x1a1096('0x56')](_0x201d56(_0x1cf0a2,_0x1a1096('0x42')))[_0x1a1096('0x38')](function(){})['catch'](_0x48cbff()));}}return _0x6f4632;})[_0x3e78c9('0x48')]();})[_0x238491('0x38')](function(){const _0x4cc2cc=_0x238491;return db['Campaign'][_0x4cc2cc('0x47')]({'attributes':['id'],'include':[{'model':db['CmList'],'as':_0x4cc2cc('0x14'),'where':{'id':LISTID}}]})[_0x4cc2cc('0x38')](function(_0x744ffa){const _0x4ae521=_0x4cc2cc,_0x3dbecc=[];if(_0x744ffa)for(let _0x3b1632=0x0,_0x7eea0b;_0x3b1632<_0x744ffa[_0x4ae521('0x16')];_0x3b1632+=0x1){_0x7eea0b=_0x744ffa[_0x3b1632]['get']({'plain':!![]}),_0x3dbecc[_0x4ae521('0x68')](db[_0x4ae521('0x39')]['query'](_0x1b3264(_0x7eea0b,_0x4ae521('0x42')))[_0x4ae521('0x38')](function(){})[_0x4ae521('0x3f')](_0x48cbff()));}return _0x3dbecc;})[_0x4cc2cc('0x48')]();})[_0x238491('0x3f')](function(_0xa9ad2b){const _0x5ceb5c=_0x238491;logger[_0x5ceb5c('0x0')](_0x5ceb5c('0x37'),_0x5ceb5c('0x5b'),_0xa9ad2b[_0x5ceb5c('0x58')]);});}const processPromises=function(_0x17d15f){const _0x460f6d=_0x34d6d9;return Promise['all'](promises)[_0x460f6d('0x3f')](function(_0x3ad0f9){const _0x2a9fd4=_0x460f6d;logger[_0x2a9fd4('0x0')]('Error\x20processing\x20rows\x20block:',JSON[_0x2a9fd4('0x27')](_0x3ad0f9));})[_0x460f6d('0x5d')](function(){const _0x31a29d=_0x460f6d;socket['emit'](_0x31a29d('0x20')+SOCKET_TIMESTAMP,{'success':success,'errors':errors,'duplicates':duplicates,'rows':rows}),promises=[],success=0x0,errors=0x0,duplicates=0x0,rows=[];if(_0x17d15f)return _0x17d15f[_0x31a29d('0x1d')]();});},endCsv=function(){const _0x44c049=_0x34d6d9;return Promise[_0x44c049('0x24')]()[_0x44c049('0x38')](function(){if(hopperContacts)return checkHopper();})[_0x44c049('0x38')](function(){const _0x13fc85=_0x44c049;socket[_0x13fc85('0x3a')](_0x13fc85('0x20')+SOCKET_TIMESTAMP,{'finished':!![],'success':success,'errors':errors,'duplicates':duplicates,'rows':rows});try{fs['unlinkSync'](FILEPATH);}catch(_0x54c1d0){logger[_0x13fc85('0x0')](_0x13fc85('0x35'),JSON[_0x13fc85('0x27')](_0x54c1d0));}finally{process[_0x13fc85('0x49')](0x0);}});};process['on'](_0x34d6d9('0x13'),function(){const _0x40286e=_0x34d6d9;logger[_0x40286e('0x23')](_0x40286e('0x4a')),endCsv();});function main(){const _0x48650d=_0x34d6d9;return Promise[_0x48650d('0x24')]()[_0x48650d('0x38')](function(){const _0x26fe5f=_0x48650d;if(DUPLICATES)return DUPLICATES=DUPLICATES['split'](','),db['CmContact'][_0x26fe5f('0x47')]({'where':{'ListId':LISTID},'attributes':DUPLICATES,'raw':!![]});})['then'](function(_0x1d6362){const _0xa7267d=_0x48650d,_0x413397=fs[_0xa7267d('0x61')](FILEPATH,{'highWaterMark':0xf*0x400*0x400});Papa[_0xa7267d('0x1b')](_0x413397,{'header':!![],'skipEmptyLines':!![],'step':function(_0x254e1d,_0x2d0f15){const _0x4b0e90=_0xa7267d;total+=0x1;const _0x5c8c42=total;promises['push'](checkRow(_0x254e1d,_0x1d6362,_0x5c8c42)[_0x4b0e90('0x38')](function(){success+=0x1;})['catch'](function(_0x182a34){const _0x100a49=_0x4b0e90;if(_0x182a34['error'])errors+=0x1,delete _0x182a34['error'];else _0x182a34[_0x100a49('0x3')]&&(duplicates+=0x1,delete _0x182a34[_0x100a49('0x3')]);rows[_0x100a49('0x68')](_0x182a34);}));if(total%0xc8===0x0)return _0x2d0f15[_0x4b0e90('0x17')](),processPromises(_0x2d0f15);},'complete':function(){const _0x5ce402=_0xa7267d;return processPromises()[_0x5ce402('0x38')](function(){const _0x309972=_0x5ce402;logger[_0x309972('0x23')](_0x309972('0x5')),endCsv();});},'error':function(_0x4ecaf2){const _0x4998c7=_0xa7267d;logger[_0x4998c7('0x23')](_0x4998c7('0x4d'),JSON[_0x4998c7('0x27')](_0x4ecaf2)),endCsv();}});})[_0x48650d('0x3f')](function(_0x29aabf){const _0x47ab78=_0x48650d;logger['error'](_0x47ab78('0x2d'),JSON[_0x47ab78('0x27')](_0x29aabf));});}main();