UseEFInterceptor

UseEFInterceptor.cs

private static IServiceCollection UseEFInterceptor<T>(this IServiceCollection services, IConfiguration configuration)
            where T : class, IInterceptor
        {
            return services
                .AddScoped<DbContextOptions>((serviceProvider) =>
                    {
                        var tenant = serviceProvider.GetRequiredService<TenantInfo>();

                        var efServices = new ServiceCollection();
                        efServices.AddEntityFrameworkSqlServer();
                        efServices.AddScoped<TenantInfo>(s => 
                            serviceProvider.GetRequiredService<TenantInfo>()); // Allows DI for tenant info, set by parent pipeline via middleware
                        efServices.AddScoped<IInterceptor, T>(); // Adds the interceptor

                        var connectionString = configuration.GetConnectionString("SqlServerConnection");

                        return new DbContextOptionsBuilder<ProductsDbContext>()
                            .UseInternalServiceProvider(efServices.BuildServiceProvider())
                            .UseSqlServer(connectionString)
                            .Options;
                    })
                .AddScoped<ProductsDbContext>(s => new ProductsDbContext(s.GetRequiredService<DbContextOptions>()));
        }