review-bench/andresharpe_dotbot/setup-background-job

public class EmailPollingJob : IJob
{
    private readonly IEmailService _emailService;
    private readonly ILogger<EmailPollingJob> _logger;
    
    public EmailPollingJob(IEmailService emailService, ILogger<EmailPollingJob> logger)
    {
        _emailService = emailService;
        _logger = logger;
    }
    
    public async Task Execute(IJobExecutionContext context)
    {
        _logger.LogInformation("Email polling job started");
        
        try
        {
            await _emailService.PollNewEmails();
            _logger.LogInformation("Email polling completed successfully");
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error polling emails");
            throw new JobExecutionException(ex, refireImmediately: false);
        }
    }
}

// In Program.cs or Startup.cs
services.AddQuartz(q =>
{
    q.UseMicrosoftDependencyInjectionJobFactory();
    
    // Define the job
    var jobKey = new JobKey("EmailPollingJob");
    q.AddJob<EmailPollingJob>(opts => opts.WithIdentity(jobKey));
    
    // Create a trigger
    q.AddTrigger(opts => opts
        .ForJob(jobKey)
        .WithIdentity("EmailPollingTrigger")
        .WithCronSchedule("0 */5 * * * ?")); // Every 5 minutes
});
 
services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);

0 0 8 * * ?        - Every day at 8:00 AM
0 */5 * * * ?      - Every 5 minutes
0 30 17 * * ?      - Every day at 5:30 PM
0 0 0 ? * SUN      - Every Sunday at midnight
0 0 * * * ?        - Every hour
0 */30 * * * ?     - Every 30 minutes
0 0 1 1 * ?        - First day of month at 1:00 AM

// When scheduling
q.AddTrigger(opts => opts
    .ForJob(jobKey)
    .UsingJobData("userId", "user123")
    .UsingJobData("maxItems", 50)
    .WithCronSchedule("0 0 * * * ?"));
 
// In job
public async Task Execute(IJobExecutionContext context)
{
    var userId = context.MergedJobDataMap.GetString("userId");
    var maxItems = context.MergedJobDataMap.GetInt("maxItems");
    // ... use parameters
}

public async Task Execute(IJobExecutionContext context)
{
    try
    {
        await DoWork();
    }
    catch (TransientException ex)
    {
        // Retry immediately
        throw new JobExecutionException(ex, refireImmediately: true);
    }
    catch (Exception ex)
    {
        // Log and don't retry
        _logger.LogError(ex, "Job failed");
        throw new JobExecutionException(ex, refireImmediately: false);
    }
}

await scheduler.PauseJob(jobKey);
await scheduler.ResumeJob(jobKey);

await scheduler.TriggerJob(jobKey);

await scheduler.DeleteJob(jobKey);

[DisallowConcurrentExecution]
public class ExclusiveJob : IJob
{
    // Only one instance runs at a time
}

services.AddQuartz(q =>
{
    q.UsePersistentStore(s =>
    {
        s.UseSqlite(sqlite =>
        {
            sqlite.ConnectionString = "Data Source=quartz.db";
        });
        s.UseJsonSerializer();
    });
});