Added modified version after migrating
This commit is contained in:
73
server.js
73
server.js
@ -1,15 +1,22 @@
|
||||
const express = require('express');
|
||||
const axios = require('axios');
|
||||
const path = require('path');
|
||||
const fs = require('fs');
|
||||
const app = express();
|
||||
const port = 80;
|
||||
|
||||
const url = 'http://transport.tallinn.ee/gps.txt';
|
||||
const fetchInterval = 10 * 1000; // 10 seconds
|
||||
const retentionPeriod = 7 * 24 * 60 * 60 * 1000; // 7 days in ms
|
||||
const gpsFilePath = 'gps/';
|
||||
const logFilePath = 'logs/';
|
||||
|
||||
app.use(express.static(path.join(__dirname, 'public')));
|
||||
app.use('/gps', express.static(path.join(__dirname, 'gps'))); // Serve static files from the gps directory
|
||||
|
||||
app.get('/gps-files', (req, res) => {
|
||||
const gpsDir = path.join(__dirname, 'gps');
|
||||
fs.readdir(gpsDir, (err, files) => {
|
||||
const gpsFilePath = path.join(__dirname, 'gps');
|
||||
fs.readdir(gpsFilePath, (err, files) => {
|
||||
if (err) return res.status(500).send(err.message);
|
||||
const gpsFiles = files
|
||||
.filter(file => file.startsWith('gps-') && file.endsWith('.txt'))
|
||||
@ -24,3 +31,65 @@ app.get('/gps-files', (req, res) => {
|
||||
app.listen(port, () => {
|
||||
console.log(`Server running at http://localhost:${port}`);
|
||||
});
|
||||
|
||||
if (!fs.existsSync(gpsFilePath)) fs.mkdirSync(gpsFilePath);
|
||||
|
||||
function writeToLog(filename, data) {
|
||||
fs.appendFileSync(filename, data);
|
||||
}
|
||||
|
||||
function deleteOldFiles() {
|
||||
const now = Date.now();
|
||||
fs.readdirSync(gpsFilePath).forEach(file => {
|
||||
const filePath = path.join(gpsFilePath, file);
|
||||
const stats = fs.statSync(filePath);
|
||||
if (now - stats.mtimeMs > retentionPeriod) {
|
||||
fs.unlinkSync(filePath);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
async function fetchAndSaveData() {
|
||||
try {
|
||||
console.log(`Fetch started`);
|
||||
const date = new Date();
|
||||
const timestamp = `gps-${date.getFullYear()}-${String(date.getMonth()+1).padStart(2,'0')}-${String(date.getDate()).padStart(2,'0')}-${String(date.getHours()).padStart(2,'0')}_${String(date.getMinutes()).padStart(2,'0')}_${String(date.getSeconds()).padStart(2,'0')}.txt`;
|
||||
const filePath = path.join(gpsFilePath, timestamp);
|
||||
|
||||
const logData = `${date} - Fetching new data...\n`;
|
||||
writeToLog('fetch_log.txt', logData);
|
||||
|
||||
const response = await axios.get(url);
|
||||
if (response.status === 200) {
|
||||
fs.writeFileSync(filePath, response.data, 'utf8');
|
||||
console.log("Fetch completed.");
|
||||
writeToLog('fetch_log.txt', `${date} - Fetching completed!\n`);
|
||||
} else {
|
||||
writeToLog('errors_log.txt', `${date} - Fetching failed. Got: ${response.status}\n`);
|
||||
}
|
||||
|
||||
deleteOldFiles();
|
||||
} catch (error) {
|
||||
const date = new Date();
|
||||
writeToLog('errors_log.txt', `${date} - Error fetching data: ${error.message}\n`);
|
||||
}
|
||||
}
|
||||
|
||||
function writeToLog(logfile, logdata) {
|
||||
const realLogFile = path.join(logFilePath, logfile);
|
||||
const dir = path.dirname(realLogFile);
|
||||
if (!fs.existsSync(dir)) {
|
||||
fs.mkdirSync(dir, { recursive: true });
|
||||
}
|
||||
if (!fs.existsSync(realLogFile)) {
|
||||
fs.writeFileSync(realLogFile, '', 'utf8');
|
||||
}
|
||||
fs.appendFile(realLogFile, logdata, 'utf8', (err) => {
|
||||
if (err) {
|
||||
console.error('Error writing to file:', err);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
setInterval(fetchAndSaveData, fetchInterval);
|
||||
fetchAndSaveData();
|
Reference in New Issue
Block a user