php-lpd/class.lpd.php at master · vakata/php-lpd · GitHub

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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
<?php
class LPD
{
	protected $sock = null;
	protected $debg = false;
	protected $call = null;

	public function __construct($call = null, $addr = '127.0.0.1', $port = 515, $maxc = 5, $start = true, $debg = false) {
		$this->debg = $debg;
		$this->call = $call;

		if(($this->sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
			throw new Exception('socket_create() failed: reason: ' . socket_strerror(socket_last_error()));
		}
		if(socket_bind($this->sock, $addr, $port) === false) {
			throw new Exception('socket_bind() failed: reason: ' . socket_strerror(socket_last_error($sock)));
		}
		if(socket_listen($this->sock, $maxc) === false) {
			throw new Exception('socket_listen() failed: reason: ' . socket_strerror(socket_last_error($sock)));
		}
		if($start) {
			$this->start();
		}
	}
	public function __destruct() {
		@socket_close($this->sock);
	}
	public function start() {
		do {
			if(($msgsock = socket_accept($this->sock)) === false) {
				throw new Exception('socket_accept() failed: reason: ' . socket_strerror(socket_last_error($sock)));
			}
			$this->debug('New client');
			$this->read_command($msgsock);
		}
		while(true);
	}

	protected function read_command($msgsock, $receive_mode = false, $control_file = null) {
		if(false === ($buff = socket_read($msgsock, 4096, PHP_NORMAL_READ))) {
			throw new Exception('socket_read() failed: reason: ' . socket_strerror(socket_last_error($msgsock)));
		}
		$command = ord($buff[0]);
		$arguments = preg_split('([\s]+)', substr($buff,1));
		$this->process_command($msgsock, $command, $arguments, $receive_mode, $control_file);
	}
	protected function read_bytes($msgsock, $bytes) {
		$content = '';
		do {
			if(false === ($buff = socket_read($msgsock, 1024, PHP_BINARY_READ))) {
				throw new Exception('socket_read() failed: reason: ' . socket_strerror(socket_last_error($msgsock)));
			}
			$content .= $buff;
		} while(mb_strlen($content, '8bit') < $bytes && $buff != '');
		return $content;
		//return mb_substr($content, 0, $bytes, '8bit');
	}
	protected function process_command($msgsock, $command, $arguments, $receive_mode, $control_file = null) {
		$this->debug($command);
		switch($command) {
			case 1:
				socket_write($msgsock, chr(0));
				socket_close($msgsock);
				break;
			case 2:
				if(!$receive_mode) {
					$receive_mode = true;
					socket_write($msgsock, chr(0));
					$this->read_command($msgsock, $receive_mode);
				}
				else {
					socket_write($msgsock, chr(0));
					$control_file = $this->read_bytes($msgsock, $arguments[0]);
					socket_write($msgsock, chr(0));
					$this->read_command($msgsock, $receive_mode, $control_file);
				}
				break;
			case 3:
				if(!$receive_mode) {
					socket_write($msgsock, chr(0));
					$this->read_command($msgsock, $receive_mode);
				}
				else {
					socket_write($msgsock, chr(0));
					$data = $this->read_bytes($msgsock, $arguments[0]);
					socket_write($msgsock, chr(0));
					socket_close($msgsock);
					$this->process_data($data, $control_file);
				}
				break;
			default:
				socket_write($msgsock, chr(0));
				break;
		}
	}
	protected function debug($msg) {
		if($this->debg) {
			echo $msg . "\r\n";
		}
	}
	protected function process_data($data, $control_file) {
		$data = preg_split('(\n)', $data);
		$dump = array();
		foreach($data as $row) {
			$res = array();
			$row = preg_split('(\r)', $row);
			foreach($row as $r) {
				for($i = 0, $j = strlen($r); $i < $j; $i++) {
					if(!isset($res[$i]) || $r[$i] !== ' ') {
						$res[$i] = $r[$i];
					}
				}
			}
			$dump[] = implode('',$res);
		}
		$dump = implode("\r\n", $dump);
		$data = $dump;

		if($this->call && is_callable($this->call)) {
			call_user_func($this->call, $data, $control_file);
		}
	}
}