release: bump version to 0.2.1.5

Diagnostic bekommt denselben Queue-Automaten wie die App: anstellen statt
abbrechen, awaiting_reply pausiert die Queue (naechste Eingabe beantwortet die
Rueckfrage), Queue-Banner mit loeschbaren Eintraegen ueber dem Eingabefeld,
und Pro-Kontext-Textfeld-Entwuerfe (Feldinhalt bleibt beim Kontextwechsel
erhalten). rvs_chat-Handler liest awaiting_reply aus der Bridge-Payload.

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

CHANGELOG.md

@@ -10,6 +10,69 @@ Alle Änderungen am Projekt. Format: [Keep a Changelog](https://keepachangelog.c
 
 ---
 
+## [0.2.1.4] — 2026-07-12 — Lokales LLM: der ehrliche Rückbau
+
+### Geändert
+
+**Lokales LLM wieder tool-los (B1a) — ein 8B ist ein schlechter Tool-Caller**
+- B1b hatte dem lokalen Modell Werkzeuge (`run_*`/`web_search`) gegeben — die gemeinsame Wurzel von **zwei** Problemen: (1) ein 8B erfindet mit Werkzeug in der Hand lieber eine plausible Antwort („der Song ist X") statt es zu rufen → Halluzination; (2) das erzwang per-Skill-Guards (skaliert nicht). Local ist jetzt wieder **tool-los** = reines Reden; alles mit Grundwahrheit (Fakt/Live-Zustand/Gedächtnis/Aktion) gehört an Claude oder den deterministischen Fast-Path. Kein Skill-Ergebnis mehr fälschbar
+- **Keine Input-Wortliste im Router:** eine kurz eingeführte `_LIVE_HINTS`-Blacklist (Wetter/Musik/… → Claude) wieder entfernt — aus offenem Freitext die Absicht per Wortliste zu raten ist nie vollständig, jeder Miss = ein Halo (nur von per-Skill auf per-Wort verschoben). Generisch = das Modell entscheidet **selbst** (`<<ESCALATE>>`); ein stärkeres lokales Modell übernimmt die Selbst-Erkennung später, bis dahin ist local per Einstellung abschaltbar (aus, nicht raus)
+- Expliziter Nutzer-Wunsch „nimm Claude/Clodi" wird im Router respektiert (geht nie lokal)
+
+### Behoben
+
+- **Info-Halluzination:** local nannte manchmal aktuellen Song/Restzeit/Skip-Titel ohne `run_spotify` zu rufen (mal echt, mal frei erfunden — „Midnight City von M83" nie aufgerufen). Neuer Output-Guard `_claims_live_media_state` eskaliert behauptete Live-Auskünfte ohne echten Skill-Call an Claude; Local-Prompt zusätzlich gehärtet (nie Titel/Zeit/Gerät ohne Tool-Ergebnis; bei „OK: next" keinen Titel erfinden)
+- **Leeres `<voice></voice>` machte TTS stumm:** Claude hängt reflexartig manchmal ein leeres Voice-Tag an → `clean_text_for_tts` nahm den leeren Inhalt → gar keine Sprachausgabe (Playlist „Fliegen" gesprochen, „Prodigy" stumm — reiner Claude-Output-Zufall, nicht Skill/Playlist-Name). Leeres/whitespace-Tag wird jetzt ignoriert, der normale Anzeigetext gelesen
+- **Datei-Anhang erschien erst nach Seitenwechsel:** die Live-`chat`-Payload trug keine `files` (Anhänge kamen nur als separates `file_from_aria`-Event) → an der Nachricht tauchte die Datei erst nach Reload aus `chat_backup` auf. Bridge schickt die `files` jetzt in der chat-Payload, App hängt sie live an die Text-Bubble (wie der Reload-Pfad) und entfernt die redundante Solo-Bubble
+- **TDZ-Zeitbombe (App):** `sendTextMessage` stand vor seinen Dependencies (`interruptAriaIfBusy`, `sendPendingAttachments`) im deps-Array — Temporal Dead Zone; lief nur dank Babels `const`→`var`-Hebung, ein strengerer Bundler hätte beim Mount weißgescreent. Deklaration hinter die Deps verschoben
+- **QRScanner tsc-clean:** toter Prop `colorForScannerFrame` (existiert in `react-native-camera-kit` v13 nicht) entfernt; die fehlerhaften Lib-Typen (optionale Props als required markiert) lokal + dokumentiert umgangen → **Projekt komplett tsc-clean (0 Fehler)**
+
+**Spotify-Skill — von ARIA live im Gespräch weiter geschärft**
+- Skip (`next`/`previous`) sagt jetzt den **echten** neuen Titel an (holt den Track nach dem Skip via API) statt local einen erfinden zu lassen
+- `playlist_play`/`search_and_play`/`play` nennen das **tatsächliche** Wiedergabegerät (aus `GET /v1/me/player`, kein Raten — verhinderte den Fehler, dass Claude ein falsch geratenes Gerät auch noch ansteuerte) und lesen konsistent vor; saubere „Sprach-Grammatik": Ansagen sprechen, Steuerbefehle (play/pause/transfer/volume) schweigen
+- `yt-dlp-download`-Skill um einen MP3-Modus erweitert — ARIA hat das fehlende Werkzeug **selbst gebaut**, als eine deutsche Titelmelodie nicht auf Spotify lag (Web-Suche → YouTube-Download → MP3 in den Chat, in <1 min)
+
+---
+
+## [0.2.1.3] — 2026-07-11
+
+### Hinzugefügt
+
+- **`skill_get`-Tool:** ARIA liest den echten Quellcode + Manifest + Readme eines Skills, **bevor** sie ihn ändert — kein Blind-Rewrite mehr (vorher wurde ein guter Skill durch eine schlechtere Neufassung ersetzt, weil das referenzierte `skill_get` gar nicht existierte)
+
+### Behoben
+
+- **`converse` folgt dem Skill (Fast-Path):** auch ein Fast-Path-Befehl kann einen Skill auslösen, nach dem noch etwas zu sagen ist — `converse` kommt jetzt aus Manifest/Skill-Output statt hart auf `False`
+- **Sprachnachricht-Bubble verschwand nach manuellem Stop:** bei „ohne Ohr" aufgenommener Sprachnachricht + Stop entfernte ein leeres stream-end-Endpoint die schon gefüllte Bubble; jetzt wird nur noch der unaufgelöste Platzhalter entfernt
+
+---
+
+## [0.2.1.2] — 2026-07-11 — Standort-Intelligenz + Skill steuert seine Ausgabe
+
+### Hinzugefügt
+
+**GPS → Ortsname im Standort-Präfix (keyless, keine Tokens)**
+- Reverse-Geocoding der Koordinaten in der Bridge (Nominatim zoom=18: Straße+Hausnr, PLZ+Ort, Bundesland; Straßen-Ref + Autobahn-km via Overpass) — damit das lokale Modell nicht „Berlin" für Oldenburg rät; Ortsname wird **vor** dem Präfix-Bau awaited (rechtzeitig für die erste Nachricht)
+- Fahrtrichtung als Himmelsrichtung **+ exakte Peilung in Grad** (Haversine/Bearing aus aufeinanderfolgenden Fixes, `MIN_MOVE_M`-Schwelle gegen Zittern)
+
+**Skill steuert seine Ausgabe selbst — `speak` + `converse` pro Aufruf**
+- Ein Skill entscheidet per JSON-Output `{speak, converse}` pro Operation, ob vorgelesen wird und ob danach 30 s weitergelauscht wird (Manifest-Default, Output überschreibt) — z. B. „was läuft" vorlesen aber kein Dialog, „nächstes Lied" stumm. In der Skill-Bauanleitung **mit dem WARUM** dokumentiert, damit die KI die Flags beim Bauen versteht (kein Hardcode im Brain)
+
+### Behoben / Geändert
+
+- **Generischer Skill-Prompt (kein Hardcode):** der Router beschreibt `run_*`-Skills generisch (weiß nicht mehr, welche „schwer" sind); ein Stop im 30-s-Lauschen beendet dieses jetzt wirklich (kein zweiter Gong / erneutes Öffnen)
+- **Anti-Halluzination:** behauptet local eine Steuerbefehl-Quittung („Spotify: …", „Playlist abspielen") ohne das Tool wirklich zu rufen → Eskalation an Claude statt erfundene Bestätigung durchzulassen
+
+---
+
+## [0.2.1.1] — 2026-07-11
+
+### Hinzugefügt
+
+- **Skill entscheidet selbst, ob vorgelesen wird (`manifest.speak`):** Grundlage der späteren `speak`/`converse`-Architektur — der `speak`-Flag greift sowohl im lokalen als auch im Claude-Pfad, statt am fragilen leeren `<voice></voice>`-Hack zu hängen
+
+---
+
 ## [0.2.0.6] — 2026-07-11
 
 ### Hinzugefügt

android/android/app/build.gradle

@@ -79,8 +79,8 @@ android {
         applicationId "com.ariacockpit"
         minSdkVersion rootProject.ext.minSdkVersion
         targetSdkVersion rootProject.ext.targetSdkVersion
-        versionCode 20007
+        versionCode 20105
-        versionName "0.2.0.7"
+        versionName "0.2.1.5"
         // Fallback fuer Libraries mit Product Flavors
         missingDimensionStrategy 'react-native-camera', 'general'
     }

android/package.json

@@ -1,6 +1,6 @@
 {
   "name": "aria-cockpit",
-  "version": "0.2.0.7",
+  "version": "0.2.1.5",
   "private": true,
   "scripts": {
     "android": "react-native run-android",

android/src/components/QRScanner.tsx

@@ -121,13 +121,20 @@ const QRScanner: React.FC<QRScannerProps> = ({ visible, onScan, onClose }) => {
       <View style={styles.container}>
         {hasPermission ? (
           <>
+            {/* react-native-camera-kit v13: die .d.ts markiert viele OPTIONALE
+                CameraScreen-Props faelschlich als required (defaultProps fuellen
+                sie zur Laufzeit) und kennt colorForScannerFrame nicht — der war
+                ein No-Op und ist raus. scanBarcode/onReadCode ist die korrekte
+                v13-Barcode-API. Props als any spreaden, um die kaputten Lib-Typen
+                zu umgehen, ohne echten Code zu veraendern. */}
             <CameraScreen
-              scanBarcode={true}
+              {...({
-              onReadCode={handleBarcodeScan}
+                scanBarcode: true,
-              showFrame={true}
+                onReadCode: handleBarcodeScan,
-              frameColor="#0096FF"
+                showFrame: true,
-              laserColor="#0096FF"
+                frameColor: '#0096FF',
-              colorForScannerFrame="#0096FF"
+                laserColor: '#0096FF',
+              } as any)}
             />
 
             {/* Overlay oben */}

android/src/screens/ChatScreen.tsx

@@ -49,7 +49,7 @@ import VoiceButton from '../components/VoiceButton';
 import FileUpload, { FileData } from '../components/FileUpload';
 import CameraUpload, { PhotoData } from '../components/CameraUpload';
 import MessageText from '../components/MessageText';
-import { loadConvWindowMs, loadTtsSpeed, TTS_SPEED_DEFAULT } from '../services/audio';
+import { loadConvWindowMs, loadTtsSpeed, TTS_SPEED_DEFAULT, loadSttEndpointMs } from '../services/audio';
 import Geolocation from '@react-native-community/geolocation';
 
 // --- Typen ---
@@ -64,6 +64,14 @@ interface Attachment {
   deleted?: boolean;    // Datei wurde nachtraeglich geloescht (Diagnostic-Manager)
 }
 
+// Pro-Projekt-Queue-Zustand: idle = nichts laeuft; running = ARIA arbeitet am
+// aktuellen Task; awaiting_reply = ARIA hat eine blockierende Rueckfrage gestellt,
+// die naechste Eingabe beantwortet sie (statt einen neuen Auftrag anzustellen).
+type CtxState = 'idle' | 'running' | 'awaiting_reply';
+
+// Wartender Queue-Eintrag (id = die Bubble-ID der pending_queue-Nachricht).
+interface QueuedItem { id: string; text: string; }
+
 interface ChatMessage {
   id: string;
   sender: 'user' | 'aria';
@@ -131,7 +139,7 @@ interface ChatMessage {
   /** Delivery-Status der User-Bubble (WhatsApp-style): queued = noch nicht
    *  raus (offline), sending = an Bridge unterwegs, sent = Bridge hat ACK
    *  gesendet, delivered = Brain hat geantwortet, failed = Retry-Limit. */
-  deliveryStatus?: 'queued' | 'sending' | 'sent' | 'delivered' | 'failed';
+  deliveryStatus?: 'queued' | 'pending_queue' | 'sending' | 'sent' | 'delivered' | 'failed';
   /** Anzahl der bisherigen Sende-Versuche (fuer Retry-Limit). */
   sendAttempts?: number;
 }
@@ -275,6 +283,7 @@ async function checkFileExists(uri: string): Promise<boolean> {
 const ChatScreen: React.FC = () => {
   const [messages, setMessages] = useState<ChatMessage[]>([]);
   const [inputText, setInputText] = useState('');
+  const inputTextRef = useRef('');
   const [connectionState, setConnectionState] = useState<ConnectionState>('disconnected');
   const [showFileUpload, setShowFileUpload] = useState(false);
   const [showCameraUpload, setShowCameraUpload] = useState(false);
@@ -301,6 +310,24 @@ const ChatScreen: React.FC = () => {
   // Ref-Spiegel fuer Callbacks (interruptAriaIfBusy liest den aktuellen
   // Busy-Status des fokussierten Kontexts ohne stale Closure).
   const queueStatusRef = useRef<Record<string, { busy: boolean; queue_size: number }>>({});
+  // ── Pro-Projekt-Nachrichten-Queue + Zustandsautomat (app-lokal) ──
+  // Key = projectId ('' = Hauptchat). state pro Kontext + Queue der wartenden
+  // User-Bubbles. Sendet man waehrend 'running', wird angestellt statt
+  // abgebrochen; 'awaiting_reply' leitet die naechste Eingabe als Antwort weiter.
+  const [projectStates, setProjectStates] = useState<Record<string, CtxState>>({});
+  const [projectQueues, setProjectQueues] = useState<Record<string, QueuedItem[]>>({});
+  const projectStatesRef = useRef<Record<string, CtxState>>({});
+  const projectQueuesRef = useRef<Record<string, QueuedItem[]>>({});
+  // Pro-Projekt-Textfeld-Entwuerfe (noch nicht gesendeter Feldinhalt). Key = pid.
+  const projectDraftsRef = useRef<Record<string, string>>({});
+  const prevFocusedPidRef = useRef<string>('');
+  // Ref-Bruecke, damit der frueh deklarierte RVS-Message-Handler den erst spaeter
+  // deklarierten Queue-Automaten aufrufen kann (ohne TDZ / stale Closure).
+  const queueApiRef = useRef<{
+    getCtxState: (pid: string) => CtxState;
+    setCtxState: (pid: string, s: CtxState) => void;
+    advanceQueue: (pid: string) => void;
+  } | null>(null);
   const [searchIndex, setSearchIndex] = useState(0);  // welcher Treffer aktiv ist
   const [pendingAttachments, setPendingAttachments] = useState<{file: any, isPhoto: boolean}[]>([]);
   const [agentActivity, setAgentActivity] = useState<{activity: string, tool: string}>({activity: 'idle', tool: ''});
@@ -338,6 +365,10 @@ const ChatScreen: React.FC = () => {
   // bliebe canPlay auf dem Mount-Initial-Wert haengen (mute ignoriert,
   // oder AsyncStorage-Load nicht beruecksichtigt).
   const ttsCanPlayRef = useRef<boolean>(true);
+  // Letzte Antwort: nach dem Vorlesen 30s weiterlauschen (Gespraech) oder direkt
+  // stoppen? Kommt als 'converse' in der Chat-Payload; onPlaybackFinished liest
+  // es. Default true (Konversation). false = Einzelaktion/Skill-Antwort.
+  const converseRef = useRef<boolean>(true);
 
   const flatListRef = useRef<FlatList>(null);
   const messageIdCounter = useRef(0);
@@ -505,14 +536,39 @@ const ChatScreen: React.FC = () => {
     return () => unsub();
   }, []);
 
-  // Focus in Storage spiegeln damit der letzte Kontext nach Neustart wieder
+  // Focus in Storage spiegeln + Pro-Projekt-Textfeld-Entwuerfe wechseln.
-  // da ist. Kein zwingender UX-Fix (Default = Hauptchat waere auch ok), aber
-  // fuer den Auto-Fall angenehm.
   useEffect(() => {
     AsyncStorage.setItem('aria_focused_project_id', focusedProjectId).catch(() => {});
     focusedProjectIdRef.current = focusedProjectId;
+    // Draft-Wechsel: der aktuelle Feldinhalt gehoert dem VERLASSENEN Projekt,
+    // der Entwurf des neuen Projekts wird geladen (leer = leeres Feld).
+    const prevPid = prevFocusedPidRef.current;
+    if (prevPid !== focusedProjectId) {
+      projectDraftsRef.current = { ...projectDraftsRef.current, [prevPid]: inputTextRef.current };
+      setInputText(projectDraftsRef.current[focusedProjectId] || '');
+      prevFocusedPidRef.current = focusedProjectId;
+      AsyncStorage.setItem('aria_project_drafts', JSON.stringify(projectDraftsRef.current)).catch(() => {});
+    }
   }, [focusedProjectId]);
 
+  // inputText-Spiegel (damit der Draft-Wechsel oben inputText nicht als Dep braucht).
+  useEffect(() => { inputTextRef.current = inputText; }, [inputText]);
+
+  // Drafts beim Start aus Storage laden.
+  useEffect(() => {
+    AsyncStorage.getItem('aria_project_drafts').then(v => {
+      if (!v) return;
+      try {
+        const map = JSON.parse(v);
+        if (map && typeof map === 'object') {
+          projectDraftsRef.current = map;
+          const cur = map[focusedProjectIdRef.current] || '';
+          if (cur) setInputText(cur);
+        }
+      } catch {}
+    }).catch(() => {});
+  }, []);
+
   // Ref-Spiegel damit useCallback-Handler die aktuelle Focus-ID lesen
   // ohne dass wir die Deps in jedes Callback muessen (sonst re-createn
   // die sich bei jedem Wechsel).
@@ -562,6 +618,14 @@ const ChatScreen: React.FC = () => {
   // Wake Word: einmalig laden + Porcupine vorbereiten (wenn Access Key gesetzt)
   useEffect(() => {
     wakeWordService.loadFromStorage().catch(() => {});
+    // Mikro-Release-Hook: vor jedem Re-Arm eine laufende (passive) Streaming-
+    // Aufnahme canceln, sonst haelt sie das Mikro und OpenWakeWord.start()
+    // schlaegt fehl → Ohr bleibt ausgegraut (state=off).
+    wakeWordService.setMicReleaseHook(async () => {
+      if (audioService.isStreamingRecording()) {
+        await audioService.cancelStreamingRecording('rearm-mic-free');
+      }
+    });
     const unsub = wakeWordService.onStateChange((s) => {
       setWakeWordState(s);
       setWakeWordActive(s !== 'off');
@@ -982,6 +1046,7 @@ const ChatScreen: React.FC = () => {
       // file_from_aria: ARIA hat eine Datei rausgegeben → als ARIA-Bubble anzeigen
       if (message.type === 'file_from_aria') {
         const p = message.payload || {};
+        const sp = (p.serverPath as string) || '';
         const ariaMsg: ChatMessage = {
           id: nextId(),
           sender: 'aria',
@@ -992,10 +1057,20 @@ const ChatScreen: React.FC = () => {
             name: (p.name as string) || 'datei',
             size: (p.size as number) || 0,
             mimeType: (p.mimeType as string) || '',
-            serverPath: (p.serverPath as string) || '',
+            serverPath: sp,
           }],
         };
-        setMessages(prev => capMessages([...prev, ariaMsg]));
+        setMessages(prev => {
+          // Falls die Chat-Bubble mit dieser Datei schon da ist (Event-Reihen-
+          // folge kann variieren, und die chat-Payload traegt die files jetzt
+          // selbst), keine doppelte Solo-Bubble anlegen.
+          if (sp && prev.some(m =>
+            m.sender === 'aria' && m.attachments?.some(a => a.serverPath === sp)
+          )) {
+            return prev;
+          }
+          return capMessages([...prev, ariaMsg]);
+        });
         return;
       }
 
@@ -1144,26 +1219,53 @@ const ChatScreen: React.FC = () => {
 
         const text = (message.payload.text as string) || '';
         const ts = message.timestamp;
+        // ARIA-Dateien, die DIREKT an dieser Chat-Bubble haengen (Bridge schickt
+        // sie jetzt in der chat-Payload mit — vorher kamen sie nur als separates
+        // file_from_aria-Event, wodurch der Anhang live nicht an der Nachricht
+        // erschien, sondern erst nach einem Seitenwechsel/Reload).
+        const incomingFiles = Array.isArray((message.payload as any).files)
+          ? (message.payload as any).files as Array<any> : [];
+        const fileAttachments: Attachment[] = incomingFiles.map(f => ({
+          type: (typeof f.mimeType === 'string' && f.mimeType.startsWith('image/')) ? 'image' : 'file',
+          name: f.name || 'datei',
+          size: f.size || 0,
+          mimeType: f.mimeType || '',
+          serverPath: f.serverPath || '',
+        }));
+        const incomingPaths = new Set(
+          fileAttachments.map(a => a.serverPath).filter(Boolean) as string[]
+        );
         // Duplikat-Schutz: gleicher Text innerhalb 5s ignorieren
         setMessages(prev => {
           const isDuplicate = prev.some(m =>
             m.sender === 'aria' && m.text === text && Math.abs(m.timestamp - ts) < 5000
           );
           if (isDuplicate) return prev;
+          const payloadAtts = (message.payload.attachments as Attachment[] | undefined) || [];
+          const mergedAtts = [...payloadAtts, ...fileAttachments];
           const ariaMsg: ChatMessage = {
             id: nextId(),
             sender: 'aria',
             text,
             timestamp: ts,
-            attachments: message.payload.attachments as Attachment[] | undefined,
+            attachments: mergedAtts.length ? mergedAtts : undefined,
             messageId: (message.payload.messageId as string) || undefined,
             backupTs: (message.payload.backupTs as number) || undefined,
             projectId: ((message.payload as any).projectId as string) || '',
             answeredBy: ((message.payload as any).answeredBy as string) || '',
           };
+          // Die separate file_from_aria-Bubble (leerer Text, nur Datei), die kurz
+          // zuvor fuer DIESE Datei ankam, entfernen — sonst doppelt (einmal solo,
+          // einmal an der Text-Bubble). Nur solche mit passendem serverPath.
+          const deduped = incomingPaths.size
+            ? prev.filter(m => !(
+                m.sender === 'aria' && !m.text && (m.attachments?.length) &&
+                m.attachments.every(a => a.serverPath && incomingPaths.has(a.serverPath))
+              ))
+            : prev;
           // ARIA hat geantwortet → alle User-Bubbles davor als 'delivered'
           // markieren (WhatsApp-Doppelhaken ✓✓). Brain hat sie verarbeitet.
-          return capMessages([...prev, ariaMsg]).map(m =>
+          return capMessages([...deduped, ariaMsg]).map(m =>
             m.sender === 'user'
               && (m.deliveryStatus === 'sent' || m.deliveryStatus === 'sending')
               ? { ...m, deliveryStatus: 'delivered' }
@@ -1186,6 +1288,18 @@ const ChatScreen: React.FC = () => {
               : prev);
           setAgentActivity(cur =>
             cur.activity === 'idle' ? cur : { activity: 'idle', tool: '' });
+          // ── Pro-Projekt-Queue-Automat: auf ARIAs Antwort reagieren ──
+          const awaiting = !!(message.payload as any).awaiting_reply;
+          const qapi = queueApiRef.current;
+          if (qapi) {
+            const st = qapi.getCtxState(ansPid);
+            // Nur reagieren, wenn wir fuer diesen Kontext wirklich auf eine
+            // Antwort warten (nicht bei unaufgeforderten Trigger-Nachrichten).
+            if (st === 'running' || st === 'awaiting_reply') {
+              if (awaiting) qapi.setCtxState(ansPid, 'awaiting_reply');
+              else qapi.advanceQueue(ansPid);
+            }
+          }
         }
         // ALLE noch laufenden ACK-Timer clearen — Bridge hat unsere Messages
         // ja offensichtlich verarbeitet (sonst keine ARIA-Antwort). Wenn
@@ -1195,6 +1309,26 @@ const ChatScreen: React.FC = () => {
           clearAckTimer(cmid);
           pendingPayloads.current.delete(cmid);
         }
+        // Stille Antwort (speak=false, z.B. Fast-Path „nächster Titel") → es
+        // kommt KEIN TTS, also feuert onPlaybackFinished nie. Genau daran haengt
+        // aber das Wake-Word-Re-Arm — sonst bleibt das Ohr nach dem Steuerbefehl
+        // grau haengen (Reproduktion Stefan im Auto). Hier dieselbe Logik wie
+        // bei TTS-Ende anstossen: aktiv → Konversations-Fenster (resume),
+        // sonst → Konversation beenden (re-arm).
+        // Stumm = die Bridge sagt speak=false (Steuerbefehl-Skill via Fast-Path
+        // ODER local). Ein Antwort-Skill (speak=true) faellt NICHT hierunter —
+        // der wird vorgelesen + haelt das Gespraech offen. Kein answeredBy-
+        // Fallback mehr: die Bridge schickt speak zuverlaessig mit.
+        // Merken ob nach dem Vorlesen 30s weiterlauschen (Gespraech) oder direkt
+        // stoppen — onPlaybackFinished liest converseRef. Default true.
+        converseRef.current = (message.payload as any).converse !== false;
+        const _isSilent = (message.payload as any).speak === false;
+        if (_isSilent && wakeWordService.isConversing()) {
+          // Klarer Steuerbefehl (Liedersteuerung etc.) = KEINE Konversation →
+          // STOP: direkt zurueck aufs Wake-Word. Kein Gong, keine Aufnahme,
+          // kein 30s-Fenster (skipPassive=true).
+          wakeWordService.endConversation(true).catch(() => {});
+        }
       }
 
       // TTS-Audio abspielen wenn vorhanden — respektiert geraetelokalen Mute/Disable
@@ -1423,12 +1557,13 @@ const ChatScreen: React.FC = () => {
   useEffect(() => {
     const unsubPlayback = audioService.onPlaybackFinished(() => {
       if (!wakeWordService.isActive()) return;
-      if (AppState.currentState === 'active') {
+      // Gespraech (gesprochene Antwort): KEIN neuer Gong / kein Aufnahme-Fenster,
-        wakeWordService.resume();
+      // sondern direkt passives Lauschen (30s weiterreden wie mit einem Menschen).
-      } else {
+      // Im Hintergrund gibt's kein Multi-Turn → direkt re-armen (skipPassive).
-        console.log('[Chat] TTS fertig im Background → endConversation (kein Multi-Turn)');
+      // converse=false (Skill-/Einzelantwort, z.B. 'was laeuft gerade') → auch
-        wakeWordService.endConversation().catch(() => {});
+      // ohne 30s: vorlesen + direkt zurueck aufs Wake-Word.
-      }
+      const bg = AppState.currentState !== 'active';
+      wakeWordService.endConversation(bg || !converseRef.current).catch(() => {});
     });
     return () => unsubPlayback();
   }, []);
@@ -1465,7 +1600,7 @@ const ChatScreen: React.FC = () => {
         interrupted: wasInterrupted,
         location: location || null,
         noSpeechTimeoutMs: windowMs,
-        endpointMs: 1500,
+        endpointMs: await loadSttEndpointMs(),
         hardCapMs: 60000,
         projectId: focusedProjectIdRef.current,
       });
@@ -1504,9 +1639,15 @@ const ChatScreen: React.FC = () => {
       } else {
         // Kein Speech im Window → Konversation beenden
         console.log('[Chat] STT-Endpoint ohne Text (reason=%s) — endConversation', ev.reason);
-        // Placeholder-Bubble wieder weg
+        // NUR den noch UNAUFGELOESTEN Platzhalter entfernen. Nach manuellem Stop
+        // klappt oft ein zweites, LEERES stream_end-Endpoint nach (das Audio war
+        // schon vom echten Endpoint transkribiert) — das darf die bereits mit
+        // dem STT-Text gefuellte Bubble NICHT loeschen, sonst verschwindet die
+        // Sprachnachricht obwohl ARIA schon an der Antwort arbeitet.
         if (ev.audioRequestId) {
-          setMessages(prev => prev.filter(m => m.audioRequestId !== ev.audioRequestId));
+          setMessages(prev => prev.filter(m =>
+            !(m.audioRequestId === ev.audioRequestId
+              && m.text.includes('Spracheingabe wird verarbeitet'))));
         }
         // Bei Passive-Listen + speaker_mismatch oder no-speech: erneut passiv
         // lauschen (Timer im wakeword-service laeuft weiter, regelt das Ende).
@@ -1561,7 +1702,7 @@ const ChatScreen: React.FC = () => {
         interrupted: true,   // Barge-In → Brain weiss "User hat unterbrochen"
         location: location || null,
         noSpeechTimeoutMs: windowMs,
-        endpointMs: 1500,
+        endpointMs: await loadSttEndpointMs(),
         hardCapMs: 60000,
         projectId: focusedProjectIdRef.current,
       });
@@ -1618,7 +1759,7 @@ const ChatScreen: React.FC = () => {
       interrupted: false,
       location: location || null,
       noSpeechTimeoutMs: Math.min(passiveMs, 30000),
-      endpointMs: 1500,
+      endpointMs: await loadSttEndpointMs(),
       hardCapMs: Math.max(passiveMs + 5000, 35000),
       projectId: focusedProjectIdRef.current,
     });
@@ -1895,6 +2036,65 @@ const ChatScreen: React.FC = () => {
 
   // --- Nachricht senden ---
 
+  // ── Pro-Projekt-Queue: Zustands-Helfer ──────────────────────────
+  const getCtxState = useCallback((pid: string): CtxState =>
+    projectStatesRef.current[pid] || 'idle', []);
+
+  const setCtxState = useCallback((pid: string, s: CtxState) => {
+    projectStatesRef.current = { ...projectStatesRef.current, [pid]: s };
+    setProjectStates(prev => ({ ...prev, [pid]: s }));
+  }, []);
+
+  const setCtxQueue = useCallback((pid: string, items: QueuedItem[]) => {
+    projectQueuesRef.current = { ...projectQueuesRef.current, [pid]: items };
+    setProjectQueues(prev => ({ ...prev, [pid]: items }));
+  }, []);
+
+  // Sendet eine Nachricht WIRKLICH (Location holen + dispatchWithAck) und setzt
+  // den Kontext auf 'running'. existingId gesetzt = eine bereits als pending_queue
+  // angezeigte Bubble wird auf 'sending' gehoben (Dequeue), sonst neue Bubble.
+  const actuallySend = useCallback(async (pid: string, text: string, existingId?: string) => {
+    const cmid = nextClientMsgId();
+    const location = await getCurrentLocation();
+    const status: ChatMessage['deliveryStatus'] =
+      connectionStateRef.current === 'connected' ? 'sending' : 'queued';
+    if (existingId) {
+      setMessages(prev => prev.map(m =>
+        m.id === existingId ? { ...m, clientMsgId: cmid, deliveryStatus: status, sendAttempts: 1 } : m));
+    } else {
+      setMessages(prev => capMessages([...prev, {
+        id: nextId(), sender: 'user', text, timestamp: Date.now(),
+        clientMsgId: cmid, deliveryStatus: status, sendAttempts: 1, projectId: pid,
+      }]));
+    }
+    setCtxState(pid, 'running');
+    dispatchWithAck(cmid, 'chat', {
+      text, voice: localXttsVoiceRef.current, speed: ttsSpeedRef.current,
+      projectId: pid, ...(location && { location }),
+    });
+  }, [getCurrentLocation, dispatchWithAck, setCtxState]);
+
+  // Naechsten Queue-Eintrag von pid abarbeiten (falls vorhanden), sonst idle.
+  const advanceQueue = useCallback((pid: string) => {
+    const q = projectQueuesRef.current[pid] || [];
+    if (q.length === 0) { setCtxState(pid, 'idle'); return; }
+    const [next, ...rest] = q;
+    setCtxQueue(pid, rest);
+    actuallySend(pid, next.text, next.id);
+  }, [actuallySend, setCtxQueue, setCtxState]);
+
+  // Einen wartenden Eintrag aus der Queue entfernen (User tippt auf ✕).
+  const removeQueued = useCallback((pid: string, id: string) => {
+    setCtxQueue(pid, (projectQueuesRef.current[pid] || []).filter(it => it.id !== id));
+    setMessages(prev => prev.filter(m => m.id !== id));
+  }, [setCtxQueue]);
+
+  // Ref-Bruecke fuellen, damit der frueh deklarierte Message-Handler den Automaten
+  // erreicht (ohne TDZ / stale Closure).
+  useEffect(() => {
+    queueApiRef.current = { getCtxState, setCtxState, advanceQueue };
+  }, [getCtxState, setCtxState, advanceQueue]);
+
   // Aufraeumen von "verarbeitet"-Placeholder die nie ein STT-Result bekommen
   // haben (leere Aufnahme, Wake-Word-Echo, STT-Fehler etc). Timeout skaliert
   // mit der Aufnahmedauer — Whisper braucht auf der Gamebox grob real-time/5,
@@ -1918,49 +2118,6 @@ const ChatScreen: React.FC = () => {
     }, timeoutMs);
   }, []);
 
-  const sendTextMessage = useCallback(async () => {
-    const text = inputText.trim();
-
-    // Wenn pending Anhaenge vorhanden → Anhaenge + Text zusammen senden
-    if (pendingAttachments.length > 0) {
-      sendPendingAttachments(text);
-      return;
-    }
-
-    if (!text) return;
-
-    setInputText('');
-
-    // Barge-In: laufende ARIA-Aktivitaet abbrechen wenn welche da ist.
-    const wasInterrupted = interruptAriaIfBusy();
-    const location = await getCurrentLocation();
-
-    const cmid = nextClientMsgId();
-    const activePid = focusedProjectIdRef.current;
-    const userMsg: ChatMessage = {
-      id: nextId(),
-      sender: 'user',
-      text,
-      timestamp: Date.now(),
-      clientMsgId: cmid,
-      deliveryStatus: connectionStateRef.current === 'connected' ? 'sending' : 'queued',
-      sendAttempts: 1,
-      projectId: activePid,
-    };
-    setMessages(prev => capMessages([...prev, userMsg]));
-
-    console.log('[Chat] sende cmid=%s voice=%s speed=%s interrupted=%s project=%s',
-                cmid, localXttsVoiceRef.current || '(default)', ttsSpeedRef.current, wasInterrupted, activePid || '(main)');
-    dispatchWithAck(cmid, 'chat', {
-      text,
-      voice: localXttsVoiceRef.current,
-      speed: ttsSpeedRef.current,
-      interrupted: wasInterrupted,
-      projectId: activePid,
-      ...(location && { location }),
-    });
-  }, [inputText, getCurrentLocation, pendingAttachments, sendPendingAttachments, interruptAriaIfBusy, dispatchWithAck]);
-
   // Anfrage abbrechen — nur den fokussierten Kontext (kontext-scoped Cancel).
   const cancelRequest = useCallback(() => {
     const pid = focusedProjectIdRef.current || '';
@@ -1968,34 +2125,22 @@ const ChatScreen: React.FC = () => {
     setAgentActivityByCtx(prev => ({ ...prev, [pid]: { activity: 'idle', tool: '' } }));
     clearStuckWatchdog();
     rvs.send('cancel_request' as any, { projectId: pid });
-  }, []);
+    // Aktuellen Task abgebrochen → naechsten Queue-Eintrag dieses Projekts
+    // starten (oder idle, wenn leer). Wartende Eintraege einzeln loeschbar.
+    advanceQueue(pid);
+  }, [advanceQueue]);
 
-  // Barge-In: wenn der User waehrend ARIA arbeitet/spricht eine neue Sprach-
+  // Queue-Modus („immer anstellen"): eine neue Sprachnachricht bricht ARIAs
-  // Nachricht aufnimmt, alte Aktivitaet sofort abbrechen — TTS verstummen,
+  // laufende Arbeit NICHT mehr ab. Sie wird — wie Text — angestellt und laeuft
-  // aria-core-Run via cancel_request abbrechen. So kann man "ach vergiss es,
+  // serialisiert (der Brain-Lock pro Projekt reiht /chat-/audio-Turns auf).
-  // mach lieber X" sagen wie in einem echten Gespraech.
+  // Nur das TTS wird akustisch gestoppt, damit das Mikro ARIAs eigene Stimme
+  // nicht mithoert. Explizites Abbrechen laeuft ueber den Stop-Button
+  // (cancelRequest). Rueckgabe = false, weil kein Barge-In/Interrupt mehr.
   const interruptAriaIfBusy = useCallback(() => {
-    const speaking = audioService.isPlayingAudio();
+    if (audioService.isPlayingAudio()) {
-    // Multi-Threading: NUR den fokussierten Kontext als "busy" werten — nicht
+      audioService.haltAllPlayback('user startet Aufnahme (Queue-Modus, kein Abbruch)');
-    // global. Sonst bricht eine Nachricht im Hauptchat die parallele Arbeit in
-    // einem Projekt ab (bzw. wird faelschlich als Barge-In behandelt und die
-    // eigene Anfrage geht unter). Der Busy-Status kommt kontextgenau aus
-    // /projects/queue-status (queueStatusRef). agentActivity ist global und
-    // taugt dafuer nicht.
-    const pid = focusedProjectIdRef.current || '';
-    const focusKey = pid || '__main__';
-    const focusBusy = !!queueStatusRef.current?.[focusKey]?.busy;
-    if (!speaking && !focusBusy) return false;
-    console.log('[Chat] Barge-In: speaking=%s focusBusy=%s (ctx=%s) — interrupting',
-                speaking, focusBusy, focusKey);
-    // TTS immer stoppen wenn ARIA gerade spricht — egal welcher Kontext.
-    if (speaking) audioService.haltAllPlayback('user spricht (barge-in)');
-    // Brain-Arbeit nur abbrechen wenn GENAU dieser Kontext arbeitet.
-    if (focusBusy) {
-      clearStuckWatchdog();
-      rvs.send('cancel_request' as any, { projectId: pid });
     }
-    return true;
+    return false;
   }, []);
 
   // Manueller Aufnahme-Knopf (VoiceButton) — Start.
@@ -2028,7 +2173,7 @@ const ChatScreen: React.FC = () => {
       // Stoppen). Hard-Cap 5 Minuten als Notbremse — danach killt Whisper
       // die Session auch app-seitig haben wir +2s Toleranz.
       noSpeechTimeoutMs: 0,
-      endpointMs: 1500,
+      endpointMs: await loadSttEndpointMs(),
       hardCapMs: 300000,
       projectId: focusedProjectIdRef.current,
     });
@@ -2046,10 +2191,20 @@ const ChatScreen: React.FC = () => {
   // forwarded direkt an Brain. Im wake-word-conversing-Fall zusaetzlich
   // endConversation: User hat explizit gestoppt → kein Multi-Turn-Resume.
   const handleVoiceButtonStop = useCallback(async (): Promise<void> => {
+    // Stop WAEHREND des passiven 30s-Lauschens ('listening'): sauber beenden
+    // (zurueck aufs Wake-Word), NICHT den passiven Stream neu starten.
+    // exitPassiveListening cancelt den Stream selbst (via _freeMic) → es feuert
+    // kein leeres Endpoint, das startPassiveStreamingRecording erneut ausloest
+    // (genau das liess die 30s vorher von vorne loslaufen).
+    if (wakeWordService.getState() === 'listening') {
+      console.log('[Chat] Manueller Stop im Passiv-Lauschen → exitPassiveListening (Ende)');
+      await wakeWordService.exitPassiveListening('manual');
+      return;
+    }
     await audioService.stopStreamingRecording('user');
     if (wakeWordService.isConversing()) {
       console.log('[Chat] Manueller Stop in Konversation → endConversation, zurueck zu armed');
-      await wakeWordService.endConversation();
+      await wakeWordService.endConversation(true);  // explizit gestoppt → STOP (kein 30s-Passiv)
     }
   }, []);
 
@@ -2157,6 +2312,53 @@ const ChatScreen: React.FC = () => {
     setInputText('');
   }, [pendingAttachments, getCurrentLocation, dispatchWithAck]);
 
+  // Reine Text-Nachricht senden. Steht bewusst NACH interruptAriaIfBusy und
+  // sendPendingAttachments — beide stehen in seinem deps-Array, und wenn es
+  // davor deklariert waere, laendeten sie dort in der Temporal Dead Zone
+  // (tsc TS2448/2454; lief nur zufaellig, weil Babel const→var hebt).
+  const sendTextMessage = useCallback(async () => {
+    const text = inputText.trim();
+
+    // Wenn pending Anhaenge vorhanden → Anhaenge + Text zusammen senden
+    if (pendingAttachments.length > 0) {
+      sendPendingAttachments(text);
+      return;
+    }
+
+    if (!text) return;
+
+    const activePid = focusedProjectIdRef.current;
+    setInputText('');
+    // Draft dieses Projekts leeren (wurde ja gerade abgeschickt/angestellt).
+    projectDraftsRef.current = { ...projectDraftsRef.current, [activePid]: '' };
+
+    const focusKey = activePid || '__main__';
+    const brainBusy = !!queueStatusRef.current?.[focusKey]?.busy;
+    let state = getCtxState(activePid);
+    // Fallback: ein per SPRACHE gestarteter Turn streamt live und setzt den
+    // App-State nicht — aber der Brain meldet busy. Dann Kontext als 'running'
+    // behandeln (anstellen; die spaetere Antwort schaltet die Queue weiter).
+    if (state === 'idle' && brainBusy) { setCtxState(activePid, 'running'); state = 'running'; }
+    if (state === 'running') {
+      // ARIA arbeitet noch am aktuellen Task → ANSTELLEN statt abbrechen.
+      // Sichtbare pending_queue-Bubble; laeuft der Reihe nach, wenn der
+      // aktuelle Task (und ggf. seine Rueckfragen) fertig ist.
+      const id = nextId();
+      setMessages(prev => capMessages([...prev, {
+        id, sender: 'user', text, timestamp: Date.now(),
+        projectId: activePid, deliveryStatus: 'pending_queue',
+      }]));
+      setCtxQueue(activePid, [...(projectQueuesRef.current[activePid] || []), { id, text }]);
+      console.log('[Chat] angestellt (queue) project=%s len=%d', activePid || '(main)',
+                  (projectQueuesRef.current[activePid] || []).length);
+    } else {
+      // idle ODER awaiting_reply → sofort senden. Bei awaiting_reply ist DAS die
+      // Antwort auf ARIAs Rueckfrage (normaler Turn in diesem Projekt).
+      console.log('[Chat] sende sofort (state=%s) project=%s', state, activePid || '(main)');
+      actuallySend(activePid, text);
+    }
+  }, [inputText, pendingAttachments, sendPendingAttachments, getCtxState, setCtxState, setCtxQueue, actuallySend]);
+
   // --- Rendering ---
 
   const renderMessage = ({ item }: { item: ChatMessage }) => {
@@ -2455,7 +2657,16 @@ const ChatScreen: React.FC = () => {
             </TouchableOpacity>
           ) : null}
           {isUser && item.deliveryStatus ? (
-            item.deliveryStatus === 'failed' && item.clientMsgId ? (
+            item.deliveryStatus === 'pending_queue' ? (
+              // Wartet in der Projekt-Queue → tippen entfernt den Eintrag.
+              <TouchableOpacity
+                hitSlop={{top:6,bottom:6,left:6,right:6}}
+                onPress={() => removeQueued(item.projectId || '', item.id)}
+                accessibilityLabel="Aus Warteschlange entfernen"
+              >
+                <Text style={styles.statusQueued}>{'⏸ wartet · ✕'}</Text>
+              </TouchableOpacity>
+            ) : item.deliveryStatus === 'failed' && item.clientMsgId ? (
               <TouchableOpacity
                 hitSlop={{top:6,bottom:6,left:6,right:6}}
                 onPress={() => retryFailedMessage(item.clientMsgId!)}
@@ -2878,6 +3089,18 @@ const ChatScreen: React.FC = () => {
         </TouchableOpacity>
       )}
 
+      {/* Rueckfrage-Banner / Queue-Zaehler fuer den fokussierten Kontext */}
+      {(projectStates[focusedProjectId] === 'awaiting_reply' ||
+        (projectQueues[focusedProjectId]?.length || 0) > 0) && (
+        <View style={styles.queueBanner}>
+          <Text style={styles.queueBannerText}>
+            {projectStates[focusedProjectId] === 'awaiting_reply'
+              ? '❓ ARIA fragt nach — deine Eingabe beantwortet das'
+              : `⏸ ${projectQueues[focusedProjectId]?.length || 0} in der Warteschlange`}
+          </Text>
+        </View>
+      )}
+
       {/* Eingabebereich */}
       <View style={styles.inputContainer}>
         {/* Datei-Buttons */}
@@ -3375,6 +3598,19 @@ const styles = StyleSheet.create({
     fontSize: 14,
     marginTop: 4,
   },
+  queueBanner: {
+    paddingHorizontal: 12,
+    paddingVertical: 6,
+    backgroundColor: '#2A2410',
+    borderTopWidth: 1,
+    borderTopColor: '#4A3F14',
+  },
+  queueBannerText: {
+    color: '#FFD60A',
+    fontSize: 13,
+    fontWeight: '600',
+    textAlign: 'center',
+  },
   inputContainer: {
     flexDirection: 'row',
     alignItems: 'flex-end',

android/src/screens/SettingsScreen.tsx

@@ -105,6 +105,14 @@ import wakeWordService, {
   KEYWORD_LABELS,
   DEFAULT_KEYWORD,
   WAKE_KEYWORD_STORAGE,
+  WAKE_THRESHOLD_DEFAULT,
+  WAKE_THRESHOLD_MIN,
+  WAKE_THRESHOLD_MAX,
+  loadWakeThreshold,
+  saveWakeThreshold,
+  PASSIVE_LISTEN_DEFAULT_MS,
+  loadPassiveListenMs,
+  savePassiveListenMs,
 } from '../services/wakeword';
 import ModeSelector from '../components/ModeSelector';
 import QRScanner from '../components/QRScanner';
@@ -200,6 +208,8 @@ const SettingsScreen: React.FC = () => {
   const [wakeKeyword, setWakeKeyword] = useState<string>(DEFAULT_KEYWORD);
   const [wakeStatus, setWakeStatus] = useState<string>('');
   const [wakeReadySound, setWakeReadySound] = useState<boolean>(true);
+  const [wakeThreshold, setWakeThreshold] = useState<number>(WAKE_THRESHOLD_DEFAULT);
+  const [passiveSec, setPassiveSec] = useState<number>(Math.round(PASSIVE_LISTEN_DEFAULT_MS / 1000));
   const [editingPath, setEditingPath] = useState(false);
   const [xttsVoice, setXttsVoice] = useState('');
   const [loadingVoice, setLoadingVoice] = useState<string | null>(null);
@@ -322,6 +332,8 @@ const SettingsScreen: React.FC = () => {
       if (saved && (WAKE_KEYWORDS as readonly string[]).includes(saved)) setWakeKeyword(saved);
     });
     isWakeReadySoundEnabled().then(setWakeReadySound);
+    loadWakeThreshold().then(setWakeThreshold).catch(() => {});
+    loadPassiveListenMs().then(ms => setPassiveSec(Math.round(ms / 1000))).catch(() => {});
     updateService.getApkCacheSize().then(setApkCacheInfo).catch(() => {});
     audioService.getTtsCacheSize().then(setTtsCacheInfo).catch(() => {});
     AsyncStorage.getItem('aria_xtts_voice').then(saved => {
@@ -1862,6 +1874,40 @@ const SettingsScreen: React.FC = () => {
           ))}
         </View>
 
+        <Text style={[styles.toggleLabel, {marginTop: 20}]}>Empfindlichkeit</Text>
+        <Text style={styles.toggleHint}>
+          Wie leicht das Wake-Word anspringt. Hoeher = strenger = weniger
+          Fehlauslösung (z.B. durch Musik/Radio, die das Mikro mithoert — der
+          Echo-Canceler kann nur ARIAs eigene Stimme rausrechnen, nicht Spotify),
+          aber du musst evtl. deutlicher sprechen. Default: {WAKE_THRESHOLD_DEFAULT.toFixed(2)}.
+          Wird beim „Speichern + Aktivieren" uebernommen.
+        </Text>
+        <View style={styles.prerollRow}>
+          <TouchableOpacity
+            style={styles.prerollButton}
+            onPress={() => {
+              const next = Math.max(WAKE_THRESHOLD_MIN, Math.round((wakeThreshold - 0.05) * 100) / 100);
+              setWakeThreshold(next);
+              saveWakeThreshold(next);
+            }}
+            disabled={wakeThreshold <= WAKE_THRESHOLD_MIN}
+          >
+            <Text style={styles.prerollButtonText}>−0.05</Text>
+          </TouchableOpacity>
+          <Text style={styles.prerollValue}>{wakeThreshold.toFixed(2)}</Text>
+          <TouchableOpacity
+            style={styles.prerollButton}
+            onPress={() => {
+              const next = Math.min(WAKE_THRESHOLD_MAX, Math.round((wakeThreshold + 0.05) * 100) / 100);
+              setWakeThreshold(next);
+              saveWakeThreshold(next);
+            }}
+            disabled={wakeThreshold >= WAKE_THRESHOLD_MAX}
+          >
+            <Text style={styles.prerollButtonText}>+0.05</Text>
+          </TouchableOpacity>
+        </View>
+
         <View style={{flexDirection: 'row', gap: 8, marginTop: 16, alignItems: 'center'}}>
           <TouchableOpacity
             style={[styles.connectButton, {flex: 1}]}
@@ -1907,6 +1953,39 @@ const SettingsScreen: React.FC = () => {
             thumbColor={wakeReadySound ? '#FFFFFF' : '#666680'}
           />
         </View>
+
+        <Text style={[styles.toggleLabel, {marginTop: 20}]}>Weiterreden-Fenster (Gespraech)</Text>
+        <Text style={styles.toggleHint}>
+          Nach einer gesprochenen ARIA-Antwort kannst du so lange einfach
+          weiterreden — ohne Wake-Word — bevor zurueck aufs Wake-Word geschaltet
+          wird. Reine Steuerbefehle (z.B. „nächster Titel") beenden sofort.
+          Default: {Math.round(PASSIVE_LISTEN_DEFAULT_MS / 1000)}s.
+        </Text>
+        <View style={styles.prerollRow}>
+          <TouchableOpacity
+            style={styles.prerollButton}
+            onPress={() => {
+              const next = Math.max(10, passiveSec - 5);
+              setPassiveSec(next);
+              savePassiveListenMs(next * 1000);
+            }}
+            disabled={passiveSec <= 10}
+          >
+            <Text style={styles.prerollButtonText}>−5</Text>
+          </TouchableOpacity>
+          <Text style={styles.prerollValue}>{passiveSec} s</Text>
+          <TouchableOpacity
+            style={styles.prerollButton}
+            onPress={() => {
+              const next = Math.min(60, passiveSec + 5);
+              setPassiveSec(next);
+              savePassiveListenMs(next * 1000);
+            }}
+            disabled={passiveSec >= 60}
+          >
+            <Text style={styles.prerollButtonText}>+5</Text>
+          </TouchableOpacity>
+        </View>
       </View>
       </>)}
 

android/src/services/audio.ts

@@ -151,6 +151,26 @@ export const CONV_WINDOW_MIN_SEC = 3.0;
 export const CONV_WINDOW_MAX_SEC = 20.0;
 export const CONV_WINDOW_STORAGE_KEY = 'aria_conv_window_sec';
 
+// STT-Endpoint (ms Stille bis "fertig gesprochen"). Zu kurz = schneidet mitten
+// im Satz ab, besonders im Auto wo man mit Pausen spricht (Reproduktion: die
+// 11.8s-Frage wurde bei "…ohne dass ein" gekappt). 1500 war zu aggressiv;
+// 2400 default, im Auto ggf. hoeher. Konfigurierbar in den Settings.
+export const STT_ENDPOINT_DEFAULT_MS = 2400;
+export const STT_ENDPOINT_MIN_MS = 1000;
+export const STT_ENDPOINT_MAX_MS = 4000;
+export const STT_ENDPOINT_STORAGE_KEY = 'aria_stt_endpoint_ms';
+
+export async function loadSttEndpointMs(): Promise<number> {
+  try {
+    const raw = await AsyncStorage.getItem(STT_ENDPOINT_STORAGE_KEY);
+    if (raw != null) {
+      const n = parseInt(raw, 10);
+      if (isFinite(n) && n >= STT_ENDPOINT_MIN_MS && n <= STT_ENDPOINT_MAX_MS) return n;
+    }
+  } catch {}
+  return STT_ENDPOINT_DEFAULT_MS;
+}
+
 // TTS-Wiedergabegeschwindigkeit — wird pro Geraet gespeichert und an die
 // Bridge mitgegeben (speed-Param im F5-TTS infer()). 1.0 = normal.
 export const TTS_SPEED_DEFAULT = 1.0;
@@ -1711,11 +1731,39 @@ class AudioService {
         this._stoppedMessageId = activeMsgId;
         console.log('[Audio] Antwort %s als gestoppt markiert', activeMsgId);
       }
-      this.stopPlayback();
+      // NUR die hoerbare Wiedergabe stoppen — Cache-Buffer behalten, damit die
+      // Nachricht spaeter ueber das Lautsprecher-Symbol nachgehoert werden kann.
+      this._silenceAudibleOutput();
     }
   }
   isMuted(): boolean { return this._muted; }
 
+  /** Mund-Button: laufendes Vorlesen SOFORT verstummen lassen, aber den
+   *  PCM-Cache NICHT verwerfen (der Stream cached zu Ende → Nachhoeren via
+   *  Lautsprecher-Symbol bleibt moeglich). Unterschied zu stopPlayback():
+   *  - stopt den AudioTrack IMMER (auch wenn pcmStreamActive schon false ist,
+   *    weil der Stream fertig empfangen wurde aber der AudioTrack seinen Buffer
+   *    noch sekundenlang ausspielt — genau da war der Mund-Button wirkungslos),
+   *  - laesst pcmBuffer/pcmMessageId/pcmStreamActive stehen (Cache laeuft weiter). */
+  private _silenceAudibleOutput(): void {
+    console.log('[Audio] _silenceAudibleOutput: AudioTrack+WAV stoppen, Cache behalten');
+    this.audioQueue = [];
+    this.isPlaying = false;
+    if (this.currentSound) {
+      try { this.currentSound.stop(); this.currentSound.release(); } catch {}
+      this.currentSound = null;
+    }
+    if (this.resumeSound) {
+      try { this.resumeSound.stop(); this.resumeSound.release(); } catch {}
+      this.resumeSound = null;
+    }
+    // AudioTrack IMMER hart stoppen (idempotent) — auch im Drain-Fall.
+    PcmStreamPlayer?.stop().catch(() => {});
+    stopBackgroundAudio().catch(() => {});
+    this._cancelDeferredFocusRelease();
+    AudioFocus?.release().catch(() => {});
+  }
+
   /** Laufende Wiedergabe stoppen + Queue leeren */
   stopPlayback(): void {
     // Idempotent: wenn nichts mehr aktiv ist, NICHT noch einen Focus-Release/

android/src/services/wakeword.ts

@@ -53,6 +53,30 @@ export async function savePassiveListenMs(ms: number): Promise<void> {
 
 export const WAKE_KEYWORD_STORAGE = 'aria_wake_keyword';
 
+// Wake-Word-Empfindlichkeit (openWakeWord-Threshold). Hoeher = strenger =
+// weniger Fehlauslösung (z.B. durch Musik/Radio ueber die Auto-Lautsprecher,
+// die das Mikro mithoert — der App-Echo-Canceler kann nur ARIAs eigenes TTS
+// rausrechnen, NICHT Spotify). Default 0.6 (war 0.5). 0..1.
+export const WAKE_THRESHOLD_DEFAULT = 0.6;
+export const WAKE_THRESHOLD_MIN = 0.3;
+export const WAKE_THRESHOLD_MAX = 0.9;
+export const WAKE_THRESHOLD_STORAGE_KEY = 'aria_wake_threshold';
+
+export async function loadWakeThreshold(): Promise<number> {
+  try {
+    const raw = await AsyncStorage.getItem(WAKE_THRESHOLD_STORAGE_KEY);
+    if (raw != null) {
+      const n = parseFloat(raw);
+      if (isFinite(n) && n >= WAKE_THRESHOLD_MIN && n <= WAKE_THRESHOLD_MAX) return n;
+    }
+  } catch {}
+  return WAKE_THRESHOLD_DEFAULT;
+}
+
+export async function saveWakeThreshold(v: number): Promise<void> {
+  await AsyncStorage.setItem(WAKE_THRESHOLD_STORAGE_KEY, String(v));
+}
+
 /** Verfuegbare Wake-Words — entsprechen den .onnx Dateien in
  *  android/app/src/main/assets/openwakeword/. Custom-Keywords (eigenes
  *  Training via openwakeword Notebook) muessen aktuell als Asset eingebaut
@@ -76,8 +100,9 @@ export const KEYWORD_LABELS: Record<WakeKeyword, string> = {
   hey_rhasspy: 'Hey Rhasspy',
 };
 
-// Detection-Tuning — kann in Settings spaeter konfigurierbar werden.
+// Detection-Tuning. Threshold ist ueber die Settings konfigurierbar
-const DEFAULT_THRESHOLD = 0.5;
+// (loadWakeThreshold) — der Wert hier ist nur der Fallback.
+const DEFAULT_THRESHOLD = WAKE_THRESHOLD_DEFAULT;
 const DEFAULT_PATIENCE = 2;
 const DEFAULT_DEBOUNCE_MS = 1500;
 
@@ -132,6 +157,12 @@ class WakeWordService {
    *  hier eine streaming-Aufnahme OHNE User-Bubble (passiv lauschen). */
   private passiveListenCallbacks: PassiveListenCallback[] = [];
 
+  /** Hook, der das Mikro freigibt (laufende Streaming-Aufnahme canceln) BEVOR
+   *  wir OpenWakeWord.start() rufen. Ohne das haelt die passive/conversing
+   *  Aufnahme das Mikro noch, start() schlaegt fehl → Ohr bleibt ausgegraut
+   *  (state=off). ChatScreen registriert den Hook mit audioService.cancel…. */
+  private micReleaseHook: (() => Promise<void>) | null = null;
+
   private keyword: WakeKeyword = DEFAULT_KEYWORD;
   private nativeReady: boolean = false;
   private initInProgress: Promise<boolean> | null = null;
@@ -149,6 +180,19 @@ class WakeWordService {
     }
   }
 
+  /** ChatScreen registriert hier einen Hook, der eine laufende Streaming-
+   *  Aufnahme cancelt (Mikro freigeben) — wird vor jedem Re-Arm gerufen. */
+  setMicReleaseHook(fn: (() => Promise<void>) | null): void {
+    this.micReleaseHook = fn;
+  }
+
+  private async _freeMic(): Promise<void> {
+    if (!this.micReleaseHook) return;
+    try { await this.micReleaseHook(); } catch (e) {
+      console.warn('[WakeWord] micReleaseHook err:', e);
+    }
+  }
+
   /** Settings-Wechsel: anderes Wake-Word. Re-Init des Native-Moduls. */
   async configure(keyword: string): Promise<boolean> {
     const next: WakeKeyword = (WAKE_KEYWORDS as readonly string[]).includes(keyword)
@@ -178,7 +222,9 @@ class WakeWordService {
     if (this.initInProgress) return this.initInProgress;
     this.initInProgress = (async () => {
       try {
-        await OpenWakeWord.init(this.keyword, DEFAULT_THRESHOLD, DEFAULT_PATIENCE, DEFAULT_DEBOUNCE_MS);
+        const threshold = await loadWakeThreshold();
+        console.log('[WakeWord] init mit threshold=%s', threshold);
+        await OpenWakeWord.init(this.keyword, threshold, DEFAULT_PATIENCE, DEFAULT_DEBOUNCE_MS);
         // Subscribe nur einmal
         if (!this.eventSub) {
           const emitter = new NativeEventEmitter(NativeModules.OpenWakeWord);
@@ -422,7 +468,10 @@ class WakeWordService {
    *  wuerde sonst OpenWakeWord.stop() rufen weil bargeListening noch true
    *  ist, und unseren frisch re-armierten Listener killen.
    */
-  async endConversation(): Promise<void> {
+  /** @param skipPassive true = KEIN passives Lauschen, direkt zurueck aufs
+   *  Wake-Word (armed). Fuer klare Steuerbefehle (Fast-Path) — nach
+   *  "nächster Titel" will Stefan kein 30s-Fenster, sondern Stop. */
+  async endConversation(skipPassive: boolean = false): Promise<void> {
     if (this.state !== 'conversing') {
       import('./logger').then(m => m.reportAppDebug('wake.end',
         `endConversation called but state=${this.state} → noop`)).catch(()=>{});
@@ -442,7 +491,7 @@ class WakeWordService {
     // (Phase 3) filtert fremde Stimmen weg, der User kann ohne erneute
     // Anrede weitersprechen.
     const passiveMs = await loadPassiveListenMs();
-    if (passiveMs > 0 && this.nativeReady) {
+    if (!skipPassive && passiveMs > 0 && this.nativeReady) {
       this.enterPassiveListening(passiveMs);
       return;
     }
@@ -454,6 +503,7 @@ class WakeWordService {
       // als state extra zu fragen, garantiert dass nach diesem Pfad
       // Native auch wirklich an ist falls es out-of-band gestoppt wurde.
       try {
+        await this._freeMic();   // Streaming-Aufnahme canceln → Mikro frei
         await OpenWakeWord.start();
         console.log('[WakeWord] Konversation zu Ende — zurueck zu armed (wasBarge=%s)', wasBarge);
         import('./logger').then(m => m.reportAppDebug('wake.end',
@@ -520,6 +570,7 @@ class WakeWordService {
     // timeout oder manual → Wake-Word reaktivieren, armed-State.
     if (this.nativeReady && OpenWakeWord) {
       try {
+        await this._freeMic();   // passive Streaming-Aufnahme canceln → Mikro frei
         await OpenWakeWord.start();
         console.log('[WakeWord] zurueck zu armed nach passive-listen');
         ToastAndroid.show(`Lausche wieder auf "${KEYWORD_LABELS[this.keyword]}"`, ToastAndroid.SHORT);
@@ -564,6 +615,7 @@ class WakeWordService {
     this.lastTriggerAt = 0;
     if (this.nativeReady && OpenWakeWord) {
       try {
+        await this._freeMic();   // ggf. laufende Aufnahme canceln → Mikro frei
         await OpenWakeWord.start();
         ToastAndroid.show('Hintergrund-Trigger verworfen — lausche wieder', ToastAndroid.SHORT);
         this.setState('armed');

aria-brain/agent.py

@@ -234,6 +234,43 @@ META_TOOLS = [
                             "\"method\":\"PUT\"},\"reply\":\"Spotify: pausiert ⏸\"}]"
                         ),
                     },
+                    "speak": {
+                        "type": "boolean",
+                        "description": (
+                            "STATISCHER Default fuers Vorlesen dieses Skills (TTS). "
+                            "Default false.\n\n"
+                            "WARUM es das gibt: ARIA ist voice-first. Ein reiner "
+                            "STEUERBEFEHL (Spotify next/pause, Licht an) muss NICHT "
+                            "vorgelesen werden — die Aktion selbst ist die Bestaetigung, "
+                            "Vorlesen waere nervig. Ein ANTWORT-Skill dagegen liefert "
+                            "eine Info, die Stefan HOEREN will (Wuerfelergebnis, Status, "
+                            "'was laeuft gerade'). Also: Kommando-Skill=false, "
+                            "Antwort-Skill=true.\n\n"
+                            "PRO AUFRUF (wichtig fuer gemischte Skills!): Wenn EIN Skill "
+                            "beides kann (z.B. Spotify: 'next' = stumm, 'was laeuft' = "
+                            "vorlesen), kann dein run.py im JSON-Output pro Aufruf "
+                            "`speak` (und `converse`, s.u.) setzen — das ueberschreibt "
+                            "diesen statischen Default. Beispiel-Output:\n"
+                            "  next        -> {\"ok\":true,\"speak\":false,\"converse\":false}\n"
+                            "  was_laeuft  -> {\"ok\":true,\"speak\":true,\"converse\":false,"
+                            "\"reply\":\"Laeuft: …\"}"
+                        ),
+                    },
+                    "converse": {
+                        "type": "boolean",
+                        "description": (
+                            "Soll ARIA NACH dieser Skill-Antwort 30s WEITERLAUSCHEN "
+                            "(Dialog), oder direkt zurueck aufs Wake-Word? Default false.\n\n"
+                            "WARUM getrennt von speak: 'vorlesen' und 'weiterreden "
+                            "koennen' sind zwei verschiedene Dinge. 'was laeuft gerade' "
+                            "soll vorgelesen werden (speak=true), aber es ist eine "
+                            "abgeschlossene Einzel-Info — Stefan will danach NICHT ins "
+                            "30s-Mikrofon-Fenster gezwungen werden (converse=false). Nur "
+                            "wenn eine echte Rueckfrage/ein Dialog sinnvoll ist "
+                            "(converse=true). Am besten pro Aufruf im run.py-Output "
+                            "setzen (dynamisch), nicht statisch."
+                        ),
+                    },
                 },
                 "required": ["name", "description", "entry_code"],
             },
@@ -247,6 +284,27 @@ META_TOOLS = [
             "parameters": {"type": "object", "properties": {}},
         },
     },
+    {
+        "type": "function",
+        "function": {
+            "name": "skill_get",
+            "description": (
+                "Liest einen EXISTIERENDEN Skill VOLLSTAENDIG: Manifest (inkl. "
+                "args, fast_patterns, speak/converse) + kompletter entry_code "
+                "(der echte Python-Code) + README. IMMER vor `skill_update` "
+                "aufrufen, damit du den bestehenden Code SIEHST und ihn gezielt "
+                "aenderst statt blind zu ueberschreiben (Blind-Rewrite killt "
+                "leicht funktionierende Teile!)."
+            ),
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "name": {"type": "string", "description": "Skill-Name."},
+                },
+                "required": ["name"],
+            },
+        },
+    },
     {
         "type": "function",
         "function": {
@@ -310,6 +368,23 @@ META_TOOLS = [
                             "wieder durch Claude). Wenn nicht angegeben: bleibt unberuehrt."
                         ),
                     },
+                    "speak": {
+                        "type": "boolean",
+                        "description": (
+                            "Statischer Vorlese-Default (siehe skill_create). false = "
+                            "Steuerbefehl/stumm, true = Antwort-Skill/vorlesen. Pro "
+                            "Aufruf via run.py-JSON-Output ueberschreibbar."
+                        ),
+                    },
+                    "converse": {
+                        "type": "boolean",
+                        "description": (
+                            "Statischer Default: nach der Antwort 30s weiterlauschen "
+                            "(Dialog=true) oder direkt zurueck aufs Wake-Word (false, "
+                            "Default). Siehe skill_create. Pro Aufruf via Output "
+                            "ueberschreibbar."
+                        ),
+                    },
                 },
                 "required": ["name"],
             },
@@ -1018,10 +1093,102 @@ META_TOOLS = [
 # Diese Logik ist generisch — ARIA deklariert die Patterns selbst beim
 # skill_create / skill_update, das Brain orchestriert nur.
 
+def _strip_leading_hint_blocks(text: str) -> str:
+    """Entfernt fuehrende Hint-Bloecke `[ ... ]`, die die Bridge an
+    Voice-Nachrichten haengt (GPS-Position, Barge-In-Hinweis). Ohne das matcht
+    KEIN Voice-Befehl je den Fast-Path (Regex ist ^...$-verankert) — selbst
+    'nächstes lied' landete unnoetig bei Claude statt beim 0-Token-Fast-Path."""
+    s = (text or "").strip()
+    prev = None
+    while prev != s:
+        prev = s
+        s = re.sub(r"^\s*\[[^\]]*\]\s*", "", s)
+    return s
+
+
+def _fold_umlauts(s: str) -> str:
+    """ä→ae, ö→oe, ü→ue, ß→ss (lowercase erwartet). Whisper liefert echte
+    Umlaute ('Nächstes Lied'), viele Skill-fast_patterns sind aber in ae/oe/ue
+    geschrieben — ohne Faltung matcht das nie."""
+    return (s.replace("ä", "ae").replace("ö", "oe").replace("ü", "ue")
+             .replace("ß", "ss"))
+
+
+def _looks_like_skill_action(text: str) -> bool:
+    """Erkennt eine BEHAUPTETE Steuerbefehl-Quittung (v.a. Spotify) im Reply.
+    Genutzt fuer den Anti-Halluzinations-Guard: sagt local sowas, hat aber KEIN
+    Werkzeug gerufen, ist real nichts passiert → eskalieren. Bewusst eng, um
+    normale Konversation ueber Musik nicht zu treffen."""
+    t = (text or "").strip().lower()
+    if not t:
+        return False
+    if t.startswith("spotify:") or t.startswith("spotify -") or t.startswith("musik:"):
+        return True
+    if "playlist" in t and ("abspiel" in t or "spiele" in t or "starte" in t):
+        return True
+    if ("ueberspring" in t or "überspring" in t) and ("titel" in t or "lied" in t or "song" in t):
+        return True
+    return False
+
+
+def _claims_live_media_state(text: str) -> bool:
+    """Erkennt eine BEHAUPTETE Live-Zustands-Auskunft, die NUR ein Werkzeug
+    wissen kann: aktueller Song/Interpret, Restzeit, was gerade laeuft, welches
+    Geraet spielt. local erfindet das gern (mal 'Midnight City von M83', mal
+    'The House Of House') ohne run_spotify zu rufen. Ohne echten Skill-Aufruf ist
+    das reine Halluzination → eskalieren (Claude ruft das Tool zuverlaessig).
+
+    Bewusst auf Medien-/Wiedergabe-Zustand begrenzt, damit normale Musik-
+    Konversation ('ich mag M83') NICHT getroffen wird — es muss nach einer
+    konkreten Ist-Zustands-Auskunft klingen."""
+    t = (text or "").strip().lower()
+    if not t:
+        return False
+    # Restzeit/Abspielposition ('noch 52 Sekunden', 'Restzeit 2:34').
+    if "restzeit" in t or "restlaufzeit" in t:
+        return True
+    if re.search(r"\bnoch\s+\d+\s*(sekunde|minute|sek|min)", t):
+        return True
+    # 'aktueller Song/Titel/Lied heisst/ist …' / 'es laeuft gerade …' /
+    # 'spielt gerade …' / 'jetzt laeuft …' — Ist-Zustands-Auskunft.
+    if re.search(r"(aktuell\w*\s+(song|titel|lied|stueck|track))", t):
+        return True
+    if re.search(r"(l(ae|ä)uft|spielt)\s+(gerade|jetzt|aktuell|zurzeit|grade)", t):
+        return True
+    if re.search(r"(gerade|jetzt|zurzeit|grade)\s+(l(ae|ä)uft|spielt)", t):
+        return True
+    # Skip-Quittung, die einen konkreten Folgetitel behauptet ('… ist jetzt „X"').
+    if ("ueberspring" in t or "übersprung" in t or "uebersprung" in t) and (
+            "song" in t or "titel" in t or "lied" in t):
+        return True
+    return False
+
+
+_AWAIT_MARKER_RE = re.compile(r"\[\[\s*AWAIT(?:_REPLY)?\s*\]\]", re.IGNORECASE)
+
+
+def _extract_await_marker(text: str) -> tuple:
+    """Erkennt ARIAs Rueckfrage-Marker `[[AWAIT]]` — den sie ans Ende haengt,
+    wenn ihre Antwort eine echte Rueckfrage ist, auf die sie eine Nutzer-Antwort
+    BRAUCHT, bevor der aktuelle Task fertig ist. Entfernt den Marker (nicht
+    anzeigen/vorlesen/in History) und meldet, ob er da war. Wie speak/converse:
+    ARIA deklariert den Zustand selbst — kein '?'-Raten."""
+    if not text:
+        return text, False
+    if _AWAIT_MARKER_RE.search(text):
+        return _AWAIT_MARKER_RE.sub("", text).strip(), True
+    return text, False
+
+
 def _normalize_for_fast_match(text: str) -> str:
-    norm = (text or "").strip().lower()
+    norm = _strip_leading_hint_blocks(text).lower()
-    norm = re.sub(r"[.!?]+$", "", norm)
+    norm = _fold_umlauts(norm)
-    norm = re.sub(r"\s+", " ", norm)
+    # Interne Satzzeichen raus, die Whisper einstreut ('Nächstes Lied, bitte.').
+    # Kommas/Semikola/Doppelpunkte → Space, Punkt/!/? ganz weg. Sonst matcht das
+    # ^...$-verankerte fast_pattern nie, weil das Komma dazwischenfunkt.
+    norm = re.sub(r"[,;:]", " ", norm)
+    norm = re.sub(r"[.!?]+", "", norm)
+    norm = re.sub(r"\s+", " ", norm).strip()
     return norm
 
 
@@ -1117,6 +1284,9 @@ class Agent:
                 rx = pat.get("match") or ""
                 if not rx:
                     continue
+                # Pattern GLEICH falten wie den Text — egal ob der Skill-Autor
+                # 'naechstes' oder 'nächstes' geschrieben hat.
+                rx = _fold_umlauts(rx)
                 try:
                     if not re.match(rx, norm, re.IGNORECASE):
                         continue
@@ -1125,6 +1295,12 @@ class Agent:
                     continue
                 args = pat.get("args") or {}
                 reply = pat.get("reply") or f"{skill_name}: ok"
+                # Vorlesen/Weiterlauschen folgen dem Skill — GENAU wie bei local/
+                # Claude: Manifest-Default, vom Skill-Output pro Aufruf ueber-
+                # schreibbar. Also NICHT generell converse=False: ein Fast-Path-
+                # Skill darf ein Dialog-Skill sein.
+                self._fast_path_speak = bool(skill.get("speak", False))
+                self._fast_path_converse = bool(skill.get("converse", False))
                 logger.info("[fast-path] match skill=%s pattern=%r msg=%r",
                             skill_name, rx, user_message[:60])
                 try:
@@ -1137,6 +1313,16 @@ class Agent:
                     tail = (res.get("stderr") or res.get("stdout") or "").strip().splitlines()
                     hint = (tail[-1] if tail else "")[:120]
                     return f"{skill_name}: {reply} — Fehler: {hint or 'siehe Brain-Log'}"
+                # Per-Aufruf-Override aus dem Skill-JSON-Output (falls vorhanden).
+                try:
+                    _j = json.loads((res.get("stdout") or "").strip())
+                    if isinstance(_j, dict):
+                        if isinstance(_j.get("speak"), bool):
+                            self._fast_path_speak = _j["speak"]
+                        if isinstance(_j.get("converse"), bool):
+                            self._fast_path_converse = _j["converse"]
+                except Exception:
+                    pass
                 return reply
         return None
 
@@ -1192,14 +1378,73 @@ class Agent:
                 break
         return tools
 
+    def _resolve_skill_manifest(self, tname: str) -> Optional[dict]:
+        """run_-Toolname → Skill-Manifest (fuzzy, Bindestrich-Mapping)."""
+        if not tname.startswith("run_"):
+            return None
+        suffix = tname[len("run_"):]
+        m = skills_mod.read_manifest(suffix)
+        if m is None:
+            for cand in skills_mod.list_skills(active_only=False):
+                cn = cand.get("name") or ""
+                if re.sub(r"[^a-zA-Z0-9_]", "_", cn) == suffix:
+                    m = cand
+                    break
+        return m
+
+    def _skill_speak_flag(self, tname: str) -> bool:
+        """speak-Flag eines run_*-Skills aus dem Manifest (Default False)."""
+        if not tname.startswith("run_"):
+            return True
+        return bool((self._resolve_skill_manifest(tname) or {}).get("speak", False))
+
+    def _skill_response_flags(self, tname: str) -> tuple:
+        """(speak, converse) fuer einen gerade ausgefuehrten run_*-Skill.
+        Prioritaet: JSON-Output des Skills (self._last_skill_flags, pro Aufruf) >
+        Manifest-Default > False. So kann EIN Skill pro Operation unterschiedlich
+        sein — 'next' stumm/stop, 'was laeuft' vorlesen aber trotzdem stop."""
+        flags = getattr(self, "_last_skill_flags", None) or {}
+        m = self._resolve_skill_manifest(tname) or {}
+        speak = bool(m.get("speak", False))
+        converse = bool(m.get("converse", False))
+        if isinstance(flags.get("speak"), bool):
+            speak = flags["speak"]
+        if isinstance(flags.get("converse"), bool):
+            converse = flags["converse"]
+        return speak, converse
+
     def _try_local_fast_lane(self, user_message: str,
                              active_project_id: str) -> Optional[str]:
         cfg = router_mod.load_config()
         if not router_mod.should_try_local(user_message, cfg):
             return None
+        # Vorlesen ja/nein fuer diesen lokalen Turn. Default True (Info-Antwort).
+        # Fuehrt local einen Skill (run_*) aus, uebernimmt dessen speak-Flag aus
+        # dem Manifest (Steuerbefehl-Skill=False → stumm, Antwort-Skill=True).
+        # Info-Tools (web_search/memory_search/trigger_timer) lassen es bei True.
+        self._local_turn_speak = True
+        # Nach der Antwort 30s weiterlauschen? Default True (Gespraech/Info via
+        # web_search). Ein run_*-Skill setzt es auf seinen Output-Wert (Default
+        # False = Einzelaktion).
+        self._local_turn_converse = True
+        # Hat local in diesem Turn ueberhaupt einen echten Skill (run_*) gerufen?
+        # Fuer den Anti-Halluzinations-Guard: behauptet local eine Spotify-/Skill-
+        # Aktion OHNE das Tool zu rufen → eskalieren statt eine erfundene
+        # Bestaetigung durchzulassen.
+        self._local_ran_skill = False
         local_only = bool(cfg.get("localOnly"))
         local_model = cfg.get("localLlmModel") or "qwen3-8b"  # B0.5: llama-swap-Key
-        tools = self._build_local_tools()  # B1b: kuratierte Tools
+        # B1a-Rueckbau (bewusst): local ist TOOL-LOS — nur reines Reden. Ein 8B
+        # ist ein unzuverlaessiger Tool-Caller: mit Werkzeug in der Hand erfindet
+        # er lieber eine plausible Antwort ('der Song ist X'), statt das Tool zu
+        # rufen — das war die Halo-Quelle UND zwang zu per-Skill-Guards. Ohne
+        # Tools KANN er kein Skill-Ergebnis faelschen. Alles mit Grundwahrheit
+        # (Fakt/Live-Zustand/Gedaechtnis/Aktion) gehoert an Claude oder an den
+        # deterministischen Fast-Path — nicht an den 8B. WIE es dorthin kommt:
+        # das Modell eskaliert SELBST (<<ESCALATE>>, siehe Prompt) — bewusst KEINE
+        # Input-Wortliste im Router. Der Output-Guard unten faengt ab, wenn der
+        # 8B doch mal statt zu eskalieren einen Live-Zustand behauptet.
+        tools = []
 
         sys_prompt = router_mod.build_local_system_prompt(IDENTITY_ANCHOR,
                                                           has_tools=bool(tools))
@@ -1244,6 +1489,13 @@ class Agent:
                     logger.info("[router] lokal Tool-Call: %s(%s)", tname,
                                 ", ".join(targs.keys()))
                     tresult = self._dispatch_tool(tname, targs)
+                    # Echter Skill (run_*) erfolgreich? Dann uebernimmt dieser
+                    # Turn das speak-Flag des Skills (Steuerbefehl=stumm,
+                    # Antwort-Skill=vorlesen). Letzter Skill gewinnt.
+                    if tname.startswith("run_") and not self._local_tool_failed(tname, tresult):
+                        self._local_turn_speak, self._local_turn_converse = \
+                            self._skill_response_flags(tname)
+                        self._local_ran_skill = True
                     if self._local_tool_failed(tname, tresult):
                         had_error = True
                     messages.append({"role": "tool",
@@ -1289,6 +1541,15 @@ class Agent:
             logger.info("[router] lokal eskaliert → Claude")
             return None
 
+        # Anti-Halluzination: local behauptet manchmal eine Musik-/Skill-Aktion
+        # ('Spotify: …', 'Playlist … abspielen'), OHNE run_spotify gerufen zu
+        # haben → es ist real nichts passiert. Dann eskalieren: Claude ruft das
+        # Tool zuverlaessig. (Echte Skill-Ausfuehrung → _local_ran_skill=True.)
+        if not self._local_ran_skill and (
+                _looks_like_skill_action(final) or _claims_live_media_state(final)):
+            logger.info("[router] lokal: Aktion/Live-Zustand behauptet ohne Tool-Call → Claude")
+            return None
+
         logger.info("[router] lokal beantwortet (%d Zeichen)", len(final))
         self.conversation.add("assistant", final, project_id=active_project_id)
         return final
@@ -1338,9 +1599,13 @@ class Agent:
                 metrics.log_fast_path(fast_reply)
             except Exception:
                 pass
-            # Fast-Path = reiner Steuerbefehl → NICHT vorlesen (speak=False).
+            # Vorlesen folgt dem Skill-Manifest (speak): Steuerbefehl=stumm,
-            # System-Flag statt <voice>-Tag: robust, unabhaengig vom Skill-Inhalt.
+            # Antwort-Skill=vorlesen. Default False (reiner Steuerbefehl).
-            return fast_reply, "fast-path", False
+            speak = bool(getattr(self, "_fast_path_speak", False))
+            # converse folgt dem Skill (Manifest/Output) — nicht mehr generell False.
+            converse = bool(getattr(self, "_fast_path_converse", False))
+            # Fast-Path = reiner Steuerbefehl, nie eine Rueckfrage → awaiting=False.
+            return fast_reply, "fast-path", speak, converse, False
 
         # 1. User-Turn an die Konversation
         self.conversation.add("user", user_message, source=source,
@@ -1354,7 +1619,12 @@ class Agent:
         # teure Claude-Aufbau + Tool-Loop wird uebersprungen. Sonst None → Claude.
         local_reply = self._try_local_fast_lane(user_message, active_project_id)
         if local_reply is not None:
-            return local_reply, "local", True  # ARIA-Antwort → vorlesen ok
+            # speak = vorlesen?  converse = danach 30s weiterlauschen? Beides folgt
+            # dem Skill (bzw. Default: Info/Gespraech = vorlesen + 30s).
+            speak = getattr(self, "_local_turn_speak", True)
+            converse = getattr(self, "_local_turn_converse", True)
+            # Local ist tool-loses Reden; blockierende Rueckfragen macht Claude.
+            return local_reply, "local", speak, converse, False
 
         # 2. Hot Memory (alle pinned Punkte)
         hot = self.store.list_pinned()
@@ -1401,6 +1671,23 @@ class Agent:
                                             oauth_callback_host=oauth_host,
                                             oauth_callback_port=oauth_port,
                                             oauth_callback_tls=oauth_tls)
+        # Rueckfrage-Signal: ARIA haengt [[AWAIT]] an, wenn ihre Antwort eine
+        # echte, blockierende Rueckfrage ist. Die App pausiert dann die Projekt-
+        # Queue und leitet Stefans naechste Eingabe als ANTWORT darauf weiter
+        # (statt als neuen Auftrag). Wie speak/converse: ARIA deklariert selbst.
+        system_prompt += (
+            "\n\n## RUECKFRAGE-SIGNAL [[AWAIT]]\n"
+            "Wenn deine Antwort eine echte RUECKFRAGE ist, auf die du Stefans "
+            "Antwort BRAUCHST, um den aktuellen Task abzuschliessen (z.B. 'Welche "
+            "der drei Playlists meinst du?', 'Soll ich X oder Y nehmen?'), haenge "
+            "als ALLERLETZTES exakt `[[AWAIT]]` an. Der Marker wird entfernt (nicht "
+            "angezeigt, nicht vorgelesen) und sagt der App: warte auf Stefans "
+            "Antwort, bevor der naechste Task der Warteschlange laeuft.\n"
+            "NUR bei echten, blockierenden Rueckfragen — NICHT bei rhetorischen "
+            "Fragen, unverbindlichen Vorschlaegen ('soll ich noch...?', die auch "
+            "ohne Antwort ok sind) oder wenn du den Task einfach fertig hast. Im "
+            "Zweifel: KEIN Marker."
+        )
         # Queue-Aware Prompting: wenn nach diesem Turn weitere Nachrichten
         # in der Warteschlange liegen, muss ARIA pruefen ob eine spaetere die
         # aktuelle Aufgabe korrigiert/annuliert (→ Skip statt Doppelarbeit).
@@ -1470,6 +1757,13 @@ class Agent:
         # zwei Turns, was OpenAI/Anthropic verwirrt und bei strict tools-Aufrufen
         # zu 400-Errors fuehren kann.
         final_reply = ""
+        # Vorlesen ja/nein fuer diesen Claude-Turn. Default True (Gespraech).
+        # Fuehrt Claude einen Steuerbefehl-Skill (run_*, speak=false) erfolgreich
+        # aus, wird die Antwort NICHT vorgelesen — der Text landet aber normal in
+        # der Bubble (Stefans Wunsch). Antwort-Skills (speak=true) + reine
+        # Konversation bleiben gesprochen.
+        self._claude_turn_speak = True
+        self._claude_turn_converse = True   # Default Gespraech; run_*-Skill setzt es
         try:
             for iteration in range(self.MAX_TOOL_ITERATIONS):
                 result = self.proxy.chat_full(messages, tools=tools,
@@ -1487,6 +1781,12 @@ class Agent:
                     # Tools ausfuehren + Ergebnis als role=tool zurueck
                     for tc in result.tool_calls:
                         tool_result = self._dispatch_tool(tc["name"], tc["arguments"])
+                        # Steuerbefehl-Skill (run_*, speak=false) erfolgreich
+                        # ausgefuehrt → Antwort nicht vorlesen (letzter Skill gewinnt).
+                        _tn = tc.get("name") or ""
+                        if _tn.startswith("run_") and not self._local_tool_failed(_tn, tool_result):
+                            self._claude_turn_speak, self._claude_turn_converse = \
+                                self._skill_response_flags(_tn)
                         # Cap auf 50 KB — passt zur Cap in _dispatch_tool fuer
                         # Skill-Outputs (siehe agent.py weiter unten). 8 KB war
                         # viel zu wenig: Spotify _all=true mit 90 Playlists
@@ -1552,10 +1852,19 @@ class Agent:
                 final_reply = ("Hey, ich bin ARIA. \U0001F60A Bei mir ist alles bereit — "
                                "sag mir einfach, was du brauchst.")
 
+        # Rueckfrage-Marker aus dem finalen Text ziehen (vor History/Return, damit
+        # er nicht angezeigt/vorgelesen wird und nicht die Conversation vergiftet).
+        final_reply, awaiting_reply = _extract_await_marker(final_reply)
+
         # 7. Assistant-Turn (final reply) in die Conversation
         self.conversation.add("assistant", final_reply,
                               project_id=active_project_id)
-        return final_reply, "claude", True  # ARIA-Antwort → vorlesen ok
+        # speak/converse folgen dem ausgefuehrten Skill (sonst Default: Gespraech);
+        # awaiting_reply = ARIA stellt eine blockierende Rueckfrage (Queue pausiert).
+        return (final_reply, "claude",
+                bool(getattr(self, "_claude_turn_speak", True)),
+                bool(getattr(self, "_claude_turn_converse", True)),
+                awaiting_reply)
 
     # ── Tool-Dispatcher ───────────────────────────────────────
 
@@ -1576,6 +1885,8 @@ class Agent:
                     pip_packages=arguments.get("pip_packages", []),
                     config_schema=arguments.get("config_schema") or None,
                     fast_patterns=arguments.get("fast_patterns") or None,
+                    speak=bool(arguments.get("speak", False)),
+                    converse=bool(arguments.get("converse", False)),
                     author="aria",
                 )
                 # Side-Channel-Event: Stefan soll sehen wenn ARIA was anlegt
@@ -1627,6 +1938,29 @@ class Agent:
                     f"- {s['name']} ({s['execution']}) {'aktiv' if s.get('active', True) else 'DEAKTIVIERT'}: {s.get('description', '')}"
                     for s in items
                 )
+            if name == "skill_get":
+                sk_name = (arguments.get("name") or "").strip()
+                if not sk_name:
+                    return "FEHLER: name ist Pflicht."
+                src = skills_mod.read_skill_source(sk_name)
+                if src is None:
+                    return f"FEHLER: Skill '{sk_name}' nicht gefunden."
+                m = src["manifest"]
+                # Manifest kompakt + kompletter Code, damit ARIA gezielt aendern kann.
+                meta = {
+                    "name": m.get("name"), "description": m.get("description"),
+                    "execution": m.get("execution"), "entry": m.get("entry"),
+                    "active": m.get("active"), "args": m.get("args"),
+                    "requires": m.get("requires"),
+                    "config_schema": m.get("config_schema"),
+                    "fast_patterns": m.get("fast_patterns"),
+                    "speak": m.get("speak"), "converse": m.get("converse"),
+                }
+                return (
+                    f"MANIFEST:\n{json.dumps(meta, ensure_ascii=False, indent=2)}\n\n"
+                    f"ENTRY-CODE ({src['entry']}):\n{src['entry_code']}\n\n"
+                    f"README:\n{src.get('readme') or '(leer)'}"
+                )
             if name == "skill_update":
                 skill_name = (arguments.get("name") or "").strip()
                 if not skill_name:
@@ -1635,6 +1969,10 @@ class Agent:
                 for k in ("entry_code", "readme", "description", "args", "active"):
                     if k in arguments and arguments[k] is not None:
                         patch[k] = arguments[k]
+                if "speak" in arguments and arguments["speak"] is not None:
+                    patch["speak"] = bool(arguments["speak"])
+                if "converse" in arguments and arguments["converse"] is not None:
+                    patch["converse"] = bool(arguments["converse"])
                 if "pip_packages" in arguments and isinstance(arguments["pip_packages"], list):
                     patch["pip_packages"] = arguments["pip_packages"]
                 if "config_schema" in arguments and isinstance(arguments["config_schema"], list):
@@ -1736,6 +2074,18 @@ class Agent:
                             skill_name = cand_name
                             break
                 res = skills_mod.run_skill(skill_name, args=arguments)
+                # Steuer-Flags aus dem Skill-JSON-Output (speak/converse) fuer
+                # DIESEN Aufruf merken. Der Aufrufer (local/claude/fast-path)
+                # liest sie und steuert damit Vorlesen (speak) + 30s-Weiter-
+                # lauschen (converse) — pro Aufruf, dynamisch. Kein JSON / nicht
+                # gesetzt → Aufrufer nimmt Manifest-Default (speak) bzw. False.
+                self._last_skill_flags = None
+                if res.get("ok"):
+                    try:
+                        _j = json.loads((res.get("stdout") or "").strip())
+                        self._last_skill_flags = _j if isinstance(_j, dict) else None
+                    except Exception:
+                        self._last_skill_flags = None
                 # 2000 Zeichen war viel zu wenig — Spotify-JSON ist 5-15 KB,
                 # da wurde der Track-Name regelmaessig abgeschnitten und ARIA
                 # hat aus dem Album-Kontext halluziniert. Claude kann hunderte

aria-brain/background.py

@@ -150,7 +150,7 @@ async def _fire(trigger: dict, agent_factory) -> None:
 
     try:
         agent = agent_factory()
-        reply, _, _ = agent.chat(prompt, source="trigger")
+        reply, _, _, _, _ = agent.chat(prompt, source="trigger")
         events = agent.pop_events()
         logger.info("[trigger] %s gefeuert → ARIA-Reply: %s", name, reply[:80])
         triggers_mod.append_log(name, {"event": "reply", "text": reply[:500]})

aria-brain/main.py

@@ -636,6 +636,13 @@ class ChatOut(BaseModel):
     # Soll die Antwort vorgelesen werden? Fast-Path (reiner Steuerbefehl) = False;
     # ARIA-Antworten (local/claude) = True. System-Flag statt <voice>-Tag.
     speak: bool = True
+    # Soll die App nach der Antwort 30s weiterlauschen (Gespraech)? Einzelaktionen/
+    # Skills = False (direkt zurueck aufs Wake-Word), Konversation = True.
+    converse: bool = True
+    # Stellt ARIA eine blockierende Rueckfrage (braucht Stefans Antwort, bevor der
+    # Task fertig ist)? Dann pausiert die App die Projekt-Queue und leitet die
+    # naechste Eingabe als Antwort weiter, statt sie als neuen Auftrag anzustellen.
+    awaiting_reply: bool = False
     # Echo der project_id die dieser Turn hatte. Bridge nutzt sie damit die
     # ausgehende Chat-Bubble sauber getaggt in der richtigen Thread-Bahn der
     # UI landet.
@@ -719,7 +726,7 @@ async def chat(body: ChatIn, background: BackgroundTasks):
                 # Sync-Aufruf im Executor damit wir den Event-Loop nicht blocken —
                 # chat() macht HTTP-Calls (Proxy) die 30-60s dauern koennen.
                 loop = asyncio.get_running_loop()
-                reply, answered_by, speak = await loop.run_in_executor(
+                reply, answered_by, speak, converse, awaiting_reply = await loop.run_in_executor(
                     None,
                     lambda: a.chat(
                         body.message, source=body.source, project_id=pid,
@@ -743,6 +750,8 @@ async def chat(body: ChatIn, background: BackgroundTasks):
                 project_id=pid,
                 answered_by=answered_by,
                 speak=speak,
+                converse=converse,
+                awaiting_reply=awaiting_reply,
             )
     finally:
         _project_pending[pid] = [

aria-brain/router.py

@@ -75,6 +75,16 @@ _TOOL_HINTS = re.compile(
     re.IGNORECASE,
 )
 
+# HINWEIS (bewusst KEINE Live-/Topic-Wortliste mehr): frueher stand hier ein
+# _LIVE_HINTS-Blacklist (Wetter/Musik/Uhrzeit/… → Claude). Das war die falsche
+# Idee — aus offenem Freitext die Absicht per Wortliste zu erraten ist NIE
+# vollstaendig, jeder Miss = ein Halo. Die generische Loesung ist keine groessere
+# Regex, sondern: das Modell entscheidet selbst („brauche ich Grundwahrheit/ein
+# Tool? → <<ESCALATE>>", siehe build_local_system_prompt). Ein 8B kann das noch
+# nicht zuverlaessig → local bleibt per Einstellung abschaltbar; ein staerkeres
+# lokales Modell uebernimmt spaeter genau diese Selbst-Erkennung. Absicherung ist
+# der Output-Guard in agent.py, nicht eine Input-Wortliste.
+
 # Technik-/Tiefe-Marker → Claude (lokales 8B soll das nicht raten).
 _HARD_HINTS = re.compile(
     r"```|"                                    # Codeblock
@@ -86,6 +96,29 @@ _HARD_HINTS = re.compile(
 
 _MAX_LEN_FOR_LOCAL = 220   # laengere Nachrichten = eher komplexe Aufgaben → Claude
 
+# Expliziter Nutzer-Wunsch „nimm das grosse Modell". Stefan sagt oft „frag Clodi"
+# / „benutze direkt Claude" — dann soll der Turn NICHT lokal versucht werden,
+# sondern direkt an Claude gehen. „Clodi/Clody" ist sein Kosename fuer Claude und
+# meint praktisch immer Routing; „claude"/„grosses modell" nur in Imperativ-Kontext
+# (nimm/nutze/frag/…), damit reine Trivia „was ist Claude" nicht faelschlich matcht.
+_FORCE_CLAUDE = re.compile(
+    r"\b(clodi|clody)\b"
+    r"|\b(nimm|nutze|benutze|verwende|frag(e|st)?|nimms?t?|mit|via|direkt|per)\b"
+    r"[^.?!]*\b(claude|gro(ss|ß)es?\s+modell)\b",
+    re.IGNORECASE,
+)
+
+
+def _strip_leading_hint_blocks(text: str) -> str:
+    """Fuehrende `[ ... ]`-Hint-Bloecke (GPS, Barge-In von der Bridge) weg —
+    sonst blaeht der Praefix die Laenge auf und verfaelscht die Heuristik."""
+    s = (text or "").strip()
+    prev = None
+    while prev != s:
+        prev = s
+        s = re.sub(r"^\s*\[[^\]]*\]\s*", "", s)
+    return s
+
 
 def should_try_local(user_message: str, cfg: dict) -> bool:
     """True, wenn der Router diesen Turn (B1a, reden-only) lokal versuchen soll.
@@ -94,9 +127,13 @@ def should_try_local(user_message: str, cfg: dict) -> bool:
         return False
     if cfg.get("localOnly"):
         return True
-    msg = (user_message or "").strip()
+    msg = _strip_leading_hint_blocks(user_message)
     if not msg or len(msg) > _MAX_LEN_FOR_LOCAL:
         return False
+    # Expliziter „nimm Claude/Clodi"-Wunsch → nie lokal (User hat entschieden).
+    if _FORCE_CLAUDE.search(msg):
+        logger.info("[router] expliziter Claude-Wunsch erkannt → nicht lokal")
+        return False
     if _TOOL_HINTS.search(msg):
         return False
     if _HARD_HINTS.search(msg):
@@ -111,10 +148,16 @@ def should_try_local(user_message: str, cfg: dict) -> bool:
 # kein volles Memory (B1a).
 
 # Was das lokale Tier NICHT selbst kann → dafuer eskaliert es an Claude.
+# Seit dem B1a-Rueckbau hat local KEINE Werkzeuge mehr: es kann nichts
+# nachschlagen und nichts steuern. Alles was aktuelle Grundwahrheit oder eine
+# Aktion braucht, gehoert ans grosse Modell.
 _AWARENESS = (
-    "Nur das grosse Modell (nicht du im Schnell-Modus) kann: Bilder generieren, "
+    "Du hast im Schnell-Modus KEINE Werkzeuge — du kannst nichts nachschlagen und "
-    "Skills bauen/aendern, Projekte & OAuth verwalten, ins Gedaechtnis SCHREIBEN, "
+    "nichts steuern. Nur das grosse Modell kann: aktuelle Infos holen (Wetter, "
-    "sowie tiefe/technische Analysen und langen Code."
+    "News, Uhrzeit, Preise), Musik/Spotify steuern oder den laufenden Song "
+    "nennen, Timer setzen, Bilder generieren, Skills bauen/aendern, Projekte & "
+    "OAuth verwalten, ins Gedaechtnis schreiben, sowie tiefe/technische Analysen "
+    "und langen Code. Fuer ALL das eskalierst du."
 )
 
 
@@ -142,10 +185,26 @@ def build_local_system_prompt(identity_anchor: str, has_tools: bool = False,
             "GPS-Hinweis in der Nachricht.",
             "- `memory_search`: in ARIAs Gedaechtnis nachsehen (lesen).",
             "- `trigger_timer`: Timer/Erinnerung setzen ('in 10 Minuten…').",
-            "- `run_spotify`: Musik steuern (naechster Titel, Pause, weiter).",
+            "- `run_*`-Skills: konkrete Faehigkeiten (z.B. Musik/Spotify u.a.). "
+            "Was ein Skill kann + welche Parameter er nimmt, steht in SEINER "
+            "Tool-Beschreibung — LIES sie und nutze den Skill fuer ALLES was "
+            "dazu passt (nicht nur die offensichtlichen Faelle). Nie selbst eine "
+            "Aktion 'spielen'/'nachschauen', wenn ein Skill das kann.",
             "WICHTIG: Bei reinem Smalltalk ('wie gehts', Begruessung, Meinung) "
             "KEIN Werkzeug — einfach direkt antworten. Werkzeuge nur bei echtem "
             "Bedarf; erfinde keine.",
+            "ANTI-HALLUZINATION (kritisch): Behaupte NIEMALS eine Aktion als "
+            "erledigt, ohne das Werkzeug WIRKLICH aufgerufen zu haben. Keine "
+            "'Spotify: …' / 'Playlist abspielen'-Quittung o.ae. ohne echten "
+            "Skill-Aufruf. Kannst/willst du es nicht per Werkzeug tun, sag es "
+            "ehrlich oder eskaliere — erfinde keine Bestaetigung.",
+            "Das gilt GENAUSO fuer Live-Auskuenfte: Nenne NIEMALS einen aktuellen "
+            "Songtitel, Interpreten, die Restzeit oder was gerade laeuft/welches "
+            "Geraet spielt, ohne den passenden Skill (z.B. run_spotify) WIRKLICH "
+            "aufgerufen und sein Ergebnis gelesen zu haben. Kein Tool-Ergebnis = du "
+            "weisst es NICHT — dann eskaliere, statt einen Titel/eine Zeit zu raten. "
+            "Gib nur weiter, was im Skill-Ergebnis wirklich steht; hat der Skill "
+            "keinen Titel geliefert (z.B. nur 'OK: next'), erfinde auch keinen.",
         ]
     parts += [
         "",

aria-brain/skills.py

@@ -139,6 +139,26 @@ def read_manifest(name: str) -> Optional[dict]:
         return None
 
 
+def read_skill_source(name: str) -> Optional[dict]:
+    """Manifest + kompletter entry_code + README eines Skills. Damit ARIA einen
+    Skill LESEN kann bevor sie ihn per skill_update aendert (sonst Blind-Rewrite,
+    der bestehende Funktionen killt)."""
+    m = read_manifest(name)
+    if m is None:
+        return None
+    d = _skill_dir(name)
+    entry = m.get("entry", "run.sh")
+    try:
+        code = (d / entry).read_text(encoding="utf-8")
+    except Exception as exc:
+        code = f"(entry-Datei '{entry}' nicht lesbar: {exc})"
+    try:
+        readme = (d / "README.md").read_text(encoding="utf-8")
+    except Exception:
+        readme = ""
+    return {"manifest": m, "entry": entry, "entry_code": code, "readme": readme}
+
+
 def write_manifest(name: str, manifest: dict) -> None:
     d = _skill_dir(name)
     d.mkdir(parents=True, exist_ok=True)
@@ -165,6 +185,8 @@ def create_skill(
     author: str = "aria",
     config_schema: Optional[list] = None,
     fast_patterns: Optional[list] = None,
+    speak: bool = False,
+    converse: bool = False,
 ) -> dict:
     """Legt einen neuen Skill an. Wirft ValueError bei ungueltigen Inputs.
 
@@ -215,6 +237,14 @@ def create_skill(
         "author": author,
         "config_schema": _normalize_config_schema(config_schema),
         "fast_patterns": _normalize_fast_patterns(fast_patterns),
+        # speak: soll die Antwort dieses Skills vorgelesen werden (TTS)?
+        # False (Default) = reiner Steuerbefehl (Spotify, Licht) → stumm, App
+        # beendet direkt. True = Antwort-Skill (Info/Ergebnis) → vorlesen.
+        # converse: nach der Antwort 30s weiterlauschen (Dialog)? Default False
+        # (Einzelaktion). Beide sind STATISCHE Defaults — der Skill kann sie im
+        # JSON-Output pro Aufruf ueberschreiben (gemischte Skills).
+        "speak": bool(speak),
+        "converse": bool(converse),
         "version_history": [],
     }
     write_manifest(name, manifest)
@@ -335,10 +365,15 @@ def update_skill(name: str, patch: dict) -> dict:
         # nach archive_current_version manifest neu laden (version_history geupdatet)
         manifest = read_manifest(name) or manifest
 
-    allowed = {"description", "args", "requires", "active", "version", "entry"}
+    allowed = {"description", "args", "requires", "active", "version", "entry",
+               "speak", "converse"}
     for k, v in patch.items():
         if k in allowed:
             manifest[k] = v
+    if "speak" in patch:
+        manifest["speak"] = bool(patch["speak"])
+    if "converse" in patch:
+        manifest["converse"] = bool(patch["converse"])
     if "config_schema" in patch:
         manifest["config_schema"] = _normalize_config_schema(patch["config_schema"])
     if "fast_patterns" in patch:

bridge/aria_bridge.py

@@ -16,6 +16,7 @@ import asyncio
 import base64
 import json
 import logging
+import math
 import mimetypes
 import os
 import re
@@ -32,6 +33,7 @@ from pathlib import Path
 from typing import Optional
 
 import subprocess
+import urllib.parse
 import urllib.request
 import numpy as np
 import sounddevice as sd
@@ -293,10 +295,17 @@ def clean_text_for_tts(text: str) -> str:
     if not text:
         return ""
 
-    # <voice>...</voice> wenn vorhanden → nur das nehmen
+    # <voice>...</voice> wenn vorhanden → nur diesen Inhalt lesen. ABER: ein
+    # LEERES <voice></voice> darf die Sprachausgabe nicht verstummen lassen.
+    # Claude haengt reflexartig manchmal ein leeres Tag an (v.a. bei Spotify-
+    # Antworten) — frueher wurde daraus text="" → gar keine TTS (Playlist-Wechsel
+    # 'Prodigy' stumm, 'Fliegen' gesprochen, rein je nachdem ob Claude Inhalt ins
+    # Tag schrieb). Leeres/whitespace-Tag → ignorieren und den normalen Text lesen.
     voice_match = _re_tts.search(r'<voice>([\s\S]*?)</voice>', text, _re_tts.IGNORECASE)
-    if voice_match:
+    if voice_match and voice_match.group(1).strip():
         text = voice_match.group(1)
+    else:
+        text = _re_tts.sub(r'<voice>[\s\S]*?</voice>', ' ', text, flags=_re_tts.IGNORECASE)
 
     t = text
 
@@ -370,6 +379,37 @@ def clean_text_for_tts(text: str) -> str:
     return t.strip()
 
 
+# ── Geo: Bewegungsrichtung aus zwei GPS-Punkten ──────────────
+
+# Fahrtrichtung als Himmelsrichtungs-Adverb (8-Wind, "…waerts"). Index =
+# gerundeter Bearing / 45 (mod 8).
+_COMPASS_ADV = ["nordwaerts", "nordostwaerts", "ostwaerts", "suedostwaerts",
+                "suedwaerts", "suedwestwaerts", "westwaerts", "nordwestwaerts"]
+
+
+def _haversine_m(lat1: float, lon1: float, lat2: float, lon2: float) -> float:
+    """Distanz in Metern zwischen zwei GPS-Punkten."""
+    r = 6371000.0
+    p1, p2 = math.radians(lat1), math.radians(lat2)
+    dp = math.radians(lat2 - lat1)
+    dl = math.radians(lon2 - lon1)
+    a = math.sin(dp / 2) ** 2 + math.cos(p1) * math.cos(p2) * math.sin(dl / 2) ** 2
+    return 2 * r * math.asin(min(1.0, math.sqrt(a)))
+
+
+def _bearing_deg(lat1: float, lon1: float, lat2: float, lon2: float) -> float:
+    """Kompass-Peilung 0..360 (0=Nord) von Punkt1 nach Punkt2."""
+    p1, p2 = math.radians(lat1), math.radians(lat2)
+    dl = math.radians(lon2 - lon1)
+    y = math.sin(dl) * math.cos(p2)
+    x = math.cos(p1) * math.sin(p2) - math.sin(p1) * math.cos(p2) * math.cos(dl)
+    return (math.degrees(math.atan2(y, x)) + 360.0) % 360.0
+
+
+def _heading_word(bearing: float) -> str:
+    return _COMPASS_ADV[round(bearing / 45.0) % 8]
+
+
 # ── STT Engine ───────────────────────────────────────────────
 
 
@@ -1175,8 +1215,28 @@ class ARIABridge:
                 "lat": float(lat),
                 "lon": float(lon),
             })
+            lat, lon = float(lat), float(lon)
+            # Fuer den Standort-Praefix merken (auch fuer Turns ohne frisches GPS).
+            self._last_location = {"lat": lat, "lon": lon}
+            # Fahrtrichtung aus dem Bewegungsvektor. Anker bleibt stehen bis wir
+            # uns >MIN_MOVE_M wirklich wegbewegt haben — so zaehlt echtes Fahren,
+            # nicht das GPS-Jitter im Stand. Stehen wir → letzte Richtung bleibt.
+            # Umdrehen liefert automatisch neue Punkte → neue Richtung.
+            MIN_MOVE_M = 25.0
+            anchor = getattr(self, "_heading_anchor", None)
+            if anchor:
+                moved = _haversine_m(anchor["lat"], anchor["lon"], lat, lon)
+                if moved >= MIN_MOVE_M:
+                    _bg = _bearing_deg(anchor["lat"], anchor["lon"], lat, lon)
+                    self._last_heading = _heading_word(_bg)
+                    self._last_bearing = int(round(_bg)) % 360   # exakte Peilung
+                    self._heading_anchor = {"lat": lat, "lon": lon}
+            else:
+                self._heading_anchor = {"lat": lat, "lon": lon}
         except Exception:
             return
+        # Ortsname im Hintergrund aufloesen (Nominatim, gecacht) — kein Modell.
+        self._maybe_reverse_geocode(float(lat), float(lon))
         # Fire-and-forget: Brain-on-demand-Tick. Wenn Brain nicht antwortet
         # oder langsam ist, blockt das nicht den GPS-Pfad.
         try:
@@ -1184,6 +1244,150 @@ class ARIABridge:
         except Exception:
             pass
 
+    def _maybe_reverse_geocode(self, lat: float, lon: float) -> None:
+        """Loest lat/lon → Ortsname auf, aber nur bei nennenswerter Bewegung
+        (~1 km Raster) und im Hintergrund. Ergebnis landet in
+        self._last_place_name; der Standort-Praefix liest es dann nur ab."""
+        try:
+            key = (round(lat, 3), round(lon, 3))   # ~110 m — fuer Strasse/Hausnr
+        except Exception:
+            return
+        if key == getattr(self, "_geocoded_key", None):
+            return  # diese Gegend schon aufgeloest
+        # Neue Gegend: alten Namen verwerfen, sonst zeigt der Praefix die falsche
+        # Stadt bis der neue Geocode da ist.
+        self._geocoded_key = key
+        self._last_place_name = ""
+        try:
+            self._geocode_task = asyncio.create_task(self._do_reverse_geocode(lat, lon, key))
+        except Exception:
+            self._geocode_task = None
+
+    async def _ensure_place_name(self, lat, lon) -> None:
+        """Stellt (blockierend, mit Timeout) sicher, dass der Ortsname fuer die
+        aktuelle Position da ist — fuer die ERSTE Nachricht an einem neuen Ort,
+        wo der Hintergrund-Geocode noch laeuft. Gecacht → danach instant."""
+        try:
+            lat, lon = float(lat), float(lon)
+            key = (round(lat, 3), round(lon, 3))
+        except Exception:
+            return
+        if key == getattr(self, "_geocoded_key", None) and getattr(self, "_last_place_name", ""):
+            return  # schon aufgeloest
+        if key != getattr(self, "_geocoded_key", None):
+            self._maybe_reverse_geocode(lat, lon)   # startet Task
+        task = getattr(self, "_geocode_task", None)
+        if task is not None and not task.done():
+            try:
+                await asyncio.wait_for(asyncio.shield(task), timeout=6)
+            except Exception:
+                pass  # Timeout/Fehler → Praefix faellt auf reine Koordinaten zurueck
+
+    async def _do_reverse_geocode(self, lat: float, lon: float, key) -> None:
+        """Nominatim-Reverse-Geocode (keyless, gratis). Baut einen moeglichst
+        genauen Ort: Strasse+Hausnummer, PLZ+Stadt, Bundesland; bei Autobahn/
+        Bundesstrasse zusaetzlich die Ref (A 28 / B 75) + best-effort Kilometer
+        (Overpass-Milestone). Setzt self._last_place_name. Fehler → still
+        (Praefix faellt auf reine Koordinaten zurueck)."""
+        base = os.environ.get("NOMINATIM_URL", "https://nominatim.openstreetmap.org").rstrip("/")
+        url = (f"{base}/reverse?lat={lat:.5f}&lon={lon:.5f}&format=jsonv2"
+               f"&zoom=18&addressdetails=1&extratags=1&accept-language=de")
+
+        def _fetch():
+            try:
+                req = urllib.request.Request(url, headers={
+                    # Nominatim verlangt einen aussagekraeftigen User-Agent.
+                    "User-Agent": "ARIA-Assistant/1.0 (personal voice assistant)",
+                })
+                with urllib.request.urlopen(req, timeout=8) as r:
+                    return json.loads(r.read().decode("utf-8", "ignore"))
+            except Exception as exc:
+                logger.debug("[geo] reverse-geocode fehlgeschlagen: %s", exc)
+                return None
+
+        data = await asyncio.get_event_loop().run_in_executor(None, _fetch)
+        if not isinstance(data, dict):
+            return
+        addr = data.get("address") or {}
+        extra = data.get("extratags") or {}
+        road = addr.get("road") or ""
+        house = addr.get("house_number") or ""
+        city = (addr.get("city") or addr.get("town") or addr.get("village")
+                or addr.get("municipality") or addr.get("county") or "")
+        plz = addr.get("postcode") or ""
+        state = addr.get("state") or ""
+        ref = (extra.get("ref") or "").strip()   # z.B. "A 28", "B 75"
+
+        # Strasse + Hausnummer
+        street = (f"{road} {house}".strip()) if road else ""
+        # PLZ + Ort
+        citypart = (f"{plz} {city}".strip()) if plz else city
+
+        segs: list[str] = []
+        # Autobahn/Bundes-/Kreisstrasse? Ref + (best-effort) Kilometer voranstellen.
+        is_road = bool(ref) or any(w in road.lower()
+                                   for w in ("autobahn", "bundesstrasse", "bundesstraße",
+                                             "kreisstrasse", "kreisstraße"))
+        if is_road:
+            label = ref or road
+            km = await self._overpass_km(lat, lon)
+            if km:
+                label = f"{label} bei km {km}"
+            if label:
+                segs.append(label)
+        if street:
+            segs.append(street)
+        if citypart:
+            segs.append(citypart)
+        if state and (state not in citypart):
+            segs.append(state)
+
+        name = ", ".join(s for s in segs if s)
+        if not name:
+            name = data.get("name") or ""
+        # Nur uebernehmen wenn Stefan nicht schon weitergezogen ist (key aktuell).
+        if name and getattr(self, "_geocoded_key", None) == key:
+            self._last_place_name = name
+            logger.info("[geo] %.5f,%.5f → %s", lat, lon, name)
+
+    async def _overpass_km(self, lat: float, lon: float) -> str:
+        """Best-effort Autobahn/Strassen-Kilometer: naechsten OSM-Milestone
+        (highway=milestone mit distance-Tag) im Umkreis suchen. Leer wenn keiner
+        gefunden / Overpass nicht erreichbar. Milestones stehen i.d.R. alle 500 m,
+        also grob (fuer Pannenhilfe 'ca. km X' voellig ausreichend)."""
+        ov = os.environ.get("OVERPASS_URL", "https://overpass-api.de/api/interpreter")
+        query = (f"[out:json][timeout:8];"
+                 f"node(around:900,{lat:.5f},{lon:.5f})[highway=milestone];out;")
+
+        def _fetch():
+            try:
+                body = urllib.parse.urlencode({"data": query}).encode("utf-8")
+                req = urllib.request.Request(ov, data=body, headers={
+                    "User-Agent": "ARIA-Assistant/1.0 (personal voice assistant)",
+                })
+                with urllib.request.urlopen(req, timeout=12) as r:
+                    return json.loads(r.read().decode("utf-8", "ignore"))
+            except Exception as exc:
+                logger.debug("[geo] overpass-km fehlgeschlagen: %s", exc)
+                return None
+
+        d = await asyncio.get_event_loop().run_in_executor(None, _fetch)
+        if not isinstance(d, dict):
+            return ""
+        best_dist = ""
+        best_sq = 1e18
+        for e in (d.get("elements") or []):
+            tags = e.get("tags") or {}
+            dist = tags.get("distance") or tags.get("milestone:distance") or ""
+            elat, elon = e.get("lat"), e.get("lon")
+            if not dist or elat is None or elon is None:
+                continue
+            sq = (float(elat) - lat) ** 2 + (float(elon) - lon) ** 2
+            if sq < best_sq:
+                best_sq = sq
+                best_dist = str(dist)
+        return best_dist.replace(".", ",") if best_dist else ""
+
     async def _trigger_brain_check_now(self) -> None:
         """Brain-Endpoint POST /triggers/check-now anstossen."""
         brain_url = os.environ.get("BRAIN_URL", "http://aria-brain:8080")
@@ -1356,6 +1560,13 @@ class ARIABridge:
                 "text": display_text,
                 "sender": "aria",
                 "messageId": message_id,
+                # ARIA-Dateien DIREKT an der Chat-Bubble mitschicken — sonst kommt
+                # der Anhang live nur als separates file_from_aria-Event (eigene
+                # Bubble) und taucht an der Nachricht erst nach einem Seiten-
+                # wechsel auf (Reload aus chat_backup, das die files kennt). Selbe
+                # Struktur wie im Backup, damit App live == Reload rendert.
+                "files": [{"serverPath": f["serverPath"], "name": f["name"],
+                           "mimeType": f["mimeType"], "size": f["size"]} for f in aria_files],
                 # backupTs = der ts in chat_backup.jsonl. Wird von Clients als
                 # Bubble-ID fuer das Mülltonne-Loeschen verwendet (delete_message_request).
                 "backupTs": assistant_backup_ts,
@@ -1366,6 +1577,18 @@ class ARIABridge:
                 "projectId": (payload.get("projectId") or "") if isinstance(payload, dict) else "",
                 # Quell-Backend (local/claude/fast-path) fuer den Diagnostic-Badge.
                 "answeredBy": (payload.get("answeredBy") or "") if isinstance(payload, dict) else "",
+                # Wird diese Antwort vorgelesen? Fast-Path/Steuerbefehl = False.
+                # Die App braucht das: ohne TTS feuert onPlaybackFinished nie,
+                # und daran haengt das Wake-Word-Re-Arm — sonst bleibt das Ohr
+                # nach einem Fast-Path-Befehl grau haengen.
+                "speak": bool(payload.get("speak", True)) if isinstance(payload, dict) else True,
+                # Nach dieser Antwort 30s weiterlauschen? Steuert das Gespraechs-
+                # Fenster in der App (Skill/Einzelaktion=False, Konversation=True).
+                "converse": bool(payload.get("converse", True)) if isinstance(payload, dict) else True,
+                # Stellt ARIA eine blockierende Rueckfrage? Dann pausiert die App
+                # die Projekt-Queue und leitet die naechste Eingabe als Antwort auf
+                # DIESE Rueckfrage weiter, statt sie als neuen Auftrag anzustellen.
+                "awaiting_reply": bool(payload.get("awaiting_reply", False)) if isinstance(payload, dict) else False,
             },
             "timestamp": int(asyncio.get_event_loop().time() * 1000),
         })
@@ -1552,14 +1775,33 @@ class ARIABridge:
                 "gesprochen oder gearbeitet hast. Folgendes ist eine Korrektur, "
                 "Ergaenzung oder ein Themenwechsel zu deiner letzten Antwort.]"
             )
-        if location and isinstance(location, dict):
+        # Standort: frische GPS aus der Nachricht, sonst der zuletzt bekannte
-            lat = location.get("lat")
+        # (damit's beim passiven Weiterreden ohne frisches GPS nicht wegfaellt).
-            lon = location.get("lon") or location.get("lng")
+        loc = location if (isinstance(location, dict) and location.get("lat") is not None) \
+            else getattr(self, "_last_location", None)
+        if isinstance(loc, dict):
+            lat = loc.get("lat")
+            lon = loc.get("lon") or loc.get("lng")
             if lat is not None and lon is not None:
+                # Ortsname kommt vom Reverse-Geocode (Nominatim, gecacht) — so
+                # muss KEIN Modell Koordinaten raten (das lokale 8B tippt sonst
+                # daneben, z.B. "Berlin" fuer Oldenburg). Noch nicht aufgeloest
+                # → nur Koordinaten (Claude kann die zur Not selbst deuten).
+                place = getattr(self, "_last_place_name", "")
+                where = f"{place} " if place else ""
+                heading = getattr(self, "_last_heading", "")
+                bearing = getattr(self, "_last_bearing", None)
+                if heading and bearing is not None:
+                    moving = f", unterwegs {heading} ({bearing} Grad)"
+                elif heading:
+                    moving = f", unterwegs {heading}"
+                else:
+                    moving = ""
                 parts.append(
-                    f"[Stefans aktuelle GPS-Position: {float(lat):.6f}, {float(lon):.6f}. "
+                    f"[Stefans aktueller Standort: {where}(GPS {float(lat):.5f}, "
-                    f"Nutze die nur wenn die Frage sich auf seinen Standort bezieht. "
+                    f"{float(lon):.5f}){moving}. Nutze das nur wenn die Frage sich "
-                    f"Erwaehne sie nicht von dir aus, ausser er fragt explizit danach.]"
+                    f"auf seinen Standort/seine Fahrtrichtung bezieht. Erwaehne es "
+                    f"nicht von dir aus, ausser er fragt explizit danach.]"
                 )
         if parts:
             return " ".join(parts) + " " + text
@@ -1707,6 +1949,12 @@ class ARIABridge:
         # Soll vorgelesen werden? Fast-Path (Steuerbefehl) = False. System-Flag
         # vom Brain — robust, unabhaengig von <voice>-Tags im Reply-Text.
         speak = data.get("speak", True)
+        # Nach der Antwort 30s weiterlauschen (Gespraech) oder direkt zurueck aufs
+        # Wake-Word? Einzelaktionen/Skills = False. Reicht die App aus.
+        converse = data.get("converse", True)
+        # Stellt ARIA eine blockierende Rueckfrage? Dann pausiert die App die
+        # Projekt-Queue und leitet die naechste Eingabe als Antwort weiter.
+        awaiting_reply = bool(data.get("awaiting_reply", False))
 
         # Side-Channel-Events VOR der Chat-Bubble broadcasten (z.B. skill_created)
         # damit sie in der UI vor der Reply auftauchen
@@ -1775,7 +2023,9 @@ class ARIABridge:
         try:
             await self._process_core_response(reply, {"projectId": turn_project_id,
                                                        "answeredBy": answered_by,
-                                                       "speak": speak})
+                                                       "speak": speak,
+                                                       "converse": converse,
+                                                       "awaiting_reply": awaiting_reply})
         except Exception:
             logger.exception("[brain] _process_core_response Fehler")
             await self._emit_activity("idle", "", project_id=project_id)
@@ -2082,6 +2332,9 @@ class ARIABridge:
                     logger.info("[rvs] App-Chat (mit Anhaengen) project=%s: '%s'",
                                 str(payload.get("projectId") or "") or "(main)", text[:80])
                 else:
+                    _lg = location or getattr(self, "_last_location", None)
+                    if isinstance(_lg, dict) and _lg.get("lat") is not None:
+                        await self._ensure_place_name(_lg.get("lat"), _lg.get("lon") or _lg.get("lng"))
                     core_text = self._build_core_text(text, interrupted, location)
                     logger.info("[rvs] App-Chat%s%s: '%s'",
                                 " [BARGE-IN]" if interrupted else "",
@@ -3006,6 +3259,24 @@ class ARIABridge:
             if self._is_duplicate_client_msg(client_msg_id):
                 return
 
+            # Text-Fenster-Dedup: im Auto cancelt der App-No-Speech-Watchdog den
+            # Stream vorzeitig und startet passives Lauschen, waehrend die Bridge
+            # dieselbe Aeusserung parallel noch finalisiert → derselbe Befehl
+            # kaeme zweimal (aus ZWEI verschiedenen audioRequestIds, darum greift
+            # die ID-Idempotenz oben nicht). Identischen Endpoint-Text innerhalb
+            # 5s verwerfen. Genuines "nächstes, nächstes" liegt praktisch immer
+            # weiter auseinander (man hoert den Wechsel erst).
+            _norm_txt = " ".join(text.lower().split())
+            _now_t = asyncio.get_event_loop().time()
+            if (_norm_txt
+                    and _norm_txt == getattr(self, "_last_endpoint_norm", "")
+                    and (_now_t - getattr(self, "_last_endpoint_at", 0.0)) < 5.0):
+                logger.info("[rvs] stt_endpoint Dupe verworfen (gleicher Text <5s): %r",
+                            text[:60])
+                return
+            self._last_endpoint_norm = _norm_txt
+            self._last_endpoint_at = _now_t
+
             # App-Focus aus stt_stream_start-Registry auflösen (falls die
             # App-Version die projectId noch nicht mitschickt: leer = Hauptchat).
             stream_req_id = payload.get("requestId", "") or ""
@@ -3161,6 +3432,9 @@ class ARIABridge:
                 logger.warning("[rvs] STT-Text konnte nicht an RVS gesendet werden: %s", e)
 
             # Dann an Brain — der blockt synchron bis ARIA fertig ist.
+            _lg = location or getattr(self, "_last_location", None)
+            if isinstance(_lg, dict) and _lg.get("lat") is not None:
+                await self._ensure_place_name(_lg.get("lat"), _lg.get("lon") or _lg.get("lng"))
             core_text = self._build_core_text(text, interrupted, location)
             await self.send_to_core(core_text,
                                     source="app-voice" + (" [barge-in]" if interrupted else ""),

diagnostic/index.html

@@ -320,6 +320,7 @@
       </div>
       <div id="diag-pending-attachments" style="display:none;padding:6px 10px;background:#1E1E2E;border-radius:6px 6px 0 0;margin-bottom:-4px;display:flex;gap:6px;flex-wrap:wrap;align-items:center;">
       </div>
+      <div id="diag-queue-banner" style="display:none;padding:6px 10px;background:#2A2410;border:1px solid #4A3F14;border-radius:6px;margin-bottom:6px;"></div>
       <div class="input-row">
         <label class="btn secondary" style="padding:6px 10px;cursor:pointer;font-size:14px;" title="Datei anhaengen">
           &#x1F4CE;
@@ -1424,6 +1425,13 @@
     let focusedContextId = localStorage.getItem('diag_focused_context_id') || '';
     let diagQueueStatus = {};
     let diagProjectsCache = [];
+    let diagShowHiddenStrip = false;   // versteckte Projekte im Streifen zeigen?
+    // ── Pro-Kontext-Queue + Zustandsautomat (spiegelt die App) ──
+    const diagCtxStates = {};   // pid → 'idle' | 'running' | 'awaiting_reply'
+    const diagCtxQueues = {};   // pid → [{id,text}]
+    const diagDrafts = JSON.parse(localStorage.getItem('diag_ctx_drafts') || '{}');
+    let diagQid = 0;
+    const diagState = (pid) => diagCtxStates[pid] || 'idle';
 
     function updateChatVisibilityByFocus() {
       for (const box of [chatBox, document.getElementById('chat-box-fs')]) {
@@ -1437,10 +1445,22 @@
     }
 
     function switchDiagFocus(id) {
-      focusedContextId = id || '';
+      const nextId = id || '';
+      // Pro-Kontext-Textfeld-Entwuerfe: Feldinhalt dem verlassenen Kontext
+      // zuordnen, Entwurf des neuen laden.
+      if (nextId !== focusedContextId) {
+        const input = document.getElementById('chat-input');
+        if (input) {
+          diagDrafts[focusedContextId] = input.value;
+          input.value = diagDrafts[nextId] || '';
+        }
+        localStorage.setItem('diag_ctx_drafts', JSON.stringify(diagDrafts));
+      }
+      focusedContextId = nextId;
       localStorage.setItem('diag_focused_context_id', focusedContextId);
       updateChatVisibilityByFocus();
       renderContextStrip();
+      renderDiagQueue();
     }
 
     function renderContextStrip() {
@@ -1464,20 +1484,79 @@
         if (s.queue_size > 0) return { color: '#FFD60A', label: `Queue: ${s.queue_size}` };
         return { color: '#34C759', label: 'idle' };
       };
+      // Projekt-Chip MIT Auge (verstecken/sichtbar). Auge hat eigenes onclick
+      // + stopPropagation, damit der Klick nicht den Kontext wechselt.
+      const projChip = (p, isFocus, dotColor, subline) => {
+        const hidden = !!p.hidden;
+        const bg = isFocus ? 'rgba(52,199,89,0.15)' : '#1E1E2E';
+        const border = isFocus ? '#34C759' : '#2A2A3E';
+        const eye = hidden ? '👁' : '🙈';
+        const eyeTitle = hidden ? 'Wieder dauerhaft sichtbar machen' : 'Verstecken (aus dem Streifen ausblenden)';
+        return `<div style="flex:0 0 auto;padding:6px 10px;background:${bg};border:1px solid ${border};border-radius:6px;display:flex;align-items:center;gap:6px;min-width:120px;${hidden ? 'opacity:0.5;' : ''}">
+          <div onclick="switchDiagFocus('${p.id}')" style="cursor:pointer;display:flex;align-items:center;gap:6px;min-width:0;">
+            <div style="width:8px;height:8px;border-radius:4px;background:${dotColor};"></div>
+            <div style="display:flex;flex-direction:column;min-width:0;">
+              <div style="color:${isFocus?'#34C759':'#E0E0F0'};font-size:12px;font-weight:600;white-space:nowrap;overflow:hidden;text-overflow:ellipsis;max-width:200px;">📁 ${escapeHtml(p.name)}${hidden ? ' <span style="color:#B392F0;font-size:9px;font-weight:700;">versteckt</span>' : ''}</div>
+              <div style="color:#8888AA;font-size:10px;">${subline}</div>
+            </div>
+          </div>
+          <span onclick="event.stopPropagation();setStripProjectHidden('${p.id}',${!hidden})" title="${eyeTitle}" style="cursor:pointer;font-size:14px;padding:2px 4px;user-select:none;">${eye}</span>
+        </div>`;
+      };
       const cards = [];
       // Hauptchat
       const mainDot = dotFor('__main__');
       cards.push(chip('', '💬 Hauptchat', focusedContextId === '', mainDot.color, mainDot.label || 'idle'));
-      // Projekte — nur active/ended, sortiert nach letzter Aktivitaet
+      // Projekte — nur active/ended, sortiert nach letzter Aktivitaet.
+      // Versteckte standardmaessig raus; per Toggle-Chip einblendbar.
+      let hiddenCount = 0;
       for (const p of diagProjectsCache) {
         if (p.status === 'archived') continue;
+        if (p.hidden) {
+          hiddenCount++;
+          if (!diagShowHiddenStrip) continue;
+        }
         const d = dotFor(p.id);
         const sub = d.label || `${p.turn_count} Turns`;
-        cards.push(chip(p.id, `📁 ${p.name}`, focusedContextId === p.id, d.color, sub));
+        cards.push(projChip(p, focusedContextId === p.id, d.color, sub));
+      }
+      // Toggle-Chip am Ende (nur wenn es versteckte gibt oder gerade gezeigt werden)
+      if (hiddenCount > 0 || diagShowHiddenStrip) {
+        const tLabel = diagShowHiddenStrip
+          ? `🙈 versteckte ausblenden (${hiddenCount})`
+          : `👁 versteckte anzeigen (${hiddenCount})`;
+        cards.push(`<div onclick="toggleDiagHiddenStrip()" title="Versteckte Projekte ein-/ausblenden" style="cursor:pointer;flex:0 0 auto;padding:6px 10px;background:#0D0D18;border:1px dashed #3A3A50;border-radius:6px;display:flex;align-items:center;color:#B392F0;font-size:11px;font-weight:600;white-space:nowrap;">${tLabel}</div>`);
       }
       strip.innerHTML = cards.join('');
     }
 
+    function toggleDiagHiddenStrip() {
+      diagShowHiddenStrip = !diagShowHiddenStrip;
+      renderContextStrip();
+    }
+
+    async function setStripProjectHidden(id, hidden) {
+      try {
+        const r = await fetch(`/api/brain/projects/${encodeURIComponent(id)}`, {
+          method: 'PATCH',
+          headers: { 'Content-Type': 'application/json' },
+          body: JSON.stringify({ hidden: !!hidden }),
+        });
+        if (!r.ok) throw new Error('HTTP ' + r.status);
+        // Wenn wir das gerade fokussierte Projekt verstecken (und Versteckte nicht
+        // eingeblendet sind), zurueck auf Hauptchat — sonst haengt der Focus an
+        // einem unsichtbaren Chip.
+        if (hidden && id === focusedContextId && !diagShowHiddenStrip) {
+          switchDiagFocus('');
+        }
+        // Lokal sofort aktualisieren (der /api/brain-Proxy broadcastet zusaetzlich
+        // project_changed an App + andere Tabs).
+        await refreshDiagProjectsCache();
+      } catch (e) {
+        alert('Verstecken/Anzeigen fehlgeschlagen: ' + e.message);
+      }
+    }
+
     async function refreshDiagQueueStatus() {
       try {
         const r = await fetch('/api/brain/projects/queue-status');
@@ -1775,8 +1854,10 @@
         }
 
         if (msg.type === 'project_changed') {
-          // ARIA hat in einem Tool-Call ein Projekt erstellt/betreten/verlassen/beendet.
+          // Projekt geaendert (ARIA-Tool, App/Diagnostic-Verstecken, …) →
-          // Liste neu laden falls sichtbar.
+          // BEIDE Projekt-UIs live aktualisieren: den Kontext-Streifen (Main)
+          // und die vertikale Liste (Einstellungen).
+          refreshDiagProjectsCache();
           loadProjects();
           return;
         }
@@ -1921,6 +2002,15 @@
             projectId: p.projectId || '',
             answeredBy: p.answeredBy || '',
           });
+          // ── Pro-Kontext-Queue-Automat: auf ARIAs Antwort reagieren ──
+          if (sender === 'aria') {
+            const apid = p.projectId || '';
+            const st = diagState(apid);
+            if (st === 'running' || st === 'awaiting_reply') {
+              if (p.awaiting_reply) { diagCtxStates[apid] = 'awaiting_reply'; renderDiagQueue(); }
+              else advanceDiagQueue(apid);
+            }
+          }
           return;
         }
         if (msg.type === 'chat_message_deleted') {
@@ -2117,16 +2207,64 @@
       renderDiagPending();
     }
 
+    // ── Pro-Kontext-Queue: Helfer (spiegelt die App) ──
+    function actuallySendDiag(pid, text) {
+      addChat('sent', text, 'via RVS', { projectId: pid });
+      send({ action: 'test_rvs', text, projectId: pid });
+      diagCtxStates[pid] = 'running';
+      renderDiagQueue();
+    }
+    function advanceDiagQueue(pid) {
+      const q = diagCtxQueues[pid] || [];
+      if (q.length === 0) { diagCtxStates[pid] = 'idle'; renderDiagQueue(); return; }
+      const next = q.shift();
+      actuallySendDiag(pid, next.text);
+    }
+    function enqueueOrSendDiag(pid, text) {
+      if (diagState(pid) === 'running') {
+        (diagCtxQueues[pid] = diagCtxQueues[pid] || []).push({ id: 'q' + (++diagQid), text });
+        renderDiagQueue();
+      } else {
+        // idle ODER awaiting_reply → sofort (bei awaiting = Antwort auf Rueckfrage).
+        actuallySendDiag(pid, text);
+      }
+    }
+    function removeDiagQueuedFocused(id) {
+      const pid = focusedContextId;
+      diagCtxQueues[pid] = (diagCtxQueues[pid] || []).filter(it => it.id !== id);
+      renderDiagQueue();
+    }
+    function renderDiagQueue() {
+      const el = document.getElementById('diag-queue-banner');
+      if (!el) return;
+      const st = diagState(focusedContextId);
+      const q = diagCtxQueues[focusedContextId] || [];
+      if (st !== 'awaiting_reply' && q.length === 0) { el.style.display = 'none'; el.innerHTML = ''; return; }
+      el.style.display = 'block';
+      let html = '';
+      if (st === 'awaiting_reply') {
+        html += '<div style="color:#FFD60A;font-weight:600;margin-bottom:4px;">&#x2753; ARIA fragt nach &mdash; deine Eingabe beantwortet das</div>';
+      }
+      if (q.length) {
+        html += q.map(it =>
+          '<span style="display:inline-block;background:#1E1E2E;border:1px solid #4A3F14;border-radius:10px;padding:2px 8px;margin:2px;font-size:12px;color:#FFD60A;">&#x23F8; ' +
+          escapeHtml(it.text.slice(0, 40)) +
+          ' <a href="#" style="color:#FF6B6B;text-decoration:none;" onclick="removeDiagQueuedFocused(\'' + it.id + '\');return false;">&#x2715;</a></span>'
+        ).join('');
+      }
+      el.innerHTML = html;
+    }
+
     function testRVS() {
       const input = document.getElementById('chat-input');
       const text = input.value.trim();
       if (!text && diagPendingFiles.length === 0) return;
       if (diagPendingFiles.length > 0) sendDiagAttachments();
       if (text) {
-        // Multi-Threading: mit fokussierter Kontext-ID senden.
+        // Draft dieses Kontexts leeren + Queue-Automat entscheidet senden/anstellen.
-        // Bridge routet an /chat body.project_id — Brain queued per Kontext.
+        diagDrafts[focusedContextId] = '';
-        addChat('sent', text, 'via RVS', { projectId: focusedContextId });
+        localStorage.setItem('diag_ctx_drafts', JSON.stringify(diagDrafts));
-        send({ action: 'test_rvs', text, projectId: focusedContextId });
+        enqueueOrSendDiag(focusedContextId, text);
       }
       input.value = '';
     }
@@ -2613,8 +2751,8 @@
       const input = document.getElementById('chat-input-fs');
       const text = input.value.trim();
       if (!text) return;
-      addChat('sent', text, 'via RVS');
+      // Ueber denselben Queue-Automaten wie der Haupt-Chat (fokussierter Kontext).
-      send({ action: 'test_rvs', text });
+      enqueueOrSendDiag(focusedContextId, text);
       input.value = '';
     }
     // Escape schliesst Vollbild-Chat
@@ -3588,6 +3726,12 @@
     }
     document.getElementById('chat-input').addEventListener('keydown', (e) => chatInputKeydown(e, testRVS));
     document.getElementById('chat-input-fs').addEventListener('keydown', (e) => chatInputKeydown(e, testRVSFS));
+    // Entwurf des zuletzt fokussierten Kontexts ins Feld laden + Queue-Banner init.
+    (function initDiagDraft() {
+      const input = document.getElementById('chat-input');
+      if (input && diagDrafts[focusedContextId]) input.value = diagDrafts[focusedContextId];
+      renderDiagQueue();
+    })();
 
     // Escape schliesst Lightbox
     document.addEventListener('keydown', (e) => {

diagnostic/server.js

@@ -1602,7 +1602,16 @@ const htmlPath = path.join(__dirname, "index.html");
 
 const server = http.createServer((req, res) => {
   if (req.url === "/" || req.url === "/index.html") {
-    res.writeHead(200, { "Content-Type": "text/html; charset=utf-8" });
+    // no-store: das Dashboard ist eine Single-HTML-App die bei jedem Deploy
+    // neue Inline-JS/CSS bekommt. Ohne Cache-Header servierte der Browser die
+    // alte Version trotz Reload (neue Features tauchten erst nach Hard-Reload
+    // auf) — genau das Symptom „ich seh den Button nicht".
+    res.writeHead(200, {
+      "Content-Type": "text/html; charset=utf-8",
+      "Cache-Control": "no-store, no-cache, must-revalidate",
+      "Pragma": "no-cache",
+      "Expires": "0",
+    });
     res.end(fs.readFileSync(htmlPath, "utf-8"));
   } else if (req.url === "/api/state") {
     res.writeHead(200, { "Content-Type": "application/json" });