Protocol.php 3.26 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
<?php

/*	EPP Client class for PHP, Copyright 2005 CentralNic Ltd
	This program is free software; you can redistribute it and/or modify
	it under the terms of the GNU General Public License as published by
	the Free Software Foundation; either version 2 of the License, or
	(at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
	GNU General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program; if not, write to the Free Software
	Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

/**
* Low-level functions useful for both EPP clients and servers
* @package Net_EPP
* @version 0.0.4
* @author Gavin Brown <gavin.brown@nospam.centralnic.com>
* @revision $Id: Protocol.php,v 1.4 2011/06/28 09:48:02 gavin Exp $
*/

/**
* Low-level functions useful for both EPP clients and servers
* @package Net_EPP
*/
class Net_EPP_Protocol {

33
34
35
36
37
	static function _fread_nb($socket,$length) {
		$result = '';

		// Loop reading and checking info to see if we hit timeout
		$info = stream_get_meta_data($socket);
38
39
		$time_start = microtime(true);

40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
		while (!$info['timed_out'] && !feof($socket)) {
			// Try read remaining data from socket
			$buffer = @fread($socket,$length - strlen($result));
			// If the buffer actually contains something then add it to the result
			if ($buffer !== false) {
				$result .= $buffer;
				// If we hit the length we looking for, break
				if (strlen($result) == $length) {
					break;
				}
			} else {
				// Sleep 0.25s
				usleep(2500);
			}
			// Update metadata
			$info = stream_get_meta_data($socket);
56
57
58
59
			$time_end = microtime(true);
			if (($time_end - $time_start) > 5) {
				throw new exception('Timeout while contacting EPP Server');
			}
60
61
62
63
		}

		// Check for timeout
		if ($info['timed_out']) {
64
			throw new Exception('Timeout while reading data from socket');
65
66
67
68
69
		}

		return $result;
	}

70
71
72
	/**
	* get an EPP frame from the remote peer
	* @param resource $socket a socket connected to the remote peer
73
74
	* @throws Exception on frame errors.
	* @return string the frame
75
76
	*/
	static function getFrame($socket) {
77
		// Read header
78
		$hdr = Net_EPP_Protocol::_fread_nb($socket,4);
79

80
		// Unpack first 4 bytes which is our length
81
82
83
		$unpacked = unpack('N', $hdr);
		$length = $unpacked[1];
		if ($length < 5) {
84
			throw new Exception(sprintf('Got a bad frame header length of %d bytes from peer', $length));
85
86

		} else {
87
			$length -= 4; // discard the length of the header itself
88
89
			// Read frame
			return Net_EPP_Protocol::_fread_nb($socket,$length);
90
91
92
93
94
95
96
		}
	}

	/**
	* send an EPP frame to the remote peer
	* @param resource $socket a socket connected to the remote peer
	* @param string $xml the XML to send
97
98
	* @throws Exception when it doesn't complete the write to the socket
	* @return the amount of bytes written to the frame
99
100
	*/
	static function sendFrame($socket, $xml) {
101
102
103
104
105
		// Grab XML length & add on 4 bytes for the counter
		$length = strlen($xml) + 4;
		$res = fwrite($socket, pack('N',$length) . $xml);
		// Check our write matches
		if ($length != $res) {
106
			throw new Exception("Short write when sending XML");
107
108
109
		}

		return $res;
110
111
	}
}