Index: src/config/database.js =================================================================== --- src/config/database.js (revision 255e3d35582549cc0de8fa12acbc354d08fcbfdb) +++ src/config/database.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -188,4 +188,34 @@ // Tags van de originele post — getoond in de cirkel (comma-separated string). ensureColumn('remote_posts', 'tags', 'TEXT'); + + // Nieuwsbrief / mailinglijst (premium). Abonnees per site; double opt-in als SMTP + // er is (status 'pending' tot bevestigd), anders single opt-in ('confirmed'). + // 'unsub' = uitgeschreven. token = confirm/unsubscribe-sleutel (in de e-maillinks). + db.exec(` + CREATE TABLE IF NOT EXISTS subscribers ( + id TEXT PRIMARY KEY, + site_id TEXT NOT NULL, + email TEXT NOT NULL, + status TEXT NOT NULL DEFAULT 'pending', + source TEXT DEFAULT 'widget', + token TEXT NOT NULL, + created_at DATETIME DEFAULT CURRENT_TIMESTAMP, + confirmed_at DATETIME, + UNIQUE(site_id, email) + ); + CREATE INDEX IF NOT EXISTS idx_subscribers_site_status ON subscribers(site_id, status); + `); + + // Verstuurde nieuwsbrieven (historie + aantallen). + db.exec(` + CREATE TABLE IF NOT EXISTS newsletters ( + id TEXT PRIMARY KEY, + site_id TEXT NOT NULL, + subject TEXT NOT NULL, + body TEXT NOT NULL, + sent_at DATETIME DEFAULT CURRENT_TIMESTAMP, + recipient_count INTEGER DEFAULT 0 + ); + `); } Index: src/routes/admin-newsletter.js =================================================================== --- src/routes/admin-newsletter.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) +++ src/routes/admin-newsletter.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -0,0 +1,96 @@ +/** + * Nieuwsbrief — beheerkant (premium feature #1). + * + * GET /admin/newsletter -> opstellen + abonnee-aantallen + historie + * POST /admin/newsletter/send -> verstuur naar alle BEVESTIGDE abonnees (SMTP) + * + * Premium-gated + site-beheerder. Versturen vereist ingestelde SMTP; zonder SMTP + * worden aanmeldingen wél verzameld (single opt-in), alleen versturen kan dan niet. + */ + +import express from 'express'; +import db from '../config/database.js'; +import { v4 as uuid } from 'uuid'; +import { renderPage } from '../middleware/render.js'; +import { requireSiteManager } from '../middleware/auth.js'; +import { premiumUnlocked } from '../services/PatreonService.js'; +import { mailerConfigured, sendMail } from '../config/mailer.js'; +import { confirmedFor, counts } from '../services/SubscriberService.js'; + +const router = express.Router(); + +function esc(s) { + return String(s || '').replace(/[&<>"]/g, (c) => ({ '&': '&', '<': '<', '>': '>', '"': '"' }[c])); +} +function fullUrl(req, p) { + const base = (process.env.PUBLIC_BASE_URL || ('https://' + (req.get('host') || ''))).replace(/\/$/, ''); + return base + (res_siteUrlBase(req)) + p; +} +function res_siteUrlBase(req) { + return req.res && req.res.locals ? (req.res.locals.siteUrlBase || '') : ''; +} + +function premiumGate(req, res, next) { + if (!premiumUnlocked()) { + return res.status(403).send('Nieuwsbrief is premium — koppel Patreon in Beheer → Instellingen.'); + } + next(); +} + +function renderCompose(req, res, extra = {}) { + const site = res.locals.site; + const c = counts(site.id); + const history = db.prepare( + 'SELECT subject, sent_at, recipient_count FROM newsletters WHERE site_id = ? ORDER BY sent_at DESC LIMIT 10' + ).all(site.id); + const subscribeUrl = fullUrl(req, '/nieuwsbrief'); + renderPage(req, res, 'pages/admin-newsletter', { + pageTitle: 'Nieuwsbrief', + bodyClass: 'on-admin', + nlCounts: c, + nlHistory: history, + nlSubscribeUrl: subscribeUrl, + nlSmtp: mailerConfigured(), + ...extra, + }); +} + +router.get('/', requireSiteManager, premiumGate, (req, res) => { + if (!res.locals.site) return res.status(404).send('Geen site.'); + renderCompose(req, res); +}); + +router.post('/send', requireSiteManager, premiumGate, async (req, res) => { + const site = res.locals.site; + if (!site) return res.status(404).send('Geen site.'); + if (!mailerConfigured()) return renderCompose(req, res, { nlMsg: 'SMTP is niet ingesteld — versturen kan nog niet.', nlMsgKind: 'bad' }); + + const subject = (req.body.subject || '').trim(); + const body = (req.body.body || '').trim(); + if (!subject || !body) return renderCompose(req, res, { nlMsg: 'Onderwerp en bericht zijn verplicht.', nlMsgKind: 'bad', nlSubject: subject, nlBody: body }); + + const subs = confirmedFor(site.id); + const bodyHtml = esc(body).replace(/\n/g, '
'); + let sent = 0; + for (const s of subs) { + const unsub = fullUrl(req, '/nieuwsbrief/uitschrijven/' + s.token); + try { + await sendMail({ + to: s.email, + subject, + text: body + '\n\n—\nUitschrijven: ' + unsub, + html: '
' + bodyHtml + '
' + + '
' + + '

