@@ -24,6 +24,7 @@ extern "C" {
2424#include " telemetry_busmessage_sender.h"
2525
2626T2ERROR getParamValue (const char * paramName, char **paramValue);
27+ void *cacheEventToFile (void *arg);
2728}
2829#include " ../mocks/rbusMock.h"
2930#include " ../mocks/SystemMock.h"
@@ -64,6 +65,15 @@ class TelemetryBusmessageSenderTest : public ::testing::Test {
6465 }
6566};
6667
68+ #ifdef GTEST_ENABLE
69+ extern " C" {
70+ typedef T2ERROR (*doPopulateEventMarkerListFunc)(void );
71+ doPopulateEventMarkerListFunc getDoPopulateEventMarkerListCallback (void );
72+ bool * test_get_isRbusEnabled_ptr (void );
73+ bool * test_get_isT2Ready_ptr (void );
74+ }
75+ #endif
76+
6777// Positive test: Init and Uninit
6878TEST_F (TelemetryBusmessageSenderTest, InitAndUninit) {
6979 t2_init ((char *)" test_component" );
@@ -230,6 +240,75 @@ TEST_F(TelemetryBusmessageSenderTest, t2_event_s_iscachingenabled_false)
230240 EXPECT_EQ (ret, T2ERROR_SUCCESS);
231241}
232242
243+ TEST_F (TelemetryBusmessageSenderTest, t2_event_d_iscachingenabled_false)
244+ {
245+ t2_init ((char *)" sysint" );
246+ EXPECT_CALL (*g_systemMock, access (_,_))
247+ .WillRepeatedly (Return (-1 ));
248+ EXPECT_CALL (*g_rbusMock, rbus_getUint (_, _, _))
249+ .Times (1 )
250+ .WillOnce ([](rbusHandle_t handle, const char * name, uint32_t * value) {
251+ *value = 0 ;
252+ return RBUS_ERROR_BUS_ERROR;
253+ });
254+
255+ int ret;
256+ ret = t2_event_d (" marker" , 13 );
257+ EXPECT_EQ (ret, T2ERROR_SUCCESS);
258+ }
259+
260+ TEST_F (TelemetryBusmessageSenderTest, t2_event_f_iscachingenabled_false)
261+ {
262+ t2_init ((char *)" sysint" );
263+ EXPECT_CALL (*g_systemMock, access (_,_))
264+ .WillRepeatedly (Return (-1 ));
265+ EXPECT_CALL (*g_rbusMock, rbus_getUint (_, _, _))
266+ .Times (1 )
267+ .WillOnce ([](rbusHandle_t handle, const char * name, uint32_t * value) {
268+ *value = 0 ;
269+ return RBUS_ERROR_BUS_ERROR;
270+ });
271+ int ret;
272+ ret = t2_event_f (" marker" , 123.456 );
273+ EXPECT_EQ (ret, T2ERROR_SUCCESS);
274+ }
275+
276+ TEST_F (TelemetryBusmessageSenderTest, t2_event_d_iscachingenabled_true)
277+ {
278+ t2_init ((char *)" sysint" );
279+
280+ EXPECT_CALL (*g_systemMock, access (_,_))
281+ .WillRepeatedly (Return (-1 )); // Accept any number of calls
282+
283+ EXPECT_CALL (*g_rbusMock, rbus_getUint (_, _, _))
284+ .Times (1 )
285+ .WillOnce ([](rbusHandle_t handle, const char * name, uint32_t * value) {
286+ *value = 0 ;
287+ return RBUS_ERROR_SUCCESS; // <-- Simulate SUCCESS
288+ });
289+
290+ int ret = t2_event_d (" marker" , 13 );
291+ EXPECT_EQ (ret, T2ERROR_SUCCESS);
292+ }
293+ TEST_F (TelemetryBusmessageSenderTest, t2_event_d_iscachingenabled_true_1)
294+ {
295+ t2_init ((char *)" sysinit" );
296+
297+ EXPECT_CALL (*g_systemMock, access (_,_))
298+ .WillRepeatedly (Return (-1 )); // Accept any number of calls
299+ EXPECT_CALL (*g_rbusMock, rbus_getUint (_, _, _))
300+ .Times (1 )
301+ .WillOnce ([](rbusHandle_t handle, const char * name, uint32_t * value) {
302+ *value = 1 ;
303+ return RBUS_ERROR_SUCCESS; // <-- Simulate SUCCESS
304+ });
305+ *test_get_isRbusEnabled_ptr () = false ;
306+ *test_get_isT2Ready_ptr () = true ;
307+ int ret = t2_event_d (" marker" , 13 );
308+
309+ *test_get_isRbusEnabled_ptr () = true ;
310+ EXPECT_EQ (ret, T2ERROR_SUCCESS);
311+ }
233312
234313TEST_F (TelemetryBusmessageSenderTest, getParameterValue_success)
235314{
@@ -270,6 +349,40 @@ TEST_F(TelemetryBusmessageSenderTest, getParameterValue_success_boolean)
270349
271350 EXPECT_EQ (T2ERROR_SUCCESS, getParamValue (" Device.DeviceInfo.SerialNumber" , ¶mValue));
272351}
352+
353+ TEST_F (TelemetryBusmessageSenderTest, getParameterValue_failure_boolean)
354+ {
355+ char * paramValue = NULL ;
356+ t2_init ((char *)" test_component" );
357+
358+ EXPECT_CALL (*g_rbusMock, rbus_get (_, _, _))
359+ .Times (1 )
360+ .WillOnce (Return (RBUS_ERROR_SUCCESS));
361+ EXPECT_CALL (*g_rbusMock, rbusValue_GetType (_))
362+ .Times (1 )
363+ .WillOnce (Return (RBUS_BOOLEAN));
364+ EXPECT_CALL (*g_rbusMock, rbusValue_GetBoolean (_))
365+ .Times (1 )
366+ .WillOnce (Return (false ));
367+ EXPECT_CALL (*g_rbusMock, rbusValue_Release (_))
368+ .Times (1 );
369+
370+ EXPECT_EQ (T2ERROR_SUCCESS, getParamValue (" Device.DeviceInfo.SerialNumber" , ¶mValue));
371+ }
372+
373+ #ifdef GTEST_ENABLE
374+ TEST_F (TelemetryBusmessageSenderTest, doPopulateEventMarkerList_ReturnsEarlyIfRbusDisabled) {
375+ t2_init ((char *)" test_component" );
376+
377+ *test_get_isRbusEnabled_ptr () = false ;
378+
379+ auto cb = getDoPopulateEventMarkerListCallback ();
380+ T2ERROR ret = cb ();
381+ EXPECT_EQ (ret, T2ERROR_SUCCESS);
382+ *test_get_isRbusEnabled_ptr () = true ;
383+ }
384+ #endif
385+
273386/*
274387TEST_F(TelemetryBusmessageSenderTest, filtered_event_send_1)
275388{
0 commit comments