更新

yeg

2026-09-30 47aece756f670dd80cf3d62be918f62a9ececf85

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
package com.battery.device.bts;
 
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
import java.time.Duration;
import java.time.ZoneId;
import java.util.Set;
import org.junit.jupiter.api.Test;
import com.battery.device.api.DeviceAdapter;
import com.battery.device.api.model.ChannelIdentity;
import com.battery.device.api.model.DeviceControlCommand;
import com.battery.device.api.model.DeviceWorkStatus;
 
class BtsDeviceAdapterContractTest
{
    @Test
    void observesCompleteReadOnlyContractWithoutSendingControlCommands() throws Exception
    {
        try (ScriptedBtsTcpSimulator simulator = new ScriptedBtsTcpSimulator();
             BtsTcpTransport transport = new BtsTcpTransport("127.0.0.1", simulator.port(),
                     Duration.ofSeconds(1), Duration.ofSeconds(2));
             DeviceAdapter adapter = new BtsDeviceAdapter("lab-bts", transport,
                     new BtsXmlCodec("lab-bts", ZoneId.of("Asia/Hong_Kong"))))
        {
            ChannelIdentity first = new ChannelIdentity("lab-bts", 22, 3, 2, 8);
            ChannelIdentity second = new ChannelIdentity("lab-bts", 22, 3, 1, 6);
            simulator.enqueue("<bts><cmd>getdevinfo_resp</cmd><middle count=\"2\">"
                    + "<channel ip=\"192.168.1.35\" devtype=\"22\" devid=\"3\" subdevid=\"2\" Channelid=\"8\">true</channel>"
                    + "<channel ip=\"192.168.1.36\" devtype=\"22\" devid=\"3\" subdevid=\"1\" Channelid=\"6\">true</channel>"
                    + "</middle></bts>");
            simulator.enqueue("<bts><cmd>inquire_resp</cmd><list count=\"2\">"
                    + "<inquire dev=\"22-3-2-8-0\" workstatus=\"working\" voltage=\"3.5\"/>"
                    + "<inquire dev=\"22-3-1-6-0\" workstatus=\"futureState\" voltage=\"3.6\"/>"
                    + "</list></bts>");
            assertEquals(2, adapter.discoverChannels().size());
            var snapshots = adapter.inquire(Set.of(first, second));
 
            assertTrue(adapter.capabilities().discovery());
            assertTrue(adapter.capabilities().realtimeObservation());
            assertFalse(adapter.capabilities().historyDownload());
            assertFalse(adapter.capabilities().control());
            assertEquals(DeviceWorkStatus.UNKNOWN, snapshots.get(second).workStatus());
            int observedRequests = simulator.requests().size();
            for (DeviceControlCommand command : DeviceControlCommand.values())
                assertThrows(UnsupportedOperationException.class, () -> adapter.control(first, command));
            assertEquals(observedRequests, simulator.requests().size());
            assertEquals(2, observedRequests);
        }
    }
 
    @Test
    void surfacesMalformedResponseScript() throws Exception
    {
        try (ScriptedBtsTcpSimulator simulator = new ScriptedBtsTcpSimulator();
             BtsTcpTransport transport = new BtsTcpTransport("127.0.0.1", simulator.port(),
                     Duration.ofSeconds(1), Duration.ofSeconds(1));
             DeviceAdapter adapter = new BtsDeviceAdapter("lab-bts", transport,
                     new BtsXmlCodec("lab-bts", ZoneId.of("Asia/Hong_Kong"))))
        {
            simulator.enqueue("<bts><cmd>getdevinfo_resp</cmd>");
 
            BtsProtocolException exception = assertThrows(BtsProtocolException.class, adapter::discoverChannels);
 
            assertEquals(BtsProtocolException.Reason.MALFORMED_XML, exception.reason());
        }
    }
 
}