index.js

var OAuth = require('oauth');
var needle = require('needle');
module.exports = {
    oauth: null,
    format: null,
    parameters: {},
    //yql-node used to output only xml, now the formatAsJSON chainloader should help.
    withOAuth: function (consumer_key, consumer_secret) {
        this.oauth = new OAuth.OAuth(
          'https://query.yahooapis.com/v1/yql/',
          'https://query.yahooapis.com/v1/yql/',
          consumer_key, //consumer key
          consumer_secret, //consumer secret
          '1.0',
          null,
          'HMAC-SHA1'
          );
        this.oauth.setClientOptions({ requestTokenHttpMethod: 'POST' });

        return this;
    },
    formatAsJSON: function () {
        this.format = 'json';
        return this;
    },
    formatAsXML: function () {
        this.format = 'xml';
        return this;
    },
    setQueryParameter: function(parameters) {
        this.parameters = Object.assign(this.parameters, parameters);
        return this;
    },

    execute: function (query, callback) {
        if (this.oauth != null) {
            this.oauth.post('https://query.yahooapis.com/v1/yql',
              '',
              '',
              Object.assign({ q: query, format: this.format || 'xml' }, this.parameters),
              callback);
        } else {
            needle
              .post("https://query.yahooapis.com/v1/public/yql",
                Object.assign({ q: query, format: this.format || 'xml' }, this.parameters),
                { multipart: false },
                function (err, res) {
                    callback(err, res.body);
                });
        }
    }
}