<?php

namespace Src\Controllers;

use Src\Services\PjeWebhookService;

require_once __DIR__ . '/../Config/config.php';

class WebhookController
{
    public function monitorar(): void
    {
        header('Content-Type: application/json');

        try {

            $input = json_decode(file_get_contents("php://input"), true) ?? [];

            $numeroOab = $input['numeroOab'] ?? null;
            $ufOab     = $input['ufOab'] ?? null;

            if (!$numeroOab || !$ufOab) {
                http_response_code(400);
                echo json_encode([
                    "status" => "error",
                    "message" => "numeroOab e ufOab são obrigatórios"
                ]);
                return;
            }

            $service = new PjeWebhookService();

            $resultado = $service->buscarComunicacoesDoDia(
                $numeroOab,
                $ufOab
            );

            if (!$resultado['sucesso']) {

                http_response_code(500);

                echo json_encode([
                    "status" => "error",
                    "message" => $resultado['erro']
                ]);

                return;
            }

            // ==================================================
            // DISPARAR WEBHOOK (ENVIAR PARA OUTRO SISTEMA)
            // ==================================================

            $webhookUrl = WEBHOOK_DESTINO;

            $payload = json_encode([
                "event" => "pje_novas_comunicacoes",
                "total" => $resultado['total'],
                "items" => $resultado['processos']
            ]);

            $ch = curl_init();

            curl_setopt_array($ch, [
                CURLOPT_URL => $webhookUrl,
                CURLOPT_POST => true,
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_HTTPHEADER => [
                    'Content-Type: application/json'
                ],
                CURLOPT_POSTFIELDS => $payload
            ]);

            curl_exec($ch);
            curl_close($ch);

            // ==================================================
            // RETORNO DO WEBHOOK
            // ==================================================

            echo json_encode([
                "status" => "success",
                "message" => "Webhook executado",
                "count" => $resultado['total'],
                "items" => $resultado['processos']
            ]);
        } catch (\Throwable $e) {

            http_response_code(500);

            echo json_encode([
                "status" => "error",
                "message" => $e->getMessage()
            ]);
        }
    }
}