pepperplus/pepperplus-cb
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: wait for req socket send to make sure we dont stay stuck - if there's no... #23

Merged
9828273 merged 19 commits from feat/cb2ui-robot-connections into dev 2025-11-18 12:24:15 +00:00
Conversation 83 Commits 19 Files Changed 9 +4
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit be5dc7f04b - Show all commits

4
test/integration/agents/test_ri_communication_agent.py
View File

@@ -428,6 +428,7 @@ async def test_listen_behaviour_ping_correct(caplog):
# TODO: Integration test between actual server and password needed for spade agents # TODO: Integration test between actual server and password needed for spade agents
agent = RICommunicationAgent("test@server", "password") agent = RICommunicationAgent("test@server", "password")
agent._req_socket = fake_socket agent._req_socket = fake_socket
agent.connected = True
behaviour = agent.ListenBehaviour() behaviour = agent.ListenBehaviour()
agent.add_behaviour(behaviour) agent.add_behaviour(behaviour)
@@ -463,6 +464,7 @@ async def test_listen_behaviour_ping_wrong_endpoint(caplog):
agent = RICommunicationAgent("test@server", "password", fake_pub_socket) agent = RICommunicationAgent("test@server", "password", fake_pub_socket)
agent._req_socket = fake_socket agent._req_socket = fake_socket
agent.connected = True
behaviour = agent.ListenBehaviour() behaviour = agent.ListenBehaviour()
agent.add_behaviour(behaviour) agent.add_behaviour(behaviour)
@@ -486,6 +488,7 @@ async def test_listen_behaviour_timeout(zmq_context, caplog):
agent = RICommunicationAgent("test@server", "password") agent = RICommunicationAgent("test@server", "password")
agent._req_socket = fake_socket agent._req_socket = fake_socket
agent.connected = True
behaviour = agent.ListenBehaviour() behaviour = agent.ListenBehaviour()
agent.add_behaviour(behaviour) agent.add_behaviour(behaviour)
@@ -514,6 +517,7 @@ async def test_listen_behaviour_ping_no_endpoint(caplog):
agent = RICommunicationAgent("test@server", "password") agent = RICommunicationAgent("test@server", "password")
agent._req_socket = fake_socket agent._req_socket = fake_socket
agent.connected = True
behaviour = agent.ListenBehaviour() behaviour = agent.ListenBehaviour()
agent.add_behaviour(behaviour) agent.add_behaviour(behaviour)