Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add postal latestitems #523

Merged
merged 2 commits into from
Jan 31, 2024
Merged

Add postal latestitems #523

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
03d75e0
chore: update packages
emalfroy Jan 30, 2024
d9e80d0
feat: add integration projections
emalfroy Jan 31, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions PostalRegistry.sln
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PostalRegistry.Producer", "
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PostalRegistry.Producer.Snapshot.Oslo", "src\PostalRegistry.Producer.Snapshot.Oslo\PostalRegistry.Producer.Snapshot.Oslo.csproj", "{B6B9729E-0EF7-48C8-88B1-BB4C437D20E6}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PostalRegistry.Projections.Integration", "src\PostalRegistry.Projections.Integration\PostalRegistry.Projections.Integration.csproj", "{8049759B-20E1-4AEE-9086-5422C437D742}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Expand Down Expand Up @@ -137,6 +139,10 @@ Global
{B6B9729E-0EF7-48C8-88B1-BB4C437D20E6}.Debug|Any CPU.Build.0 = Debug|Any CPU
{B6B9729E-0EF7-48C8-88B1-BB4C437D20E6}.Release|Any CPU.ActiveCfg = Release|Any CPU
{B6B9729E-0EF7-48C8-88B1-BB4C437D20E6}.Release|Any CPU.Build.0 = Release|Any CPU
{8049759B-20E1-4AEE-9086-5422C437D742}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{8049759B-20E1-4AEE-9086-5422C437D742}.Debug|Any CPU.Build.0 = Debug|Any CPU
{8049759B-20E1-4AEE-9086-5422C437D742}.Release|Any CPU.ActiveCfg = Release|Any CPU
{8049759B-20E1-4AEE-9086-5422C437D742}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
Expand All @@ -159,6 +165,7 @@ Global
{D13F985B-F16B-4F38-B170-F86E5D447926} = {81BE6CDF-434E-42AB-9CB1-B5E7A26DC317}
{DAC34E64-9C52-495E-9BF6-868E3DFE99EE} = {81BE6CDF-434E-42AB-9CB1-B5E7A26DC317}
{B6B9729E-0EF7-48C8-88B1-BB4C437D20E6} = {81BE6CDF-434E-42AB-9CB1-B5E7A26DC317}
{8049759B-20E1-4AEE-9086-5422C437D742} = {81BE6CDF-434E-42AB-9CB1-B5E7A26DC317}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {14E5CC1E-7FCC-4086-A7DD-CEFDAD492801}
Expand Down
26 changes: 17 additions & 9 deletions paket.dependencies
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,15 @@ nuget CsvHelper 27.2.1

nuget NetTopologySuite 2.4.0
nuget Dapper 2.0.123

nuget NodaTime 3.1.6

// For more healtchecks, look at https://github.com/Xabaril/AspNetCore.Diagnostics.HealthChecks
nuget AspNetCore.HealthChecks.SqlServer 6.0.2
nuget AspNetCore.HealthChecks.NpgSql 6.0.2

nuget Npgsql 6.0.3
nuget Npgsql.EntityFrameworkCore.PostgreSQL 6.0.3
nuget Npgsql.EntityFrameworkCore.PostgreSQL.Design 2.0.0-preview1

nuget Microsoft.EntityFrameworkCore.Design 6.0.3

Expand All @@ -42,14 +47,17 @@ nuget Be.Vlaanderen.Basisregisters.CommandHandling.SqlStreamStore 8.0.0
nuget Be.Vlaanderen.Basisregisters.EventHandling 4.2.3
nuget Be.Vlaanderen.Basisregisters.EventHandling.Autofac 4.2.3

nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.LastChangedList 11.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore 11.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac 11.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner 11.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector.Testing 11.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Syndication 11.0.1

nuget Be.Vlaanderen.Basisregisters.Projector 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.LastChangedList 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.Npgsql 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector.Testing 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Testing.Xunit 12.0.1
nuget Be.Vlaanderen.Basisregisters.ProjectionHandling.Syndication 12.0.1

nuget Be.Vlaanderen.Basisregisters.Projector 13.1.0

