diff options
| author | nsfisis <nsfisis@gmail.com> | 2026-06-20 23:37:42 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2026-06-20 23:37:42 +0900 |
| commit | 84655bf3a4a21dbbe7aec8e3aee1e661505bbb6d (patch) | |
| tree | 189f8ce5d7d53246632d5e2419c392d58f06e2b8 /crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs | |
| parent | 10840ec1fd7f1140305449fc94175d60998572c1 (diff) | |
| download | php-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.rs | 102 |
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 + } +} |
