1 files changed, 75 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);
+    }
+}