Apply suggestions from code review

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

Author: hhvrc

API.IntegrationTests/Tests/EmailOutboxPersistenceTests.cs

@@ -103,7 +103,7 @@ public async Task DueForDelivery_RunsTheJobsRawSql_AgainstTheRealSchema()
         // of truth the job uses) against real Postgres: the email_outbox table name, its column names, the
         // email_status enum, LIMIT, FOR UPDATE SKIP LOCKED, and SELECT * -> full entity materialization
         // (jsonb payload included). A schema rename breaks this test rather than only the Cron host at runtime.
-        var claimed = await db.EmailOutbox.DueForDelivery(EmailOutboxQueries.ClaimBatchSize).ToListAsync();
+        var claimed = await db.EmailOutbox.DueForDelivery(1).ToListAsync();
 
         await Assert.That(claimed.Any(m => m.Id == id)).IsTrue();
     }

Common/OpenShockDb/EmailOutboxQueries.cs

@@ -19,14 +19,17 @@ public static class EmailOutboxQueries
     /// capped at <paramref name="batchSize"/>, locked with <c>FOR UPDATE SKIP LOCKED</c> so concurrent
     /// runs take disjoint batches. Run it inside an explicit transaction to hold the locks for the claim.
     /// </summary>
-    public static IQueryable<EmailOutboxMessage> DueForDelivery(this DbSet<EmailOutboxMessage> outbox, int batchSize) =>
-        outbox.FromSql(
-            $"""
-             SELECT * FROM email_outbox
-             WHERE next_attempt_at <= now()
-               AND (status = {EmailStatus.Pending} OR status = {EmailStatus.Sending})
-             ORDER BY next_attempt_at
-             LIMIT {batchSize}
-             FOR UPDATE SKIP LOCKED
-             """);
+public static IQueryable<EmailOutboxMessage> DueForDelivery(this DbSet<EmailOutboxMessage> outbox, int batchSize)
+{
+    if (batchSize <= 0) throw new ArgumentOutOfRangeException(nameof(batchSize));
+
+    return outbox.FromSql(
+        $"""
+         SELECT * FROM email_outbox
+         WHERE next_attempt_at <= now()
+           AND (status = {EmailStatus.Pending} OR status = {EmailStatus.Sending})
+         ORDER BY next_attempt_at
+         LIMIT {batchSize}
+         FOR UPDATE SKIP LOCKED
+         """);
 }