|
|
|
|
@ -1,135 +0,0 @@
|
|
|
|
|
using Grpc.Core;
|
|
|
|
|
using Grpc.Net.Client;
|
|
|
|
|
using ProtosLib.Statistics;
|
|
|
|
|
|
|
|
|
|
namespace ServiceLib.Services.Statistics
|
|
|
|
|
{
|
|
|
|
|
public class StatisticsV2rayService
|
|
|
|
|
{
|
|
|
|
|
private Models.Config _config;
|
|
|
|
|
private GrpcChannel? _channel;
|
|
|
|
|
private StatsService.StatsServiceClient? _client;
|
|
|
|
|
private bool _exitFlag;
|
|
|
|
|
private Action<ServerSpeedItem>? _updateFunc;
|
|
|
|
|
|
|
|
|
|
public StatisticsV2rayService(Models.Config config, Action<ServerSpeedItem> updateFunc)
|
|
|
|
|
{
|
|
|
|
|
_config = config;
|
|
|
|
|
_updateFunc = updateFunc;
|
|
|
|
|
_exitFlag = false;
|
|
|
|
|
|
|
|
|
|
GrpcInit();
|
|
|
|
|
|
|
|
|
|
Task.Run(Run);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void GrpcInit()
|
|
|
|
|
{
|
|
|
|
|
if (_channel is null)
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
_channel = GrpcChannel.ForAddress($"{Global.HttpProtocol}{Global.Loopback}:{AppHandler.Instance.StatePort}");
|
|
|
|
|
_client = new StatsService.StatsServiceClient(_channel);
|
|
|
|
|
}
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
{
|
|
|
|
|
Logging.SaveLog(ex.Message, ex);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void Close()
|
|
|
|
|
{
|
|
|
|
|
_exitFlag = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async void Run()
|
|
|
|
|
{
|
|
|
|
|
while (!_exitFlag)
|
|
|
|
|
{
|
|
|
|
|
await Task.Delay(1000);
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
if (!_config.IsRunningCore(ECoreType.Xray))
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
if (_channel?.State == ConnectivityState.Ready)
|
|
|
|
|
{
|
|
|
|
|
QueryStatsResponse? res = null;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
if (_client != null)
|
|
|
|
|
res = await _client.QueryStatsAsync(new QueryStatsRequest() { Pattern = "", Reset = true });
|
|
|
|
|
}
|
|
|
|
|
catch
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (res != null)
|
|
|
|
|
{
|
|
|
|
|
ParseOutput(res.Stat, out ServerSpeedItem server);
|
|
|
|
|
_updateFunc?.Invoke(server);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (_channel != null)
|
|
|
|
|
await _channel.ConnectAsync();
|
|
|
|
|
}
|
|
|
|
|
catch
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void ParseOutput(Google.Protobuf.Collections.RepeatedField<Stat> source, out ServerSpeedItem server)
|
|
|
|
|
{
|
|
|
|
|
server = new();
|
|
|
|
|
long aggregateProxyUp = 0;
|
|
|
|
|
long aggregateProxyDown = 0;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
foreach (Stat stat in source)
|
|
|
|
|
{
|
|
|
|
|
string name = stat.Name;
|
|
|
|
|
long value = stat.Value / 1024; //KByte
|
|
|
|
|
string[] nStr = name.Split(">>>".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
|
|
string type = "";
|
|
|
|
|
|
|
|
|
|
name = name.Trim();
|
|
|
|
|
|
|
|
|
|
name = nStr[1];
|
|
|
|
|
type = nStr[3];
|
|
|
|
|
|
|
|
|
|
if (name.StartsWith(Global.ProxyTag))
|
|
|
|
|
{
|
|
|
|
|
if (type == "uplink")
|
|
|
|
|
{
|
|
|
|
|
aggregateProxyUp += value;
|
|
|
|
|
}
|
|
|
|
|
else if (type == "downlink")
|
|
|
|
|
{
|
|
|
|
|
aggregateProxyDown += value;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
else if (name == Global.DirectTag)
|
|
|
|
|
{
|
|
|
|
|
if (type == "uplink")
|
|
|
|
|
{
|
|
|
|
|
server.DirectUp = value;
|
|
|
|
|
}
|
|
|
|
|
else if (type == "downlink")
|
|
|
|
|
{
|
|
|
|
|
server.DirectDown = value;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
server.ProxyUp = aggregateProxyUp;
|
|
|
|
|
server.ProxyDown = aggregateProxyDown;
|
|
|
|
|
}
|
|
|
|
|
catch
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
2dust
5 days ago