Kekkai/Currency-parser
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: Kekkai:1a63649bef1362b9817a7aa0accf8347495db864
Branches Tags
Kekkai:main
..
compare: Kekkai:6125f99ec6fb9442c4f743fc3c6b084ba468573b
Branches Tags
Kekkai:main

No commits in common. "1a63649bef1362b9817a7aa0accf8347495db864" and "6125f99ec6fb9442c4f743fc3c6b084ba468573b" have entirely different histories.
1a63649bef ... 6125f99ec6

3 changed files with 15 additions and 34 deletions
Show stats Expand all files Collapse all files

9
config.sample.hjson
View file

@ -10,15 +10,6 @@
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,

30
main.js
View file

@ -7,28 +7,26 @@ 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);
services.push(serviceModule);
console.log(`Service ${serviceName} loaded successfully`);
} else {
console.error(`Service file for ${serviceName} not found at ${servicePath}`);
}
});
if (typeof moduleLoaded.parseCurrencies === 'function')
services.push(moduleLoaded);
}
console.log('Loaded parser services:', serviceFiles);
await create_table();
schedule.scheduleJob(config['schedule'], async () => {
@ -38,8 +36,6 @@ 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);
@ -53,9 +49,7 @@ 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);
}
}

10
services/coinmarketcap.js
View file

@ -8,17 +8,15 @@ module.exports = {
return config['currency']['crypto'].map(convCurrency => {
if (fromCurrency === convCurrency) return Promise.resolve(null);
const coinmarketcap = config['currency']['services']['coinmarketcap'];
return axios.get(
coinmarketcap['base_url'],
'https://pro-api.coinmarketcap.com/v1/cryptocurrency/quotes/latest',
{
params: {
symbol: fromCurrency,
convert: convCurrency,
},
headers: {
'X-CMC_PRO_API_KEY': coinmarketcap['api_key'],
'X-CMC_PRO_API_KEY': config['currency']['api_keys']['coinmarketcap'],
}
}
)
@ -27,8 +25,6 @@ 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,
@ -37,7 +33,7 @@ module.exports = {
};
})
.catch((err) => {
console.error(err);
console.error(err.respone.data);
return null;
});
});