{-# LANGUAGE OverloadedStrings #-}
module Network.MPD.Applicative.ClientToClient
(
ChannelName
, MessageText
, subscribe
, unsubscribe
, channels
, readMessages
, sendMessage
) where
import Network.MPD.Commands.Arg hiding (Command)
import Network.MPD.Applicative.Internal
import Network.MPD.Applicative.Util
import Network.MPD.Util
import Data.ByteString.Char8 (ByteString)
import qualified Data.ByteString.UTF8 as UTF8
type ChannelName = String
type MessageText = String
subscribe :: ChannelName -> Command ()
subscribe :: ChannelName -> Command ()
subscribe ChannelName
name = forall a. Parser a -> [ChannelName] -> Command a
Command Parser ()
emptyResponse [Command
"subscribe" forall a. MPDArg a => Command -> a -> ChannelName
<@> ChannelName
name]
unsubscribe :: ChannelName -> Command ()
unsubscribe :: ChannelName -> Command ()
unsubscribe ChannelName
name = forall a. Parser a -> [ChannelName] -> Command a
Command Parser ()
emptyResponse [Command
"unsubscribe" forall a. MPDArg a => Command -> a -> ChannelName
<@> ChannelName
name]
channels :: Command [ChannelName]
channels :: Command [ChannelName]
channels = forall a. Parser a -> [ChannelName] -> Command a
Command Parser [ChannelName]
p [ChannelName
"channels"]
where
p :: Parser [ChannelName]
p = forall a b. (a -> b) -> [a] -> [b]
map ByteString -> ChannelName
UTF8.toString forall b c a. (b -> c) -> (a -> b) -> a -> c
. [ByteString] -> [ByteString]
takeValues forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> Parser [ByteString]
getResponse
readMessages :: Command [(ChannelName, MessageText)]
readMessages :: Command [(ChannelName, ChannelName)]
readMessages = forall a. Parser a -> [ChannelName] -> Command a
Command (forall a. ([ByteString] -> Either ChannelName a) -> Parser a
liftParser [ByteString] -> Either ChannelName [(ChannelName, ChannelName)]
p) [ChannelName
"readmessages"]
where
p :: [ByteString] -> Either ChannelName [(ChannelName, ChannelName)]
p = forall (t :: * -> *) (m :: * -> *) a b.
(Traversable t, Monad m) =>
(a -> m b) -> t a -> m (t b)
mapM [(ByteString, ByteString)]
-> Either ChannelName (ChannelName, ChannelName)
parseMessage forall b c a. (b -> c) -> (a -> b) -> a -> c
. [ByteString]
-> [(ByteString, ByteString)] -> [[(ByteString, ByteString)]]
splitGroups [ByteString
"channel"] forall b c a. (b -> c) -> (a -> b) -> a -> c
. [ByteString] -> [(ByteString, ByteString)]
toAssocList
parseMessage :: [(ByteString, ByteString)] -> Either String (ChannelName, MessageText)
parseMessage :: [(ByteString, ByteString)]
-> Either ChannelName (ChannelName, ChannelName)
parseMessage [(ByteString
"channel", ByteString
ch),(ByteString
"message", ByteString
msg)] = forall a b. b -> Either a b
Right (ByteString -> ChannelName
UTF8.toString ByteString
ch, ByteString -> ChannelName
UTF8.toString ByteString
msg)
parseMessage [(ByteString, ByteString)]
_ = forall a b. a -> Either a b
Left ChannelName
"Unexpected result from readMessages"
sendMessage :: ChannelName -> MessageText -> Command ()
sendMessage :: ChannelName -> ChannelName -> Command ()
sendMessage ChannelName
name ChannelName
text = forall a. Parser a -> [ChannelName] -> Command a
Command Parser ()
emptyResponse [Command
"sendmessage" forall a. MPDArg a => Command -> a -> ChannelName
<@> ChannelName
name forall a b. (MPDArg a, MPDArg b) => a -> b -> Args
<++> ChannelName
text]