codeninjasllc/codecombat
1
0
Fork 0
mirror of https://github.com/codeninjasllc/codecombat.git synced 2025-03-14 07:00:01 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add ZP auto-reply contacts to Close

Browse source 
Also now including phone number when adding a new contact to an
existing Close lead.
This commit is contained in:
Matt Lott 2016-07-06 15:48:46 -07:00
parent 228019ac89
commit 98da7962cf
1 changed files with 61 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

97
scripts/addZenProspectLeadsToClose.js
View file

@ -16,7 +16,7 @@ const request = require('request');
const zpPageSize = 100;
getZPRepliedContacts((err, emailContactMap) => {
getZPContacts((err, emailContactMap) => {
if (err) {
console.log(err);
return;
@ -68,6 +68,7 @@ function createCloseLead(zpContact, done) {
}
function updateCloseLead(zpContact, existingLead, done) {
// console.log(`DEBUG: updateCloseLead ${existingLead.id} ${zpContact.email}`);
const putData = {
status: 'Contacted',
'custom.lastUpdated': new Date(),
@ -89,6 +90,9 @@ function updateCloseLead(zpContact, existingLead, done) {
title: zpContact.title,
emails: [{email: zpContact.email}]
};
if (zpContact.phone) {
postData.phones = [{phone: zpContact.phone}];
}
const options = {
uri: `https://${closeIoApiKey}:X@app.close.io/api/v1/contact/`,
body: JSON.stringify(postData)
@ -132,10 +136,9 @@ function createUpsertCloseLeadFn(zpContact) {
};
}
function getZPRepliedContactsPage(contacts, page, done) {
// console.log(`DEBUG: Fetching page ${page} ${zpPageSize}...`);
function getZPContactsPage(contacts, searchQuery, done) {
const options = {
url: `https://www.zenprospect.com/api/v1/contacts/search?codecombat_special_auth_token=${zpAuthToken}&page=${page}&per_page=${zpPageSize}&contact_email_replied=true`,
url: `https://www.zenprospect.com/api/v1/contacts/search?${searchQuery}`,
headers: {
'Accept': 'application/json'
}
@ -144,47 +147,69 @@ function getZPRepliedContactsPage(contacts, page, done) {
if (err) return done(err);
const data = JSON.parse(body);
for (let contact of data.contacts) {
if (contact.email_replied) {
contacts.push({
organization: contact.organization_name,
name: contact.name,
title: contact.title,
email: contact.email,
phone: contact.phone,
data: contact
});
}
contacts.push({
organization: contact.organization_name,
name: contact.name,
title: contact.title,
email: contact.email,
phone: contact.phone,
data: contact
});
}
return done(null, data.pipeline_total);
});
}
function getZPRepliedContacts(done) {
// Get first page to get total contact count for parallized page fetches
function createGetZPAutoResponderContactsPage(contacts, page) {
return (done) => {
// console.log(`DEBUG: Fetching autoresponder page ${page} ${zpPageSize}...`);
let searchQuery = `codecombat_special_auth_token=${zpAuthToken}&page=${page}&per_page=${zpPageSize}&contact_email_autoresponder=true`;
getZPContactsPage(contacts, searchQuery, done);
};
}
function createGetZPRepliedContactsPage(contacts, page) {
return (done) => {
// console.log(`DEBUG: Fetching email reply page ${page} ${zpPageSize}...`);
let searchQuery = `codecombat_special_auth_token=${zpAuthToken}&page=${page}&per_page=${zpPageSize}&contact_email_replied=true`;
getZPContactsPage(contacts, searchQuery, done);
};
}
function getZPContacts(done) {
// Get first page to get total contact count for future parallized page fetches
const contacts = [];
getZPRepliedContactsPage(contacts, 0, (err, total) => {
createGetZPAutoResponderContactsPage(contacts, 0)((err, autoResponderTotal) => {
if (err) return done(err);
const createGetZPLeadsPage = (leads, page) => {
return (done) => {
getZPRepliedContactsPage(leads, page, done);
};
}
const tasks = [];
for (let i = 1; (i - 1) * zpPageSize < total; i++) {
tasks.push(createGetZPLeadsPage(contacts, i));
}
async.series(tasks, (err, results) => {
createGetZPRepliedContactsPage(contacts, 0)((err, repliedTotal) => {
if (err) return done(err);
const emailContactMap = {};
for (const contact of contacts) {
if (!contact.organization || !contact.name || !contact.title || !contact.email) {
console.log(JSON.stringify(contact, null, 2));
return done(`DEBUG: missing data for zp contact:`);
}
if (!emailContactMap[contact.email]) emailContactMap[contact.email] = contact;
const tasks = [];
for (let i = 1; (i - 1) * zpPageSize < autoResponderTotal; i++) {
tasks.push(createGetZPAutoResponderContactsPage(contacts, i));
}
log(`${total} total ZP contacts, ${Object.keys(emailContactMap).length} with replies`);
return done(null, emailContactMap);
for (let i = 1; (i - 1) * zpPageSize < repliedTotal; i++) {
tasks.push(createGetZPRepliedContactsPage(contacts, i));
}
async.series(tasks, (err, results) => {
if (err) return done(err);
const emailContactMap = {};
for (const contact of contacts) {
if (!contact.organization || !contact.name || !contact.title || !contact.email) {
console.log(JSON.stringify(contact, null, 2));
return done(`DEBUG: missing data for zp contact:`);
}
if (!emailContactMap[contact.email]) {
emailContactMap[contact.email] = contact;
}
// else {
// console.log(`DEBUG: already have contact ${contact.email}`);
// }
}
log(`(${autoResponderTotal + repliedTotal}) ${autoResponderTotal} autoresponder ZP contacts ${repliedTotal} ZP contacts ${Object.keys(emailContactMap).length} contacts mapped`);
return done(null, emailContactMap);
});
});
});
}