diff --git a/collect-currency/save_crypto.js b/collect-currency/save_crypto.js index ffa7acc..f139ac2 100644 --- a/collect-currency/save_crypto.js +++ b/collect-currency/save_crypto.js @@ -27,17 +27,6 @@ async function save_crypto() { const point = data['price'].toString().indexOf('.') + 4; - const db = await pool.query( - 'SELECT * FROM currency WHERE ' + - 'from_currency = $1 AND conv_currency = $2 AND date = $3', - [ - value, - pair, - new Date(data['last_updated']).toISOString().substring(0, 10), - ], - ); - - if (db['rows'][0]) return; await pool.query( `INSERT INTO currency (from_currency, conv_currency, rate, date) VALUES ($1, $2, $3, $4)`, [ diff --git a/collect-currency/save_fiat.js b/collect-currency/save_fiat.js index 1492437..e553dad 100644 --- a/collect-currency/save_fiat.js +++ b/collect-currency/save_fiat.js @@ -31,17 +31,6 @@ async function save_fiat() { const point = data['to'][0]['mid'].toString().indexOf('.') + 4; - const db = await pool.query( - 'SELECT * FROM currency WHERE ' + - 'from_currency = $1 AND conv_currency = $2 AND date = $3', - [ - value, - pair, - new Date(data['timestamp']).toISOString().substring(0, 10), - ], - ); - - if (db['rows'][0]) return; await pool.query( `INSERT INTO currency (from_currency, conv_currency, rate, date) VALUES ($1, $2, $3, $4)`, [