Сделал сбор криптовалюты

collect-currency/save_crypto.js

@@ -0,0 +1,54 @@
+const config = require('../config/main.js')();
+const axios = require('axios');
+const pool = require('../database/postgresql.js');
+
+function save_fiat() {
+    if (!config['currency']['collecting']['crypto']) return;
+    const depth = config['currency']['cryptoKeys']
+
+    if (depth <= 0) new Error('Rate limit on all API tokens');
+
+    config['currency']['crypto'].forEach(
+        (value) => config['currency']['crypto'].forEach(async (pair) => {
+          if (value !== pair) {
+              const cryptoKeyActive = [0];
+              const res = await axios.get(`https://rest.coinapi.io/v1/exchangerate/${value}/${pair}`, {
+                  timeout: 3000,
+                  headers: {
+                      'X-CoinAPI-Key': config['currency']['cryptoKeys'][cryptoKeyActive[0]],
+                  }
+              });
+
+              if (res.status === 429) rotate_key(config['currency']['cryptoKeys'], cryptoKeyActive);
+
+              const data = res.data;
+              const point = data['rate'].toString().indexOf('.') + 4;
+
+              pool.query('SELECT * FROM currency WHERE from_currency = $1 AND conv_currency = $2 AND date = $3',
+                    [
+                        value,
+                        pair,
+                        new Date(data['time']).toLocaleDateString()
+                    ]).then(async (db) => {
+                    if (db['rows'][0]) return;
+
+                    await pool.query(`INSERT INTO currency (from_currency, conv_currency, rate, date) 
+                        VALUES ($1, $2, $3, $4) RETURNING *`,
+                        [
+                            value,
+                            pair,
+                            data['rate'].toString().slice(0, point),
+                            new Date(data['time']).toLocaleDateString()
+                        ],
+                    );
+                });
+          }
+        })
+    );
+}
+
+function rotate_key(list, active) {
+    return active[0] = (active + 1) % list.length;
+}
+
+module.exports = save_fiat;