@@ -22,7 +22,7 @@ def setUp(self):
22
22
def test_correct_callback_called_when_message_is_published (self ):
23
23
from pitop .common .ptdm import Message , PTDMSubscribeClient
24
24
25
- self .poller_mock .poll .return_value = [1 ]
25
+ self .poller_mock .poll .return_value = [2 ]
26
26
27
27
def callback_without_args ():
28
28
callback_without_args .counter += 1
@@ -43,14 +43,19 @@ def callback_with_args():
43
43
)
44
44
client .start_listening ()
45
45
46
+ assert callback_without_args .counter == 0
47
+ assert callback_with_args .counter == 0
48
+
49
+ # Emit event that doesn't use an argument
46
50
self .socket_mock .recv_string .return_value = f"{ Message .PUB_LOW_BATTERY_WARNING } "
47
- wait_until (lambda : callback_without_args .counter > 0 , timeout = 3 )
51
+ wait_until (lambda : callback_without_args .counter > 0 , timeout = 5 )
48
52
assert callback_with_args .counter == 0
49
53
54
+ # Emit event that uses an argument
50
55
self .socket_mock .recv_string .return_value = (
51
56
f"{ Message .PUB_BRIGHTNESS_CHANGED } |1"
52
57
)
53
- wait_until (lambda : callback_with_args .counter > 0 , timeout = 3 )
58
+ wait_until (lambda : callback_with_args .counter > 0 , timeout = 5 )
54
59
55
60
client .stop_listening ()
56
61
@@ -59,6 +64,7 @@ def test_callback_not_included_if_has_wrong_signature(self):
59
64
60
65
self .socket_mock .recv_string .return_value = f"{ Message .PUB_LOW_BATTERY_WARNING } "
61
66
67
+ # Callback should have only 1 argument
62
68
def callback (x , y ):
63
69
callback .counter += 1
64
70
@@ -71,6 +77,7 @@ def callback(x, y):
71
77
}
72
78
)
73
79
80
+ # Callback wasn't saved
74
81
assert client ._callback_funcs .get (Message .PUB_LOW_BATTERY_WARNING ) is None
75
82
76
83
def test_subscribe_client_cleanup_closes_socket (self ):
0 commit comments