diff --git a/DeskHub-Webseite/staff/_header.php b/DeskHub-Webseite/staff/_header.php index c8caacee..60ebda8c 100644 --- a/DeskHub-Webseite/staff/_header.php +++ b/DeskHub-Webseite/staff/_header.php @@ -66,7 +66,7 @@ if ('serviceWorker' in navigator) { [$__lcDeptSql, $__lcDeptParams] = dept_filter_sql(staff_department_ids($staff), 't.department_id'); $__lcSql = "SELECT COUNT(*) FROM tickets t WHERE t.source = 'chat' AND t.status != 'closed' AND (SELECT tt.author_type FROM ticket_threads tt WHERE tt.ticket_id = t.id ORDER BY tt.created_at DESC, tt.id DESC LIMIT 1) = 'customer'" - . ($__lcDeptSql !== '' ? " AND $__lcDeptSql" : ''); + . $__lcDeptSql; // enthält bereits das führende " AND " (dept_filter_sql) $__lcStmt = get_db()->prepare($__lcSql); $__lcStmt->execute($__lcDeptParams); $__lcPending = (int) $__lcStmt->fetchColumn(); @@ -105,6 +105,7 @@ if ('serviceWorker' in navigator) { E-Mail-Adressen E-Mail-Vorlagen Wissensdatenbank + Digitaler Assistent Plugins Kunden diff --git a/DeskHub-Webseite/tests/assistant.php b/DeskHub-Webseite/tests/assistant.php new file mode 100644 index 00000000..97eaffff --- /dev/null +++ b/DeskHub-Webseite/tests/assistant.php @@ -0,0 +1,347 @@ +getPathname(), strlen($root) + 1)); + if (preg_match($skip, $rel) && !preg_match('#^(backups|uploads|plugins)/(\.htaccess|README\.md)$#', $rel)) continue; + if ($f->isDir()) { @mkdir($tmp . '/' . $rel, 0755, true); continue; } + @mkdir(dirname($tmp . '/' . $rel), 0755, true); + copy($f->getPathname(), $tmp . '/' . $rel); +} +@mkdir($tmp . '/uploads'); +@mkdir($tmp . '/config'); +file_put_contents($tmp . '/config/config.php', ' bin2hex(random_bytes(32)), + 'db' => ['driver' => 'sqlite', 'sqlite_path' => $tmp . '/database/deskhub.sqlite'], + 'site' => ['name' => 'Test', 'url' => 'http://127.0.0.1', 'admin_email' => 'a@test.de', 'timezone' => 'Europe/Berlin'], + 'uploads' => ['max_size_bytes' => 10485760, 'allowed_extensions' => ['png'], 'path' => $tmp . '/uploads'], +], true) . ';'); + +putenv('DESKHUB_CONFIG_JSON'); +putenv('DESKHUB_SQLITE_PATH'); +putenv('DESKHUB_TESTING'); +putenv('DESKHUB_API_ALLOW_INSECURE=1'); +require_once $root . '/database/sqlite_schema.php'; +require_once $root . '/database/migrate.php'; +$db = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); +$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); +$db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); +$db->exec('PRAGMA foreign_keys = ON'); +$db->exec(convert_schema_to_sqlite((string) file_get_contents($root . '/database/schema.sql'))); +$mig = run_migrations($db, true); +$now = date('Y-m-d H:i:s'); +$dept = (int) $db->query('SELECT id FROM departments ORDER BY id LIMIT 1')->fetchColumn(); +$db->exec('DELETE FROM staff'); +$ins = $db->prepare('INSERT INTO staff (name, email, password_hash, role, department_id, is_active, created_at) VALUES (?,?,?,?,?,1,?)'); +$ids = []; +foreach ([['Chef', 'chef@test.de', 'admin'], ['Agent', 'agent@test.de', 'agent'], ['Andere', 'andere@test.de', 'agent']] as [$n, $e, $r]) { + $ins->execute([$n, $e, password_hash('Sehr-Sicher-1234', PASSWORD_DEFAULT), $r, $dept, $now]); + $ids[$n] = (int) $db->lastInsertId(); +} +$db = null; + +$failures = []; +$total = 0; +$check = function (bool $ok, string $what) use (&$failures, &$total): void { $total++; if (!$ok) $failures[] = $what; }; +$webProc = proc_open([PHP_BINARY, '-S', "127.0.0.1:$webPort", '-t', $tmp], [['pipe', 'r'], ['file', $work . '/web.out', 'w'], ['file', $work . '/web.out', 'a']], $wp, $tmp); + +try { + for ($i = 0; $i < 50; $i++) { if (@fsockopen('127.0.0.1', $webPort)) break; usleep(100000); } + $pdo = function () use ($tmp): PDO { + $p = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); + $p->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); + $p->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); + return $p; + }; + $set = function (string $k, string $v) use ($pdo): void { + $pdo()->prepare('INSERT OR REPLACE INTO settings (setting_key, setting_value) VALUES (?, ?)')->execute([$k, $v]); + }; + $call = function (string $method, string $path, string $jar, array $form = [], array $headers = []) use ($webPort): array { + $ch = curl_init("http://127.0.0.1:$webPort$path"); + curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, CURLOPT_FOLLOWLOCATION => false, CURLOPT_TIMEOUT => 60, CURLOPT_COOKIEJAR => $jar, CURLOPT_COOKIEFILE => $jar, CURLOPT_HTTPHEADER => array_merge(['Sec-Fetch-Mode: navigate', 'Sec-Fetch-User: ?1'], $headers)]); + if ($method === 'POST') { curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($form)); } + $b = (string) curl_exec($ch); + $s = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE); + curl_close($ch); + return [$s, $b]; + }; + // Kunden-Sitzung mit CSRF-Token + $cust = tempnam(sys_get_temp_dir(), 'ast'); + [, $lp] = $call('GET', '/staff/login.php', $cust); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $lp, $m); + $csrf = $m[1] ?? ''; + $as = function (string $action, array $f = [], ?string $jar = null, ?string $token = null) use ($call, $cust, $csrf): array { + [$s, $b] = $call('POST', '/assistant.php', $jar ?? $cust, array_merge(['action' => $action, 'csrf_token' => $token ?? $csrf], $f)); + return [$s, json_decode($b, true) ?? []]; + }; + + // Wissensdatenbank und zusätzliche Antworten + $db = $pdo(); + $db->exec("INSERT INTO kb_categories (name, slug, sort_order) VALUES ('Konto', 'konto', 1)"); + $cat = (int) $db->lastInsertId(); + $now = date('Y-m-d H:i:s'); + $art = $db->prepare('INSERT INTO kb_articles (category_id, title, slug, body, is_published, created_at, updated_at) VALUES (?,?,?,?,?,?,?)'); + $art->execute([$cat, 'Passwort zurücksetzen', 'passwort-zuruecksetzen', '

Klicken Sie auf der Anmeldeseite auf Passwort vergessen. Wir senden Ihnen einen Link per E-Mail.

', 1, $now, $now]); + $art->execute([$cat, 'Rechnungen herunterladen', 'rechnungen', '

Ihre Rechnungen finden Sie im Kundenbereich unter Rechnungen.

', 1, $now, $now]); + $art->execute([$cat, 'Interner Entwurf', 'entwurf', '

Geheimer Entwurf zum Thema Garantie.

', 0, $now, $now]); + $db->prepare('INSERT INTO assistant_answers (title, keywords, answer, is_active, created_at, updated_at) VALUES (?,?,?,?,?,?)') + ->execute(['Wie lange dauert der Versand?', 'Lieferzeit, Paket, Lieferung', "Der Versand dauert 2 bis 3 Werktage.\nDetails: https://example.org/versand", 1, $now, $now]); + $db->prepare('INSERT INTO assistant_answers (title, keywords, answer, is_active, created_at, updated_at) VALUES (?,?,?,?,?,?)') + ->execute(['Alte Antwort zur Garantie', 'Garantie', 'Diese Antwort ist abgeschaltet.', 0, $now, $now]); + + // ── Schalter ─────────────────────────────────────────────────────────── + [$s, $r] = $as('status'); + $check($s === 200 && $r['active'] === false, 'Ausgeschaltet: der Assistent ist nicht aktiv'); + [$s] = $as('ask', ['message' => 'Passwort']); + $check($s === 409, 'Ausgeschaltet: Fragen werden abgelehnt (HTTP ' . $s . ')'); + [$s] = $call('GET', '/home.php', $cust); + [, $home] = $call('GET', '/home.php', $cust); + $check(!str_contains($home, 'id="as-bubble"'), 'Ausgeschaltet: kein Fenster auf der Seite'); + + $set('assistant_enabled', '1'); + [$s, $r] = $as('status'); + $check($r['active'] === true && $r['name'] === 'Digitaler Assistent' && str_contains($r['greeting'], 'Hallo'), 'Eingeschaltet und Live-Chat aus: der Assistent ist aktiv, mit Vorgabe-Texten'); + [, $home] = $call('GET', '/home.php', $cust); + $check(str_contains($home, 'id="as-bubble"') && str_contains($home, '/assistant.php'), 'Das Fenster des Assistenten erscheint auf der Kundenseite'); + + $set('live_chat_enabled', '1'); + $db = $pdo(); + $db->prepare("INSERT OR REPLACE INTO staff_availability (staff_id, status, updated_at) VALUES (?, 'available', ?)")->execute([$ids['Agent'], $now]); + [$s, $r] = $as('status'); + $check($r['active'] === false, 'Live-Chat an und ein Mitarbeiter erreichbar: der Assistent ist nicht aktiv'); + [, $home] = $call('GET', '/home.php', $cust); + $check(!str_contains($home, 'id="as-bubble"') && str_contains($home, 'lc-bubble'), 'dann erscheint stattdessen das Live-Chat-Fenster'); + $set('assistant_mode', 'always'); + [$s, $r] = $as('status'); + $check($r['active'] === true, 'Einstellung „Immer“: aktiv, auch wenn jemand erreichbar ist'); + $set('assistant_mode', 'offline_only'); + $db->prepare("UPDATE staff_availability SET status = 'offline' WHERE staff_id = ?")->execute([$ids['Agent']]); + [$s, $r] = $as('status'); + $check($r['active'] === true, 'Live-Chat an, aber niemand erreichbar: der Assistent übernimmt'); + [, $home] = $call('GET', '/home.php', $cust); + $check(str_contains($home, 'id="as-bubble"') && !str_contains($home, 'id="lc-bubble"'), 'und ersetzt das Live-Chat-Fenster (nur eine Sprechblase)'); + $set('helpdesk_status', 'offline'); + [$s, $r] = $as('status'); + $check($r['active'] === false, 'Im Wartungsmodus ist der Assistent nicht aktiv'); + $set('helpdesk_status', 'online'); + + // ── Antworten ────────────────────────────────────────────────────────── + [$s, $r] = $as('ask', ['message' => 'Wie kann ich mein Passwort zurücksetzen?']); + $check($s === 200 && $r['type'] === 'answer' && $r['source'] === 'kb' && str_contains($r['text'], 'Passwort vergessen') && !str_contains($r['text'], 'color') && ($r['link'] ?? '') === '/kb_article.php?slug=passwort-zuruecksetzen', 'Antwort aus der Wissensdatenbank (Text ohne CSS, mit Link) ' . json_encode($r, JSON_UNESCAPED_UNICODE)); + [$s, $r] = $as('ask', ['message' => 'Wo finde ich meine Rechnung?']); + $check($r['type'] === 'answer' && $r['title'] === 'Rechnungen herunterladen', 'Einzahl und Mehrzahl passen zusammen („Rechnung“ findet „Rechnungen“)'); + [$s, $r] = $as('ask', ['message' => 'Wie lange dauert die Lieferung meines Pakets?']); + $check($r['type'] === 'answer' && $r['source'] === 'custom' && str_contains($r['text'], '2 bis 3 Werktage') && str_contains($r['text'], 'https://example.org/versand'), 'Zusätzliche Antwort aus dem Backend, gefunden über Stichwörter'); + $hits = (int) $pdo()->query("SELECT hits FROM assistant_answers WHERE title LIKE 'Wie lange%'")->fetchColumn(); + $check($hits === 1, 'Die Nutzung wird gezählt'); + [$s, $r] = $as('ask', ['message' => 'Wie lange dauert der Versand?']); + $check($r['source'] === 'custom', 'Eigene Antworten haben Vorrang'); + [$s, $r] = $as('ask', ['message' => 'Habe ich Garantie?']); + $check($r['type'] === 'none', 'Abgeschaltete Antworten und unveröffentlichte Artikel werden nicht verwendet'); + $pdo()->prepare('INSERT INTO assistant_answers (title, keywords, answer, is_active, created_at, updated_at) VALUES (?,?,?,?,?,?)')->execute(['Discord beitreten', 'Discord, Einladungslink', 'Hier ist der Link: https://discord.gg/beispiel', 1, $now, $now]); + [$s, $r] = $as('ask', ['message' => 'Wie bekomme ich Zugang zum Discord?']); + $check($r['type'] === 'answer' && $r['source'] === 'custom' && str_contains($r['text'], 'discord.gg/beispiel'), 'Ein hinterlegtes Stichwort genügt (Frage mit mehreren anderen Wörtern findet die Discord-Antwort) ' . json_encode($r, JSON_UNESCAPED_UNICODE)); + // Wissensdatenbank: Kategorie und Synonyme (Frage „Zugang zum Discord“ findet „Wie trete ich dem Server bei?“ in der Kategorie Discord) + $db = $pdo(); + $db->exec("UPDATE assistant_answers SET is_active = 0 WHERE title = 'Discord beitreten'"); + $db->exec("INSERT INTO kb_categories (name, slug, sort_order) VALUES ('Discord', 'discord', 2)"); + $dcat = (int) $db->lastInsertId(); + $art->execute([$dcat, 'Wie trete ich dem Server bei?', 'server-beitreten', '

https://discord.gg/Qtsna6ZHer – Der Server hat 400 Mitglieder. Du brauchst einen Discord-Account.

  1. Beitreten.
', 1, $now, $now]); + $art->execute([$cat, 'Wie bekomme ich Zugang zur Auto-Veröffentlichung?', 'auto-veroeffentlichung', '

Melde dich per Ticket, Discord oder Telegram. Wir senden dir die Zugangsdaten.

', 1, $now, $now]); + [$s, $r] = $as('ask', ['message' => 'Wie bekomme ich zugang zum Discord?']); + $check($r['type'] === 'answer' && $r['title'] === 'Wie trete ich dem Server bei?' && str_contains($r['text'], 'discord.gg/Qtsna6ZHer'), 'Wissensdatenbank: Kategorie „Discord“ und Synonym „Zugang = beitreten“ führen zum richtigen Artikel ' . json_encode($r, JSON_UNESCAPED_UNICODE)); + $db->exec("UPDATE assistant_answers SET is_active = 1 WHERE title = 'Discord beitreten'"); + [$s, $r] = $as('ask', ['message' => 'Wie wird das Wetter in Berlin morgen?']); + $check($r['type'] === 'none' && str_contains($r['text'], 'Ticket'), 'Ohne Treffer: Angebot, ein Ticket zu erstellen'); + [$s, $r] = $as('ask', ['message' => 'Ich möchte ein Ticket erstellen']); + $check($r['type'] === 'ticket', 'Wunsch nach einem Ticket startet die Ticket-Erfassung'); + [$s, $r] = $as('ask', ['message' => 'Hallo']); + $check($r['type'] === 'smalltalk', 'Begrüßung wird freundlich beantwortet'); + [$s, $r] = $as('ask', ['message' => 'Danke']); + $check($r['type'] === 'smalltalk', 'Dank wird beantwortet'); + [$s] = $as('ask', ['message' => ' ']); + $check($s === 422, 'Leere Frage wird abgelehnt'); + [$s] = $as('ask', ['message' => 'Passwort'], null, 'falscher-token'); + $check($s === 403, 'Falscher Token wird abgelehnt (HTTP ' . $s . ')'); + $set('kb_enabled', '0'); + [$s, $r] = $as('ask', ['message' => 'Wie kann ich mein Passwort zurücksetzen?']); + $check($r['type'] === 'none', 'Bei ausgeschalteter Wissensdatenbank im Portal werden ihre Artikel nicht ausgegeben'); + $set('kb_enabled', '1'); + // ── Ticket ───────────────────────────────────────────────────────────── + $tk = tempnam(sys_get_temp_dir(), 'ast'); + [, $lp] = $call('GET', '/staff/login.php', $tk); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $lp, $m); + $tcsrf = $m[1] ?? ''; + $prioId = (int) $pdo()->query('SELECT id FROM priorities ORDER BY sort_order DESC LIMIT 1')->fetchColumn(); + $db = $pdo(); + $db->prepare("INSERT INTO departments (name, email, is_active, auto_assign_mode, auto_assign_staff_id, created_at) VALUES ('First Support', '', 1, 'staff', ?, ?)")->execute([$ids['Chef'], $now]); + $firstDept = (int) $db->lastInsertId(); + $set('assistant_department_id', (string) $firstDept); + $set('assistant_priority_id', (string) $prioId); + $good = ['name' => 'Erika Muster', 'email' => 'erika@example.org', 'subject' => 'Meine Frage zur Rechnung', 'message' => 'Ich finde meine Rechnung nicht.']; + [$s, $r] = $as('ticket', ['name' => '', 'email' => 'x'] + $good, $tk, $tcsrf); + $check($s === 422 && !empty($r['error']), 'Ticket ohne Namen wird abgelehnt (HTTP ' . $s . ')'); + [$s, $r] = $as('ticket', ['email' => 'keine-mail'] + $good, $tk, $tcsrf); + $check($s === 422, 'Ungültige E-Mail-Adresse wird abgelehnt'); + [$s] = $as('ticket', ['hp_website' => 'http://spam'] + $good, $tk, $tcsrf); + $check($s === 400, 'Die Spam-Falle (verstecktes Feld) lehnt Bots ab'); + [$s] = $as('ticket', ['helpTopicId' => '99999'] + $good, $tk, $tcsrf); + $check($s === 422, 'Unbekanntes Hilfethema wird abgelehnt'); + [$s, $r] = $as('ticket', $good, $tk, $tcsrf); + $check($s === 201 && !empty($r['number']), 'Ticket wird erstellt (HTTP ' . $s . ' ' . json_encode($r, JSON_UNESCAPED_UNICODE) . ')'); + $t = $pdo()->prepare('SELECT * FROM tickets WHERE ticket_number = ?'); + $t->execute([$r['number'] ?? '']); + $row = $t->fetch() ?: []; + $check(($row['subject'] ?? '') === $good['subject'] && ($row['requester_email'] ?? '') === 'erika@example.org' && (int) ($row['department_id'] ?? 0) === $firstDept && (int) ($row['priority_id'] ?? 0) === $prioId, 'Betreff, Absender, eingestellte Abteilung und Priorität stimmen'); + $check((int) ($row['assigned_staff_id'] ?? 0) === $ids['Chef'], 'Die automatische Zuweisung der Abteilung greift'); + $tag = $pdo()->prepare('SELECT COUNT(*) FROM ticket_tags tt JOIN tags g ON g.id = tt.tag_id WHERE tt.ticket_id = ? AND g.name = ?'); + $tag->execute([$row['id'] ?? 0, 'Assistent']); + $log = $pdo()->prepare("SELECT COUNT(*) FROM activity_log WHERE ticket_id = ? AND action = 'Ticket über den digitalen Assistenten erstellt'"); + $log->execute([$row['id'] ?? 0]); + $check((int) $tag->fetchColumn() === 1 && (int) $log->fetchColumn() === 1, 'Das Ticket trägt den Tag „Assistent“ und der Verlauf nennt den Assistenten'); + $msg = $pdo()->prepare('SELECT message FROM ticket_threads WHERE ticket_id = ?'); + $msg->execute([$row['id'] ?? 0]); + $check(str_contains((string) $msg->fetchColumn(), 'Rechnung nicht'), 'Die Beschreibung steht im Ticket'); + $as('ticket', ['subject' => 'Zweites'] + $good, $tk, $tcsrf); + $as('ticket', ['subject' => 'Drittes'] + $good, $tk, $tcsrf); + [$s, $r] = $as('ticket', ['subject' => 'Viertes'] + $good, $tk, $tcsrf); + $check($s === 429, 'Höchstens 3 Tickets pro Stunde und Adresse (HTTP ' . $s . ')'); + + // ── Verwaltung ───────────────────────────────────────────────────────── + $login = function (string $email) use ($call): string { + $jar = tempnam(sys_get_temp_dir(), 'ast'); + [, $lp] = $call('GET', '/staff/login.php', $jar); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $lp, $m); + $call('POST', '/staff/login.php', $jar, ['csrf_token' => $m[1] ?? '', 'email' => $email, 'password' => 'Sehr-Sicher-1234']); + return $jar; + }; + $tokenOf = function (string $jar, string $path) use ($call): string { + [, $p] = $call('GET', $path, $jar); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $p, $mm); + return $mm[1] ?? ''; + }; + $jarA = $login('chef@test.de'); + [$s, $page] = $call('GET', '/staff/assistant.php?tab=answers', $jarA); + $check($s === 200 && str_contains($page, 'Digitaler Assistent') && str_contains($page, 'Zusätzliche Antworten') && str_contains($page, 'Wie lange dauert der Versand?'), 'Admin sieht die Verwaltungsseite mit den Antworten (HTTP ' . $s . ')'); + [, $menu] = $call('GET', '/staff/availability.php', $jarA); + $check(str_contains($menu, 'href="/staff/assistant.php"'), 'Der Menüpunkt „Digitaler Assistent“ steht im Adminportal'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + [$s] = $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'save_answer', 'id' => '0', 'title' => 'Öffnungszeiten', 'keywords' => 'geöffnet, Uhrzeit', 'answer' => 'Wir sind Mo-Fr von 9 bis 17 Uhr erreichbar.', 'is_active' => '1']); + $newAns = (int) $pdo()->query("SELECT COUNT(*) FROM assistant_answers WHERE title = 'Öffnungszeiten'")->fetchColumn(); + $check($s === 302 && $newAns === 1, 'Antwort im Backend anlegen'); + [$s, $r] = $as('ask', ['message' => 'Wann seid ihr geöffnet?']); + $check($r['type'] === 'answer' && $r['source'] === 'custom' && str_contains($r['text'], '9 bis 17'), 'Die neue Antwort wird sofort verwendet (Stichwort „geöffnet“)'); + [$s, $page] = $call('POST', '/staff/assistant.php', $jarA, ['action' => 'save_answer', 'id' => '0', 'title' => 'x', 'answer' => 'y']); + $check($s === 403, 'Ohne CSRF-Token wird nichts gespeichert (HTTP ' . $s . ')'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'save_settings', 'assistant_enabled' => '1', 'assistant_mode' => 'always', 'assistant_name' => 'Hilfe-Bot ', 'assistant_greeting' => 'Moin!', 'assistant_no_answer' => '', 'assistant_department_id' => '0', 'assistant_priority_id' => '0']); + [$s, $r] = $as('status'); + $check($r['name'] === 'Hilfe-Bot' && $r['greeting'] === 'Moin!' && $r['active'] === true, 'Name und Begrüßung lassen sich einstellen (HTML wird entfernt)'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + [$s, $page] = $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'test', 'question' => 'Wo finde ich meine Rechnung?']); + $check($s === 200 && str_contains($page, 'Rechnungen herunterladen'), 'Die Testfunktion zeigt die Antwort'); + $id = (int) $pdo()->query("SELECT id FROM assistant_answers WHERE title = 'Öffnungszeiten'")->fetchColumn(); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'delete_answer', 'id' => (string) $id]); + $check((int) $pdo()->query("SELECT COUNT(*) FROM assistant_answers WHERE title = 'Öffnungszeiten'")->fetchColumn() === 0, 'Antwort löschen'); + // Recht für Mitarbeiter + $jarB = $login('agent@test.de'); + [$s] = $call('GET', '/staff/availability.php', $jarB); + $check($s === 200, 'Regression: Mitarbeiter ohne Admin-Rolle kommen bei eingeschaltetem Live-Chat auf Seiten des Mitarbeiterbereichs (Menü-Zähler des Live-Chats, HTTP ' . $s . ')'); + [$s] = $call('GET', '/staff/assistant.php', $jarB); + $check($s === 302 || $s === 403, 'Mitarbeiter ohne das Recht kommen nicht auf die Seite (HTTP ' . $s . ')'); + $db = $pdo(); + $db->prepare('INSERT INTO roles (name, permissions) VALUES (?,?)')->execute(['Assistent-Pfleger', json_encode(['reply_ticket' => true, 'manage_assistant' => true])]); + $roleId = (int) $db->lastInsertId(); + $db->prepare('UPDATE staff SET role_id = ? WHERE id = ?')->execute([$roleId, $ids['Agent']]); + [$s, $page] = $call('GET', '/staff/assistant.php', $jarB); + $check($s === 200 && str_contains($page, 'Zusätzliche Antworten'), 'Mit dem Recht „Digitalen Assistenten verwalten“ darf ein Mitarbeiter die Seite nutzen (HTTP ' . $s . ') ' . ($s === 200 ? '' : substr((string) @file_get_contents($work . '/web.out'), -1200))); + // ── Fragen-Log ───────────────────────────────────────────────────────── + $lg = $pdo()->query('SELECT result, COUNT(*) n FROM assistant_log GROUP BY result')->fetchAll(PDO::FETCH_KEY_PAIR); + $check(($lg['kb'] ?? 0) >= 2 && ($lg['custom'] ?? 0) >= 2 && ($lg['none'] ?? 0) >= 2 && ($lg['ticket_request'] ?? 0) === 1 && ($lg['ticket_created'] ?? 0) === 3, 'Log: Fragen werden mit Ergebnis protokolliert ' . json_encode($lg)); + $check((int) $pdo()->query("SELECT COUNT(*) FROM assistant_log WHERE question IN ('Hallo','Danke')")->fetchColumn() === 0, 'Log: Begrüßung und Dank werden nicht protokolliert'); + $check((int) $pdo()->query("SELECT COUNT(*) FROM assistant_log WHERE matched_title = 'Wie lange dauert der Versand?' AND source = 'custom'")->fetchColumn() >= 1, 'Log: zeigt, welche eigene Antwort gefunden wurde'); + $check((int) $pdo()->query("SELECT COUNT(*) FROM assistant_log WHERE result = 'ticket_created' AND ticket_number IS NOT NULL")->fetchColumn() === 3, 'Log: erstellte Tickets mit Nummer'); + [$s, $page] = $call('GET', '/staff/assistant.php?lr=none&lp=all', $jarA); + $check($s === 200 && str_contains($page, 'Fragen-Log') && str_contains($page, 'Wie wird das Wetter in Berlin morgen?') && !str_contains($page, 'Wo finde ich meine Rechnung?'), 'Log: Filter „Keine Antwort“ zeigt nur unbeantwortete Fragen (HTTP ' . $s . ')'); + [$s, $page] = $call('GET', '/staff/assistant.php?lr=custom&lp=all', $jarA); + $check(str_contains($page, 'Wie lange dauert die Lieferung meines Pakets?') && !str_contains($page, 'Wie wird das Wetter in Berlin morgen?'), 'Log: Filter „Meine Antwort gefunden“'); + [$s, $page] = $call('GET', '/staff/assistant.php?lq=Wetter&lp=all', $jarA); + $check(str_contains($page, 'Wie wird das Wetter in Berlin morgen?') && !str_contains($page, 'Lieferung meines Pakets?'), 'Log: Suche im Text'); + $as('ask', ['message' => 'Wie wird das Wetter in Berlin morgen?']); + [, $page] = $call('GET', '/staff/assistant.php?lr=none&lp=all', $jarA); + $check(str_contains($page, 'Häufige Fragen ohne Antwort') && str_contains($page, '(2×)') && str_contains($page, 'Antwort dazu anlegen'), 'Log: häufige unbeantwortete Fragen mit Zähler und Link zum Anlegen'); + [, $page] = $call('GET', '/staff/assistant.php?new=1&title=' . rawurlencode('Wetter in Berlin'), $jarA); + $check(str_contains($page, 'value="Wetter in Berlin"'), 'Log: „Antwort anlegen“ füllt die Frage vor'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'save_settings', 'assistant_enabled' => '1', 'assistant_mode' => 'always', 'assistant_log_days' => '0']); + $before = (int) $pdo()->query('SELECT COUNT(*) FROM assistant_log')->fetchColumn(); + $as('ask', ['message' => 'Noch eine Frage zum Wetter']); + $check((int) $pdo()->query('SELECT COUNT(*) FROM assistant_log')->fetchColumn() === $before, 'Log: bei Aufbewahrung 0 wird nichts gespeichert'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'save_settings', 'assistant_enabled' => '1', 'assistant_mode' => 'always', 'assistant_log_days' => '90']); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'clear_log']); + $check((int) $pdo()->query('SELECT COUNT(*) FROM assistant_log')->fetchColumn() === 0, 'Log: Leeren löscht alle Einträge'); + [$s, $page] = $call('GET', '/staff/assistant.php', $jarB); + $check($s === 200 && str_contains($page, 'Fragen-Log'), 'Log: auch für Mitarbeiter mit dem Recht sichtbar'); + // ── Rückmeldung und eigene Synonyme ──────────────────────────────────── + [$s, $r] = $as('ask', ['message' => 'Wie lange dauert die Lieferung meines Pakets?']); + $check(!empty($r['logId']), 'Rückmeldung: die Antwort nennt ihre Log-Nummer'); + $lid = (int) ($r['logId'] ?? 0); + $as('feedback', ['logId' => (string) ($lid + 999), 'helpful' => '1']); + $check($pdo()->query('SELECT COUNT(*) FROM assistant_log WHERE helpful IS NOT NULL')->fetchColumn() == 0, 'Rückmeldung: fremde Log-Nummern werden ignoriert'); + [$s, $x] = $as('feedback', ['logId' => (string) $lid, 'helpful' => '1']); + $check($s === 200 && (int) $pdo()->query("SELECT helpful FROM assistant_log WHERE id = $lid")->fetchColumn() === 1, 'Rückmeldung: „Das hat geholfen“ wird gespeichert'); + [$s, $r2] = $as('ask', ['message' => 'Wo finde ich meine Rechnung?']); + $as('feedback', ['logId' => (string) ($r2['logId'] ?? 0), 'helpful' => '0']); + [, $page] = $call('GET', '/staff/assistant.php?lr=helpful&lp=all', $jarA); + $check(str_contains($page, 'Lieferung meines Pakets?') && !str_contains($page, 'Wo finde ich meine Rechnung?'), 'Log: Filter „Hat geholfen“'); + [, $page] = $call('GET', '/staff/assistant.php?lr=not_helpful&lp=all', $jarA); + $check(str_contains($page, 'Wo finde ich meine Rechnung?') && str_contains($page, '👎'), 'Log: Filter „Hat nicht geholfen“ mit Markierung'); + $db = $pdo(); + $db->prepare('INSERT INTO assistant_answers (title, keywords, answer, is_active, created_at, updated_at) VALUES (?,?,?,?,?,?)')->execute(['Erstattung beantragen', '', 'Schreiben Sie uns eine Nachricht mit Ihrer Bestellnummer.', 1, $now, $now]); + [$s, $r] = $as('ask', ['message' => 'Wie läuft die Rückerstattung ab?']); + $check($r['type'] === 'none', 'Synonyme: ohne eigene Gruppe passt „Rückerstattung“ nicht zu „Erstattung“'); + $tok = $tokenOf($jarA, '/staff/assistant.php'); + $call('POST', '/staff/assistant.php', $jarA, ['csrf_token' => $tok, 'action' => 'save_synonyms', 'assistant_synonyms' => "Erstattung, Rückerstattung, Geld zurück\nnur, einzeln"]); + [$s, $r] = $as('ask', ['message' => 'Wie läuft die Rückerstattung ab?']); + $check($r['type'] === 'answer' && $r['title'] === 'Erstattung beantragen', 'Synonyme: eigene Gruppe verbindet „Rückerstattung“ mit „Erstattung“ ' . json_encode($r, JSON_UNESCAPED_UNICODE)); + [, $page] = $call('GET', '/staff/assistant.php', $jarA); + $check(str_contains($page, 'Gleichbedeutende Wörter') && str_contains($page, 'Rückerstattung'), 'Synonyme: Eingabefeld zeigt die gespeicherten Gruppen'); + // Begrenzung der Fragen + $limited = false; + for ($i = 0; $i < 35; $i++) { [$s] = $as('ask', ['message' => 'Passwort']); if ($s === 429) { $limited = true; break; } } + $check($limited, 'Zu viele Fragen in kurzer Zeit werden gebremst (HTTP 429)'); + + @unlink($jarA); @unlink($jarB); @unlink($cust); @unlink($tk); +} finally { + if (isset($webProc) && is_resource($webProc)) { proc_terminate($webProc); proc_close($webProc); } +} + +usleep(300000); +$rm = function (string $d) use (&$rm) { + foreach (scandir($d) ?: [] as $e) { if ($e === '.' || $e === '..') continue; is_dir("$d/$e") && !is_link("$d/$e") ? $rm("$d/$e") : @unlink("$d/$e"); } + @rmdir($d); +}; +if (str_starts_with($work, sys_get_temp_dir() . '/deskhub-assistant-')) $rm($work); + +if ($failures) { + fwrite(STDERR, "Fehlgeschlagen:\n - " . implode("\n - ", $failures) . "\n"); + exit(1); +} +echo "Assistant checks passed ({$total} Prüfungen).\n"; diff --git a/DeskHub-Webseite/tests/assistant_api.php b/DeskHub-Webseite/tests/assistant_api.php new file mode 100644 index 00000000..efdb329c --- /dev/null +++ b/DeskHub-Webseite/tests/assistant_api.php @@ -0,0 +1,180 @@ +getPathname(), strlen($root) + 1)); + if (preg_match($skip, $rel) && !preg_match('#^(backups|uploads|plugins)/(\.htaccess|README\.md)$#', $rel)) continue; + if ($f->isDir()) { @mkdir($tmp . '/' . $rel, 0755, true); continue; } + @mkdir(dirname($tmp . '/' . $rel), 0755, true); + copy($f->getPathname(), $tmp . '/' . $rel); +} +@mkdir($tmp . '/uploads'); +@mkdir($tmp . '/config'); +file_put_contents($tmp . '/config/config.php', ' bin2hex(random_bytes(32)), + 'db' => ['driver' => 'sqlite', 'sqlite_path' => $tmp . '/database/deskhub.sqlite'], + 'site' => ['name' => 'Test', 'url' => 'http://127.0.0.1', 'admin_email' => 'a@test.de', 'timezone' => 'Europe/Berlin'], + 'uploads' => ['max_size_bytes' => 10485760, 'allowed_extensions' => ['png'], 'path' => $tmp . '/uploads'], +], true) . ';'); + +putenv('DESKHUB_CONFIG_JSON'); +putenv('DESKHUB_SQLITE_PATH'); +putenv('DESKHUB_TESTING'); +putenv('DESKHUB_API_ALLOW_INSECURE=1'); +require_once $root . '/database/sqlite_schema.php'; +require_once $root . '/database/migrate.php'; +$db = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); +$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); +$db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); +$db->exec('PRAGMA foreign_keys = ON'); +$db->exec(convert_schema_to_sqlite((string) file_get_contents($root . '/database/schema.sql'))); +$mig = run_migrations($db, true); +$now = date('Y-m-d H:i:s'); +$dept = (int) $db->query('SELECT id FROM departments ORDER BY id LIMIT 1')->fetchColumn(); +$db->exec('DELETE FROM staff'); +$ins = $db->prepare('INSERT INTO staff (name, email, password_hash, role, department_id, is_active, created_at) VALUES (?,?,?,?,?,1,?)'); +$ids = []; +foreach ([['Chef', 'chef@test.de', 'admin'], ['Agent', 'agent@test.de', 'agent'], ['Pfleger', 'pfleger@test.de', 'agent']] as [$n, $e, $r]) { + $ins->execute([$n, $e, password_hash('Sehr-Sicher-1234', PASSWORD_DEFAULT), $r, $dept, $now]); + $ids[$n] = (int) $db->lastInsertId(); +} +$db = null; + +$failures = []; +$total = 0; +$check = function (bool $ok, string $what) use (&$failures, &$total): void { $total++; if (!$ok) $failures[] = $what; }; +$webProc = proc_open([PHP_BINARY, '-S', "127.0.0.1:$webPort", '-t', $tmp], [['pipe', 'r'], ['file', $work . '/web.out', 'w'], ['file', $work . '/web.out', 'a']], $wp, $tmp); + +try { + for ($i = 0; $i < 50; $i++) { if (@fsockopen('127.0.0.1', $webPort)) break; usleep(100000); } + $pdo = function () use ($tmp): PDO { + $p = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); + $p->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); + $p->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); + return $p; + }; + $api = function (string $method, string $path, ?array $json = null, ?string $bearer = null) use ($webPort): array { + $ch = curl_init("http://127.0.0.1:$webPort$path"); + $h = ['Content-Type: application/json']; + if ($bearer) $h[] = 'Authorization: Bearer ' . $bearer; + curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, CURLOPT_TIMEOUT => 60, CURLOPT_HTTPHEADER => $h, CURLOPT_CUSTOMREQUEST => $method]); + if ($json !== null) curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($json)); + $b = (string) curl_exec($ch); + $s = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE); + curl_close($ch); + return [$s, json_decode($b, true) ?? $b]; + }; + $loginApi = function (string $email) use ($api): string { + [, $r] = $api('POST', '/api/staff/v1/login.php', ['email' => $email, 'password' => 'Sehr-Sicher-1234', 'deviceName' => 'Test']); + return (string) ($r['token'] ?? ''); + }; + $db = $pdo(); + $db->prepare('INSERT INTO roles (name, permissions) VALUES (?,?)')->execute(['Assistent-Pfleger', json_encode(['reply_ticket' => true, 'manage_assistant' => true])]); + $db->prepare('UPDATE staff SET role_id = ? WHERE email = ?')->execute([(int) $db->lastInsertId(), 'pfleger@test.de']); + $chef = $loginApi('chef@test.de'); + $agent = $loginApi('agent@test.de'); + $pfleger = $loginApi('pfleger@test.de'); + $check($chef !== '' && $agent !== '' && $pfleger !== '', 'Anmeldung der drei Mitarbeiter'); + + // ── Rechte ───────────────────────────────────────────────────────────── + foreach (['GET /api/staff/v1/assistant.php?section=overview', 'GET /api/staff/v1/assistant.php?section=answers', 'GET /api/staff/v1/assistant.php?section=log'] as $call) { + [$m, $p] = explode(' ', $call); + [$s] = $api($m, $p, null, $agent); + $check($s === 403, "Ohne Recht: $p wird abgelehnt (HTTP $s)"); + } + foreach (['save_settings', 'save_answer', 'delete_answer', 'save_synonyms', 'clear_log', 'test'] as $a) { + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => $a, 'title' => 'x', 'answer' => 'y', 'id' => 1, 'question' => 'x'], $agent); + $check($s === 403, "Ohne Recht: Aktion $a wird abgelehnt (HTTP $s)"); + } + [$s] = $api('GET', '/api/staff/v1/assistant.php?section=overview'); + $check($s === 401, 'Ohne Anmeldung: HTTP 401'); + [, $me] = $api('GET', '/api/staff/v1/me.php', null, $pfleger); + $check(($me['staff']['permissions']['manage_assistant'] ?? false) === true, 'Die App erfährt das Recht „manage_assistant“ über me.php'); + [, $me] = $api('GET', '/api/staff/v1/me.php', null, $agent); + $check(($me['staff']['permissions']['manage_assistant'] ?? true) === false, '… und bei Mitarbeitern ohne das Recht als „nein“'); + + // ── Einstellungen ────────────────────────────────────────────────────── + [$s, $o] = $api('GET', '/api/staff/v1/assistant.php?section=overview', null, $pfleger); + $check($s === 200 && $o['dbReady'] === true && $o['settings']['enabled'] === false && $o['settings']['logDays'] === 90 && !empty($o['defaults']['greeting']) && count($o['departments']) >= 1 && count($o['priorities']) >= 1, 'Mit dem Recht: Übersicht mit Einstellungen, Vorgaben, Abteilungen und Prioritäten (HTTP ' . $s . ')'); + $deptId = (int) $o['departments'][0]['id']; + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'save_settings', 'enabled' => true, 'mode' => 'always', 'name' => 'Hilfe-Bot ', 'greeting' => 'Moin!', 'noAnswer' => 'Nichts gefunden.', 'departmentId' => $deptId, 'priorityId' => 999999, 'logDays' => 30], $pfleger); + [, $o] = $api('GET', '/api/staff/v1/assistant.php?section=overview', null, $chef); + $st = $o['settings']; + $check($s === 200 && $st['enabled'] === true && $st['mode'] === 'always' && $st['name'] === 'Hilfe-Bot' && $st['greeting'] === 'Moin!' && $st['departmentId'] === $deptId && $st['priorityId'] === 0 && $st['logDays'] === 30 && $o['state']['activeNow'] === true, 'Einstellungen speichern: HTML entfernt, unbekannte Priorität ignoriert, Zustand „aktiv“ ' . json_encode($st)); + $check((int) $pdo()->query("SELECT COUNT(*) FROM admin_audit_log WHERE action LIKE 'Einstellungen des digitalen Assistenten%(App)'")->fetchColumn() === 1, 'Die Änderung steht im Admin-Protokoll'); + + // ── Antworten ────────────────────────────────────────────────────────── + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'save_answer', 'title' => '', 'answer' => 'x'], $pfleger); + $check($s === 422, 'Antwort ohne Titel wird abgelehnt (HTTP ' . $s . ')'); + [$s, $r] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'save_answer', 'title' => 'Wie lange dauert der Versand?', 'keywords' => 'Lieferzeit, Paket', 'answer' => 'Zwei bis drei Werktage.', 'isActive' => true], $pfleger); + $aid = (int) ($r['item']['id'] ?? 0); + $check($s === 200 && $aid > 0 && $r['item']['isActive'] === true, 'Antwort anlegen (HTTP ' . $s . ')'); + [, $r] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'save_answer', 'id' => $aid, 'title' => 'Wie lange dauert der Versand?', 'keywords' => 'Lieferzeit, Paket, Lieferung', 'answer' => 'Zwei bis drei Werktage.', 'isActive' => true], $chef); + $check(($r['item']['keywords'] ?? '') === 'Lieferzeit, Paket, Lieferung', 'Antwort ändern'); + [, $l] = $api('GET', '/api/staff/v1/assistant.php?section=answers', null, $pfleger); + $check(count($l['items'] ?? []) === 1 && $l['items'][0]['hits'] === 0, 'Liste der Antworten'); + [, $t] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'test', 'question' => 'Wie lange dauert die Lieferung meines Pakets?'], $pfleger); + $check(($t['found'] ?? false) === true && ($t['result']['source'] ?? '') === 'custom' && str_contains($t['result']['text'] ?? '', 'Werktage'), 'Frage ausprobieren findet die Antwort'); + [, $l] = $api('GET', '/api/staff/v1/assistant.php?section=answers', null, $pfleger); + $check($l['items'][0]['hits'] === 0, 'Das Ausprobieren zählt nicht als Nutzung'); + [, $t] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'test', 'question' => 'Wie wird das Wetter morgen?'], $pfleger); + $check(($t['found'] ?? true) === false, 'Ohne Treffer: found = false'); + + // ── Synonyme ─────────────────────────────────────────────────────────── + [$s, $r] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'save_synonyms', 'text' => "Versand, Zustellung, Auslieferung\nnur"], $pfleger); + $check($s === 200 && $r['groups'] === 1, 'Synonyme speichern: eine gültige Gruppe'); + [, $t] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'test', 'question' => 'Wann ist die Zustellung?'], $pfleger); + $check(($t['found'] ?? false) === true, 'Die eigene Gruppe wirkt sofort (Zustellung findet „Versand“)'); + + // ── Log ──────────────────────────────────────────────────────────────── + $now = date('Y-m-d H:i:s'); + $ins = $pdo()->prepare('INSERT INTO assistant_log (question, result, source, matched_title, helpful, created_at) VALUES (?,?,?,?,?,?)'); + $ins->execute(['Wo ist mein Paket?', 'custom', 'custom', 'Wie lange dauert der Versand?', 1, $now]); + $ins->execute(['Wie kündige ich?', 'none', null, null, null, $now]); + $ins->execute(['Wie kündige ich?', 'none', null, null, null, $now]); + $ins->execute(['Brauche Rechnung', 'kb', 'kb', 'Rechnungen', 0, $now]); + [$s, $g] = $api('GET', '/api/staff/v1/assistant.php?section=log&period=all', null, $pfleger); + $check($s === 200 && $g['total'] === 4 && $g['stats']['none'] === 2 && $g['stats']['helpful'] === 1 && $g['stats']['not_helpful'] === 1 && ($g['top'][0]['n'] ?? 0) === 2, 'Log: Einträge, Kennzahlen und häufigste Frage ohne Antwort ' . json_encode($g['stats'] ?? $g)); + [, $g] = $api('GET', '/api/staff/v1/assistant.php?section=log&period=all&result=none', null, $pfleger); + $check($g['total'] === 2, 'Log: Filter „Keine Antwort“'); + [, $g] = $api('GET', '/api/staff/v1/assistant.php?section=log&period=all&result=helpful', null, $pfleger); + $check($g['total'] === 1 && $g['items'][0]['helpful'] === true, 'Log: Filter „Hat geholfen“'); + [, $g] = $api('GET', '/api/staff/v1/assistant.php?section=log&period=all&q=Paket', null, $pfleger); + $check($g['total'] === 1, 'Log: Suche'); + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'clear_log'], $pfleger); + $check($s === 200 && (int) $pdo()->query('SELECT COUNT(*) FROM assistant_log')->fetchColumn() === 0, 'Log leeren'); + + // ── Löschen ──────────────────────────────────────────────────────────── + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'delete_answer', 'id' => $aid], $pfleger); + $check($s === 200 && (int) $pdo()->query('SELECT COUNT(*) FROM assistant_answers')->fetchColumn() === 0, 'Antwort löschen'); + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'delete_answer', 'id' => $aid], $pfleger); + $check($s === 404, 'Nochmal löschen: HTTP 404'); + [$s] = $api('POST', '/api/staff/v1/assistant.php', ['action' => 'unbekannt'], $pfleger); + $check($s === 422, 'Unbekannte Aktion: HTTP 422'); +} finally { + if (isset($webProc) && is_resource($webProc)) { proc_terminate($webProc); proc_close($webProc); } +} + +usleep(300000); +$rm = function (string $d) use (&$rm) { + foreach (scandir($d) ?: [] as $e) { if ($e === '.' || $e === '..') continue; is_dir("$d/$e") && !is_link("$d/$e") ? $rm("$d/$e") : @unlink("$d/$e"); } + @rmdir($d); +}; +if (str_starts_with($work, sys_get_temp_dir() . '/deskhub-assistapi-')) $rm($work); + +if ($failures) { + fwrite(STDERR, "Fehlgeschlagen:\n - " . implode("\n - ", $failures) . "\n"); + exit(1); +} +echo "Assistant API checks passed ({$total} Prüfungen).\n"; diff --git a/DeskHub-Webseite/tests/fcm_push.php b/DeskHub-Webseite/tests/fcm_push.php index b20dd82b..eb202376 100644 --- a/DeskHub-Webseite/tests/fcm_push.php +++ b/DeskHub-Webseite/tests/fcm_push.php @@ -208,7 +208,7 @@ try { $reset(); fcm_notify_mention($ticket, $agentB, $admin); $check($sends() === [], 'Rechte: Erwähnung in fremder Abteilung bleibt ohne Push'); - $check(array_keys(fcm_event_types_for($pdo->query('SELECT * FROM staff WHERE id = ' . $reader)->fetch())) === ['ticket_assigned', 'ticket_sla', 'ticket_mention'], 'Einstellungen zeigen einem Mitarbeiter ohne Antwort-Recht nur passende Arten'); + $check(array_keys(fcm_event_types_for($pdo->query('SELECT * FROM staff WHERE id = ' . $reader)->fetch())) === ['ticket_assigned', 'ticket_sla', 'ticket_mention', 'ticket_snooze', 'ticket_follow'], 'Einstellungen zeigen einem Mitarbeiter ohne Antwort-Recht nur passende Arten'); $check(!array_key_exists('chat_new', fcm_event_types_for($pdo->query('SELECT * FROM staff WHERE id = ' . $agentA)->fetch())), 'Live-Chat-Popups nur, wenn der Live-Chat eingeschaltet ist'); set_setting('live_chat_enabled', '1'); $check(array_key_exists('chat_new', fcm_event_types_for($pdo->query('SELECT * FROM staff WHERE id = ' . $agentA)->fetch())), 'mit eingeschaltetem Live-Chat erscheint die Art'); @@ -311,7 +311,7 @@ try { [, $chefReg] = $call('POST', '/api/staff/v1/push_device.php', ['action' => 'register', 'token' => 'devChef_' . str_repeat('b', 40), 'deviceName' => 'Chef-Handy'], $chefToken); // Push-Einstellungen und Absturzberichte der App [$s, $r] = $call('GET', '/api/staff/v1/push_prefs.php', null, $agentToken); - $check($s === 200 && count($r['events'] ?? []) === 5 && count($r['eventTypes'] ?? []) === 5 && !in_array('chat_new', $r['events'] ?? [], true) && ($r['quietFrom'] ?? 'x') === '', 'Push-Einstellungen lesen: Standard alles an (HTTP ' . $s . ')'); + $check($s === 200 && count($r['events'] ?? []) === 7 && count($r['eventTypes'] ?? []) === 7 && !in_array('chat_new', $r['events'] ?? [], true) && ($r['quietFrom'] ?? 'x') === '', 'Push-Einstellungen lesen: Standard alles an (HTTP ' . $s . ')'); [$s, $r] = $call('POST', '/api/staff/v1/push_prefs.php', ['events' => ['ticket_new', 'nix'], 'quietFrom' => '22:00', 'quietTo' => '06:00'], $agentToken); $check($s === 200 && ($r['events'] ?? []) === ['ticket_new'] && ($r['quietFrom'] ?? '') === '22:00', 'Push-Einstellungen speichern (unbekannte Ereignisse verworfen)'); [$s] = $call('POST', '/api/staff/v1/push_prefs.php', ['events' => [], 'quietFrom' => '25:00', 'quietTo' => '06:00'], $agentToken); diff --git a/DeskHub-Webseite/tests/session_timeout.php b/DeskHub-Webseite/tests/session_timeout.php index 53bf3cab..0f949b49 100644 --- a/DeskHub-Webseite/tests/session_timeout.php +++ b/DeskHub-Webseite/tests/session_timeout.php @@ -123,6 +123,24 @@ try { [$s, $body] = $call('GET', '/staff/session_ping.php?check=1', $jar, $POLL); $check($s === 401, 'Die Abfrage der Restzeit meldet ebenfalls „abgelaufen“ (HTTP ' . $s . ')'); + // C2: Seite wird vom Browser selbst neu geladen (Tab nach dem Ruhezustand, Neuladen per Skript): bei abgelaufener Sitzung Anmeldeseite, nie die rohe Fehlermeldung + $jar = $login(); + $setAge($jar, 31 * 60); + [$s, $body, $loc] = $call('GET', '/staff/reports.php', $jar, $SCRIPT_NAV); + $check($s === 302 && str_contains($loc, 'login') && !str_contains($body, 'sessionExpired'), 'Vom Browser selbst ausgelöster Seitenaufruf bei abgelaufener Sitzung führt zur Anmeldung statt zur Fehlermeldung (HTTP ' . $s . ')'); + $jar = $login(); + $setAge($jar, 31 * 60); + [$s, $body, $loc] = $call('GET', '/staff/reports.php', $jar, ['Accept: text/html,application/xhtml+xml']); + $check($s === 302 && str_contains($loc, 'login'), 'Auch ältere Browser ohne Sec-Fetch-Kopfzeilen werden bei einem Seitenaufruf zur Anmeldung geleitet (HTTP ' . $s . ')'); + + // C3: Ein Hintergrund-Abruf beendet die abgelaufene Sitzung zuerst; die nächste Seite zeigt trotzdem den Grund auf der Anmeldeseite + $jar = $login(); + $setAge($jar, 31 * 60); + $call('GET', '/staff/availability_status.php', $jar, $POLL); + [$s, , $loc] = $call('GET', '/staff/reports.php', $jar, $USER_NAV); + [$s2, $loginPage] = $call('GET', '/staff/login.php', $jar, $USER_NAV); + $check($s === 302 && str_contains($loc, 'login') && $s2 === 200 && str_contains($loginPage, 'wegen Inaktivität abgemeldet'), 'Die Anmeldeseite nennt den Grund („wegen Inaktivität abgemeldet“), auch wenn ein Hintergrund-Abruf die Sitzung zuerst beendet hat'); + // D: echter Seitenaufruf (Klick/F5) verlängert, per Skript ausgelöstes Neuladen nicht $jar = $login(); $setAge($jar, 29 * 60); diff --git a/DeskHub-Webseite/tests/ticket_extras.php b/DeskHub-Webseite/tests/ticket_extras.php new file mode 100644 index 00000000..f2268364 --- /dev/null +++ b/DeskHub-Webseite/tests/ticket_extras.php @@ -0,0 +1,240 @@ +getPathname(), strlen($root) + 1)); + if (preg_match($skip, $rel) && !preg_match('#^(backups|uploads|plugins)/(\.htaccess|README\.md)$#', $rel)) continue; + if ($f->isDir()) { @mkdir($tmp . '/' . $rel, 0755, true); continue; } + @mkdir(dirname($tmp . '/' . $rel), 0755, true); + copy($f->getPathname(), $tmp . '/' . $rel); +} +@mkdir($tmp . '/uploads'); +@mkdir($tmp . '/config'); +file_put_contents($tmp . '/config/config.php', ' bin2hex(random_bytes(32)), + 'db' => ['driver' => 'sqlite', 'sqlite_path' => $tmp . '/database/deskhub.sqlite'], + 'site' => ['name' => 'Test', 'url' => 'http://127.0.0.1', 'admin_email' => 'a@test.de', 'timezone' => 'Europe/Berlin'], + 'uploads' => ['max_size_bytes' => 10485760, 'allowed_extensions' => ['png'], 'path' => $tmp . '/uploads'], +], true) . ';'); + +putenv('DESKHUB_CONFIG_JSON'); +putenv('DESKHUB_SQLITE_PATH'); +putenv('DESKHUB_TESTING'); +putenv('DESKHUB_API_ALLOW_INSECURE=1'); +require_once $root . '/database/sqlite_schema.php'; +require_once $root . '/database/migrate.php'; +$db = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); +$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); +$db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); +$db->exec('PRAGMA foreign_keys = ON'); +$db->exec(convert_schema_to_sqlite((string) file_get_contents($root . '/database/schema.sql'))); +$mig = run_migrations($db, true); +$now = date('Y-m-d H:i:s'); +$dept = (int) $db->query('SELECT id FROM departments ORDER BY id LIMIT 1')->fetchColumn(); +$db->exec('DELETE FROM staff'); +$ins = $db->prepare('INSERT INTO staff (name, email, password_hash, role, department_id, is_active, created_at) VALUES (?,?,?,?,?,1,?)'); +$ids = []; +foreach ([['Chef', 'chef@test.de', 'admin'], ['Agent', 'agent@test.de', 'agent']] as [$n, $e, $r]) { + $ins->execute([$n, $e, password_hash('Sehr-Sicher-1234', PASSWORD_DEFAULT), $r, $dept, $now]); + $ids[$n] = (int) $db->lastInsertId(); +} +$db = null; + +$failures = []; +$total = 0; +$check = function (bool $ok, string $what) use (&$failures, &$total): void { $total++; if (!$ok) $failures[] = $what; }; +$webProc = proc_open([PHP_BINARY, '-S', "127.0.0.1:$webPort", '-t', $tmp], [['pipe', 'r'], ['file', $work . '/web.out', 'w'], ['file', $work . '/web.out', 'a']], $wp, $tmp); + +try { + for ($i = 0; $i < 50; $i++) { if (@fsockopen('127.0.0.1', $webPort)) break; usleep(100000); } + putenv('DESKHUB_SQLITE_PATH=' . $tmp . '/database/deskhub.sqlite'); // nur für die Kommandozeilen-Aufrufe unten (der Webserver läuft schon) + $pdo = function () use ($tmp): PDO { + $p = new PDO('sqlite:' . $tmp . '/database/deskhub.sqlite'); + $p->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); + $p->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); + return $p; + }; + $call = function (string $method, string $path, string $jar, array $form = []) use ($webPort): array { + $ch = curl_init("http://127.0.0.1:$webPort$path"); + curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, CURLOPT_FOLLOWLOCATION => false, CURLOPT_TIMEOUT => 60, CURLOPT_COOKIEJAR => $jar, CURLOPT_COOKIEFILE => $jar, CURLOPT_HTTPHEADER => ['Sec-Fetch-Mode: navigate', 'Sec-Fetch-User: ?1']]); + if ($method === 'POST') { curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($form)); } + $b = (string) curl_exec($ch); + $s = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE); + curl_close($ch); + return [$s, $b]; + }; + $login = function (string $email) use ($call): string { + $jar = tempnam(sys_get_temp_dir(), 'tex'); + [, $lp] = $call('GET', '/staff/login.php', $jar); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $lp, $m); + $call('POST', '/staff/login.php', $jar, ['csrf_token' => $m[1] ?? '', 'email' => $email, 'password' => 'Sehr-Sicher-1234']); + return $jar; + }; + $tokenOf = function (string $jar, string $path) use ($call): string { + [, $p] = $call('GET', $path, $jar); + preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $p, $mm); + return $mm[1] ?? ''; + }; + $cli = function (string $script) use ($tmp, $work): string { + $file = $work . '/run_' . bin2hex(random_bytes(3)) . '.php'; + file_put_contents($file, "&1'); + }; + $cron = fn(string $name): string => (string) shell_exec(escapeshellarg(PHP_BINARY) . ' ' . escapeshellarg($tmp . '/cron/' . $name) . ' 2>&1'); + + $db = $pdo(); + $now = date('Y-m-d H:i:s'); + $dept = (int) $db->query('SELECT id FROM departments ORDER BY id LIMIT 1')->fetchColumn(); + $prio = (int) $db->query('SELECT id FROM priorities ORDER BY sort_order LIMIT 1')->fetchColumn(); + $mk = function (string $number, string $subject, string $status, string $updated, string $email = 'kunde@example.org') use ($pdo, $dept, $prio): int { + $d = $pdo(); + $d->prepare('INSERT INTO tickets (ticket_number, subject, requester_name, requester_email, department_id, priority_id, status, source, created_at, updated_at) VALUES (?,?,?,?,?,?,?,?,?,?)') + ->execute([$number, $subject, 'Kunde', $email, $dept, $prio, $status, 'web', $updated, $updated]); + return (int) $d->lastInsertId(); + }; + $t1 = $mk('T9001', 'Passwort zurücksetzen funktioniert nicht', 'open', $now); + $t2 = $mk('T9002', 'Passwort zurücksetzen Problem', 'closed', date('Y-m-d H:i:s', time() - 86400 * 20)); + $db->exec("INSERT INTO kb_categories (name, slug, sort_order) VALUES ('Konto', 'konto', 1)"); + $db->prepare('INSERT INTO kb_articles (category_id, title, slug, body, is_published, created_at, updated_at) VALUES (?,?,?,?,?,?,?)') + ->execute([(int) $db->lastInsertId(), 'Passwort zurücksetzen', 'passwort-zuruecksetzen', '

Klicken Sie auf Passwort vergessen.

', 1, $now, $now]); + + $jarA = $login('chef@test.de'); + $jarB = $login('agent@test.de'); + + // ── Wiedervorlage ────────────────────────────────────────────────────── + [$s, $page] = $call('GET', '/staff/ticket_view.php?n=T9001', $jarA); + $check($s === 200 && str_contains($page, 'Wiedervorlage') && str_contains($page, 'Auf später legen') && str_contains($page, 'Ticket beobachten'), 'Ticketseite zeigt Wiedervorlage und Beobachten (HTTP ' . $s . ')'); + [$s, $list] = $call('GET', '/staff/tickets.php?tab=open', $jarA); + $check(str_contains($list, 'T9001'), 'Vorher: Ticket steht in der Liste „Offen“'); + $tok = $tokenOf($jarA, '/staff/ticket_view.php?n=T9001'); + $call('POST', '/staff/ticket_view.php?n=T9001', $jarA, ['csrf_token' => $tok, 'action' => 'snooze', 'snooze_choice' => 'custom', 'snooze_custom' => date('Y-m-d\TH:i', time() - 3600)]); + $check($pdo()->query("SELECT snoozed_until FROM tickets WHERE id = $t1")->fetchColumn() === null, 'Ein Zeitpunkt in der Vergangenheit wird abgelehnt'); + $tok = $tokenOf($jarA, '/staff/ticket_view.php?n=T9001'); + $call('POST', '/staff/ticket_view.php?n=T9001', $jarA, ['csrf_token' => $tok, 'action' => 'snooze', 'snooze_choice' => '3h']); + $until = (string) $pdo()->query("SELECT snoozed_until FROM tickets WHERE id = $t1")->fetchColumn(); + $check($until !== '' && strtotime($until) > time() + 2 * 3600 && strtotime($until) < time() + 4 * 3600, 'Wiedervorlage in 3 Stunden wird gespeichert'); + [, $list] = $call('GET', '/staff/tickets.php?tab=open', $jarA); + $check(!str_contains($list, 'T9001'), 'In der Wiedervorlage: Ticket verschwindet aus „Offen“'); + [, $list] = $call('GET', '/staff/tickets.php?tab=all', $jarA); + $check(!str_contains($list, 'T9001'), '… und aus „Alle“'); + [, $list] = $call('GET', '/staff/tickets.php?tab=snoozed', $jarA); + $check(str_contains($list, 'T9001') && str_contains($list, 'Wiedervorlage'), '… und steht im Tab „Wiedervorlage“'); + $tok = $tokenOf($jarA, '/staff/ticket_view.php?n=T9001'); + $call('POST', '/staff/ticket_view.php?n=T9001', $jarA, ['csrf_token' => $tok, 'action' => 'unsnooze']); + [, $list] = $call('GET', '/staff/tickets.php?tab=open', $jarA); + $check(str_contains($list, 'T9001'), 'Zurückholen: Ticket ist wieder in der Liste'); + + // fällig: Cron holt zurück + $pdo()->prepare('UPDATE tickets SET snoozed_until = ?, snoozed_by = ? WHERE id = ?')->execute([date('Y-m-d H:i:s', time() - 60), 1, $t1]); + $out = $cron('process_snoozes.php'); + $check($pdo()->query("SELECT snoozed_until FROM tickets WHERE id = $t1")->fetchColumn() === null && str_contains($out, '1 Ticket'), 'Fällige Wiedervorlage wird vom Cron zurückgeholt ' . trim($out)); + $act = $pdo()->prepare("SELECT COUNT(*) FROM activity_log WHERE ticket_id = ? AND action = 'Wiedervorlage fällig'"); + $act->execute([$t1]); + $check((int) $act->fetchColumn() === 1, 'Der Verlauf nennt die fällige Wiedervorlage'); + + // Kundenantwort holt sofort zurück + $pdo()->prepare('UPDATE tickets SET snoozed_until = ?, snoozed_by = 1 WHERE id = ?')->execute([date('Y-m-d H:i:s', time() + 86400), $t1]); + $out = $cli("\$p = get_db(); \$t = \$p->query('SELECT * FROM tickets WHERE id = $t1')->fetch(); notify_new_reply_channels(\$t, 'Hallo, noch eine Frage');\necho 'fertig';"); + $check(str_contains($out, 'fertig') && $pdo()->query("SELECT snoozed_until FROM tickets WHERE id = $t1")->fetchColumn() === null, 'Antwortet der Kunde, kommt das Ticket sofort zurück ' . trim($out)); + + // ── Beobachter ───────────────────────────────────────────────────────── + $pdo()->exec('UPDATE tickets SET locked_by = NULL, locked_at = NULL'); // der Admin hatte das Ticket geöffnet (Sperre) + $tok = $tokenOf($jarB, '/staff/ticket_view.php?n=T9001'); + $call('POST', '/staff/ticket_view.php?n=T9001', $jarB, ['csrf_token' => $tok, 'action' => 'follow']); + $check((int) $pdo()->query("SELECT COUNT(*) FROM ticket_followers WHERE ticket_id = $t1")->fetchColumn() === 1, 'Beobachten: Mitarbeiter wird als Beobachter eingetragen'); + [, $page] = $call('GET', '/staff/ticket_view.php?n=T9001', $jarB); + $check(str_contains($page, 'Nicht mehr beobachten') && str_contains($page, 'Agent'), 'Die Ticketseite zeigt den Beobachter und „Nicht mehr beobachten“'); + $out = $cli("\$p = get_db(); \$t = \$p->query('SELECT * FROM tickets WHERE id = $t1')->fetch(); ticket_followers_notify(\$t, 'Neue Kundenantwort', null); echo 'fertig';"); + $check(str_contains($out, 'fertig') && !str_contains($out, 'Fatal'), 'Benachrichtigung der Beobachter läuft ohne Fehler ' . trim($out)); + $tok = $tokenOf($jarB, '/staff/ticket_view.php?n=T9001'); + $call('POST', '/staff/ticket_view.php?n=T9001', $jarB, ['csrf_token' => $tok, 'action' => 'unfollow']); + $check((int) $pdo()->query("SELECT COUNT(*) FROM ticket_followers WHERE ticket_id = $t1")->fetchColumn() === 0, 'Nicht mehr beobachten entfernt den Eintrag'); + + // ── Ähnliche Tickets und Artikel ─────────────────────────────────────── + [, $page] = $call('GET', '/staff/ticket_view.php?n=T9001', $jarA); + $check(str_contains($page, 'Dazu passend') && str_contains($page, '/kb_article.php?slug=passwort-zuruecksetzen') && str_contains($page, 'T9002'), 'Ähnliches: passender Artikel und gelöstes Ticket werden vorgeschlagen'); + [, $page] = $call('GET', '/staff/ticket_view.php?n=T9002', $jarA); + $check(!str_contains($page, 'href="/staff/ticket_view.php?n=T9002" target'), 'Ähnliches: ein Ticket schlägt sich nicht selbst vor'); + + // ── Erinnerung an Kunden ─────────────────────────────────────────────── + $old = date('Y-m-d H:i:s', time() - 5 * 86400); + $t3 = $mk('T9003', 'Frage zur Lieferung', 'answered', $old); + $t4 = $mk('T9004', 'Frage zur Rechnung', 'answered', date('Y-m-d H:i:s', time() - 86400)); + $out = $cron('remind_customers.php'); + $check(str_contains($out, 'deaktiviert') && $pdo()->query("SELECT reminder_sent_at FROM tickets WHERE id = $t3")->fetchColumn() === null, 'Erinnerung ist standardmäßig aus'); + [$s, $sp] = $call('GET', '/staff/settings.php', $jarA); + $check(str_contains($sp, 'Kunden erinnern'), 'Die Einstellung „Kunden erinnern“ steht in den Einstellungen'); + $set = $pdo()->prepare('INSERT OR REPLACE INTO settings (setting_key, setting_value) VALUES (?, ?)'); + foreach (['remind_enabled' => '1', 'remind_after_days' => '3', 'auto_close_enabled' => '1', 'auto_close_days' => '7'] as $k => $v) $set->execute([$k, $v]); + $out = $cron('remind_customers.php'); + $row = $pdo()->query("SELECT reminder_sent_at, updated_at FROM tickets WHERE id = $t3")->fetch(); + $check(!empty($row['reminder_sent_at']) && $row['updated_at'] === $old, 'Nach 5 Tagen ohne Reaktion geht eine Erinnerung raus, die Frist zum Schließen bleibt unverändert ' . trim($out)); + $check($pdo()->query("SELECT reminder_sent_at FROM tickets WHERE id = $t4")->fetchColumn() === null, 'Ein Ticket mit frischer Antwort wird nicht erinnert'); + $cron('remind_customers.php'); + $act = $pdo()->prepare("SELECT COUNT(*) FROM activity_log WHERE ticket_id = ? AND action = 'Erinnerung an den Kunden gesendet'"); + $act->execute([$t3]); + $check((int) $act->fetchColumn() === 1, 'Pro Antwort nur eine Erinnerung'); + $cli("\$p = get_db(); \$t = \$p->query('SELECT * FROM tickets WHERE id = $t3')->fetch(); notify_new_reply_channels(\$t, 'Danke');"); + $check($pdo()->query("SELECT reminder_sent_at FROM tickets WHERE id = $t3")->fetchColumn() === null, 'Eine Kundenantwort setzt die Erinnerung zurück'); + + // ── Schnittstelle für Android und Windows ────────────────────────────── + $api = function (string $method, string $path, ?array $json = null, ?string $bearer = null) use ($webPort): array { + $ch = curl_init("http://127.0.0.1:$webPort$path"); + $h = ['Content-Type: application/json']; + if ($bearer) $h[] = 'Authorization: Bearer ' . $bearer; + curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, CURLOPT_TIMEOUT => 60, CURLOPT_HTTPHEADER => $h, CURLOPT_CUSTOMREQUEST => $method]); + if ($json !== null) curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($json)); + $b = (string) curl_exec($ch); + $s = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE); + curl_close($ch); + return [$s, json_decode($b, true) ?? $b]; + }; + [, $lg] = $api('POST', '/api/staff/v1/login.php', ['email' => 'chef@test.de', 'password' => 'Sehr-Sicher-1234', 'deviceName' => 'Test']); + $bt = (string) ($lg['token'] ?? ''); + $check($bt !== '', 'App-Schnittstelle: Anmeldung klappt'); + $iso = gmdate('Y-m-d\TH:i:s\Z', time() + 2 * 3600); + [$s, $r] = $api('PATCH', '/api/staff/v1/ticket_update.php', ['number' => 'T9001', 'snoozeUntil' => $iso], $bt); + $check($s === 200 && !empty($r['ticket']['snoozedUntil']), 'App: Wiedervorlage setzen (ISO-Zeit), Antwort nennt snoozedUntil (HTTP ' . $s . ')'); + [, $r] = $api('GET', '/api/staff/v1/tickets.php?status=open,pending,answered,on_hold,resolved,closed&perPage=50', null, $bt); + $nums = array_column($r['items'] ?? [], 'number'); + $check(!in_array('T9001', $nums, true) && in_array('T9002', $nums, true), 'App: Ticket in der Wiedervorlage fehlt in der normalen Liste'); + [, $r] = $api('GET', '/api/staff/v1/tickets.php?status=open,pending,answered,on_hold,resolved,closed&snoozed=1', null, $bt); + $check(array_column($r['items'] ?? [], 'number') === ['T9001'], 'App: ?snoozed=1 liefert nur die Wiedervorlagen'); + [$s, $r] = $api('PATCH', '/api/staff/v1/ticket_update.php', ['number' => 'T9001', 'snoozeUntil' => gmdate('Y-m-d\TH:i:s\Z', time() - 100)], $bt); + $check($s === 422, 'App: Zeitpunkt in der Vergangenheit wird abgelehnt (HTTP ' . $s . ')'); + [, $r] = $api('PATCH', '/api/staff/v1/ticket_update.php', ['number' => 'T9001', 'snoozeUntil' => null, 'following' => true], $bt); + $check(empty($r['ticket']['snoozedUntil']) && ($r['ticket']['following'] ?? false) === true, 'App: Wiedervorlage aufheben und beobachten in einem Aufruf'); + [, $r] = $api('GET', '/api/staff/v1/tickets.php?status=open,pending,answered,on_hold,resolved,closed&following=1', null, $bt); + $check(array_column($r['items'] ?? [], 'number') === ['T9001'], 'App: ?following=1 liefert nur beobachtete Tickets'); + [, $r] = $api('GET', '/api/staff/v1/ticket.php?number=T9001', null, $bt); + $check(!empty($r['ticket']['similar']['articles']) && !empty($r['ticket']['similar']['tickets']) && ($r['ticket']['following'] ?? false) === true, 'App: Ticketdetail enthält „Dazu passend“ und following'); + + @unlink($jarA); @unlink($jarB); +} finally { + if (isset($webProc) && is_resource($webProc)) { proc_terminate($webProc); proc_close($webProc); } +} + +usleep(300000); +$rm = function (string $d) use (&$rm) { + foreach (scandir($d) ?: [] as $e) { if ($e === '.' || $e === '..') continue; is_dir("$d/$e") && !is_link("$d/$e") ? $rm("$d/$e") : @unlink("$d/$e"); } + @rmdir($d); +}; +if (str_starts_with($work, sys_get_temp_dir() . '/deskhub-extras-')) $rm($work); + +if ($failures) { + fwrite(STDERR, "Fehlgeschlagen:\n - " . implode("\n - ", $failures) . "\n"); + exit(1); +} +echo "Ticket extras checks passed ({$total} Prüfungen).\n";