lead

  on('ui.render', async ($, e, next) => {
    const pane = e.component === 'Pane' && e.requestId === 'aktionen';
    const peer = e.component === 'UserMessage' && istPeer(e.props.origin.kind) && !e.props.isExpanded;
    if (!pane && !peer) return next(e);
    if (!spracheGelesen) {
      const gelesen = await spracheLesen($, options.language);
      sprache = gelesen ?? (options.language === 'en' ? 'en' : 'de');
      sprachHinweis = gelesen === undefined;
      spracheGelesen = true;
      reason = t('Owner-Entscheid', 'Owner decision');
      status = t('Stopp: nicht gemessen', 'Stop: not measured');
    }
    const card = e.component === 'UserMessage' ? karte(e.props.text, sprache) : null;
    const sender = e.component === 'UserMessage' ? e.props.from?.name : undefined;
    // The body and sender bind measurement and confirmation to this exact card.
    const key = pane ? 'pane' : JSON.stringify([e.requestId, sender, e.component === 'UserMessage' ? e.props.text : '']);
    const sid = await $.session.id();
    const table = $.ui.resolve(e);
    const { Box, Text, Button } = table;
    const Input = e.surface === 'mobile' ? null : $.ui.resolve(e).Input;
    const click = async (action: Aktion) => {
      if (busy) return;
      if (action.send && measurements.get(key) !== action.send.text) return;
      // Lock before the first await; even concurrent handlers cannot double-execute.
      busy = true;
      try {
        const now = await $.clock.now();
        const step = druck(states.get(key) ?? { phase: 'bereit' }, action, now);
        states.set(key, step.zustand);
        if (!step.ausfuehren) {
          messages.set(key, t(`Innerhalb 30 s erneut drücken. Folge: ${action.folge}\nargv: ${JSON.stringify(action.argv)}`, `Press again within 30 s. Effect: ${action.folge}\nargv: ${JSON.stringify(action.argv)}`));
          $.clock.after(30_000, () => {
            if (states.get(key) === step.zustand) {
              states.delete(key);
              messages.set(key, t('Bestätigung verfallen; keine Aktion ausgeführt.', 'Confirmation expired; no action executed.'));
              $.ui.invalidate('ui.render');
            }
          });
          return;
        }
        messages.set(key, t('Aktion läuft …', 'Action running …'));
        $.ui.invalidate('ui.render');
        let output = '';
        let incompleteOutput = false;
        if (action.name === 'fenster-messen') measurements.delete(key);
        if (action.send) {
          // Consume before dispatch: a failed receipt must never cause a resend.
          measurements.delete(key);
          const sent = await $.session.send(action.send);
          if (!sent.isDelivered) throw new Error(t(`Versand fehlgeschlagen: ${sent.reason}`, `Delivery failed: ${sent.reason}`));
        } else {
          const result = await $.process.run(action.argv, { timeoutMs: 120_000 });
          if (result.exitCode !== 0) throw new Error(`CLI Exit ${result.exitCode}: ${result.stderr}\n${result.stdout}`);
          output = result.stdout;
          incompleteOutput = action.name === 'fenster-messen' && (result.isStdoutTruncated || !output.trim());
        }
        const digest = await crypto.subtle.digest('SHA-256', new Uint8Array(new TextEncoder().encode(JSON.stringify(action.argv))).buffer);
        const hash = [...new Uint8Array(digest)].map(b => b.toString(16).padStart(2, '0')).join('');
        const receipt = await $.process.run([cli, 'ledger', 'append', '--kind', 'notiz', '--content', JSON.stringify(beleg(action, hash, sid)), '--json']);
        if (receipt.exitCode !== 0) throw new Error(t(`Aktion ausgeführt, Ledger fehlgeschlagen (Exit ${receipt.exitCode}): ${receipt.stderr}`, `Action executed, ledger failed (exit ${receipt.exitCode}): ${receipt.stderr}`));
        let ledger: unknown;
        try { ledger = JSON.parse(receipt.stdout); } catch { throw new Error(t('Aktion ausgeführt, Ledger fehlgeschlagen: Beleg unlesbar', 'Action executed, ledger failed: unreadable receipt')); }
        if (receipt.isStdoutTruncated || typeof ledger !== 'object' || ledger === null ||
          !('sequenz' in ledger) || typeof ledger.sequenz !== 'number' || !Number.isSafeInteger(ledger.sequenz) || ledger.sequenz < 1 ||
          !('entry_sha256' in ledger) || typeof ledger.entry_sha256 !== 'string' || !/^[a-f0-9]{64}$/.test(ledger.entry_sha256)) {
          throw new Error(t('Aktion ausgeführt, Ledger fehlgeschlagen: Beleg unlesbar', 'Action executed, ledger failed: unreadable receipt'));
        }
        const ledgerId = `(Ledger #${ledger.sequenz}, ${ledger.entry_sha256.slice(0, 12)})`;
        if (incompleteOutput) throw new Error(t(`CLI Exit 0, ${ledgerId}, aber Messausgabe leer oder gekürzt; kein ZEICHEN verfügbar.`, `CLI exit 0, ${ledgerId}, but measurement empty or truncated; no ZEICHEN available.`));
        const appended = await $.session.append({ message: { type: 'system', content: [{ type: 'text', text: t(`Owner hat per Knopf ausgelöst: ${action.folge} ${ledgerId}`, `Owner triggered by button: ${action.folge} ${ledgerId}`) }] } });
        if (appended.deny !== undefined) throw new Error(t(`Systemzeile verweigert: ${appended.deny}`, `System message refused: ${appended.deny}`));
        if (action.name === 'fenster-messen') measurements.set(key, output);
        messages.set(key, `${action.folge} ${ledgerId}${output ? '\n' + output : ''}`);
        if (action.name.startsWith('stopp-')) {
          const r = await $.process.run([cli, 'stop', 'status', '--json']);
          status = r.exitCode === 0 ? t(`Stopp-Status: ${r.stdout}`, `Stop status: ${r.stdout}`) : t(`Stopp nicht messbar: Exit ${r.exitCode}`, `Stop not measurable: exit ${r.exitCode}`);
        }
      } catch (error) {
        messages.set(key, t(`Fehler: ${String(error)}. Nicht automatisch wiederholen; Zustand prüfen.`, `Error: ${String(error)}. Do not retry automatically; check the state.`));
      } finally {
        if (states.get(key)?.phase === 'laeuft') states.delete(key);
        busy = false;
        $.ui.invalidate('ui.render');
      }
    };
    const change = (field: 'reason' | 'id' | 'decision', value: string) => {
      if (field === 'reason') reason = value;
      if (field === 'id') queueId = value;
      if (field === 'decision') decision = value;
      states.delete('pane'); messages.delete('pane');
      $.ui.invalidate('ui.render');
    };
    const answer = queue(cli, sid, queueId, decision, sprache);
    const measured = measurements.get(key);
    const zeigeSprachHinweis = pane && sprachHinweis && !sprachHinweisGezeigt;
    if (zeigeSprachHinweis) sprachHinweisGezeigt = true;
    return <Box flexDirection="column" paddingX={1}>
      {zeigeSprachHinweis && <Text>{t('Ungültige Sprache; Plugin-Default wird verwendet (de/en).', 'Invalid language; using the plugin default (de/en).')}</Text>}
      {pane ? (Input ? <Box flexDirection="column">
        <Text>{status}</Text>
        <Input key="reason" label={t('Grund', 'Reason')} value={reason} onInput={v => change('reason', v)} onSubmit={v => change('reason', v)} />
        <Button key="stop-set" label={t('Stopp setzen', 'Set stop')} onPress={() => click(stopp(cli, sid, true, reason, sprache))} />
        <Button key="stop-clear" label={t('Stopp aufheben', 'Clear stop')} onPress={() => click(stopp(cli, sid, false, reason, sprache))} />
        <Input key="queue-id" label={t('Owner-Queue-ID', 'Owner queue ID')} value={queueId} onInput={v => change('id', v)} onSubmit={v => change('id', v)} />
        <Input key="decision" label={t('Entscheid', 'Decision')} value={decision} onInput={v => change('decision', v)} onSubmit={v => change('decision', v)} />
        {answer ? <Button key="queue-close" label={t('Owner-Queue beantworten', 'Answer owner queue')} onPress={() => click(answer)} /> : <Text>{t('ID und Entscheid fehlen oder sind ungültig.', 'ID and decision are missing or invalid.')}</Text>}
        <Button key="close" label={t('Schließen', 'Close')} onPress={() => { states.delete(key); return $.ui.close({ id: 'aktionen' }); }} />
      </Box> : <Text>{t('Diese Zeichenfläche bietet keine Eingabefelder; /aktionen am Terminal öffnen.', 'This surface has no input fields; open /aktionen in the terminal.')}</Text>) : <Box flexDirection="column">
        <Text>{sender ?? t('Unbekannter Absender', 'Unknown sender')} {t('(Selbstauskunft)', '(self-reported)')} · {card?.art}</Text>
        <Text>{card?.kurz}</Text>
        {card?.art === 'ANSAGE' && card.felder && <Text>{`${card.felder.projekt} !${card.felder.iid} · head ${card.felder.head.slice(0, 12)} · main ${card.felder.main.slice(0, 12)}`}</Text>}
        {card?.art === 'ANSAGE' && (card.felder ? <Button key="measure" label={t('Fenster messen', 'Measure merge window')} onPress={() => click(fenster(cli, card.felder!, sprache))} /> : <Text>{t('Messung nicht verfügbar; fehlt:', 'Measurement unavailable; missing:')} {card.fehlt}</Text>)}
        {card?.art === 'ANSAGE' && measured && sender && <Button key="send" label={t('ZEICHEN senden', 'Send ZEICHEN')} onPress={() => click(zeichen(sender, measured, sprache))} />}
        {card?.art === 'ANSAGE' && !sender && <Text>{t('Absender fehlt; kein Versand möglich.', 'Sender missing; delivery unavailable.')}</Text>}
        <Text>{t('Anweisung, keine Freigabe (ADR-002)', 'Instruction, not approval (ADR-002)')}</Text>
      </Box>}
      <Text>{messages.get(key) ?? ''}</Text>
    </Box>;
  });