<?php
error_reporting(E_ALL);
ini_set('display_errors', 1);

echo "Listener start with SSL verification...\n";

// === Konfigurasi Server Laravel (SSL/CA) ===
$apiUrl  = 'https://pos.arkanatech.id/api/print/pending';
$markUrl = 'https://pos.arkanatech.id/api/print/mark-printed';
$cacertPath = __DIR__ . '/ssl-cert/ssl-cert.pem'; // Path absolut SSL

// === Konfigurasi Printer Windows ===
$printerShare = 'POS-58'; // harus sama persis dengan share name di Windows
$pcIP         = '192.168.200.17';
$username     = 'desktop-p6qe5bq\\\\terasys virtual'; // 2x backslash supaya lolos ke shell_exec dan command
$password     = '@bcd!234';

$lastPrintedId = null;

while (true) {
    echo "Polling antrean...\n";

    // Ambil antrean dari server (pending)
    $ch = curl_init($apiUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_TIMEOUT, 10);
    curl_setopt($ch, CURLOPT_CAINFO, $cacertPath);
    $response = curl_exec($ch);

    if (curl_errno($ch)) {
        echo "❌ CURL Error: " . curl_error($ch) . "\n";
        curl_close($ch);
        sleep(3);
        continue;
    }

    $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($http_code !== 200) {
        echo "❌ HTTP Error $http_code saat ambil antrean\n";
        sleep(3);
        continue;
    }

    $data = json_decode($response, true);

    // Hanya proses jika status == "pending"
    if (!isset($data['status']) || $data['status'] !== 'pending') {
        echo "Tidak ada antrean.\n";
        sleep(3);
        continue;
    }

    if (!isset($data['id']) || !isset($data['content'])) {
        echo "❌ Data dari API tidak lengkap.\n";
        sleep(3);
        continue;
    }

    $id = $data['id'];
    $content = $data['content'];

    // Cegah cetak berulang
    if ($id == $lastPrintedId) {
        echo "⚠️ ID $id sudah dicetak sebelumnya, skip.\n";
        sleep(3);
        continue;
    }
    $lastPrintedId = $id;

    echo "Dapat struk ID: $id\n";

    // Simpan file sementara
    $filename = "struk_$id.txt";
    file_put_contents($filename, $content);
    echo "File disiapkan: $filename\n";

    // Jalankan perintah print ke SMB Windows
    // Username perlu escape backslash
    // smbclient '//192.168.18.11/POS-58' -U desktop-cb3glp7\\dell\ e7450t%Class5erver@ -c 'print struk_1.txt'
    $cmd = "smbclient '//{$pcIP}/{$printerShare}' -U \"{$username}%{$password}\" -c 'print {$filename}'";
    echo "Menjalankan: $cmd\n";
    $output = shell_exec($cmd);
    echo "📄 Output smbclient:\n$output\n";

    // Validasi: hanya gagal jika output mengandung error keywords
    if (
        stripos($output, 'NT_STATUS') !== false ||
        stripos($output, 'error') !== false ||
        stripos($output, 'failed') !== false
    ) {
        echo "❌ Print gagal atau error terdeteksi dalam output! Tidak akan di-mark printed.\n";
        file_put_contents('thermal_printer_error.log', date('c') . " | Print GAGAL ID $id: $output\n", FILE_APPEND);
        sleep(3);
        continue;
    }

    // Tandai sebagai sudah dicetak
    $postdata = http_build_query(['id' => $id]);
    $ch2 = curl_init($markUrl);
    curl_setopt($ch2, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch2, CURLOPT_POST, true);
    curl_setopt($ch2, CURLOPT_POSTFIELDS, $postdata);
    curl_setopt($ch2, CURLOPT_CAINFO, $cacertPath);
    curl_setopt($ch2, CURLOPT_TIMEOUT, 10);
    $markResponse = curl_exec($ch2);

    if (curl_errno($ch2)) {
        echo "❌ Gagal tandai printed: " . curl_error($ch2) . "\n";
        curl_close($ch2);
        sleep(3);
        continue;
    }

    $markHttpCode = curl_getinfo($ch2, CURLINFO_HTTP_CODE);
    curl_close($ch2);

    echo "📨 Response mark: $markResponse (HTTP $markHttpCode)\n";

    if ($markHttpCode === 200 && strpos($markResponse, 'updated') !== false) {
        echo "✅ Struk ID $id ditandai sebagai printed.\n";
        unlink($filename);
    } else {
        echo "❌ Gagal tandai printed, response: $markResponse (HTTP $markHttpCode)\n";
    }

    sleep(3);
}