kumi/fossbilling-epp-isnic
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Rewritten EPP connection code

Browse source
This commit is contained in:
Pinga 2023-02-15 23:53:25 +02:00 committed by GitHub
parent fa17784456
commit 85ba677f5e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 25 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
epp.php
View file

@ -1286,35 +1286,39 @@ class Registrar_Adapter_EPP extends Registrar_AdapterAbstract
public function read() public function read()
{ {
if (feof($this->socket)) { $hdr = stream_get_contents($this->socket, 4);
throw new exception('Connection appears to have closed.'); if ($hdr === false) {
} throw new exception('Connection appears to have closed.');
}
$hdr = @fread($this->socket, 4); if (strlen($hdr) < 4) {
if (empty($hdr)) { throw new exception('Failed to read header from the connection.');
throw new exception('Error reading from server.'); }
} $unpacked = unpack('N', $hdr);
$xml = fread($this->socket, ($unpacked[1] - 4));
$unpacked = unpack('N', $hdr); $xml = preg_replace('/></', ">\n<", $xml);
$xml = fread($this->socket, ($unpacked[1] - 4)); return $xml;
$xml = preg_replace('/></', ">\n<", $xml);
return $xml;
} }
public function write($xml, $action = 'Unknown') public function write($xml)
{ {
@fwrite($this->socket, pack('N', (strlen($xml) + 4)) . $xml); if (fwrite($this->socket, pack('N', (strlen($xml) + 4)) . $xml) === false) {
$r = $this->read(); throw new exception('Error writing to the connection.');
$r = new SimpleXMLElement($r); }
if ($r->response->result->attributes()->code >= 2000) { $r = simplexml_load_string($this->readResponse());
throw new exception($r->response->result->msg); if ($r->response->result->attributes()->code >= 2000) {
} throw new exception($r->response->result->msg);
}
return $r; return $r;
} }
public function disconnect() public function disconnect()
{ {
return @fclose($this->socket); $result = fclose($this->socket);
if (!$result) {
throw new exception('Error closing the connection.');
}
$this->socket = null;
return $result;
} }
function generateObjectPW($objType = 'none') function generateObjectPW($objType = 'none')