aboutsummaryrefslogtreecommitdiffhomepage
path: root/crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2026-06-20 23:37:42 +0900
committernsfisis <nsfisis@gmail.com>2026-06-20 23:37:42 +0900
commit84655bf3a4a21dbbe7aec8e3aee1e661505bbb6d (patch)
tree189f8ce5d7d53246632d5e2419c392d58f06e2b8 /crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs
parent10840ec1fd7f1140305449fc94175d60998572c1 (diff)
downloadphp-shirabe-84655bf3a4a21dbbe7aec8e3aee1e661505bbb6d.tar.gz
php-shirabe-84655bf3a4a21dbbe7aec8e3aee1e661505bbb6d.tar.zst
php-shirabe-84655bf3a4a21dbbe7aec8e3aee1e661505bbb6d.zip
feat(symfony-process): port full Process class from PHP
Faithfully port every method, field and constant of Symfony's Process.php into process.rs, replacing the reduced stub. Add the supporting pipes module (PipesInterface/AbstractPipes/UnixPipes/ WindowsPipes), ProcessUtils and the missing process exceptions (LogicException/InvalidArgumentException) with constructors. Methods now return anyhow::Result where PHP throws, take the env argument and a bool-returning callback, and borrow &mut for status-updating accessors; all callers are updated accordingly. Extend the php-shim with proc_open/proc_close (PHP-compatible signatures), proc_get_status, proc_terminate, posix_kill, uniqid, ftruncate, ftell_stream, fseek3, stream_get_contents3 and env helpers. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
Diffstat (limited to 'crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs')
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs102
1 files changed, 102 insertions, 0 deletions
diff --git a/crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs b/crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs
new file mode 100644
index 0000000..387bcdf
--- /dev/null
+++ b/crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs
@@ -0,0 +1,102 @@
+//! ref: composer/vendor/symfony/process/Pipes/UnixPipes.php
+
+use indexmap::IndexMap;
+use shirabe_php_shim::PhpMixed;
+
+use crate::symfony::process::pipes::abstract_pipes::AbstractPipes;
+use crate::symfony::process::pipes::pipes_interface::PipesInterface;
+use crate::symfony::process::process::Process;
+
+/// UnixPipes implementation uses unix pipes as handles.
+#[derive(Debug)]
+pub struct UnixPipes {
+ inner: AbstractPipes,
+ tty_mode: Option<bool>,
+ pty_mode: bool,
+ have_read_support: bool,
+}
+
+impl UnixPipes {
+ pub fn new(
+ tty_mode: Option<bool>,
+ pty_mode: bool,
+ input: PhpMixed,
+ have_read_support: bool,
+ ) -> Self {
+ Self {
+ inner: AbstractPipes::new(input),
+ tty_mode,
+ pty_mode,
+ have_read_support,
+ }
+ }
+}
+
+fn descriptor(items: &[&str]) -> PhpMixed {
+ PhpMixed::List(
+ items
+ .iter()
+ .map(|s| PhpMixed::String(s.to_string()))
+ .collect(),
+ )
+}
+
+impl PipesInterface for UnixPipes {
+ fn get_descriptors(&mut self) -> Vec<PhpMixed> {
+ if !self.have_read_support {
+ let nullstream = shirabe_php_shim::fopen("/dev/null", "c");
+
+ return vec![descriptor(&["pipe", "r"]), nullstream.clone(), nullstream];
+ }
+
+ if self.tty_mode == Some(true) {
+ return vec![
+ descriptor(&["file", "/dev/tty", "r"]),
+ descriptor(&["file", "/dev/tty", "w"]),
+ descriptor(&["file", "/dev/tty", "w"]),
+ ];
+ }
+
+ if self.pty_mode && Process::is_pty_supported() {
+ return vec![
+ descriptor(&["pty"]),
+ descriptor(&["pty"]),
+ descriptor(&["pty"]),
+ ];
+ }
+
+ vec![
+ descriptor(&["pipe", "r"]),
+ descriptor(&["pipe", "w"]),
+ descriptor(&["pipe", "w"]),
+ ]
+ }
+
+ fn get_files(&self) -> IndexMap<i64, String> {
+ IndexMap::new()
+ }
+
+ fn read_and_write(&mut self, _blocking: bool, _close: bool) -> IndexMap<i64, String> {
+ todo!()
+ }
+
+ fn have_read_support(&self) -> bool {
+ self.have_read_support
+ }
+
+ fn are_open(&self) -> bool {
+ shirabe_php_shim::php_truthy(&self.inner.pipes)
+ }
+
+ fn close(&mut self) {
+ self.inner.close();
+ }
+
+ fn pipes(&self) -> &PhpMixed {
+ &self.inner.pipes
+ }
+
+ fn pipes_mut(&mut self) -> &mut PhpMixed {
+ &mut self.inner.pipes
+ }
+}