<?php
/**
 * GPUQ STT-Exec: wird vom GPUQ-Worker aufgerufen (job_type vr_stt).
 * POST { _gpuq_secret, audio_path, language } → Transkription via vrstt (127.0.0.1:8032).
 */

header('Content-Type: application/json; charset=utf-8');

if ($_SERVER['REQUEST_METHOD'] !== 'POST') {
    http_response_code(405);
    echo json_encode(['ok' => false, 'message' => 'Method not allowed']);
    exit;
}

$config = require __DIR__ . '/config.gpuq.php';

$raw = file_get_contents('php://input') ?: '';
$body = json_decode($raw, true);
if (!is_array($body)) {
    http_response_code(400);
    echo json_encode(['ok' => false, 'message' => 'Invalid JSON payload']);
    exit;
}

$secret = (string)($body['_gpuq_secret'] ?? '');
if ($secret === '' || !hash_equals((string)($config['self_exec_secret'] ?? ''), $secret)) {
    http_response_code(403);
    echo json_encode(['ok' => false, 'message' => 'Forbidden']);
    exit;
}

$audioPath = (string)($body['audio_path'] ?? '');
$language = strtolower(trim((string)($body['language'] ?? '')));

// Nur Dateien aus dem dafür vorgesehenen Cache-Verzeichnis zulassen.
$sttDir = realpath(__DIR__ . '/../admin/data/cache/stt');
$real = $audioPath !== '' ? realpath($audioPath) : false;
if ($sttDir === false || $real === false || strpos($real, $sttDir . '/') !== 0 || !is_file($real)) {
    http_response_code(400);
    echo json_encode(['ok' => false, 'message' => 'Invalid audio_path']);
    exit;
}

$sttUrl = rtrim((string)($config['stt_url'] ?? 'http://127.0.0.1:8032'), '/') . '/transcribe';

$post = ['file' => new CURLFile($real, null, basename($real))];
if (preg_match('/^[a-z]{2}$/', $language)) {
    $post['language'] = $language;
}

$ch = curl_init($sttUrl);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_POSTFIELDS => $post,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 90,
]);
$response = curl_exec($ch);
$error = curl_error($ch);
$httpCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);

if ($response === false || $httpCode !== 200) {
    http_response_code(502);
    echo json_encode(['ok' => false, 'message' => 'STT service error: ' . ($error ?: ('HTTP ' . $httpCode))]);
    exit;
}

$decoded = json_decode((string)$response, true);
if (!is_array($decoded) || empty($decoded['ok'])) {
    http_response_code(502);
    echo json_encode(['ok' => false, 'message' => 'STT service invalid response']);
    exit;
}

echo json_encode([
    'ok' => true,
    'text' => (string)($decoded['text'] ?? ''),
    'language' => (string)($decoded['language'] ?? ''),
    'duration' => $decoded['duration'] ?? null,
], JSON_UNESCAPED_UNICODE);