update to PHP-8.1

[m6w6/seekat] / examples / amploop.php

diff --git a/examples/amploop.php b/examples/amploop.php
index 1abbaa11e42d264dacaf4478607f1f6d49ea2bb2..9afda4c29b20a495fbb8564c5628247275563013 100755 (executable)
--- a/examples/amploop.php
+++ b/examples/amploop.php
@@ -6,107 +6,113 @@ require_once __DIR__."/../vendor/autoload.php";
 use seekat\API;
 use Amp\Loop as AmpLoop;
 
-$log = new Monolog\Logger("seekat");
-$log->pushHandler((new Monolog\Handler\StreamHandler(STDERR))->setLevel(Monolog\Logger::INFO));
+$client = new http\Client("curl", "seekat");
+$client->configure([
+       "use_eventloop" => new class($client, AmpLoop::get()) implements http\Client\Curl\User {
 
-$cli = new http\Client("curl", "seekat");
-$cli->configure([
-       "use_eventloop" => new class($cli, AmpLoop::get()) implements http\Client\Curl\User {
+               /**
+                * Timeout ID
+                */
+               private ?string $timeout = null;
+               private \Closure $runcb;
 
-       private $driver;
-       private $timeout;
-       private $client;
-       private $runcb;
+               function __construct(private http\Client $client, private AmpLoop\Driver $driver) {
+               }
 
-       function __construct(http\Client $client, AmpLoop\Driver $driver) {
-               $this->client = $client;
-               $this->driver = $driver;
-       }
-       function init($run) {
-               $this->runcb = $run;
-       }
-       function run($socket = null, int $action = null) {
-               if ($socket) {
-                       $remaining = ($this->runcb)($this->client, $socket, $action);
-               } else {
-                       $remaining = ($this->runcb)($this->client);
+               function init($run) : void {
+                       $this->runcb = $run(...);
                }
 
-               if (!$remaining) {
-                       $this->done();
+               /**
+                * @param resource $socket
+                */
+               function run($socket = null, int $action = null) : void {
+                       if ($socket) {
+                               $remaining = ($this->runcb)($this->client, $socket, $action);
+                       } else {
+                               $remaining = ($this->runcb)($this->client);
+                       }
+
+                       if (!$remaining) {
+                               $this->done();
+                       }
                }
-       }
-       function once() {
-               if (!$this->driver->getInfo()["running"]) {
-                       $this->driver->run();
+               function once() : void {
+                       if (!$this->driver->getInfo()["running"]) {
+                               $this->driver->run();
+                       }
                }
-       }
-       function send() {
-               # unused
-               throw new BadMethodCallException(__FUNCTION__);
-       }
-       function wait(int $timeout_ms = null) {
-               # unused
-               throw new BadMethodCallException(__FUNCTION__);
-       }
-       function timer(int $timeout_ms = null) {
-               if ($this->timeout) {
-                       $this->driver->cancel($this->timeout);
+               function send() : never {
+                       # unused
+                       throw new BadMethodCallException(__FUNCTION__);
+               }
+               function wait(int $timeout_ms = null) : never {
+                       # unused
+                       throw new BadMethodCallException(__FUNCTION__);
                }
+               function timer(int $timeout_ms = null) : void {
+                       if ($this->timeout) {
+                               $this->driver->cancel($this->timeout);
+                       }
 
-               $this->timeout = $this->driver->delay($timeout_ms, function() {
-                       $this->run();
-               });
-       }
-       function done() {
-               if ($this->timeout) {
-                       $this->driver->cancel($this->timeout);
-                       $this->timeout = null;
+                       $this->timeout = $this->driver->delay($timeout_ms, function() {
+                               $this->run();
+                       });
                }
-       }
-       function socket($socket, int $poll) {
-               foreach ((array) $this->driver->getState((string) $socket) as $id) {
-                       $this->driver->disable($id);
+               function done() : void {
+                       if ($this->timeout) {
+                               $this->driver->cancel($this->timeout);
+                               $this->timeout = null;
+                       }
                }
-               switch ($poll) {
-               case self::POLL_NONE:
-                       break;
-               case self::POLL_IN:
-                       $id = $this->driver->onReadable($socket, function($id, $socket) {
-                               $this->run($socket, self::POLL_IN);
-                       });
-                       $this->driver->setState((string) $socket, $id);
-                       break;
-               case self::POLL_OUT:
-                       $id = $this->driver->onWritable($socket, function($id, $socket) {
-                               $this->run($socket, self::POLL_OUT);
-                       });
-                       $this->driver->setState((string) $socket, $id);
-                       break;
-               case self::POLL_INOUT:
-                       $id = [
-                               $this->driver->onReadable($socket, function($id, $socket) {
+
+               /**
+                * @param resource $socket
+                */
+               function socket($socket, int $poll) : void {
+                       foreach ((array) $this->driver->getState((string) $socket) as $id) {
+                               $this->driver->disable($id);
+                       }
+                       switch ($poll) {
+                       case self::POLL_NONE:
+                               break;
+                       case self::POLL_IN:
+                               $id = $this->driver->onReadable($socket, function($id, $socket) {
                                        $this->run($socket, self::POLL_IN);
-                               }),
-                               $this->driver->onWritable($socket, function($id, $socket) {
+                               });
+                               $this->driver->setState((string) $socket, $id);
+                               break;
+                       case self::POLL_OUT:
+                               $id = $this->driver->onWritable($socket, function($id, $socket) {
                                        $this->run($socket, self::POLL_OUT);
-                               })
-                       ];
-                       $this->driver->setState((string) $socket, $id);
-                       break;
-               case self::POLL_REMOVE:
-                       foreach ((array) $this->driver->getState((string) $socket) as $id) {
-                               $this->driver->cancel($id);
+                               });
+                               $this->driver->setState((string) $socket, $id);
+                               break;
+                       case self::POLL_INOUT:
+                               $id = [
+                                       $this->driver->onReadable($socket, function($id, $socket) {
+                                               $this->run($socket, self::POLL_IN);
+                                       }),
+                                       $this->driver->onWritable($socket, function($id, $socket) {
+                                               $this->run($socket, self::POLL_OUT);
+                                       })
+                               ];
+                               $this->driver->setState((string) $socket, $id);
+                               break;
+                       case self::POLL_REMOVE:
+                               foreach ((array) $this->driver->getState((string) $socket) as $id) {
+                                       $this->driver->cancel($id);
+                               }
+                               $this->driver->setState((string) $socket, null);
+                               break;
                        }
-                       $this->driver->setState((string) $socket, null);
-                       break;
                }
        }
-}]);
+]);
+
+$future = API\Future\amp();
 
-$api = new API(API\Future\amp(), [
-       "Authorization" => "token ".getenv("GITHUB_TOKEN")
-], null, $cli, $log);
+$api = include "examples.inc";
 
 AmpLoop::run(function() use($api) {
        list($m6w6, $seekat) = yield [$api->users->m6w6(), $api->repos->m6w6->seekat()];