From 471948fd789591470b80ad2c9fb69f91de81f446 Mon Sep 17 00:00:00 2001 From: shifter Date: Wed, 15 Jan 2025 09:15:29 +0100 Subject: [PATCH] filterx: add light test for pubsub_message Signed-off-by: shifter --- .../functional_tests/filterx/test_filterx.py | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/tests/light/functional_tests/filterx/test_filterx.py b/tests/light/functional_tests/filterx/test_filterx.py index e08de0cd7..c9b02cf2c 100644 --- a/tests/light/functional_tests/filterx/test_filterx.py +++ b/tests/light/functional_tests/filterx/test_filterx.py @@ -2627,3 +2627,20 @@ def test_keys(config, syslog_ng): r""""direct_access":"foo"}""" + "\n" ) assert file_true.read_log() == exp + + +def test_pubsub_message(config, syslog_ng): + (file_true, file_false) = create_config( + config, r""" + $MSG = json(); + $MSG.msg = pubsub_message("my pubsub message", {"foo":"bar"}); + """, + ) + syslog_ng.start(config) + + assert file_true.get_stats()["processed"] == 1 + assert "processed" not in file_false.get_stats() + exp = ( + r"""{"msg":{"data":"bXkgcHVic3ViIG1lc3NhZ2U=","attributes":{"foo":"bar"}}}""" + "\n" + ) + assert file_true.read_log() == exp