diff --git a/server/services/aboFunktionenAbgleich.js b/server/services/aboFunktionenAbgleich.js index 16f37ea..714335e 100644 --- a/server/services/aboFunktionenAbgleich.js +++ b/server/services/aboFunktionenAbgleich.js @@ -3,11 +3,15 @@ import { ENTHALTEN_IN, aboProdukt } from './aboFunktionen.js' import { ohneAboBisher } from './aboAufbauphase.js' import { istAboModell } from './aboModell.js' import { meldeBeendet } from './aboFunktionenMeldung.js' -import { Query, getDocument, listAllDocuments, updateDocument } from './appwriteAdmin.js' +import { Query, deleteDocument, getDocument, listAllDocuments, updateDocument } from './appwriteAdmin.js' import { withLocks } from './keyedLock.js' +import { deleteNewsImage } from './newsImages.js' +import { listPosts } from './newsPosts.js' import { activate, disable, stateFields } from './siteFeatures.js' import { pruefeNow } from './termine/util.js' +import { loeschTag } from './termine/frist.js' import { ladeEinstellung } from './termine/kontext.js' +import { heute } from './termine/zeit.js' import { leereCache } from './unterkunft/kontext.js' /** @@ -27,6 +31,14 @@ import { leereCache } from './unterkunft/kontext.js' * Rueckkehr disabled mit Grund abo_ende und das Abo deckt wieder, solange die Daten da sind (News: das Dokument ist noch disabled; * Terminplaner: die Einstellung ist gespeichert; Webshop und Buchungskalender: die Notiz nennt keine Loeschung "gelöscht am") * => wieder active (activate), ohne activatedAt wieder setup. Still, ohne Mail (K39 hat es angekuendigt). + * Loeschen News: disabled mit Grund abo_ende, das Abo deckt nicht und disabledAt plus 30 Tage ist erreicht (Berliner Kalendertag wie + * termine/frist.js) => alle Beitraege des Projekts samt Bild loeschen, dann das Dokument auf off (Felder ticketId, activatedAt, + * aboEndeMailAt, disabledAt, disabledReason geleert); scheitert ein Loeschen, bleibt das Dokument disabled (fehler, der naechste + * Lauf wiederholt). Deckt das Abo wieder, gilt die Rueckkehr vor der Loeschung. + * Zuruecksetzen Webshop und Buchungskalender: haben die bestehenden Jobs (shop/jobs.js, unterkunft/aufbewahrung.js) nach 90 Tagen die + * Daten geloescht und "Shopdaten gelöscht am" bzw. "Buchungsdaten gelöscht am" in adminNote vermerkt, wird das Dokument off + * (wie bei News, der Vermerk endet damit), unabhaengig vom Abo. Ohne Vermerk bleibt alles. Der Terminplaner wird von + * termine/jobs.js selbst auf off gesetzt. * * Regeln wie termine/aboAbgleich.js: eine Listenabfrage fuer alle Kunden; das Abo je Kunde einmal fuer die Vorauswahl lesen. Geschrieben * wird nur unter der Sperre feature-admin: nach frischem Lesen von Dokument UND Abo (nie aus der Vorauswahl); die Mail und der @@ -57,12 +69,23 @@ const artVon = (abo) => (abo.produkt === 'hosting' ? 'hosting' : GRUND) /** * Sind die Daten der abgeschalteten Funktion noch da? News: das Dokument ist noch disabled (der Loeschschritt setzt es auf off); * Terminplaner: die Einstellung ist gespeichert (ladeEinstellung wirft bei Lesefehlern, dann bleibt alles); Webshop und Buchungskalender: - * die Notiz nennt keine Loeschung ("Shopdaten gelöscht am", "Buchungsdaten gelöscht am"). + * ein Vermerk der Loeschjobs in der Notiz wird vor der Rueckkehr behandelt (setzeNachLoeschungZurueck), ohne Vermerk sind die Daten da. */ async function datenDa(doc) { if (doc.featureKey === 'termine') return (await ladeEinstellung(doc.$id)) !== null - if (doc.featureKey === 'shop' || doc.featureKey === 'unterkunft') return !/gelöscht am/.test(String(doc.adminNote ?? '')) - return true + return !hatLoeschVermerk(doc) +} + +const TAG_FELDER_LEER = Object.freeze({ ticketId: null, activatedAt: null, aboEndeMailAt: null, disabledAt: null, disabledReason: null }) + +/** Vermerk der bestehenden Loeschjobs von Webshop und Buchungskalender in der Notiz. */ +const LOESCH_VERMERK = /\s*(?:[-–|]\s*)?(?:Shopdaten|Buchungsdaten) gelöscht am \d{4}-\d{2}-\d{2}/g +const hatLoeschVermerk = (doc) => (doc.featureKey === 'shop' || doc.featureKey === 'unterkunft') && /gelöscht am/.test(String(doc.adminNote ?? '')) + +/** News: ist disabledAt plus die Loeschfrist (30 Tage) am Berliner Kalendertag erreicht? Ohne gueltiges disabledAt nie. */ +function loeschReif(doc, now) { + const tag = loeschTag(doc.disabledAt) + return tag !== null && tag <= heute(now) } /** K39 nach der Sperre; ein Misserfolg zaehlt als Fehler, der naechste Lauf wiederholt (Marker leer). */ @@ -131,6 +154,56 @@ async function schalteWiederEin(doc, ctx) { }) } +/** + * News, ein Dokument: unter der Sperre frisch lesen (noch disabled/abo_ende, Frist erreicht, das Abo deckt nicht), zuerst alle Beitraege des + * Projekts samt Bild loeschen (erst das Bild, dann der Beitrag, wie retention.js), dann das Dokument auf off. Ein Fehler laesst das + * Dokument disabled (fehler, der naechste Lauf wiederholt); die uebrigen Beitraege werden trotzdem versucht. + */ +async function loescheNews(doc, ctx) { + const { erg } = ctx + await withLocks([`feature-admin:${doc.projectId}`], async () => { + const frisch = await getDocument(portalFeatures(), doc.$id) + if (!istAboModell(frisch) || frisch.featureKey !== 'news' || frisch.state !== 'disabled' || frisch.disabledReason !== GRUND) return + if (!loeschReif(frisch, ctx.now)) return + const abo = await aboProdukt(frisch.customerId, { now: ctx.now }) + if (deckt(abo, frisch.featureKey)) return // das Abo ist zurueck: Rueckkehr, keine Loeschung + const { hanging, expired } = await listPosts(frisch.projectId, ctx.now) + let geloeschtOk = true + for (const post of [...hanging, ...expired]) { + try { + if (post.imageId) await deleteNewsImage(post.projectId || frisch.projectId, post.imageId) // erst das Bild, bei Fehler bleibt der Beitrag + await deleteDocument(config.collections.newsPosts, post.$id).catch((err) => { + if (err?.status !== 404) throw err + }) + } catch (err) { + geloeschtOk = false + console.error(`[abo-funktionen] News-Beitrag ${post.$id} nicht gelöscht, das Dokument bleibt abgeschaltet: ${fehlerText(err)}`) + } + } + if (!geloeschtOk) { + erg.fehler += 1 + return + } + await updateDocument(portalFeatures(), frisch.$id, { ...stateFields('off'), ...TAG_FELDER_LEER }) + erg.geloescht += 1 + }) +} + +/** + * Webshop und Buchungskalender, ein Dokument: die bestehenden Jobs haben die Daten geloescht (Vermerk in adminNote), unabhaengig vom Abo + * zurueck auf off. Der Vermerk endet damit, damit er nicht in eine spaetere Abschaltung desselben Dokuments hineinreicht. + */ +async function setzeNachLoeschungZurueck(doc, ctx) { + const { erg } = ctx + await withLocks([`feature-admin:${doc.projectId}`], async () => { + const frisch = await getDocument(portalFeatures(), doc.$id) + if (!istAboModell(frisch) || frisch.state !== 'disabled' || frisch.disabledReason !== GRUND || !hatLoeschVermerk(frisch)) return + const adminNote = String(frisch.adminNote ?? '').replace(LOESCH_VERMERK, '').trim() + await updateDocument(portalFeatures(), frisch.$id, { ...stateFields('off'), ...TAG_FELDER_LEER, adminNote }) + erg.geloescht += 1 + }) +} + async function bearbeiteKunde(customerId, dokumente, ctx) { const { erg } = ctx let abo @@ -168,7 +241,9 @@ async function bearbeiteKunde(customerId, dokumente, ctx) { if (doc.unlockedBy === 'projekt' && (await inAufbauphase())) continue await schalteAb(doc, ctx) } else if (doc.state === 'disabled' && doc.disabledReason === GRUND) { - if (gedeckt) await schalteWiederEin(doc, ctx) + if (hatLoeschVermerk(doc)) await setzeNachLoeschungZurueck(doc, ctx) // Daten weg: nie Rueckkehr, off + else if (gedeckt) await schalteWiederEin(doc, ctx) + else if (doc.featureKey === 'news' && loeschReif(doc, ctx.now)) await loescheNews(doc, ctx) else if (!doc.aboEndeMailAt) await holeMeldungNach(doc, ctx) } } catch (err) { @@ -182,8 +257,8 @@ async function bearbeiteKunde(customerId, dokumente, ctx) { * Taeglicher Abgleich der Funktionen des Abo-Modells mit dem Abo (siehe Kopf der Datei). Wirft nie; jedes Problem steht im Log und in `fehler`. * @param {Date} [now] * @returns {Promise<{ geprueft: number, abgeschaltet: number, wiederEin: number, geloescht: number, mails: number, fehler: number }>} - * geprueft = bewertete Dokumente des Abo-Modells, deren Kunde lesbar war; abgeschaltet und wiederEin = in diesem Lauf; geloescht = Daten, die - * der Loeschschritt in diesem Lauf entfernt hat (Task 9); mails = versendete K39; fehler = Kunden und Dokumente, die nicht bearbeitet werden + * geprueft = bewertete Dokumente des Abo-Modells, deren Kunde lesbar war; abgeschaltet und wiederEin = in diesem Lauf; geloescht = Dokumente, + * die der Loeschschritt in diesem Lauf auf off gesetzt hat (News nach 30 Tagen, Webshop und Buchungskalender nach der Loeschung); mails = versendete K39; fehler = Kunden und Dokumente, die nicht bearbeitet werden * konnten, sowie ein gescheiterter K39-Versand */ export async function gleicheAboFunktionenAb(now = new Date()) { diff --git a/test/aboFunktionenAbgleich.test.js b/test/aboFunktionenAbgleich.test.js index 094a99e..bd4c795 100644 --- a/test/aboFunktionenAbgleich.test.js +++ b/test/aboFunktionenAbgleich.test.js @@ -14,12 +14,13 @@ const aw = await startAppwriteMock({ subscriptions: schemaKeys('subscriptions'), contractEvents: schemaKeys('contractEvents'), termineConfig: schemaKeys('termineConfig'), + newsPosts: schemaKeys('newsPosts'), }, }) const st = await startFakeStripe() useTestEnv({ appwriteUrl: aw.url, stripeUrl: st.url }) const { customers, hostingDoc, seedFixtures, subscriptionDoc, wartungDoc } = await import('./support/fixtures.js') -const { deleteDocument } = await import('../server/services/appwriteAdmin.js') +const { deleteDocument, updateDocument } = await import('../server/services/appwriteAdmin.js') const { setMailTransportForTests } = await import('../server/services/mailer.js') const { datumKurz } = await import('../server/services/termine/zeit.js') const { gleicheAboFunktionenAb } = await import('../server/services/aboFunktionenAbgleich.js') @@ -44,7 +45,7 @@ const leere = async (...collections) => { seedFixtures(aw) aw.seed('websiteProjects', { $id: 'p1', customerId: 'c1', projectName: 'Bäckerei' }) beforeEach(async () => { - await leere('portalFeatures', 'subscriptions', 'contractEvents', 'termineConfig') + await leere('portalFeatures', 'subscriptions', 'contractEvents', 'termineConfig', 'newsPosts') mails.sent.length = 0 setMailTransportForTests(mails) aw.seed('customers', customers.c1) @@ -76,10 +77,10 @@ test('Rückkehr: nur solange die Daten da sind; ohne activatedAt zurück auf set assert.deepEqual([f('news').state, f('news').disabledReason, f('news').aboEndeMailAt, f('shop').state, f('unterkunft').state, f('termine').state], ['active', null, null, 'active', 'active', 'disabled']) aw.seed('termineConfig', { $id: 'f_p1_termine', einstellung: '{}', version: 1 }); await gleicheAboFunktionenAb(JETZT); assert.equal(f('termine').state, 'setup') // ohne activatedAt: setup, nicht active }) -test('Rückkehr des Webshops und des Buchungskalenders nicht nach der Löschung der Daten', async () => { +test('Rückkehr des Webshops und des Buchungskalenders nie nach der Löschung der Daten: das Dokument wird off (Task 9)', async () => { abo(wartungDoc); const aus = { state: 'disabled', enabled: false, disabledReason: 'abo_ende', disabledAt: '2026-07-10T09:00:00.000Z', aboEndeMailAt: '2026-07-10T09:05:00.000Z' } seed('shop', { ...aus, adminNote: '2026-10-10T09:00:00.000Z System: Shopdaten gelöscht am 2026-10-10' }); seed('unterkunft', { ...aus, adminNote: 'Buchungsdaten gelöscht am 2026-10-10' }) - const r = await gleicheAboFunktionenAb(JETZT); assert.deepEqual([r.wiederEin, f('shop').state, f('unterkunft').state], [0, 'disabled', 'disabled']) + const r = await gleicheAboFunktionenAb(JETZT); assert.deepEqual([r.wiederEin, r.geloescht, f('shop').state, f('unterkunft').state], [0, 2, 'off', 'off']) }) test('Alte Dokumente bleiben unberührt; Kunde ohne Adresse setzt nur den Marker; Mailfehler: Marker leer, nächster Lauf sendet, disabledAt bleibt', async (t) => { t.mock.method(console, 'error', () => {}); t.mock.method(console, 'warn', () => {}) @@ -101,3 +102,32 @@ test('Projektstart-Funktionen (projekt): ohne jedes Abo unberührt (Aufbauphase) test('abo-Dokumente kennen keine Aufbauphase: ohne jedes Abo-Dokument werden sie wie bisher abgeschaltet', async () => { seed('news'); const r = await gleicheAboFunktionenAb(JETZT); assert.deepEqual([r.abgeschaltet, f('news').state], [1, 'disabled']) }) + +// Task 9: News-Löschschritt und Zurücksetzen nach der Löschung +test('News: nach 30 Tagen werden Beiträge samt Bild gelöscht und das Dokument ist off; vorher und mit laufendem Abo nicht', async () => { + abo({ ...wartungDoc, status: 'canceled' }); const aus = { state: 'disabled', enabled: false, disabledReason: 'abo_ende', aboEndeMailAt: '2026-09-01T00:00:00.000Z' } + seed('news', { ...aus, disabledAt: new Date(JETZT.getTime() - 29 * TAG).toISOString() }) + aw.seed('newsPosts', { $id: 'np1', customerId: 'c1', projectId: 'p1', title: 'A', imageId: null, visibleFrom: '2026-09-01T00:00:00.000Z', visibleUntil: null }); aw.seed('newsPosts', { $id: 'np2', customerId: 'c1', projectId: 'p_anders', title: 'B', imageId: null, visibleFrom: '2026-09-01T00:00:00.000Z', visibleUntil: null }) + assert.equal((await gleicheAboFunktionenAb(JETZT)).geloescht, 0); assert.equal(aw.docs('newsPosts').size, 2) + await updateDocument('portalFeatures', 'f_p1_news', { disabledAt: new Date(JETZT.getTime() - 31 * TAG).toISOString() }) + assert.equal((await gleicheAboFunktionenAb(JETZT)).geloescht, 1); assert.deepEqual([...aw.docs('newsPosts').keys()], ['np2']) + assert.deepEqual([f('news').state, f('news').disabledAt, f('news').aboEndeMailAt], ['off', null, null]) + seed('news', { ...aus, disabledAt: new Date(JETZT.getTime() - 40 * TAG).toISOString() }); aw.seed('subscriptions', subscriptionDoc('sub_h', wartungDoc)) // Abo kehrt zurück: Rückkehr statt Löschung + aw.seed('newsPosts', { $id: 'np3', customerId: 'c1', projectId: 'p1', title: 'C', imageId: null, visibleFrom: '2026-09-01T00:00:00.000Z', visibleUntil: null }) + await gleicheAboFunktionenAb(JETZT); assert.deepEqual([f('news').state, aw.docs('newsPosts').has('np3')], ['active', true]) +}) +test('News: ein Fehler beim Löschen lässt das Dokument disabled und zählt fehler', async (t) => { + abo({ ...wartungDoc, status: 'canceled' }); seed('news', { state: 'disabled', enabled: false, disabledReason: 'abo_ende', aboEndeMailAt: 'x', disabledAt: new Date(JETZT.getTime() - 31 * TAG).toISOString() }) + aw.seed('newsPosts', { $id: 'np1', customerId: 'c1', projectId: 'p1', title: 'A', imageId: null, visibleFrom: '2026-09-01T00:00:00.000Z', visibleUntil: null }); t.mock.method(console, 'error', () => {}); aw.failNext({ collection: 'newsPosts', method: 'DELETE', status: 500 }) + const r = await gleicheAboFunktionenAb(JETZT); assert.deepEqual([r.fehler, f('news').state], [1, 'disabled']); assert.equal((await gleicheAboFunktionenAb(JETZT)).geloescht, 1) +}) +test('Shop und Unterkunft: nach der Löschung durch die bestehenden Jobs wird das Dokument off (auch bei laufendem Abo); ohne Marker nichts', async () => { + abo(wartungDoc); const aus = { state: 'disabled', enabled: false, disabledReason: 'abo_ende', disabledAt: '2026-06-01T00:00:00.000Z', aboEndeMailAt: '2026-06-01T00:05:00.000Z' } + seed('shop', { ...aus, adminNote: 'Shopdaten gelöscht am 2026-09-01' }); seed('unterkunft', { ...aus, adminNote: 'Buchungsdaten gelöscht am 2026-09-01' }); seed('termine', { ...aus }) + const r = await gleicheAboFunktionenAb(JETZT); assert.equal(r.geloescht, 2); assert.deepEqual([f('shop').state, f('unterkunft').state, f('shop').aboEndeMailAt], ['off', 'off', null]) + assert.deepEqual([f('termine').state, f('shop').adminNote], ['disabled', '']) // Terminplaner: setzt termine/jobs.js selbst auf off; der Löschvermerk endet mit dem Zurücksetzen +}) +test('News: ohne Marker und nach Ablauf der Frist wird gelöscht, ohne noch einmal K39 zu senden', async () => { + abo({ ...wartungDoc, status: 'canceled' }); seed('news', { state: 'disabled', enabled: false, disabledReason: 'abo_ende', disabledAt: new Date(JETZT.getTime() - 35 * TAG).toISOString(), aboEndeMailAt: null }) + const r = await gleicheAboFunktionenAb(JETZT); assert.deepEqual([r.geloescht, r.mails, f('news').state, mails.sent.length], [1, 0, 'off', 0]) +})