73 lines
2.3 KiB
C#
73 lines
2.3 KiB
C#
using System.Text.Json;
|
|
using Common;
|
|
using LocalServer;
|
|
using RemoteServer;
|
|
using XUnit.Project.Attributes;
|
|
|
|
/*using Newtonsoft.Json;*/
|
|
|
|
namespace ServerTest;
|
|
|
|
public class PipeTest
|
|
{
|
|
[Fact]
|
|
public async void TestCase()
|
|
{
|
|
var p1 = new TestPipe(false, "1");
|
|
var x = Task.Run(async () =>
|
|
{
|
|
var rs = p1.Work(
|
|
(byte[] b) =>
|
|
{
|
|
var msg = JsonSerializer.Deserialize<SyncMsg>(b);
|
|
if (msg.Body == "·¢²¼Íê³É£¡")
|
|
{
|
|
p1.Close("Õý³£Í˳ö£¡");
|
|
}
|
|
Console.WriteLine(b);
|
|
return true;
|
|
}
|
|
);
|
|
await foreach (var r in rs)
|
|
{
|
|
Console.WriteLine(r);
|
|
}
|
|
});
|
|
//await p1.Close("sdf");
|
|
//await x;
|
|
var p2 = new TestPipe(false, "2");
|
|
p1.Other = p2;
|
|
p2.Other = p1;
|
|
var p3 = new TestPipe(true, "3");
|
|
var p4 = new TestPipe(true, "4");
|
|
p3.Other = p4;
|
|
p4.Other = p3;
|
|
LocalSyncServer.TempRootFile = "D:/FileSyncTest/stemp";
|
|
RemoteSyncServer.SqlPackageAbPath = "C:\\Users\\ZHAOLEI\\.dotnet\\tools\\sqlpackage.exe";
|
|
LocalSyncServer.MsdeployAbPath =
|
|
"C:\\Program Files\\IIS\\Microsoft Web Deploy V3\\msdeploy.exe";
|
|
LocalSyncServer.SqlPackageAbPath = "C:\\Users\\ZHAOLEI\\.dotnet\\tools\\sqlpackage.exe";
|
|
LocalSyncServer.MSBuildAbPath =
|
|
"C:\\Program Files\\Microsoft Visual Studio\\2022\\Community\\MSBuild\\Current\\Bin\\amd64\\MSBuild.exe";
|
|
RemoteSyncServer.TempRootFile = "D:/FileSyncTest/dtemp";
|
|
RemoteSyncServerFactory.NamePwd = [new Tuple<string, string>("Test", "t123")];
|
|
var lf = new LocalSyncServerFactory();
|
|
lf.CreateLocalSyncServer(p2, "Test", p3);
|
|
var rf = new RemoteSyncServerFactory();
|
|
rf.CreateRemoteSyncServer(p4, "Test");
|
|
TestPipe.syncServerFactory = rf;
|
|
var starter = new SyncMsg
|
|
{
|
|
Body = JsonSerializer.Serialize(new PipeSeed().TestConfig),
|
|
Type = SyncMsgType.General,
|
|
Step = SyncProcessStep.Connect
|
|
};
|
|
await p1.SendMsg(starter);
|
|
await x;
|
|
if (p1.ErrResult != "Õý³£Í˳ö£¡")
|
|
{
|
|
Assert.Fail(p1.ErrResult);
|
|
}
|
|
}
|
|
}
|