1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
-- |
-- Copyright : (c) Sam T. 2013
-- License : MIT
-- Maintainer : pxqr.sta@gmail.com
-- Stability : experimental
-- Portability : portable
--
{-# LANGUAGE RecordWildCards #-}
module Network.BitTorrent
(
module Data.Torrent
-- * Session
, ClientSession
, newClient
, SwarmSession
, newLeacher, newSeeder
-- * Discovery
, discover
-- * Peer to Peer
, P2P
, Event(..)
, PeerSession ( connectedPeerAddr, enabledExtensions )
, Block(..), BlockIx(..), ppBlock, ppBlockIx
, awaitEvent, yieldEvent
) where
import Control.Monad
import Data.IORef
import Data.Torrent
import Network.BitTorrent.Internal
import Network.BitTorrent.Exchange
import Network.BitTorrent.Exchange.Protocol
import Network.BitTorrent.Tracker
-- discover should hide tracker and DHT communication under the hood
-- thus we can obtain unified interface
discover :: SwarmSession -> P2P () -> IO ()
discover swarm action = do
let conn = TConnection (tAnnounce (torrentMeta swarm))
(tInfoHash (torrentMeta swarm))
(clientPeerID (clientSession swarm))
port
progress <- getCurrentProgress (clientSession swarm)
putStrLn "lookup peers"
withTracker progress conn $ \tses -> do
forever $ do
addr <- getPeerAddr tses
putStrLn "connecting to peer"
withPeer swarm addr action
port = 10000
|
