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
|
extern crate ascii;
extern crate tiny_http;
use ascii::AsAsciiStr;
/**!
A web server that redirects every request to a PHP script.
Usage: php-cgi <php-script-path>
*/
fn handle(rq: tiny_http::Request, script: &str) {
use std::io::Write;
use std::process::Command;
let php = Command::new("php-cgi")
.arg(script)
//.stdin(Ignored)
//.extra_io(Ignored)
.env("AUTH_TYPE", "")
.env(
"CONTENT_LENGTH",
format!("{}", rq.body_length().unwrap_or(0)),
)
.env("CONTENT_TYPE", "")
.env("GATEWAY_INTERFACE", "CGI/1.1")
.env("PATH_INFO", "")
.env("PATH_TRANSLATED", "")
.env("QUERY_STRING", format!("{}", rq.url()))
.env("REMOTE_ADDR", format!("{}", rq.remote_addr().unwrap()))
.env("REMOTE_HOST", "")
.env("REMOTE_IDENT", "")
.env("REMOTE_USER", "")
.env("REQUEST_METHOD", format!("{}", rq.method()))
.env("SCRIPT_NAME", script)
.env("SERVER_NAME", "tiny-http php-cgi example")
.env("SERVER_PORT", format!("{}", rq.remote_addr().unwrap()))
.env("SERVER_PROTOCOL", "HTTP/1.1")
.env("SERVER_SOFTWARE", "tiny-http php-cgi example")
.output()
.unwrap();
// note: this is not a good implementation
// cgi returns the status code in the headers ; also many headers will be missing
// in the response
match php.status {
status if status.success() => {
let mut writer = rq.into_writer();
let writer: &mut dyn Write = &mut *writer;
(write!(writer, "HTTP/1.1 200 OK\r\n")).unwrap();
(write!(writer, "{}", php.stdout.clone().as_ascii_str().unwrap())).unwrap();
writer.flush().unwrap();
}
_ => {
println!(
"Error in script execution: {}",
php.stderr.clone().as_ascii_str().unwrap()
);
}
}
}
fn main() {
use std::env;
use std::sync::Arc;
use std::thread::spawn;
let php_script = {
let mut args = env::args();
if args.len() < 2 {
println!("Usage: php-cgi <php-script-path>");
return;
}
args.nth(1).unwrap()
};
let server = Arc::new(tiny_http::Server::http("0.0.0.0:9975").unwrap());
println!("Now listening on port 9975");
let num_cpus = 4; // TODO: dynamically generate this value
for _ in 0..num_cpus {
let server = server.clone();
let php_script = php_script.clone();
spawn(move || {
for rq in server.incoming_requests() {
handle(rq, &php_script);
}
});
}
}
|
