modules/twitter/lib/twitter-service.js

   1 'use strict';
   2
   3 var debug = require('debug')('gitter:app:twitter:service');
   4 var Promise = require('bluebird');
   5 var request = Promise.promisify(require('request'));
   6 var querystring = require('querystring');
   7 var StatusError = require('statuserror');
   8
   9 function escapeTweet(str) {
  10   return encodeURIComponent(str).replace(/[!'()*]/g, escape);
  11 }
  12
  13 var FOLLOWER_API_ENDPOINT = 'https://api.twitter.com/1.1/followers/list.json';
  14 var FAVORITES_API_ENDPOINT = 'https://api.twitter.com/1.1/favorites/list.json';
  15 var TWEET_API_ENDPOINT = 'https://api.twitter.com/1.1/statuses/update.json';
  16
  17 function TwitterService(consumerKey, consumerSecret, accessToken, accessTokenSecret) {
  18   this.consumerKey = consumerKey;
  19   this.consumerSecret = consumerSecret;
  20   this.accessToken = accessToken;
  21   this.accessTokenSecret = accessTokenSecret;
  22 }
  23
  24 TwitterService.prototype.findFollowers = function(username) {
  25   return request({
  26     url: FOLLOWER_API_ENDPOINT,
  27     json: true,
  28     oauth: {
  29       consumer_key: this.consumerKey,
  30       consumer_secret: this.consumerSecret,
  31       token: this.accessToken,
  32       token_secret: this.accessTokenSecret
  33     },
  34     qs: {
  35       screen_name: username
  36     }
  37   }).then(function(results) {
  38     debug('Twitter API results: %j', results && results.body);
  39     if (!results.body || !results.body.users) {
  40       return [];
  41     }
  42
  43     return results.body.users;
  44   });
  45 };
  46
  47 TwitterService.prototype.findFavorites = function() {
  48   return request({
  49     url: FAVORITES_API_ENDPOINT,
  50     json: true,
  51     oauth: {
  52       consumer_key: this.consumerKey,
  53       consumer_secret: this.consumerSecret,
  54       token: this.accessToken,
  55       token_secret: this.accessTokenSecret
  56     }
  57   });
  58 };
  59
  60 TwitterService.prototype.sendTweet = function(status) {
  61   return request({
  62     method: 'POST',
  63     url: TWEET_API_ENDPOINT,
  64     json: true,
  65     oauth: {
  66       consumer_key: this.consumerKey,
  67       consumer_secret: this.consumerSecret,
  68       token: this.accessToken,
  69       token_secret: this.accessTokenSecret
  70     },
  71     encoding: null,
  72     headers: {
  73       'content-type': 'application/x-www-form-urlencoded'
  74     },
  75     body: querystring.stringify(
  76       {
  77         status: status
  78       },
  79       '&',
  80       '=',
  81       {
  82         encodeURIComponent: escapeTweet
  83       }
  84     )
  85   }).then(function(res) {
  86     if (res.statusCode === 200) {
  87       return;
  88     }
  89
  90     var errorMessage = res.body;
  91     if (res.body.errors) {
  92       errorMessage = (res.body.errors || []).reduce(function(errorString, error) {
  93         return (
  94           errorString + (errorString.length > 0 ? ' -- ' : '') + error.code + ' ' + error.message
  95         );
  96       }, '');
  97     }
  98     var errorString = 'Status: ' + res.statusCode + ' -- ' + errorMessage;
  99
 100     throw new StatusError(400, errorString);
 101   });
 102 };
 103
 104 module.exports = TwitterService;