From d559a537c615221e665a7c5617dc251726120e5d Mon Sep 17 00:00:00 2001 From: Dennis Yurasov Date: Wed, 15 Jan 2025 15:09:26 +0300 Subject: [PATCH] MT#55283 Added several useful fields for mqtt stats publishing Closes #1899 Change-Id: Ib7553a4aa173f460dc0a59b7bb1adbc4b98757b8 --- daemon/mqtt.c | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/daemon/mqtt.c b/daemon/mqtt.c index f01647b33..7053f86a2 100644 --- a/daemon/mqtt.c +++ b/daemon/mqtt.c @@ -347,8 +347,22 @@ static void mqtt_stream_stats(struct packet_stream *ps, JsonBuilder *json) { json_builder_set_member_name(json, "port"); json_builder_add_int_value(json, sfd->socket.local.port); + + json_builder_set_member_name(json, "endpoint_address"); + json_builder_add_string_value(json, sockaddr_print_buf(&ps->endpoint.address)); + + json_builder_set_member_name(json, "endpoint_port"); + json_builder_add_int_value(json, ps->endpoint.port); } + if (ps->crypto.params.crypto_suite) { + json_builder_set_member_name(json, "crypto_suite"); + json_builder_add_string_value(json, ps->crypto.params.crypto_suite->name); + } + + json_builder_set_member_name(json, "transcoding"); + json_builder_add_boolean_value(json, MEDIA_ISSET(ps->media, TRANSCODING) ? TRUE : FALSE); + json_builder_set_member_name(json, "ingress"); json_builder_begin_object(json); mqtt_stream_stats_dir(ps->stats_in, json);