source: Klonkt/src/routes/admin-sites.js@ 6401681

/**
 * Admin: Site management — Phase E.
 *
 * GET  /admin/sites             -> list all sites
 * GET  /admin/sites/new         -> create form
 * POST /admin/sites/create      -> insert + redirect to edit
 * GET  /admin/sites/:slug/edit  -> edit form
 * POST /admin/sites/:slug/save  -> update
 * POST /admin/sites/:slug/delete-> delete (refuses if site has posts)
 *
 * God-only (requireGod middleware). Slug is immutable after create — too
 * many things hang off it (URLs, manifest scope, federation). If you really
 * need to rename: delete + re-create.
 */

import express from 'express';
import path from 'path';
import fs from 'fs';
import multer from 'multer';
import { v4 as uuid } from 'uuid';
import db from '../config/database.js';
import { renderPage } from '../middleware/render.js';
import { requireGod, requireAuth, requireSiteManagerBySlug } from '../middleware/auth.js';
import ThemeService from '../services/ThemeService.js';
import { listPlatforms, PLATFORMS } from '../services/PlatformIcons.js';
import { toWebp } from '../services/ImageWebpService.js';
import { mediaDir } from '../config/paths.js';
import AP from '../services/ActivityPubService.js';
import MusicBrainz from '../services/MusicBrainzService.js';


// Profile photos share the avatar directory with user avatars — same physical
// folder, same URL prefix. Filenames are uuid-prefixed so site photos and
// user avatars never collide.
const PHOTO_DIR = mediaDir('AVATAR_PATH', 'avatars');
fs.mkdirSync(PHOTO_DIR, { recursive: true });

const ALLOWED_PHOTO_EXT = new Set(['.jpg', '.jpeg', '.png', '.webp', '.gif']);
const MAX_PHOTO_BYTES = 5 * 1024 * 1024;
const photoUpload = multer({
  storage: multer.diskStorage({
    destination: (req, file, cb) => cb(null, PHOTO_DIR),
    filename: (req, file, cb) => {
      const ext = path.extname(file.originalname || '').toLowerCase() || '.jpg';
      cb(null, `site-${uuid()}${ext}`);
    },
  }),
  limits: { fileSize: MAX_PHOTO_BYTES },
  fileFilter: (req, file, cb) => {
    const ext = path.extname(file.originalname || '').toLowerCase();
    if (!ALLOWED_PHOTO_EXT.has(ext)) {
      return cb(new Error('Alleen JPG/PNG/WebP/GIF toegestaan'));
    }
    cb(null, true);
  },
});

