Update server.js

server.js

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