✨ Lotteries

DysonNetwork.Pass/Startup/BroadcastEventHandler.cs

@@ -104,9 +104,33 @@ public class BroadcastEventHandler(
                     logger.LogInformation("Subscription for order {OrderId} handled successfully.", evt.OrderId);
                     await msg.AckAsync(cancellationToken: stoppingToken);
                 }
+                else if (evt.ProductIdentifier == "lottery")
+                {
+                    logger.LogInformation("Handling lottery order: {OrderId}", evt.OrderId);
+
+                    await using var scope = serviceProvider.CreateAsyncScope();
+                    var db = scope.ServiceProvider.GetRequiredService<AppDatabase>();
+                    var lotteries = scope.ServiceProvider.GetRequiredService<Lotteries.LotteryService>();
+
+                    var order = await db.PaymentOrders.FindAsync(
+                        [evt.OrderId],
+                        cancellationToken: stoppingToken
+                    );
+                    if (order == null)
+                    {
+                        logger.LogWarning("Order with ID {OrderId} not found. Redelivering.", evt.OrderId);
+                        await msg.NakAsync(cancellationToken: stoppingToken);
+                        continue;
+                    }
+
+                    await lotteries.HandleLotteryOrder(order);
+
+                    logger.LogInformation("Lottery ticket for order {OrderId} created successfully.", evt.OrderId);
+                    await msg.AckAsync(cancellationToken: stoppingToken);
+                }
                 else
                 {
-                    // Not a subscription or gift order, skip
+                    // Not a subscription, gift, or lottery order, skip
                     continue;
                 }
             }

DysonNetwork.Pass/Startup/ScheduledJobsConfiguration.cs

@@ -66,6 +66,13 @@ public static class ScheduledJobsConfiguration
                     .WithIntervalInHours(1)
                     .RepeatForever())
             );
+
+            var lotteryDrawJob = new JobKey("LotteryDraw");
+            q.AddJob<Lotteries.LotteryDrawJob>(opts => opts.WithIdentity(lotteryDrawJob));
+            q.AddTrigger(opts => opts
+                .ForJob(lotteryDrawJob)
+                .WithIdentity("LotteryDrawTrigger")
+                .WithCronSchedule("0 0 0 * * ?"));
         });
         services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);
 

DysonNetwork.Pass/Startup/ServiceCollectionExtensions.cs

@@ -141,6 +141,7 @@ public static class ServiceCollectionExtensions
         services.AddScoped<SocialCreditService>();
         services.AddScoped<ExperienceService>();
         services.AddScoped<RealmService>();
+        services.AddScoped<Lotteries.LotteryService>();
         
         services.Configure<OidcProviderOptions>(configuration.GetSection("OidcProvider"));
         services.AddScoped<OidcProviderService>();
@@ -149,4 +150,4 @@ public static class ServiceCollectionExtensions
 
         return services;
     }
-}
+}