From ff02141235d1dbec3492c5a7b49631fe440c4806 Mon Sep 17 00:00:00 2001 From: LLLL Colonq Date: Sat, 3 Jan 2026 21:59:46 -0500 Subject: web: Add Shindigs sorting endpoints --- fig-web/src/Fig/Web/Module/ShindigsSorting.hs | 31 +++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 fig-web/src/Fig/Web/Module/ShindigsSorting.hs (limited to 'fig-web/src/Fig/Web/Module/ShindigsSorting.hs') diff --git a/fig-web/src/Fig/Web/Module/ShindigsSorting.hs b/fig-web/src/Fig/Web/Module/ShindigsSorting.hs new file mode 100644 index 0000000..516f2a2 --- /dev/null +++ b/fig-web/src/Fig/Web/Module/ShindigsSorting.hs @@ -0,0 +1,31 @@ +module Fig.Web.Module.ShindigsSorting + ( public + , publicWebsockets + ) where + +import Fig.Prelude + +import qualified Control.Concurrent.Chan as Chan + +import qualified Data.Aeson as Aeson + +import qualified Network.WebSockets as WS + +import Fig.Web.Utils +import Fig.Web.Types + +public :: PublicModule +public a = do + onPost "/api/shindigssort" do + b :: ShindigsSort <- bodyJSON + liftIO $ Chan.writeChan a.channels.shindigssort b + +publicWebsockets :: PublicWebsockets +publicWebsockets a = + [ ( "/api/shindigssort/events", \conn -> do + c <- Chan.dupChan a.channels.shindigssort + forever do + ev <- liftIO $ Chan.readChan c + WS.sendTextData conn $ Aeson.encode ev + ) + ] -- cgit v1.2.3