nuget Be.Vlaanderen.Basisregisters.DataDog.Tracing.Autofac 5.0.3
nuget Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql 5.0.3
Expand Down
93 changes: 74 additions & 19 deletions paket.lock
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
RESTRICTION: == net6.0
NUGET
remote: https://api.nuget.org/v3/index.json
AspNetCore.HealthChecks.NpgSql (6.0.2)
Microsoft.Extensions.Diagnostics.HealthChecks (>= 6.0.2)
Npgsql (>= 6.0)
AspNetCore.HealthChecks.SqlServer (6.0.2)
Microsoft.Data.SqlClient (>= 3.0.1)
Microsoft.Extensions.Diagnostics.HealthChecks (>= 6.0)
Expand Down Expand Up @@ -292,25 +295,38 @@ NUGET
Be.Vlaanderen.Basisregisters.Middleware.AddProblemJsonHeader (2.0)
Be.Vlaanderen.Basisregisters.ProblemDetails (8.0.1)
System.Reflection.Metadata (>= 6.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Microsoft.EntityFrameworkCore (>= 6.0.3)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector.Testing (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.LastChangedList (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector.Testing (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.LastChangedList (12.0.1)
Autofac.Extensions.DependencyInjection (>= 7.2)
Be.Vlaanderen.Basisregisters.AggregateSource.SqlStreamStore.Autofac (>= 6.0)
Be.Vlaanderen.Basisregisters.AggregateSource.SqlStreamStore (>= 7.1.3)
Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql (>= 5.0)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Microsoft.EntityFrameworkCore.SqlServer (>= 6.0.3)
Microsoft.Extensions.DependencyInjection (>= 6.0)
Polly (>= 7.2.3)
SqlStreamStore.MsSql (>= 1.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (12.0.1)
Autofac.Extensions.DependencyInjection (>= 7.2)
Be.Vlaanderen.Basisregisters.EntityFrameworkCore.EntityTypeConfiguration (>= 3.0)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Microsoft.EntityFrameworkCore.InMemory (>= 6.0.3)
Microsoft.EntityFrameworkCore.Relational (>= 6.0.3)
Microsoft.Extensions.Configuration (>= 6.0.1)
Microsoft.Extensions.Configuration.CommandLine (>= 6.0)
Microsoft.Extensions.Configuration.EnvironmentVariables (>= 6.0.1)
Microsoft.Extensions.Configuration.FileExtensions (>= 6.0)
Microsoft.Extensions.Configuration.Json (>= 6.0)
SqlStreamStore (>= 1.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.Microsoft (12.0.1)
Be.Vlaanderen.Basisregisters.DependencyInjection (>= 1.0.3)
Be.Vlaanderen.Basisregisters.EntityFrameworkCore.EntityTypeConfiguration (>= 3.0)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Microsoft.EntityFrameworkCore.InMemory (>= 6.0.3)
Microsoft.EntityFrameworkCore.SqlServer (>= 6.0.3)
Microsoft.Extensions.Configuration (>= 6.0.1)
Expand All @@ -319,24 +335,44 @@ NUGET
Microsoft.Extensions.Configuration.FileExtensions (>= 6.0)
Microsoft.Extensions.Configuration.Json (>= 6.0)
SqlStreamStore (>= 1.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (11.0.1)
Be.Vlaanderen.Basisregisters.EventHandling (>= 4.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.Npgsql (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Npgsql.EntityFrameworkCore.PostgreSQL (>= 6.0.3)
Polly (>= 7.2.3)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Microsoft.EntityFrameworkCore.SqlServer (>= 6.0.3)
Polly (>= 7.2.3)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Be.Vlaanderen.Basisregisters.EventHandling (>= 4.2.2)
SqlStreamStore (>= 1.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac (12.0.1)
Autofac.Extensions.DependencyInjection (>= 7.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Syndication (11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Syndication (12.0.1)
Microsoft.Extensions.Http (>= 6.0)
Microsoft.Extensions.Logging (>= 6.0)
Microsoft.SyndicationFeed.ReaderWriter (>= 1.0.2)
Be.Vlaanderen.Basisregisters.Projector (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Testing.Xunit (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector.Testing (12.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore (12.0.1)
Microsoft.EntityFrameworkCore (>= 6.0.3)
Microsoft.Extensions.Logging (>= 6.0)
xunit (>= 2.4.1)
Be.Vlaanderen.Basisregisters.Projector (13.1)
Autofac (>= 6.3)
Autofac.Extensions.DependencyInjection (>= 7.2)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (>= 11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (>= 11.0.1)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector (>= 12.0)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner (>= 12.0)
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.Microsoft (>= 12.0)
Dapper (>= 2.0.123)
Microsoft.Data.SqlClient (>= 4.1)
Polly (>= 7.2.3)
System.Configuration.ConfigurationManager (>= 6.0)
System.Threading.Tasks.Dataflow (>= 6.0)
Be.Vlaanderen.Basisregisters.Shaperon (9.0.1)
Be.Vlaanderen.Basisregisters.Testing.Infrastructure.Events (3.0) - copy_local: true, copy_content_to_output_dir: always, content: true
Expand Down Expand Up @@ -595,6 +631,9 @@ NUGET
Microsoft.EntityFrameworkCore.Relational (6.0.3)
Microsoft.EntityFrameworkCore (>= 6.0.3)
Microsoft.Extensions.Configuration.Abstractions (>= 6.0)
Microsoft.EntityFrameworkCore.Relational.Design (2.0.0-preview1-final)
Microsoft.EntityFrameworkCore.Relational (>= 2.0.0-preview1-final)
NETStandard.Library (>= 2.0.0-preview1-25301-01)
Microsoft.EntityFrameworkCore.SqlServer (6.0.3)
Microsoft.Data.SqlClient (>= 2.1.4)
Microsoft.EntityFrameworkCore.Relational (>= 6.0.3)
Expand Down Expand Up @@ -781,11 +820,27 @@ NUGET
Newtonsoft.Json (>= 9.0.1)
NJsonSchema (>= 10.6.10)
NJsonSchema.CodeGeneration (>= 10.6.10)
NodaTime (3.0.10)
NodaTime (3.1.6)
System.Runtime.CompilerServices.Unsafe (>= 4.7.1)
NodaTime.Serialization.JsonNet (3.0)
Newtonsoft.Json (>= 12.0.1)
NodaTime (>= 3.0 < 4.0)
Npgsql (6.0.3)
System.Runtime.CompilerServices.Unsafe (>= 6.0)
Npgsql.EntityFrameworkCore.PostgreSQL (6.0.3)
Microsoft.EntityFrameworkCore (>= 6.0.1)
Microsoft.EntityFrameworkCore.Abstractions (>= 6.0.1)
Microsoft.EntityFrameworkCore.Relational (>= 6.0.1)
Npgsql (>= 6.0.3)
Npgsql.EntityFrameworkCore.PostgreSQL.Design (2.0.0-preview1)
Microsoft.EntityFrameworkCore (>= 2.0.0-preview1-final)
Microsoft.EntityFrameworkCore.Relational (>= 2.0.0-preview1-final)
Microsoft.EntityFrameworkCore.Relational.Design (>= 2.0.0-preview1-final)
Microsoft.Extensions.DependencyInjection (>= 2.0.0-preview1-final)
Microsoft.Extensions.DependencyInjection.Abstractions (>= 2.0.0-preview1-final)
NETStandard.Library (>= 1.6.1)
Npgsql (>= 3.2.2)
Npgsql.EntityFrameworkCore.PostgreSQL (>= 2.0.0-preview1)
NSwag.CodeGeneration (13.15.10)
Newtonsoft.Json (>= 9.0.1)
NJsonSchema (>= 10.6.10)
Expand Down
1 change: 1 addition & 0 deletions src/EF.MigrationsHelper/EF.MigrationsHelper.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
<ProjectReference Include="..\PostalRegistry.Projections.Legacy\PostalRegistry.Projections.Legacy.csproj" />
<ProjectReference Include="..\PostalRegistry.Projections.LastChangedList\PostalRegistry.Projections.LastChangedList.csproj" />
<ProjectReference Include="..\PostalRegistry.Projections.Syndication\PostalRegistry.Projections.Syndication.csproj" />
<ProjectReference Include="..\PostalRegistry.Projections.Integration\PostalRegistry.Projections.Integration.csproj" />
<ProjectReference Include="..\PostalRegistry.Producer\PostalRegistry.Producer.csproj" />
<ProjectReference Include="..\PostalRegistry.Producer.Snapshot.Oslo\PostalRegistry.Producer.Snapshot.Oslo.csproj" />
</ItemGroup>
Expand Down
4 changes: 3 additions & 1 deletion src/EF.MigrationsHelper/appsettings.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,9 @@
"SyndicationProjections": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.PostalRegistry;Trusted_Connection=True;",
"SyndicationProjectionsAdmin": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.PostalRegistry;Trusted_Connection=True;",
"LastChangedListAdmin": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.MunicipalityRegistry;Trusted_Connection=True;",
"ProducerProjectionsAdmin": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.MunicipalityRegistry;Trusted_Connection=True;"
"ProducerProjectionsAdmin": "Server=(localdb)\\mssqllocaldb;Database=EFProviders.InMemory.MunicipalityRegistry;Trusted_Connection=True;",
"IntegrationProjections": ".",
"IntegrationProjectionsAdmin": "."
},

"Serilog": {
Expand Down
4 changes: 4 additions & 0 deletions src/PostalRegistry.Infrastructure/Schema.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,8 @@ public static class Schema

public const string Producer = "PostalRegistryProducer";
public const string ProducerSnapshotOslo = "PostalRegistryProducerSnapshotOslo";

public const string Integration = "integration_postal";
}

public static class MigrationTables
Expand All @@ -22,5 +24,7 @@ public static class MigrationTables

public const string Producer = "__EFMigrationsHistoryProducer";
public const string ProducerSnapshotOslo = "__EFMigrationsHistoryProducerSnapshotOslo";

public const string Integration = "__EFMigrationsHistory";
}
}
3 changes: 2 additions & 1 deletion src/PostalRegistry.Producer.Snapshot.Oslo/ProducerContextMigrationFactory.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
namespace PostalRegistry.Producer.Snapshot.Oslo
{
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer;
using Microsoft.EntityFrameworkCore;
using PostalRegistry.Infrastructure;

public class ProducerContextMigrationFactory : RunnerDbContextMigrationFactory<ProducerContext>
public class ProducerContextMigrationFactory : SqlServerRunnerDbContextMigrationFactory<ProducerContext>
{
public ProducerContextMigrationFactory()
: base("ProducerProjectionsAdmin", HistoryConfiguration) { }
Expand Down
2 changes: 1 addition & 1 deletion src/PostalRegistry.Producer.Snapshot.Oslo/ProducerModule.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ namespace PostalRegistry.Producer.Snapshot.Oslo
using System;
using Autofac;
using Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql.EntityFrameworkCore;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.MigrationExtensions;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer.MigrationExtensions;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
Expand Down
2 changes: 1 addition & 1 deletion src/PostalRegistry.Producer.Snapshot.Oslo/paket.references
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql
Be.Vlaanderen.Basisregisters.GrAr.Legacy
Be.Vlaanderen.Basisregisters.GrAr.Oslo
Be.Vlaanderen.BasisRegisters.MessageHandling.Kafka.Producer
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac
Be.Vlaanderen.Basisregisters.Projector

Expand Down
4 changes: 2 additions & 2 deletions src/PostalRegistry.Producer/ProducerContextMigrationFactory.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
namespace PostalRegistry.Producer
{
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer;
using Microsoft.EntityFrameworkCore;
using PostalRegistry.Infrastructure;

public class ProducerContextMigrationFactory : RunnerDbContextMigrationFactory<ProducerContext>
public class ProducerContextMigrationFactory : SqlServerRunnerDbContextMigrationFactory<ProducerContext>
{
public ProducerContextMigrationFactory()
: base("ProducerProjectionsAdmin", HistoryConfiguration) { }
Expand Down
1 change: 1 addition & 0 deletions src/PostalRegistry.Producer/ProducerModule.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ namespace PostalRegistry.Producer
using Autofac;
using Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql.EntityFrameworkCore;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.MigrationExtensions;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer.MigrationExtensions;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
Expand Down
2 changes: 1 addition & 1 deletion src/PostalRegistry.Producer/paket.references
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ Be.Vlaanderen.Basisregisters.EventHandling.Autofac
Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql
Be.Vlaanderen.Basisregisters.GrAr.Contracts
Be.Vlaanderen.BasisRegisters.MessageHandling.Kafka.Producer
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac
Be.Vlaanderen.Basisregisters.Projector

Expand Down
3 changes: 2 additions & 1 deletion src/PostalRegistry.Projections.Extract/ExtractContextMigrationFactory.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
namespace PostalRegistry.Projections.Extract
{
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer;
using Infrastructure;
using Microsoft.EntityFrameworkCore;

public class ExtractContextMigrationFactory : RunnerDbContextMigrationFactory<ExtractContext>
public class ExtractContextMigrationFactory : SqlServerRunnerDbContextMigrationFactory<ExtractContext>
{
public ExtractContextMigrationFactory() :
base("ExtractProjectionsAdmin", HistoryConfiguration)
Expand Down
4 changes: 2 additions & 2 deletions src/PostalRegistry.Projections.Extract/ExtractModule.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
namespace PostalRegistry.Projections.Extract
{
using System;
using Microsoft.Data.SqlClient;
using Autofac;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.MigrationExtensions;
using Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql.EntityFrameworkCore;
using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer.MigrationExtensions;
using Infrastructure;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
Expand Down
2 changes: 1 addition & 1 deletion src/PostalRegistry.Projections.Extract/paket.references
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
Be.Vlaanderen.Basisregisters.AggregateSource
Be.Vlaanderen.Basisregisters.EventHandling.Autofac
Be.Vlaanderen.Basisregisters.DataDog.Tracing.Sql
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner
Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer
Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac
Be.Vlaanderen.Basisregisters.Shaperon

Expand Down
Loading
Loading