diff --git a/android/app/src/main/java/com/naviapp/registration/usecase/RealTimeMessagingInitUseCase.kt b/android/app/src/main/java/com/naviapp/registration/usecase/RealTimeMessagingInitUseCase.kt index 3cd7512bbf..962a4ae602 100644 --- a/android/app/src/main/java/com/naviapp/registration/usecase/RealTimeMessagingInitUseCase.kt +++ b/android/app/src/main/java/com/naviapp/registration/usecase/RealTimeMessagingInitUseCase.kt @@ -8,6 +8,7 @@ package com.naviapp.registration.usecase import com.navi.analytics.utils.NaviTrackEvent +import com.navi.base.utils.BaseUtils import com.navi.base.utils.coroutine.CoroutineManager import com.navi.common.model.ModuleName import com.navi.common.utils.deviceId @@ -34,26 +35,30 @@ constructor( fun initSdks(naeScreenName: String) { CoroutineManager.scope.launchOnIO { - val response = - configRepository.fetchKruzConfig( - ModuleName.KRUZ_PROXY.name, - naeScreenName = naeScreenName, - ) + if (BaseUtils.isUserLoggedIn()) { + val response = + configRepository.fetchKruzConfig( + ModuleName.KRUZ_PROXY.name, + naeScreenName = naeScreenName, + ) - if (!response.isValidResponse()) { - trackError(response.error?.message.orEmpty()) - return@launchOnIO + if (!response.isValidResponse()) { + trackError(response.error?.message.orEmpty()) + return@launchOnIO + } + + val data = + response.data + ?: run { + trackError(MSG_RESPONSE_DATA_NULL) + return@launchOnIO + } + + setupMqttIfEnabled(data) + setupFcmTopics(data.fcmTopics) + } else { + setupFcmTopics(null) } - - val data = - response.data - ?: run { - trackError(MSG_RESPONSE_DATA_NULL) - return@launchOnIO - } - - setupMqttIfEnabled(data) - setupFcmTopics(data.fcmTopics) } } @@ -70,7 +75,7 @@ constructor( MqttManager.init( NaviApplication.instance, MqttSdkInitParams( - username = BuildConfig.MQTT_USERNAME, + username = data.username ?: BuildConfig.MQTT_USERNAME, password = BuildConfig.MQTT_PASSWORD, clientId = deviceId, brokerIP = data.brokerIP.orEmpty(),