WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/scripts/Atom1.5-phpExampleClient/light/tcp.php


<?
 
error_reporting(E_ALL);
 
function atomd_connect($host, $port)
{
  $socket = pfsockopen($host, $port, $errno, $errstr);
 
  if (!$socket)
  {
    throw new Exception("$errstr ($errno)");
  }
 
  return $socket;
}
 
 
function atomd_read_packet($socket)
{
  if (feof($socket))
  {
    throw new Exception("socket not open");
  }
 
  $command = fread($socket, 4);
 
  if ($command === FALSE)
  {
    throw new Exception("got EOF while reading command from socket");
  }
 
  $payload_length = fread($socket, 4);
 
  if ($payload_length === FALSE)
  {
    throw new Exception("got EOF while reading payload_length from socket");
  }
 
  $payload = "";
 
  if ($payload_length > 0)
  {
    $payload = fread($socket, intval($payload_length));
   
    if ($payload === FALSE)
    {
      throw new Exception("got EOF while reading payload from socket");
    }
  }
 
  return $command . $payload_length . $payload;
}
 
function atomd_write_packet($socket, $command, $payload)
{
  if (feof($socket))
  {
    throw new Exception("socket not open");
  }
 
  $packet = $command . str_pad(strlen($payload) + 1, 4, "0", STR_PAD_LEFT) . $payload . "\0";
 
  if (fwrite($socket, $packet) === FALSE)
  {
     throw new Exception("got error while writing payload to socket");
  }
}
 
function atomd_data_available($socket)
{
  $position = ftell($socket);
 
  fseek($socket, -1, SEEK_END);
 
  $has_data = ftell($socket) > $position;
 
  fseek($socket, $position, SEEK_SET);
 
  return $has_data;
}
 
 
 
function atomd_initialize($host, $port)
{
  $socket = atomd_connect($host, $port);
 
  while (atomd_data_available($socket))
  {
    $packet = atomd_read_packet($socket); // Read initial prompt
  }
 
  return $socket;
}
 
function atomd_send_command($socket, $command)
{
  atomd_write_packet($socket, "RESP", $command);
}
 
function atomd_read_command_response($socket)
{
  $response = "";
 
  while (true)
  {
    $packet = atomd_read_packet($socket);
   
    if (substr($packet, 0, 4) != "TEXT")
    {
      break;
    }
   
    $response .= substr($packet, 8) . "\n";
  }
 
  return $response;
}
 
try
{
  $socket = atomd_initialize("127.0.0.1", 1202);
 
  atomd_send_command($socket, "Module_GetLastValue bokhylla");
 
  echo atomd_read_command_response($socket);
}
catch (Exception $e)
{
  die($e);
}
 
 
/*
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 
if ($socket === false)
{
  die("Socket Creation Failed");
}
 
$result = socket_connect($socket, "127.0.0.1", 1202);
 
if ($result === false)
{
  die("Connection Failed");
}
 
 
$command = "help";
$length = strlen($command) + 1;
 
$data = "RESP" . str_pad($length, 4, "0", STR_PAD_LEFT) . $command . "\0\n";
 
echo "Sending:" . $data . "<br/>";
 
socket_write($socket, $data, strlen($data));
 
do
{
  $line = socket_read($socket, 1024, PHP_BINARY_READ);
  $output .= $line;
}
while ($line != "");
 
echo $output . "<br/>";
$output = "";
 
echo "Done first read!<br/>";
 
do
{
  $line = socket_read($socket, 1024, PHP_BINARY_READ);
  $output .= $line;
}
while ($line != "");
 
echo $output . "<br/>";
$output = "";
 
echo "Done!<br/>";
 
socket_close($socket);
*/
?>
 

