[checkmk-commits] Added test cases for event cancelling

Module: check_mk Branch: master Commit: 49c51f94bb1227b4cbdad90ecc2793420babe096 URL: http://git.mathias-kettner.de/git/?p=check_mk.git;a=commit;h=49c51f94bb1227… Author: Lars Michelsen <lm(a)mathias-kettner.de> Date: Wed Oct 4 10:17:19 2017 +0200 Added test cases for event cancelling Change-Id: I0a7df86c111e601da1458ae9b68adaa413a49df6 --- tests/mkeventd/test_mkeventd_status.py | 31 ++++++++----------------------- tests/testlib/__init__.py | 25 +++++++++++++++++++++++++ 2 files changed, 33 insertions(+), 23 deletions(-) diff --git a/tests/mkeventd/test_mkeventd_status.py b/tests/mkeventd/test_mkeventd_status.py index af608c8..b3d5a17 100644 --- a/tests/mkeventd/test_mkeventd_status.py +++ b/tests/mkeventd/test_mkeventd_status.py @@ -4,7 +4,7 @@ import pytest import time import ast -from testlib import web, ec, cmk_path +from testlib import web, ec, cmk_path, CMKEventConsole # # UNIT TESTS @@ -76,29 +76,14 @@ def test_handle_client(status_server, event_status): def test_mkevent_check_query_perf(config, status_server, event_status, perfcounters): - def new_event(num): - return { - "rule_id": 815, - "text": "%s %s BLA BLUB DINGELING ABASD AD R#@A AR@AR A@ RA@R A@RARAR ARKNLA@RKA@LRKNA@KRLNA@RLKNA@äRLKA@RNKAL@R" \ - " j:O#A@J$ KLA@J $L:A@J :AMW: RAMR@: RMA@:LRMA@ L:RMA@ :AL@R MA:L@RM A@:LRMA@ :RLMA@ R:LA@RMM@RL:MA@R: AM@" % \ - (time.time(), num), - "phase": "open", - "count": 1, - "time": time.time(), - "first": time.time(), - "last": time.time(), - "comment": "", - "host": "heute-%d" % num, - "ipaddress": "127.0.0.1", - "application": "", - "pid": 0, - "priority": 3, - "facility": 1, # user - "match_groups": (), - } - for n in range(10000): - event_status.new_event(new_event(n)) + event_status.new_event(CMKEventConsole.new_event({ + "host": "heute-%d" % num, + "text": "%s %s BLA BLUB DINGELING ABASD AD R#@A AR@AR A@ RA@R A@RARAR ARKNLA@RKA@LRKNA@KRLNA@RLKNA@äRLKA@RNKAL@R" \ + " j:O#A@J$ KLA@J $L:A@J :AMW: RAMR@: RMA@:LRMA@ L:RMA@ :AL@R MA:L@RM A@:LRMA@ :RLMA@ R:LA@RMM@RL:MA@R: AM@" % \ + (time.time(), num), + })) + assert len(event_status.events()) == 10000 s = FakeStatusSocket("GET events\n" diff --git a/tests/testlib/__init__.py b/tests/testlib/__init__.py index 6a3c99d..195c346 100644 --- a/tests/testlib/__init__.py +++ b/tests/testlib/__init__.py @@ -1289,6 +1289,31 @@ class CMKEventConsole(CMKWebSession): assert config_reloaded() + @classmethod + def new_event(cls, attrs): + default_event = { + "rule_id": 815, + "text": "", + "phase": "open", + "count": 1, + "time": time.time(), + "first": time.time(), + "last": time.time(), + "comment": "", + "host": "test-host", + "ipaddress": "127.0.0.1", + "application": "", + "pid": 0, + "priority": 3, + "facility": 1, # user + "match_groups": (), + } + + event = default_event.copy() + event.update(attrs) + return event + + class CMKEventConsoleStatus(object): def __init__(self, address):