Update server.js

server.js

@@ -1,89 +1,69 @@
 const express = require('express');
 const axios = require('axios');
-const NodeCache = require('node-cache');
-const cron = require('node-cron');
+const apicache = require('apicache'); // Import apicache
 const cors = require('cors');
 
 const app = express();
 const port = process.env.PORT || 3000;
-const cache = new NodeCache({ stdTTL: 900 }); // Cache TTL is 15 minutes
+
+const cache = apicache.middleware;
+const cacheDuration = '15 minutes'; // Cache duration
 
 const ERGAST_API_BASE_URL = 'https://ergast.com/api/f1/';
 
 app.use(cors());
 
-// Function to fetch data from Ergast API and update cache
-const fetchDataAndUpdateCache = async (url, cacheKey) => {
-    try {
-        const response = await axios.get(url);
-        cache.set(cacheKey, response.data);
-        console.log(`Updated ${cacheKey} cache`);
-    } catch (error) {
-        console.error(`Error updating ${cacheKey} cache:`, error);
-    }
-};
-
-// Schedule to update cache every 15 minutes for all endpoints
-cron.schedule('*/15 * * * *', async () => {
-    // Example: Update current season data
-    await fetchDataAndUpdateCache(`${ERGAST_API_BASE_URL}current.json`, 'currentSeason');
+// Middleware to enable caching
+app.use(cache(cacheDuration));
 
-    // Add more endpoints to update cache as needed
-    // await fetchDataAndUpdateCache(`${ERGAST_API_BASE_URL}current/other.json`, 'otherData');
-});
-
-// Generic endpoint handler to fetch data with caching and error handling
-const handleEndpointWithCache = async (req, res, url, cacheKey) => {
+app.get('/api/currentSeason', async (req, res) => {
     try {
-        const cachedData = cache.get(cacheKey);
-        if (cachedData) {
-            res.json(cachedData);
-        } else {
-            const response = await axios.get(url);
-            cache.set(cacheKey, response.data);
-            res.json(response.data);
-        }
+        const response = await axios.get(`${ERGAST_API_BASE_URL}current.json`);
+        res.json(response.data);
     } catch (error) {
-        console.error(`Error fetching ${cacheKey} from Ergast API:`, error);
-        const cachedData = cache.get(cacheKey);
-        if (cachedData) {
-            res.json(cachedData);
-        } else {
-            res.status(500).send(`Error fetching data from Ergast API for ${cacheKey} and no cache available.`);
-        }
+        console.error('Error fetching currentSeason from Ergast API:', error);
+        res.status(500).send('Error fetching data from Ergast API.');
     }
-};
-
-// Example endpoint to get current season data
-app.get('/api/currentSeason', async (req, res) => {
-    await handleEndpointWithCache(req, res, `${ERGAST_API_BASE_URL}current.json`, 'currentSeason');
 });
 
-// Example endpoint to get driver standings data
 app.get('/api/driverStandings', async (req, res) => {
     const season = req.query.season || 'current';
-    await handleEndpointWithCache(req, res, `${ERGAST_API_BASE_URL}${season}/driverStandings.json`, `driverStandings-${season}`);
+    try {
+        const response = await axios.get(`${ERGAST_API_BASE_URL}${season}/driverStandings.json`);
+        res.json(response.data);
+    } catch (error) {
+        console.error(`Error fetching driverStandings-${season} from Ergast API:`, error);
+        res.status(500).send('Error fetching data from Ergast API.');
+    }
 });
 
-// Example endpoint to get constructor standings data
 app.get('/api/constructorStandings', async (req, res) => {
     const season = req.query.season || 'current';
-    await handleEndpointWithCache(req, res, `${ERGAST_API_BASE_URL}${season}/constructorStandings.json`, `constructorStandings-${season}`);
+    try {
+        const response = await axios.get(`${ERGAST_API_BASE_URL}${season}/constructorStandings.json`);
+        res.json(response.data);
+    } catch (error) {
+        console.error(`Error fetching constructorStandings-${season} from Ergast API:`, error);
+        res.status(500).send('Error fetching data from Ergast API.');
+    }
 });
 
-// Example endpoint to get race results data
 app.get('/api/raceResults', async (req, res) => {
     const season = req.query.season || 'current';
     const round = req.query.round;
     if (!round) {
         return res.status(400).send('Round is required.');
     }
-    await handleEndpointWithCache(req, res, `${ERGAST_API_BASE_URL}${season}/${round}/results.json`, `raceResults-${season}-${round}`);
-});
 
-// Add more endpoints with similar structure as needed
+    try {
+        const response = await axios.get(`${ERGAST_API_BASE_URL}${season}/${round}/results.json`);
+        res.json(response.data);
+    } catch (error) {
+        console.error(`Error fetching raceResults-${season}-${round} from Ergast API:`, error);
+        res.status(500).send('Error fetching data from Ergast API.');
+    }
+});
 
-// Start server
 app.listen(port, () => {
     console.log(`Server running on port ${port}`);
 });