using System;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Aging.Infrastructure.Drivers;
|
using CanSimulatorServer;
|
using Xunit;
|
|
namespace Aging.MvpTests
|
{
|
/// <summary>
|
/// 统一 CAN 驱动（CanDeviceDriver, TCP NodeChannel 后端）行为测试：
|
/// 在测试进程内托管模拟器服务，验证连接/发送/推送事件/本地缓冲查询/错误语义
|
/// 与调试面板现有解析格式（RECV_ALL:n:…、OK:TX…）保持兼容。
|
/// </summary>
|
public class CanDeviceDriverTests : IDisposable
|
{
|
private readonly TcpSimulatorHost _host;
|
|
public CanDeviceDriverTests()
|
{
|
_host = new TcpSimulatorHost();
|
_host.StartAsync().GetAwaiter().GetResult();
|
}
|
|
public void Dispose() => _host.Dispose();
|
|
private CanDeviceDriver NewDriver(string deviceId, string bus, int node) =>
|
new CanDeviceDriver(deviceId, $"{bus}:{node}", hostOverride: "127.0.0.1", portOverride: _host.Port);
|
|
[Fact]
|
public void ConnectAsync_OnRunningServer_Succeeds()
|
{
|
using var drv = NewDriver("CAN-T1", "CAN_BUS_1", 0);
|
drv.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
Assert.True(drv.IsConnected);
|
}
|
|
[Fact]
|
public void ConnectAsync_NoServer_ThrowsWithStartupHint()
|
{
|
// 指向必然空闲的端口：错误文案应引导用户启动模拟器服务
|
using var drv = new CanDeviceDriver("CAN-T2", "CAN_BUS_1:0", hostOverride: "127.0.0.1", portOverride: 1);
|
var ex = Assert.ThrowsAny<Exception>(() =>
|
drv.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult());
|
Assert.Contains("模拟器", ex.Message);
|
}
|
|
[Fact]
|
public void SendCommandAsync_ReturnsOkTx_ReadableByPanel()
|
{
|
using var drv = NewDriver("CAN-T3", "CAN_BUS_1", 1);
|
drv.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
|
string resp = drv.SendCommandAsync("SEND:0x100:AA BB", CancellationToken.None)
|
.GetAwaiter().GetResult();
|
Assert.StartsWith("OK:TX", resp);
|
}
|
|
[Fact]
|
public void Push_FromPeer_TriggersEvent_AndLocalRecvAll()
|
{
|
using var a = NewDriver("CAN-T4A", "CAN_BUS_1", 2);
|
using var b = NewDriver("CAN-T4B", "CAN_BUS_1", 3);
|
a.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
b.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
|
CanSimulator.CanFrame received = null;
|
a.DriverFrameReceived += (s, f) => received = f;
|
|
b.SendCommandAsync("SEND:0x222:11 22 33", CancellationToken.None).GetAwaiter().GetResult();
|
|
// 等待推送事件到达（读循环线程触发）
|
SpinWait.SpinUntil(() => received != null, 3000);
|
Assert.NotNull(received);
|
Assert.Equal("0x222", received.FrameIdHex);
|
|
// RECV_ALL 由驱动本地缓冲应答（不依赖服务端邮箱）
|
string all = a.QueryAsync("RECV_ALL", CancellationToken.None).GetAwaiter().GetResult();
|
Assert.StartsWith("RECV_ALL:1:", all);
|
Assert.Contains("0x222:11 22 33", all);
|
}
|
|
[Fact]
|
public void Query_AutoResponse_ProxiedToServer_ReturnsOk()
|
{
|
using var drv = NewDriver("CAN-T5", "CAN_BUS_1", 4);
|
drv.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
|
string resp = drv.QueryAsync("AUTO_RESPONSE:ON", CancellationToken.None).GetAwaiter().GetResult();
|
Assert.StartsWith("OK:", resp);
|
string back = drv.QueryAsync("AUTO_RESPONSE", CancellationToken.None).GetAwaiter().GetResult();
|
Assert.Contains("ON", back);
|
}
|
|
[Fact]
|
public void Query_Status_HasLegacyCompatibleFormat()
|
{
|
using var drv = NewDriver("CAN-T6", "CAN_BUS_1", 5);
|
drv.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
|
// 面板 GetStatValue 解析 "STATUS:Node=…, …, Rx=0, Tx=0, …"（逗号等号分隔）
|
string resp = drv.QueryAsync("STATUS", CancellationToken.None).GetAwaiter().GetResult();
|
Assert.StartsWith("STATUS:Node=", resp);
|
Assert.Contains("Tx=", resp);
|
Assert.Contains("Rx=", resp);
|
}
|
|
[Fact]
|
public void Connect_NodeBusy_ThrowsWithNodeIndexHint()
|
{
|
using var first = NewDriver("CAN-T7A", "CAN_BUS_1", 6);
|
first.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult();
|
|
using var second = NewDriver("CAN-T7B", "CAN_BUS_1", 6);
|
var ex = Assert.ThrowsAny<Exception>(() =>
|
second.ConnectAsync(CancellationToken.None).GetAwaiter().GetResult());
|
Assert.Contains("节点编号", ex.Message);
|
}
|
}
|
}
|
