Elgato_dark/fleet
1
0
Fork 0
mirror of https://github.com/fleetdm/fleet synced 2026-05-22 16:39:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 121

Website: update Zapier webhook (#26741)

Browse source 
ChangeS:
- updated the `receive-from-zapier` webhook's expected inputs when
receiving a `receive-new-customer-data` event
This commit is contained in:
Eric 2025-02-28 19:44:32 -06:00 committed by GitHub
parent ef415f23fb
commit c4e8f83a70
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
website/api/controllers/webhooks/receive-from-zapier.js vendored
View file

@ -75,28 +75,11 @@ module.exports = {
} else if (eventName === 'receive-new-customer-data') {
assert(_.isObject(data));
assert(_.isString(data.newMarketingStage));
assert(_.isString(data.name));
assert(_.isString(data.website));
assert(_.isString(data.linkedinCompanyPageUrl));
assert(_.isString(data.persona) && AdCampaign.validate('persona', data.persona));
// Enrich to obtain linkedin company ID using provided data.
// Remove any trailing slashes from the LinkedIn URL.
let trailingSlashlessLinkedinCompanyUrl = _.trim(data.linkedinCompanyPageUrl, '/');
// Split the LinkedIn url by slashes
let splitLinkedinCompanyUrl = trailingSlashlessLinkedinCompanyUrl.split('/');
// Grab the last fragment of the URL, we'll use this for the coreSignal API request to
let linkedinCompanyIdOrSlug = splitLinkedinCompanyUrl[splitLinkedinCompanyUrl.length - 1];
let matchedCompanyPageInfo = await sails.helpers.http.get('https://api.coresignal.com/cdapi/v1/linkedin/company/collect/'+linkedinCompanyIdOrSlug, {}, {
Authorization: `Bearer ${sails.config.custom.iqSecret}`,
'content-type': 'application/json'
}).intercept((err)=>{
sails.log.warn(`When the receive-from-zapier webhook received a request about a Salesforce record, a linkedin company could not be found using the provided linkedIn URL (${data.linkedinCompanyPageUrl})`, err);
return 'couldNotMatchLinkedinId';
});
assert(data.linkedinCompanyId);
// (FUTURE: make field for this and have it already in CRM so this step isn't necessary)
let linkedinCompanyId = matchedCompanyPageInfo.id;
let linkedinCompanyId = data.linkedinCompanyId;
// Check if we have enough space in our current active campaign.
// If so, then use it and update its inventory. Otherwise, prepare to create
@ -110,6 +93,9 @@ module.exports = {
let filterCriteriaForLatestCampaign = latestCampaign.linkedinCompanyIds.map((id)=>{
return `urn:li:organization:${id}`;
});
// Append the new organization to the end of the the filterCriteria
filterCriteriaForLatestCampaign.push(`urn:li:organization:${linkedinCompanyId}`);
// Send a request to update this campaign.
await sails.helpers.http.sendHttpRequest.with({
method: 'POST',
url: `https://hooks.zapier.com/hooks/catch/3627242/2wdx23r?webhookSecret=${ encodeURIComponent(sails.config.custom.zapierWebhookSecret)}`,