fix(jobs): correct mission event type when mission deleted is null

Author: acostes

api/src/jobs/import-missions/utils/__tests__/db.test.ts

@@ -0,0 +1,95 @@
+import { beforeEach, describe, expect, it, vi } from "vitest";
+
+const findMissionsByMock = vi.fn();
+const createMissionMock = vi.fn();
+const updateMissionMock = vi.fn();
+const createMissionEventsMock = vi.fn();
+const findPublisherOrganizationsMock = vi.fn();
+const buildPublisherOrganizationPayloadMock = vi.fn();
+const isPublisherOrganizationUpToDateMock = vi.fn();
+const upsertPublisherOrganizationPayloadMock = vi.fn();
+const getMissionChangesMock = vi.fn();
+
+vi.mock("../../../../services/mission", () => ({
+  missionService: {
+    findMissionsBy: findMissionsByMock,
+    create: createMissionMock,
+    update: updateMissionMock,
+  },
+}));
+
+vi.mock("../../../../services/mission-event", () => ({
+  missionEventService: {
+    createMissionEvents: createMissionEventsMock,
+  },
+}));
+
+vi.mock("../../../../repositories/publisher-organization", () => ({
+  publisherOrganizationRepository: {
+    findMany: findPublisherOrganizationsMock,
+  },
+}));
+
+vi.mock("../organization", () => ({
+  buildPublisherOrganizationPayload: buildPublisherOrganizationPayloadMock,
+  isPublisherOrganizationUpToDate: isPublisherOrganizationUpToDateMock,
+  upsertPublisherOrganizationPayload: upsertPublisherOrganizationPayloadMock,
+}));
+
+vi.mock("../../../../utils/mission", () => ({
+  EVENT_TYPES: {
+    CREATE: "create",
+    UPDATE: "update",
+    DELETE: "delete",
+  },
+  getMissionChanges: getMissionChangesMock,
+}));
+
+import { bulkDB } from "../db";
+
+describe("bulkDB mission event type", () => {
+  beforeEach(() => {
+    vi.clearAllMocks();
+    buildPublisherOrganizationPayloadMock.mockReturnValue(null);
+    isPublisherOrganizationUpToDateMock.mockReturnValue(true);
+    findPublisherOrganizationsMock.mockResolvedValue([]);
+    createMissionEventsMock.mockResolvedValue(1);
+  });
+
+  it("tracks undelete (deletedAt -> null) as update", async () => {
+    findMissionsByMock.mockResolvedValue([
+      {
+        id: "mission-1",
+        clientId: "client-1",
+        organizationClientId: null,
+      },
+    ]);
+    updateMissionMock.mockResolvedValue({
+      id: "mission-1",
+      clientId: "client-1",
+      organizationClientId: null,
+      deletedAt: null,
+    });
+    getMissionChangesMock.mockReturnValue({
+      deletedAt: {
+        previous: "2026-01-05T05:15:09.598Z",
+        current: null,
+      },
+    });
+
+    const result = await bulkDB(
+      [{ clientId: "client-1", organizationClientId: null } as any],
+      { id: "publisher-1", name: "Publisher 1" } as any,
+      { createdCount: 0, updatedCount: 0, deletedCount: 0 } as any,
+      { recordMissionEvents: true }
+    );
+
+    expect(result).toBe(true);
+    expect(createMissionEventsMock).toHaveBeenCalledWith([
+      expect.objectContaining({
+        missionId: "mission-1",
+        type: "update",
+      }),
+    ]);
+  });
+});

api/src/jobs/import-missions/utils/db.ts

@@ -114,9 +114,10 @@ export const bulkDB = async (
       if (changes) {
         const updated = await missionService.update(current.id, missionInput as MissionUpdatePatch);
         existingMap.set(missionInput.clientId, updated);
+        const isDeletion = changes.deletedAt ? changes.deletedAt.current !== null : false;
         missionEvents.push({
           missionId: current.id,
-          type: changes.deletedAt?.current === null ? EVENT_TYPES.DELETE : EVENT_TYPES.UPDATE,
+          type: isDeletion ? EVENT_TYPES.DELETE : EVENT_TYPES.UPDATE,
           changes,
         });
         importDoc.updatedCount += 1;