Oda/managing-apps
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Disable workers

Browse Source
This commit is contained in:
cryptooda
2025-04-26 01:31:47 +07:00
parent 5eb401dc80
commit de25791eb4
2 changed files with 9 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Managing.Api.Workers/Program.cs
View File

@@ -152,7 +152,7 @@ builder.Services.AddSwaggerGen(options =>
builder.WebHost.SetupDiscordBot(); builder.WebHost.SetupDiscordBot();
// builder.Services.AddHostedService<FeeWorker>(); // builder.Services.AddHostedService<FeeWorker>();
// builder.Services.AddHostedService<PositionManagerWorker>(); // builder.Services.AddHostedService<PositionManagerWorker>();
builder.Services.AddHostedService<PositionFetcher>(); // builder.Services.AddHostedService<PositionFetcher>();
// builder.Services.AddHostedService<PricesFiveMinutesWorker>(); // builder.Services.AddHostedService<PricesFiveMinutesWorker>();
builder.Services.AddHostedService<PricesFifteenMinutesWorker>(); builder.Services.AddHostedService<PricesFifteenMinutesWorker>();
builder.Services.AddHostedService<PricesOneHourWorker>(); builder.Services.AddHostedService<PricesOneHourWorker>();
@@ -160,8 +160,8 @@ builder.Services.AddHostedService<PricesFourHoursWorker>();
builder.Services.AddHostedService<PricesOneDayWorker>(); builder.Services.AddHostedService<PricesOneDayWorker>();
// builder.Services.AddHostedService<SpotlightWorker>(); // builder.Services.AddHostedService<SpotlightWorker>();
// builder.Services.AddHostedService<TraderWatcher>(); // builder.Services.AddHostedService<TraderWatcher>();
builder.Services.AddHostedService<LeaderboardWorker>(); // builder.Services.AddHostedService<LeaderboardWorker>();
builder.Services.AddHostedService<FundingRatesWatcher>(); // builder.Services.AddHostedService<FundingRatesWatcher>();
// App // App
var app = builder.Build(); var app = builder.Build();

17
src/Managing.Api/Program.cs
View File

@@ -4,7 +4,6 @@ using HealthChecks.UI.Client;
using Managing.Api.Authorization; using Managing.Api.Authorization;
using Managing.Api.Filters; using Managing.Api.Filters;
using Managing.Api.HealthChecks; using Managing.Api.HealthChecks;
using Managing.Api.Workers;
using Managing.Application.Hubs; using Managing.Application.Hubs;
using Managing.Bootstrap; using Managing.Bootstrap;
using Managing.Common; using Managing.Common;
@@ -74,15 +73,11 @@ var web3ProxyUrl = builder.Configuration.GetSection("Web3Proxy")["BaseUrl"];
// Add HTTP client for Web3Proxy health check with detailed response // Add HTTP client for Web3Proxy health check with detailed response
builder.Services.AddHttpClient("Web3ProxyHealthCheck") builder.Services.AddHttpClient("Web3ProxyHealthCheck")
.ConfigureHttpClient(client => { .ConfigureHttpClient(client => { client.Timeout = TimeSpan.FromSeconds(15); });
client.Timeout = TimeSpan.FromSeconds(15);
});
// Add HTTP client for GMX API health check // Add HTTP client for GMX API health check
builder.Services.AddHttpClient("GmxHealthCheck") builder.Services.AddHttpClient("GmxHealthCheck")
.ConfigureHttpClient(client => { .ConfigureHttpClient(client => { client.Timeout = TimeSpan.FromSeconds(10); });
client.Timeout = TimeSpan.FromSeconds(10);
});
// Register Web3ProxyHealthCheck with the web3ProxyUrl // Register Web3ProxyHealthCheck with the web3ProxyUrl
builder.Services.AddSingleton<Web3ProxyHealthCheck>(sp => builder.Services.AddSingleton<Web3ProxyHealthCheck>(sp =>
@@ -200,7 +195,7 @@ builder.Services.AddSwaggerGen(options =>
}); });
builder.WebHost.SetupDiscordBot(); builder.WebHost.SetupDiscordBot();
builder.Services.AddHostedService<BotManagerWorker>(); // builder.Services.AddHostedService<BotManagerWorker>();
// App // App
var app = builder.Build(); var app = builder.Build();
@@ -253,19 +248,19 @@ app.UseEndpoints(endpoints =>
Predicate = r => r.Tags.Contains("live"), Predicate = r => r.Tags.Contains("live"),
ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse
}); });
endpoints.MapHealthChecks("/health/candles", new HealthCheckOptions endpoints.MapHealthChecks("/health/candles", new HealthCheckOptions
{ {
Predicate = r => r.Tags.Contains("candles"), Predicate = r => r.Tags.Contains("candles"),
ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse
}); });
endpoints.MapHealthChecks("/health/gmx", new HealthCheckOptions endpoints.MapHealthChecks("/health/gmx", new HealthCheckOptions
{ {
Predicate = r => r.Name == "gmx-connectivity", Predicate = r => r.Name == "gmx-connectivity",
ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse ResponseWriter = UIResponseWriter.WriteHealthCheckUIResponse
}); });
endpoints.MapHealthChecks("/health/web3proxy", new HealthCheckOptions endpoints.MapHealthChecks("/health/web3proxy", new HealthCheckOptions
{ {
Predicate = r => r.Name == "web3proxy", Predicate = r => r.Name == "web3proxy",