Internal: add test for POST /messages with sync (#464)

Author: odesenfans

tests/api/test_p2p.py

@@ -5,6 +5,7 @@
 from configmanager import Config
 
 P2P_PUB_URI = "/api/v0/p2p/pubsub/pub"
+POST_MESSAGES_URI = "/api/v0/messages"
 
 MESSAGE_DICT = {
     "chain": "NULS2",
@@ -63,3 +64,37 @@ async def test_pubsub_pub_errors(ccn_api_client, mock_config: Config):
         P2P_PUB_URI, json={"topic": message_topic, "data": json.dumps(message_dict)}
     )
     assert response.status == 422, await response.text()
+
+
+@pytest.mark.asyncio
+async def test_post_message_sync(ccn_api_client, mocker):
+    # Mock the functions used to create the RabbitMQ queue
+    mocker.patch("aleph.web.controllers.p2p.get_mq_channel_from_request")
+    mocked_queue = mocker.patch(
+        "aleph.web.controllers.p2p.mq_make_aleph_message_topic_queue"
+    )
+
+    # Create a mock MQ response object
+    mock_mq_message = mocker.Mock()
+    mock_mq_message.routing_key = f"processed.{MESSAGE_DICT['item_hash']}"
+    mocker.patch(
+        "aleph.web.controllers.p2p._mq_read_one_message", return_value=mock_mq_message
+    )
+
+    response = await ccn_api_client.post(
+        POST_MESSAGES_URI,
+        json={
+            "message": MESSAGE_DICT,
+            "sync": True,
+        },
+    )
+
+    assert response.status == 200, await response.text()
+    json_response = await response.json()
+    pub_status = json_response["publication_status"]
+    assert json_response["message_status"] == "processed"
+    assert pub_status["status"] == "success"
+    assert pub_status["failed"] == []
+
+    # Check that we cleaned up the queue
+    assert mocked_queue.delete.called_once