Use correct topic for scm_request_processor

The Pagure messages are not sent with org.fedoraproject. prefix, but with
io.pagure. prefix.

Signed-off-by: Michal Konečný <mkonecny@redhat.com>
This commit is contained in:
Michal Konečný 2022-07-21 14:57:11 +02:00
parent 049403fc59
commit 506e59558c
2 changed files with 13 additions and 13 deletions

View file

@ -31,15 +31,15 @@ class TestAcceptsTopic:
@pytest.mark.parametrize(
"topic",
[
"org.fedoraproject.*.pagure.issue.new",
"org.fedoraproject.*.pagure.issue.edit",
"org.fedoraproject.*.pagure.issue.comment.added",
"org.fedoraproject.stg.pagure.issue.new",
"org.fedoraproject.stg.pagure.issue.edit",
"org.fedoraproject.stg.pagure.issue.comment.added",
"org.fedoraproject.prod.pagure.issue.new",
"org.fedoraproject.prod.pagure.issue.edit",
"org.fedoraproject.prod.pagure.issue.comment.added",
"io.pagure.*.pagure.issue.new",
"io.pagure.*.pagure.issue.edit",
"io.pagure.*.pagure.issue.comment.added",
"io.pagure.stg.pagure.issue.new",
"io.pagure.stg.pagure.issue.edit",
"io.pagure.stg.pagure.issue.comment.added",
"io.pagure.prod.pagure.issue.new",
"io.pagure.prod.pagure.issue.edit",
"io.pagure.prod.pagure.issue.comment.added",
],
)
def test_accetps_topic_valid(self, topic, toddler):

View file

@ -63,9 +63,9 @@ class SCMRequestProcessor(ToddlerBase):
name: str = "scm_request_processor"
amqp_topics: list = [
"org.fedoraproject.*.pagure.issue.new",
"org.fedoraproject.*.pagure.issue.edit",
"org.fedoraproject.*.pagure.issue.comment.added",
"io.pagure.*.pagure.issue.new",
"io.pagure.*.pagure.issue.edit",
"io.pagure.*.pagure.issue.comment.added",
]
# SLAs for branches
@ -113,7 +113,7 @@ class SCMRequestProcessor(ToddlerBase):
:returns: True if topic is accepted, False otherwise.
"""
if topic.startswith("org.fedoraproject."):
if topic.startswith("io.pagure."):
if topic.endswith("pagure.issue.new"):
return True
if topic.endswith("pagure.issue.edit"):