diff options
| author | nsfisis <nsfisis@gmail.com> | 2026-08-09 11:14:42 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2026-08-09 11:14:42 +0900 |
| commit | 446f719f6c34453f027d5ccdbf81b16e63f4c982 (patch) | |
| tree | 9c0443adbb99da5891a81d0131fc414d9a04c8ef /crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs | |
| parent | 880ba0fd1d05faf98588cc326b3d9fbe625ebf2b (diff) | |
| download | php-shirabe-446f719f6c34453f027d5ccdbf81b16e63f4c982.tar.gz php-shirabe-446f719f6c34453f027d5ccdbf81b16e63f4c982.tar.zst php-shirabe-446f719f6c34453f027d5ccdbf81b16e63f4c982.zip | |
refactor(symfony-process): extract symfony/process into the shirabe-symfony-process crate
Move `Symfony\Component\Process` out of shirabe-external-packages and
into its own crate, so the path is `shirabe_symfony_process::Process`
instead of `shirabe_external_packages::symfony::process::Process`.
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Diffstat (limited to 'crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs')
| -rw-r--r-- | crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs | 104 |
1 files changed, 0 insertions, 104 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 deleted file mode 100644 index 8741926c..00000000 --- a/crates/shirabe-external-packages/src/symfony/process/pipes/abstract_pipes.rs +++ /dev/null @@ -1,104 +0,0 @@ -//! ref: composer/vendor/symfony/process/Pipes/AbstractPipes.php - -use indexmap::IndexMap; -use shirabe_php_shim::{PhpMixed, PhpResource}; - -#[derive(Debug)] -pub struct AbstractPipes { - pub pipes: IndexMap<i64, PhpResource>, - - input_buffer: String, - input: PhpMixed, - blocked: bool, - last_error: Option<String>, -} - -impl AbstractPipes { - pub fn new(input: PhpMixed) -> Self { - let input_buffer; - let stored_input; - // TODO(plugin): `$input instanceof \Iterator` is not modeled. The PHP `is_resource($input)` - // branch never applies: a PhpMixed is never a resource, so input is never stored as-is here. - 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: IndexMap::new(), - input_buffer, - input: stored_input, - blocked: true, - last_error: None, - } - } - - pub fn close(&mut self) { - for (_, pipe) in &self.pipes { - shirabe_php_shim::fclose(pipe); - } - self.pipes = IndexMap::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) { - if !self.blocked { - return; - } - - for (_, pipe) in &self.pipes { - shirabe_php_shim::stream_set_blocking(pipe, false); - } - // The `is_resource($this->input)` branch does not apply: `input` is never a resource in this - // port (is_resource on a PhpMixed is always false). - - self.blocked = false; - } - - /// Writes input to stdin. - pub(crate) fn write(&mut self) -> Option<Vec<PhpResource>> { - let stdin = self.pipes.get(&0)?.clone(); - - // TODO(plugin): the `$input instanceof \Iterator` branch is not modeled. `input` is never a - // resource here, so the fread($input)/stream_set_blocking($input) paths do not apply and - // only the input buffer is written to stdin. - - let mut r: Vec<PhpResource> = Vec::new(); - let mut e: Vec<PhpResource> = Vec::new(); - let mut w: Vec<PhpResource> = vec![stdin.clone()]; - - // let's have a look if something changed in streams - shirabe_php_shim::stream_select(&mut r, &mut w, &mut e, 0, Some(0))?; - - if !self.input_buffer.is_empty() { - let written = - shirabe_php_shim::fwrite(&stdin, &self.input_buffer, None).unwrap_or(0) as usize; - self.input_buffer = self.input_buffer.get(written..).unwrap_or("").to_string(); - if !self.input_buffer.is_empty() { - return Some(vec![stdin]); - } - } - - // no input to read on resource, buffer is empty - if self.input_buffer.is_empty() && !shirabe_php_shim::php_truthy(&self.input) { - self.input = PhpMixed::Null; - shirabe_php_shim::fclose(&stdin); - self.pipes.shift_remove(&0); - } - - None - } -} |