Je ontvangt dit omdat je je aanmeldde voor de nieuwsbrief van ' + + esc(site.title) + '. Uitschrijven.

', + }); + sent++; + } catch (e) { /* sla deze ontvanger over, ga door */ } + } + db.prepare('INSERT INTO newsletters (id, site_id, subject, body, recipient_count) VALUES (?,?,?,?,?)') + .run(uuid(), site.id, subject, body, sent); + + renderCompose(req, res, { nlMsg: 'Verstuurd naar ' + sent + ' van ' + subs.length + ' abonnee(s).', nlMsgKind: 'ok' }); +}); + +export default router; Index: src/routes/newsletter.js =================================================================== --- src/routes/newsletter.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) +++ src/routes/newsletter.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -0,0 +1,90 @@ +/** + * Nieuwsbrief — publieke kant (premium feature #1). + * + * GET /nieuwsbrief -> aanmeldformulier (premium; anders 404) + * POST /nieuwsbrief -> aanmelden (double opt-in als SMTP er is) + * GET /nieuwsbrief/bevestigen/:token -> opt-in bevestigen + * GET /nieuwsbrief/uitschrijven/:token -> uitschrijven (ALTIJD toegestaan) + * + * In hub-modus loopt dit via /user/:slug/nieuwsbrief (resolveSite zet siteUrlBase). + * Confirm-/unsub-links in de mail zijn absoluut (PUBLIC_BASE_URL + siteUrlBase). + */ + +import express from 'express'; +import { renderPage } from '../middleware/render.js'; +import { premiumUnlocked } from '../services/PatreonService.js'; +import { mailerConfigured, sendMail } from '../config/mailer.js'; +import { addSubscriber, confirm, unsubscribe } from '../services/SubscriberService.js'; + +const router = express.Router(); + +function esc(s) { + return String(s || '').replace(/[&<>"]/g, (c) => ({ '&': '&', '<': '<', '>': '>', '"': '"' }[c])); +} +function fullUrl(req, siteUrlBase, p) { + const base = (process.env.PUBLIC_BASE_URL || ('https://' + (req.get('host') || ''))).replace(/\/$/, ''); + return base + (siteUrlBase || '') + p; +} +function show(req, res, state, extra = {}) { + renderPage(req, res, 'pages/newsletter', { + pageTitle: 'Nieuwsbrief' + (res.locals.site ? ' — ' + res.locals.site.title : ''), + bodyClass: 'on-newsletter', + nlState: state, + ...extra, + }); +} + +router.get('/nieuwsbrief', (req, res, next) => { + if (!premiumUnlocked()) return next(); + if (!res.locals.site) return next(); + const fan = req.session && req.session.user; + const prefill = (fan && fan.email && fan.email.includes('@')) ? fan.email : ''; + show(req, res, 'form', { nlPrefill: prefill }); +}); + +router.post('/nieuwsbrief', async (req, res, next) => { + if (!premiumUnlocked()) return next(); + const site = res.locals.site; + if (!site) return next(); + const email = (req.body.email || '').trim(); + const doubleOptin = mailerConfigured(); + const r = addSubscriber(site.id, email, 'widget', { doubleOptin }); + if (!r.ok) return show(req, res, r.error === 'invalid_email' ? 'invalid' : 'error', { nlPrefill: email }); + + if (r.status === 'pending') { + // Double opt-in: stuur de bevestigingsmail. + const link = fullUrl(req, res.locals.siteUrlBase, '/nieuwsbrief/bevestigen/' + r.token); + const unsub = fullUrl(req, res.locals.siteUrlBase, '/nieuwsbrief/uitschrijven/' + r.token); + try { + await sendMail({ + to: email, + subject: 'Bevestig je inschrijving — ' + (site.title || 'nieuwsbrief'), + text: 'Bevestig je inschrijving op de nieuwsbrief van ' + (site.title || '') + ':\n' + link + + '\n\nNiet aangevraagd? Negeer deze mail. Uitschrijven: ' + unsub, + html: '

