|
|
|
const Twitter = require('twitter')
|
|
|
|
const morph = require('morphmorph')
|
|
|
|
|
|
|
|
const RATE_LIMIT_CODE = 420
|
|
|
|
|
|
|
|
const client = new Twitter({
|
|
|
|
consumer_key: process.env.TWITTER_CONSUMER_KEY,
|
|
|
|
consumer_secret: process.env.TWITTER_CONSUMER_SECRET,
|
|
|
|
access_token_key: process.env.TWITTER_ACCESS_TOKEN_KEY,
|
|
|
|
access_token_secret: process.env.TWITTER_ACCESS_TOKEN_SECRET
|
|
|
|
})
|
|
|
|
|
|
|
|
const uploadImage = data => client.post('media/upload', { media_data: data })
|
|
|
|
const uploadTweet = (media = {}) =>
|
|
|
|
client.post('statuses/update', {
|
|
|
|
status: `Carbon Copy #${media.media_id_string.slice(0, 8)}`,
|
|
|
|
media_ids: media.media_id_string
|
|
|
|
})
|
|
|
|
|
|
|
|
const extractImageUrl = morph.get('entities.media.0.display_url')
|
|
|
|
const extractErrorCode = morph.get('0.code')
|
|
|
|
|
|
|
|
const respondSuccess = (res, url) => res.json({ url })
|
|
|
|
const respondFail = (res, err) => {
|
|
|
|
const errorCode = extractErrorCode(err)
|
|
|
|
|
|
|
|
// check for rate limit
|
|
|
|
if (errorCode === RATE_LIMIT_CODE) {
|
|
|
|
return res.status(420).send()
|
|
|
|
}
|
|
|
|
|
|
|
|
console.error(`Error: ${err.message || JSON.stringify(err, null, 2)}`)
|
|
|
|
res.status(500).send()
|
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = (req, res) => {
|
|
|
|
if (!req.body.data) {
|
|
|
|
return res.status(400).send()
|
|
|
|
}
|
|
|
|
|
|
|
|
uploadImage(req.body.data)
|
|
|
|
.then(uploadTweet)
|
|
|
|
.then(extractImageUrl)
|
|
|
|
.then(respondSuccess.bind(null, res))
|
|
|
|
.catch(respondFail.bind(null, res))
|
|
|
|
}
|