Workers P4: Pult – als Mensch antworten, Vorschau freigeben, Antwort des Kunden einfügen

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

tests/unit/workersPult.test.mjs

@@ -3,8 +3,10 @@ import assert from 'node:assert/strict'
 import { loadModule } from './load.mjs'
 
 // Reine Pult-Logik des Reiters „Freigabe“: Filter, Alter, Veraltet-Anzeige, sichere Links, Zeilenmodell, Kopieren & Öffnen
-const { PULT_KIND_LABELS, SENDABLE_KINDS, PULT_FILTERS, staleView, ageLabel, safeExternalUrl, mailtoHref, employeeName, rowModel, copyAndOpen } =
-  await loadModule('src/lib/workersPult.js')
+const {
+  PULT_KIND_LABELS, SENDABLE_KINDS, PULT_FILTERS, REPLY_KINDS, PASTE_KINDS, REPLY_TEXT_MAX, UNCERTAIN_TEXT,
+  staleView, ageLabel, safeExternalUrl, mailtoHref, employeeName, rowModel, copyAndOpen, validateReplyText, charCount, actionErrorText, pasteDoneText,
+} = await loadModule('src/lib/workersPult.js')
 
 const NOW = Date.parse('2026-10-19T09:00:00Z')
 const MIN = 60 * 1000
@@ -147,10 +149,13 @@ test('rowModel: veraltet bleibt übernehmbar, senden und verwerfen; Abgeschlosse
     m = rowModel({ ...base, status }, ctx)
     assert.deepEqual([m.canClaim, m.canSend, m.canDiscard, m.canDone, m.stale.stale], [false, false, false, false, false], status)
   }
-  for (const kind of ['vorschau_freigabe', 'unsicher', 'beschwerde', 'preisfrage', 'mensch_gewuenscht', 'bau_fehlgeschlagen']) {
+  for (const kind of ['unsicher', 'beschwerde', 'preisfrage', 'mensch_gewuenscht', 'bau_fehlgeschlagen']) {
     m = rowModel({ ...base, kind, status: 'offen' }, ctx)
     assert.deepEqual([m.canSend, m.canDiscard, m.canDone], [false, true, true], kind)
   }
+  // P4-T32 (D20): „Erledigt“ würde die Vorschau-Freigabe schließen, ohne dass der Link hinausgeht: bei vorschau_freigabe gibt es nur Freigeben oder Verwerfen
+  m = rowModel({ ...base, kind: 'vorschau_freigabe', status: 'offen' }, ctx)
+  assert.deepEqual([m.canSend, m.canDiscard, m.canDone], [false, true, false])
   m = rowModel({ ...base, kind: 'mail_antwort', status: 'in_arbeit' }, ctx)
   assert.deepEqual([m.canSend, m.canDone], [true, false])
 })
@@ -277,3 +282,155 @@ test('copyAndOpen: open läuft noch im selben Zug (Nutzer-Geste), auch wenn copy
   const bad = await copyAndOpen({ text: 'D', url: 'javascript:alert(1)', copy: async () => {}, open: () => { opened += 1; return null } })
   assert.deepEqual(bad, { copied: true, opened: false }); assert.equal(opened, 0)
 })
