Triggers

curl -H 'Authorization: Bearer <your token>' https://myendpoint.m.pipedream.net

curl -H 'Authorization: Bearer <OAuth access token>' https://myendpoint.m.pipedream.net

import { PipedreamClient } from "@pipedream/sdk";
 
// These secrets should be saved securely and passed to your environment
const client = new PipedreamClient({
  clientId: "{oauth_client_id}",
  clientSecret: "{oauth_client_secret}",
  projectId: "{project_id}",
  projectEnvironment: "development" // or "production"
});
 
await client.workflows.invokeForExternalUser(
  "enabc123", // pass the endpoint ID or full URL here
  "{external_user_id}", // The end user's ID in your system
  "POST", // HTTP method
  {
    key: "value",
  } // request body
)

import { PipedreamClient } from "@pipedream/sdk";
 
// These secrets should be saved securely and passed to your environment
const client = new PipedreamClient({
  clientId: "{oauth_client_id}",
  clientSecret: "{oauth_client_secret}",
  projectId: "{project_id}",
  projectEnvironment: "development" // or "production"
});
 
await client.workflows.invokeForExternalUser(
  "enabc123", // pass the endpoint ID or full URL here
  "{external_user_id}", // The end user's ID in your system
  "POST", // HTTP method
  {
    key: "value",
  } // request body
)

# First, obtain an OAuth access token
curl -X POST https://api.pipedream.com/v1/oauth/token \
  -H "Content-Type: application/json" \
  -d '{
    "grant_type": "client_credentials",
    "client_id": "{oauth_client_id}",
    "client_secret": "{oauth_client_secret}"
  }'
 
# The response will include an access_token. Use it in the Authorization header below.
 
curl -X POST https://{your-endpoint-url} \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer {access_token}" \
  -d '{
    "message": "Hello, world"
  }'

curl -F 'name=Leia' -F 'title=General' https://myendpoint.m.pipedream.net

{
  name: "Leia",
  title: "General",
}

curl -d '{ "name": "Yoda" }' \
  https://endpoint.m.pipedream.net\?pipedream_upload_body\=1
 
curl -d '{ "name": "Yoda" }' \
  -H "x-pd-upload-body: 1" \
  https://endpoint.m.pipedream.net

import stream from "stream";
import { promisify } from "util";
import fs from "fs";
import got from "got";
 
export default defineComponent({
  async run({ steps, $ }) {
    const pipeline = promisify(stream.pipeline);
    await pipeline(
      got.stream(steps.trigger.event.body.raw_body_url),
      fs.createWriteStream(`/tmp/raw_body`)
    );
  },
})

curl -F 'image=@my_image.png' https://myendpoint.m.pipedream.net

import stream from "stream";
import { promisify } from "util";
import fs from "fs";
import got from "got";
 
const pipeline = promisify(stream.pipeline);
await pipeline(
  got.stream(steps.trigger.event.body.image.url),
  fs.createWriteStream(`/tmp/${steps.trigger.event.body.image.filename}`)
);

Access-Control-Allow-Origin: *
Access-Control-Allow-Methods: GET,HEAD,PUT,PATCH,POST,DELETE

<p><b>Success!</b></p>
<p>To customize this response, check out our docs <a href="https://docs.pipedream.com/workflows/steps/triggers/#http-responses">here</a></p>

defineComponent({
  async run({ steps, $ }) {
    await $.respond({
      status: 200,
      headers: { "my-custom-header": "value" },
      body: { message: "My custom response" }, // This can be any string, object, Buffer, or Readable stream
    });
  },
});

defineComponent({
  async run({ steps, $ }) {
    await $.respond({
      immediate: true,
      status: 200,
      headers: { "my-custom-header": "value" },
      body: { message: "My custom response" },
    });
  },
});

defineComponent({
  async run({ steps, $ }) {
    await $.respond({
      immediate: true,
      status: 200,
      body: "",
    });
  },
});

No $.respond called in workflow

defineComponent({
  async run({ steps, $ }) {
    try {
      // Your code here that might throw an exception or not run
      throw new Error("Whoops, something unexpected happened.");
    } finally {
      await $.respond({
        status: 200,
        body: {
          msg: "Default response",
        },
      });
    }
  },
});

import { simpleParser } from "mailparser";
 
export default defineComponent({
  async run({ steps, $ }) {
    return await simpleParser(steps.get_large_email_content.$return_value);
  },
});

import stream from "stream";
import { promisify } from "util";
import fs from "fs";
import got from "got";
import { simpleParser } from "mailparser";
 
// To use previous step data, pass the `steps` object to the run() function
export default defineComponent({
  async run({ steps, $ }) {
    const pipeline = promisify(stream.pipeline);
    await pipeline(
      got.stream(steps.trigger.event.mail.content_url),
      fs.createWriteStream(`/tmp/raw_email`)
    );
 
    // Now read the file and parse its contents into the `parsed` variable
    // See https://nodemailer.com/extras/mailparser/ for parsing options
    const f = fs.readFileSync(`/tmp/raw_email`);
    return await simpleParser(f);
  },
});

myemailaddr+test@pipedream.net

myemailaddr+test@pipedream.net
myemailaddr+unsubscribe@pipedream.net