|
1 | 1 | from twisted.trial import unittest |
2 | 2 |
|
| 3 | +from dht.node import Node |
| 4 | +from dht.utils import digest |
| 5 | +from dht.routing import RoutingTable |
3 | 6 | from market.protocol import MarketProtocol |
| 7 | +from dht.tests.utils import mknode |
4 | 8 |
|
5 | 9 | class MarketProtocolTest(unittest.TestCase): |
6 | | - def test_connect_multiplexer(self): |
| 10 | + def setUp(self): |
| 11 | + self.node = Node(digest("test"), "127.0.0.1", 1234) |
| 12 | + self.router = RoutingTable(self, 20, self.node.id) |
| 13 | + |
| 14 | + def test_connect_multiplexer_correctly(self): |
7 | 15 | mp = MarketProtocol(0, 0, 0, 0) |
8 | 16 | self.assertEqual(mp.multiplexer, None) |
9 | | - mp.connect_multiplexer("3") |
10 | | - self.assertEqual(mp.multiplexer, "3") |
| 17 | + mp.connect_multiplexer("3") |
| 18 | + self.assertEqual(mp.multiplexer, "3") |
11 | 19 |
|
12 | | - def test_add_listener(self): |
| 20 | + def test_add_listener_correctly(self): |
13 | 21 | mp = MarketProtocol(0, 0, 0, 0) |
14 | 22 | self.assertEqual(len(mp.listeners), 0) |
15 | | - mp.add_listener(3) |
16 | | - self.assertEqual(len(mp.listeners),1) |
| 23 | + mp.add_listener(3) |
| 24 | + self.assertEqual(len(mp.listeners), 1) |
| 25 | + |
| 26 | + def test_rpc_get_image_invalid_image_hash(self): |
| 27 | + mp = MarketProtocol(self.node, self.router, 0, 0) |
| 28 | + self.assertRaises(Exception, mp.rpc_get_image(mknode(), "invalid_hash")); |
0 commit comments