feat(kvot): debitera AI-skanning PER BILD + fixa dubbeldebitering

Johans beslut: en skanning debiteras per bild (6 foton = 6 skanningar), streckkod
gratis. consumeAiScan tar nu units=imageCount och kollar att hela ryms.
Refunden ger tillbaka lika manga (antal bilder) vid misslyckat jobb. Appen kapar
antalet foton till kvarvarande kvot och gar till paywall om 0 (servern ar dock
den slutgiltiga grinden).

Hittade + fixade en PRE-EXISTING bugg pa vagen: kvoten drogs bade vid skapande
(consumeAiScan) OCH vid slutford analys (recordAiUsage aiScans:1) -> varje LYCKAD
skanning kostade 2 enheter, dolt av att appen bara uppdaterade raknaren vid start.
Nu dras kvoten exakt en gang, vid skapandet. Enbildsanvandare far alltsa nu sina
fulla 5 gratis-skanningar (var tidigare ~2,5).

apps/worker/src/processors/quota-refund.ts

@@ -4,36 +4,58 @@ import type { WorkerContext } from "../context.js";
 
 /**
  * Återbetalar AI-skanningskvot när ett skann-jobb dör definitivt.
- * Speglar consumeAiScan (api): kvot debiteras på household-ägaren (billingUser).
- * Barcode-skanningar drar ingen kvot och hoppas över. Golvat på 0.
+ * Speglar consumeAiScan (api): kvot debiteras på household-ägaren (billingUser)
+ * och PER BILD, så återbetalningen ger tillbaka lika många enheter som drogs
+ * (antal bilder i jobbet). Barcode-skanningar drar ingen kvot och hoppas över.
+ * Golvat på 0.
  */
-export async function refundAiScanForFailedJob(ctx: WorkerContext, scanJobId: string): Promise<void> {
- const [job] = await ctx.db
- .select({ userId: schema.scanJobs.userId, scanType: schema.scanJobs.scanType })
- .from(schema.scanJobs)
- .where(eq(schema.scanJobs.id, scanJobId))
- .limit(1);
- if (!job || job.scanType === "barcode") return;
+export async function refundAiScanForFailedJob(
+  ctx: WorkerContext,
+  scanJobId: string,
+): Promise<void> {
+  const [job] = await ctx.db
+    .select({
+      userId: schema.scanJobs.userId,
+      scanType: schema.scanJobs.scanType,
+      s3Keys: schema.scanJobs.s3Keys,
+    })
+    .from(schema.scanJobs)
+    .where(eq(schema.scanJobs.id, scanJobId))
+    .limit(1);
+  if (!job || job.scanType === "barcode") return;
 
- let billingUserId = job.userId;
- const [member] = await ctx.db
- .select({ householdId: schema.householdMembers.householdId })
- .from(schema.householdMembers)
- .where(eq(schema.householdMembers.userId, job.userId))
- .orderBy(schema.householdMembers.joinedAt)
- .limit(1);
- if (member?.householdId) {
- const [owner] = await ctx.db
- .select({ userId: schema.householdMembers.userId })
- .from(schema.householdMembers)
- .where(and(eq(schema.householdMembers.householdId, member.householdId), eq(schema.householdMembers.role, "owner")))
- .limit(1);
- if (owner?.userId) billingUserId = owner.userId;
- }
+  // Debiteras per bild – återbetala lika många enheter som drogs (en per bild).
+  const units = Math.max(1, Array.isArray(job.s3Keys) ? job.s3Keys.length : 1);
 
- const month = new Date().toISOString().slice(0, 7);
- await ctx.db
- .update(schema.aiUsageCounters)
- .set({ aiScans: sql`GREATEST(${schema.aiUsageCounters.aiScans} - 1, 0)` })
- .where(and(eq(schema.aiUsageCounters.userId, billingUserId), eq(schema.aiUsageCounters.month, month)));
+  let billingUserId = job.userId;
+  const [member] = await ctx.db
+    .select({ householdId: schema.householdMembers.householdId })
+    .from(schema.householdMembers)
+    .where(eq(schema.householdMembers.userId, job.userId))
+    .orderBy(schema.householdMembers.joinedAt)
+    .limit(1);
+  if (member?.householdId) {
+    const [owner] = await ctx.db
+      .select({ userId: schema.householdMembers.userId })
+      .from(schema.householdMembers)
+      .where(
+        and(
+          eq(schema.householdMembers.householdId, member.householdId),
+          eq(schema.householdMembers.role, "owner"),
+        ),
+      )
+      .limit(1);
+    if (owner?.userId) billingUserId = owner.userId;
+  }
+
+  const month = new Date().toISOString().slice(0, 7);
+  await ctx.db
+    .update(schema.aiUsageCounters)
+    .set({ aiScans: sql`GREATEST(${schema.aiUsageCounters.aiScans} - ${units}, 0)` })
+    .where(
+      and(
+        eq(schema.aiUsageCounters.userId, billingUserId),
+        eq(schema.aiUsageCounters.month, month),
+      ),
+    );
 }

apps/worker/src/processors/scans.ts

@@ -116,13 +116,15 @@ export async function processScanJob(ctx: WorkerContext, scanJobId: string): Pro
     }
   }
 
-  // Bokför verklig AI-kostnad/tokens utan PII (spec §45).
+  // Bokför verklig AI-kostnad/tokens utan PII (spec §45). Kvoten (aiScans) drogs
+  // redan vid skapandet (consumeAiScan, per bild) – räkna INTE upp den igen här,
+  // annars dubbeldebiteras varje lyckad skanning.
   if (result.costUsd != null || result.inputTokens || result.outputTokens) {
     await recordAiUsage(ctx.db, job.userId, {
       costUsd: result.costUsd ?? 0,
       inputTokens: result.inputTokens ?? 0,
       outputTokens: result.outputTokens ?? 0,
-      aiScans: 1,
+      aiScans: 0,
     });
   }