module Network.Pusher.Protocol
( ChannelInfo(..)
, ChannelInfoAttributes(..)
, ChannelInfoQuery(..)
, ChannelsInfo(..)
, ChannelsInfoQuery(..)
, ChannelsInfoAttributes(..)
, FullChannelInfo(..)
, User(..)
, Users(..)
, ToURLParam
, toURLParam
) where
import Data.Aeson ((.:), (.:?))
import qualified Data.Aeson as A
import qualified Data.HashMap.Strict as HM
import qualified Data.HashSet as HS
import Data.Hashable (Hashable)
import qualified Data.Text as T
import GHC.Generics (Generic)
import Network.Pusher.Data (Channel, parseChannel)
import Network.Pusher.Internal.Util (failExpectObj)
class ToURLParam a where
toURLParam :: a -> T.Text
data ChannelsInfoAttributes =
ChannelsUserCount
deriving (Eq, Generic)
instance ToURLParam ChannelsInfoAttributes where
toURLParam ChannelsUserCount = "user_count"
instance Hashable ChannelsInfoAttributes
newtype ChannelsInfoQuery =
ChannelsInfoQuery (HS.HashSet ChannelsInfoAttributes)
deriving (ToURLParam)
data ChannelInfoAttributes
= ChannelUserCount
| ChannelSubscriptionCount
deriving (Eq, Generic)
instance ToURLParam ChannelInfoAttributes where
toURLParam ChannelUserCount = "user_count"
toURLParam ChannelSubscriptionCount = "subscription_count"
instance Hashable ChannelInfoAttributes
newtype ChannelInfoQuery =
ChannelInfoQuery (HS.HashSet ChannelInfoAttributes)
deriving (ToURLParam)
instance ToURLParam a => ToURLParam (HS.HashSet a) where
toURLParam hs = T.intercalate "," $ toURLParam <$> HS.toList hs
newtype ChannelsInfo =
ChannelsInfo (HM.HashMap Channel ChannelInfo)
deriving (Eq, Show)
instance A.FromJSON ChannelsInfo where
parseJSON (A.Object v) = do
chansV <- v .: "channels"
case chansV of
A.Object cs
->
ChannelsInfo . HM.fromList <$>
mapM
(\(channel, info) -> (parseChannel channel, ) <$> A.parseJSON info)
(HM.toList cs)
v1 -> failExpectObj v1
parseJSON v2 = failExpectObj v2
newtype ChannelInfo = ChannelInfo
{ channelInfoUserCount :: Maybe Int
} deriving (Eq, Show)
instance A.FromJSON ChannelInfo where
parseJSON (A.Object v) = ChannelInfo <$> v .:? "user_count"
parseJSON v = failExpectObj v
data FullChannelInfo = FullChannelInfo
{ fullChannelInfoOccupied :: Bool
, fullChannelInfoUserCount :: Maybe Int
, fullChannelInfoSubCount :: Maybe Int
} deriving (Eq, Show)
instance A.FromJSON FullChannelInfo where
parseJSON (A.Object v) =
FullChannelInfo <$> v .: "occupied" <*> v .:? "user_count" <*>
v .:? "subscription_count"
parseJSON v = failExpectObj v
newtype Users =
Users [User]
deriving (Eq, Show)
instance A.FromJSON Users where
parseJSON (A.Object v) = do
users <- v .: "users"
Users <$> A.parseJSON users
parseJSON v = failExpectObj v
newtype User = User
{ userID :: T.Text
} deriving (Eq, Show)
instance A.FromJSON User where
parseJSON (A.Object v) = User <$> v .: "id"
parseJSON v = failExpectObj v