Bevestig je inschrijving op de nieuwsbrief van ' + esc(site.title) + ':

' + + '

Inschrijving bevestigen

' + + '

Niet aangevraagd? Negeer deze mail. ' + + 'Uitschrijven

', + }); + } catch (e) { + return show(req, res, 'smtperror'); + } + return show(req, res, 'check', { nlEmail: email }); + } + return show(req, res, 'done', { nlEmail: email }); +}); + +router.get('/nieuwsbrief/bevestigen/:token', (req, res, next) => { + if (!premiumUnlocked()) return next(); + const ok = confirm(req.params.token); + show(req, res, ok ? 'confirmed' : 'badtoken'); +}); + +// Uitschrijven mag altijd (ook als de premium-laag later uit zou gaan): een abonnee +// moet zich altijd kunnen afmelden. Niet premium-gated. +router.get('/nieuwsbrief/uitschrijven/:token', (req, res) => { + const ok = unsubscribe(req.params.token); + show(req, res, ok ? 'unsubbed' : 'badtoken'); +}); + +export default router; Index: src/server.js =================================================================== --- src/server.js (revision 255e3d35582549cc0de8fa12acbc354d08fcbfdb) +++ src/server.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -53,4 +53,6 @@ import circleRoutes from './routes/circle.js'; import epkRoutes from './routes/epk.js'; +import newsletterRoutes from './routes/newsletter.js'; +import adminNewsletterRoutes from './routes/admin-newsletter.js'; if (!process.env.SESSION_SECRET) { @@ -252,4 +254,5 @@ app.use('/admin/patreon', adminPatreonRoutes); app.use('/admin/stats', adminStatsRoutes); +app.use('/admin/newsletter', adminNewsletterRoutes); app.use('/admin', adminRoutes); app.use('/prutter', prutterRoutes); @@ -267,4 +270,5 @@ app.use('/', circleRoutes); // /cirkel-feed (solo/hub: next() -> postsRoutes) app.use('/', epkRoutes); // /pers perskit (premium; niet-premium: next() -> 404) +app.use('/', newsletterRoutes); // /nieuwsbrief in/uitschrijven (premium; niet-premium: next()) app.use('/', postsRoutes); Index: src/services/SubscriberService.js =================================================================== --- src/services/SubscriberService.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) +++ src/services/SubscriberService.js (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -0,0 +1,79 @@ +/** + * SubscriberService — nieuwsbrief-abonnees per site (premium feature #1). + * + * Double opt-in als SMTP er is (status 'pending' → 'confirmed' via confirm-link), + * anders single opt-in ('confirmed' meteen). Elke abonnee heeft een token dat zowel + * de confirm- als de unsubscribe-link draagt. Hergebruikt door #2 (download-voor- + * email) en #8 (notify-me) als gedeelde abonnee-opslag. + */ + +import crypto from 'crypto'; +import db from '../config/database.js'; +import { v4 as uuid } from 'uuid'; + +const EMAIL_RE = /^[^\s@]+@[^\s@]+\.[^\s@]+$/; + +export function isValidEmail(email) { + return typeof email === 'string' && email.length <= 254 && EMAIL_RE.test(email.trim()); +} + +function newToken() { + return crypto.randomBytes(24).toString('hex'); +} + +/** + * Voeg een abonnee toe (of heractiveer een uitgeschreven/bestaande). + * @returns {{ok:boolean, status?:string, token?:string, created?:boolean, error?:string}} + * status 'pending' → er moet nog bevestigd worden (stuur confirm-mail) + * status 'confirmed'→ direct actief (single opt-in) + */ +export function addSubscriber(siteId, email, source = 'widget', { doubleOptin = false } = {}) { + email = (email || '').trim().toLowerCase(); + if (!siteId) return { ok: false, error: 'no_site' }; + if (!isValidEmail(email)) return { ok: false, error: 'invalid_email' }; + + const existing = db.prepare('SELECT * FROM subscribers WHERE site_id = ? AND email = ?').get(siteId, email); + const status = doubleOptin ? 'pending' : 'confirmed'; + + if (existing) { + // Al actief → niets te doen (idempotent, geen dubbele mail). + if (existing.status === 'confirmed') return { ok: true, status: 'confirmed', token: existing.token, created: false }; + // Pending of uitgeschreven → opnieuw uitnodigen/activeren met een verse token. + const token = newToken(); + db.prepare("UPDATE subscribers SET status = ?, token = ?, source = ?, confirmed_at = CASE WHEN ? = 'confirmed' THEN CURRENT_TIMESTAMP ELSE NULL END WHERE id = ?") + .run(status, token, source, status, existing.id); + return { ok: true, status, token, created: false }; + } + + const token = newToken(); + db.prepare( + "INSERT INTO subscribers (id, site_id, email, status, source, token, confirmed_at) VALUES (?,?,?,?,?,?, CASE WHEN ? = 'confirmed' THEN CURRENT_TIMESTAMP ELSE NULL END)" + ).run(uuid(), siteId, email, status, source, token, status); + return { ok: true, status, token, created: true }; +} + +export function confirm(token) { + if (!token) return false; + const row = db.prepare('SELECT id FROM subscribers WHERE token = ?').get(token); + if (!row) return false; + db.prepare("UPDATE subscribers SET status = 'confirmed', confirmed_at = CURRENT_TIMESTAMP WHERE id = ?").run(row.id); + return true; +} + +export function unsubscribe(token) { + if (!token) return false; + const row = db.prepare('SELECT id FROM subscribers WHERE token = ?').get(token); + if (!row) return false; + db.prepare("UPDATE subscribers SET status = 'unsub' WHERE id = ?").run(row.id); + return true; +} + +/** Bevestigde abonnees (email + token) voor een site — voor het versturen. */ +export function confirmedFor(siteId) { + return db.prepare("SELECT email, token FROM subscribers WHERE site_id = ? AND status = 'confirmed'").all(siteId); +} + +export function counts(siteId) { + const c = (st) => db.prepare('SELECT COUNT(*) AS n FROM subscribers WHERE site_id = ? AND status = ?').get(siteId, st).n; + return { confirmed: c('confirmed'), pending: c('pending'), unsub: c('unsub') }; +} Index: src/views/pages/admin-newsletter.ejs =================================================================== --- src/views/pages/admin-newsletter.ejs (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) +++ src/views/pages/admin-newsletter.ejs (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -0,0 +1,66 @@ +<% + var c = (typeof nlCounts !== 'undefined') ? nlCounts : { confirmed:0, pending:0, unsub:0 }; + var msg = (typeof nlMsg !== 'undefined') ? nlMsg : ''; + var msgKind = (typeof nlMsgKind !== 'undefined') ? nlMsgKind : ''; + var hist = (typeof nlHistory !== 'undefined') ? nlHistory : []; + var smtp = (typeof nlSmtp !== 'undefined') ? nlSmtp : false; +%> +
+

