Remove old option for distribution

This commit is contained in:
2025-08-09 13:09:38 +03:00
parent b409e5ef08
commit cc7d2d478c
2 changed files with 5 additions and 17 deletions
@@ -10,17 +10,18 @@ namespace mROA.Implementation.Backend
private readonly IRealStoreInstanceRepository _contextRepository; private readonly IRealStoreInstanceRepository _contextRepository;
private readonly IInstanceRepository _remoteContextRepository; private readonly IInstanceRepository _remoteContextRepository;
private readonly IExecuteModule _executeModule; private readonly IExecuteModule _executeModule;
private readonly DistributionOptions _mode; private readonly IDistributionModule _distribution;
private readonly Dictionary<int, IRequestExtractor> _producedExtractors = new(); private readonly Dictionary<int, IRequestExtractor> _producedExtractors = new();
public HubRequestExtractor(IRealStoreInstanceRepository contextRepository, public HubRequestExtractor(IRealStoreInstanceRepository contextRepository,
IInstanceRepository remoteContextRepository, IExecuteModule executeModule, IInstanceRepository remoteContextRepository, IExecuteModule executeModule,
IOptions<DistributionOptions> mode) IDistributionModule distribution)
{ {
_contextRepository = contextRepository; _contextRepository = contextRepository;
_remoteContextRepository = remoteContextRepository; _remoteContextRepository = remoteContextRepository;
_executeModule = executeModule; _executeModule = executeModule;
_mode = mode.Value; _distribution = distribution;
} }
public IRequestExtractor this[int id] => _producedExtractors[id]; public IRequestExtractor this[int id] => _producedExtractors[id];
@@ -28,7 +29,7 @@ namespace mROA.Implementation.Backend
public IRequestExtractor HubOnOnConnected(IRepresentationModule representationModule) public IRequestExtractor HubOnOnConnected(IRepresentationModule representationModule)
{ {
var extractor = CreateExtractor(representationModule); var extractor = CreateExtractor(representationModule);
if (_mode.DistributionType == EDistributionType.Channeled) if (_distribution is ChannelDistributionModule)
{ {
extractor.StartExtraction().ContinueWith(_ => OnDisconnected(representationModule)); extractor.StartExtraction().ContinueWith(_ => OnDisconnected(representationModule));
} }
@@ -1,13 +0,0 @@
namespace mROA.Implementation
{
public class DistributionOptions
{
public EDistributionType DistributionType { get; set; }
}
public enum EDistributionType
{
Channeled,
ExtractorFirst
}
}