Add Email to Global Suppression with Twilio SendGrid API on New Executed Trade from BitMEX API

Pipedream makes it easy to connect APIs for Twilio SendGrid, BitMEX and 3,000+ other apps remarkably fast.

Trigger workflow on

New Executed Trade from the BitMEX API

Next, do this

Add Email to Global Suppression with the Twilio SendGrid 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 BitMEX trigger and Twilio SendGrid action. When you configure and deploy the workflow, it will run on Pipedream's servers 24x7 for free.

Select this integration
Configure the New Executed Trade trigger
1. Connect your BitMEX account
2. Configure timer
3. Configure Target Account ID
4. Optional- Select a Symbol
Configure the Add Email to Global Suppression action
1. Connect your Twilio SendGrid account
2. Configure Recipient Emails
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 Executed Trade on BitMEX

Description:Emit new event when a balance‑affecting execution (trade fill, settlement, realized PnL) occurs in your BitMEX account. [See the documentation](https://www.bitmex.com/api/explorer/#!/Execution/Execution_getTradeHistory)

Version:0.0.1

Key:bitmex-new-executed-trade

View on GitHub

Trigger Code#

import common from "../common/common-polling.mjs";

export default {
  ...common,
  key: "bitmex-new-executed-trade",
  name: "New Executed Trade",
  description: "Emit new event when a balance‑affecting execution (trade fill, settlement, realized PnL) occurs in your BitMEX account. [See the documentation](https://www.bitmex.com/api/explorer/#!/Execution/Execution_getTradeHistory)",
  version: "0.0.1",
  type: "source",
  dedupe: "unique",
  props: {
    ...common.props,
    targetAccountId: {
      type: "integer",
      label: "Target Account ID",
      description: "AccountId fetching the trade history, must be a paired account with main user",
    },
    symbol: {
      propDefinition: [
        common.props.bitmex,
        "symbol",
      ],
      optional: true,
    },
  },
  methods: {
    ...common.methods,
    _getEmittedTradeIds() {
      return new Set(this.db.get("emittedTradeIds") || []);
    },
    _setEmittedTradeIds(tradeIds) {
      this.db.set("emittedTradeIds", Array.from(tradeIds));
    },
  },
  hooks: {
    async deploy() {
      const trades = await this.bitmex.getTradeHistory({
        targetAccountId: this.targetAccountId,
        symbol: this.symbol,
        count: 25,
        reverse: true,
      });

      const emittedTradeIds = new Set();
      for (const trade of trades.slice(0, 10)) {
        if (trade.execID) {
          emittedTradeIds.add(trade.execID);
          this.$emit(trade, {
            id: trade.execID,
            summary: `Executed trade: ${trade.symbol} ${trade.side || ""} ${trade.lastQty || 0} @ ${trade.lastPx || 0}`,
            ts: trade.timestamp
              ? new Date(trade.timestamp).getTime()
              : Date.now(),
          });
        }
      }
      this._setEmittedTradeIds(emittedTradeIds);
      if (trades.length > 0 && trades[0].timestamp) {
        this._setLastTimestamp(new Date(trades[0].timestamp).getTime());
      }
    },
  },
  async run() {
    const lastTimestamp = this._getLastTimestamp();
    const emittedTradeIds = this._getEmittedTradeIds();
    const now = Date.now();

    const trades = await this.bitmex.getTradeHistory({
      targetAccountId: this.targetAccountId,
      symbol: this.symbol,
      count: 100,
      reverse: true,
    });

    const newTrades = [];
    for (const trade of trades) {
      if (!trade.execID || emittedTradeIds.has(trade.execID)) {
        continue;
      }

      const tradeTimestamp = trade.timestamp
        ? new Date(trade.timestamp).getTime()
        : now;
      if (!lastTimestamp || tradeTimestamp > lastTimestamp) {
        newTrades.push(trade);
        emittedTradeIds.add(trade.execID);
      }
    }

    // Sort by timestamp ascending
    newTrades.sort((a, b) => {
      const tsA = a.timestamp
        ? new Date(a.timestamp).getTime()
        : 0;
      const tsB = b.timestamp
        ? new Date(b.timestamp).getTime()
        : 0;
      return tsA - tsB;
    });

    for (const trade of newTrades) {
      this.$emit(trade, {
        id: trade.execID,
        summary: `Executed trade: ${trade.symbol} ${trade.side || ""} ${trade.lastQty || 0} @ ${trade.lastPx || 0}`,
        ts: trade.timestamp
          ? new Date(trade.timestamp).getTime()
          : Date.now(),
      });
    }

    if (newTrades.length > 0) {
      const latestTimestamp = newTrades[newTrades.length - 1].timestamp
        ? new Date(newTrades[newTrades.length - 1].timestamp).getTime()
        : now;
      this._setLastTimestamp(latestTimestamp);
    }

    // Keep only recent trade IDs (last 1000)
    const tradeIdsArray = Array.from(emittedTradeIds);
    if (tradeIdsArray.length > 1000) {
      this._setEmittedTradeIds(new Set(tradeIdsArray.slice(-1000)));
    } else {
      this._setEmittedTradeIds(emittedTradeIds);
    }
  },
};

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
BitMEX	`bitmex`	`app`	This component uses the BitMEX app.
N/A	`db`	`$.service.db`	This component uses `$.service.db` to maintain state between executions.
	`timer`	`$.interface.timer`
Target Account ID	`targetAccountId`	`integer`	AccountId fetching the trade history, must be a paired account with main user
Symbol	`symbol`	`string`	Select a value from the drop down menu.

Trigger Authentication#

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

About BitMEX#

Crypto Derivatives Exchange

Action#

Add Email to Global Suppression on Twilio SendGrid

Description:Allows you to add one or more email addresses to the global suppressions group. [See the docs here](https://sendgrid.api-docs.io/v3.0/suppressions-global-suppressions/add-recipient-addresses-to-the-global-suppression-group)

Version:0.0.6

Key:sendgrid-add-email-to-global-suppression

View on GitHub

Twilio SendGrid Overview#

The Twilio SendGrid API opens up a world of possibilities for email automation, enabling you to send emails efficiently and track their performance. With this API, you can programmatically create and send personalized email campaigns, manage contacts, and parse inbound emails for data extraction. When you harness the power of Pipedream, you can connect SendGrid to 3,000+ other apps to automate workflows, such as triggering email notifications based on specific actions, syncing email stats with your analytics, or handling incoming emails to create tasks or tickets.

Action Code#

import common from "../common/common.mjs";

export default {
  ...common,
  key: "sendgrid-add-email-to-global-suppression",
  name: "Add Email to Global Suppression",
  description: "Allows you to add one or more email addresses to the global suppressions group. [See the docs here](https://sendgrid.api-docs.io/v3.0/suppressions-global-suppressions/add-recipient-addresses-to-the-global-suppression-group)",
  version: "0.0.6",
  annotations: {
    destructiveHint: false,
    openWorldHint: true,
    readOnlyHint: false,
  },
  type: "action",
  props: {
    ...common.props,
    recipientEmails: {
      type: "string[]",
      label: "Recipient Emails",
      description: "An array of email addresses to be added to the global suppressions group. Example `[\"email1@example.com\",\"email2@example.com\"]`",
    },
  },
  async run({ $ }) {
    const resp = await this.sendgrid.addEmailToGlobalSuppression(this.recipientEmails);
    $.export("$summary", "Successfully added emails to global suppressions group");
    return resp;
  },
};

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
Twilio SendGrid	`sendgrid`	`app`	This component uses the Twilio SendGrid app.
Recipient Emails	`recipientEmails`	`string[]`	An array of email addresses to be added to the global suppressions group. Example `["email1@example.com","email2@example.com"]`