Add healthcheck to marlowe-sync

marlowe-runtime/marlowe-sync/Main.hs

@@ -49,7 +49,7 @@ main :: IO ()
 main = run =<< getOptions
 
 run :: Options -> IO ()
-run Options{..} = bracket (Pool.acquire 100 (Just $ 5000000) (fromString databaseUri)) Pool.release $
+run Options{..} = bracket (Pool.acquire 100 (Just 5000000) (fromString databaseUri)) Pool.release $
   runComponent_ proc pool -> do
     eventBackend <- logger -< LoggerDependencies
       { configFilePath = logConfigFile
@@ -90,6 +90,7 @@ run Options{..} = bracket (Pool.acquire 100 (Just $ 5000000) (fromString databas
       , querySource = SomeConnectionSource
           $ logConnectionSource (narrowEventBackend (injectSelector MarloweQueryServer) eventBackend)
           $ handshakeConnectionSource querySource
+      , httpPort = fromIntegral httpPort
       }
   where
     throwUsageError (ConnectionUsageError err)                       = error $ show err
@@ -104,6 +105,7 @@ data Options = Options
   , queryPort :: PortNumber
   , host :: HostName
   , logConfigFile :: Maybe FilePath
+  , httpPort :: PortNumber
   }
 
 getOptions :: IO Options
@@ -116,6 +118,7 @@ getOptions = execParser $ info (helper <*> parser) infoMod
       <*> queryPort
       <*> hostParser
       <*> logConfigFileParser
+      <*> httpPortParser
 
     databaseUriParser = strOption $ mconcat
       [ long "database-uri"
@@ -163,6 +166,14 @@ getOptions = execParser $ info (helper <*> parser) infoMod
       , help "The logging configuration JSON file."
       ]
 
+    httpPortParser = option auto $ mconcat
+      [ long "http-port"
+      , metavar "PORT_NUMBER"
+      , help "Port number to serve the http healthcheck API on"
+      , value 8080
+      , showDefault
+      ]
+
     infoMod = mconcat
       [ fullDesc
       , progDesc "Contract synchronization and query service for Marlowe Runtime"

marlowe-runtime/sync/Language/Marlowe/Runtime/Sync.hs

@@ -4,6 +4,7 @@ module Language.Marlowe.Runtime.Sync
   where
 
 import Control.Concurrent.Component
+import Control.Concurrent.Component.Probes
 import Language.Marlowe.Protocol.HeaderSync.Server (MarloweHeaderSyncServer)
 import Language.Marlowe.Protocol.Query.Server (MarloweQueryServer)
 import Language.Marlowe.Protocol.Sync.Server (MarloweSyncServer)
@@ -18,10 +19,19 @@ data SyncDependencies = SyncDependencies
   , syncSource :: SomeConnectionSource MarloweSyncServer IO
   , headerSyncSource :: SomeConnectionSource MarloweHeaderSyncServer IO
   , querySource :: SomeConnectionSource MarloweQueryServer IO
+  , httpPort :: Int
   }
 
 sync :: Component IO SyncDependencies ()
 sync = proc SyncDependencies{..} -> do
   marloweSyncServer -< MarloweSyncServerDependencies{..}
   marloweHeaderSyncServer -< MarloweHeaderSyncServerDependencies{..}
   queryServer -< QueryServerDependencies{..}
+  probeServer -< ProbeServerDependencies
+    { probes = Probes
+        { startup = pure True
+        , liveness = pure True
+        , readiness = pure True
+        }
+    , port = httpPort
+    }