removed connection options that weren´t working and added support for

forking a script

1 files changed, 25 insertions, 23 deletions

diff --git a/src/Trivmix.hs b/src/Trivmix.hs
index a139a15..2d6a50a 100644
--- a/src/Trivmix.hs
+++ b/src/Trivmix.hs
@@ -13,6 +13,7 @@ import System.FilePath
 import System.Posix.Files
 import System.Posix.IO
 import System.Environment
+import System.Process
 
 import Control.Concurrent
 import Control.Concurrent.MVar
@@ -29,8 +30,7 @@ data Options = Options
                { input :: String
                , output :: String
                , client :: String
-               , connFrom :: Maybe String
-               , connTo :: Maybe String
+               , run :: Maybe String
                , initialLevel :: Float
                , stateDir :: FilePath
                }
@@ -46,12 +46,10 @@ optionParser = Options <$>
                <*> strOption ( long "client"
                                <> metavar "STRING"
                              )
-               <*> optional (strOption ( long "input-from"
-                                         <> metavar "STRING"
-                                       ))
-               <*> optional (strOption ( long "output-to"
-                                         <> metavar "STRING"
-                                       ))
+               <*> optional ( strOption ( long "run"
+                                          <> metavar "FILE"
+                                        )
+                            )
                <*> (fromMaybe 0 <$> optional (option auto ( long "level"
                                                             <> metavar "FLOAT"
                                                           )
@@ -71,25 +69,29 @@ main = execParser opts >>= trivmix
            )
 
 trivmix :: Options -> IO ()
-trivmix Options{..} = do
-  createDirectoryIfMissing True stateDir
+trivmix Options{..} = onDirectory stateDir $ do
   level <- newMVar initialLevel
   let levelFile = stateDir </> "level"
   onLevelFile levelFile initialLevel $ withINotify $ \n -> do
     addWatch n [Modify] levelFile (const $ handleLevel level levelFile)
     Jack.handleExceptions $
-      Jack.withClientDefault client $ \client ->
-      Jack.withPort client input $ \input' ->
-      Jack.withPort client output $ \output' -> do
-        case connFrom of
-          Nothing -> return ()
-          Just f -> Jack.connect client input f
-        case connTo of
-          Nothing -> return ()
-          Just t -> Jack.connect client t output
-        Audio.withProcessMono client input' (mix level) output' $
-          Jack.withActivation client $ Trans.lift $ do
-            Jack.waitForBreak
+      Jack.withClientDefault client $ \client' ->
+      Jack.withPort client' input $ \input' ->
+      Jack.withPort client' output $ \output' -> do
+        Trans.lift $ do
+          case run of
+            Nothing -> return ()
+            Just run' -> do
+              (_, _, _, ph) <- createProcess $ (proc run' [client ++ ":" ++ input, client ++ ":" ++ output]) { delegate_ctlc = True }
+              return ()
+        Audio.withProcessMono client' input' (mix level) output' $
+          Jack.withActivation client' $ Trans.lift Jack.waitForBreak
+
+onDirectory :: FilePath -> IO () -> IO ()
+onDirectory stateDir io = do
+  exists <- doesDirectoryExist stateDir
+  createDirectoryIfMissing True stateDir
+  finally io $ if exists then removeDirectory stateDir else return ()
   
 mix :: MVar Float -> CFloat -> IO CFloat
 mix level input = do
@@ -101,7 +103,7 @@ onLevelFile file initial action = do
   exists <- doesFileExist file
   let acquire = case exists of
         True -> return ()
-        False -> createFile file mode >>= closeFd
+        False -> createFile file mode >>= closeFd >> writeFile file (show initial)
       mode = foldl unionFileModes nullFileMode [ ownerReadMode
                                                , ownerWriteMode
                                                , groupReadMode