<?php
namespace DoraRPC;

class Monitor
{
    protected $_server = null;

    protected $_ip = "0.0.0.0";
    protected $_port = 9569;

    protected $_config;

    //server report
    final public function discovery(array $config)
    {
        $self = $this;

        $this->_server->addProcess(new \swoole_process(function () use ($config, $self) {

            swoole_set_process_name("dora: monitor service");

            static $_redisObj = array();

            while (true) {
                //for result list
                $serverListResult = array();

                //get redis config
                $redisConfig = $self->_config["redis"];

                //connect all redis
                foreach ($redisConfig as $redisItem) {
                    //validate redis ip and port
                    if (trim($redisItem["ip"]) && $redisItem["port"] > 0) {
                        $key = $redisItem["ip"] . "_" . $redisItem["port"];
                        try {
                            //connecte redis
                            if (!isset($_redisObj[$key])) {
                                //if not connect
                                $_redisObj[$key] = new \Redis();
                                $_redisObj[$key]->connect($redisItem["ip"], $redisItem["port"]);
                            }

                            //get register node server
                            $serverList = $_redisObj[$key]->smembers("dora.serverlist");
                            if ($serverList) {
                                foreach ($serverList as $sitem) {
                                    $info = json_decode($sitem, true);
                                    //decode success
                                    if ($info) {
                                        //get last report time
                                        $lastTimeKey = "dora.servertime." . $info["node"]["ip"] . "." . $info["node"]["port"] . ".time";
                                        $lastUpdatTime = $_redisObj[$key]->get($lastTimeKey);

                                        //timeout ignore
                                        if (time() - $lastUpdatTime > 20) {
                                            continue;
                                        }

                                        if (is_array($info["group"])) {
                                            foreach ($info["group"] as $groupname) {
                                                $clientkey = $info["node"]["ip"] . "_" . $info["node"]["port"];
                                                $serverListResult[$groupname][$clientkey] = array("ip" => $info["node"]["ip"], "port" => $info["node"]["port"]);
                                                $serverListResult[$groupname][$clientkey]["updatetime"] = $lastUpdatTime;
                                            }
                                        }
                                        //foreach group and record this info
                                    }//decode info if
                                }// foreach
                            }//if got server list from redis

                        } catch (\Exception $ex) {
                            //var_dump($ex);
                            $_redisObj[$key] = null;
                            echo "get redis server error" . PHP_EOL;
                        }
                    }
                }

                if (count($serverListResult) > 0) {

                    $configString = var_export($serverListResult, true);
                    $ret = file_put_contents($this->_config["export_path"], "<?php" . PHP_EOL . "//This is generaled by client monitor" . PHP_EOL . "return " . $configString . ";");
                    if (!$ret) {
                        echo "Error save the config to file..." . PHP_EOL;
                    } else {
                        echo "General config file to:" . $this->_config["export_path"] . PHP_EOL;
                    }
                } else {
                    echo "Error there is no Config get..." . PHP_EOL;
                }

                //sleep 10 sec
                sleep(10);
            }
        }));
    }

    public function __construct($ip = "0.0.0.0", $port = 9569, $config = array())
    {
        //record ip:port
        $this->_ip = $ip;
        $this->_port = $port;

        //create server object
        $this->_server = new \swoole_server($ip, $port, \SWOOLE_PROCESS, \SWOOLE_SOCK_UDP);
        //set config
        $this->_server->set(array(
            'open_length_check' => 1,
            'dispatch_mode' => 3,
            'package_length_type' => 'N',
            'package_length_offset' => 0,
            'package_body_offset' => 4,
            'package_max_length' => 1024 * 1024 * 2,
            'buffer_output_size' => 1024 * 1024 * 3,
            'pipe_buffer_size' => 1024 * 1024 * 32,
            'open_tcp_nodelay' => 1,
            'heartbeat_check_interval' => 5,
            'heartbeat_idle_time' => 10,

            'reactor_num' => 1,
            'worker_num' => 2,
            'task_worker_num' => 0,

            'max_request' => 0, //必须设置为0否则并发任务容易丢,don't change this number
            'task_max_request' => 4000,

            'backlog' => 2000,
            'log_file' => '/tmp/sw_monitor.log',
            'task_tmpdir' => '/tmp/swmonitor/',
            'daemonize' => 0,//product env is 1
        ));

        //register the event
        $this->_server->on('Packet', array($this, 'onPacket'));

        echo "Start Init Server udp://" . $ip . ":" . $port . PHP_EOL;

        //store the list of redis
        $this->_config["redis"] = $config["discovery"];

        //store the avaliable node list to this config file
        $this->_config["export_path"] = $config["config"];

        //log monitor path
        $this->_config["log_path"] = $config["log"];

        $this->discovery($this->_config["redis"]);
    }

    public function start()
    {
        $this->_server->start();
    }

    public function onPacket(\swoole_server $server, $data, $client_info)
    {
        //$data = \DoraDRPC\Base\Packet::packDecode($data);
        //$server->sendto($client_info['address'], $client_info['port'], \DoraDRPC\Base\Packet::packEncode(array()));

        //var_dump($server, $data);
    }

}