News: Aufbewahrung, Datenschutz-Abschnitt und Leistungsbeschreibung (Entwurf)

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

server/services/retention.js

@@ -2,6 +2,8 @@ import { rm } from 'node:fs/promises'
 import path from 'node:path'
 import { config } from '../config.js'
 import { deleteDocument, listDocuments, Query } from './appwriteAdmin.js'
+import { deleteNewsImage } from './newsImages.js'
+import { disable } from './siteFeatures.js'
 import { getStripe } from './stripeBilling.js'
 import { filesOf, STATUS } from './takeoverCredits.js'
 
@@ -16,6 +18,9 @@ import { filesOf, STATUS } from './takeoverCredits.js'
  *   (purgeExpiredUploads, sechs Monate nach der Entscheidung); hier werden sie nur gemeldet, falls die
  *   Bereinigung sie verpasst hat. Genehmigte Antraege sind Belege und bleiben acht Jahre ab Ende des
  *   Entscheidungsjahres (Abschnitt 9, § 147 AO); erst danach werden sie samt Nachweisen geloescht.
+ * - News-Pinnwand: Wird ein Kunde geloescht (Frist wie oben), loeschen wir auch seine News-Beitraege samt Fotos
+ *   (newsPosts, Bilddateien) und setzen seine Funktionen (portalFeatures) auf disabled. Der Plan fuehrt sie in
+ *   plan.news (nur Kunden mit Beitraegen oder noch nicht abgeschalteten Funktionen), damit plan.customers unveraendert bleibt.
  * Zeitrechnung in deutscher Zeit: Silvester 23:30 in Berlin ist noch das alte Jahr.
  * Nicht abgedeckt: Vertragsereignisse ohne customerId bzw. ohne zugehoeriges Abo-Dokument (Waisen) werden
  * weder gefunden noch geloescht; sie muessen von Hand geprueft werden. Listen werden nicht paginiert: wird eine
@@ -25,6 +30,8 @@ import { filesOf, STATUS } from './takeoverCredits.js'
 const SUBSCRIPTIONS = () => config.collections.subscriptions
 const EVENTS = () => config.collections.contractEvents
 const TAKEOVER = () => config.collections.takeoverCredits
+const NEWS_POSTS = () => config.collections.newsPosts
+const FEATURES = () => config.collections.portalFeatures
 
 export const RETENTION_YEARS = 3
 export const RECEIPT_YEARS = 8
@@ -101,6 +108,18 @@ export async function findDueDeletions(now = new Date(), { limit = LIST_LIMIT }
     customers.push({ customerId, lastEndAt, subscriptionIds: docs.map((d) => d.$id), eventIds: events.map((e) => e.$id) })
   }
 
+  const news = []
+  for (const { customerId } of customers) {
+    const posts = await list(NEWS_POSTS(), [Query.equal('customerId', customerId)])
+    const features = (await list(FEATURES(), [Query.equal('customerId', customerId)])).filter((f) => f.state !== 'disabled')
+    if (!posts.length && !features.length) continue
+    news.push({
+      customerId,
+      posts: posts.map((p) => ({ id: p.$id, projectId: p.projectId, imageId: p.imageId || null })),
+      featureIds: features.map((f) => f.$id),
+    })
+  }
+
   const takeover = []
   const rejectedCutoff = now.getTime() - config.takeover.rejectedRetentionDays * 86400000
   const rejected = await list(TAKEOVER(), [Query.equal('status', STATUS.rejected)])
@@ -126,7 +145,7 @@ export async function findDueDeletions(now = new Date(), { limit = LIST_LIMIT }
       reason: `genehmigt ${decided.slice(0, 10)}, Beleg-Aufbewahrung von acht Jahren ab Jahresende abgelaufen`,
     })
   }
-  return { customers, takeover, pending, skipped }
+  return { customers, news, takeover, pending, skipped }
 }
 
 const isGone = (err) => err?.status === 404
