New Customer - Pipedream

import common from "../common/timer-based.mjs"; import constants from "../constants.mjs"; export default { ...common, key: "mailchimp-new-customer", name: "New Customer", description: "Emit new event when a new customer is added to a selected store.", version: "0.0.2", type: "source", dedupe: "unique", props: { ...common.props, storeId: { propDefinition: [ common.props.mailchimp, "storeId", ], description: "The unique ID of the store you'd like to watch for new customers", }, }, hooks: { async deploy() { this._clearProcessedIds(); const processedIds = new Set(this._getProcessedIds()); // Emits sample events on the first run during deploy. const pageSize = 10; const customerStream = this.mailchimp.getAllStoreCustomers(this.storeId, pageSize); let i = 0; for await (const customer of customerStream) { if (i < pageSize) { this.processEvent(customer); processedIds.add(customer.id);// Mark customer as successfully processed this._setProcessedIds(processedIds); } i++; } }, }, methods: { ...common.methods, generateMeta(eventPayload) { const ts = Date.parse(eventPayload.created_at); return { id: eventPayload.id, summary: `New customer "${eventPayload.first_name} ${eventPayload.last_name}" was added to your store. `, ts, }; }, _clearProcessedIds() { return this.db.set("processedIds", []); }, _getProcessedIds() { return this.db.get("processedIds"); }, _setProcessedIds(processedIds) { this.db.set("processedIds", Array.from(processedIds)); }, }, async run() { const processedIds = new Set(this._getProcessedIds()); const pageSize = constants.PAGE_SIZE; const customerStream = this.mailchimp.getAllStoreCustomers(this.storeId, pageSize); for await (const customer of customerStream) { if (processedIds.has(customer.id)) { continue; } this.processEvent(customer); processedIds.add(customer.id);// Mark customer as successfully processed this._setProcessedIds(processedIds); } }, };

Label	Prop	Type	Description
N/A	`db`	`$.service.db`	This component uses `$.service.db` to maintain state between executions.
Mailchimp	`mailchimp`	`app`	This component uses the Mailchimp app.
	`timer`	`$.interface.timer`
Store Id	`storeId`	`string`	Select a value from the drop down menu.

Label

Prop

Type

Description

N/A

db

$.service.db

This component uses $.service.db to maintain state between executions.

Mailchimp

mailchimp

app

This component uses the Mailchimp app.

timer

$.interface.timer

Store Id

storeId

string

Select a value from the drop down menu.

More Ways to Use Mailchimp#

Triggers#

Link Clicked from the Mailchimp API

Emit new event when a recipient clicks a pre-specified link in an specific campaign.

Try it

New Audience from the Mailchimp API

Emit new event when an audience is added to the connected Mailchimp account.

Try it

New Campaign from the Mailchimp API

Emit new event when a new campaign is created or sent

Try it

New File from the Mailchimp API

Emit new event when a new file is added to the File Manager of the connected Mailchimp account.

Try it

New List Event (Instant) from the Mailchimp API

Emit new event when the following occurs on an audience list: a campaign is sent or cancelled, a subsciber is added, unsuscribed, has a profile update, or has the associated email address changed, or cleaned.

Try it