<?php

namespace App\Http\Controllers\Api\Admin\DnsManager;

use App\Http\Controllers\Controller;
use App\Repositories\DnsManager\Server\DnsServerRepositoryInterface;
use App\Services\ServerService;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Crypt;
use Illuminate\Support\Facades\DB;

class ServerController extends Controller
{
    private const DOMAIN_PATTERN = '/^(?=.{1,253}$)([a-z0-9]([a-z0-9-]{0,61}[a-z0-9])?\.)+[a-z]{2,63}$/i';

    public function __construct(
        private readonly DnsServerRepositoryInterface $serverRepository,
        private readonly ServerService $serverService,
    ) {}

    public function index(Request $request): JsonResponse
    {
        $perPage = min((int) $request->get('per_page', 15), 500);
        $filter = $request->get('filter');
        $status = $request->get('status');
        $type = $request->get('type');

        $query = $this->serverRepository->model->newQuery();

        if ($filter) {
            $query->where(function ($subQuery) use ($filter) {
                $subQuery->where('name', 'like', "%{$filter}%")
                    ->orWhere('ip_address', 'like', "%{$filter}%")
                    ->orWhere('domain', 'like', "%{$filter}%")
                    ->orWhere('username', 'like', "%{$filter}%");
            });
        }

        if ($status !== null && $status !== '') {
            $query->where('status', $status);
        }

        if ($type === 'hosting') {
            $query->whereIn('type', ['hosting', 'both']);
        } elseif ($type === 'domain') {
            $query->whereIn('type', ['domain', 'both']);
        } elseif ($type !== null && $type !== '') {
            $query->where('type', $type);
        }

        $paginator = $query->orderByDesc('id')->paginate($perPage);

        return response()->json([
            'error' => false,
            'data' => [
                'items' => $paginator->getCollection()->map(fn($server) => $this->formatServer($server)),
                'total' => $paginator->total(),
                'per_page' => $paginator->perPage(),
                'current_page' => $paginator->currentPage(),
                'last_page' => $paginator->lastPage(),
            ],
        ]);
    }

    public function show(int $id): JsonResponse
    {
        $server = $this->serverRepository->find($id);

        if (!$server) {
            return response()->json(['error' => true, 'message' => "Không tìm thấy server #$id"], 404);
        }

        return response()->json([
            'error' => false,
            'data' => $this->formatServer($server),
        ]);
    }

    public function store(Request $request): JsonResponse
    {
        $validated = $request->validate([
            'name' => 'required|string|max:255',
            'ip_address' => 'required|string|max:255',
            'domain' => ['nullable', 'string', 'max:255', 'regex:' . self::DOMAIN_PATTERN],
            'panel_port' => 'nullable|integer|min:1|max:65535',
            'username' => 'required|string|max:255',
            'password' => 'required|string|max:255',
            'api_key' => 'nullable|string',
            'status' => 'nullable|string|in:activated,Stopped',
            'type' => 'nullable|string|in:domain,hosting,both',
        ]);

        DB::beginTransaction();

        try {
            $server = $this->serverRepository->create([
                'name' => $validated['name'],
                'ip_address' => $validated['ip_address'],
                'domain' => $validated['domain'] ?? null,
                'panel_port' => $validated['panel_port'] ?? 8880,
                'username' => $validated['username'],
                'password' => Crypt::encryptString($validated['password']),
                'api_key' => $validated['api_key'] ?? null,
                'status' => $validated['status'] ?? 'activated',
                'type' => $validated['type'] ?? 'domain',
            ]);

            DB::commit();

            return response()->json([
                'error' => false,
                'data' => $this->formatServer($server),
            ], 201);
        } catch (\Exception $e) {
            DB::rollBack();

            return response()->json(['error' => true, 'message' => $e->getMessage()], 500);
        }
    }

    public function update(int $id, Request $request): JsonResponse
    {
        $server = $this->serverRepository->find($id);

        if (!$server) {
            return response()->json(['error' => true, 'message' => "Không tìm thấy server #$id"], 404);
        }

        $validated = $request->validate([
            'name' => 'sometimes|required|string|max:255',
            'ip_address' => 'sometimes|required|string|max:255',
            'domain' => ['nullable', 'string', 'max:255', 'regex:' . self::DOMAIN_PATTERN],
            'panel_port' => 'nullable|integer|min:1|max:65535',
            'username' => 'sometimes|required|string|max:255',
            'password' => 'nullable|string|max:255',
            'api_key' => 'nullable|string',
            'status' => 'nullable|string|in:activated,Stopped',
            'type' => 'nullable|string|in:domain,hosting,both',
        ]);

        DB::beginTransaction();

        try {
            $payload = collect($validated)
                ->except('password')
                ->toArray();

            if ($request->filled('password')) {
                $payload['password'] = Crypt::encryptString((string) $request->password);
            }

            $this->serverRepository->update($id, $payload);

            DB::commit();

            return $this->show($id);
        } catch (\Exception $e) {
            DB::rollBack();

            return response()->json(['error' => true, 'message' => $e->getMessage()], 500);
        }
    }

    public function destroy(int $id): JsonResponse
    {
        $server = $this->serverRepository->find($id);

        if (!$server) {
            return response()->json(['error' => true, 'message' => "Không tìm thấy server #$id"], 404);
        }

        $this->serverRepository->delete($id);

        return response()->json(['error' => false, 'message' => 'Đã xoá server thành công']);
    }

    public function checkConnection(int $id): JsonResponse
    {
        $server = $this->serverRepository->find($id);

        if (!$server) {
            return response()->json(['error' => true, 'message' => "Không tìm thấy server #$id"], 404);
        }

        $meta = $this->serverService->checkConnectionByServer($server);

        return response()->json([
            'error' => $meta === false,
            'data' => ['connected' => $meta !== false, 'server' => $meta ?: null],
            'message' => $meta !== false
                ? 'Kết nối server thành công.'
                : 'Không thể kết nối tới server. Vui lòng kiểm tra lại IP hoặc tài khoản.',
        ]);
    }

    private function formatServer($server): array
    {
        return [
            'id' => $server->id,
            'name' => $server->name,
            'ip_address' => $server->ip_address,
            'domain' => $server->domain,
            'panel_port' => $server->panel_port,
            'username' => $server->username,
            'api_key' => $server->api_key,
            'status' => $server->status,
            'type' => $server->type,
            'created_at' => $server->created_at,
            'updated_at' => $server->updated_at,
        ];
    }
}