@@ -145,12 +164,13 @@ async function deleteQuietly(collection, id) {
  * Faellige Daten loeschen. Reihenfolge je Kunde: erst Stripe-Metadaten (Abo-ID steht noch im Plan), dann die
  * Appwrite-Dokumente. Lehnt Stripe ab (beendete Abos lassen sich oft nicht mehr aendern), steht das Abo in manual;
  * die Appwrite-Dokumente werden trotzdem geloescht, denn die Frist ist abgelaufen.
- * @returns {Promise<{ deleted: { subscriptions: number, contractEvents: number, takeover: number, stripeCleared: number },
+ * @returns {Promise<{ deleted: { subscriptions: number, contractEvents: number, takeover: number, stripeCleared: number,
+ *   newsPosts: number, newsImages: number, features: number },
  *   manual: { customerId: string, subscriptionId: string, reason: string }[],
  *   failed: { what: string, id: string, reason: string }[] }>}
  */
 export async function applyDeletions(plan) {
-  const deleted = { subscriptions: 0, contractEvents: 0, takeover: 0, stripeCleared: 0 }
+  const deleted = { subscriptions: 0, contractEvents: 0, takeover: 0, stripeCleared: 0, newsPosts: 0, newsImages: 0, features: 0 }
   const manual = []
   const failed = []
   const clear = Object.fromEntries(CONSENT_METADATA_KEYS.map((key) => [key, '']))
@@ -184,6 +204,28 @@ export async function applyDeletions(plan) {
     }
   }
 
+  for (const entry of plan.news || []) {
+    for (const post of entry.posts) {
+      // erst das Bild (Dokument bleibt bei Fehler und wird beim naechsten Lauf erneut gefunden), dann der Beitrag
+      if (post.imageId) {
+        const removed = await attempt('newsImages', post.imageId, async () => {
+          await deleteNewsImage(post.projectId, post.imageId)
+          return true
+        })
+        if (!removed) continue
+        deleted.newsImages += 1
+      }
+      if (await attempt('newsPosts', post.id, () => deleteQuietly(NEWS_POSTS(), post.id))) deleted.newsPosts += 1
+    }
+    for (const id of entry.featureIds) {
+      const off = await attempt('portalFeatures', id, async () => {
+        await disable(id, { adminNote: 'Abgeschaltet: Aufbewahrungsfrist abgelaufen' })
+        return true
+      })
+      if (off) deleted.features += 1
+    }
+  }
+
   for (const item of (plan.takeover || []).filter((t) => t.action === 'loeschen')) {
     const removed = await attempt('takeoverCredits', item.id, async () => {
       await rm(path.join(config.takeover.uploadDir, item.id), { recursive: true, force: true })
@@ -206,6 +248,10 @@ export function formatReport(plan, result = null) {
       `Kunde ${c.customerId}: letztes Abo endete am ${fmtDate(c.lastEndAt)}; ${c.subscriptionIds.length} Abo(s) (${c.subscriptionIds.join(', ')}), ${c.eventIds.length} Vertragsereignis(se)`
     )
   }
+  for (const n of plan.news || []) {
+    const images = n.posts.filter((p) => p.imageId).length
+    lines.push(`Kunde ${n.customerId}: ${n.posts.length} News-Beitrag/-Beiträge mit ${images} Foto(s) zu löschen, ${n.featureIds.length} Funktion(en) abzuschalten`)
+  }
   const del = plan.takeover.filter((t) => t.action === 'loeschen')
   const report = plan.takeover.filter((t) => t.action === 'melden')
   if (del.length) lines.push('', 'Übernahme-Anträge zu löschen:', ...del.map((t) => `  ${t.id}: ${t.reason}`))
@@ -220,7 +266,8 @@ export function formatReport(plan, result = null) {
     const d = result.deleted
     lines.push(
       '',
-      `Gelöscht: ${d.subscriptions} Abo(s), ${d.contractEvents} Vertragsereignis(se), ${d.takeover} Übernahme-Antrag/-Anträge; Stripe-Metadaten geleert bei ${d.stripeCleared} Abo(s).`
+      `Gelöscht: ${d.subscriptions} Abo(s), ${d.contractEvents} Vertragsereignis(se), ${d.takeover} Übernahme-Antrag/-Anträge; Stripe-Metadaten geleert bei ${d.stripeCleared} Abo(s).`,
+      `News: ${d.newsPosts} Beitrag/Beiträge und ${d.newsImages} Foto(s) gelöscht, ${d.features} Funktion(en) abgeschaltet.`
     )
     if (result.failed?.length) {
       lines.push('', 'Fehlgeschlagen (Lauf erneut starten):', ...result.failed.map((f) => `  ${f.what} ${f.id}: ${f.reason}`))