summaryrefslogtreecommitdiff
path: root/api.js
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2018-05-05 13:52:50 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2018-05-05 13:52:50 +0200
commit63da93e9f443a799208c8e706616a828fa528a3e (patch)
treee0d540555cdca710645efb0ce061742ec55c8ec6 /api.js
parentc8dc06971c6dab447250bb81cca20836ed5b2772 (diff)
downloadbrokentalents-63da93e9f443a799208c8e706616a828fa528a3e.tar.gz
brokentalents-63da93e9f443a799208c8e706616a828fa528a3e.zip
move request param generation to own file, retry failed queries
Diffstat (limited to 'api.js')
-rw-r--r--api.js24
1 files changed, 12 insertions, 12 deletions
diff --git a/api.js b/api.js
index 3e65d66..30b4937 100644
--- a/api.js
+++ b/api.js
@@ -1,17 +1,17 @@
#!/usr/bin/node
-const requestP = require('request-promise')
- Future = require('fluture');
+const requestP = require('request-promise'),
+ config = require('./config'),
+ Future = require('fluture'),
+ FutureRetry = require('fluture-retry');
-const API_KEY = process.env.API_KEY || require('./secret').apikey,
- API_BASE = 'https://api.dc01.gamelockerapp.com',
- API_TIMEOUT = 1; // seconds
+const API_KEY = process.env.API_KEY || require('./secret').apikey;
const requestF = Future.encaseP(requestP);
function apiRequest(path, query) {
- return requestF({
- uri: API_BASE + path,
+ return FutureRetry.retryLinearly(requestF({
+ uri: config.api.baseUrl + path,
headers: {
'X-Title-Id': 'semc-vainglory',
'Authorization': API_KEY
@@ -20,20 +20,20 @@ function apiRequest(path, query) {
json: true,
gzip: true,
forever: true,
- timeout: API_TIMEOUT*1000,
+ timeout: config.api.timeout * 1000,
strictSSL: true
- });
+ }));
}
function awsRequest(url) {
- return requestF({
+ return FutureRetry.retryLinearly(requestF({
uri: url,
json: true,
gzip: true,
forever: true,
- timeout: API_TIMEOUT*1000,
+ timeout: config.api.timeout * 1000,
strictSSL: true
- });
+ }));
}
module.exports = {