From 210663040bf65ee00b5f86545fdc31bd0356fddf Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期四, 27 八月 2026 16:31:53 +0800
Subject: [PATCH] feat(device): persist simulator discovery in redis
---
ruoyi-admin/src/test/java/com/ruoyi/config/DeviceAdapterRuntimeConfigTest.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/ruoyi-admin/src/test/java/com/ruoyi/config/DeviceAdapterRuntimeConfigTest.java b/ruoyi-admin/src/test/java/com/ruoyi/config/DeviceAdapterRuntimeConfigTest.java
index aa72eaa..cbceb70 100644
--- a/ruoyi-admin/src/test/java/com/ruoyi/config/DeviceAdapterRuntimeConfigTest.java
+++ b/ruoyi-admin/src/test/java/com/ruoyi/config/DeviceAdapterRuntimeConfigTest.java
@@ -6,24 +6,24 @@
import org.junit.jupiter.api.Test;
import org.springframework.boot.DefaultApplicationArguments;
import org.mockito.ArgumentCaptor;
-import com.ruoyi.system.domain.TDeviceAdapter;
-import com.ruoyi.system.service.IDeviceAdapterService;
+import com.ruoyi.device.registry.AdapterInstanceConfig;
+import com.ruoyi.device.registry.DeviceAdapterRegistry;
class DeviceAdapterRuntimeConfigTest
{
@Test
void registersDevelopmentSimulatorBeforeApplicationReady() throws Exception
{
- IDeviceAdapterService service = mock(IDeviceAdapterService.class);
- var runner = new DeviceAdapterRuntimeConfig().registerDevelopmentSimulatorAdapter(service);
+ DeviceAdapterRegistry registry = mock(DeviceAdapterRegistry.class);
+ var runner = new DeviceAdapterRuntimeConfig().registerDevelopmentSimulatorAdapter(registry);
runner.run(new DefaultApplicationArguments(new String[0]));
- ArgumentCaptor<TDeviceAdapter> adapter = ArgumentCaptor.forClass(TDeviceAdapter.class);
- verify(service).ensureManagedAdapter(adapter.capture());
- assertEquals("dev-sim", adapter.getValue().getAdapterCode());
- assertEquals("127.0.0.1", adapter.getValue().getHost());
- assertEquals(15020, adapter.getValue().getPort());
- assertEquals(5000, adapter.getValue().getPollIntervalMs());
+ ArgumentCaptor<AdapterInstanceConfig> adapter = ArgumentCaptor.forClass(AdapterInstanceConfig.class);
+ verify(registry).synchronize(adapter.capture());
+ assertEquals("dev-sim", adapter.getValue().adapterCode());
+ assertEquals("127.0.0.1", adapter.getValue().host());
+ assertEquals(15020, adapter.getValue().port());
+ assertEquals(5000, adapter.getValue().pollIntervalMs());
}
}
--
Gitblit v1.7.1