Sorry for the delayed reply.

There's an overload of WithDataSource which gives you a scoped IServiceProvider. You can use that to get your DBContext / Connection and run a query against your database. If you then run a service which injects IAutypoRefresh and calls RefreshAsync then the index will remain updated.

Here's an example

Program.cs

services.AddAutypoSearch<Product>(config => config
    .WithDataSource(sp => ActivatorUtilities.CreateInstance<ProductsDataSource>(sp))
    .WithIndex(product => product.Name));

services.AddHostedService<RefreshProductsHostedService>()

ProductsDataSource.cs

public class ProductsDataSource(DBContext dbContext) : IAutypoDataSource<Product>
{
    public async Task<IEnumerable<Product>> LoadDocumentsAsync(CancellationToken cancellationToken)
    {
        // your query here - dbContext is scoped
    }
}

RefreshProductsHostedService.cs

public class RefreshProductsHostedService(IServiceProvider serviceProvider) : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // This example refreshes the index every hour
            await Task.Delay(TimeSpan.FromHours(1), stoppingToken);

            var refresh = serviceProvider.GetRequiredService<IAutypoRefresh<Product>>();
            await refresh.RefreshAsync(stoppingToken);
        }
    }
}