Sjoerd de Vries
fb3fc62b4b
Finding 3: fetch_error, not_found, mail_error and de onverwachte-fout branch loggen nu naam/url plus reden naar stderr; runCheck logt na elke run een regel met de tellingen per status, zodat een cron-run zichtbaar is in de container-logs. De recordCheckSuccess/recordCheckFailure-condities en alle return-waarden zijn ongewijzigd. Finding 4: server.js controleert bij het opstarten dat BASIC_AUTH_USER, BASIC_AUTH_PASS, SMTP_FROM en NOTIFY_EMAIL gezet zijn en stopt anders met exit code 1 in plaats van later opake 500's te geven. Finding 7: dotenv toegevoegd en als eerste regel in server.js geladen, zodat het gedocumenteerde `cp .env.example .env && npm start` echt werkt. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_013gwc3aCiyQxmCWQke8RvEz
72 lines
2.5 KiB
JavaScript
72 lines
2.5 KiB
JavaScript
// Leest een .env-bestand in voor lokale ontwikkeling; in productie komen de
|
|
// env vars van Coolify. quiet houdt de opstartlogging schoon.
|
|
require('dotenv').config({ quiet: true });
|
|
|
|
const path = require('node:path');
|
|
const {
|
|
openDb, listProducts, addProduct, deleteProduct,
|
|
recordCheckSuccess, recordCheckFailure,
|
|
} = require('./src/db');
|
|
const { fetchAndExtractPrice } = require('./src/scraper');
|
|
const { createTransport, sendPriceChangeEmail } = require('./src/mailer');
|
|
const { checkAllProducts } = require('./src/checkProducts');
|
|
const { start: startScheduler } = require('./src/scheduler');
|
|
const { createApp } = require('./src/app');
|
|
|
|
const REQUIRED_ENV = ['BASIC_AUTH_USER', 'BASIC_AUTH_PASS', 'SMTP_FROM', 'NOTIFY_EMAIL'];
|
|
const missing = REQUIRED_ENV.filter((name) => !process.env[name]);
|
|
if (missing.length > 0) {
|
|
console.error(`Ontbrekende verplichte environment variables: ${missing.join(', ')}`);
|
|
console.error('Zet ze (bijvoorbeeld in .env, zie .env.example) en start opnieuw.');
|
|
process.exit(1);
|
|
}
|
|
|
|
const PORT = process.env.PORT || 3000;
|
|
const DB_PATH = process.env.DB_PATH || path.join(__dirname, 'data', 'korting.db');
|
|
|
|
const db = openDb(DB_PATH);
|
|
const transport = createTransport(process.env);
|
|
|
|
function summarize(results) {
|
|
const counts = {};
|
|
for (const result of results) {
|
|
counts[result.status] = (counts[result.status] || 0) + 1;
|
|
}
|
|
const parts = Object.entries(counts).map(([status, count]) => `${status}=${count}`);
|
|
return parts.length > 0 ? parts.join(' ') : 'geen producten';
|
|
}
|
|
|
|
function runCheck() {
|
|
const products = listProducts(db);
|
|
const deps = {
|
|
fetchAndExtractPrice,
|
|
sendMail: (payload) => sendPriceChangeEmail(transport, {
|
|
from: process.env.SMTP_FROM,
|
|
to: process.env.NOTIFY_EMAIL,
|
|
...payload,
|
|
}),
|
|
recordCheckFailure: (id, status) => recordCheckFailure(db, id, status),
|
|
recordCheckSuccess: (id, data) => recordCheckSuccess(db, id, data),
|
|
now: () => new Date().toISOString(),
|
|
};
|
|
return checkAllProducts(products, deps).then((results) => {
|
|
console.log(`[check] ${products.length} product(en) gecontroleerd: ${summarize(results)}`);
|
|
return results;
|
|
});
|
|
}
|
|
|
|
startScheduler(runCheck);
|
|
|
|
const app = createApp({
|
|
listProducts: () => listProducts(db),
|
|
addProduct: (data) => addProduct(db, data),
|
|
deleteProduct: (id) => deleteProduct(db, id),
|
|
checkAllProducts: runCheck,
|
|
authUser: process.env.BASIC_AUTH_USER,
|
|
authPass: process.env.BASIC_AUTH_PASS,
|
|
});
|
|
|
|
app.listen(PORT, () => {
|
|
console.log(`Korting draait op poort ${PORT}`);
|
|
});
|