diff --git a/catalog-info.yaml b/catalog-info.yaml index c825026..b4eb3a5 100644 --- a/catalog-info.yaml +++ b/catalog-info.yaml @@ -22,7 +22,7 @@ spec: Receives events from Pathfinder via RestApi, converts them to CloudEvents and sends them to a `cloudevents` topic in Kafka. paths: - /webhhook: + /webhook: post: summary: Receive a POST request and generate a CloudEvent. requestBody: diff --git a/pathfinderevents.py b/pathfinderevents.py index 3eddef1..ca44a39 100644 --- a/pathfinderevents.py +++ b/pathfinderevents.py @@ -25,8 +25,8 @@ def from_pathfinder_request(request: Request) -> CloudEvent: "source": "https://github.com/radiorabe/pathfinder-cloudevents-service", "subject": form["channel"][0], "datacontenttype": "text/plain", - "partitionid": form["channel"][0], }, + form["channel"][0], ) diff --git a/test_pathfinderevents.py b/test_pathfinderevents.py index a481251..3e743ce 100644 --- a/test_pathfinderevents.py +++ b/test_pathfinderevents.py @@ -110,9 +110,9 @@ def test_api_webhook(mock_producer, mock_api, mock_sys_exit): headers=None, ) value = json.loads(mock_producer.send.call_args.kwargs["value"]) - assert value["data"] is None + assert value["data"] == "Klangbecken" assert value["datacontenttype"] == "text/plain" - assert value["partitionid"] == "Klangbecken" + assert "partitionid" not in value assert ( value["source"] == "https://github.com/radiorabe/pathfinder-cloudevents-service" )