Solar/Swarm
2
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

👔 Remove the activity timeout control, make client send heartbeat instead

Browse Source
This commit is contained in:
LittleSheep
2025-07-29 17:06:19 +08:00
parent 83059374e9
commit 4246fea03f
2 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
DysonNetwork.Gateway/RegistryProxyConfigProvider.cs
View File

@@ -91,10 +91,6 @@ public class RegistryProxyConfigProvider : IProxyConfigProvider, IDisposable
{ {
{ "destination1", new DestinationConfig { Address = serviceUrl } } { "destination1", new DestinationConfig { Address = serviceUrl } }
}, },
HttpRequest = new ForwarderRequestConfig
{
ActivityTimeout = directRoute.IsWebSocket ? TimeSpan.FromHours(24) : TimeSpan.FromMinutes(2)
}
}; };
clusters.Add(cluster); clusters.Add(cluster);
} }
@@ -104,7 +100,6 @@ public class RegistryProxyConfigProvider : IProxyConfigProvider, IDisposable
RouteId = $"direct-{directRoute.Service}-{directRoute.Path.Replace("/", "-")}", RouteId = $"direct-{directRoute.Service}-{directRoute.Path.Replace("/", "-")}",
ClusterId = directRoute.Service, ClusterId = directRoute.Service,
Match = new RouteMatch { Path = directRoute.Path }, Match = new RouteMatch { Path = directRoute.Path },
Timeout = directRoute.IsWebSocket ? null : TimeSpan.FromSeconds(5),
}; };
routes.Add(route); routes.Add(route);
_logger.LogInformation(" Added Direct Route: {Path} -> {Service}", directRoute.Path, _logger.LogInformation(" Added Direct Route: {Path} -> {Service}", directRoute.Path,
@@ -232,7 +227,6 @@ public class RegistryProxyConfigProvider : IProxyConfigProvider, IDisposable
{ {
public required string Path { get; set; } public required string Path { get; set; }
public required string Service { get; set; } public required string Service { get; set; }
public bool IsWebSocket { get; set; } = false;
} }
public virtual void Dispose() public virtual void Dispose()
@@ -242,4 +236,4 @@ public class RegistryProxyConfigProvider : IProxyConfigProvider, IDisposable
_watchCts.Cancel(); _watchCts.Cancel();
_watchCts.Dispose(); _watchCts.Dispose();
} }
} }

3
DysonNetwork.Gateway/Startup/ServiceCollectionExtensions.cs
View File

@@ -18,7 +18,6 @@ public static class ServiceCollectionExtensions
var caCert = X509CertificateLoader.LoadCertificateFromFile(configuration["CaCert"]!); var caCert = X509CertificateLoader.LoadCertificateFromFile(configuration["CaCert"]!);
handler.SslOptions = new SslClientAuthenticationOptions handler.SslOptions = new SslClientAuthenticationOptions
{ {
// TODO: check the ca in the future, for now just trust it, i need sleep
RemoteCertificateValidationCallback = (sender, cert, chain, errors) => true RemoteCertificateValidationCallback = (sender, cert, chain, errors) => true
}; };
}); });
@@ -28,4 +27,4 @@ public static class ServiceCollectionExtensions
return services; return services;
} }
} }