<?php

namespace jytools;

require_once __DIR__ . '/func.php';

use Swoole\Http\Request;
use Swoole\Http\Response;
use Swoole\Coroutine\Http\Server;
use function jytools\output;

class SimpleServerCoroutine
{
    private Server $httpServer;
    public function __construct($host, $port, $ssl = false)
    {
        $this->httpServer = new Server($host, $port, $ssl);
    }
    public function router(array $method, $path, $callback)
    {
        $this->httpServer->handle($path, function (Request $request, Response $response) use ($method, $callback) {
            $m = $request->getMethod();
            foreach ($method as $k => $v) {
                $method[$k] = strtolower($v);
            }
            $m = strtolower($m);
            if (!in_array($m, $method)) {
                $response->status(405);
                $data = [
                    'code' => 405,
                    'msg' => 'Method Not Allowed',
                    'currentMethod' => $m,
                    'allowMethod' => $method,
                ];
                $response->end(json_encode($data));
                return;
            }
            $requestInfo = [
                'method' => $request->getMethod(),
                'path' => $request->server['path_info'],
                'uri' => $request->server['request_uri'],
                'get' => $request->get ?: [],
                'post' => $request->post ?: [],
                'header' => $request->header ?: [],
                'cookie' => $request->cookie ?: [],
                'rawContent' => $request->rawContent() ?: ''
            ];
            output($requestInfo['method'], $requestInfo['path'], "GET:" . json_encode($requestInfo['get']), "POST:" . json_encode($requestInfo['post']), "rawContent:" . $requestInfo['rawContent']);
            $simpleRequest = new SimpleRequest($requestInfo);
            $res = call_user_func($callback, $simpleRequest);
            if (empty($res)) {
                $response->end(json_encode(['code' => -1, 'msg' => 'nothing return']));
            } else {
                $response->end($res);
            }
        });
    }

    public function start()
    {
        $this->httpServer->start();
    }
    public function stop()
    {
        $this->httpServer->shutdown();
    }
}