const options = {
method: 'POST',
headers: {'content-type': 'application/json', authorization: 'Bearer <TOKEN>'},
body: JSON.stringify({
config: {environment: 'production'},
pipes: [
{
connector: {strategy: 'first', connections: [{connection: 'resend_123', type: 'vault'}]},
pipe_id: 'email:send:resend@1',
config: {reply_to: '<REPLY_TO_EMAIL_ADDRESS>', from: '<FROM_EMAIL_ADDRESS>'}
}
],
input: [
{
id: '1',
email: '<EMAIL_ADDRESS>',
email_body: '<EMAIL_TEXT>',
email_subject: '<EMAIL_SUBJECT_LINE>'
}
]
})
};
fetch('https://api.pipe0.com/v1/pipes/run', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));
import requests
url = "https://api.pipe0.com/v1/pipes/run"
payload = {
"config": { "environment": "production" },
"pipes": [
{
"connector": {
"strategy": "first",
"connections": [
{
"connection": "resend_123",
"type": "vault"
}
]
},
"pipe_id": "email:send:resend@1",
"config": {
"reply_to": "<REPLY_TO_EMAIL_ADDRESS>",
"from": "<FROM_EMAIL_ADDRESS>"
}
}
],
"input": [
{
"id": "1",
"email": "<EMAIL_ADDRESS>",
"email_body": "<EMAIL_TEXT>",
"email_subject": "<EMAIL_SUBJECT_LINE>"
}
]
}
headers = {
"content-type": "application/json",
"authorization": "Bearer <TOKEN>"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)
curl --request POST \
--url https://api.pipe0.com/v1/pipes/run \
--header 'authorization: Bearer <TOKEN>' \
--header 'content-type: application/json' \
--data '
{
"config": {
"environment": "production"
},
"pipes": [
{
"connector": {
"strategy": "first",
"connections": [
{
"connection": "resend_123",
"type": "vault"
}
]
},
"pipe_id": "email:send:resend@1",
"config": {
"reply_to": "<REPLY_TO_EMAIL_ADDRESS>",
"from": "<FROM_EMAIL_ADDRESS>"
}
}
],
"input": [
{
"id": "1",
"email": "<EMAIL_ADDRESS>",
"email_body": "<EMAIL_TEXT>",
"email_subject": "<EMAIL_SUBJECT_LINE>"
}
]
}
'
package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.pipe0.com/v1/pipes/run"
payload := strings.NewReader("{\"config\":{\"environment\":\"production\"},\"pipes\":[{\"connector\":{\"strategy\":\"first\",\"connections\":[{\"connection\":\"resend_123\",\"type\":\"vault\"}]},\"pipe_id\":\"email:send:resend@1\",\"config\":{\"reply_to\":\"<REPLY_TO_EMAIL_ADDRESS>\",\"from\":\"<FROM_EMAIL_ADDRESS>\"}}],\"input\":[{\"id\":\"1\",\"email\":\"<EMAIL_ADDRESS>\",\"email_body\":\"<EMAIL_TEXT>\",\"email_subject\":\"<EMAIL_SUBJECT_LINE>\"}]}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("content-type", "application/json")
req.Header.Add("authorization", "Bearer <TOKEN>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}
<?php
require_once('vendor/autoload.php');
$client = new \GuzzleHttp\Client();
$response = $client->request('POST', 'https://api.pipe0.com/v1/pipes/run', [
'body' => '{"config":{"environment":"production"},"pipes":[{"connector":{"strategy":"first","connections":[{"connection":"resend_123","type":"vault"}]},"pipe_id":"email:send:resend@1","config":{"reply_to":"<REPLY_TO_EMAIL_ADDRESS>","from":"<FROM_EMAIL_ADDRESS>"}}],"input":[{"id":"1","email":"<EMAIL_ADDRESS>","email_body":"<EMAIL_TEXT>","email_subject":"<EMAIL_SUBJECT_LINE>"}]}',
'headers' => [
'authorization' => 'Bearer <TOKEN>',
'content-type' => 'application/json',
],
]);
echo $response->getBody();
POST /v1/pipes/run HTTP/1.1
Content-Type: application/json
Authorization: Bearer <TOKEN>
Host: api.pipe0.com
Content-Length: 368
{"config":{"environment":"production"},"pipes":[{"connector":{"strategy":"first","connections":[{"connection":"resend_123","type":"vault"}]},"pipe_id":"email:send:resend@1","config":{"reply_to":"<REPLY_TO_EMAIL_ADDRESS>","from":"<FROM_EMAIL_ADDRESS>"}}],"input":[{"id":"1","email":"<EMAIL_ADDRESS>","email_body":"<EMAIL_TEXT>","email_subject":"<EMAIL_SUBJECT_LINE>"}]}