From dc6bf1472c930ff1448c419d3205148bce1b787e Mon Sep 17 00:00:00 2001
From: Paul Oliver <contact@pauloliver.dev>
Date: Thu, 16 Jan 2025 18:26:16 -0800
Subject: Adds error and dummy-fail service

---
 hsm-status/Main.hs | 86 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 hsm-status/Main.hs

(limited to 'hsm-status/Main.hs')

diff --git a/hsm-status/Main.hs b/hsm-status/Main.hs
new file mode 100644
index 0000000..6220474
--- /dev/null
+++ b/hsm-status/Main.hs
@@ -0,0 +1,86 @@
+{-# LANGUAGE OverloadedRecordDot #-}
+{-# LANGUAGE OverloadedStrings #-}
+{-# LANGUAGE TemplateHaskell #-}
+
+import Data.Function ((&))
+import Data.Set (Set, singleton)
+import Data.Text (Text, pack)
+import Effectful (Eff, (:>), runEff)
+import Effectful.Log (Log, LogLevel(LogAttention), runLog)
+import Effectful.Reader.Static (Reader, ask, runReader)
+import Effectful.Resource (runResource)
+import Effectful.State.Static.Local (evalState)
+import Hsm.Core.App (launch)
+import Hsm.Core.Env (deriveFromYaml)
+import Hsm.Core.Fsm qualified as F
+import Hsm.Core.Zmq.Client (poll, runClient)
+import Hsm.GPIO (GPIO, GPIOEffect, runGPIO, toggle)
+import Hsm.Status.Error (Error(Error))
+import Streamly.Data.Fold qualified as S (drain)
+import Streamly.Data.Stream qualified as S (Stream, fold, mapM)
+import System.IO.Echo (withoutInputEcho)
+
+data Env = Env
+  { name :: Text
+  , gpioOk :: GPIO
+  , gpioError :: GPIO
+  , period :: Int
+  , subEps :: [Text]
+  , topics :: [Text]
+  }
+
+$(deriveFromYaml ''Env)
+
+result ::
+     Bool
+  -> F.FsmState [Error] Bool Env ()
+  -> [Error]
+  -> F.FsmOutput [Error] Bool Env ()
+result sta next es =
+  F.FsmOutput (Just $ F.FsmResult sta () next) (logError <$> es)
+  where
+    logError (Error code msg) =
+      ( LogAttention
+      , "Error received with code "
+          <> pack (show code)
+          <> " and message: "
+          <> msg)
+
+stateOk :: F.FsmState [Error] Bool Env ()
+stateOk =
+  F.FsmState "ok" $ \msg _ _ ->
+    if null msg
+      then result True stateOk msg
+      else result False stateError msg
+
+stateError :: F.FsmState [Error] Bool Env ()
+stateError = F.FsmState "error" $ \msg _ _ -> result False stateError msg
+
+handle ::
+     (GPIOEffect Bool :> es, Log :> es, Reader Env :> es)
+  => S.Stream (Eff es) Bool
+  -> Eff es ()
+handle = S.fold S.drain . S.mapM handler
+  where
+    handler sta = do
+      env <- ask @Env
+      toggle False sta [env.period, env.period, 0]
+
+mapper :: Env -> Bool -> Set GPIO
+mapper env True = singleton env.gpioOk
+mapper env False = singleton env.gpioError
+
+-- Status service blinks a GPIO pin periodically and listens for error
+-- messages. If an error is received it switches to a different pin.
+main :: IO ()
+main =
+  launch "status" withoutInputEcho $ \env logger level ->
+    (poll @_ @Error & F.fsm @_ @_ @Env @() & handle)
+      & runClient @Env
+      & runGPIO (mapper env)
+      & evalState ()
+      & evalState stateOk
+      & runLog env.name logger level
+      & runReader env
+      & runResource
+      & runEff
-- 
cgit v1.2.1