blob: 8f0f42ceb90f4828d755fb5873f230fd74bc7974 (
plain)
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
|
-- |
-- 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, PeerSession
( connectedPeerAddr, enabledExtensions
, peerBitfield, peerSessionStatus
)
, awaitEvent, signalEvent
) where
import Control.Monad
import Data.IORef
import Data.Torrent
import Network.BitTorrent.Internal
import Network.BitTorrent.Exchange
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 @ SwarmSession {..} action = do
let conn = TConnection (tAnnounce torrentMeta) (tInfoHash torrentMeta)
(clientPeerID clientSession) port
progress <- readIORef (currentProgress clientSession)
withTracker progress conn $ \tses -> do
forever $ do
addr <- getPeerAddr tses
withPeer swarm addr action
port = 10000
|
