machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Catch http request error - Fix 24h retry period

Browse Source
This commit is contained in:
nymkappa 2022-04-07 16:14:43 +09:00
parent 2d29b9ef89
commit e451b40084
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
backend/src/tasks/pools-updater.ts
View File

@ -47,7 +47,7 @@ class PoolsUpdater {
logger.notice('PoolsUpdater completed'); logger.notice('PoolsUpdater completed');
} catch (e) { } catch (e) {
this.lastRun = now - oneWeek - oneDay; // Try again in 24h this.lastRun = now - (oneWeek - oneDay); // Try again in 24h instead of waiting next week
logger.err('PoolsUpdater failed. Will try again in 24h. Error: ' + e); logger.err('PoolsUpdater failed. Will try again in 24h. Error: ' + e);
} }
} }
@ -113,7 +113,7 @@ class PoolsUpdater {
/** /**
* Http request wrapper * Http request wrapper
*/ */
private async query(path): Promise<string> { private query(path): Promise<string> {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const options = { const options = {
host: 'api.github.com', host: 'api.github.com',
@ -124,7 +124,7 @@ class PoolsUpdater {
logger.debug('Querying: api.github.com' + path); logger.debug('Querying: api.github.com' + path);
https.get(options, (response) => { const request = https.get(options, (response) => {
const chunks_of_data: any[] = []; const chunks_of_data: any[] = [];
response.on('data', (fragments) => { response.on('data', (fragments) => {
chunks_of_data.push(fragments); chunks_of_data.push(fragments);
@ -136,6 +136,11 @@ class PoolsUpdater {
reject(error); reject(error);
}); });
}); });
request.on('error', (error) => {
logger.err('Query failed with error: ' + error);
reject(error);
})
}); });
} }
} }