Send a DM when a user follows @pipedream on Twitter
•@demo•
•code:
•data:public•last updated:2 years ago
today
Generate events to trigger workflow code...
This is a live workflow with public data.
Select an event to inspect the return values and logs for each step (learn more).
Sign up to customize, add steps, modify code and more.
Join 1,000,000+ developers using the Pipedream platform
steps.
trigger
active
•last updated:-•last event:-steps.
generate_message
auth
to use OAuth tokens and API keys in code via the
auths objectcode
Write any Node.jscodeand use anynpm package. You can alsoexport datafor use in later steps via
return or this.key = 'value', pass input data to your code viaparams, and maintain state across executions with$checkpoint.async (event, steps) => {1
2
3
4
5
6
7
8
9
10
11
12
}13
return `Hi ${steps.trigger.event.screen_name}! Thanks for the follow!
Want to see how we automatically sent this DM when you followed us? Check out this live workflow:
https://pipedream.com/@/${steps.trigger.context.workflow_id}/edit?e=${steps.trigger.context.id}
The workflow was triggered when you followed @pipedream, and we used Node.js code steps together with the Twit npm package and Pipedream managed authentication for the Twitter API to send this message.
You can copy the workflow to customize and run it for free, or build your own using any APIs (we support managed auth for 900+ OAuth and key-based apps), Node.js + npm, and no code triggers and actions!
Check out more live demos at https://pipedream.com/@demo or see how to build a workflow at https://www.youtube.com/watch?v=pRHsQyyfYl0.`steps.
send_dm
auth
to use OAuth tokens and API keys in code via the
auths object(auths.twitter_developer_app)
code
Write any Node.jscodeand use anynpm package. You can alsoexport datafor use in later steps via
return or this.key = 'value', pass input data to your code viaparams, and maintain state across executions with$checkpoint.async (event, steps, auths) => {1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
}30
const Twit = require('twit')
const { api_key, api_secret_key, access_token, access_token_secret } = auths.twitter_developer_app
const T = new Twit({
consumer_key: api_key,
consumer_secret: api_secret_key,
access_token,
access_token_secret,
timeout_ms: 60 * 1000, // optional HTTP request timeout to apply to all requests.
strictSSL: true, // optional - requires SSL certificates to be valid.
})
const response = await T.post("direct_messages/events/new", {
"event": {
"type": "message_create",
"message_create": {
"target": {
"recipient_id": steps.trigger.event.id_str
},
"message_data": {
"text": steps.generate_message.$return_value
}
}
}
});
return response.data.event