Add SeederApi PlayData delete scheduled job

test/SeederApi.IntegrationTest/SeederApiApplicationFactory.cs

@@ -1,6 +1,7 @@
 using Bit.Core.Services;
 using Bit.IntegrationTestCommon;
 using Bit.IntegrationTestCommon.Factories;
+using Microsoft.AspNetCore.TestHost;
 
 namespace Bit.SeederApi.IntegrationTest;
 
@@ -15,4 +16,16 @@ public SeederApiApplicationFactory()
             serviceCollection.AddHttpContextAccessor();
         });
     }
+
+    protected override void ConfigureWebHost(IWebHostBuilder builder)
+    {
+        base.ConfigureWebHost(builder);
+
+        builder.ConfigureTestServices(services =>
+        {
+            // Remove scheduled background jobs to prevent errors in parallel test execution
+            var jobService = services.First(sd => sd.ServiceType == typeof(IHostedService) && sd.ImplementationType == typeof(Jobs.JobsHostedService));
+            services.Remove(jobService);
+        });
+    }
 }

util/SeederApi/Controllers/SeedController.cs

@@ -75,13 +75,18 @@ public async Task<IActionResult> DeleteAsync([FromRoute] string playId)
         }
     }
 
-
     [HttpDelete]
-    public async Task<IActionResult> DeleteAllAsync()
+    public async Task<IActionResult> DeleteAllAsync([FromBody] DateTime? olderThanRequest)
     {
-        logger.LogInformation("Deleting all seeded data");
+        if (!ModelState.IsValid)
+        {
+            return BadRequest(ModelState);
+        }
+
+        var olderThan = olderThanRequest?.ToUniversalTime() ?? DateTime.UtcNow.AddDays(-1);
+        logger.LogInformation("Deleting all seeded data older than {OlderThan} UTC", olderThan);
 
-        var playIds = getAllPlayIdsQuery.GetAllPlayIds();
+        var playIds = getAllPlayIdsQuery.GetAllPlayIds(olderThan: olderThan);
 
         try
         {

util/SeederApi/Jobs/DeleteOldPlayDataJob.cs

@@ -0,0 +1,32 @@
+using Bit.Core;
+using Bit.Core.Jobs;
+using Bit.SeederApi.Commands.Interfaces;
+using Bit.SeederApi.Queries.Interfaces;
+using Quartz;
+
+namespace Bit.SeederApi.Jobs;
+
+public class DeleteOldPlayDataJob : BaseJob
+{
+    private readonly IGetAllPlayIdsQuery _getAllPlayIdsQuery;
+    private readonly IDestroyBatchScenesCommand _destroyBatchScenesCommand;
+
+    public DeleteOldPlayDataJob(
+        IGetAllPlayIdsQuery getAllPlayIdsQuery,
+        IDestroyBatchScenesCommand destroyBatchScenesCommand,
+        ILogger<DeleteOldPlayDataJob> logger)
+        : base(logger)
+    {
+        _getAllPlayIdsQuery = getAllPlayIdsQuery;
+        _destroyBatchScenesCommand = destroyBatchScenesCommand;
+    }
+
+    protected async override Task ExecuteJobAsync(IJobExecutionContext context)
+    {
+        _logger.LogInformation(Constants.BypassFiltersEventId, "Execute job task: DeleteOldPlayDataJob");
+        var olderThan = DateTime.UtcNow.AddDays(-1);
+        var playIds = _getAllPlayIdsQuery.GetAllPlayIds(olderThan);
+        await _destroyBatchScenesCommand.DestroyAsync(playIds);
+        _logger.LogInformation(Constants.BypassFiltersEventId, "Finished job task: DeleteOldPlayDataJob. Deleted {PlayIdCount} root items", playIds.Count);
+    }
+}

util/SeederApi/Jobs/JobsHostedService.cs

@@ -0,0 +1,38 @@
+using Bit.Core.Jobs;
+using Bit.Core.Settings;
+using Quartz;
+
+namespace Bit.SeederApi.Jobs;
+
+public class JobsHostedService : BaseJobsHostedService
+{
+    public JobsHostedService(
+        GlobalSettings globalSettings,
+        IServiceProvider serviceProvider,
+        ILogger<JobsHostedService> logger,
+        ILogger<JobListener> listenerLogger)
+        : base(globalSettings, serviceProvider, logger, listenerLogger) { }
+
+    public override async Task StartAsync(CancellationToken cancellationToken)
+    {
+        var everyFifteenMinutesTrigger = TriggerBuilder.Create()
+            .WithIdentity("everyFifteenMinutesTrigger")
+            .StartNow()
+            .WithCronSchedule("0 */15 * ? * *")
+            .Build();
+
+
+        var jobs = new List<Tuple<Type, ITrigger>>
+        {
+            new Tuple<Type, ITrigger>(typeof(DeleteOldPlayDataJob), everyFifteenMinutesTrigger),
+        };
+
+        Jobs = jobs;
+        await base.StartAsync(cancellationToken);
+    }
+
+    public static void AddJobsServices(IServiceCollection services)
+    {
+        services.AddTransient<DeleteOldPlayDataJob>();
+    }
+}

util/SeederApi/Queries/GetAllPlayIdsQuery.cs

@@ -12,4 +12,13 @@ public List<string> GetAllPlayIds()
             .Distinct()
             .ToList();
     }
+
+    public List<string> GetAllPlayIds(DateTime olderThan)
+    {
+        return databaseContext.PlayItem
+            .Where(pd => pd.CreationDate < olderThan)
+            .Select(pd => pd.PlayId)
+            .Distinct()
+            .ToList();
+    }
 }

util/SeederApi/Queries/Interfaces/IGetAllPlayIdsQuery.cs

@@ -10,4 +10,10 @@ public interface IGetAllPlayIdsQuery
     /// </summary>
     /// <returns>A list of play IDs representing active seeded data that can be destroyed.</returns>
     List<string> GetAllPlayIds();
+    /// <summary>
+    /// Retrieves all play IDs for currently tracked seeded data that were created prior to the given DateTime
+    /// </summary>
+    /// <param name="olderThan">The cutoff point for PlayId creation date</param>
+    /// <returns></returns>
+    List<string> GetAllPlayIds(DateTime olderThan);
 }

util/SeederApi/SeederApi.csproj

@@ -9,6 +9,7 @@
     </PropertyGroup>
 
     <ItemGroup>
+      <ProjectReference Include="..\..\src\Core\Core.csproj" />
       <ProjectReference Include="..\..\src\SharedWeb\SharedWeb.csproj" />
       <ProjectReference Include="..\Seeder\Seeder.csproj" />
     </ItemGroup>

util/SeederApi/Startup.cs

@@ -41,6 +41,9 @@ public void ConfigureServices(IServiceCollection services)
         services.AddQueries();
 
         services.AddControllers();
+
+        Jobs.JobsHostedService.AddJobsServices(services);
+        services.AddHostedService<Jobs.JobsHostedService>();
     }
 
     public void Configure(