| | |
|---|
| | | { |
|---|
| | | simulator.updateChannel(1, 1, true, DeviceWorkStatus.PROTECTED); |
|---|
| | | simulator.updateCollectorChannelStatus(1, "S-01", DeviceWorkStatus.UNOBSERVABLE); |
|---|
| | | var collector = simulator.latestCollector("dev-sim-collector-1"); |
|---|
| | | var collector = simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1"); |
|---|
| | | assertTrue(collector.measurements().stream().noneMatch(item -> item.channelCode().equals("S-01"))); |
|---|
| | | firstSequence = collector.measurements().get(0).sequenceId(); |
|---|
| | | simulator.setSoftwareAccessible(false); |
|---|
| | |
|---|
| | | assertEquals(DeviceWorkStatus.PROTECTED, restored.snapshot().devices().get(0).channels().get(0).workStatus()); |
|---|
| | | assertTrue(restored.snapshot().collectors().get(0).latestMeasurements().isEmpty()); |
|---|
| | | restored.setSoftwareAccessible(true); |
|---|
| | | assertTrue(restored.latestCollector("dev-sim-collector-1").measurements().get(0).sequenceId() > firstSequence); |
|---|
| | | assertTrue(restored.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().get(0).sequenceId() > firstSequence); |
|---|
| | | assertEquals(DeviceWorkStatus.UNOBSERVABLE, restored.snapshot().collectors().get(0).channels().get(0).workStatus()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | simulator.updateChannel(1, 1, true, DeviceWorkStatus.WORKING); |
|---|
| | | var first = simulator.latestCabinet(channel); |
|---|
| | | assertNotNull(first); |
|---|
| | | assertFalse(simulator.latestCollector("dev-sim-collector-1").measurements().isEmpty()); |
|---|
| | | assertFalse(simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().isEmpty()); |
|---|
| | | simulator.setSoftwareAccessible(false); |
|---|
| | | assertEquals(channel, simulator.discoverChannels().get(0).identity()); |
|---|
| | | assertTrue(simulator.snapshot().devices().get(0).online()); |
|---|
| | | assertEquals(DeviceWorkStatus.UNOBSERVABLE, |
|---|
| | | simulator.observe(java.util.Set.of(channel)).get(channel).workStatus()); |
|---|
| | | assertNull(simulator.latestCabinet(channel)); |
|---|
| | | assertTrue(simulator.latestCollector("dev-sim-collector-1").measurements().isEmpty()); |
|---|
| | | assertTrue(simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().isEmpty()); |
|---|
| | | simulator.setSoftwareAccessible(true); |
|---|
| | | var next = simulator.latestCabinet(channel); |
|---|
| | | assertTrue(next.sequenceId() > first.sequenceId()); |
|---|
