import Control.Monad.Reader

import Control.Monad.State.Strict

import Data.Set as Set

import qualified Data.ByteString.Char8 as B

import ServerState

timerLoop :: Int -> Chan CoreMessage -> IO ()

reactCmd :: [B.ByteString] -> StateT ServerState IO ()

reactCmd cmd = do

    (Just ci) <- gets clientIndex

    rnc <- gets roomsClients

    actions <- liftIO $ withRoomsAndClients rnc (\irnc -> runReader (handleCmd cmd) (ci, irnc))

    forM_ actions processAction

mainLoop :: StateT ServerState IO ()

mainLoop = forever $ do

    get >>= \s -> put $! s

    si <- gets serverInfo

    r <- liftIO $ readChan $ coreChan si

    case r of

        Accept ci -> processAction (AddClient ci)

        ClientMessage (ci, cmd) -> do

            liftIO $ debugM "Clients" $ (show ci) ++ ": " ++ (show cmd)

            removed <- gets removedClients

            when (not $ ci `Set.member` removed) $ do

                as <- get

                put $! as{clientIndex = Just ci}

                reactCmd cmd

        Remove ci -> do

            liftIO $ debugM "Clients"  $ "DeleteClient: " ++ show ci

            processAction (DeleteClient ci)

                --else

                --do

                --debugM "Clients" "Message from dead client"

                --return (serverInfo, rnc)

        ClientAccountInfo (ci, info) -> do

            rnc <- gets roomsClients

            exists <- liftIO $ clientExists rnc ci

            when (exists) $ do

                as <- get

                put $! as{clientIndex = Just ci}

                processAction (ProcessAccountInfo info)

                return ()

        TimerAction tick ->

                mapM_ processAction $

                    PingAll : [StatsAction | even tick]

    --forkIO $ timerLoop 0 $ coreChan serverInfo

    rnc <- newRoomsAndClients newRoom

    forkIO $ evalStateT mainLoop (ServerState Nothing serverInfo Set.empty rnc)

    forever $ threadDelay (60 * 60 * 10^6)