{

protected array $metadata = [];

protected array $config = [

'enable' => false,

'port' => 9500,

'json_dir' => BASE_PATH . '/storage/swagger',

'html' => null,

'url' => '/swagger',

'auto_generate' => false,

'scan' => [

'paths' => null,

],

];

public function __construct(protected ContainerInterface $container, protected ResponseEmitter $emitter)

{

$this->config = array_merge($this->config, $this->container->get(ConfigInterface::class)->get('swagger', []));

}

public function onRequest($request, $response): void

{

try {

if ($request instanceof ServerRequestInterface) {

$psr7Request = $request;

} else {

$psr7Request = Psr7Request::loadFromSwooleRequest($request);

}

$path = $psr7Request->getUri()->getPath();

if ($path === $this->config['url']) {

$stream = new Stream($this->getHtml());

$contentType = 'text/html;charset=utf-8';

} else {

$stream = new Stream($this->getMetadata($path));

$contentType = 'application/json;charset=utf-8';

}

$psrResponse = (new Response())->setBody($stream)->setHeader('content-type', $contentType);

$this->emitter->emit($psrResponse, $response);

} catch (Throwable) {

$this->emitter->emit(

(new Response())

->setBody(new Stream('Server Error'))

->setHeader('content-type', 'text/html;charset=utf-8'),

$response

);

}

}

protected function getMetadata(string $path): string

{

$path = rtrim($this->config['json_dir'], '/') . $path;

$id = md5($path);

if (isset($this->metadata[$id])) {

return $this->metadata[$id];

}

if (is_file($path) && file_exists($path)) {

$metadata = file_get_contents($path);

} else {

$metadata = Json::encode([

'openapi' => '3.0.0',

]);

}

return $this->metadata[$id] = $metadata;

}

protected function getHtml(): string

{

if (! empty($this->config['html'])) {

return $this->config['html'];

}

return <<<'HTML'

HTML;

}