index.ts•11.9 kB
import { HttpMethod, HttpRequest, httpClient } from '@activepieces/pieces-common';
import { mauticAuth } from '../../index';
import { Property, TriggerStrategy, createTrigger } from "@activepieces/pieces-framework";
const contactTestData = {
"contact": {
"id": 38186,
"points": 0,
"color": null,
"fields": {
"core": {
"points": {
"id": "9",
"label": "Points",
"alias": "points",
"type": "number",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": "0"
},
"title": {
"id": "1",
"label": "Title",
"alias": "title",
"type": "lookup",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"firstname": {
"id": "2",
"label": "First Name",
"alias": "firstname",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": "Test"
},
"lastname": {
"id": "3",
"label": "Last Name",
"alias": "lastname",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": "Contact"
},
"company": {
"id": "4",
"label": "Company",
"alias": "company",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"position": {
"id": "5",
"label": "Position",
"alias": "position",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"email": {
"id": "6",
"label": "Email",
"alias": "email",
"type": "email",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": "Test@email.com"
},
"phone": {
"id": "8",
"label": "Phone",
"alias": "phone",
"type": "tel",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"mobile": {
"id": "7",
"label": "Mobile",
"alias": "mobile",
"type": "tel",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"address1": {
"id": "11",
"label": "Address Line 1",
"alias": "address1",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"address2": {
"id": "12",
"label": "Address Line 2",
"alias": "address2",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"city": {
"id": "13",
"label": "City",
"alias": "city",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"state": {
"id": "14",
"label": "State",
"alias": "state",
"type": "region",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"zipcode": {
"id": "15",
"label": "Zip Code",
"alias": "zipcode",
"type": "text",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"country": {
"id": "16",
"label": "Country",
"alias": "country",
"type": "country",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": ""
},
"fax": {
"id": "10",
"label": "Fax",
"alias": "fax",
"type": "tel",
"group": "core",
"object": "lead",
"is_fixed": "0",
"value": null
},
"preferred_locale": {
"id": "17",
"label": "Preferred Locale",
"alias": "preferred_locale",
"type": "locale",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": null
},
"attribution_date": {
"id": "18",
"label": "Attribution Date",
"alias": "attribution_date",
"type": "datetime",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": null
},
"attribution": {
"id": "19",
"label": "Attribution",
"alias": "attribution",
"type": "number",
"group": "core",
"object": "lead",
"is_fixed": "1",
"value": null
},
"website": {
"id": "20",
"label": "Website",
"alias": "website",
"type": "url",
"group": "core",
"object": "lead",
"is_fixed": "0",
"value": null
},
"boolean": {
"id": "43",
"label": "Boolean",
"alias": "boolean",
"type": "boolean",
"group": "core",
"object": "lead",
"is_fixed": "0",
"value": null
},
"multiple_contact": {
"id": "44",
"label": "Multiple Contact",
"alias": "multiple_contact",
"type": "multiselect",
"group": "core",
"object": "lead",
"is_fixed": "0",
"value": null
}
},
"social": {
"facebook": {
"id": "21",
"label": "Facebook",
"alias": "facebook",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
},
"foursquare": {
"id": "22",
"label": "Foursquare",
"alias": "foursquare",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
},
"instagram": {
"id": "24",
"label": "Instagram",
"alias": "instagram",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
},
"linkedin": {
"id": "25",
"label": "LinkedIn",
"alias": "linkedin",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
},
"skype": {
"id": "26",
"label": "Skype",
"alias": "skype",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
},
"twitter": {
"id": "27",
"label": "Twitter",
"alias": "twitter",
"type": "text",
"group": "social",
"object": "lead",
"is_fixed": "0",
"value": null
}
},
"personal": [],
"professional": []
}
},
"channel": "email",
"old_status": "contactable",
"new_status": "manual",
"timestamp": "2017-12-01T00:05:18-06:00"
}
export const triggers = [
{
name: "lead_post_save_update",
displayName: "Contact Updated",
description: "Triggers when a contact is updated.",
sampleData: {
"mautic.lead_post_save_update": [contactTestData]
},
eventType: "mautic.lead_post_save_update",
},
{
name: "lead_company_change",
displayName: "Contact Company Subscription Change",
description: "Triggers when a commpany is added or removed to/from contact.",
sampleData: {
"mautic.lead_company_change": [contactTestData]
},
eventType: "mautic.lead_company_change",
},
{
name: "lead_channel_subscription_changed",
displayName: "Contact Channel Subscription Change",
description: "Triggers when a contact's channel subscription status changes.",
sampleData: {
"mautic.lead_channel_subscription_changed": [contactTestData]
},
eventType: "mautic.lead_channel_subscription_changed",
},
{
name: "lead_post_save_new",
displayName: "New Contact",
description: "Triggers when a new contact is created.",
sampleData: {
"mautic.lead_post_save_new": [contactTestData]
},
eventType: "mautic.lead_post_save_new",
},
]
.map((props) => registerTrigger(props));
function registerTrigger({
name,
displayName,
eventType,
description,
sampleData
}: {
name: string;
displayName: string;
eventType: string;
description: string;
sampleData: unknown;
}) {
return createTrigger({
auth: mauticAuth,
name: `mautic_${name}_trigger`,
displayName,
description,
props: {
name: Property.ShortText({
displayName: "Webhook Name",
description: "The name the webhook will be searchable by in mautic the webhooks page.",
required: true
}),
description: Property.LongText({
displayName: "Description",
description: "A short description of the webhook",
required: true
})
},
sampleData,
type: TriggerStrategy.WEBHOOK,
async onEnable(context) {
const { base_url, username, password } = context.auth
const request: HttpRequest = {
method: HttpMethod.POST,
url: `${(base_url.endsWith('/') ? base_url : base_url + '/')}api/hooks/new`,
body: {
name: context.propsValue.name,
description: context.propsValue.description,
webhookUrl: context.webhookUrl,
eventsOrderbyDir: "ASC",
triggers: [eventType]
},
headers: {
'Content-Type': 'application/json',
'Authorization':
'Basic ' + Buffer.from(`${username}:${password}`).toString('base64'),
},
queryParams: {},
}
const response = await httpClient.sendRequest<WebhookInformation>(request);
await context.store.put<WebhookInformation>(`mautic_${name}_trigger`, response.body);
},
async onDisable(context) {
const { base_url, username, password } = context.auth
const webhook = await context.store.get<WebhookInformation>(`mautic_${name}_trigger`);
if (webhook != null) {
const request: HttpRequest = {
method: HttpMethod.DELETE,
url: `${(base_url.endsWith('/') ? base_url : base_url + '/')}api/hooks/${webhook.hook.id}/delete`,
headers: {
'Content-Type': 'application/json',
'Authorization':
'Basic ' + Buffer.from(`${username}:${password}`).toString('base64'),
},
};
const response = await httpClient.sendRequest(request);
console.debug(`mautic.trigger.onDisable`, response);
}
},
async run(context) {
return [context.payload.body];
},
});
}
interface WebhookInformation {
hook: {
isPublished: boolean
dateAdded: string
dateModified: string
createdBy: number
createdByUser: string
modifiedBy: unknown | null
modifiedByUser: string
id: number
name: string
description: string
webhookUrl: string
secret: string
eventsOrderbyDir: string
category: {
id: number
createdByUser: string
modifiedByUser: string
title: string
alias: string
description: string | null
color: string | null
bundle: string
}
triggers: string[]
}
}