From d35dc5da0495154b09be3ab350f40f04b0cae970 Mon Sep 17 00:00:00 2001 From: James Rich Date: Wed, 6 May 2026 18:02:00 -0500 Subject: [PATCH] fix: update MqttManagerImplTest for nodeRepository constructor param After rebase, MqttManagerImpl gained a nodeRepository parameter. Updated test to mock and pass the new dependency. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --- .../org/meshtastic/core/data/manager/MqttManagerImplTest.kt | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MqttManagerImplTest.kt b/core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MqttManagerImplTest.kt index 66b1a6d2d..294f9f06a 100644 --- a/core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MqttManagerImplTest.kt +++ b/core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MqttManagerImplTest.kt @@ -35,6 +35,7 @@ import okio.ByteString.Companion.toByteString import org.meshtastic.core.model.MqttConnectionState import org.meshtastic.core.network.repository.MQTTRepository import org.meshtastic.core.repository.PacketHandler +import org.meshtastic.core.repository.NodeRepository import org.meshtastic.core.testing.FakeServiceRepository import org.meshtastic.mqtt.ConnectionState import org.meshtastic.mqtt.MqttException @@ -58,6 +59,7 @@ class MqttManagerImplTest { private lateinit var mqttRepository: MQTTRepository private lateinit var packetHandler: PacketHandler private lateinit var serviceRepository: FakeServiceRepository + private lateinit var nodeRepository: NodeRepository private lateinit var serviceScope: TestScope private lateinit var connectionStateFlow: MutableStateFlow private lateinit var proxyMessageFlow: MutableSharedFlow @@ -73,6 +75,7 @@ class MqttManagerImplTest { mqttRepository = mock(MockMode.autofill) packetHandler = mock(MockMode.autofill) serviceRepository = FakeServiceRepository() + nodeRepository = mock(MockMode.autofill) publishCalls.clear() every { mqttRepository.connectionState } returns connectionStateFlow @@ -87,7 +90,7 @@ class MqttManagerImplTest { } every { packetHandler.sendToRadio(any()) } returns Unit - mqttManager = MqttManagerImpl(mqttRepository, packetHandler, serviceRepository, serviceScope) + mqttManager = MqttManagerImpl(mqttRepository, packetHandler, serviceRepository, nodeRepository, serviceScope) } @AfterTest