1<?php declare(strict_types=1); 2 3function http_server_skipif() { 4 5 if (!function_exists('pcntl_fork')) die('skip pcntl_fork() not available'); 6 if (!function_exists('posix_kill')) die('skip posix_kill() not available'); 7 if (!stream_socket_server('tcp://localhost:0')) die('skip stream_socket_server() failed'); 8} 9 10function http_server_init(&$output = null) { 11 pcntl_alarm(60); 12 13 $server = stream_socket_server('tcp://localhost:0', $errno, $errstr); 14 if (!$server) { 15 return false; 16 } 17 18 if ($output === null) { 19 $output = tmpfile(); 20 if ($output === false) { 21 return false; 22 } 23 } 24 25 $pid = pcntl_fork(); 26 if ($pid == -1) { 27 die('could not fork'); 28 } else if ($pid) { 29 return [ 30 'pid' => $pid, 31 'uri' => 'http://' . stream_socket_get_name($server, false), 32 ]; 33 } 34 35 return $server; 36} 37 38/* Minimal HTTP server with predefined responses. 39 * 40 * $socket_string is the socket to create and listen on (e.g. tcp://127.0.0.1:1234) 41 * $files is an iterable of files or callable generator yielding files. 42 * containing N responses for N expected requests. Server dies after N requests. 43 * $output is a stream on which everything sent by clients is written to 44 */ 45function http_server($files, &$output = null) { 46 47 if (!is_resource($server = http_server_init($output))) { 48 return $server; 49 } 50 51 if (is_callable($files)) { 52 $files = $files($server); 53 } 54 55 foreach($files as $file) { 56 57 $sock = stream_socket_accept($server); 58 if (!$sock) { 59 exit(1); 60 } 61 62 // read headers 63 64 $content_length = 0; 65 66 stream_set_blocking($sock, false); 67 while (!feof($sock)) { 68 69 list($r, $w, $e) = array(array($sock), null, null); 70 if (!stream_select($r, $w, $e, 1)) continue; 71 72 $line = stream_get_line($sock, 8192, "\r\n"); 73 if ($line === '') { 74 fwrite($output, "\r\n"); 75 break; 76 } else if ($line !== false) { 77 fwrite($output, "$line\r\n"); 78 79 if (preg_match('#^Content-Length\s*:\s*([[:digit:]]+)\s*$#i', $line, $matches)) { 80 $content_length = (int) $matches[1]; 81 } 82 } 83 } 84 stream_set_blocking($sock, true); 85 86 // read content 87 88 if ($content_length > 0) { 89 stream_copy_to_stream($sock, $output, $content_length); 90 } 91 92 // send response 93 94 $fd = fopen($file, 'rb'); 95 stream_copy_to_stream($fd, $sock); 96 97 fclose($sock); 98 } 99 100 exit(0); 101} 102 103function http_server_sleep($micro_seconds = 500000) 104{ 105 if (!is_resource($server = http_server_init($output))) { 106 return $server; 107 } 108 109 $sock = stream_socket_accept($server); 110 if (!$sock) { 111 exit(1); 112 } 113 114 usleep($micro_seconds); 115 116 fclose($sock); 117 118 exit(0); 119} 120 121function http_server_kill(int $pid) { 122 posix_kill($pid, SIGTERM); 123 pcntl_waitpid($pid, $status); 124} 125
