Oshima-Studios/FunGame-Testing
3
0
Fork 0
mirror of https://github.com/milimoe/FunGame-Testing.git synced 2025-04-23 12:49:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

添加 WebSocket 测试

Browse Source
This commit is contained in:
milimoe 2025-01-10 19:44:59 +08:00
parent 7a565b0a33
commit 61f43402ec
Signed by: milimoe
GPG Key ID: 05D280912DA6C69E
2 changed files with 135 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Library/Main.cs
View File

@ -8,6 +8,8 @@ using Oshima.FunGame.OshimaModules;
using Oshima.FunGame.OshimaModules.Characters; using Oshima.FunGame.OshimaModules.Characters;
using Oshima.FunGame.OshimaModules.Effects.OpenEffects; using Oshima.FunGame.OshimaModules.Effects.OpenEffects;
_ = new Milimoe.FunGame.Testing.Tests.WebSocketTest();
CharacterModule cm = new(); CharacterModule cm = new();
cm.Load(); cm.Load();
SkillModule sm = new(); SkillModule sm = new();

157
Library/Tests/WebSocketTest.cs
View File

@ -1,42 +1,147 @@
using Milimoe.FunGame.Core.Api.Utility; using System.Collections;
using Milimoe.FunGame.Core.Api.Transmittal;
using Milimoe.FunGame.Core.Api.Utility;
using Milimoe.FunGame.Core.Controller;
using Milimoe.FunGame.Core.Entity;
using Milimoe.FunGame.Core.Library.Common.Network; using Milimoe.FunGame.Core.Library.Common.Network;
using Milimoe.FunGame.Core.Library.Constant;
namespace Milimoe.FunGame.Testing.Tests namespace Milimoe.FunGame.Testing.Tests
{ {
public class WebSocketTestRunTime : RunTimeController
{
public bool Quit { get; set; } = false;
public override bool BeforeConnect(ref string addr, ref int port, ArrayList args)
{
string[] strings = ["oshima.fungame.fastauto"];
args.Add(strings);
args.Add(false);
return true;
}
public override void AfterConnect(ArrayList ConnectArgs)
{
string msg = ConnectArgs[1]?.ToString() ?? "";
string serverName = ConnectArgs[2]?.ToString() ?? "";
string notice = ConnectArgs[3]?.ToString() ?? "";
if (msg != "") Console.WriteLine(msg);
if (serverName != "") Console.WriteLine(serverName);
if (notice != "") Console.WriteLine(notice);
}
public async Task StartTest()
{
await ConnectAsync(TransmittalType.WebSocket, "localhost", 5000, false, "ws");
}
public async Task CheckInput(string str)
{
if (WebSocket is null || Quit)
{
if (str == "retry")
{
if (await ConnectAsync(TransmittalType.WebSocket, "localhost", 5000, false, "ws") == ConnectResult.Success)
{
Console.WriteLine("重连成功！");
}
else
{
Console.WriteLine("重连失败！");
}
}
return;
}
if (str == "quit")
{
await WebSocket.Send(SocketMessageType.Disconnect);
}
if (str == "login")
{
DataRequest request = NewDataRequest(DataRequestType.Login_Login);
request.AddRequestData("username", "mili");
request.AddRequestData("password", Encryption.HmacSha512("123123", "Mili"));
request.AddRequestData("autokey", "");
request.AddRequestData("key", Guid.Empty);
await request.SendRequestAsync();
if (request.Result == RequestResult.Success)
{
string msg = request.GetResult<string>("msg") ?? "";
if (msg != "")
{
Console.WriteLine(msg);
}
else
{
Guid loginKey = request.GetResult<Guid>("key");
if (loginKey != Guid.Empty)
{
request = NewDataRequest(DataRequestType.Login_Login);
request.AddRequestData("username", "username");
request.AddRequestData("password", Encryption.HmacSha512("password", "username"));
request.AddRequestData("autokey", "");
request.AddRequestData("key", loginKey);
await request.SendRequestAsync();
if (request.Result == RequestResult.Success)
{
msg = request.GetResult<string>("msg") ?? "";
if (msg != "")
{
Console.WriteLine(msg);
}
else
{
User? user = request.GetResult<User>("user");
if (user != null)
{
Console.WriteLine("登录用户完成：" + user.Username);
}
}
}
}
}
}
}
}
public override void Error(Exception e)
{
Console.WriteLine(e.ToString());
}
public override void WritelnSystemInfo(string msg)
{
Console.WriteLine(msg);
}
protected override void SocketHandler_Disconnect(SocketObject ServerMessage)
{
Quit = true;
}
protected override void SocketHandler_HeartBeat(SocketObject ServerMessage)
{
Console.WriteLine("服务器连接成功");
}
}
public class WebSocketTest public class WebSocketTest
{ {
public WebSocketTest() public WebSocketTest()
{ {
bool quit = false; WebSocketTestRunTime runtime = new();
HTTPClient? client = null; TaskUtility.NewTask(runtime.StartTest).OnError(Console.WriteLine);
TaskUtility.NewTask(async () => while (!runtime.Quit)
{
string[] strings = ["oshima.fungame.fastauto"];
client = await HTTPClient.Connect("localhost", 5000, false, "ws", strings, false);
if (client.Connected)
{
client.AddSocketObjectHandler(obj =>
{
Console.WriteLine(NetworkUtility.JsonSerialize(obj));
if (obj.SocketType == Core.Library.Constant.SocketMessageType.Connect)
{
client.Token = obj.GetParam<Guid>(2);
}
if (obj.SocketType == Core.Library.Constant.SocketMessageType.Disconnect)
{
quit = true;
client.Close();
}
});
}
}).OnError(Console.WriteLine);
while (!quit)
{ {
string str = Console.ReadLine() ?? ""; string str = Console.ReadLine() ?? "";
TaskUtility.NewTask(async () => await runtime.CheckInput(str)).OnError(Console.WriteLine).OnCompleted(() =>
{
if (str == "quit") if (str == "quit")
{ {
client?.Send(Core.Library.Constant.SocketMessageType.Disconnect); Console.WriteLine("断开服务器连接成功！");
Console.ReadLine();
} }
});
} }
} }
} }