Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
80 changes: 40 additions & 40 deletions composer.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 2 additions & 0 deletions phpstan.neon
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
parameters:
scanDirectories:
- vendor/swoole/ide-helper
level: 5
paths:
- src
Expand Down
31 changes: 11 additions & 20 deletions src/Http/Adapter/Swoole/Server.php
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,10 @@

use Swoole\Coroutine;
use Utopia\Http\Adapter;
use Swoole\Http\Server as SwooleServer;
use Swoole\Coroutine\Http\Server as SwooleServer;
use Swoole\Http\Request as SwooleRequest;
use Swoole\Http\Response as SwooleResponse;
use Utopia\Http\Http;

class Server extends Adapter
{
Expand All @@ -30,34 +31,24 @@ public function setConfig(array $configs)

public function onRequest(callable $callback)
{
$this->server->on('request', function (SwooleRequest $request, SwooleResponse $response) use ($callback) {
call_user_func($callback, new Request($request), new Response($response), \strval(Coroutine::getCid()));
});
}
$this->server->handle('/', function (SwooleRequest $request, SwooleResponse $response) use ($callback) {
$context = \strval(Coroutine::getCid());

public function onWorkerStart(callable $callback)
{
$this->server->on('WorkerStart', $callback);
}
Http::setResource('swooleRequest', fn () => $request, [], $context);
Http::setResource('swooleResponse', fn () => $response, [], $context);

public function onBeforeReload(callable $callback)
{
$this->server->on('BeforeReload', $callback);
}

public function onAfterReload(callable $callback)
{
$this->server->on('AfterReload', $callback);
call_user_func($callback, new Request($request), new Response($response), $context);
});
}

public function onBeforeShutdown(callable $callback)
public function onWorkerStart(callable $callback)
{
$this->server->on('beforeShutdown', $callback);
return;
}

public function onStart(callable $callback)
{
$this->server->on('start', $callback);
call_user_func($callback, $this);
}

public function start()
Expand Down
Loading