harden history find tokens and shops earch

src/Controller/AskSseController.php

@@ -92,6 +92,13 @@ final readonly class AskSseController
                 if (($claimed['ok'] ?? false) !== true) {
                     $this->prepareStreamRuntime();
                     echo "retry: 15000\n\n";
+
+                    if ($this->shouldSilentlyCloseDuplicateJobStream($claimed)) {
+                        $this->sendComment('duplicate-or-finished-stream');
+                        $this->sendEvent('done', '[DONE]');
+                        return;
+                    }
+
                     $this->sendEvent('error', $this->jobClaimErrorMessage($claimed));
                     $this->sendEvent('done', '[DONE]');
                     return;
@@ -504,6 +511,24 @@ final readonly class AskSseController
             }
         }
     }
+    /**
+     * EventSource may reconnect to an already running or already completed job.
+     * Those duplicate connections should be closed quietly so the UI does not
+     * append a misleading error after the real stream already produced output.
+     *
+     * @param array<string, mixed> $claim
+     */
+    private function shouldSilentlyCloseDuplicateJobStream(array $claim): bool
+    {
+        if (($claim['reason'] ?? null) !== 'not_pending') {
+            return false;
+        }
+
+        $status = (string) ($claim['status'] ?? '');
+
+        return $status === self::JOB_STATUS_RUNNING
+            || $status === self::JOB_STATUS_COMPLETED;
+    }
 
     /**
      * @param array<string, mixed> $claim
@@ -548,7 +573,6 @@ final readonly class AskSseController
 
         return 'Der Antwort-Job wurde nicht gefunden. Falls deine Verbindung kurz unterbrochen war, sende die Anfrage bitte erneut.';
     }
-
     private function cleanupExpiredJobs(): void
     {
         $directory = $this->jobDirectory();