Rev 1880	Rev 1883
1	<?	1	<?
2		2
3	error_reporting(E_ALL);	3	error_reporting(E_ALL);
4		4
5	function atomd_connect($host, $port)	5	function atomd_connect($host, $port)
6	{	6	{
7	$socket = pfsockopen($host, $port, $errno, $errstr);	7	$socket = pfsockopen($host, $port, $errno, $errstr);
8		8
9	if (!$socket)	9	if (!$socket)
10	{	10	{
11	throw new Exception("$errstr ($errno)");	11	throw new Exception("$errstr ($errno)");
12	}	12	}
13		13
14	return $socket;	14	return $socket;
15	}	15	}
16		16
17		17
18	function atomd_read_packet($socket)	18	function atomd_read_packet($socket)
19	{	19	{
20	if (feof($socket))	20	if (feof($socket))
21	{	21	{
22	throw new Exception("socket not open");	22	throw new Exception("socket not open");
23	}	23	}
24		24
25	$command = fread($socket, 4);	25	$command = fread($socket, 4);
26		26
27	if ($command === FALSE)	27	if ($command === FALSE)
28	{	28	{
29	throw new Exception("got EOF while reading command from socket");	29	throw new Exception("got EOF while reading command from socket");
30	}	30	}
31		31
32	$payload_length = fread($socket, 4);	32	$payload_length = fread($socket, 4);
33		33
34	if ($payload_length === FALSE)	34	if ($payload_length === FALSE)
35	{	35	{
36	throw new Exception("got EOF while reading payload_length from socket");	36	throw new Exception("got EOF while reading payload_length from socket");
37	}	37	}
38		38
39	$payload = "";	39	$payload = "";
40		40
41	if ($payload_length > 0)	41	if ($payload_length > 0)
42	{	42	{
43	$payload = fread($socket, intval($payload_length));	43	$payload = fread($socket, intval($payload_length));
44		44
45	if ($payload === FALSE)	45	if ($payload === FALSE)
46	{	46	{
47	throw new Exception("got EOF while reading payload from socket");	47	throw new Exception("got EOF while reading payload from socket");
48	}	48	}
49	}	49	}
50		50
51	return $command . $payload_length . $payload;	51	return $command . $payload_length . $payload;
52	}	52	}
53		53
54	function atomd_write_packet($socket, $command, $payload)	54	function atomd_write_packet($socket, $command, $payload)
55	{	55	{
56	if (feof($socket))	56	if (feof($socket))
57	{	57	{
58	throw new Exception("socket not open");	58	throw new Exception("socket not open");
59	}	59	}
60		60
61	$packet = $command . str_pad(strlen($payload) + 1, 4, "0", STR_PAD_LEFT) . $payload . "\0";	61	$packet = $command . str_pad(strlen($payload) + 1, 4, "0", STR_PAD_LEFT) . $payload . "\0";
62		62
63	if (fwrite($socket, $packet) === FALSE)	63	if (fwrite($socket, $packet) === FALSE)
64	{	64	{
65	throw new Exception("got error while writing payload to socket");	65	throw new Exception("got error while writing payload to socket");
66	}	66	}
67	}	67	}
68		68
69	function atomd_data_available($socket)	69	function atomd_data_available($socket)
70	{	70	{
71	$position = ftell($socket);	71	$position = ftell($socket);
72		72
73	fseek($socket, -1, SEEK_END);	73	fseek($socket, -1, SEEK_END);
74		74
75	$has_data = ftell($socket) > $position;	75	$has_data = ftell($socket) > $position;
76		76
77	fseek($socket, $position, SEEK_SET);	77	fseek($socket, $position, SEEK_SET);
78		78
79	return $has_data;	79	return $has_data;
80	}	80	}
81		81
82		82
83		83
84	function atomd_initialize($host, $port)	84	function atomd_initialize($host, $port)
85	{	85	{
86	$socket = atomd_connect($host, $port);	86	$socket = atomd_connect($host, $port);
87		87
88	while (atomd_data_available($socket))	88	while (atomd_data_available($socket))
89	{	89	{
90	$packet = atomd_read_packet($socket); // Read initial prompt	90	$packet = atomd_read_packet($socket); // Read initial prompt
91	}	91	}
92		92
93	return $socket;	93	return $socket;
94	}	94	}
95		95
96	function atomd_send_command($socket, $command)	96	function atomd_send_command($socket, $command)
97	{	97	{
98	atomd_write_packet($socket, "RESP", $command);	98	atomd_write_packet($socket, "RESP", $command);
99	}	99	}
100		100
101	function atomd_read_command_response($socket)	101	function atomd_read_command_response($socket)
102	{	102	{
103	$response = "";	103	$response = "";
104		104
105	while (true)	105	while (true)
106	{	106	{
107	$packet = atomd_read_packet($socket);	107	$packet = atomd_read_packet($socket);
108		108
109	if (substr($packet, 0, 4) != "TEXT")	109	if (substr($packet, 0, 4) != "TEXT")
110	{	110	{
111	break;	111	break;
112	}	112	}
113		113
114	$response .= substr($packet, 8) . "\n";	114	$response .= substr($packet, 8) . "\n";
115	}	115	}
116		116
117	return $response;	117	return $response;
118	}	118	}
119		119
120	try	120	try
121	{	121	{
122	$socket = atomd_initialize("127.0.0.1", 1202);	122	$socket = atomd_initialize("127.0.0.1", 1202);
123		123
124	atomd_send_command($socket, "Module_GetLastValue bokhylla");	124	atomd_send_command($socket, "Module_GetLastValue bokhylla");
125		125
126	echo atomd_read_command_response($socket);	126	echo atomd_read_command_response($socket);
127	}	127	}
128	catch (Exception $e)	128	catch (Exception $e)
129	{	129	{
130	die($e);	130	die($e);
131	}	131	}
132		132
133		133
134	/*	134	/*
135	$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);	135	$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
136		136
137	if ($socket === false)	137	if ($socket === false)
138	{	138	{
139	die("Socket Creation Failed");	139	die("Socket Creation Failed");
140	}	140	}
141		141
142	$result = socket_connect($socket, "127.0.0.1", 1202);	142	$result = socket_connect($socket, "127.0.0.1", 1202);
143		143
144	if ($result === false)	144	if ($result === false)
145	{	145	{
146	die("Connection Failed");	146	die("Connection Failed");
147	}	147	}
148		148
149		149
150	$command = "help";	150	$command = "help";
151	$length = strlen($command) + 1;	151	$length = strlen($command) + 1;
152		152
153	$data = "RESP" . str_pad($length, 4, "0", STR_PAD_LEFT) . $command . "\0\n";	153	$data = "RESP" . str_pad($length, 4, "0", STR_PAD_LEFT) . $command . "\0\n";
154		154
155	echo "Sending:" . $data . "<br/>";	155	echo "Sending:" . $data . "<br/>";
156		156
157	socket_write($socket, $data, strlen($data));	157	socket_write($socket, $data, strlen($data));
158		158
159	do	159	do
160	{	160	{
161	$line = socket_read($socket, 1024, PHP_BINARY_READ);	161	$line = socket_read($socket, 1024, PHP_BINARY_READ);
162	$output .= $line;	162	$output .= $line;
163	}	163	}
164	while ($line != "");	164	while ($line != "");
165		165
166	echo $output . "<br/>";	166	echo $output . "<br/>";
167	$output = "";	167	$output = "";
168		168
169	echo "Done first read!<br/>";	169	echo "Done first read!<br/>";
170		170
171	do	171	do
172	{	172	{
173	$line = socket_read($socket, 1024, PHP_BINARY_READ);	173	$line = socket_read($socket, 1024, PHP_BINARY_READ);
174	$output .= $line;	174	$output .= $line;
175	}	175	}
176	while ($line != "");	176	while ($line != "");
177		177
178	echo $output . "<br/>";	178	echo $output . "<br/>";
179	$output = "";	179	$output = "";
180		180
181	echo "Done!<br/>";	181	echo "Done!<br/>";
182		182
183	socket_close($socket);	183	socket_close($socket);
184	*/	184	*/
185	?>	185	?>
186		186

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/scripts/Atom1.5-phpExampleClient/light/tcp.php @ 1993 – Rev 1880 → 1883