Compare commits

..

2 commits

3 changed files with 34 additions and 15 deletions

View file

@ -10,6 +10,15 @@
fiat: true
crypto: false
}
services: {
enabled: [
'coinmarketcap'
]
coinmarketcap: {
"api_key": TOKEN_COINMARKETCAP"
"base_url": https://pro-api.coinmarketcap.com/v1/cryptocurrency/quotes/latest
}
}
fiat:
[
USD,

28
main.js
View file

@ -7,26 +7,28 @@ const { validateCurrency } = require('./models/Currency.js');
const { create_table, pool } = require('./database/data.js');
const config = require('./utils/load_config.js')();
const services = [];
const servicesDir = path.join(__dirname, 'services');
async function main() {
if (!config['schedule'])
throw new Error('The crontab schedule is not set.');
else if (!cron.isValidCron(config['schedule'], { alias: true }))
throw new Error('The crontab is invalid.');
const servicesDir = path.join(__dirname, 'services');
const serviceFiles = fs.readdirSync(servicesDir)
.filter(filename => filename.endsWith('.js'));
console.log('Loading services...');
config['currency']['services']['enabled'].forEach(serviceName => {
const servicePath = path.join(servicesDir, `${serviceName}.js`);
if (fs.existsSync(servicePath)) {
const serviceModule = require(servicePath);
const services = [];
for (const file of serviceFiles) {
const filePath = path.join(servicesDir, file);
const moduleLoaded = require(filePath);
if (typeof moduleLoaded.parseCurrencies === 'function')
services.push(moduleLoaded);
services.push(serviceModule);
console.log(`Service ${serviceName} loaded successfully`);
} else {
console.error(`Service file for ${serviceName} not found at ${servicePath}`);
}
});
console.log('Loaded parser services:', serviceFiles);
await create_table();
schedule.scheduleJob(config['schedule'], async () => {
@ -36,6 +38,8 @@ async function main() {
const results = await srv.parseCurrencies();
if (Array.isArray(results) && results.length > 0) {
console.log(`Data received from ${srv.name || 'unknown service'}:`, results.length, 'items');
for (const result of results) {
try {
const currency = await validateCurrency(result);
@ -49,7 +53,9 @@ async function main() {
currency.date,
]
);
console.log(`Inserted data for ${currency.from_currency} -> ${currency.conv_currency}, Rate: ${currency.rate}`);
} catch (validationError) {
console.error('Validation failed for data:', result);
console.error(validationError);
}
}

View file

@ -8,15 +8,17 @@ module.exports = {
return config['currency']['crypto'].map(convCurrency => {
if (fromCurrency === convCurrency) return Promise.resolve(null);
const coinmarketcap = config['currency']['services']['coinmarketcap'];
return axios.get(
'https://pro-api.coinmarketcap.com/v1/cryptocurrency/quotes/latest',
coinmarketcap['base_url'],
{
params: {
symbol: fromCurrency,
convert: convCurrency,
},
headers: {
'X-CMC_PRO_API_KEY': config['currency']['api_keys']['coinmarketcap'],
'X-CMC_PRO_API_KEY': coinmarketcap['api_key'],
}
}
)
@ -25,6 +27,8 @@ module.exports = {
const truncatedPriceStr = truncate_number(data.price, 3);
const rate = parseFloat(truncatedPriceStr);
console.log(`Data fetched from CoinMarketCap: ${fromCurrency} -> ${convCurrency}, Rate: ${rate}`);
return {
from_currency: fromCurrency,
conv_currency: convCurrency,
@ -33,7 +37,7 @@ module.exports = {
};
})
.catch((err) => {
console.error(err.respone.data);
console.error(err);
return null;
});
});