From 1f2e453d0c9f8412b9032cb4e655713ecdcf1fa3 Mon Sep 17 00:00:00 2001
From: LLLL Colonq <llll@colonq>
Date: Mon, 26 May 2025 04:43:38 -0400
Subject: web: Refactor major style

---
 fig-web/src/Fig/Web/Secure.hs | 115 ++++++++++++------------------------------
 1 file changed, 32 insertions(+), 83 deletions(-)

(limited to 'fig-web/src/Fig/Web/Secure.hs')

diff --git a/fig-web/src/Fig/Web/Secure.hs b/fig-web/src/Fig/Web/Secure.hs
index cf10bc1..22135f5 100644
--- a/fig-web/src/Fig/Web/Secure.hs
+++ b/fig-web/src/Fig/Web/Secure.hs
@@ -1,12 +1,9 @@
-module Fig.Web.Secure where
+module Fig.Web.Secure
+  ( server
+  ) where
 
 import Fig.Prelude
 
-import Data.Maybe (maybeToList)
-import qualified Data.Text as Text
-import qualified Data.Text.Lazy as Text.Lazy
-import qualified Data.Set as Set
-
 import qualified Network.Wai as Wai
 import qualified Network.Wai.Middleware.Static as Wai.Static
 import qualified Network.Wai.Handler.Warp as Warp
@@ -14,32 +11,39 @@ import qualified Network.Wai.Handler.Warp as Warp
 import qualified Web.Scotty as Sc
 
 import Fig.Bus.Binary.Client
+import Fig.Web.Types
 import Fig.Web.Utils
 import qualified Fig.Web.DB as DB
-import qualified Fig.Web.Exchange as Exchange
+import qualified Fig.Web.Module.Exchange as Exchange
+import qualified Fig.Web.Module.Exchange as Redeem
 
-data LiveEvent
-  = LiveEventOnline !(Set.Set Text)
-  | LiveEventOffline !(Set.Set Text)
-  deriving (Show, Eq, Ord)
+allBusEvents :: ModuleArgs -> BusEventHandlers
+allBusEvents args = busEvents . mconcat $ fmap ($ args)
+  [ 
+  ]
 
 server :: Config -> (Text, Text) -> IO ()
 server cfg busAddr = do
   log $ "Web server running on port " <> tshow cfg.port
+  log "Connecting to database..."
+  db <- DB.connect cfg
+  channels <- newChannels
+  globals <- newGlobals
   busClient busAddr
     (\cmds -> do
         log "Connected to bus!"
-        Warp.run cfg.port =<< app cfg cmds
+        let args = ModuleArgs{..}
+        subscribeBusEvents cmds $ allBusEvents args
+        Warp.run cfg.port =<< app args
     )
-    (\_cmds ev _d -> do
-        log $ "Invalid event: " <> tshow ev
+    (\cmds ev d -> do
+        let args = ModuleArgs{..}
+        handleBusEvent (allBusEvents args) ev d
     )
     (pure ())
 
-app :: Config -> Commands IO -> IO Wai.Application
-app cfg cmds = do
-  log "Connecting to database..."
-  db <- DB.connect cfg
+app :: ModuleArgs -> IO Wai.Application
+app args = do
   log "Connected! Secure server active."
   Sc.scottyApp do
     Sc.middleware . Wai.Static.staticPolicy $ mconcat
@@ -52,70 +56,15 @@ app cfg cmds = do
         ]
         Wai.Static.<|> Wai.Static.hasPrefix "assets"
         Wai.Static.<|> Wai.Static.hasPrefix "newton"
-      , Wai.Static.addBase cfg.assetPath
+      , Wai.Static.addBase args.cfg.assetPath
       ]
-    Sc.get "/" do
-      Sc.text "this is the secure endpoint"
-    Sc.get "/api/status" do
-      Sc.text "this is the secure endpoint"
-    Sc.get "/api/info" do
-      muser <- Sc.header "Remote-User"
-      memail <- Sc.header "Remote-Email"
-      case (muser, memail) of
-        (Just user, Just email) -> do
-          Sc.text $ user <> " " <> email
-        _else -> do
-          Sc.status status401
-          Sc.text "you're not logged in buddy"
-    Sc.post "/api/redeem" do
-      muser <- Sc.header "Remote-User"
-      memail <- Sc.header "Remote-Email"
-      case (muser, memail) of
-        (Just user, Just _email) -> do
-          name <- Sc.formParam "name"
-          input <- Sc.formParamMaybe "input"
-          liftIO . cmds.publish "frontend redeem incoming"
-            . encodeUtf8 . Text.intercalate "\t" $
-            [ Text.Lazy.toStrict user
-            , name
-            ] <> maybeToList input
-          Sc.text "it worked"
-        _else -> do
-          Sc.status status401
-          Sc.text "you're not logged in buddy"
-    Sc.post "/api/exchange" do
-      Sc.header "Remote-Email" >>= \case
-        Nothing -> do
-          Sc.status status401
-          Sc.text "you're not logged in buddy"
-        Just creator -> do
-          haveCur <- Text.Lazy.toStrict <$> Sc.formParam "haveCur"
-          haveAmount <- Sc.formParam "haveAmount"
-          wantCur <- Text.Lazy.toStrict <$> Sc.formParam "wantCur"
-          wantAmount <- Sc.formParam "wantAmount"
-          key <- Exchange.createOrder db $ Exchange.Order
-            { creator = Text.Lazy.toStrict creator
-            , haveCur = haveCur
-            , haveAmount = haveAmount
-            , wantCur = wantCur
-            , wantAmount = wantAmount
-            }
-          Sc.text . Text.Lazy.fromStrict $ decodeUtf8 key
-    Sc.post "/api/exchange/:key" do
-      Sc.header "Remote-Email" >>= \case
-        Nothing -> do
-          Sc.status status401
-          Sc.text "you're not logged in buddy"
-        Just buyer -> do
-          key <- Sc.pathParam "key"
-          Exchange.satisfyOrder db key $ Text.Lazy.toStrict buyer
-    Sc.delete "/api/exchange/:key" do
-      Sc.header "Remote-Email" >>= \case
-        Nothing -> do
-          Sc.status status401
-          Sc.text "you're not logged in buddy"
-        Just _buyer -> do
-          key <- Sc.pathParam "key"
-          Exchange.cancelOrder db key
+    onGet "/" do
+      respondText "this is the secure endpoint"
+    onGet "/api/status" do
+      respondText "this is the secure endpoint"
+    onGet "/api/info" $ authed \creds -> do
+      respondText $ creds.user <> " " <> creds.email
+    Exchange.secure args
+    Redeem.secure args
     Sc.notFound do
-      Sc.text "not found"
+      respondText "not found"
-- 
cgit v1.2.3