diff options
Diffstat (limited to 'src/Network')
-rw-r--r-- | src/Network/DHT/Kademlia.hs | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/src/Network/DHT/Kademlia.hs b/src/Network/DHT/Kademlia.hs new file mode 100644 index 00000000..d5418beb --- /dev/null +++ b/src/Network/DHT/Kademlia.hs | |||
@@ -0,0 +1,68 @@ | |||
1 | -- TODO move to Network.DHT.Kademlia | ||
2 | {-# LANGUAGE OverloadedStrings #-} | ||
3 | module Network.DHT.Kademlia | ||
4 | ( | ||
5 | ) where | ||
6 | |||
7 | import Data.ByteString | ||
8 | import Network | ||
9 | import Remote.KRPC | ||
10 | |||
11 | |||
12 | |||
13 | -- | Global unique identifier of the node. Size of the identifier | ||
14 | -- should(!) be equal to the size of DHT keys. This limitation arises | ||
15 | -- from the design of Kademlia: we should estimate distance between | ||
16 | -- keys and NodeId in routing algorithms. | ||
17 | -- | ||
18 | type NodeID = ByteString | ||
19 | |||
20 | type NodeAddr = ByteString | ||
21 | type InfoHash = ByteString | ||
22 | type Token = ByteString | ||
23 | |||
24 | -- | Used to check out if a node is alive or not. This has a tow-fold effect: | ||
25 | -- | ||
26 | -- * If(!) caller get response it should update the bucket | ||
27 | -- corresponding to the callee. | ||
28 | -- | ||
29 | -- * Callee of the ping should update the bucket corresponding | ||
30 | -- to the caller as well. | ||
31 | -- | ||
32 | ping :: Method NodeID NodeID | ||
33 | ping = method "ping" ["id"] ["id"] | ||
34 | |||
35 | type PeerContact = () | ||
36 | data NodeContact = NodeContact { | ||
37 | peerContact :: PeerContact | ||
38 | , nodeID :: NodeID | ||
39 | } | ||
40 | |||
41 | -- | Used to lookup peer ID from node ID. | ||
42 | -- | ||
43 | find_node :: Method (NodeID, NodeID) (NodeID, NodeContact) | ||
44 | find_node = method "find_node" ["id", "target"] ["id", "nodes"] | ||
45 | |||
46 | -- | | ||
47 | announce_peer :: Method (NodeID, InfoHash, PortNumber, Token) NodeID | ||
48 | announce_peer = undefined | ||
49 | |||
50 | genNodeID :: IO NodeID | ||
51 | genNodeID = undefined | ||
52 | |||
53 | {- | ||
54 | type InfoHash = Int | ||
55 | type Token = Int | ||
56 | |||
57 | ping :: Method NodeId NodeId | ||
58 | ping = method "ping" ["id"] ["id"] | ||
59 | |||
60 | get_peers :: Method (NodeId :*: InfoHash) (NodeId, Token, NodeAddr :|: NodeAddr) | ||
61 | get_peers = method "get_peers" | ||
62 | ("id", "target") | ||
63 | ("id", "token", view ("values" :|: "nodes")) | ||
64 | |||
65 | |||
66 | |||
67 | |||
68 | -} \ No newline at end of file | ||