Annotation of embedaddon/php/ext/ftp/tests/server.inc, revision 1.1
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");
! 360: break;
! 361: default:
! 362: fputs($s, "550 {$matches[1]}: No such file or directory \r\n");
! 363: break;
! 364: }
! 365: if(isset($fs))
! 366: fclose($fs);
! 367:
! 368:
! 369: }elseif (preg_match('/^PASV/', $buf, $matches)) {
! 370: $port = $pasv_port;
! 371: $p2 = $port % ((int) 1 << 8);
! 372: $p1 = ($port-$p2)/((int) 1 << 8);
! 373: $host = "127.0.0.1";
! 374: fputs($s, "227 Entering Passive Mode. (127,0,0,1,{$p1},{$p2})\r\n");
! 375:
! 376:
! 377: } elseif (preg_match('/^SITE EXEC/', $buf, $matches)) {
! 378: fputs($s, "200 OK\r\n");
! 379:
! 380: } elseif (preg_match('/^RMD/', $buf, $matches)) {
! 381: fputs($s, "250 OK\r\n");
! 382:
! 383: } elseif (preg_match('/^SITE CHMOD/', $buf, $matches)) {
! 384: fputs($s, "200 OK\r\n");
! 385:
! 386: } elseif (preg_match('/^ALLO (\d+)/', $buf, $matches)) {
! 387: fputs($s, "200 " . $matches[1] . " bytes allocated\r\n");
! 388:
! 389: }elseif (preg_match('/^LIST www\//', $buf, $matches)) {
! 390: fputs($s, "150 Opening ASCII mode data connection for file list\r\n");
! 391: fputs($s, "226 Transfer complete\r\n");
! 392:
! 393: }elseif (preg_match('/^LIST no_exists\//', $buf, $matches)) {
! 394: fputs($s, "425 Error establishing connection\r\n");
! 395:
! 396: }elseif (preg_match('/^REST \d+/', $buf, $matches)) {
! 397: fputs($s, "350 OK\r\n");
! 398: }
! 399:
! 400: else {
! 401: fputs($s, "500 Syntax error, command unrecognized.\r\n");
! 402: dump_and_exit($buf);
! 403: }
! 404: }
! 405: fclose($s);
! 406: exit;
! 407: }
! 408:
! 409: fclose($socket);
! 410: ?>
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[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