Skip to content

Commit

Permalink
refactor: remove projector legacy toggle
Browse files Browse the repository at this point in the history
  • Loading branch information
@emalfroy
emalfroy committed Dec 5, 2023
1 parent c0b5eab commit 695fdcd
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 143 deletions.
143 changes: 4 additions & 139 deletions src/BuildingRegistry.Projector/Infrastructure/Modules/ApiModule.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,6 @@ public class ApiModule : Module
private readonly IConfiguration _configuration;
private readonly IServiceCollection _services;
private readonly ILoggerFactory _loggerFactory;
private readonly bool _useProjectionsV2;

public ApiModule(
IConfiguration configuration,
Expand All @@ -52,7 +51,6 @@ public ApiModule(
_configuration = configuration;
_services = services;
_loggerFactory = loggerFactory;
_useProjectionsV2 = Convert.ToBoolean(_configuration.GetSection(FeatureToggleOptions.ConfigurationKey)[nameof(FeatureToggleOptions.UseProjectionsV2)]);
}

protected override void Load(ContainerBuilder builder)
Expand Down Expand Up @@ -81,51 +79,10 @@ private void RegisterProjectionSetup(ContainerBuilder builder)

RegisterLastChangedProjections(builder);

if (_useProjectionsV2)
{
RegisterExtractProjectionsV2(builder);
RegisterLegacyProjectionsV2(builder);
RegisterWmsProjectionsV2(builder);
RegisterWfsProjectionsV2(builder);
}
else
{
RegisterExtractProjections(builder);
RegisterLegacyProjections(builder);
RegisterWmsProjections(builder);
RegisterWfsProjections(builder);
}
}

private void RegisterExtractProjections(ContainerBuilder builder)
{
builder
.RegisterModule(
new ExtractModule(
_configuration,
_services,
_loggerFactory));

builder
.RegisterProjectionMigrator<ExtractContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingExtractProjections, ExtractContext>(
context =>
new BuildingExtractProjections(
context.Resolve<IOptions<ExtractConfig>>(),
DbaseCodePage.Western_European_ANSI.ToEncoding(),
WKBReaderFactory.Create()),
ConnectedProjectionSettings.Default)

.RegisterProjections<BuildingUnitExtractProjections, ExtractContext>(
context =>
new BuildingUnitExtractProjections(
context.Resolve<IOptions<ExtractConfig>>(),
DbaseCodePage.Western_European_ANSI.ToEncoding(),
WKBReaderFactory.Create()),
ConnectedProjectionSettings.Default);
RegisterExtractProjectionsV2(builder);
RegisterLegacyProjectionsV2(builder);
RegisterWmsProjectionsV2(builder);
RegisterWfsProjectionsV2(builder);
}

private void RegisterExtractProjectionsV2(ContainerBuilder builder)
Expand All @@ -141,23 +98,20 @@ private void RegisterExtractProjectionsV2(ContainerBuilder builder)
.RegisterProjectionMigrator<ExtractContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingExtractV2Projections, ExtractContext>(
context =>
new BuildingExtractV2Projections(
context.Resolve<IOptions<ExtractConfig>>(),
DbaseCodePage.Western_European_ANSI.ToEncoding(),
WKBReaderFactory.Create()),
ConnectedProjectionSettings.Default)

.RegisterProjections<BuildingUnitExtractV2Projections, ExtractContext>(
context =>
new BuildingUnitExtractV2Projections(
context.Resolve<IOptions<ExtractConfig>>(),
DbaseCodePage.Western_European_ANSI.ToEncoding(),
WKBReaderFactory.Create()),
ConnectedProjectionSettings.Default)

.RegisterProjections<BuildingUnitAddressLinkExtractProjections, ExtractContext>(
context => new BuildingUnitAddressLinkExtractProjections(
context.Resolve<IOptions<ExtractConfig>>(),
Expand Down Expand Up @@ -185,38 +139,6 @@ private void RegisterLastChangedProjections(ContainerBuilder builder)
.RegisterProjections<BuildingUnitProjections, LastChangedListContext>(ConnectedProjectionSettings.Default);
}

private void RegisterLegacyProjections(ContainerBuilder builder)
{
builder
.RegisterModule(
new LegacyModule(
_configuration,
_services,
_loggerFactory));

var syndicationCatchUpSize = _configuration.GetSection(CatchUpSizesConfigKey).GetValue<int>("BuildingSyndication");
var syndicationProjectionSettings =
ConnectedProjectionSettings.Configure(settings => settings.ConfigureCatchUpPageSize(syndicationCatchUpSize));

builder
.RegisterProjectionMigrator<LegacyContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingDetailProjections, LegacyContext>(
() => new BuildingDetailProjections(),
ConnectedProjectionSettings.Default)
.RegisterProjections<BuildingSyndicationProjections, LegacyContext>(
() => new BuildingSyndicationProjections(),
syndicationProjectionSettings)
.RegisterProjections<BuildingUnitDetailProjections, LegacyContext>(
() => new BuildingUnitDetailProjections(),
ConnectedProjectionSettings.Default)
.RegisterProjections<BuildingPersistenLocalIdCrabIdProjections, LegacyContext>(
() => new BuildingPersistenLocalIdCrabIdProjections(),
ConnectedProjectionSettings.Default);
}

private void RegisterLegacyProjectionsV2(ContainerBuilder builder)
{
builder
Expand All @@ -234,7 +156,6 @@ private void RegisterLegacyProjectionsV2(ContainerBuilder builder)
.RegisterProjectionMigrator<LegacyContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingDetailV2Projections, LegacyContext>(
() => new BuildingDetailV2Projections(),
ConnectedProjectionSettings.Default)
Expand All @@ -246,33 +167,6 @@ private void RegisterLegacyProjectionsV2(ContainerBuilder builder)
ConnectedProjectionSettings.Default);
}

