Update Record Expiration with Data Stores API on New Contact Updated from Flexmail API

Pipedream makes it easy to connect APIs for Data Stores, Flexmail and 2,500+ other apps remarkably fast.

Trigger workflow on

New Contact Updated from the Flexmail API

Next, do this

Update Record Expiration with the Data Stores API

No credit card required

▶

Watch us build a workflow

8 min

Watch now ➜

Trusted by 1,000,000+ developers from startups to Fortune 500 companies

Developers ♥ Pipedream

Getting Started#

This integration creates a workflow with a Flexmail trigger and Data Stores action. When you configure and deploy the workflow, it will run on Pipedream's servers 24x7 for free.

Select this integration
Configure the New Contact Updated trigger
1. Connect your Flexmail account
2. Configure timer
Configure the Update Record Expiration action
1. Connect your Data Stores account
2. Configure Data Store
3. Select a Key
4. Select a Expiration Type
Deploy the workflow
Send a test event to validate your setup
Turn on the trigger

Details#

This integration uses pre-built, source-available components from Pipedream's GitHub repo. These components are developed by Pipedream and the community, and verified and maintained by Pipedream.

To contribute an update to an existing component or create a new component, create a PR on GitHub. If you're new to Pipedream component development, you can start with quickstarts for trigger span and action development, and then review the component API reference.

Trigger#

New Contact Updated on Flexmail

Description:Emit new event when a contact is updated in Flexmail

Version:0.0.1

Key:flexmail-new-contact-updated

View on GitHub

Flexmail Overview#

Flexmail API offers a way to automate your email marketing campaigns by allowing you to manage contacts, send out emails, and track results. With Pipedream's ability to integrate with hundreds of services, you can set up complex workflows that respond to events from various apps by updating contact lists, sending personalized content, or triggering sequences of marketing actions based on user behavior or data changes.

Trigger Code#

import common from "../common/base.mjs";
import md5 from "md5";
import sampleEmit from "./test-event.mjs";

export default {
  ...common,
  key: "flexmail-new-contact-updated",
  name: "New Contact Updated",
  description: "Emit new event when a contact is updated in Flexmail",
  version: "0.0.1",
  type: "source",
  dedupe: "unique",
  methods: {
    ...common.methods,
    _getContacts() {
      return this.db.get("contacts") || {};
    },
    _setContacts(contacts) {
      this.db.set("contacts", contacts);
    },
    getRelevantContacts(contacts) {
      const existingContacts = this._getContacts();
      const relevantContacts = [];
      const newContacts = {};
      for (const contact of contacts) {
        const hash = md5(JSON.stringify(contact));
        if (existingContacts[contact.id] && existingContacts[contact.id] != hash) {
          relevantContacts.push(contact);
        }
        newContacts[contact.id] = hash;
      }
      this._setContacts(newContacts);
      return relevantContacts;
    },
    getSummary(id) {
      return `Contact Updated ${id}`;
    },
  },
  sampleEmit,
};

Trigger Configuration#

This component may be configured based on the props defined in the component code. Pipedream automatically prompts for input values in the UI and CLI.

Label	Prop	Type	Description
Flexmail	`flexmail`	`app`	This component uses the Flexmail app.
N/A	`db`	`$.service.db`	This component uses `$.service.db` to maintain state between executions.
	`timer`	`$.interface.timer`

Trigger Authentication#

Flexmail uses API keys for authentication. When you connect your Flexmail account, Pipedream securely stores the keys so you can easily authenticate to Flexmail APIs in both code and no-code steps.

About Flexmail#

Create captivating email campaigns with the most complete and reliable platform.

Action#

Update Record Expiration on Data Stores

