Leahnaya/NHSE
1
0
Fork 0
mirror of https://github.com/kwsch/NHSE.git synced 2026-10-02 14:56:38 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update to .NET 10 (#683)

Browse Source
This commit is contained in:
Kurt
2026-01-13 16:02:58 -06:00
committed by GitHub
parent 63bd5f643c
commit fa3f0e3cc8
316 changed files with 31897 additions and 32159 deletions
Download Patch File Download Diff File Expand all files Collapse all files

143
NHSE.Injection/SysBot/SysBot.cs
View File

@@ -1,84 +1,83 @@
using System.Net.Sockets;
using System.Threading;
namespace NHSE.Injection
namespace NHSE.Injection;
public class SysBot : IRAMReadWriter
{
public class SysBot : IRAMReadWriter
public string IP = "192.168.1.65";
public int Port = 6000;
public Socket Connection = new(SocketType.Stream, ProtocolType.Tcp);
public bool Connected { get; private set; }
private readonly Lock _sync = new();
public void Connect(string ip, int port)
{
public string IP = "192.168.1.65";
public int Port = 6000;
public Socket Connection = new(SocketType.Stream, ProtocolType.Tcp);
public bool Connected { get; private set; }
private readonly object _sync = new();
public void Connect(string ip, int port)
IP = ip;
Port = port;
lock (_sync)
{
IP = ip;
Port = port;
lock (_sync)
{
Connection = new Socket(SocketType.Stream, ProtocolType.Tcp);
Connection.Connect(IP, Port);
Connected = true;
}
}
public void Disconnect()
{
lock (_sync)
{
Connection.Disconnect(false);
Connected = false;
}
}
private int ReadInternal(byte[] buffer)
{
int br = Connection.Receive(buffer, 0, 1, SocketFlags.None);
while (buffer[br - 1] != (byte)'\n')
br += Connection.Receive(buffer, br, 1, SocketFlags.None);
return br;
}
private int SendInternal(byte[] buffer) => Connection.Send(buffer);
public int Read(byte[] buffer)
{
lock (_sync)
return ReadInternal(buffer);
}
public byte[] ReadBytes(uint offset, int length)
{
lock (_sync)
{
var cmd = SwitchCommand.Peek(offset, length);
SendInternal(cmd);
// give it time to push data back
Thread.Sleep((length / 256) + 100);
var buffer = new byte[(length * 2) + 1];
var _ = ReadInternal(buffer);
return Decoder.ConvertHexByteStringToBytes(buffer);
}
}
public void WriteBytes(byte[] data, uint offset)
{
lock (_sync)
{
SendInternal(SwitchCommand.Poke(offset, data));
// give it time to push data back
Thread.Sleep((data.Length / 256) + 100);
}
Connection = new Socket(SocketType.Stream, ProtocolType.Tcp);
Connection.Connect(IP, Port);
Connected = true;
}
}
public enum InjectionType
public void Disconnect()
{
Generic,
Pouch,
lock (_sync)
{
Connection.Disconnect(false);
Connected = false;
}
}
private int ReadInternal(byte[] buffer)
{
int br = Connection.Receive(buffer, 0, 1, SocketFlags.None);
while (buffer[br - 1] != (byte)'\n')
br += Connection.Receive(buffer, br, 1, SocketFlags.None);
return br;
}
private int SendInternal(byte[] buffer) => Connection.Send(buffer);
public int Read(byte[] buffer)
{
lock (_sync)
return ReadInternal(buffer);
}
public byte[] ReadBytes(uint offset, int length)
{
lock (_sync)
{
var cmd = SwitchCommand.Peek(offset, length);
SendInternal(cmd);
// give it time to push data back
Thread.Sleep((length / 256) + 100);
var buffer = new byte[(length * 2) + 1];
_ = ReadInternal(buffer);
return Decoder.ConvertHexByteStringToBytes(buffer);
}
}
public void WriteBytes(byte[] data, uint offset)
{
lock (_sync)
{
SendInternal(SwitchCommand.Poke(offset, data));
// give it time to push data back
Thread.Sleep((data.Length / 256) + 100);
}
}
}
public enum InjectionType
{
Generic,
Pouch,
}