| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Test |
|---|
| | | void restoresChannelPlanWhenRedisReturnsNestedJsonObjects() |
|---|
| | | { |
|---|
| | | JSONObject state = JSON.parseObject(JSON.toJSONString(state(1, "127.0.0.2"))); |
|---|
| | | JSONObject configuration = state.getJSONArray("devices").getJSONObject(0) |
|---|
| | | .getJSONArray("channels").getJSONObject(0).getJSONObject("configuration"); |
|---|
| | | configuration.getJSONArray("steps").forEach(item -> ((JSONObject) item).put("@type", JSONObject.class.getName())); |
|---|
| | | FastJson2JsonRedisSerializer<Object> serializer = new FastJson2JsonRedisSerializer<>(Object.class); |
|---|
| | | Object restoredValue = serializer.deserialize(serializer.serialize(state)); |
|---|
| | | |
|---|
| | | SimulatorState restored = store(new AtomicReference<>(restoredValue)) |
|---|
| | | .loadOrInitialize(state(9, "127.0.0.9")); |
|---|
| | | |
|---|
| | | assertEquals("恒流充电", restored.devices().get(0).channels().get(0) |
|---|
| | | .configuration().steps().get(0).name()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Test |
|---|
| | | void upgradesLegacyCollectorDiscoveryStateWithSamplingDefaults() |
|---|
| | | { |
|---|
| | | AtomicReference<Object> stored = new AtomicReference<>("{\"version\":1,\"devices\":[]," |
|---|