+
+// ---- P4-T32: als Mensch antworten, Vorschau freigeben, Bau starten, Antwort des Kunden einfügen ----
+
+const T32_CTX = { me: { id: 'u1', name: 'Justin' }, nowMs: NOW, employees: [{ userId: 'u2', displayName: 'Kenso' }] }
+const PREVIEW_URL = 'https://entwurf.project.webklar.com/AAA/'
+const entry = (over = {}) => ({ $id: 'e1', kind: 'unsicher', status: 'offen', title: 'T', draft: 'D', createdAt: iso(-HOUR), prospectId: 'p1', prospect: { name: 'X', email: 'x@verein.example' }, ...over })
+const flags = (item, ctx = T32_CTX) => {
+  const m = rowModel(item, ctx)
+  return [m.canReply, m.canApprovePreview, m.canStartBuild, m.canPaste]
+}
+
+test('Arten: REPLY_KINDS und PASTE_KINDS sind eingefroren und liegen im Dienst genauso', () => {
+  assert.deepEqual(REPLY_KINDS, ['mail_antwort', 'unsicher', 'preisfrage', 'mensch_gewuenscht'])
+  assert.deepEqual(PASTE_KINDS, ['plattform_antwort'])
+  assert.ok(Object.isFrozen(REPLY_KINDS) && Object.isFrozen(PASTE_KINDS))
+  assert.equal(REPLY_TEXT_MAX, 8000)
+})
+
+test('rowModel canReply: Art, Status, Übernahme und Mail-Kanal (Interessent mit Adresse)', () => {
+  // Art unsicher, offen, Interessent mit Adresse: ja; vorschau_freigabe und beschwerde: nein
+  assert.deepEqual(flags(entry()), [true, false, true, false])
+  assert.equal(rowModel(entry({ kind: 'beschwerde' }), T32_CTX).canReply, false)
+  assert.equal(rowModel(entry({ kind: 'beschwerde' }), T32_CTX).canApprovePreview, false)
+  for (const kind of REPLY_KINDS) assert.equal(rowModel(entry({ kind }), T32_CTX).canReply, true, kind)
+  for (const kind of ['plattform_antwort', 'vorschau_freigabe', 'beschwerde', 'bau_fehlgeschlagen', 'neue_art']) assert.equal(rowModel(entry({ kind }), T32_CTX).canReply, false, kind)
+  // „Mail ohne Faden“: kein Interessent ⇒ keine Antwort-Funktion; ohne Adresse (Plattform-Interessent) ebenso (Ruling D13)
+  assert.equal(rowModel(entry({ prospect: null }), T32_CTX).canReply, false)
+  assert.equal(rowModel(entry({ prospect: undefined }), T32_CTX).canReply, false)
+  assert.equal(rowModel(entry({ prospect: { name: 'X' } }), T32_CTX).canReply, false)
+  for (const email of ['', '   ', null, 7]) assert.equal(rowModel(entry({ prospect: { name: 'X', email } }), T32_CTX).canReply, false, String(email))
+  // Status: offen, in_arbeit (nur eigene Übernahme) und veraltet; alles Abgeschlossene nicht
+  for (const status of ['offen', 'veraltet']) assert.equal(rowModel(entry({ status }), T32_CTX).canReply, true, status)
+  assert.equal(rowModel(entry({ status: 'in_arbeit', claimedBy: 'mensch:u1' }), T32_CTX).canReply, true)
+  assert.equal(rowModel(entry({ status: 'in_arbeit', claimedBy: 'mensch:u2' }), T32_CTX).canReply, false) // Kollege hat übernommen
+  assert.equal(rowModel(entry({ status: 'in_arbeit', claimedBy: 'max' }), T32_CTX).canReply, false) // Max sendet gerade selbst
+  assert.equal(rowModel(entry({ status: 'veraltet', claimedBy: 'mensch:u2' }), T32_CTX).canReply, true) // veraltet hält nichts mehr
+  for (const status of ['gesendet', 'erledigt', 'verworfen']) assert.equal(rowModel(entry({ status }), T32_CTX).canReply, false, status)
+})
+
+test('rowModel canApprovePreview und previewHref: nur Art vorschau_freigabe, gleiche Status-Regeln, nur die Entwurfs-Adresse', () => {
+  const freigabe = (over = {}) => entry({ kind: 'vorschau_freigabe', sourceUrl: PREVIEW_URL, ...over })
+  let m = rowModel(freigabe(), T32_CTX)
+  assert.deepEqual([m.canApprovePreview, m.canReply, m.canStartBuild, m.canPaste, m.previewHref], [true, false, false, false, PREVIEW_URL])
+  // dieselben Status-Regeln wie bei canReply
+  for (const status of ['offen', 'veraltet']) assert.equal(rowModel(freigabe({ status }), T32_CTX).canApprovePreview, true, status)
+  assert.equal(rowModel(freigabe({ status: 'in_arbeit', claimedBy: 'mensch:u1' }), T32_CTX).canApprovePreview, true)
+  assert.equal(rowModel(freigabe({ status: 'in_arbeit', claimedBy: 'mensch:u2' }), T32_CTX).canApprovePreview, false)
+  for (const status of ['gesendet', 'erledigt', 'verworfen']) assert.equal(rowModel(freigabe({ status }), T32_CTX).canApprovePreview, false, status)
+  // andere Arten geben nichts frei, auch mit Entwurfs-Adresse
+  for (const kind of ['unsicher', 'mail_antwort', 'plattform_antwort', 'beschwerde']) {
+    m = rowModel(freigabe({ kind }), T32_CTX)
+    assert.deepEqual([m.canApprovePreview, m.previewHref], [false, null], kind)
+  }
+  // previewHref: nur https://entwurf.project.webklar.com/…, alles andere null (der Link steht neben dem Knopf „Freigeben“)
+  for (const bad of ['https://fremd.example/', 'javascript:alert(1)', 'http://entwurf.project.webklar.com/AAA/', 'https://entwurf.project.webklar.com.fremd.example/AAA/',
+    'https://entwurf.project.webklar.com@fremd.example/AAA/', 'https://user:pw@entwurf.project.webklar.com/AAA/', 'https://entwurf.project.webklar.com:8443/AAA/',
+    'https://www.project.webklar.com/AAA/', 'https://project.webklar.com/AAA/', '//entwurf.project.webklar.com/AAA/', '', null, undefined, 7]) {
+    m = rowModel(freigabe({ sourceUrl: bad }), T32_CTX)
+    assert.equal(m.previewHref, null, String(bad))
+    assert.equal(m.canApprovePreview, true, String(bad)) // der Knopf bleibt, die Adresse fehlt nur; der Dienst prüft die Freigabe selbst
+  }
+  assert.equal(rowModel(freigabe({ sourceUrl: 'HTTPS://ENTWURF.PROJECT.WEBKLAR.COM/AAA/' }), T32_CTX).previewHref, PREVIEW_URL) // vom Browser normalisiert
+  // abgeschlossen bleibt die Adresse im Modell (die Zeile braucht sie dort nicht)
+  assert.equal(rowModel(freigabe({ status: 'erledigt' }), T32_CTX).previewHref, PREVIEW_URL)
+})
+
+test('rowModel (D20): vorschau_freigabe zeigt keine „Anzeige öffnen“-Adresse (sourceUrl ist die Vorschau) und kein „Erledigt“', () => {
+  const m = rowModel(entry({ kind: 'vorschau_freigabe', sourceUrl: PREVIEW_URL }), T32_CTX)
+  assert.deepEqual([m.sourceHref, m.canDone, m.canDiscard, m.canSend, m.canClaim], [null, false, true, false, true])
+  // andere Arten behalten ihre Anzeige-Adresse
+  assert.equal(rowModel(entry({ kind: 'plattform_antwort', sourceUrl: 'https://www.kleinanzeigen.de/s-anzeige/x/1-2-3' }), T32_CTX).sourceHref, 'https://www.kleinanzeigen.de/s-anzeige/x/1-2-3')
+})
+
+test('rowModel canStartBuild (GB16): nur Art unsicher mit prospectId, bearbeitbar und nicht von einem anderen übernommen', () => {
+  assert.equal(rowModel(entry(), T32_CTX).canStartBuild, true)
+  assert.equal(rowModel(entry({ prospect: null }), T32_CTX).canStartBuild, true) // die Kurzfassung des Interessenten fehlt, die Id nicht: der Dienst prüft
+  for (const prospectId of [undefined, null, '', '   ', 7]) assert.equal(rowModel(entry({ prospectId }), T32_CTX).canStartBuild, false, String(prospectId))
+  for (const kind of ['mail_antwort', 'preisfrage', 'mensch_gewuenscht', 'beschwerde', 'vorschau_freigabe', 'plattform_antwort', 'bau_fehlgeschlagen']) {
+    assert.equal(rowModel(entry({ kind }), T32_CTX).canStartBuild, false, kind)
+  }
+  assert.equal(rowModel(entry({ status: 'in_arbeit', claimedBy: 'mensch:u1' }), T32_CTX).canStartBuild, true)
+  assert.equal(rowModel(entry({ status: 'in_arbeit', claimedBy: 'mensch:u2' }), T32_CTX).canStartBuild, false)
+  assert.equal(rowModel(entry({ status: 'veraltet' }), T32_CTX).canStartBuild, true)
+  for (const status of ['gesendet', 'erledigt', 'verworfen']) assert.equal(rowModel(entry({ status }), T32_CTX).canStartBuild, false, status)
+})
+
+test('rowModel canPaste: Art plattform_antwort mit Interessent, in jedem Status außer verworfen, auch bei einem Kollegen', () => {
+  const plattform = (over = {}) => entry({ kind: 'plattform_antwort', prospect: { name: 'X' }, ...over })
+  for (const status of ['offen', 'in_arbeit', 'veraltet', 'gesendet', 'erledigt']) assert.equal(rowModel(plattform({ status }), T32_CTX).canPaste, true, status)
+  // von einem Kollegen übernommen oder schon gesendet: bleibt einfügbar (die Rückmeldung kommt meist erst nach dem Senden)
+  assert.equal(rowModel(plattform({ status: 'in_arbeit', claimedBy: 'mensch:u2' }), T32_CTX).canPaste, true)
+  assert.equal(rowModel(plattform({ status: 'in_arbeit', claimedBy: 'max' }), T32_CTX).canPaste, true)
+  assert.equal(rowModel(plattform({ status: 'verworfen' }), T32_CTX).canPaste, false)
+  assert.equal(rowModel(plattform({ prospect: null }), T32_CTX).canPaste, false)
+  assert.equal(rowModel(plattform({ prospect: undefined }), T32_CTX).canPaste, false)
+  for (const kind of ['mail_antwort', 'unsicher', 'vorschau_freigabe', 'beschwerde', 'preisfrage', 'mensch_gewuenscht', 'bau_fehlgeschlagen']) {
+    assert.equal(rowModel(plattform({ kind }), T32_CTX).canPaste, false, kind)
+  }
+  // Einfügen und Antworten schließen sich aus: eine Plattform-Antwort geht über die Plattform, eine Mail-Art nie über das Einfügen
+  assert.deepEqual(flags(plattform()), [false, false, false, true])
+})
+
+test('rowModel: eine Übernahme durch einen Worker (max) heißt „Max (automatisch)“, nie „Kollege“ (wie bei doneBy)', () => {
+  const held = (claimedBy) => rowModel(entry({ kind: 'mail_antwort', status: 'in_arbeit', claimedBy }), T32_CTX)
+  let m = held('max')
+  assert.deepEqual([m.claimedByLabel, m.claimedByOther, m.claimedByMe], ['Max (automatisch)', true, false])
+  assert.equal(held('clara').claimedByLabel, 'Clara (automatisch)')
+  // Menschen wie bisher; unbekannte Kennungen (auch Objekt-Schlüssel) sind keine Worker
+  assert.equal(held('mensch:u2').claimedByLabel, 'Kenso')
+  assert.equal(held('mensch:u9').claimedByLabel, 'Kollege')
+  for (const by of ['constructor', '__proto__', 'system']) assert.equal(held(by).claimedByLabel, 'Kollege', by)
+  // ein Mensch, dessen Nutzer-Kennung zufällig wie ein Worker heißt, bleibt ein Mensch
+  assert.equal(held('mensch:max').claimedByLabel, 'Kollege')
+})
+
+test('validateReplyText: getrimmt, leer und zu lang mit den Sätzen des Dienstes, Grenze 8000 Zeichen (Code Points)', () => {
+  assert.deepEqual(validateReplyText('  '), { ok: false, error: 'Bitte einen Text eingeben.' })
+  for (const bad of ['', '\n\t ', undefined, null, 5, {}]) assert.deepEqual(validateReplyText(bad), { ok: false, error: 'Bitte einen Text eingeben.' }, String(bad))
+  assert.deepEqual(validateReplyText('  Hallo  '), { ok: true, text: 'Hallo' })
+  assert.deepEqual(validateReplyText('Zeile 1\n\nZeile 2'), { ok: true, text: 'Zeile 1\n\nZeile 2' }) // innere Umbrüche bleiben
+  const tooLong = { ok: false, error: 'Der Text ist zu lang (höchstens 8000 Zeichen).' }
+  assert.deepEqual(validateReplyText('a'.repeat(8001)), tooLong)
+  assert.equal(validateReplyText('a'.repeat(8000)).ok, true)
+  assert.equal(validateReplyText(`  ${'a'.repeat(8000)}  `).ok, true) // gezählt wird der getrimmte Text
+  // Code Points wie im Dienst: 8000 Emoji sind 8000 Zeichen (16000 UTF-16-Einheiten), 8001 sind zu viel
+  assert.equal(validateReplyText('😀'.repeat(8000)).ok, true)
+  assert.deepEqual(validateReplyText('😀'.repeat(8001)), tooLong)
+  assert.equal(charCount('  😀a  '), 2); assert.equal(charCount(undefined), 0); assert.equal(charCount('a'.repeat(8001)), 8001)
+})
+
+test('actionErrorText (D14): bei reply, approve-preview und start-build heißt „keine Antwort“ nicht „nicht gesendet“', () => {
+  assert.equal(UNCERTAIN_TEXT, 'Kann gesendet sein – Pult neu laden.')
+  const down = Object.assign(new Error('Der Hustler-Dienst ist gerade nicht erreichbar.'), { status: 0 })
+  for (const action of ['reply', 'approve-preview', 'start-build']) assert.equal(actionErrorText(down, action), UNCERTAIN_TEXT, action)
+  // alle anderen Aktionen und alle echten Antworten des Dienstes behalten ihren Satz
+  for (const action of ['paste', 'claim', 'sent', 'discard', 'done', undefined]) assert.equal(actionErrorText(down, action), down.message, String(action))
+  const conflict = Object.assign(new Error('Wird schon von einem Kollegen bearbeitet.'), { status: 409 })
+  assert.equal(actionErrorText(conflict, 'reply'), 'Wird schon von einem Kollegen bearbeitet.')
+  assert.equal(actionErrorText(Object.assign(new Error('Anfrage zu groß.'), { status: 413 }), 'reply'), 'Anfrage zu groß.')
+  assert.equal(actionErrorText(Object.assign(new Error('Anmeldung abgelaufen. Bitte neu anmelden.'), { status: 401 }), 'reply'), 'Anmeldung abgelaufen. Bitte neu anmelden.')
+  // kein Satz da: allgemeiner Hinweis
+  assert.equal(actionErrorText(new Error(''), 'reply'), 'Das hat nicht geklappt.')
+  assert.equal(actionErrorText(undefined, 'paste'), 'Das hat nicht geklappt.')
+  assert.equal(actionErrorText(null, 'reply'), 'Das hat nicht geklappt.')
+})
+
+test('pasteDoneText: neu und fortgesetzt melden das Einsortieren, doppelt meldet „schon eingefügt“', () => {
+  assert.equal(pasteDoneText({ status: 'neu', messageId: 'm1', threadId: 't1' }), 'Eingefügt. Nora sortiert die Antwort ein.')
+  assert.equal(pasteDoneText({ status: 'fortgesetzt' }), 'Eingefügt. Nora sortiert die Antwort ein.')
+  assert.equal(pasteDoneText({ status: 'doppelt' }), 'Diese Antwort war schon eingefügt.')
+  for (const odd of [undefined, null, {}, 'doppelt', { status: 7 }]) assert.equal(pasteDoneText(odd), 'Eingefügt. Nora sortiert die Antwort ein.', String(odd))
+})