#!/usr/bin/env php
<?php

require __DIR__ . '/vendor/autoload.php';
require __DIR__ . '/vendor/yiisoft/yii2/Yii.php';
require __DIR__ . '/common/config/bootstrap.php';

use common\helpers\FileHelper;
use common\helpers\StringHelper;
use common\rpc\AddonsRpcService;
use common\rpc\pdo\PdoPoolContainer;
use common\rpc\redis\RedisPoolContainer;
use common\rpc\userCenter\UserModule;
use common\rpc\userCenter\UserRpcService;
use common\rpc\utility\DebugHelper;
use EasySwoole\Rpc\Config;
use EasySwoole\Rpc\Protocol\Response;
use EasySwoole\Rpc\Rpc;
use Swoole\Database\PDOConfig;
use Swoole\Database\PDOPool;
use Swoole\Database\RedisConfig;
use Swoole\Database\RedisPool;
use Swoole\Http\Server;

$isWin = StringHelper::isWindowsOS();
if ($isWin){
    DebugHelper::consoleWrite('暂时不支持windows环境');
    die;
}

// 使用环境变量或配置文件获取配置
$serverIp = env('RPC_SERVER_IP') ?: '127.0.0.1';
$serverPort = env('RPC_SERVER_PORT') ?: 9508;

$config = new Config();
$serverConfig =$config->getServer();
$serverConfig->setServerIp($serverIp);
// 设置服务端最大接受包大小
$serverConfig->setMaxPackageSize(1024 * 1024 * 2);
// 设置接收客户端数据时间
$serverConfig->setNetworkReadTimeout(3);

$rpc = new Rpc($config);

$service = new AddonsRpcService();
$RpcMpdules = FileHelper::file_tree(__DIR__ .'/addons',['*/config/rpc.php']);

foreach ($RpcMpdules as $rpcMpdule) {
    $config = require_once $rpcMpdule;
    foreach ($config as $moduleName => $item) {
        $service->addModule(new $item);
    }
}

$rpc->serviceManager()->addService($service);
/**
 * 用户中心
 */
$UserService = new UserRpcService();
$UserService->addModule(new UserModule());
$rpc->serviceManager()->addService($UserService);



echo "RPC server started at {$serverIp}:{$serverPort}\n";
$http = new Server($serverIp, $serverPort);
$pdoPool = new PDOPool((new PDOConfig())
    ->withHost(env('DB_HOST','127.0.0.1'))
    ->withPort(env('DB_PORT','3306'))
    ->withUnixSocket('/tmp/mysql.sock')
    ->withDbName(env('DB_NAME','test'))
    ->withCharset('utf8mb4')
    ->withUsername(env('DB_USER','root'))
    ->withPassword(env('DB_PASS','root'))
//    ->withOptions()
);
echo "RPC server started\n";
PdoPoolContainer::getInstance()->set('pdoPool',$pdoPool);

$redisPool = new RedisPool((new RedisConfig())
    ->withHost(env('REDIS_HOST','127.0.0.1'))
    ->withPort(env('REDIS_PORT',6379))
    ->withAuth('')
    ->withDbIndex(env('REDIS_DB',0))
    ->withTimeout(1)
);
RedisPoolContainer::getInstance()->set('redisPool',$redisPool);
echo '容器中获取内容';
$http->on('workerStart', function ($server) use($rpc,$pdoPool){

});

try {
    $rpc->attachServer($http);
} catch (\EasySwoole\Rpc\Exception\Exception $e) {
    echo $e->getMessage();
}

$http->on('request', function ($request, $response) use($rpc){
    try {
        if ($request->server['path_info'] == '/favicon.ico' || $request->server['request_uri'] == '/favicon.ico' || $request->server['request_uri'] === '/') {
            $response->end();
            return;
        }
        $response->header('Content-Type', 'application/json');
        echo "RPC client started\n";
        echo "RPC client request: {$request->server['request_uri']}\n";

        list($service,$module, $action) = explode('/', trim($request->server['request_uri'], '/'));
        $route = [ucwords($service),ucwords($module),$action];
        $routePath = implode('.',$route);
        $client = $rpc->client();
        echo "RPC client request: $routePath\n";
        $ctx = $client->addRequest($routePath);
        $Arg = array_merge((array)($request->get),(array)($request->post));
        $Header = $request->header;
        $ctx->setArg($Arg);
        $ctx->setHeader($Header);
        // 使用匿名函数处理成功响应
        $onSuccess = function (Response $Response) use ($response) {
            // 使用日志记录而不是直接输出
            $data = $Response->getResult();
            $code = $Response->getCode();
            $response->end(json_encode(['data'=>$data,'message'=>$Response->getMsg(),'code'=>$code]));
        };
        $ctx->setOnSuccess($onSuccess);

        $onFail = function (Response $Response) use ($response) {
            // 使用日志记录而不是直接输出
            DebugHelper::consoleWrite('onFail',[
                    'msg'=>$Response->getMsg()
            ]);
            $data = $Response->getResult();
            $code = $Response->getCode();
            $response->end(json_encode(['data'=>$data,'message'=>$Response->getMsg(),'code'=>$code]));
        };

        $ctx->setOnFail($onFail);
        $client->exec();
    } catch (\Exception $e) {
        // 异常处理，记录日志或返回错误响应
        $err = \common\helpers\ErrorsHelper::throwMsg($e);
        var_dump($err);
        var_dump("RPC call failed: " . $e->getMessage());
    } catch (\Throwable $e) {
        // 异常处理，记录日志或返回错误响应
        $err = \common\helpers\ErrorsHelper::throwMsg($e);
        var_dump($err);
        var_dump("RPC call failed: " . $e->getMessage());
    }
});

// 启动服务器前进行一些必要的日志记录或配置检查
// ...
$http->start();