queries.js

var http = require("http");
var request = require("request");
//var fs = require("fs");
//var IDs = require("./values.js");

/*
    backpacktf.queryAPI()
    Queries the backpack.tf API with a given method and parameters
    Parameters: 
      method: the method you are calling the API with
      v: version of the method. i.e. v4
      key: backpack.tf api key
      format: format of the file, this should really always be json
        unless debugging.
      adds: any additional parameters in the method
      callback: called when API responds.
        Callback arguments:
          data: an Object containing the response
    Not included in module.exports.
 */

function queryAPI(method, v, key, format, adds, callback) {
  var urltouse = "http://backpack.tf/api/" + method + "/" + v + "/?key=" + key + "&format=" + format + adds;
  http.get(urltouse, function(res) {
    var body = "";
    res.on("data", function(chunk) {
      body += chunk;
    });
    res.on("end", function() {
      callback(JSON.parse(body));
    });
  });
}

/*
    backpacktf.getMarketPrices()
    Uses the backpack.tf api to get SCM data.
    Parameters:
      key: backpack.tf api key
      appid: steam"s numeric identifier for the game
        you want data from
      callback: called when market prices are retrieved.
        Callback arguments:
          err: an Error object, null on success
          data: an Object containing the response
*/

function getMarketPrices(key, appid, callback) {
  queryAPI("IGetMarketPrices", "v4", key, "json", "&appid=" + appid, function(data) {
    if (data.response.success === 0) {
      callback(new Error(data.response.message));
    } else {
      callback(null, data);
    }
  });
}

/*
    backpacktf.getBPPrices()
    Retrieves backpack.tf price data for specified appid.
    Parameters:
      key: backpack.tf api key
      appid: game id
      callback: called when prices are recieved
        Callback arguments:
          err: an Error object with the reason for
            failure, null on success
          data: an Object containing the response
*/

function getBPPrices(key, appid, callback) {
  queryAPI("IGetPrices", "v4", key, "json", "&appid=" + appid, function(data) {
    if (data.response.success === 0) {
      callback(new Error(data.response.message));
    } else {
      callback(null, data);
    }
  });
}

/*
    backpacktf.getUser()
    Retrieves backpack.tf price data for specified appid.
    Parameters:
      key: backpack.tf api key
      steamids: list of users to retrieve data on, delimited by commas
      callback: called when backpacks are retrieved
        Callback Arguments:
          err: an Error object with the reason for failure,
            null on success
          data: an Object containing the response
*/

function getUser(key, steamids, callback) {
  queryAPI("IGetUsers", "v3", key, "json", "&steamids=" + steamids, function(data) {
    if (data.response.success === 0) {
      callback(new Error(data.response.message));
    } else {
      callback(null, data);
    }
  });
}

function getCurrencies(key, appid, callback) {
  queryAPI("IGetCurrencies", "v1", key, "json", "&appid=" + appid, function(data) {
    if (data.response.success === 0) {
      callback(new Error(data.response.message));
    } else {
      callback(null, data);
    }
  });
}

/*
    backpacktf.startAutomatic()
    Tells backpack.tf that your SteamID should have the lightning icon. Cool.
    Parameters:

*/

function startAutomatic(steamid, token, callback) {
  var requestParams = {
    uri: "http://backpack.tf/api/IAutomatic/IHeartBeat/",
    form: {
      method: "alive",
      version: "1.0.0",
      steamid,
      token
    },
    json: true,
    method: "POST"
  };
  request(requestParams, function(err, response, body) {
    //uh yeah. probably should return a status code or something
    if (err) {
      callback(err);
    } else if (response.statusCode !== 200) {
      callback(new Error("Connection Error: HTTP Status code " + response.statusCode));
    } else {
      if (body.success) {
        callback();
      } else {
        callback(new Error("Invalid Token"));
      }
    }
  });
}

function offerAccepted(steamid, token, callback) {
  var requestParams = {
    uri: "http://backpack.tf/api/IAutomatic/IOfferDetails/",
    form: {
      method: "completed",
      steamid,
      version: "1.0.0",
      token,
      offer: 943526664, //hard-coded in, doesn't actually matter i think
      message: "Yes" //same ^^
    },
    method: "POST"
  };
  request(requestParams, function(err, response, body) {
    //uh yeah. probably should return a status code or something
    if (err) {
      callback(err);
    } else if (response.statusCode !== 200) {
      callback(new Error("Connection Error: HTTP Status code " + response.statusCode));
    } else {
      //success!
      callback();
    }
  });
}

module.exports = {
  getUser,
  getCurrencies,
  getBPPrices,
  getMarketPrices,
  startAutomatic,
  offerAccepted
};