|
1 | 1 | using NetworkLibrary.Components; |
| 2 | +using NetworkLibrary.Components.Statistics; |
2 | 3 | using ProtoBuf; |
3 | 4 | using Protobuff; |
4 | 5 | using Protobuff.P2P; |
| 6 | +using System; |
5 | 7 | using System.Security.Cryptography.X509Certificates; |
| 8 | +using System.Text.Json; |
6 | 9 |
|
7 | 10 | namespace RrlayServerTest |
8 | 11 | { |
9 | 12 | //KFtyEu7h6E |
10 | | - internal class Program |
| 13 | + public class Adress |
11 | 14 | { |
12 | | - [ProtoContract] |
13 | | - public class PeerList |
14 | | - { |
15 | | - [ProtoMember(1)] |
16 | | - public Guid asd; |
| 15 | + public string ip { get; set; } |
| 16 | + public string country { get; set; } |
| 17 | + public string cc { get; set; } |
| 18 | + } |
17 | 19 |
|
| 20 | + public class UpdateAdress |
| 21 | + { |
| 22 | + public string Ip { get; set; } |
18 | 23 |
|
19 | | - } |
| 24 | + public string Id { get; set; } |
| 25 | + } |
| 26 | + |
| 27 | + internal class Program |
| 28 | + |
| 29 | + { |
| 30 | + private static readonly string uri = @"http://localhost:8001/"; |
| 31 | + static ManualResetEvent m = new ManualResetEvent(false); |
| 32 | + |
20 | 33 | static void Main(string[] args) |
21 | 34 | { |
22 | 35 |
|
23 | 36 | var scert = new X509Certificate2("server.pfx", "greenpass"); |
24 | 37 | var server = new SecureProtoRelayServer(20011, 1000, scert); |
| 38 | + Task.Run(async () => { |
| 39 | + while (true) |
| 40 | + { |
| 41 | + try |
| 42 | + { |
| 43 | + HttpClient cl = new HttpClient(); |
| 44 | + |
| 45 | + var uri_ = @"https://api.myip.com"; |
| 46 | + var result = await cl.GetAsync(uri_); |
| 47 | + var str = await result.Content.ReadAsStringAsync(); |
| 48 | + |
| 49 | + var IPinfo = JsonSerializer.Deserialize<Adress>(str); |
| 50 | + var update = new UpdateAdress() |
| 51 | + { |
| 52 | + Ip = IPinfo.ip, |
| 53 | + Id = "IPass" |
| 54 | + }; |
| 55 | + |
| 56 | + var updateMsg = JsonSerializer.Serialize(update); |
| 57 | + await cl.PostAsync(uri, new StringContent(updateMsg)); |
| 58 | + await Task.Delay(60000); |
| 59 | + } |
| 60 | + catch (Exception ex) { } |
| 61 | + |
| 62 | + |
| 63 | + } |
| 64 | + |
| 65 | + |
| 66 | + |
| 67 | + }); |
25 | 68 | Task.Run(async () => |
26 | 69 | { |
27 | 70 | while (true) |
28 | 71 | { |
29 | 72 | await Task.Delay(1000); |
30 | 73 | server.GetTcpStatistics(out SessionStats generalStats, out var a); |
31 | 74 | server.GetUdpStatistics(out UdpStatistics generalStatsU, out _); |
32 | | - (int left,int right )=Console.GetCursorPosition(); |
| 75 | + (int left, int right) = Console.GetCursorPosition(); |
33 | 76 | Console.Clear(); |
34 | | - Console.WriteLine("Session Count: "+a.Count); |
| 77 | + Console.WriteLine("Session Count: " + a.Count); |
35 | 78 | Console.WriteLine(generalStats.ToString()); |
36 | 79 | Console.WriteLine(generalStatsU.ToString()); |
37 | | - if(left != 0 && right != 0) |
| 80 | + if (left != 0 && right != 0) |
38 | 81 | Console.SetCursorPosition(left, right); |
39 | 82 | } |
40 | 83 |
|
41 | 84 | }); |
| 85 | + |
| 86 | + m.WaitOne(); |
42 | 87 | while (Console.ReadLine() != "e") |
43 | 88 | { |
44 | 89 |
|
|
0 commit comments