HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
test_transport_ConnectionBuilderLight.py
Go to the documentation of this file.
1 '''
2 Created on Feb 28, 2014
3 
4 @author: igor
5 '''
6 import unittest
7 from mock import MagicMock, call
8 import zmq
9 from transport.ConnectionBuilderLight import ConnectionBuilderLight
10 import transport.Consts as consts
11 
12 
13 class TestConnectionBuilderLight(unittest.TestCase):
14 
15 
16  def setUp(self):
17  self.zmq_context_mock = MagicMock(spec = zmq.Context)
18  self.zmq_sock_mock = MagicMock(spec = zmq.Socket)
19  self.zmq_context_mock.socket.return_value = self.zmq_sock_mock
21  self.original_zmq_context = self.connect_builder.zmq_context
22  self.connect_builder.zmq_context = self.zmq_context_mock
23 
24 
25  def tearDown(self):
26  self.connect_builder.zmq_context = self.original_zmq_context
27 
28 
30  connect_endpoint = "server"
31  expect_calls = [call.connect("inproc://server")]
32 
33  self.connect_builder.build(consts.CLIENT_CONNECT, connect_endpoint)
34 
35  self.assertEqual(self.zmq_sock_mock.mock_calls, expect_calls, "")
36 
37 
39  connect_endpoint = "server"
40  expect_calls = [call.bind("inproc://server")]
41 
42  self.connect_builder.build(consts.SERVER_CONNECT, connect_endpoint)
43 
44  self.assertEqual(self.zmq_sock_mock.mock_calls, expect_calls, "")
45 
46 
48  connect_endpoint = "10.10.1.1:1234"
49  expect_calls = [call.bind("tcp://10.10.1.1:1234")]
50 
51  self.connect_builder.build(consts.SERVER_CONNECT, connect_endpoint, consts.TCP_TYPE)
52 
53  self.assertEqual(self.zmq_sock_mock.mock_calls, expect_calls, "")
54 
Class hides routines of bulding connection objects.