Chat server: Difference between revisions

}</lang>

 

import Network

import System.IO

 

type ServerApp = ReaderT ThreadData IO

data ThreadData = ThreadData { threadHandle :: Handle

, userTableMV :: MVar (Map Text Handle)}

removeUser name = do

echoLocal $ "Exception with " <> name <> ", removing from userTable"

modifyUserTable (M.delete name)

 

addUser

else do putMVarT usersMV (M.insert name h userTable)

echoRemote "Welcome to the server!\n>> Other users:"

readMVarT usersMV >>=

return name

 

broadcast user msg =

viewUsers >>= readMVarT >>= mapM_ (f . snd) . fn . M.toList

where f h = liftIO $ T.hPutStrLn h $ nm <> msg

(fn, nm) = case user of

Client t -> (filter ((/=t) . fst), t <> "> ")

 

T.putStrLn "Server started"

newMVar (M.empty) >>= clientLoop server

 

=={{header|Java}}==