chore: Added logging of what data was received, whether it passed validation or not

config.sample.hjson

@@ -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,

main.js

@@ -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'));
 
-    const services = [];
+    console.log('Loading services...');
-    for (const file of serviceFiles) {
+    config['currency']['services']['enabled'].forEach(serviceName => {
-        const filePath = path.join(servicesDir, file);
+        const servicePath = path.join(servicesDir, `${serviceName}.js`);
-        const moduleLoaded = require(filePath);
+        if (fs.existsSync(servicePath)) {
+            const serviceModule = require(servicePath);
 
-        if (typeof moduleLoaded.parseCurrencies === 'function') 
+            services.push(serviceModule);
-            services.push(moduleLoaded);
+            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);
                     }
                 }

services/coinmarketcap.js

@@ -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;
                 });
             });