From 2b2080f48cfa34616d5debc938496b4c004627a8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Marc-Andr=C3=A9=20Bombeck?= <mbombeck@gmail.com>
Date: Thu, 6 Aug 2026 01:52:19 +0200
Subject: [PATCH] test: pin import actor attribution

Cover durable record and actor attribution across completion retries.
---
 .../sharing-import-attribution.test.ts        | 90 +++++++++++++++++++
 1 file changed, 90 insertions(+)
 create mode 100644 tests/integration/sharing-import-attribution.test.ts

diff --git a/tests/integration/sharing-import-attribution.test.ts b/tests/integration/sharing-import-attribution.test.ts
new file mode 100644
index 000000000..ac96363dc
--- /dev/null
+++ b/tests/integration/sharing-import-attribution.test.ts
@@ -0,0 +1,90 @@
+import { beforeEach, describe, expect, it } from "vitest";
+
+import { toJson } from "@/lib/db";
+import {
+  _setMedicationIntakeImportPrismaForTests,
+  processMedicationIntakeImportJob,
+  type MedicationImportProgress,
+} from "@/lib/jobs/medication-intake-import";
+
+import { getPrismaClient, truncateAllTables } from "./setup";
+
+const EMPTY_PROGRESS: MedicationImportProgress = {
+  processed: 0,
+  total: 0,
+  imported: 0,
+  skippedByReason: {},
+  touchedDays: [],
+  rollupProcessed: 0,
+};
+
+beforeEach(async () => {
+  const prisma = getPrismaClient();
+  _setMedicationIntakeImportPrismaForTests(prisma);
+  await truncateAllTables(prisma);
+});
+
+describe("shared intake import attribution", () => {
+  it("retains the record and manager through one durable completion audit", async () => {
+    const prisma = getPrismaClient();
+    await prisma.user.createMany({
+      data: [
+        {
+          id: "import-record",
+          username: "import-record",
+          email: "import-record@example.test",
+          role: "USER",
+        },
+        {
+          id: "import-manager",
+          username: "import-manager",
+          email: "import-manager@example.test",
+          role: "USER",
+        },
+      ],
+    });
+    const job = await prisma.medicationIntakeImportJob.create({
+      data: {
+        recordUserId: "import-record",
+        actorUserId: "import-manager",
+        medicationId: null,
+        payload: toJson({ entries: [] }),
+        progress: toJson(EMPTY_PROGRESS),
+      } as never,
+    });
+
+    await processMedicationIntakeImportJob(job.id);
+    await processMedicationIntakeImportJob(job.id);
+
+    const [completed, audits] = await Promise.all([
+      prisma.medicationIntakeImportJob.findUniqueOrThrow({
+        where: { id: job.id },
+      }),
+      prisma.auditLog.findMany({
+        where: {
+          userId: "import-record",
+          action: "medication.intake.import",
+        },
+      }),
+    ]);
+
+    expect(completed).toMatchObject({
+      recordUserId: "import-record",
+      actorUserId: "import-manager",
+      status: "done",
+    });
+    expect(audits).toHaveLength(1);
+    expect(audits[0]).toMatchObject({
+      userId: "import-record",
+      actorUserId: "import-manager",
+    });
+    expect(JSON.parse(audits[0]!.details!)).toEqual({
+      jobId: job.id,
+      recordUserId: "import-record",
+      actorUserId: "import-manager",
+      imported: 0,
+      skipped: 0,
+      total: 0,
+    });
+  });
+});