<?php

namespace App\Jobs\VNet;

use App\Models\Node;
use App\Models\User;
use Arr;
use Exception;
use Http;
use Log;

class getUser
{
    public function existsinVNet(User $user): array
    {
        $nodeList = [];
        foreach ($user->nodes()->whereType(4)->get() as $node) {
            $list = $this->list($node);
            if ($list && in_array($user->id, $list, true)) {
                $nodeList[] = $node->id;
            }
        }

        return $nodeList;
    }

    public function list(Node $node, string $mode = 'uid'): false|array
    {
        $list = $this->send(($node->server ?: $node->ips()[0]).':'.$node->push_port, $node->auth->secret);

        if (is_array($list)) {
            if ($mode === 'uid') {
                return Arr::pluck($list, 'uid');
            }

            if ($mode === 'port') {
                return Arr::pluck($list, 'port');
            }

            return $list;
        }

        return false;
    }

    private function send(string $host, string $secret): false|array
    {
        try {
            $response = Http::baseUrl($host)->timeout(20)->withHeaders(['secret' => $secret])->get('api/user/list');
            $message = $response->json();
            if ($message && $response->ok()) {
                return $message;
            }

            Log::warning('【用户列表】获取失败（推送地址：'.$host.'）');
        } catch (Exception $exception) {
            Log::alert('【用户列表】获取异常：'.$exception->getMessage());
        }

        return false;
    }
}