![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to server.inc CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / ftp / tests|
Return to server.inc CVS log | Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / ftp / tests |
1.1 misho 1: <?php
2:
3: $socket = null;
4: $errno = 0;
5: $context = stream_context_create(array('ssl' => array('local_cert' => dirname(__FILE__).'/cert.pem', 'passphrase' => 'pass')));
6:
7: for ($i=0; $i<10 && !$socket; ++$i) {
8: $port = rand(50000, 65535);
9:
10: $socket = stream_socket_server("tcp://127.0.0.1:$port", $errno, $errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN, $context);
11: }
12: //set anther random port that is not the same as $port
13: do{
14: $pasv_port = rand(50000, 65535);
15: }while($pasv_port == $port);
16:
17: if (!$socket) {
18: die("could not start/bind the ftp server\n");
19: }
20:
21:
22:
23:
24: $pid = pcntl_fork();
25:
26:
27:
28: function pasv_listen($action){
29: global $pasv_port, $tmp_file;
30: $tmp_file = 'nm2.php';
31: $pid = pcntl_fork();
32: if($pid === 0){
33: $soc = stream_socket_server("tcp://127.0.0.1:$pasv_port");
34: $fs = stream_socket_accept($soc, 3);
35: switch ($action) {
36: case 'fget':
37: case 'get':
38: //listen for 3 seconds 3 seconds
39: fputs($fs, "I am passive.\r\n");
40: break;
41: case 'put':
42: file_put_contents($tmp_file, stream_get_contents($fs));
43: break;
44: case 'list':
45: fputs($fs, "drwxr-x--- 3 owner group 4096 Jul 12 12:16 .\r\n");
46: fputs($fs, "drwxr-x--- 3 owner group 4096 Jul 12 12:16 ..\r\n");
47: fputs($fs, "drwxr-x--- 3 owner group 4096 Jul 12 12:16 public_ftp\r\n");
48: break;
49: case 'list_null':
50: fputs($fs, "\r\n");
51: break;
52: }
53: fclose($fs);
54: exit;
55: }
56: }
57:
58:
59:
60: if ($pid) {
61:
62: function dump_and_exit($buf)
63: {
64: var_dump($buf);
65: fclose($GLOBALS['s']);
66: exit;
67: }
68:
69: function anonymous()
70: {
71: return $GLOBALS['user'] === 'anonymous';
72: }
73:
74: /* quick&dirty realpath() like function */
75: function change_dir($dir)
76: {
77: global $cwd;
78:
79: if ($dir[0] == '/') {
80: $cwd = $dir;
81: return;
82: }
83:
84: $cwd = "$cwd/$dir";
85:
86: do {
87: $old = $cwd;
88: $cwd = preg_replace('@/?[^/]+/\.\.@', '', $cwd);
89: } while ($old != $cwd);
90:
91: $cwd = strtr($cwd, array('//' => '/'));
92: if (!$cwd) $cwd = '/';
93: }
94:
95: $s = stream_socket_accept($socket);
96:
97: if (!$s) die("Error accepting a new connection\n");
98:
99: fputs($s, "220----- PHP FTP server 0.3 -----\r\n220 Service ready\r\n");
100: $buf = fread($s, 2048);
101:
102:
103: function user_auth($buf) {
104: global $user, $s, $ssl, $bug37799;
105:
106: if (!empty($ssl)) {
107: if ($buf !== "AUTH TLS\r\n") {
108: fputs($s, "500 Syntax error, command unrecognized.\r\n");
109: dump_and_exit($buf);
110: }
111:
112: if (empty($bug37799)) {
113: fputs($s, "234 auth type accepted\r\n");
114: } else {
115: fputs($s, "666 dummy\r\n");
116: fputs($s, "666 bogus msg\r\n");
117: exit;
118: }
119:
120: if (!stream_socket_enable_crypto($s, true, STREAM_CRYPTO_METHOD_SSLv23_SERVER)) {
121: die("SSLv23 handshake failed.\n");
122: }
123:
124: if (!preg_match('/^PBSZ \d+\r\n$/', $buf = fread($s, 2048))) {
125: fputs($s, "501 bogus data\r\n");
126: dump_and_exit($buf);
127: }
128:
129: fputs($s, "200 OK\r\n");
130: $buf = fread($s, 2048);
131:
132: if ($buf !== "PROT P\r\n") {
133: fputs($s, "504 Wrong protection.\r\n");
134: dump_and_exit($buf);
135: }
136:
137: fputs($s, "200 OK\r\n");
138:
139: $buf = fread($s, 2048);
140: }
141:
142: if (!preg_match('/^USER (\w+)\r\n$/', $buf, $m)) {
143: fputs($s, "500 Syntax error, command unrecognized.\r\n");
144: dump_and_exit($buf);
145: }
146: $user = $m[1];
147: if ($user !== 'user' && $user !== 'anonymous') {
148: fputs($s, "530 Not logged in.\r\n");
149: fclose($s);
150: exit;
151: }
152:
153: if (anonymous()) {
154: fputs($s, "230 Anonymous user logged in\r\n");
155:
156: } else {
157: fputs($s, "331 User name ok, need password\r\n");
158:
159: if (!preg_match('/^PASS (\w+)\r\n$/', $buf = fread($s, 100), $m)) {
160: fputs($s, "500 Syntax error, command unrecognized.\r\n");
161: dump_and_exit($buf);
162: }
163:
164: $pass = $m[1];
165: if ($pass === 'pass') {
166: fputs($s, "230 User logged in\r\n");
167: } else {
168: fputs($s, "530 Not logged in.\r\n");
169: fclose($s);
170: exit;
171: }
172: }
173: }
174:
175: user_auth($buf);
176:
177: $cwd = '/';
178: $num_bogus_cmds = 0;
179:
180: while($buf = fread($s, 4098)) {
181: if (!empty($bogus)) {
182: fputs($s, "502 Command not implemented (".$num_bogus_cmds++.").\r\n");
183:
184: } else if ($buf === "HELP\r\n") {
185: fputs($s, "214-There is help available for the following commands:\r\n");
186: fputs($s, " USER\r\n");
187: fputs($s, " HELP\r\n");
188: fputs($s, "214 end of list\r\n");
189:
190: } elseif ($buf === "HELP HELP\r\n") {
191: fputs($s, "214 Syntax: HELP [<SP> <string>] <CRLF>\r\n");
192:
193: } elseif ($buf === "PWD\r\n") {
194: fputs($s, "257 \"$cwd\" is current directory.\r\n");
195:
196: } elseif ($buf === "CDUP\r\n") {
197: change_dir('..');
198: fputs($s, "250 CDUP command successful.\r\n");
199:
200: } elseif ($buf === "SYST\r\n") {
201: if (isset($bug27809)) {
202: fputs($s, "215 OS/400 is the remote operating system. The TCP/IP version is \"V5R2M0\"\r\n");
203: } else {
204: fputs($s, "215 UNIX Type: L8.\r\n");
205: }
206:
207: } elseif ($buf === "TYPE A\r\n") {
208: $ascii = true;
209: fputs($s, "200 OK\r\n");
210:
211: } elseif ($buf === "TYPE I\r\n") {
212: $ascii = false;
213: fputs($s, "200 OK\r\n");
214:
215: } elseif ($buf === "QUIT\r\n") {
216: break;
217:
218: } elseif (preg_match("~^PORT (\d+),(\d+),(\d+),(\d+),(\d+),(\d+)\r\n$~", $buf, $m)) {
219: $host = "$m[1].$m[2].$m[3].$m[4]";
220: $port = ((int)$m[5] << 8) + (int)$m[6];
221: fputs($s, "200 OK.\r\n");
222:
223: } elseif (preg_match("~^STOR ([\w/.-]+)\r\n$~", $buf, $m)) {
224: fputs($s, "150 File status okay; about to open data connection\r\n");
225:
226: if(empty($pasv))
227: {
228: if (!$fs = stream_socket_client("tcp://$host:$port")) {
229: fputs($s, "425 Can't open data connection\r\n");
230: continue;
231: }
232:
233: $data = stream_get_contents($fs);
234: $orig = file_get_contents(dirname(__FILE__).'/'.$m[1]);
235:
236:
237: if (isset($ascii) && !$ascii && $orig === $data) {
238: fputs($s, "226 Closing data Connection.\r\n");
239:
240: } elseif ((!empty($ascii) || isset($bug39583)) && $data === strtr($orig, array("\r\n" => "\n", "\r" => "\n", "\n" => "\r\n"))) {
241: fputs($s, "226 Closing data Connection.\r\n");
242:
243: } else {
244: var_dump($data);
245: var_dump($orig);
246: fputs($s, "552 Requested file action aborted.\r\n");
247: }
248: fclose($fs);
249: }else{
250: $data = file_get_contents('nm2.php');
251: $orig = file_get_contents(dirname(__FILE__).'/'.$m[1]);
252: if ( $orig === $data) {
253: fputs($s, "226 Closing data Connection.\r\n");
254:
255: } else {
256: var_dump($data);
257: var_dump($orig);
258: fputs($s, "552 Requested file action aborted.\r\n");
259: }
260: }
261:
262: } elseif (preg_match("~^CWD ([A-Za-z./]+)\r\n$~", $buf, $m)) {
263: change_dir($m[1]);
264: fputs($s, "250 CWD command successful.\r\n");
265:
266: } elseif (preg_match("~^NLST(?: ([A-Za-z./]+))?\r\n$~", $buf, $m)) {
267:
268: if (isset($m[1]) && $m[1] === 'bogusdir') {
269: fputs($s, "250 $m[1]: No such file or directory\r\n");
270: continue;
271: }
272:
273: // there are some servers that don't open the ftp-data socket if there's nothing to send
274: if (isset($bug39458) && isset($m[1]) && $m[1] === 'emptydir') {
275: fputs($s, "226 Transfer complete.\r\n");
276: continue;
277: }
278:
279: fputs($s, "150 File status okay; about to open data connection\r\n");
280:
281: if (!$fs = stream_socket_client("tcp://$host:$port")) {
282: fputs($s, "425 Can't open data connection\r\n");
283: continue;
284: }
285:
286: if (empty($m[1]) || $m[1] !== 'emptydir') {
287: fputs($fs, "file1\r\nfile1\r\nfile\nb0rk\r\n");
288: }
289:
290: fputs($s, "226 Closing data Connection.\r\n");
291: fclose($fs);
292:
293: } elseif (preg_match("~^MKD ([A-Za-z./]+)\r\n$~", $buf, $m)) {
294: if (isset($bug7216)) {
295: fputs($s, "257 OK.\r\n");
296: } else {
297: fputs($s, "257 \"/path/to/ftproot$cwd$m[1]\" created.\r\n");
298: }
299:
300: } elseif (preg_match('/^USER /', $buf)) {
301: user_auth($buf);
302:
303: } elseif (preg_match('/^MDTM ([\w\h]+)/', $buf, $matches)) {
304: switch ($matches [1]){
305: case "A":
306: fputs($s, "213 19980615100045.014\r\n");
307: break;
308: case "B":
309: fputs($s, "213 19980615100045.014\r\n");
310: break;
311: case "C":
312: fputs($s, "213 19980705132316\r\n");
313: break;
314: case "19990929043300 File6":
315: fputs($s, "213 19991005213102\r\n");
316: break;
317: default :
318: fputs($s, "550 No file named \"{$matches [1]}\"\r\n");
319: break;
320: }
321: }elseif (preg_match('/^RETR ([\w\h]+)/', $buf, $matches)) {
322: if(!empty($pasv)){
323: ;
324: }
325: else if (!$fs = stream_socket_client("tcp://$host:$port")) {
326: fputs($s, "425 Can't open data connection\r\n");
327: continue;
328: }
329:
330: switch($matches[1]){
331:
332: case "pasv":
333: fputs($s, "150 File status okay; about to open data connection.\r\n");
334: //the data connection is handled in another forked process
335: // called from outside this while loop
336: fputs($s, "226 Closing data Connection.\r\n");
337: break;
338: case "a story":
339: fputs($s, "150 File status okay; about to open data connection.\r\n");
340: fputs($fs, "For sale: baby shoes, never worn.\r\n");
341: fputs($s, "226 Closing data Connection.\r\n");
342: break;
343: case "binary data":
344: fputs($s, "150 File status okay; about to open data connection.\r\n");
345: $transfer_type = $ascii? 'ASCII' : 'BINARY' ;
346: fputs($fs, $transfer_type."Foo\0Bar\r\n");
347: fputs($s, "226 Closing data Connection.\r\n");
348: break;
349: case "fget":
350: fputs($s, "150 File status okay; about to open data connection.\r\n");
351: $transfer_type = $ascii? 'ASCII' : 'BINARY' ;
352: fputs($fs, $transfer_type."FooBar\r\n");
353: fputs($s, "226 Closing data Connection.\r\n");
354: break;
355: case "fgetresume":
356: fputs($s, "150 File status okay; about to open data connection.\r\n");
357: $transfer_type = $ascii? 'ASCII' : 'BINARY' ;
358: fputs($fs, "Bar\r\n");
359: fputs($s, "226 Closing data Connection.\r\n");
1.1.1.2 misho 360: break;
361: case "fget_large":
362: fputs($s, "150 File status okay; about to open data connection.\r\n");
363: $transfer_type = $ascii? 'ASCII' : 'BINARY' ;
364: if ($GLOBALS['rest_pos'] == '5368709119') {
365: fputs($fs, "X");
366: } else {
367: fputs($fs, "Y");
368: }
369: fputs($s, "226 Closing data Connection.\r\n");
370: break;
1.1.1.3 ! misho 371: case "mediumfile":
! 372: fputs($s, "150 File status okay; about to open data connection.\r\n");
! 373: for($i = 0; $i < 150; $i++){
! 374: fputs($fs, "This is line $i of the test data.\n");
! 375: }
! 376: fputs($s, "226 Closing data Connection.\r\n");
! 377:
1.1 misho 378: default:
379: fputs($s, "550 {$matches[1]}: No such file or directory \r\n");
380: break;
381: }
382: if(isset($fs))
383: fclose($fs);
384:
385:
386: }elseif (preg_match('/^PASV/', $buf, $matches)) {
387: $port = $pasv_port;
388: $p2 = $port % ((int) 1 << 8);
389: $p1 = ($port-$p2)/((int) 1 << 8);
390: $host = "127.0.0.1";
391: fputs($s, "227 Entering Passive Mode. (127,0,0,1,{$p1},{$p2})\r\n");
392:
393:
394: } elseif (preg_match('/^SITE EXEC/', $buf, $matches)) {
395: fputs($s, "200 OK\r\n");
396:
397: } elseif (preg_match('/^RMD/', $buf, $matches)) {
398: fputs($s, "250 OK\r\n");
399:
400: } elseif (preg_match('/^SITE CHMOD/', $buf, $matches)) {
401: fputs($s, "200 OK\r\n");
402:
403: } elseif (preg_match('/^ALLO (\d+)/', $buf, $matches)) {
404: fputs($s, "200 " . $matches[1] . " bytes allocated\r\n");
405:
406: }elseif (preg_match('/^LIST www\//', $buf, $matches)) {
407: fputs($s, "150 Opening ASCII mode data connection for file list\r\n");
408: fputs($s, "226 Transfer complete\r\n");
409:
410: }elseif (preg_match('/^LIST no_exists\//', $buf, $matches)) {
411: fputs($s, "425 Error establishing connection\r\n");
412:
1.1.1.2 misho 413: }elseif (preg_match('/^REST (\d+)/', $buf, $matches)) {
414: $GLOBALS['rest_pos'] = $matches[1];
1.1 misho 415: fputs($s, "350 OK\r\n");
1.1.1.2 misho 416: }elseif (preg_match('/^SIZE largefile/', $buf)) {
417: fputs($s, "213 5368709120\r\n");
418: }else {
1.1 misho 419: fputs($s, "500 Syntax error, command unrecognized.\r\n");
420: dump_and_exit($buf);
421: }
422: }
423: fclose($s);
424: exit;
425: }
426:
427: fclose($socket);
1.1.1.2 misho 428: ?>