SCP-5012 Migrated marlowe-pipe from marlowe-lambda repo.

marlowe-apps/marlowe-apps.cabal

@@ -64,6 +64,29 @@ library
   default-language  : Haskell2010
 
 
+executable marlowe-pipe
+  main-is           : Main.hs
+  hs-source-dirs    : pipe
+  build-depends     : base >= 4.9 && < 5
+                    , aeson
+                    , bytestring
+                    , eventuo11y
+                    , eventuo11y-dsl
+                    , eventuo11y-json
+                    , marlowe-apps
+                    , mtl
+                    , optparse-applicative
+                    , text
+  ghc-options       : -Wall
+                      -Wnoncanonical-monad-instances
+                      -Wincomplete-uni-patterns
+                      -Wincomplete-record-updates
+                      -Wredundant-constraints
+                      -Widentities
+                      -Wunused-packages
+  default-language  : Haskell2010
+
+
 executable marlowe-scaling
   main-is           : Main.hs
   hs-source-dirs    : scaling

marlowe-apps/pipe/Main.hs

@@ -0,0 +1,56 @@
+
+
+{-# LANGUAGE LambdaCase #-}
+{-# LANGUAGE OverloadedStrings #-}
+
+
+module Main
+  ( main
+  ) where
+
+
+import Control.Monad.Except (liftIO, runExceptT)
+import Data.Aeson (eitherDecode, encode)
+import Data.Text (Text)
+import Language.Marlowe.Runtime.App.Parser (getConfigParser)
+import Language.Marlowe.Runtime.App.Transact (handleWithEvents)
+import Observe.Event (addField, hoistEvent, withEvent)
+import Observe.Event.Dynamic (DynamicEventSelector(..))
+import Observe.Event.Render.JSON (DefaultRenderSelectorJSON(defaultRenderSelectorJSON))
+import Observe.Event.Render.JSON.Handle (simpleJsonStderrBackend)
+import Observe.Event.Syntax ((≔))
+
+import qualified Data.ByteString.Lazy.Char8 as LBS8 (getContents, lines, putStrLn, unpack)
+import qualified Options.Applicative as O
+
+
+main :: IO ()
+main =
+  do
+    configParser <- getConfigParser
+    config <-
+      O.execParser
+        $ O.info
+          (O.helper {- <*> O.versionOption -} <*> configParser)
+          (
+            O.fullDesc
+              <> O.progDesc "This command-line tool reads lines of JSON from standard input, interpets them as Marlowe App requests, executes them, and prints the response JSON on standard output."
+              <> O.header "marlowe-pipe: run marlowe application requests"
+          )
+    eventBackend <- simpleJsonStderrBackend defaultRenderSelectorJSON
+    requests <- LBS8.lines <$> LBS8.getContents
+    sequence_
+      [
+        withEvent eventBackend (DynamicEventSelector "MarloweApp")
+          $ \event ->
+            do
+              addField event $ ("line" :: Text) ≔ LBS8.unpack line
+              case eitherDecode line of
+                Right request -> runExceptT (handleWithEvents (hoistEvent liftIO event) "Handle" config request pure)
+                                   >>= \case
+                                    Right response -> LBS8.putStrLn $ encode response
+                                    Left message -> LBS8.putStrLn $ encode message
+                Left message -> LBS8.putStrLn $ encode message
+      |
+        line <- requests
+      ]

marlowe-apps/src/Language/Marlowe/Runtime/App/Types.hs

@@ -64,7 +64,6 @@ import Language.Marlowe.Runtime.History.Api
   (ContractStep(..), CreateStep(..), RedeemStep(RedeemStep, datum, redeemingTx, utxo))
 import Language.Marlowe.Runtime.Transaction.Api (MarloweTxCommand)
 import Network.Protocol.Job.Client (JobClient)
-import Network.Protocol.Query.Client (QueryClient)
 import Network.Socket (HostName, PortNumber)
 
 import qualified Cardano.Api as C