aboutsummaryrefslogtreecommitdiffhomepage
path: root/crates/shirabe-external-packages/src/symfony/process/pipes
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
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')
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs75
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/mod.rs9
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/pipes_interface.rs31
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs102
-rw-r--r--crates/shirabe-external-packages/src/symfony/process/pipes/windows_pipes.rs66
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
+ }
+}