1
1
from unittest import mock
2
2
from ros_tcp_endpoint import TcpServer
3
3
from ros_tcp_endpoint .server import SysCommands
4
- from ros_tcp_endpoint .server import resolve_message_name
5
4
import importlib
6
5
import rospy
7
6
import sys
@@ -43,9 +42,7 @@ def test_unity_service_resolve_message_name_failure():
43
42
44
43
@mock .patch .object (rospy , "Service" )
45
44
@mock .patch .object (
46
- ros_tcp_endpoint .server ,
47
- "resolve_message_name" ,
48
- return_value = "unity_interfaces.msg/RosUnitySrvMessage" ,
45
+ SysCommands , "resolve_message_name" , return_value = "unity_interfaces.msg/RosUnitySrvMessage"
49
46
)
50
47
def test_unity_service_resolve_news_service (mock_resolve_message , mock_ros_service ):
51
48
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
@@ -58,9 +55,7 @@ def test_unity_service_resolve_news_service(mock_resolve_message, mock_ros_servi
58
55
59
56
@mock .patch .object (rospy , "Service" )
60
57
@mock .patch .object (
61
- ros_tcp_endpoint .server ,
62
- "resolve_message_name" ,
63
- return_value = "unity_interfaces.msg/RosUnitySrvMessage" ,
58
+ SysCommands , "resolve_message_name" , return_value = "unity_interfaces.msg/RosUnitySrvMessage"
64
59
)
65
60
def test_unity_service_resolve_existing_service (mock_resolve_message , mock_ros_service ):
66
61
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
@@ -74,8 +69,9 @@ def test_unity_service_resolve_existing_service(mock_resolve_message, mock_ros_s
74
69
@mock .patch .object (sys , "modules" , return_value = "unity_interfaces.msg" )
75
70
@mock .patch .object (importlib , "import_module" )
76
71
def test_resolve_message_name (mock_import_module , mock_sys_modules ):
72
+ server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
77
73
msg_name = "unity_interfaces.msg/UnityColor.msg"
78
- result = resolve_message_name (msg_name )
74
+ result = SysCommands ( server ). resolve_message_name (msg_name )
79
75
mock_import_module .assert_called_once
80
76
mock_sys_modules .assert_called_once
81
77
assert result is not None
@@ -113,9 +109,7 @@ def test_publish_empty_message_should_return_none():
113
109
114
110
115
111
@mock .patch .object (rospy , "Subscriber" )
116
- @mock .patch .object (
117
- ros_tcp_endpoint .server , "resolve_message_name" , return_value = "unity_interfaces.msg/Pos"
118
- )
112
+ @mock .patch .object (SysCommands , "resolve_message_name" , return_value = "unity_interfaces.msg/Pos" )
119
113
def test_subscribe_to_new_topic (mock_resolve_msg , mock_ros_subscriber ):
120
114
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
121
115
result = SysCommands (server ).subscribe ("object_pos_topic" , "pos" )
@@ -124,9 +118,7 @@ def test_subscribe_to_new_topic(mock_resolve_msg, mock_ros_subscriber):
124
118
125
119
126
120
@mock .patch .object (rospy , "Subscriber" )
127
- @mock .patch .object (
128
- ros_tcp_endpoint .server , "resolve_message_name" , return_value = "unity_interfaces.msg/Pos"
129
- )
121
+ @mock .patch .object (SysCommands , "resolve_message_name" , return_value = "unity_interfaces.msg/Pos" )
130
122
def test_subscribe_to_existing_topic (mock_resolve_msg , mock_ros_subscriber ):
131
123
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
132
124
server .subscribers = {"object_pos_topic" : mock .Mock ()}
@@ -150,7 +142,7 @@ def test_subscribe_to_empty_message_should_return_none():
150
142
151
143
152
144
@mock .patch .object (rospy , "ServiceProxy" )
153
- @mock .patch .object (ros_tcp_endpoint . server , "resolve_message_name" )
145
+ @mock .patch .object (SysCommands , "resolve_message_name" )
154
146
def test_ros_service_new_topic (mock_resolve_msg , mock_ros_service ):
155
147
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
156
148
result = SysCommands (server ).ros_service ("object_pos_topic" , "pos" )
@@ -159,7 +151,7 @@ def test_ros_service_new_topic(mock_resolve_msg, mock_ros_service):
159
151
160
152
161
153
@mock .patch .object (rospy , "ServiceProxy" )
162
- @mock .patch .object (ros_tcp_endpoint . server , "resolve_message_name" )
154
+ @mock .patch .object (SysCommands , "resolve_message_name" )
163
155
def test_ros_service_existing_topic (mock_resolve_msg , mock_ros_service ):
164
156
server = TcpServer (node_name = "test-tcp-server" , tcp_ip = "127.0.0.1" , tcp_port = 10000 )
165
157
server .ros_services = {"object_pos_topic" : mock .Mock ()}
0 commit comments