mirror of
https://github.com/badlogic/heissepreise.git
synced 2024-06-29 20:05:51 +02:00
45 lines
1.3 KiB
JavaScript
45 lines
1.3 KiB
JavaScript
const fs = require("fs");
|
|
const analysis = require("./analysis");
|
|
|
|
function copyItemsToSite(dataDir) {
|
|
fs.copyFileSync(`${dataDir}/latest-canonical.json`, `site/latest-canonical.json`);
|
|
const items = JSON.parse(fs.readFileSync(`${dataDir}/latest-canonical.json`));
|
|
for (const store of analysis.STORE_KEYS) {
|
|
const storeItems = items.filter(item => item.store === store);
|
|
fs.writeFileSync(`site/latest-canonical.${store}.compressed.json`, JSON.stringify(analysis.compress(storeItems)));
|
|
}
|
|
}
|
|
|
|
(async () => {
|
|
const dataDir = 'data';
|
|
|
|
if (!fs.existsSync(dataDir)) {
|
|
fs.mkdirSync(dataDir)
|
|
}
|
|
|
|
if (fs.existsSync(`${dataDir}/latest-canonical.json`)) {
|
|
copyItemsToSite(dataDir);
|
|
analysis.updateData(dataDir, (_newItems) => {
|
|
copyItemsToSite(dataDir);
|
|
});
|
|
} else {
|
|
await analysis.updateData(dataDir)
|
|
copyItemsToSite(dataDir);
|
|
}
|
|
setInterval(async () => {
|
|
items = await analysis.updateData(dataDir)
|
|
copyItemsToSite(dataDir);
|
|
}, 1000 * 60 * 60 * 24);
|
|
|
|
const express = require('express')
|
|
const compression = require('compression');
|
|
const app = express()
|
|
const port = process?.argv?.[2] ?? 3000
|
|
|
|
app.use(compression());
|
|
app.use(express.static('site'));
|
|
|
|
app.listen(port, () => {
|
|
console.log(`Example app listening on port ${port}`)
|
|
})
|
|
})(); |