-> String -> [String] -> Integer -> IO ()
runTracker msgChannel fsChan infohash port peerId announceList sz = do
ps <- newEmptyMVar
- let initialTState = TState { currentState = None
- , connectedPeers = ps
- , left = sz }
- turl = head announceList
- host = getHostname turl
- case getTrackerType turl of
- Http -> do
- _ <- forkIO $ HT.trackerLoop turl port peerId infohash fsChan initialTState
- runStateT (msgHandler msgChannel) initialTState
- return ()
- Udp -> do
- _ <- forkIO $ UT.trackerLoop turl (fromIntegral port) peerId infohash fsChan initialTState
- runStateT (msgHandler msgChannel) initialTState
- return ()
- _ ->
- error "Tracker Protocol unimplemented"
+ forkIO $ (getTrackerLoopFn turl) turl port peerId infohash fsChan (initialTState ps)
+ runStateT (msgHandler msgChannel) (initialTState ps)
+ return ()
+ where getTrackerLoopFn turl =
+ case getTrackerType turl of
+ Http -> HT.trackerLoop
+ Udp -> UT.trackerLoop
+ _ -> error "Tracker Protocol unimplemented"
+ initialTState ps' = TState { currentState = None
+ , connectedPeers = ps'
+ , left = sz }
+ turl = head announceList
getTrackerType :: String -> TrackerProtocol
getTrackerType url | "http://" `isPrefixOf` url = Http