private void RegisterWmsProjections(ContainerBuilder builder)
{
builder
.RegisterModule(
new WmsModule(
_configuration,
_services,
_loggerFactory));

var wmsProjectionSettings = ConnectedProjectionSettings
.Configure(settings =>
settings.ConfigureLinearBackoff<SqlException>(_configuration, "Wms"));

builder
.RegisterProjectionMigrator<WmsContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingRegistry.Projections.Wms.Building.BuildingProjections, WmsContext>(() =>
new BuildingRegistry.Projections.Wms.Building.BuildingProjections(WKBReaderFactory.Create()),
wmsProjectionSettings)

.RegisterProjections<BuildingRegistry.Projections.Wms.BuildingUnit.BuildingUnitProjections, WmsContext>(() =>
new BuildingRegistry.Projections.Wms.BuildingUnit.BuildingUnitProjections(WKBReaderFactory.Create()),
wmsProjectionSettings);
}

private void RegisterWmsProjectionsV2(ContainerBuilder builder)
{
builder
Expand All @@ -290,42 +184,14 @@ private void RegisterWmsProjectionsV2(ContainerBuilder builder)
.RegisterProjectionMigrator<WmsContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingRegistry.Projections.Wms.BuildingV2.BuildingV2Projections, WmsContext>(() =>
new BuildingRegistry.Projections.Wms.BuildingV2.BuildingV2Projections(WKBReaderFactory.Create()),
wmsProjectionSettings)

.RegisterProjections<BuildingRegistry.Projections.Wms.BuildingUnitV2.BuildingUnitV2Projections, WmsContext>(() =>
new BuildingRegistry.Projections.Wms.BuildingUnitV2.BuildingUnitV2Projections(WKBReaderFactory.Create()),
wmsProjectionSettings);
}

private void RegisterWfsProjections(ContainerBuilder builder)
{
builder
.RegisterModule(
new WfsModule(
_configuration,
_services,
_loggerFactory));

var wfsProjectionSettings = ConnectedProjectionSettings
.Configure(settings =>
settings.ConfigureLinearBackoff<SqlException>(_configuration, "Wfs"));

builder
.RegisterProjectionMigrator<WfsContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingRegistry.Projections.Wfs.Building.BuildingProjections, WfsContext>(() =>
new BuildingRegistry.Projections.Wfs.Building.BuildingProjections(WKBReaderFactory.Create()),
wfsProjectionSettings)
.RegisterProjections<BuildingRegistry.Projections.Wfs.BuildingUnit.BuildingUnitProjections, WfsContext>(() =>
new BuildingRegistry.Projections.Wfs.BuildingUnit.BuildingUnitProjections(WKBReaderFactory.Create()),
wfsProjectionSettings);
}

private void RegisterWfsProjectionsV2(ContainerBuilder builder)
{
builder
Expand All @@ -343,7 +209,6 @@ private void RegisterWfsProjectionsV2(ContainerBuilder builder)
.RegisterProjectionMigrator<WfsContextMigrationFactory>(
_configuration,
_loggerFactory)

.RegisterProjections<BuildingRegistry.Projections.Wfs.BuildingV2.BuildingV2Projections, WfsContext>(() =>
new BuildingRegistry.Projections.Wfs.BuildingV2.BuildingV2Projections(WKBReaderFactory.Create()),
wfsProjectionSettings)
Expand Down
4 changes: 0 additions & 4 deletions src/BuildingRegistry.Projector/appsettings.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,6 @@
"ConsumerAddress": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.BuildingRegistry;Trusted_Connection=True;TrustServerCertificate=True;"
},

"FeatureToggles": {
"UseProjectionsV2": false
},

"DataDog": {
"Enabled": true,
"Debug": false,
Expand Down

0 comments on commit 695fdcd

Please sign in to comment.