From 446f719f6c34453f027d5ccdbf81b16e63f4c982 Mon Sep 17 00:00:00 2001
From: nsfisis <nsfisis@gmail.com>
Date: Sun, 9 Aug 2026 11:14:42 +0900
Subject: 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>
---
 .../src/symfony/process/pipes/unix_pipes.rs        | 136 ---------------------
 1 file changed, 136 deletions(-)
 delete mode 100644 crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs

(limited to 'crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs')

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
deleted file mode 100644
index a7026318..00000000
--- a/crates/shirabe-external-packages/src/symfony/process/pipes/unix_pipes.rs
+++ /dev/null
@@ -1,136 +0,0 @@
-//! ref: composer/vendor/symfony/process/Pipes/UnixPipes.php
-
-use crate::symfony::process::pipes::abstract_pipes::AbstractPipes;
-use crate::symfony::process::pipes::pipes_interface::{CHUNK_SIZE, PipesInterface};
-use crate::symfony::process::process::Process;
-use indexmap::IndexMap;
-use shirabe_php_shim::{Descriptor, PhpMixed, PhpResource};
-
-/// UnixPipes implementation uses unix pipes as handles.
-#[derive(Debug)]
-pub struct UnixPipes {
-    inner: AbstractPipes,
-    tty_mode: Option<bool>,
-}
-
-impl UnixPipes {
-    pub fn new(tty_mode: Option<bool>, input: PhpMixed) -> Self {
-        Self {
-            inner: AbstractPipes::new(input),
-            tty_mode,
-        }
-    }
-}
-
-fn descriptor(items: &[&str]) -> Descriptor {
-    match items {
-        ["pipe", mode] => Descriptor::Pipe(mode.to_string()),
-        ["file", path, mode] => Descriptor::File(path.to_string(), mode.to_string()),
-        _ => panic!("unsupported descriptor spec: {:?}", items),
-    }
-}
-
-impl PipesInterface for UnixPipes {
-    fn get_descriptors(&mut self) -> Vec<Descriptor> {
-        if self.tty_mode == Some(true) {
-            return vec![
-                descriptor(&["file", "/dev/tty", "r"]),
-                descriptor(&["file", "/dev/tty", "w"]),
-                descriptor(&["file", "/dev/tty", "w"]),
-            ];
-        }
-
-        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> {
-        self.inner.unblock();
-        let w = self.inner.write();
-
-        let mut read: IndexMap<i64, String> = IndexMap::new();
-        // $r = $this->pipes; unset($r[0]);
-        let r: Vec<(i64, PhpResource)> = self
-            .inner
-            .pipes
-            .iter()
-            .filter(|(fd, _)| **fd != 0)
-            .map(|(fd, pipe)| (*fd, pipe.clone()))
-            .collect();
-
-        // TODO(plugin): set_error_handler/restore_error_handler around stream_select is not modeled.
-        let mut r_sel: Vec<PhpResource> = r.iter().map(|(_, p)| p.clone()).collect();
-        let mut w_sel: Vec<PhpResource> = w.clone().unwrap_or_default();
-        let mut e_sel: Vec<PhpResource> = Vec::new();
-
-        // let's have a look if something changed in streams
-        if (!r_sel.is_empty() || w.is_some())
-            && shirabe_php_shim::stream_select(
-                &mut r_sel,
-                &mut w_sel,
-                &mut e_sel,
-                0,
-                Some(if blocking {
-                    (Process::TIMEOUT_PRECISION * 1e6) as i64
-                } else {
-                    0
-                }),
-            )
-            .is_none()
-        {
-            // if a system call has been interrupted, forget about it, let's try again
-            // otherwise, an error occurred, let's reset pipes
-            if !self.inner.has_system_call_been_interrupted() {
-                self.inner.pipes = IndexMap::new();
-            }
-
-            return read;
-        }
-
-        for (fd, pipe) in &r {
-            let mut data = String::new();
-            loop {
-                let chunk = shirabe_php_shim::fread(pipe, CHUNK_SIZE).unwrap_or_default();
-                let len = chunk.len() as i64;
-                data.push_str(&chunk);
-                if !(len > 0 && (close || len >= CHUNK_SIZE)) {
-                    break;
-                }
-            }
-
-            if !data.is_empty() {
-                read.insert(*fd, data);
-            }
-
-            if close && shirabe_php_shim::feof(pipe) {
-                shirabe_php_shim::fclose(pipe);
-                self.inner.pipes.shift_remove(fd);
-            }
-        }
-
-        read
-    }
-
-    fn are_open(&self) -> bool {
-        !self.inner.pipes.is_empty()
-    }
-
-    fn close(&mut self) {
-        self.inner.close();
-    }
-
-    fn pipes(&self) -> &IndexMap<i64, PhpResource> {
-        &self.inner.pipes
-    }
-
-    fn pipes_mut(&mut self) -> &mut IndexMap<i64, PhpResource> {
-        &mut self.inner.pipes
-    }
-}
-- 
cgit v1.3.1-4-g156e