Description:Update the expiration time for a record in your [Pipedream Data Store](https://pipedream.com/data-stores/).

Version:0.0.1

Key:data_stores-update-ttl

View on GitHub

Data Stores Overview#

Data Stores are a key-value store that allow you to persist state and share data across workflows. You can perform CRUD operations, enabling dynamic data management within your serverless architecture. Use it to save results from API calls, user inputs, or interim data; then read, update, or enrich this data in subsequent steps or workflows. Data Stores simplify stateful logic and cross-workflow communication, making them ideal for tracking process statuses, aggregating metrics, or serving as a simple configuration store.

Action Code#

import app from "../../data_stores.app.mjs";

export default {
  key: "data_stores-update-ttl",
  name: "Update Record Expiration",
  description: "Update the expiration time for a record in your [Pipedream Data Store](https://pipedream.com/data-stores/).",
  version: "0.0.1",
  type: "action",
  props: {
    app,
    dataStore: {
      propDefinition: [
        app,
        "dataStore",
      ],
    },
    key: {
      propDefinition: [
        app,
        "key",
        ({ dataStore }) => ({
          dataStore,
        }),
      ],
      description: "Select the key for the record you'd like to update the expiration time.",
    },
    ttlOption: {
      type: "string",
      label: "Expiration Type",
      description: "Choose a common expiration time or specify a custom value",
      options: [
        {
          label: "Custom value",
          value: "custom",
        },
        {
          label: "No expiration (remove expiry)",
          value: "0",
        },
        {
          label: "1 hour",
          value: "3600",
        },
        {
          label: "1 day",
          value: "86400",
        },
        {
          label: "1 week",
          value: "604800",
        },
        {
          label: "30 days",
          value: "2592000",
        },
        {
          label: "90 days",
          value: "7776000",
        },
        {
          label: "1 year",
          value: "31536000",
        },
      ],
      reloadProps: true,
    },
  },
  async additionalProps() {
    const props = {};
    if (this.ttlOption === "custom") {
      props.ttl = {
        type: "integer",
        label: "Custom TTL (seconds)",
        description: "The number of seconds until this record expires and is automatically deleted. Use 0 to remove expiration.",
        min: 0,
        max: 31536000, // 1 year (safe upper limit)
      };
    }
    return props;
  },
  async run({ $ }) {
    const {
      key, ttlOption, ttl,
    } = this;

    // Determine TTL value to use
    const ttlValue = ttlOption === "custom"
      ? ttl
      : parseInt(ttlOption, 10);

    if (!await this.dataStore.has(key)) {
      $.export("$summary", `No record found with key \`${key}\`.`);
      return {
        success: false,
        message: `No record found with key ${key}`,
      };
    }

    if (ttlValue === 0) {
      // Remove expiration
      await this.dataStore.setTtl(key, null);
      $.export("$summary", `Successfully removed expiration for key \`${key}\`.`);
      return {
        success: true,
        key,
        ttl: null,
        message: "Expiration removed",
      };
    } else {
      // Update TTL
      await this.dataStore.setTtl(key, ttlValue);
      $.export("$summary", `Successfully updated expiration for key \`${key}\` (expires in ${this.app.formatTtl(ttlValue)}).`);
      return {
        success: true,
        key,
        ttl: ttlValue,
        ttlFormatted: this.app.formatTtl(ttlValue),
      };
    }
  },
};

Action Configuration#

This component may be configured based on the props defined in the component code. Pipedream automatically prompts for input values in the UI.

Label	Prop	Type	Description
Data Stores	`app`	`app`	This component uses the Data Stores app.
Data Store	`dataStore`	`data_store`	Select an existing Data Store or create a new one.
Key	`key`	`string`	Select a value from the drop down menu.
Expiration Type	`ttlOption`	`string`	Select a value from the drop down menu:`{ "label": "Custom value", "value": "custom" }{ "label": "No expiration (remove expiry)", "value": "0" }{ "label": "1 hour", "value": "3600" }{ "label": "1 day", "value": "86400" }{ "label": "1 week", "value": "604800" }{ "label": "30 days", "value": "2592000" }{ "label": "90 days", "value": "7776000" }{ "label": "1 year", "value": "31536000" }`