94 lines
2.1 KiB
PHP
94 lines
2.1 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
/*
|
|
* Identity switch RoundCube Bundle
|
|
*
|
|
* @copyright (c) 2024 Forian Daeumling, Germany. All right reserved
|
|
* @license https://github.com/toteph42/identity_switch/blob/master/LICENSE
|
|
*/
|
|
|
|
class identity_switch_rpc {
|
|
|
|
private $host = null;
|
|
private $req = null;
|
|
private $fp = null;
|
|
|
|
/**
|
|
* Open asynchronous communication channel
|
|
*
|
|
* @param string $host
|
|
* @return string|resource
|
|
*/
|
|
function open(string $host): mixed
|
|
{
|
|
$errno = $errmsg = null;
|
|
|
|
$ctx = stream_context_create([
|
|
'ssl' => [
|
|
'verify_peer' => false,
|
|
'verify_peer_name' => false,
|
|
'allow_self_signed' => false,
|
|
],
|
|
]);
|
|
|
|
// open async connection
|
|
if (!($this->fp = stream_socket_client($host, $errno, $errmsg, 30,STREAM_CLIENT_ASYNC_CONNECT, $ctx)))
|
|
return 'Cannot connect to "'.$host.'" - ['.$errno.'] '.$errmsg;
|
|
|
|
// set timeout
|
|
stream_set_timeout($this->fp, 30);
|
|
|
|
// save host name
|
|
if ($p = strpos($host, '://'))
|
|
$host = substr($host, 3 + $p);
|
|
if ($p = strpos($host, ':'))
|
|
$host = substr($host, 0, $p);
|
|
$this->host = $host;
|
|
|
|
return $this->fp;
|
|
}
|
|
|
|
/**
|
|
* Write to asynchroneous communication channel
|
|
*
|
|
* @param string $req
|
|
* @return bool
|
|
*/
|
|
function write(string $req): bool
|
|
{
|
|
|
|
$this->req = $req;
|
|
|
|
// finalize request
|
|
$req = 'GET '.$req." HTTP/1.0\r\nHost: ".$this->host."\r\n\r\n";
|
|
|
|
return (bool)fwrite($this->fp, $req);
|
|
}
|
|
|
|
/**
|
|
* Read from asynchroneous communication channel
|
|
*
|
|
* @return string
|
|
*/
|
|
function read(): string
|
|
{
|
|
if (!($wrk = fread($this->fp, 8192)))
|
|
return 'Errror reading from "'.$this->host.'" Request: "'.$this->req.'"';
|
|
|
|
$head = explode("\r\n", substr($wrk, 0, $pos = strpos($wrk, "\r\n\r\n")));
|
|
$wrk = substr($wrk, $pos + 4);
|
|
|
|
// we use this approach to get "HTTP/1.0 200 OK" as well as "HTTP/1.1 200 OK"
|
|
if (count($head) && strpos($head[0], '200 OK') === false)
|
|
return '"'.$head[0].'" for "'.$this->host.'" Request: "'.$this->req.'"';
|
|
else {
|
|
if (is_string($wrk) && strlen($wrk) > 1)
|
|
return $wrk;
|
|
}
|
|
|
|
return $wrk;
|
|
}
|
|
|
|
}
|