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 | |
| 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')
5 files changed, 283 insertions, 0 deletions
diff --git a/crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs b/crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs new file mode 100644 index 0000000..47db6b9 --- /dev/null +++ b/crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs @@ -0,0 +1,75 @@ +//! ref: composer/vendor/symfony/process/Pipes/AbstractPipes.php + +use indexmap::IndexMap; +use shirabe_php_shim::{self as php, PhpMixed}; + +#[derive(Debug)] +pub struct AbstractPipes { + pub pipes: PhpMixed, + + input_buffer: String, + input: PhpMixed, + blocked: bool, + last_error: Option<String>, +} + +impl AbstractPipes { + pub fn new(input: PhpMixed) -> Self { + let mut input_buffer = String::new(); + let stored_input; + if php::is_resource(&input) { + stored_input = input; + } else if let PhpMixed::String(s) = &input { + input_buffer = s.clone(); + stored_input = PhpMixed::Null; + } else { + input_buffer = input.as_string().map(|s| s.to_string()).unwrap_or_default(); + stored_input = PhpMixed::Null; + } + + Self { + pipes: PhpMixed::List(Vec::new()), + input_buffer, + input: stored_input, + blocked: true, + last_error: None, + } + } + + pub fn close(&mut self) { + if let PhpMixed::List(pipes) = &self.pipes { + for pipe in pipes { + if php::is_resource(pipe) { + php::fclose(pipe.clone()); + } + } + } + self.pipes = PhpMixed::List(Vec::new()); + } + + /// Returns true if a system call has been interrupted. + pub(crate) fn has_system_call_been_interrupted(&mut self) -> bool { + let last_error = self.last_error.take(); + + // stream_select returns false when the `select` system call is interrupted by an incoming signal + last_error + .map(|e| e.to_lowercase().contains("interrupted system call")) + .unwrap_or(false) + } + + /// Unblocks streams. + pub(crate) fn unblock(&mut self) { + let _ = &self.input_buffer; + let _ = &self.blocked; + todo!() + } + + /// Writes input to stdin. + pub(crate) fn write(&mut self) -> Option<IndexMap<i64, PhpMixed>> { + todo!() + } + + pub fn handle_error(&mut self, _type: i64, msg: String) { + self.last_error = Some(msg); + } +} diff --git a/crates/shirabe-external-packages/src/symfony/process/pipes/mod.rs b/crates/shirabe-external-packages/src/symfony/process/pipes/mod.rs new file mode 100644 index 0000000..6a77f5f --- /dev/null +++ b/crates/shirabe-external-packages/src/symfony/process/pipes/mod.rs @@ -0,0 +1,9 @@ +pub mod abstract_pipes; +pub mod pipes_interface; +pub mod unix_pipes; +pub mod windows_pipes; + +pub use abstract_pipes::*; +pub use pipes_interface::*; +pub use unix_pipes::*; +pub use windows_pipes::*; diff --git a/crates/shirabe-external-packages/src/symfony/process/pipes/pipes_interface.rs b/crates/shirabe-external-packages/src/symfony/process/pipes/pipes_interface.rs new file mode 100644 index 0000000..e10b3b3 --- /dev/null +++ b/crates/shirabe-external-packages/src/symfony/process/pipes/pipes_interface.rs @@ -0,0 +1,31 @@ +//! ref: composer/vendor/symfony/process/Pipes/PipesInterface.php + +use indexmap::IndexMap; +use shirabe_php_shim::PhpMixed; + +pub const CHUNK_SIZE: i64 = 16384; + +/// PipesInterface manages descriptors and pipes for the use of proc_open. +pub trait PipesInterface: std::fmt::Debug { + /// Returns an array of descriptors for the use of proc_open. + fn get_descriptors(&mut self) -> Vec<PhpMixed>; + + /// Returns an array of filenames indexed by their related stream in case these pipes use temporary files. + fn get_files(&self) -> IndexMap<i64, String>; + + /// Reads data in file handles and pipes. + fn read_and_write(&mut self, blocking: bool, close: bool) -> IndexMap<i64, String>; + + /// Returns if the current state has open file handles or pipes. + fn are_open(&self) -> bool; + + /// Returns if pipes are able to read output. + fn have_read_support(&self) -> bool; + + /// Closes file handles and pipes. + fn close(&mut self); + + /// Accessor for the `pipes` property populated by proc_open. + fn pipes(&self) -> &PhpMixed; + fn pipes_mut(&mut self) -> &mut PhpMixed; +} 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 + } +} diff --git a/crates/shirabe-external-packages/src/symfony/process/pipes/windows_pipes.rs b/crates/shirabe-external-packages/src/symfony/process/pipes/windows_pipes.rs new file mode 100644 index 0000000..7602e7d --- /dev/null +++ b/crates/shirabe-external-packages/src/symfony/process/pipes/windows_pipes.rs @@ -0,0 +1,66 @@ +//! ref: composer/vendor/symfony/process/Pipes/WindowsPipes.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; + +/// WindowsPipes implementation uses temporary files as handles. +#[derive(Debug)] +pub struct WindowsPipes { + inner: AbstractPipes, + files: IndexMap<i64, String>, + file_handles: IndexMap<i64, PhpMixed>, + lock_handles: IndexMap<i64, PhpMixed>, + read_bytes: IndexMap<i64, i64>, + have_read_support: bool, +} + +impl WindowsPipes { + pub fn new(_input: PhpMixed, _have_read_support: bool) -> Self { + // Windows-only path: never constructed on POSIX (DIRECTORY_SEPARATOR is "/"). + todo!() + } +} + +impl PipesInterface for WindowsPipes { + fn get_descriptors(&mut self) -> Vec<PhpMixed> { + let _ = ( + &self.files, + &self.file_handles, + &self.lock_handles, + &self.read_bytes, + ); + todo!() + } + + fn get_files(&self) -> IndexMap<i64, String> { + self.files.clone() + } + + 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) && !self.file_handles.is_empty() + } + + fn close(&mut self) { + self.inner.close(); + todo!() + } + + fn pipes(&self) -> &PhpMixed { + &self.inner.pipes + } + + fn pipes_mut(&mut self) -> &mut PhpMixed { + &mut self.inner.pipes + } +} |
