Redume/Kekkai
1
0
Fork 0
mirror of https://github.com/Redume/Kekkai.git synced 2025-02-23 12:43:12 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: Removed depth check that caused memory overflow

Browse source
This commit is contained in:
Данил 2024-11-27 14:43:57 +03:00
parent 5009595ef2
commit 4ca14c5281
1 changed files with 3 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

18
collect-currency/save_fiat.js
View file

@ -3,9 +3,8 @@ const axios = require('axios');
const config = require('../shared/config/src/main.js')(); const config = require('../shared/config/src/main.js')();
const logger = require('../shared/logger/src/main.js'); const logger = require('../shared/logger/src/main.js');
async function save_fiat(depth = 0) { async function save_fiat() {
if (!config['currency']['collecting']['fiat']) return; if (!config['currency']['collecting']['fiat']) return;
const max_depth = 5;
config['currency']['fiat'].forEach((value) => config['currency']['fiat'].forEach((value) =>
config['currency']['fiat'].forEach(async (pair) => { config['currency']['fiat'].forEach(async (pair) => {
@ -38,7 +37,7 @@ async function save_fiat(depth = 0) {
[ [
value, value,
pair, pair,
new Date(data['timestamp']).toLocaleDateString(), new Date(data['timestamp']).toISOString().substring(0, 10),
], ],
); );
@ -49,23 +48,12 @@ async function save_fiat(depth = 0) {
value, value,
pair, pair,
data['to'][0]['mid'].toString().slice(0, point), data['to'][0]['mid'].toString().slice(0, point),
new Date(data['timestamp']).toLocaleDateString(), new Date(data['timestamp']).toISOString().substring(0, 10),
], ],
); );
}) })
.catch(async (err) => { .catch(async (err) => {
logger.error(err); logger.error(err);
if (depth < max_depth) {
await new Promise((resolve) =>
setTimeout(resolve, max_depth),
);
await save_fiat(depth + 1);
} else {
logger.error(
'Max retry limit reached for saving fiat data.',
);
}
}); });
}), }),
); );