deskhub/DeskHub-Webseite/tests/staff_chat.php

<?php
declare(strict_types=1);
/**
 * Prüft den Chat der Mitarbeiter untereinander: Abruf über laufende Nummern (keine Doppelten), Anzeige-Angaben für neue Nachrichten,
 * gleiche Darstellung beim Nachladen wie beim Laden der Seite.
 */

date_default_timezone_set('Europe/Berlin'); // wie in der Test-Installation
$root = dirname(__DIR__);
$work = sys_get_temp_dir() . '/deskhub-staffchat-' . bin2hex(random_bytes(4));
$tmp = $work . '/inst';
mkdir($tmp, 0755, true);
$webPort = random_int(37000, 37499);
$skip = '#^(config/config\.php|database/[^/]+\.sqlite[^/]*|backups|uploads|tests|plugins/[^/]+|\.git)(/|$)#';
foreach (new RecursiveIteratorIterator(new RecursiveDirectoryIterator($root, FilesystemIterator::SKIP_DOTS), RecursiveIteratorIterator::SELF_FIRST) as $f) {
    $rel = str_replace(chr(92), '/', substr($f->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', '<?php return ' . var_export([
    'app_key' => 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); }
    $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', 'X-Requested-With: XMLHttpRequest']]);
        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(), 'chat');
        [, $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;
    };
    $token = function (string $jar, string $path) use ($call): string { [, $p] = $call('GET', $path, $jar); preg_match('/name="csrf_token" value="([a-f0-9]+)"/', $p, $m); return $m[1] ?? ''; };
    $ids = $pdo()->query('SELECT email, id FROM staff')->fetchAll(PDO::FETCH_KEY_PAIR);
    $chefId = (int) $ids['chef@test.de']; $agentId = (int) $ids['agent@test.de'];
    $jarA = $login('chef@test.de');
    $jarB = $login('agent@test.de');

    $send = function (string $jar, int $toId, string $text) use ($call, $token): void {
        $t = $token($jar, '/staff/chat.php?with=' . $toId);
        $call('POST', '/staff/chat.php', $jar, ['csrf_token' => $t, 'to_id' => (string) $toId, 'message' => $text]);
    };
    $poll = function (string $jar, int $withId, int $after) use ($call): array { [, $b] = $call('GET', "/staff/chat.php?with=$withId&action=poll&after=$after", $jar); return json_decode($b, true) ?? []; };

    $send($jarA, $agentId, 'Hallo Agent');
    $send($jarA, $agentId, "Zweite Zeile\nmit Umbruch <b>fett</b>");
    $m = $poll($jarB, $chefId, 0);
    $check(count($m) === 2 && $m[0]['message'] === 'Hallo Agent' && $m[0]['id'] < $m[1]['id'], 'Abruf liefert die neuen Nachrichten in der Reihenfolge ihrer Nummer');
    $check(($m[0]['initial'] ?? '') === 'C' && !empty($m[0]['av_class']) && $m[0]['from_name'] === 'Chef' && (int) $m[0]['from_staff_id'] === $chefId, 'Abruf enthält Initiale, Farbklasse und Absender für die Anzeige');
    $check(count($poll($jarB, $chefId, (int) $m[1]['id'])) === 0, 'Nach der letzten Nummer kommt nichts mehr (keine Doppelten)');
    $check(count($poll($jarB, $chefId, (int) $m[0]['id'])) === 1, 'Ab einer mittleren Nummer kommt nur die jüngere Nachricht');

    // Auch die eigene Nachricht kommt mit Nummer zurück, damit die Seite sie ohne Neuladen richtig zeigt
    $own = $poll($jarA, $agentId, 0);
    $check(count($own) === 2 && (int) $own[0]['from_staff_id'] === $chefId, 'Der Absender sieht seine Nachrichten im Abruf (mit Nummer und Serverzeit)');

    // Seite: Nachrichten tragen ihre Nummer, die Skripte nutzen die Klassen der Seite (nicht die alten)
    [, $page] = $call('GET', '/staff/chat.php?with=' . $chefId, $jarB);
    $check(preg_match_all('/class="ac-msg [a-z]+" data-id="\d+"/', $page) === 2, 'Die Seite zeigt beide Nachrichten mit ihrer Nummer');
    $check(str_contains($page, "'ac-msg-bubble'") && str_contains($page, "'ac-msg-time'") && !str_contains($page, 'chat-bubble') && !str_contains($page, 'bubble-text'), 'Neue Nachrichten werden mit denselben Klassen gebaut wie beim Laden der Seite');
    $check(str_contains($page, 'var lastId = ' . (int) $m[1]['id'] . ';'), 'Der Abruf startet bei der letzten bekannten Nummer');
    $check(!str_contains($page, 'toISOString'), 'Die Seite benutzt keine Browser-Uhrzeit mehr (Zeitzonen-Fehler)');
    $check(str_contains($page, 'Zweite Zeile<br />') && str_contains($page, '&lt;b&gt;fett&lt;/b&gt;'), 'Text wird maskiert, Zeilenumbrüche bleiben');

    // fremde Konversation bleibt fremd
    $jarC = $login('agent@test.de');
    $check(count($poll($jarC, $chefId, 0)) === 2, 'Gegenstelle sieht dieselben Nachrichten');
    @unlink($jarA); @unlink($jarB); @unlink($jarC);
} 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-staffchat-')) $rm($work);

if ($failures) {
    fwrite(STDERR, "Fehlgeschlagen:\n - " . implode("\n - ", $failures) . "\n");
    exit(1);
}
echo "Staff chat checks passed ({$total} Prüfungen).\n";