/** Coerce req.body fields into the JSON profile_links array. */
function buildProfileLinks(body) {
  const platforms = body.profile_link_platform || [];
  const urls = body.profile_link_url || [];
  const arr = [];
  const platformsArr = Array.isArray(platforms) ? platforms : [platforms];
  const urlsArr      = Array.isArray(urls)      ? urls      : [urls];
  for (let i = 0; i < platformsArr.length; i++) {
    const p = (platformsArr[i] || '').toString().trim();
    const u = (urlsArr[i] || '').toString().trim();
    if (!p || !u) continue;
    if (!PLATFORMS[p]) continue;
    if (!/^https?:\/\//i.test(u) && p !== 'email') continue;
    if (p === 'email' && !/^mailto:|^[^\s@]+@[^\s@]+$/i.test(u)) continue;
    arr.push({ platform: p, url: u });
  }
  return arr.length ? JSON.stringify(arr) : null;
}

/**
 * FEP-7628 aliases (alsoKnownAs): one former identity per line, as an actor
 * URL or an @user@host handle. Handles resolve via WebFinger AT SAVE TIME on
 * purpose — a typo'd alias that silently lands on the actor would make a later
 * Move fail at the old server with no hint why. Throws the offending line.
 */
async function parseApAliases(raw, ownActorUri) {
  const lines = String(raw || '').split(/\r?\n/).map((s) => s.trim()).filter(Boolean);
  if (lines.length > 5) throw new Error(lines[5] + ' (max 5)');
  const out = [];
  for (const line of lines) {
    let uri = null;
    if (/^https?:\/\//i.test(line)) uri = line;
    else if (line.includes('@')) uri = await AP.webfingerResolve(line).catch(() => null);
    if (!uri) throw new Error(line);
    if (uri === ownActorUri) continue; // claiming yourself adds nothing
    if (!out.includes(uri)) out.push(uri);
  }
  return out;
}

const router = express.Router();

// ==================== UPLOAD PROFILE PHOTO (JSON) ====================
// POST /admin/sites/upload-photo  → { ok: true, url: '/media/avatars/<filename>' }
// Used by the admin-site-edit form's photo picker. The form itself still
// holds the URL string in `profile_photo` — this endpoint just stores the
// file and hands back a URL that the form can paste into the input field.
router.post('/upload-photo', requireAuth, (req, res) => {
  photoUpload.single('photo')(req, res, (err) => {
    if (err) return res.status(400).json({ ok: false, error: err.message });
    if (!req.file) return res.status(400).json({ ok: false, error: 'Geen bestand ontvangen' });
    res.json({
      ok: true,
      url: `/media/avatars/${toWebp(req.file)}`,
      size: req.file.size,
      mime: req.file.mimetype,
    });
  });
});

const RESERVED_SITE_SLUGS = new Set([
  'auth', 'admin', 'login', 'register', 'logout', 'archive', 'search',
  'account', 'sites', 'comments', 'posts', 'media', 'audio',
  'forum', 'tag', 'user', 'users', 'artiesten', 'leden', 'feed.xml', 'atom.xml', 'sitemap.xml',
  'manifest.webmanifest', 'sw.js', 'favicon.ico', 'favicon.svg', 'assets',
  'paid', 'push', 'guardian',
]);

function siteEditableFields() {
  return {
    title: '',
    description: '',
    tagline: '',
    language: 'nl',
    palette: 'klonkt',
    accent: '#e8b04b',
    profile_photo: '',
    profile_enabled: 1,
    profile_name: '',
    profile_bio: '',
    is_public: 1,
    robots_index: 1,
    require_login_to_comment: 1,
    enable_audio_player: 1,
    comments_moderation_mode: 'moderate',
    feed_view_default: 'grid',
    feed_view_switch: 1,
    show_search: 1,
    show_archive_link: 1,
    title_template: '{title} — {site}',
    twitter: '',
    canonical: '',
    google_verification: '',
    bing_verification: '',
    pinterest_verification: '',
    yandex_verification: '',
    custom_css: '',
    custom_head_html: '',
    custom_foot_html: '',
  };
}

/** Valid user-id for owner assignment, or null if empty/unknown. */
function validOwnerId(raw) {
  const id = (raw || '').toString().trim();
  if (!id) return null;
  return db.prepare('SELECT 1 FROM users WHERE id = ?').get(id) ? id : null;
}

/** Grant a user admin rights on a site (idempotent upsert). */
function grantSiteAdmin(siteId, userId) {
  db.prepare(`
    INSERT INTO site_members (site_id, user_id, role) VALUES (?, ?, 'admin')
    ON CONFLICT(site_id, user_id) DO UPDATE SET role = 'admin'
  `).run(siteId, userId);
}

/** Candidate owners for the owner selector field (god-only). */
function listOwnerCandidates() {
  return db.prepare('SELECT id, username, role FROM users ORDER BY username').all();
}

// ==================== LIST ====================
router.get('/', requireGod, (req, res) => {
  const sites = db.prepare(`
    SELECT s.id, s.slug, s.title, s.description, s.created_at,
           s.is_public, s.robots_index, s.is_primary,
           u.username AS owner_username,
           (SELECT COUNT(*) FROM posts WHERE site_id = s.id) AS post_count
    FROM sites s LEFT JOIN users u ON u.id = s.owner_id
    ORDER BY s.is_primary DESC, s.created_at DESC
  `).all();

  renderPage(req, res, 'pages/admin-sites', {
    pageTitleKey: 'admin.t_sites',
    bodyClass: 'on-admin',
    sites,
    success: req.query.success || null,
    error: req.query.error || null,
  });
});

// ==================== NEW (form) ====================
router.get('/new', requireGod, (req, res) => {
  renderPage(req, res, 'pages/admin-site-edit', {
    pageJs: 'admin-site-edit',
    pageTitleKey: 'admin.t_newsite',
    bodyClass: 'on-admin',
    isNew: true,
    // ?owner=<id> (from the users page: "give this user a Klonkt") is
    // pre-selected; otherwise defaults to the creating god.
    site: { slug: '', owner_id: validOwnerId(req.query.owner) || req.session.user.id, ...siteEditableFields() },
    users: listOwnerCandidates(),
    palettes: ThemeService.listPalettes(),
    accents: ThemeService.listAccents(),
    platforms: listPlatforms(),
    parsedLinks: [],
    apAliases: '',
    error: null,
  });
});

// ==================== CREATE ====================
router.post('/create', requireGod, (req, res) => {
  const slug = (req.body.slug || '').toString().toLowerCase().trim();
  if (!/^[a-z0-9_-]{2,40}$/.test(slug)) {
    return res.redirect('/admin/sites/new?error=' + encodeURIComponent('Slug: 2-40 chars, letters/numbers/underscore/dash'));
  }
  if (RESERVED_SITE_SLUGS.has(slug)) {
    return res.redirect('/admin/sites/new?error=' + encodeURIComponent('That slug is reserved'));
  }
  const existing = db.prepare('SELECT id FROM sites WHERE slug = ?').get(slug);
  if (existing) {
    return res.redirect('/admin/sites/new?error=' + encodeURIComponent('Slug already taken'));
  }

  const f = { ...siteEditableFields(), ...req.body };

  // Owner: god may assign the site to a DIFFERENT user — this is the core of
  // hub mode (each user their own self-managed Klonkt). Empty or invalid → the
  // creating god themselves.
  const ownerId = validOwnerId(req.body.owner_id) || req.session.user.id;

  const siteId = uuid();
  db.prepare(`
    INSERT INTO sites (
      id, slug, title, description, tagline, owner_id,
      language, palette, accent, profile_photo,
      is_public, robots_index, require_login_to_comment, enable_audio_player,
      feed_view_default
    ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
  `).run(
    siteId, slug,
    (f.title || slug).slice(0, 200),
    (f.description || '').slice(0, 500),
    (f.tagline || '').slice(0, 200),
    ownerId,
    f.language || 'nl',
    f.palette || 'klonkt',
    ThemeService.validateAccent(f.accent) || '#e8b04b',
    f.profile_photo || null,
    f.is_public ? 1 : 0,
    f.robots_index ? 1 : 0,
    f.require_login_to_comment ? 1 : 0,
    (f.enable_audio_player !== undefined ? (f.enable_audio_player ? 1 : 0) : 1),
    f.feed_view_default === 'timeline' ? 'timeline' : 'grid',
  );

  // The OWNER (not necessarily the creator) gets a site_members admin row → this
  // lets them pass canAdminSite + requireSiteManager gates to manage their site.
  grantSiteAdmin(siteId, ownerId);

  res.redirect(`/admin/sites/${slug}/edit?success=` + encodeURIComponent('Site aangemaakt'));
});

// ==================== EDIT (form) ====================
router.get('/:slug/edit', requireSiteManagerBySlug, (req, res) => {
  const site = db.prepare('SELECT * FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.redirect('/admin/sites?error=Not+found');

  let parsedLinks = [];
  if (site.profile_links) {
    try { parsedLinks = JSON.parse(site.profile_links) || []; } catch {}
  }

  let apAliases = '';
  try { apAliases = (JSON.parse(site.ap_aliases || '[]') || []).join('\n'); } catch { /* show empty on malformed */ }

  renderPage(req, res, 'pages/admin-site-edit', {
    pageJs: 'admin-site-edit',
    pageTitleKey: 'admin.t_editsite', pageTitleVars: { title: site.title },
    bodyClass: 'on-admin',
    isNew: false,
    site,
    users: listOwnerCandidates(),
    palettes: ThemeService.listPalettes(),
    accents: ThemeService.listAccents(),
    platforms: listPlatforms(),
    parsedLinks,
    apAliases,
    success: req.query.success || null,
    error: req.query.error || null,
  });
});

// ==================== MOVE (FEP-7628, slice 2) ====================
// The explicit departure: announce to every follower that this account now
// lives elsewhere. Deliberately its own POST with its own button, never a
// side effect of Save: a Move is a door you close behind you.
router.post('/:slug/move', requireSiteManagerBySlug, async (req, res) => {
  const site = db.prepare('SELECT * FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.redirect('/admin/sites?error=Not+found');
  const r = await AP.moveAccount(site, req.body.move_target || '');
  if (r && r.ok) {
    return res.redirect(`/admin/sites/${req.params.slug}/edit?success=` + encodeURIComponent(`Verhuizing aangekondigd naar ${r.target} (${r.inboxes} inboxen).`));
  }
  const msg = {
    guarded_account: 'Dit account heeft guardians; verhuizen kan pas als de guardianship mee kan (shaer-tge).',
    no_backreference: 'Het nieuwe profiel claimt dit account niet in zijn aliassen. Zet daar eerst dit adres als alias.',
    not_found: 'Nieuw adres niet gevonden. Gebruik @naam@server of een actor-URL.',
    unreachable: 'Het nieuwe profiel is niet bereikbaar.',
    self: 'Dat is dit account zelf.',
  }[r && r.error] || 'Verhuizen mislukte; probeer het opnieuw.';
  res.redirect(`/admin/sites/${req.params.slug}/edit?error=` + encodeURIComponent(msg));
});

// ==================== SAVE ====================
/**
 * "Ben jij dit?" -- kandidaten uit MusicBrainz (shaer-mbz).
 *
 * De zoekopdracht draait HIER en niet in de browser: MusicBrainz staat een
 * verzoek per seconde toe per APPLICATIE, en dat is alleen af te dwingen als
 * alles langs een plek gaat. Bovendien eisen ze een User-Agent met contact, en
 * die kan een browser niet zetten.
 *
 * Wij kiezen NIET. Ook niet als er precies een treffer is: een verkeerd geraden
 * MBID zet jouw naam onder andermans werk.
 */
router.get('/:slug/api/musicbrainz', requireSiteManagerBySlug, async (req, res) => {
  const site = db.prepare('SELECT title, mb_artist_id, mb_artist_name FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.status(404).json({ error: 'no_site' });
  const q = String(req.query.q || site.title || '').trim();
  if (!q) return res.json({ ok: true, q: '', kandidaten: [] });
  res.json({ ok: true, q, kandidaten: await MusicBrainz.zoekArtiesten(q) });
});

router.post('/:slug/save', requireSiteManagerBySlug, async (req, res) => {
  const site = db.prepare('SELECT id, ap_aliases FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.redirect('/admin/sites?error=Not+found');

  const f = req.body;
  const feedViewDef = f.feed_view_default === 'grid' ? 'grid' : 'timeline';
  const profileLinksJson = buildProfileLinks(f);

  // FEP-7628 aliases — validated/resolved before anything is written.
  const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
  let apAliasesJson = null;
  try {
    const arr = await parseApAliases(f.ap_aliases, AP.actorId(base, req.params.slug));
    apAliasesJson = arr.length ? JSON.stringify(arr) : null;
  } catch (e) {
    return res.redirect(`/admin/sites/${req.params.slug}/edit?error=` + encodeURIComponent(`Alias niet herkend of niet vindbaar: ${e.message}`));
  }

  // theme_override: only accept the three legal values. Empty string means
  // "Auto" — defer to user's prefers-color-scheme on first paint.
  const themeOverride = ['light', 'dark'].includes(f.theme_override) ? f.theme_override : '';

  // accent: only accept colors from the curated ACCENTS list. Falls back to
  // the orange default if the submitted value isn't recognised.
  // De MusicBrainz-koppeling (shaer-mbz). Alleen een echte MBID komt de kolom
  // in: zonder deze zeef sluipt er een hele URL of een handle in het veld dat
  // straks naar buiten gaat. Leeg is een geldige keuze -- dat is ontkoppelen.
  const mbRuw = String(f.mb_artist_id || '').trim().toLowerCase();
  const mbArtistId = MusicBrainz.isMbid(mbRuw) ? mbRuw : null;

  const accent = ThemeService.validateAccent(f.accent) || '#e8b04b';

  db.prepare(`
    UPDATE sites SET
      title = ?, description = ?, tagline = ?, language = ?,
      palette = ?, accent = ?, theme_override = ?, profile_photo = ?,
      profile_enabled = ?,
      profile_links = ?,
      ap_aliases = ?,
      mb_artist_id = ?, mb_artist_name = ?,
      is_public = ?, robots_index = ?, require_login_to_comment = ?,
      enable_audio_player = ?,
      feed_view_default = ?, feed_view_switch = ?,
      show_search = ?, show_archive_link = ?,
      custom_css = ?, custom_head_html = ?, custom_foot_html = ?,
      updated_at = CURRENT_TIMESTAMP
    WHERE id = ?
  `).run(
    (f.title || '').slice(0, 200),
    (f.description || '').slice(0, 500),
    (f.tagline || '').slice(0, 200),
    f.language || 'nl',
    f.palette || 'klonkt',
    accent,
    themeOverride,
    f.profile_photo || null,
    f.profile_enabled ? 1 : 0,
    profileLinksJson,
    apAliasesJson,
    mbArtistId,
    mbArtistId ? (String(f.mb_artist_name || '').trim().slice(0, 200) || null) : null,
    f.is_public ? 1 : 0,
    f.robots_index ? 1 : 0,
    f.require_login_to_comment ? 1 : 0,
    f.enable_audio_player ? 1 : 0,
    feedViewDef,
    f.feed_view_switch ? 1 : 0,
    f.show_search ? 1 : 0,
    f.show_archive_link ? 1 : 0,
    f.custom_css      || null,
    f.custom_head_html || null,
    f.custom_foot_html || null,
    site.id,
  );

  // (Re)assign owner — god ONLY. A site-owner editing their own site cannot
  // change the owner (the field is not shown to non-god users either).
  if (req.session.user.role === 'god') {
    const newOwner = validOwnerId(req.body.owner_id);
    if (newOwner) {
      db.prepare('UPDATE sites SET owner_id = ? WHERE id = ?').run(newOwner, site.id);
      grantSiteAdmin(site.id, newOwner);
    }
  }

  // Alias change → broadcast an actor Update so remote caches refresh. The old
  // server re-fetches the actor live during a Move anyway; this is freshness,
  // not correctness, hence best-effort.
  if ((site.ap_aliases || null) !== apAliasesJson) {
    try {
      const fresh = db.prepare('SELECT * FROM sites WHERE id = ?').get(site.id);
      AP.deliverActorUpdate(fresh).catch(() => {});
    } catch { /* never blocks the save */ }
  }

  res.redirect(`/admin/sites/${req.params.slug}/edit?success=` + encodeURIComponent('Opgeslagen'));
});

// ==================== MAKE PRIMARY ====================
// God chooses which site is the primary/main site (the label/company site in hub;
// in solo mode: the one site). Exactly one site is primary → clear all, then set this one.
router.post('/:slug/make-primary', requireGod, (req, res) => {
  const site = db.prepare('SELECT id FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.redirect('/admin/sites?error=Niet+gevonden');
  db.transaction(() => {
    db.prepare('UPDATE sites SET is_primary = 0').run();
    db.prepare('UPDATE sites SET is_primary = 1 WHERE id = ?').run(site.id);
  })();
  res.redirect('/admin/sites?success=' + encodeURIComponent('Primaire site bijgewerkt'));
});

// ==================== DELETE ====================
router.post('/:slug/delete', requireGod, (req, res) => {
  const site = db.prepare('SELECT id FROM sites WHERE slug = ?').get(req.params.slug);
  if (!site) return res.redirect('/admin/sites?error=Not+found');

  const postCount = db.prepare('SELECT COUNT(*) AS c FROM posts WHERE site_id = ?').get(site.id).c;
  if (postCount > 0) {
    return res.redirect('/admin/sites?error=' + encodeURIComponent(`Cannot delete: site has ${postCount} post(s). Delete posts first.`));
  }

  // Clean up site_members and audio_tracks (no posts to worry about).
  db.prepare('DELETE FROM site_members WHERE site_id = ?').run(site.id);
  db.prepare('DELETE FROM audio_tracks WHERE site_id = ?').run(site.id);
  db.prepare('DELETE FROM sites WHERE id = ?').run(site.id);

  res.redirect('/admin/sites?success=' + encodeURIComponent('Site deleted'));
});

export default router;