apps/linker
1
0
Fork 0
mirror of https://github.com/snltty/linker.git synced 2025-10-05 09:06:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

183

Browse Source
This commit is contained in:
snltty
2025-06-14 20:50:30 +08:00
parent f20ea4f575
commit d28d46f837
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/linker.messenger.relay/messenger/RelayMessenger.cs
View File

@@ -113,7 +113,7 @@ namespace linker.messenger.relay.messenger
public async Task RelayAsk(IConnection connection) public async Task RelayAsk(IConnection connection)
{ {
RelayInfo info = serializer.Deserialize<RelayInfo>(connection.ReceiveRequestWrap.Payload.Span); RelayInfo info = serializer.Deserialize<RelayInfo>(connection.ReceiveRequestWrap.Payload.Span);
if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to)) if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to) == false)
{ {
connection.Write(serializer.Serialize(new RelayAskResultInfo { })); connection.Write(serializer.Serialize(new RelayAskResultInfo { }));
return; return;
@@ -128,7 +128,7 @@ namespace linker.messenger.relay.messenger
string error = await relayValidatorTransfer.Validate(info, from, to).ConfigureAwait(false); string error = await relayValidatorTransfer.Validate(info, from, to).ConfigureAwait(false);
bool validated = string.IsNullOrWhiteSpace(error); bool validated = string.IsNullOrWhiteSpace(error);
result.Nodes = relayServerTransfer.GetNodes(validated).Select(c => (RelayServerNodeReportInfo)c).ToList(); result.Nodes = relayServerTransfer.GetNodes(validated).Select(c => (RelayServerNodeReportInfo)c).ToList();
if (result.Nodes.Count > 0) if (result.Nodes.Count > 0)
{ {
result.FlowingId = relayServerTransfer.AddRelay(from.MachineId, from.MachineName, to.MachineId, to.MachineName, from.GroupId, validated, []); result.FlowingId = relayServerTransfer.AddRelay(from.MachineId, from.MachineName, to.MachineId, to.MachineName, from.GroupId, validated, []);
@@ -140,7 +140,7 @@ namespace linker.messenger.relay.messenger
public async Task RelayAsk170(IConnection connection) public async Task RelayAsk170(IConnection connection)
{ {
RelayInfo170 info = serializer.Deserialize<RelayInfo170>(connection.ReceiveRequestWrap.Payload.Span); RelayInfo170 info = serializer.Deserialize<RelayInfo170>(connection.ReceiveRequestWrap.Payload.Span);
if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to)) if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to) == false)
{ {
connection.Write(serializer.Serialize(new RelayAskResultInfo170 { })); connection.Write(serializer.Serialize(new RelayAskResultInfo170 { }));
return; return;
@@ -193,7 +193,7 @@ namespace linker.messenger.relay.messenger
} }
public async Task RelayForward(IConnection connection, RelayInfo info, ushort id, Func<byte[]> data) public async Task RelayForward(IConnection connection, RelayInfo info, ushort id, Func<byte[]> data)
{ {
if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to)) if (signCaching.TryGet(connection.Id, info.RemoteMachineId, out SignCacheInfo from, out SignCacheInfo to) == false)
{ {
connection.Write(Helper.FalseArray); connection.Write(Helper.FalseArray);
return; return;

2
version.txt
View File

@@ -1,5 +1,5 @@
v1.8.3 v1.8.3
2025-06-14 19:40:51 2025-06-14 20:50:30
1. 一些累计更新 1. 一些累计更新
2. 修复socks5，解决CPU爆满问题，增加本地域名解析，支持HTTP代理 2. 修复socks5，解决CPU爆满问题，增加本地域名解析，支持HTTP代理
3. 优化唤醒模块 3. 优化唤醒模块