mirror of
https://pagure.io/fm-orchestrator.git
synced 2026-02-13 01:54:59 +08:00
b939d53c57
This patch drops message objects, defined by class BaseMessage and its subclasses, and pass event info arguments to event handler directly. Different event handler requires different arguments to handle a kind of specific event. The event info is parsed from the raw message received from message bus. Signed-off-by: Chenxiong Qi <cqi@redhat.com>
78 lines
2.9 KiB
Python
78 lines
2.9 KiB
Python
# -*- coding: utf-8 -*-
|
|
# SPDX-License-Identifier: MIT
|
|
|
|
from module_build_service import messaging
|
|
from module_build_service.scheduler.parser import FedmsgMessageParser
|
|
|
|
|
|
class TestFedmsgMessaging:
|
|
def test_buildsys_state_change(self):
|
|
# https://fedora-fedmsg.readthedocs.io/en/latest/topics.html#id134
|
|
buildsys_state_change_msg = {
|
|
"msg": {
|
|
"attribute": "state",
|
|
"build_id": 614503,
|
|
"instance": "primary",
|
|
"name": "plasma-systemsettings",
|
|
"new": 1,
|
|
"old": 0,
|
|
"owner": "dvratil",
|
|
"release": "1.fc23",
|
|
"task_id": 9053697,
|
|
"version": "5.2.1",
|
|
},
|
|
"msg_id": "2015-51be4c8e-8ab6-4dcb-ac0d-37b257765c71",
|
|
"timestamp": 1424789698.0,
|
|
"topic": "org.fedoraproject.prod.buildsys.build.state.change",
|
|
}
|
|
|
|
parser = FedmsgMessageParser(messaging.known_fedmsg_services)
|
|
event_info = parser.parse(buildsys_state_change_msg)
|
|
|
|
assert event_info["build_id"] == 614503
|
|
assert event_info["build_new_state"] == 1
|
|
|
|
def test_buildsys_tag(self):
|
|
# https://fedora-fedmsg.readthedocs.io/en/latest/topics.html#id134
|
|
buildsys_tag_msg = {
|
|
"msg": {
|
|
"build_id": 875961,
|
|
"name": "module-build-macros",
|
|
"tag_id": 619,
|
|
"instance": "primary",
|
|
"tag": "module-debugging-tools-master-20170405115403-build",
|
|
"user": "mbs/mbs.fedoraproject.org",
|
|
"version": "0.1",
|
|
"owner": "mbs/mbs.fedoraproject.org",
|
|
"release": "1.module_0c3d13fd",
|
|
},
|
|
"msg_id": "2015-51be4c8e-8ab6-4dcb-ac0d-37b257765c71",
|
|
"timestamp": 1424789698.0,
|
|
"topic": "org.fedoraproject.prod.buildsys.tag",
|
|
}
|
|
|
|
parser = FedmsgMessageParser(messaging.known_fedmsg_services)
|
|
event_info = parser.parse(buildsys_tag_msg)
|
|
|
|
assert event_info["tag_name"] == "module-debugging-tools-master-20170405115403-build"
|
|
assert event_info["build_name"] == "module-build-macros"
|
|
|
|
def test_buildsys_repo_done(self):
|
|
# https://fedora-fedmsg.readthedocs.io/en/latest/topics.html#id134
|
|
buildsys_tag_msg = {
|
|
"msg": {
|
|
"instance": "primary",
|
|
"repo_id": 728809,
|
|
"tag": "module-f0f7e44f3c6cccab-build",
|
|
"tag_id": 653,
|
|
},
|
|
"msg_id": "2015-51be4c8e-8ab6-4dcb-ac0d-37b257765c71",
|
|
"timestamp": 1424789698.0,
|
|
"topic": "org.fedoraproject.prod.buildsys.repo.done",
|
|
}
|
|
|
|
parser = FedmsgMessageParser(messaging.known_fedmsg_services)
|
|
event_info = parser.parse(buildsys_tag_msg)
|
|
|
|
assert event_info["repo_tag"] == "module-f0f7e44f3c6cccab-build"
|