michael/dip
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

delete commented sections

Browse source
This commit is contained in:
Michael Zhang 2018-08-22 21:32:06 -05:00
parent 34eae4569f
commit 7c1360d9b9
No known key found for this signature in database
GPG key ID: A1B65B603268116B
1 changed files with 0 additions and 169 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

169
src/handler.rs
View file

@ -136,178 +136,9 @@ impl Handler {
})
}).map_err(|err| err_msg(format!("error: {}", err)));
// let _result: Either<_, FutureResult<(), Error>> = {
// match child.stdin() {
// Some(ref mut stdin) => Either::A(write_all(stdin, input.as_bytes())),
// None => Either::B(future::err(err_msg("rip"))),
// }
// };
Box::new(result)
// let input_s = format!("{}", input);
// let result: Box<Future<Item = (), Error = Error> + Send> = {
// let rf = child.clone().lock().unwrap();
// match rf.stdin() {
// Some(ref mut stdin) => Box::new(
// write_all(stdin, input_s.as_bytes())
// .map(|_| ())
// .map_err(|err| err_msg(format!("error: {}", err))),
// ),
// None => Box::new(future::err(err_msg("Failed to acquire child stdin"))),
// }
// };
// {
// let rf = child.clone().lock().unwrap();
// let result = rf
// .wait_with_output()
// .and_then(|output| {
// if output.status.success() {
// future::ok(output)
// } else {
// // TODO: change this
// future::ok(output)
// }
// }).map(|output| {
// let stdout = String::from_utf8(output.stdout)
// .unwrap_or_else(|_| String::new());
// let stderr = String::from_utf8(output.stderr)
// .unwrap_or_else(|_| String::new());
// println!("stdout: {}, stderr: {}", stdout, stderr);
// json!({
// "stdout": stdout,
// "stderr": stderr,
// })
// }).map_err(|err| err_msg(format!("could not get output: {}", err)));
// });
// .and_then(move |output| {
// if output.status.success() {
// future::ok(output)
// } else {
// // TODO: get rid of unwraps
// future::err(err_msg(format!(
// "'{:?}' returned with a non-zero status code: {}\nstdout:\n{}\nstderr:\n{}",
// path,
// output.status,
// String::from_utf8(output.stdout).unwrap_or_else(|_| String::new()),
// String::from_utf8(output.stderr).unwrap_or_else(|_| String::new())
// )))
// }
// }).map(|output| {
// let stdout =
// String::from_utf8(output.stdout).unwrap_or_else(|_| String::new());
// let stderr =
// String::from_utf8(output.stderr).unwrap_or_else(|_| String::new());
// // future::ok(json!({
// // "stdout": stdout,
// // "stderr": stderr,
// // }))
// json!("")
// }).map_err(|err| err_msg(format!("could not get output: {}", err)))
// let result = child
// .spawn_async()
// .expect("could not spawn child")
// .map_err(|err| err_msg(format!("failed to get output: {}", err)))
// .and_then(|child| {
// match child.stdin() {
// Some(ref mut stdin) => {
// // future::result(write!(stdin, "{}", input))
// future::ok(0)
// }
// None => future::err(err_msg("done fucked")),
// }
// });
// let output = child.wait_with_output().unwrap();
// if !output.status.success() {
// // TODO: get rid of unwraps
// return future::err(err_msg(format!(
// "'{:?}' returned with a non-zero status code: {}\nstdout:\n{}\nstderr:\n{}",
// path,
// output.status,
// String::from_utf8(output.stdout).unwrap_or_else(|_| String::new()),
// String::from_utf8(output.stderr).unwrap_or_else(|_| String::new())
// )));
// }
// output
}
};
output.map(|x| (temp_path, x))
// let result = match action {
// Action::Command(ref cmd) => {
// // TODO: allow some kind of simple variable replacement
// let child = Command::new("/bin/bash")
// .current_dir(&temp_path)
// .env("DIP_ROOT", "lol")
// .env("DIP_WORKDIR", &temp_path)
// .arg("-c")
// .arg(cmd)
// .stdin(Stdio::piped())
// .stdout(Stdio::piped())
// .stderr(Stdio::piped());
// child.output_async().map_err(|err| err_msg(format!("failed to get output: {}", err))).and_then(|output| {
// if output.status.success() {
// future::ok(output)
// } else {
// // TODO: get rid of unwraps
// future::err(err_msg(format!(
// "Command '{}' returned with a non-zero status code: {}\nstdout:\n{}\nstderr:\n{}",
// cmd,
// output.status,
// String::from_utf8(output.stdout).unwrap_or_else(|_| String::new()),
// String::from_utf8(output.stderr).unwrap_or_else(|_| String::new())
// )))
// }
// })
// }
// Action::Exec(ref path) => {
// let mut child = Command::new(&path)
// .current_dir(&temp_path)
// .env("DIP_ROOT", "")
// .env("DIP_WORKDIR", &temp_path)
// .arg("--config")
// .arg(config)
// .stdin(Stdio::piped())
// .stdout(Stdio::piped())
// .stderr(Stdio::piped());
// child
// .spawn_async()
// .map_err(|err| err_msg(format!("failed to get output: {}", err))).and_then(|child| {
// future::ok()
// })
// // {
// // match child.stdin {
// // Some(ref mut stdin) => {
// // write!(stdin, "{}", input);
// // }
// // None => return future::err(err_msg("done fucked")),
// // };
// // }
// // let output = child.wait_with_output().unwrap();
// // if !output.status.success() {
// // // TODO: get rid of unwraps
// // return future::err(err_msg(format!(
// // "'{:?}' returned with a non-zero status code: {}\nstdout:\n{}\nstderr:\n{}",
// // path,
// // output.status,
// // String::from_utf8(output.stdout).unwrap_or_else(|_| String::new()),
// // String::from_utf8(output.stderr).unwrap_or_else(|_| String::new())
// // )));
// // }
// // output
// }
// };
// let stdout = String::from_utf8(output.stdout).unwrap_or_else(|_| String::new());
// let stderr = String::from_utf8(output.stderr).unwrap_or_else(|_| String::new());
// future::ok((
// temp_path,
// json!({
// "stdout": stdout,
// "stderr": stderr,
// }),
// ))
}
}