Nieuwsbrief

+ + <% if (msg) { %>
<%= msg %>
<% } %> + +
+
<%= c.confirmed %>bevestigd
+
<%= c.pending %>in afwachting
+
<%= c.unsub %>uitgeschreven
+
+ + <% if (!smtp) { %> +
⚠ SMTP is nog niet ingesteld. Aanmeldingen worden wél verzameld, maar versturen kan pas als je SMTP-gegevens invult (SMTP_HOST / SMTP_PORT / SMTP_USER / SMTP_PASS / SMTP_FROM in .env).
+ <% } %> + +

Aanmeldlink om te delen: <%= nlSubscribeUrl %>

+ +
+ + + +
+ + <% if (hist.length) { %> +

Verstuurd

+ + <% } %> +
+ + Index: src/views/pages/admin.ejs =================================================================== --- src/views/pages/admin.ejs (revision 255e3d35582549cc0de8fa12acbc354d08fcbfdb) +++ src/views/pages/admin.ejs (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -33,4 +33,6 @@ <% if (typeof premiumUnlocked === 'undefined' || premiumUnlocked) { %> 📊 Statistieken + ✉️ Nieuwsbrief + <% if (tenancy !== 'hub' && primarySite) { %>📰 Perskit<% } %> <% } %> 🔄 Updates Index: src/views/pages/newsletter.ejs =================================================================== --- src/views/pages/newsletter.ejs (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) +++ src/views/pages/newsletter.ejs (revision 2e247e4c529b09d55619100d5bd4e50de5a95e54) @@ -0,0 +1,54 @@ +<% + var _site = site || {}; + var _title = _site.title || 'deze artiest'; + var st = (typeof nlState !== 'undefined') ? nlState : 'form'; +%> +
+
+ <% if (st === 'form') { %> +

Blijf op de hoogte

+

Schrijf je in voor de nieuwsbrief van <%= _title %> — nieuwe muziek, shows en updates, rechtstreeks in je inbox. Uitschrijven kan altijd met één klik.

+
+ + +
+ <% } else if (st === 'check') { %> +

Bijna klaar ✉

+

We hebben een bevestigingsmail gestuurd naar <%= (typeof nlEmail!=='undefined')?nlEmail:'je adres' %>. Klik op de link in die mail om je inschrijving te bevestigen.

+ <% } else if (st === 'done') { %> +

Je bent ingeschreven ✓

+

Bedankt — je staat op de lijst van <%= _title %>.

+ <% } else if (st === 'confirmed') { %> +

Inschrijving bevestigd ✓

+

Top! Je ontvangt voortaan de nieuwsbrief van <%= _title %>.

+ <% } else if (st === 'unsubbed') { %> +

Uitgeschreven

+

Je bent afgemeld. Je ontvangt geen nieuwsbrieven meer. Van gedachten veranderd? Je kunt je altijd opnieuw inschrijven.

+ <% } else if (st === 'invalid') { %> +

Ongeldig e-mailadres

+

Controleer je adres en probeer 't opnieuw.

+

← Terug

+ <% } else if (st === 'smtperror') { %> +

Even niet gelukt

+

De bevestigingsmail kon niet verstuurd worden. Probeer 't later nog eens.

+ <% } else if (st === 'badtoken') { %> +

Link ongeldig of verlopen

+

Deze link werkt niet meer. Schrijf je eventueel opnieuw in.

+

Naar inschrijven

+ <% } else { %> +

Er ging iets mis

+

Probeer 't later nog eens.

+ <% } %> +
+
+ +