saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Account for changes in transport api in tests

Browse source
This commit is contained in:
Daniel A. Wozniak 2024-09-13 18:21:47 -07:00
parent 2e514c5e96
commit a9b37c2b5d
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
tests/pytests/unit/transport/test_zeromq.py
View file

@ -389,7 +389,7 @@ def test_serverside_exception(temp_salt_minion, temp_salt_master):
assert ret == "Server-side exception handling payload"
def test_zeromq_async_pub_channel_publish_port(temp_salt_master):
async def test_zeromq_async_pub_channel_publish_port(temp_salt_master):
"""
test when connecting that we use the publish_port set in opts when its not 4506
"""
@ -415,7 +415,7 @@ def test_zeromq_async_pub_channel_publish_port(temp_salt_master):
patch_socket = MagicMock(return_value=True)
patch_auth = MagicMock(return_value=True)
with patch.object(transport, "_socket", patch_socket):
transport.connect(455505)
await transport.connect(455505)
assert str(opts["publish_port"]) in patch_socket.mock_calls[0][1][0]
@ -461,7 +461,7 @@ def test_zeromq_async_pub_channel_filtering_decode_message_no_match(
MagicMock(return_value={"tgt_type": "glob", "tgt": "*", "jid": 1}),
):
res = channel._decode_messages(message)
assert res.result() is None
assert res is None
def test_zeromq_async_pub_channel_filtering_decode_message(
@ -511,7 +511,7 @@ def test_zeromq_async_pub_channel_filtering_decode_message(
) as mock_test:
res = channel._decode_messages(message)
assert res.result()["enc"] == "aes"
assert res["enc"] == "aes"
def test_req_server_chan_encrypt_v2(