github-repos/node-steamcommunity
1
0
Fork 0
mirror of https://github.com/DoctorMcKay/node-steamcommunity.git synced 2025-02-12 10:40:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Code cleanup for http.js

Browse Source
This commit is contained in:
Alex Corn 2019-09-24 04:43:51 -04:00
parent 30ebf333b4
commit fa253920e3
1 changed files with 29 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
components/http.js
View File

@ -1,12 +1,12 @@
const SteamCommunity = require('../index.js'); const SteamCommunity = require('../index.js');
SteamCommunity.prototype.httpRequest = function(uri, options, callback, source) { SteamCommunity.prototype.httpRequest = function(uri, options, callback, source) {
if (typeof uri === 'object') { if (typeof uri == 'object') {
source = callback; source = callback;
callback = options; callback = options;
options = uri; options = uri;
uri = options.url || options.uri; uri = options.url || options.uri;
} else if (typeof options === 'function') { } else if (typeof options == 'function') {
source = callback; source = callback;
callback = options; callback = options;
options = {}; options = {};
@ -19,18 +19,12 @@ SteamCommunity.prototype.httpRequest = function(uri, options, callback, source)
delete this._httpRequestConvenienceMethod; delete this._httpRequestConvenienceMethod;
} }
var requestID = ++this._httpRequestID; let requestID = ++this._httpRequestID;
source = source || ""; source = source || '';
var self = this; let continued = false;
var continued = false;
if (!this.onPreHttpRequest || !this.onPreHttpRequest(requestID, source, options, continueRequest)) { let continueRequest = (err) => {
// No pre-hook, or the pre-hook doesn't want to delay the request.
continueRequest(null);
}
function continueRequest(err) {
if (continued) { if (continued) {
return; return;
} }
@ -45,14 +39,14 @@ SteamCommunity.prototype.httpRequest = function(uri, options, callback, source)
return; return;
} }
self.request(options, function (err, response, body) { this.request(options, (err, response, body) => {
var hasCallback = !!callback; let hasCallback = !!callback;
var httpError = options.checkHttpError !== false && self._checkHttpError(err, response, callback, body); let httpError = options.checkHttpError !== false && this._checkHttpError(err, response, callback, body);
var communityError = !options.json && options.checkCommunityError !== false && self._checkCommunityError(body, httpError ? function () {} : callback); // don't fire the callback if hasHttpError did it already let communityError = !options.json && options.checkCommunityError !== false && this._checkCommunityError(body, httpError ? noop : 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 let tradeError = !options.json && options.checkTradeError !== false && this._checkTradeError(body, httpError || communityError ? noop : callback); // don't fire the callback if either of the previous already did
var jsonError = options.json && options.checkJsonError !== false && !body ? new Error("Malformed JSON response") : null; let jsonError = options.json && options.checkJsonError !== false && !body ? new Error("Malformed JSON response") : null;
self.emit('postHttpRequest', requestID, source, options, httpError || communityError || tradeError || jsonError || null, response, body, { this.emit('postHttpRequest', requestID, source, options, httpError || communityError || tradeError || jsonError || null, response, body, {
"hasCallback": hasCallback, "hasCallback": hasCallback,
"httpError": httpError, "httpError": httpError,
"communityError": communityError, "communityError": communityError,
@ -62,12 +56,17 @@ SteamCommunity.prototype.httpRequest = function(uri, options, callback, source)
if (hasCallback && !(httpError || communityError || tradeError)) { if (hasCallback && !(httpError || communityError || tradeError)) {
if (jsonError) { if (jsonError) {
callback.call(self, jsonError, response); callback.call(this, jsonError, response);
} else { } else {
callback.apply(self, arguments); callback.apply(this, arguments);
} }
} }
}); });
};
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);
} }
}; };
@ -98,7 +97,7 @@ SteamCommunity.prototype._checkHttpError = function(err, response, callback, bod
return err; return err;
} }
if (response.statusCode == 403 && typeof response.body === 'string' && response.body.match(/<div id="parental_notice_instructions">Enter your PIN below to exit Family View.<\/div>/)) { if (response.statusCode == 403 && typeof response.body == 'string' && response.body.match(/<div id="parental_notice_instructions">Enter your PIN below to exit Family View.<\/div>/)) {
err = new Error("Family View Restricted"); err = new Error("Family View Restricted");
callback(err, response, body); callback(err, response, body);
return err; return err;
@ -115,16 +114,16 @@ SteamCommunity.prototype._checkHttpError = function(err, response, callback, bod
}; };
SteamCommunity.prototype._checkCommunityError = function(html, callback) { SteamCommunity.prototype._checkCommunityError = function(html, callback) {
var err; let err;
if(typeof html === 'string' && html.match(/<h1>Sorry!<\/h1>/)) { if (typeof html == 'string' && html.match(/<h1>Sorry!<\/h1>/)) {
var match = html.match(/<h3>(.+)<\/h3>/); let match = html.match(/<h3>(.+)<\/h3>/);
err = new Error(match ? match[1] : "Unknown error occurred"); err = new Error(match ? match[1] : "Unknown error occurred");
callback(err); callback(err);
return err; return err;
} }
if (typeof html === 'string' && html.match(/g_steamID = false;/) && html.match(/<h1>Sign In<\/h1>/)) { if (typeof html == 'string' && html.match(/g_steamID = false;/) && html.match(/<h1>Sign In<\/h1>/)) {
err = new Error("Not Logged In"); err = new Error("Not Logged In");
callback(err); callback(err);
this._notifySessionExpired(err); this._notifySessionExpired(err);
@ -139,12 +138,14 @@ SteamCommunity.prototype._checkTradeError = function(html, callback) {
return false; return false;
} }
var match = html.match(/<div id="error_msg">\s*([^<]+)\s*<\/div>/); let match = html.match(/<div id="error_msg">\s*([^<]+)\s*<\/div>/);
if (match) { if (match) {
var err = new Error(match[1].trim()); let err = new Error(match[1].trim());
callback(err); callback(err);
return err; return err;
} }
return false; return false;
}; };
function noop() {}