From fda89c96529db0c61f98e29028d68ca15cdbda1e Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Mon, 9 Feb 2026 03:50:35 +0100
Subject: WIP

---
 Process.hs | 52 ----------------------------------------------------
 1 file changed, 52 deletions(-)
 delete mode 100644 Process.hs

(limited to 'Process.hs')

diff --git a/Process.hs b/Process.hs
deleted file mode 100644
index e4f55d1..0000000
--- a/Process.hs
+++ /dev/null
@@ -1,52 +0,0 @@
-module Process (mkProcess) where
-
-import Control.Concurrent.Async (async, cancel)
-import Control.Concurrent.Chan.Unagi (newChan, readChan, writeChan)
-import Control.Exception (IOException)
-import Control.Monad (forever, unless)
-import Data.Bifunctor (bimap)
-import Data.ByteString (ByteString)
-import Data.ByteString.Char8 qualified as BS8
-import System.IO (hClose, hIsEOF)
-import System.Process qualified as P
-
-mkProcess :: FilePath -> [String] -> IO (IO (Either IOException ByteString), IO ())
-mkProcess prog args = do
-  (Just hin, Just hout, Just herr, ph) <-
-    P.createProcess (P.proc prog args)
-      { P.std_in  = P.CreatePipe
-      , P.std_out = P.CreatePipe
-      , P.std_err = P.CreatePipe
-      }
-
-  (putOutput, takeOutput) <- bimap writeChan readChan <$> newChan
-
-  let reader h = forever do
-        eof <- hIsEOF h
-        unless eof do
-          BS8.hGetLine h >>= putOutput -- TODO mark as stdout/stderr
-
-  outReader <- async (reader hout)
-  errReader <- async (reader herr)
-
-  let
-    -- normal termination path: wait for process, then kill readers
-    waitProcessAndReaders = do
-      _ <- P.waitForProcess ph
-      shutdown
-      --cancel outReader
-      --cancel errReader
-
-    -- explicit shutdown: kill everything
-    shutdown = do
-      P.terminateProcess ph
-      cancel outReader
-      cancel errReader
-      hClose hin
-      hClose hout
-      hClose herr
-
-  -- optionally run waitProcessAndReaders in background:
-  _ <- async waitProcessAndReaders
-
-  pure (Right <$> takeOutput, shutdown)
-- 
cgit v1.2.3