SEC API Pipedream Workflow

import axios from "axios";

export default defineComponent({
  props: {
    tickers: {
      type: "string",
      label: "Ticker watchlist",
      default: "AAPL,MSFT,NVDA"
    },
    since: {
      type: "string",
      label: "Earliest filed date",
      default: "2026-07-01"
    }
  },
  async run({ $, steps }) {
    const rapidapiKey = process.env.RAPIDAPI_KEY;
    if (!rapidapiKey) {
      throw new Error("Set RAPIDAPI_KEY as a Pipedream environment variable.");
    }

    const response = await axios.get(
      "https://sec-event-intelligence.p.rapidapi.com/v1/sec/watchlist/changes",
      {
        params: {
          tickers: this.tickers,
          since: this.since,
          limit: 25
        },
        headers: {
          "x-rapidapi-host": "sec-event-intelligence.p.rapidapi.com",
          "x-rapidapi-key": rapidapiKey,
          "accept": "application/json"
        },
        timeout: 20000
      }
    );

    $.export("filing_count", response.data.data?.length || 0);
    return response.data;
  }
});