sfp_api_laravel_ginastica_cerebro/app/Services/UnitPaymentAccountService.php

<?php

namespace App\Services;

use App\Exceptions\AsaasException;
use App\Models\UnitPaymentAccount;
use App\Services\Integrations\Asaas\AsaasWebhookService;
use Illuminate\Support\Facades\Log;
use Illuminate\Validation\ValidationException;

class UnitPaymentAccountService
{
    public function __construct(
        protected AsaasWebhookService $webhookService,
    ) {}

    public function getByUnitId(int $unitId): ?UnitPaymentAccount
    {
        return UnitPaymentAccount::where('unit_id', $unitId)->first();
    }

    /**
     * Cria/atualiza a conta de pagamento da unidade.
     *
     * Ao informar uma chave: valida na Asaas e registra o webhook (síncrono e
     * estrito — chave inválida bloqueia). Ao limpar: remove o webhook (best-effort).
     */
    public function upsertAsaasApiKey(int $unitId, ?string $apiKey): UnitPaymentAccount
    {
        $apiKey = $apiKey !== null ? trim($apiKey) : null;
        $hasKey = $apiKey !== null && $apiKey !== '';

        $model = UnitPaymentAccount::firstOrNew(['unit_id' => $unitId]);

        if (!$hasKey) {
            $this->removeWebhook($model);

            $model->asaas_api_key    = null;
            $model->asaas_webhook_id = null;
            $model->status           = UnitPaymentAccount::STATUS_PENDING;
            $model->onboarded_at     = null;
            $model->save();

            return $model->fresh();
        }

        // Reenvio da mesma chave já configurada: mantém como está.
        if ($model->exists && $model->asaas_api_key === $apiKey && $model->asaas_webhook_id) {
            return $model->fresh();
        }

        try {
            $this->webhookService->validateKey($apiKey);
        } catch (AsaasException $e) {
            throw ValidationException::withMessages([
                'asaas_api_key' => 'Chave Asaas inválida ou sem permissão. Verifique e tente novamente.',
            ]);
        }

        // Troca de chave: remove o webhook antigo antes de registrar o novo.
        $this->removeWebhook($model);

        try {
            $webhookId = $this->webhookService->register($apiKey);
        } catch (AsaasException $e) {
            Log::error("Falha ao registrar webhook Asaas da unidade {$unitId}: " . $e->getMessage());
            throw ValidationException::withMessages([
                'asaas_api_key' => 'Não foi possível registrar o webhook na Asaas. Tente novamente.',
            ]);
        }

        $model->asaas_api_key    = $apiKey;
        $model->asaas_webhook_id = $webhookId;
        $model->status           = UnitPaymentAccount::STATUS_ACTIVE;
        $model->onboarded_at     = $model->onboarded_at ?? now();
        $model->save();

        return $model->fresh();
    }

    /**
     * Remove o webhook atual da conta (ignora erros — best-effort).
     */
    private function removeWebhook(UnitPaymentAccount $model): void
    {
        if (!$model->asaas_api_key || !$model->asaas_webhook_id) {
            return;
        }

        try {
            $this->webhookService->delete($model->asaas_api_key, $model->asaas_webhook_id);
        } catch (\Throwable $e) {
            Log::warning("Não foi possível remover webhook Asaas da unidade {$model->unit_id}: " . $e->getMessage());
        }
    }
}