@@ -38,7 +38,6 @@ import Network.Wai
38import Network.WebSockets
38import Network.WebSockets
39 (defaultConnectionOptions, ConnectionOptions(..), sendTextData,
39 (defaultConnectionOptions, ConnectionOptions(..), sendTextData,
40 receiveDataMessage, acceptRequest, ServerApp, sendPing)
40 receiveDataMessage, acceptRequest, ServerApp, sendPing)
41−import qualified Network.WebSockets as WS (DataMessage(..))
42import Network.Wai.Handler.WebSockets (websocketsOr)
41import Network.Wai.Handler.WebSockets (websocketsOr)
44import Language.Javascript.JSaddle.Types (JSM(..), JSContextRef(..))
43import Language.Javascript.JSaddle.Types (JSM(..), JSContextRef(..))
@@ -65,6 +64,8 @@ import Foreign.Store (newStore, readStore, lookupStore)
65import Language.Javascript.JSaddle (askJSM)
64import Language.Javascript.JSaddle (askJSM)
66import Control.Monad.IO.Class (MonadIO(..))
65import Control.Monad.IO.Class (MonadIO(..))
67+import Language.Javascript.JSaddle.WebSockets.Compat (getTextMessageByteString)
68jsaddleOr :: ConnectionOptions -> JSM () -> Application -> IO Application
69jsaddleOr :: ConnectionOptions -> JSM () -> Application -> IO Application
69jsaddleOr opts entryPoint otherApp = do
70jsaddleOr opts entryPoint otherApp = do
70 syncHandlers <- newIORef M.empty
71 syncHandlers <- newIORef M.empty
@@ -77,8 +78,8 @@ jsaddleOr opts entryPoint otherApp = do
77 liftIO $ sendTextData conn (encode syncKey)
78 liftIO $ sendTextData conn (encode syncKey)
78 entryPoint
79 entryPoint
79 _ <- forkIO . forever $
80 _ <- forkIO . forever $
80− receiveDataMessage conn >>= \case
81+ receiveDataMessage conn >>= \msg -> case getTextMessageByteString msg of
81− (WS.Text t) ->
82+ Just t ->
82 case decode t of
83 case decode t of
83 Nothing -> error $ "jsaddle Results decode failed : " <> show t
84 Nothing -> error $ "jsaddle Results decode failed : " <> show t
84 Just r -> processResult r
85 Just r -> processResult r