54 lines
1.5 KiB
Haskell
54 lines
1.5 KiB
Haskell
module Hsbot.Core
|
|
( connectServer
|
|
, disconnectServer
|
|
) where
|
|
|
|
import Control.Concurrent
|
|
import Control.Concurrent.Chan
|
|
import Control.Monad.State
|
|
import Data.List
|
|
import qualified Data.Map as M
|
|
import Network
|
|
import System.IO
|
|
import System.Time (getClockTime)
|
|
|
|
import Hsbot.IRCParser
|
|
import Hsbot.Types
|
|
import Hsbot.Utils
|
|
|
|
-- Connect to the server and return the initial bot state
|
|
connectServer :: IrcServer -> IO Bot
|
|
connectServer server = do
|
|
let name = address server
|
|
starttime <- getClockTime
|
|
putStr $ "Connecting to " ++ name ++ "... "
|
|
handle <- connectTo name $ port server
|
|
hSetBuffering handle NoBuffering
|
|
putStrLn "done."
|
|
putStr $ "Opening server communication channel... "
|
|
chan <- newChan :: IO (Chan BotMsg)
|
|
threadId <- forkIO $ botReader handle chan
|
|
putStrLn "done."
|
|
return (Bot server starttime handle [] M.empty chan threadId M.empty)
|
|
|
|
-- | Disconnect from the server
|
|
disconnectServer :: Bot -> IO () -- IO Bot ?
|
|
disconnectServer bot = do
|
|
killThread $ readerThreadId bot
|
|
mapM_ (killThread . pluginThreadId . snd) (M.toList $ botPlugins bot)
|
|
hClose $ botHandle bot
|
|
return ()
|
|
|
|
-- | Socket reading loop
|
|
botReader :: Handle -> Chan BotMsg -> IO ()
|
|
botReader handle chan = forever $ do
|
|
-- TODO : detect end of connection!
|
|
str <- hGetLine handle
|
|
let msg = parseIrcMsg str
|
|
case msg of
|
|
Right msg' -> do
|
|
trace $ inColor ("<-- " ++ (show msg')) [33]
|
|
writeChan chan (InputMsg msg')
|
|
_ -> do
|
|
return ()
|
|
|