The webhook implementation will always be language-specific so we'd have to know what language is most comfortable for you to work in.
As our webhook service uses standard JavaScript, the main routine looks like this (with a more exception handling in production):
FBHttp.fetch(mktoRESTIdentity)
.then((identResp) => identResp.json())
.then((identRespJ) => {
// get session access_token
commonHTTPHeaders = {
'Authorization' : `bearer ${identRespJ.access_token}`,
'Content-Type' : 'application/json;charset=UTF-8'
}
})
.then(() =>
// get all leads matching current lead's email (including current lead)
FBHttp.fetch(
`${mktoRESTLeadsByFilterBase}?filterValues=${webhookContext.leadEmail}&fields=${fieldsToSync}&filterType=Email`,
{
headers: commonHTTPHeaders
}
)
)
.then((getResp) => getResp.json())
.then((getRespJ) => {
// filter list of leads to (a) exclude current lead and (b) leave only interesting custom fields to sync
var matchedLeads = getRespJ.result,
thisLead = matchedLeads.find((lead) => lead.id == webhookContext.leadId ),
secondaryLeads = matchedLeads.filter((lead) => lead != thisLead ),
reservedFields = ["id","email"],
pushInput;
reservedFields.forEach((field) => delete thisLead[field] );
pushInput = secondaryLeads.map((secondaryLead) => Object.assign({}, secondaryLead, thisLead) );
return Object.assign(pushTemplate, { input : pushInput });
})
.then((pushReq) =>
// sync list of leads back to Mkto
FBHttp.fetch(
mktoRESTPushLead,
{
method: "POST",
headers: commonHTTPHeaders,
body: JSON.stringify(pushReq)
}
)
.then((pushResp) => pushResp.json())
);
.png)
Adchoices