diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2018-05-05 13:52:50 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2018-05-05 13:52:50 +0200 |
| commit | 63da93e9f443a799208c8e706616a828fa528a3e (patch) | |
| tree | e0d540555cdca710645efb0ce061742ec55c8ec6 /api.js | |
| parent | c8dc06971c6dab447250bb81cca20836ed5b2772 (diff) | |
| download | brokentalents-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.js | 24 |
1 files changed, 12 insertions, 12 deletions
@@ -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 = { |
