Compare commits

..

5 Commits

Author SHA1 Message Date
Alexander Corn
840e9548ed 3.19.0-beta5 2016-03-05 00:40:56 -05:00
Alexander Corn
dee6b7964b Fixed crash under specific conditions 2016-03-05 00:40:45 -05:00
Alexander Corn
2fc434d475 3.19.0-beta4 2016-03-05 00:27:13 -05:00
Alexander Corn
42ebbda00d Fixed typo 2016-03-05 00:27:04 -05:00
Alexander Corn
eed791acbd Added ability to delay HTTP requests 2016-03-05 00:14:36 -05:00
3 changed files with 43 additions and 23 deletions

View File

@@ -22,30 +22,46 @@ SteamCommunity.prototype.httpRequest = function(uri, options, callback, source)
var requestID = ++this._httpRequestID;
source = source || "";
if (this.onPreHttpRequest && this.onPreHttpRequest(requestID, source, options, callback) === false) {
return false;
var self = this;
var continued = false;
if (!this.onPreHttpRequest || !this.onPreHttpRequest(requestID, source, options, continueRequest)) {
// No pre-hook, or the pre-hook doesn't want to delay the request.
continueRequest(null);
}
var self = this;
this.request(options, function(err, response, body) {
var hasCallback = !!callback;
var httpError = options.checkHttpError !== false && self._checkHttpError(err, response, callback);
var communityError = !options.json && options.checkCommunityError !== false && self._checkCommunityError(body, httpError ? function() {} : callback); // don't fire the callback if hasHttpError did it already
var tradeError = !options.json && options.checkTradeError !== false && self._checkTradeError(body, httpError || communityError ? function() {} : callback); // don't fire the callback if either of the previous already did
self.emit('postHttpRequest', requestID, source, options, httpError || communityError || tradeError || null, response, body, {
"hasCallback": hasCallback,
"httpError": httpError,
"communityError": communityError,
"tradeError": tradeError
});
if (hasCallback && !(httpError || communityError || tradeError)) {
callback.apply(self, arguments);
function continueRequest(err) {
if (continued) {
return;
}
});
return true;
continued = true;
if (err) {
callback(err);
return;
}
self.request(options, function (err, response, body) {
var hasCallback = !!callback;
var httpError = options.checkHttpError !== false && self._checkHttpError(err, response, callback);
var communityError = !options.json && options.checkCommunityError !== false && self._checkCommunityError(body, httpError ? function () {
} : callback); // don't fire the callback if hasHttpError did it already
var tradeError = !options.json && options.checkTradeError !== false && self._checkTradeError(body, httpError || communityError ? function () {
} : callback); // don't fire the callback if either of the previous already did
self.emit('postHttpRequest', requestID, source, options, httpError || communityError || tradeError || null, response, body, {
"hasCallback": hasCallback,
"httpError": httpError,
"communityError": communityError,
"tradeError": tradeError
});
if(hasCallback && !(httpError || communityError || tradeError)) {
callback.apply(self, arguments);
}
});
}
};
SteamCommunity.prototype.httpRequestGet = function() {
@@ -81,7 +97,7 @@ SteamCommunity.prototype._checkHttpError = function(err, response, callback) {
};
SteamCommunity.prototype._checkCommunityError = function(html, callback) {
if(html.match(/<h1>Sorry!<\/h1>/)) {
if(html && html.match(/<h1>Sorry!<\/h1>/)) {
var match = html.match(/<h3>(.+)<\/h3>/);
var err = new Error(match ? match[1] : "Unknown error occurred");
callback(err);
@@ -92,6 +108,10 @@ SteamCommunity.prototype._checkCommunityError = function(html, callback) {
};
SteamCommunity.prototype._checkTradeError = function(html, callback) {
if (!html) {
return false;
}
var match = html.match(/<div id="error_msg">\s*([^<]+)\s*<\/div>/);
if (match) {
var err = new Error(match[1].trim());

View File

@@ -348,7 +348,7 @@ SteamCommunity.prototype._myProfile = function(endpoint, form, callback) {
}
var options = {
"uri": "https://steamcommunity.com" + mtch[1] + "/" + endpoint,
"uri": "https://steamcommunity.com" + match[1] + "/" + endpoint,
"method": "GET"
};

View File

@@ -1,6 +1,6 @@
{
"name": "steamcommunity",
"version": "3.19.0-beta3",
"version": "3.19.0-beta5",
"description": "Provides an interface for logging into and interacting with the Steam Community website",
"keywords": ["steam", "steam community"],
"homepage": "https://github.com/DoctorMcKay/node-steamcommunity",