feat(device): persist simulator discovery in redis

yeg

2026-08-27 210663040bf65ee00b5f86545fdc31bd0356fddf

 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());
    }
}