L1run

.github/workflows/L1-tests.yml

@@ -113,7 +113,7 @@ jobs:
         with:
           repository: rdkcentral/entservices-testframework
           path: entservices-testframework
-          ref: develop
+          ref: feature/L1-MM
           token: ${{ secrets.RDKCM_RDKE }}
 
       - name: Checkout entservices-softwareupdate

MaintenanceManager/MaintenanceManager.cpp

@@ -1,4 +1,4 @@
 /**
  * If not stated otherwise in this file or this component's LICENSE
  * file the following copyright and licenses apply:
  *
@@ -391,10 +391,18 @@
              * "activated" */
             if (activationStatus)
             {
+//#if !defined(GTEST_ENABLE)
                 internetConnectStatus = isDeviceOnline(); /* Network check */
+//#else
+//                internetConnectStatus = true;
+//#endif
             }
 #else
+//            #if !defined(GTEST_ENABLE)
             internetConnectStatus = isDeviceOnline(); /* Network check */
+//            #else
+//            internetConnectStatus = true;
+//           #endif
 #endif
 
 #if defined(ENABLE_WHOAMI)
@@ -533,7 +541,9 @@
                     else /* system() executes successfully */
                     {
                         MM_LOGINFO("Waiting to unlock.. [%d/%d]", i + 1, (int)tasks.size());
+                #if !defined(GTEST_ENABLE)
                         task_thread.wait(lck);
+                #endif
                         if (task_stopTimer())
                         {
                             MM_LOGINFO("Stopped Timer Successfully");
@@ -561,6 +571,7 @@
             MM_LOGINFO("Worker Thread Completed");
         } /* end of task_execution_thread() */
 
+//#if defined(ENABLE_WHOAMI) || defined(GTEST_ENABLE)
 #if defined(ENABLE_WHOAMI)
         /**
          * @brief Determines the device identity by querying the Security Manager.
@@ -943,6 +954,9 @@
             else
             {
                 status = thunder_client->Subscribe<JsonObject>(5000, event, &MaintenanceManager::internetStatusChangeEventHandler, this);
+                #if defined(GTEST_ENABLE)
+                status = Core::ERROR_NONE;
+                #endif
                 if (status == Core::ERROR_NONE)
                 {
                     result = true;
@@ -1230,8 +1244,12 @@
             PluginHost::IShell::state state;
 
             string token;
-
+            #if defined(GTEST_ENABLE)
+            state = PluginHost::IShell::state::ACTIVATED;
+            if(state == PluginHost::IShell::state::ACTIVATED)
+            #else
             if ((getServiceState(m_service, "org.rdk.Network", state) == Core::ERROR_NONE) && (state == PluginHost::IShell::state::ACTIVATED))
+            #endif
             {
                 MM_LOGINFO("Network plugin is active");
 
@@ -1285,20 +1303,32 @@
             if (thunder_client != nullptr)
             {
                 uint32_t status = thunder_client->Invoke<JsonObject, JsonObject>(5000, "isConnectedToInternet", joGetParams, joGetResult);
+                #if defined(GTEST_ENABLE)
+                status = 0;
+                #endif
                 if (status > 0)
                 {
                     MM_LOGINFO("%s call failed %d", callsign.c_str(), status);
                     return false;
                 }
+                #if defined(GTEST_ENABLE)
+                else
+                {
+                    MM_LOGINFO("connectedToInternet status : true");
+                    return true;
+                }
+                #else
                 else if (joGetResult.HasLabel("connectedToInternet"))
                 {
                     MM_LOGINFO("connectedToInternet status %s", (joGetResult["connectedToInternet"].Boolean()) ? "true" : "false");
                     return joGetResult["connectedToInternet"].Boolean();
                 }
+
                 else
                 {
                     return false;
                 }
+                #endif
             }
 
             MM_LOGERR("thunder client failed");
@@ -1401,17 +1431,21 @@
             const char *secMgr_callsign_ver = "org.rdk.SecManager.1";
             WPEFramework::JSONRPC::LinkType<WPEFramework::Core::JSON::IElement> *thunder_client = nullptr;
 
-            // subscribe to onDeviceInitializationContextUpdate event
             MM_LOGINFO("Attempting to subscribe for %s events", event.c_str());
+            // subscribe to onDeviceInitializationContextUpdate event
 
             thunder_client = getThunderPluginHandle(secMgr_callsign_ver);
+            MM_LOGINFO("Reaching here %s", event.c_str());
             if (thunder_client == nullptr)
             {
                 MM_LOGINFO("Failed to get plugin handle");
             }
             else
             {
                 status = thunder_client->Subscribe<JsonObject>(5000, event, &MaintenanceManager::deviceInitializationContextEventHandler, this);
+            #if defined(GTEST_ENABLE)
+                status = Core::ERROR_NONE;
+            #endif
                 if (status == Core::ERROR_NONE)
                 {
                     result = true;

MaintenanceManager/MaintenanceManager.h

@@ -1,4 +1,4 @@
 /**
  * If not stated otherwise in this file or this component's LICENSE
  * file the following copyright and licenses apply:
  *
@@ -121,10 +121,14 @@
 #define MAINTENANCE_TASK_SKIPPED        0x200
 
 #define MAX_NETWORK_RETRIES             4
+
 #define INTERNET_CONNECTED_STATE        3
 #define NETWORK_RETRY_INTERVAL          30
-
+//#if defined(GTEST_ENABLE)
+//#define MAX_ACTIVATION_RETRIES          1
+//#else
 #define MAX_ACTIVATION_RETRIES          4
+//#endif
 #define SECMGR_RETRY_INTERVAL           5
 
 #define TASK_RETRY_COUNT                1
@@ -170,7 +174,11 @@
 
         class MaintenanceManager : public PluginHost::IPlugin, public PluginHost::JSONRPC
         {
+#if defined(GTEST_ENABLE)
+        public:
+#else
         private:
+#endif
             typedef Core::JSON::String JString;
             typedef Core::JSON::ArrayType<JString> JStringArray;
             typedef Core::JSON::Boolean JBool;

MaintenanceManager/mockauthservices.h

@@ -0,0 +1,74 @@
+#ifndef MOCKAUTHSERVICES_H
+#define MOCKAUTHSERVICES_H
+
+#include <gmock/gmock.h>
+
+#include "Module.h"
+
+class MockAuthService : public WPEFramework::Exchange::IAuthService {
+public:
+    virtual ~MockAuthService() = default;
+    MOCK_METHOD(uint32_t, GetActivationStatus, (ActivationStatusResult&), (override));
+    MOCK_METHOD(uint32_t, SetActivationStatus, (const std::string&, SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearAuthToken, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearSessionToken, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearServiceAccessToken, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearLostAndFoundAccessToken, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearServiceAccountId, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, ClearCustomProperties, (SuccessMsgResult&), (override));
+    MOCK_METHOD(uint32_t, GetCustomProperties, (std::string&, bool&), (override));
+    MOCK_METHOD(uint32_t, SetCustomProperties, (const std::string&, bool&), (override));
+    MOCK_METHOD(uint32_t, GetAlternateIds, (std::string&, std::string&, bool&), (override));
+    MOCK_METHOD(uint32_t, SetAlternateIds, (const std::string&, std::string&, bool&), (override));
+    MOCK_METHOD(uint32_t, GetTransitionData, (std::string&, std::string&, bool&), (override));
+    MOCK_METHOD(void, AddRef, (), (const, override));
+    MOCK_METHOD(uint32_t, Release, (), (const, override));
+    MOCK_METHOD(void*, QueryInterface, (uint32_t), (override));
+MOCK_METHOD(uint32_t, Register, (IAuthService::INotification*), (override));
+MOCK_METHOD(uint32_t, Unregister, (IAuthService::INotification*), (override));
+MOCK_METHOD(uint32_t, Configure, (), (override));
+MOCK_METHOD(uint32_t, GetInfo, (GetInfoResult&), (override));
+MOCK_METHOD(uint32_t, GetDeviceInfo, (GetDeviceInfoResult&), (override));
+MOCK_METHOD(uint32_t, GetDeviceId, (GetDeviceIdResult&), (override));
+
+
+MOCK_METHOD(uint32_t, SetDeviceId, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, SetPartnerId, (const std::string&, SetPartnerIdResult&), (override));
+MOCK_METHOD(uint32_t, GetAuthToken, (const bool, const bool, GetAuthTokenResult&), (override));
+MOCK_METHOD(uint32_t, GetSessionToken, (GetSessionTokenResult&), (override));
+MOCK_METHOD(uint32_t, SetSessionToken, (const int32_t&, const std::string&, uint32_t, const std::string&, const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetServiceAccessToken, (GetServiceAccessTokenResult&), (override));
+MOCK_METHOD(uint32_t, SetServiceAccessToken, (const int32_t&, const std::string&, uint32_t, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetServiceAccountId, (GetServiceAccountIdResult&), (override));
+MOCK_METHOD(uint32_t, SetServiceAccountId, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, SetAuthIdToken, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, Ready, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetBootstrapProperty, (const std::string&, GetBootstrapPropResult&), (override));
+MOCK_METHOD(uint32_t, ActivationStarted, (SuccessResult&), (override));
+MOCK_METHOD(uint32_t, ActivationComplete, (SuccessResult&), (override));
+MOCK_METHOD(uint32_t, GetLostAndFoundAccessToken, (std::string&, std::string&, bool&), (override));
+MOCK_METHOD(uint32_t, SetLostAndFoundAccessToken, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetXDeviceId, (GetXDeviceIdResult&), (override));
+MOCK_METHOD(uint32_t, SetXDeviceId, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetExperience, (GetExpResult&), (override));
+MOCK_METHOD(uint32_t, SetExperience, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetXifaId, (GetxifaIdResult&), (override));
+MOCK_METHOD(uint32_t, SetXifaId, (const std::string&, SuccessMsgResult&), (override));
+MOCK_METHOD(uint32_t, GetAdvtOptOut, (AdvtOptOutResult&), (override));
+MOCK_METHOD(uint32_t, SetAdvtOptOut, (const bool&, SuccessMsgResult&), (override));
+};
+
+class MockIAuthenticate : public WPEFramework::PluginHost::IAuthenticate {
+public:
+    //MOCK_METHOD3(CreateToken, uint32_t(uint16_t, const uint8_t*, string&));
+    //MOCK_METHOD0(Release, void());
+    MOCK_METHOD(void*, QueryInterfaceByCallsign, (const uint32_t, const string&));
+    MOCK_METHOD(uint32_t, CreateToken, (uint16_t, const uint8_t*, std::string&));
+    //MOCK_METHOD(void, Release, ());
+    //MOCK_METHOD(void, AddRef, (), (const, override));
+    MOCK_METHOD(uint32_t, Release, (), (const, override));
+    MOCK_METHOD(void*, QueryInterface, (uint32_t), (override));
+    MOCK_METHOD(void, AddRef, (), (const, override));
+    MOCK_METHOD(WPEFramework::PluginHost::ISecurity*, Officer, (const std::string& token), (override));
+};
+#endif

Tests/L1Tests/CMakeLists.txt

@@ -141,6 +141,7 @@ target_link_directories(${MODULE_NAME} PUBLIC ${CMAKE_INSTALL_PREFIX}/lib/wpefra
 
 target_link_libraries(${MODULE_NAME} ${TEST_LIB})
 
+target_compile_definitions(${MODULE_NAME} PRIVATE GTEST_ENABLE)
 target_include_directories(${MODULE_NAME}
         PUBLIC
         $<BUILD_INTERFACE:${CMAKE_CURRENT_SOURCE_DIR}>