{-# LANGUAGE ExistentialQuantification #-}
module Network.WebSockets.Protocol
( Protocol (..)
, defaultProtocol
, protocols
, compatible
, headerVersions
, finishRequest
, finishResponse
, encodeMessages
, decodeMessages
, createRequest
) where
import Data.ByteString (ByteString)
import qualified Data.ByteString as B
import Network.WebSockets.Connection.Options
import Network.WebSockets.Http
import qualified Network.WebSockets.Hybi13 as Hybi13
import Network.WebSockets.Stream (Stream)
import Network.WebSockets.Types
data Protocol
= Hybi13
deriving (Show)
defaultProtocol :: Protocol
defaultProtocol = Hybi13
protocols :: [Protocol]
protocols = [Hybi13]
headerVersions :: Protocol -> [ByteString]
headerVersions Hybi13 = Hybi13.headerVersions
compatible :: Protocol -> RequestHead -> Bool
compatible protocol req = case getRequestSecWebSocketVersion req of
Just v -> v `elem` headerVersions protocol
_ -> True
finishRequest
:: Protocol -> RequestHead -> Headers -> Either HandshakeException Response
finishRequest Hybi13 = Hybi13.finishRequest
finishResponse
:: Protocol -> RequestHead -> ResponseHead
-> Either HandshakeException Response
finishResponse Hybi13 = Hybi13.finishResponse
encodeMessages
:: Protocol -> ConnectionType -> Stream
-> IO ([Message] -> IO ())
encodeMessages Hybi13 = Hybi13.encodeMessages
decodeMessages
:: Protocol -> SizeLimit -> SizeLimit -> Stream
-> IO (IO (Maybe Message))
decodeMessages Hybi13 frameLimit messageLimit =
Hybi13.decodeMessages frameLimit messageLimit
createRequest
:: Protocol -> B.ByteString -> B.ByteString -> Bool -> Headers
-> IO RequestHead
createRequest Hybi13 = Hybi13.createRequest