#$@%#$%!

Ngiler SH3LL 360
: / opt / alt / tests / alt-php81-pecl-http_4.2.4-1.el8 / tests /

Information Server
MySQL : OFF Perl : OFF CURL : ON WGET : OFF PKEXEC : OFF

Directive	Local Value
IP Address	162.0.209.101
System	Linux premium169.web-hosting.com 4.18.0-553.50.1.lve.el8.x86_64 #1 SMP Thu Apr 17 19:10:24 UTC 2025 x86_64
User	luxeelil
PHP Version	8.0.30
Software	LiteSpeed
Doc root	Writable

Edit File : client029.phpt \| Size : 2.66 KB
--TEST-- client curl user handler --SKIPIF-- <?php include "skipif.inc"; skip_client_test(); _ext("event"); ?> --FILE-- <?php echo "Test\n"; class UserHandler implements http\Client\Curl\User { private $evbase; private $client; private $run; private $ios = []; private $timeout; function __construct(http\Client $client, EventBase $evbase) { $this->evbase = $evbase; $this->client = $client; } function init($run) { $this->run = $run; } function timer(int $timeout_ms) { echo "T"; if (isset($this->timeout)) { $this->timeout->add($timeout_ms/1000); } else { $this->timeout = Event::timer($this->evbase, function() { if (!call_user_func($this->run, $this->client)) { if ($this->timeout) { $this->timeout->del(); $this->timeout = null; } } }); $this->timeout->add($timeout_ms/1000); } } function socket($socket, int $action) { echo "S"; switch ($action) { case self::POLL_NONE: break; case self::POLL_REMOVE: if (isset($this->ios[(int) $socket])) { echo "U"; $this->ios[(int) $socket]->del(); unset($this->ios[(int) $socket]); } break; default: $ev = 0; if ($action & self::POLL_IN) { $ev \|= Event::READ; } if ($action & self::POLL_OUT) { $ev \|= Event::WRITE; } if (isset($this->ios[(int) $socket])) { $this->ios[(int) $socket]->set($this->evbase, $socket, $ev, $this->onEvent($socket)); } else { $this->ios[(int) $socket] = new Event($this->evbase, $socket, $ev, $this->onEvent($socket)); } break; } } function onEvent($socket) { return function($watcher, $events) use($socket) { $action = 0; if ($events & Ev::READ) { $action \|= self::POLL_IN; } if ($events & Ev::WRITE) { $action \|= self::POLL_OUT; } if (!call_user_func($this->run, $this->client, $socket, $action)) { if ($this->timeout) { $this->timeout->del(); $this->timeout = null; } } }; } function once() { throw new BadMethodCallException("this test uses EventBase::loop()"); } function wait(int $timeout_ms = null) { throw new BadMethodCallException("this test uses EventBase::loop()"); } function send() { throw new BadMethodCallException("this test uses EventBase::loop()"); } } include "helper/server.inc"; server("proxy.inc", function($port) { $evbase = new EventBase; $client = new http\Client; $client->configure([ "use_eventloop" => new UserHandler($client, $evbase) ]); $client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"), function($r) { var_dump($r->getResponseCode()); }); $evbase->loop(); }); ?> ===DONE=== --EXPECTREGEX-- Test T[ST]+U+Tint\(200\) ===DONE=== Back

Edit File : client029.phpt | Size : 2.66 KB

--TEST--
client curl user handler
--SKIPIF--
<?php 
include "skipif.inc";
skip_client_test();
_ext("event");
?> 
--FILE--
<?php 
echo "Test\n";

class UserHandler implements http\Client\Curl\User
{
	private $evbase;
	private $client;
	private $run;
	private $ios = [];
	private $timeout;

include "helper/server.inc";

server("proxy.inc", function($port) {
	$evbase = new EventBase;
	$client = new http\Client;
	$client->configure([
			"use_eventloop" => new UserHandler($client, $evbase)
	]);
	$client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"), function($r) {
		var_dump($r->getResponseCode());
	});
	$evbase->loop();
});

?>
===DONE===
--EXPECTREGEX--
Test
T*[ST]+U+T*int$200$
===DONE===

Back