-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathProgram.cs
More file actions
78 lines (70 loc) · 1.92 KB
/
Copy pathProgram.cs
File metadata and controls
78 lines (70 loc) · 1.92 KB
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
71
72
73
74
75
76
77
78
using ForzaUdpMock;
using System.Net;
using System.Net.Sockets;
string targetIp = "127.0.0.1";
int targetPort = 5300;
int hz = 60;
int engineMaxRpm = 10_000;
for (int i = 0; i < args.Length; i++)
{
switch (args[i])
{
case "--ip" when i + 1 < args.Length:
targetIp = args[++i];
break;
case "--port" when i + 1 < args.Length:
targetPort = int.Parse(args[++i]);
break;
case "--hz" when i + 1 < args.Length:
hz = int.Parse(args[++i]);
break;
case "--max-rpm" when i + 1 < args.Length:
engineMaxRpm = int.Parse(args[++i]);
break;
}
}
var baseMessage = new Message
{
Game = EGame.FH4,
EngineMaxRpm = engineMaxRpm,
EngineIdleRpm = 1_000,
IsRaceOn = 1,
};
var endpoint = new IPEndPoint(IPAddress.Parse(targetIp), targetPort);
using var udpClient = new UdpClient();
var cts = new CancellationTokenSource();
var senderTask = Task.Run(async () =>
{
using var timer = new PeriodicTimer(TimeSpan.FromSeconds(1.0 / hz));
try
{
while (await timer.WaitForNextTickAsync(cts.Token))
{
byte[] packet;
lock (baseMessage)
{
packet = baseMessage.GetPacket();
}
await udpClient.SendAsync(packet, endpoint, cts.Token);
}
}
catch (OperationCanceledException) { }
});
Console.WriteLine($"Sending FH4 packets to {targetIp}:{targetPort} at {hz} Hz.");
Console.WriteLine("Type an RPM value and press Enter, or 'q' to quit.");
while (true)
{
string? line = Console.ReadLine();
if (line == null || line.Equals("q", StringComparison.OrdinalIgnoreCase))
break;
if (float.TryParse(line, out float rpm))
{
lock (baseMessage)
{
baseMessage.CurrentEngineRpm = rpm;
}
Console.WriteLine($"CurrentEngineRpm => {rpm}");
}
}
cts.Cancel();
await senderTask;