Secured API

3 files changed, 85 insertions, 5 deletions

diff --git a/fig-web/fig-web.cabal b/fig-web/fig-web.cabal
index 3cf3502..600d4d8 100644
--- a/fig-web/fig-web.cabal
+++ b/fig-web/fig-web.cabal
@@ -55,6 +55,7 @@ library
   hs-source-dirs: src
   exposed-modules:
     Fig.Web
+    Fig.Web.Secure
     Fig.Web.Utils
     Fig.Web.Auth
     Fig.Web.State
diff --git a/fig-web/main/Main.hs b/fig-web/main/Main.hs
index 890c010..926685c 100644
--- a/fig-web/main/Main.hs
+++ b/fig-web/main/Main.hs
@@ -6,13 +6,25 @@ import Fig.Prelude
 
 import Options.Applicative
 
-import Fig.Web
 import Fig.Web.Utils
+import qualified Fig.Web as Public
+import qualified Fig.Web.Secure as Secure
+
+data Command
+  = Public
+  | Secure
+
+parseCommand :: Parser Command
+parseCommand = subparser $ mconcat
+  [ command "public" $ info (pure Public) (progDesc "Launch the public web server")
+  , command "secure" $ info (pure Secure) (progDesc "Launch the private web server (intended to be run behind authentication proxy)")
+  ]
 
 data Opts = Opts
-  { busHost :: Text
-  , busPort :: Text
-  , config :: FilePath
+  { busHost :: !Text
+  , busPort :: !Text
+  , config :: !FilePath
+  , command :: !Command
   }
 
 parseOpts :: Parser Opts
@@ -20,6 +32,7 @@ parseOpts = do
   busHost <- strOption (long "bus-host" <> metavar "HOST" <> help "Address of message bus" <> value "localhost")
   busPort <- strOption (long "bus-port" <> metavar "PORT" <> help "Message bus port" <> showDefault <> value "32050")
   config <- strOption (long "config" <> metavar "PATH" <> help "Path to config file" <> showDefault <> value "fig-web.toml")
+  command <- parseCommand
   pure Opts{..}
 
 main :: IO ()
@@ -29,4 +42,6 @@ main = do
     <> header "fig-web - public-facing web applications"
     )
   cfg <- loadConfig opts.config
-  server cfg (opts.busHost, opts.busPort)
+  case cfg.command of
+    Public -> Public.server cfg (opts.busHost, opts.busPort)
+    Secure -> Secure.server cfg (opts.busHost, opts.busPort)
diff --git a/fig-web/src/Fig/Web/Secure.hs b/fig-web/src/Fig/Web/Secure.hs
new file mode 100644
index 0000000..dfb7e1b
--- /dev/null
+++ b/fig-web/src/Fig/Web/Secure.hs
@@ -0,0 +1,64 @@
+{-# Language QuasiQuotes #-}
+
+module Fig.Web where
+
+import Fig.Prelude
+
+import System.Random (randomRIO)
+
+import Control.Monad (unless)
+import Control.Lens (use, (^?), Ixed (..))
+import qualified Control.Concurrent.Chan as Chan
+import qualified Control.Concurrent.MVar as MVar
+
+import Data.Maybe (mapMaybe)
+import qualified Data.Text as Text
+import qualified Data.Text.Lazy as Text.L
+import qualified Data.ByteString.Base64 as BS.Base64
+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
+import qualified Network.WebSockets as WS
+
+import qualified Web.Scotty as Sc
+
+import Fig.Utils.SExpr
+import Fig.Bus.Client
+import Fig.Web.Utils
+import Fig.Web.Auth
+import Fig.Web.State
+import qualified Fig.Web.DB as DB
+
+data LiveEvent
+  = LiveEventOnline !(Set.Set Text)
+  | LiveEventOffline !(Set.Set Text)
+  deriving (Show, Eq, Ord)
+
+server :: Config -> (Text, Text) -> IO ()
+server cfg busAddr = do
+  log $ "Web server running on port " <> tshow cfg.port
+  busClient busAddr
+    (\cmds -> do
+        log "Connected to bus!"
+        Warp.run cfg.port =<< app cfg cmds
+    )
+    (\_cmds d -> do
+        log $ "Invalid event: " <> tshow d
+    )
+    (pure ())
+
+sexprStr :: Text -> SExpr
+sexprStr = SExprString . BS.Base64.encodeBase64 . encodeUtf8
+
+app :: Config -> Commands IO -> IO Wai.Application
+app cfg cmds = do
+  log "Connecting to database..."
+  db <- DB.connect cfg
+  log "Connected! Secure server active."
+  Sc.scottyApp do
+    Sc.get "/" do
+      Sc.text "this is the secure endpoint"
+    Sc.notFound do
+      Sc.text "not found"