From dcef0b65069fb38fd0f6c4382353167f603ebff1 Mon Sep 17 00:00:00 2001
From: LLLL Colonq <llll@colonq>
Date: Thu, 16 Nov 2023 19:06:43 -0500
Subject: Initial commit

---
 fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs | 36 ++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs

(limited to 'fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs')

diff --git a/fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs b/fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs
new file mode 100644
index 0000000..1a267f8
--- /dev/null
+++ b/fig-monitor-bullfrog/src/Fig/Monitor/Bullfrog.hs
@@ -0,0 +1,36 @@
+{-# Language QuasiQuotes #-}
+{-# Language RecordWildCards #-}
+{-# Language ApplicativeDo #-}
+
+module Fig.Monitor.Bullfrog
+  ( bullfrogClient
+  ) where
+
+import Fig.Prelude
+
+import qualified Data.Text as Text
+
+import qualified Wuss as WS
+import qualified Network.WebSockets.Connection as WS
+
+import Fig.Utils.SExpr
+import Fig.Bus.Client
+import Fig.Monitor.Bullfrog.Utils
+
+bullfrogClient :: Config -> (Text, Text) -> IO ()
+bullfrogClient cfg busAddr = do
+  WS.runSecureClient "colonq.computer" 443 ("/bullfrog/api/channel/broadcast?token=" <> Text.unpack cfg.authToken) \conn -> do
+    busClient busAddr
+      (\cmds -> do
+          log "Connected to bus and broadcast server"
+          cmds.subscribe [sexp|(monitor bullfrog broadcast)|]
+      )
+      (\_cmds d -> do
+          case d of
+            SExprList [ev, SExprString msg]
+              | ev == [sexp|(monitor bullfrog broadcast)|] -> do
+                  log $ "Broadcasting message: " <> msg
+                  WS.sendTextData conn msg
+            _ -> log $ "Invalid incoming message: " <> tshow d
+      )
+      (pure ())
-- 
cgit v1.2.3