Release vintasend-medplum@0.9.0

Author: hugobessa

package.json

@@ -1,6 +1,6 @@
 {
   "name": "vintasend-medplum",
-  "version": "0.8.2",
+  "version": "0.9.0",
   "description": "",
   "main": "dist/index.js",
   "scripts": {
@@ -25,7 +25,7 @@
     "@medplum/fhirtypes": "^5.0.10",
     "pdfmake": "^0.2.23",
     "pug": "^3.0.3",
-    "vintasend": "^0.8.2"
+    "vintasend": "^0.9.0"
   },
   "devDependencies": {
     "@medplum/definitions": "^5.0.10",
@@ -37,6 +37,7 @@
     "jest": "^30.2.0",
     "ts-jest": "^29.4.6",
     "ts-node": "^10.9.2",
-    "typescript": "^5.9.3"
+    "typescript": "^5.9.3",
+    "vintasend": "file:../../.."
   }
 }

src/__tests__/medplum-backend.test.ts

@@ -695,6 +695,103 @@ describe('MedplumNotificationBackend', () => {
     });
   });
 
+  describe('applyReplicationSnapshotIfNewer', () => {
+    it('should skip apply when destination notification is newer', async () => {
+      const snapshot = {
+        id: 'notif-1',
+        userId: 'user-123',
+        notificationType: 'EMAIL',
+        title: 'Incoming',
+        bodyTemplate: 'body',
+        contextName: 'testContext',
+        contextParameters: { param1: 'value1' },
+        sendAfter: null,
+        subjectTemplate: 'subject',
+        status: 'SENT',
+        contextUsed: null,
+        extraParams: null,
+        adapterUsed: null,
+        sentAt: null,
+        readAt: null,
+        gitCommitSha: null,
+        createdAt: new Date('2026-02-28T10:00:00.000Z'),
+        updatedAt: new Date('2026-02-28T11:00:00.000Z'),
+      };
+      const destinationNewer = {
+        ...snapshot,
+        updatedAt: new Date('2026-02-28T12:00:00.000Z'),
+      };
+
+      jest.spyOn(backend, 'getNotification').mockResolvedValue(
+        // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+        destinationNewer as any,
+      );
+      const persistNotificationUpdateSpy = jest
+        .spyOn(backend, 'persistNotificationUpdate')
+        .mockResolvedValue(
+          // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+          destinationNewer as any,
+        );
+
+      const result = await backend.applyReplicationSnapshotIfNewer(
+        // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+        snapshot as any,
+      );
+
+      expect(result).toEqual({ applied: false });
+      expect(persistNotificationUpdateSpy).not.toHaveBeenCalled();
+    });
+
+    it('should apply update when destination notification is older', async () => {
+      const snapshot = {
+        id: 'notif-1',
+        userId: 'user-123',
+        notificationType: 'EMAIL',
+        title: 'Incoming title',
+        bodyTemplate: 'body',
+        contextName: 'testContext',
+        contextParameters: { param1: 'value1' },
+        sendAfter: null,
+        subjectTemplate: 'subject',
+        status: 'SENT',
+        contextUsed: null,
+        extraParams: null,
+        adapterUsed: null,
+        sentAt: null,
+        readAt: null,
+        gitCommitSha: null,
+        createdAt: new Date('2026-02-28T10:00:00.000Z'),
+        updatedAt: new Date('2026-02-28T11:00:00.000Z'),
+      };
+      const destinationOlder = {
+        ...snapshot,
+        updatedAt: new Date('2026-02-28T09:00:00.000Z'),
+      };
+
+      jest.spyOn(backend, 'getNotification').mockResolvedValue(
+        // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+        destinationOlder as any,
+      );
+      const persistNotificationUpdateSpy = jest
+        .spyOn(backend, 'persistNotificationUpdate')
+        .mockResolvedValue(
+          // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+          snapshot as any,
+        );
+
+      const result = await backend.applyReplicationSnapshotIfNewer(
+        // biome-ignore lint/suspicious/noExplicitAny: test-only cast
+        snapshot as any,
+      );
+
+      expect(result).toEqual({ applied: true });
+      expect(persistNotificationUpdateSpy).toHaveBeenCalledWith(
+        'notif-1',
+        expect.objectContaining({ title: 'Incoming title' }),
+      );
+    });
+  });
+
   describe('filterNotifications', () => {
     it('should map sendAfterRange to sent date comparators in FHIR search params', async () => {
       const from = new Date('2026-01-01T00:00:00.000Z');

src/medplum-backend.ts

@@ -121,6 +121,17 @@ export class MedplumNotificationBackend<Config extends BaseNotificationTypeConfi
     };
   }
 
+  private isDuplicateReplicationConflict(error: unknown): boolean {
+    const normalizedError = String(error).toLowerCase();
+
+    return (
+      normalizedError.includes('duplicate') ||
+      normalizedError.includes('unique') ||
+      normalizedError.includes('already exists') ||
+      normalizedError.includes('conflict')
+    );
+  }
+
   private convertNotificationOrderByToFhirSort(orderBy: NotificationOrderBy): string {
     const fieldMap: Record<NotificationOrderBy['field'], string> = {
       sendAfter: 'sent',
@@ -439,6 +450,78 @@ export class MedplumNotificationBackend<Config extends BaseNotificationTypeConfi
     return this.mapToDatabaseNotification(result) as DatabaseNotification<Config>;
   }
 
+  async applyReplicationSnapshotIfNewer(
+    snapshot: AnyDatabaseNotification<Config>,
+  ): Promise<{ applied: boolean }> {
+    const existingNotification = await this.getNotification(snapshot.id, false);
+
+    if (
+      existingNotification?.updatedAt &&
+      snapshot.updatedAt &&
+      existingNotification.updatedAt >= snapshot.updatedAt
+    ) {
+      return { applied: false };
+    }
+
+    if ('emailOrPhone' in snapshot) {
+      if (existingNotification) {
+        await this.persistOneOffNotificationUpdate(
+          snapshot.id,
+          snapshot as unknown as Partial<Omit<OneOffNotificationInput<Config>, 'id'>>,
+        );
+
+        return { applied: true };
+      }
+
+      try {
+        await this.persistOneOffNotification(
+          snapshot as unknown as Omit<OneOffNotificationInput<Config>, 'id'> & {
+            id?: Config['NotificationIdType'];
+          },
+        );
+      } catch (createError) {
+        if (!this.isDuplicateReplicationConflict(createError)) {
+          throw createError;
+        }
+
+        await this.persistOneOffNotificationUpdate(
+          snapshot.id,
+          snapshot as unknown as Partial<Omit<OneOffNotificationInput<Config>, 'id'>>,
+        );
+      }
+
+      return { applied: true };
+    }
+
+    if (existingNotification) {
+      await this.persistNotificationUpdate(
+        snapshot.id,
+        snapshot as unknown as Partial<Omit<Notification<Config>, 'id'>>,
+      );
+
+      return { applied: true };
+    }
+
+    try {
+      await this.persistNotification(
+        snapshot as unknown as Omit<Notification<Config>, 'id'> & {
+          id?: Config['NotificationIdType'];
+        },
+      );
+    } catch (createError) {
+      if (!this.isDuplicateReplicationConflict(createError)) {
+        throw createError;
+      }
+
+      await this.persistNotificationUpdate(
+        snapshot.id,
+        snapshot as unknown as Partial<Omit<Notification<Config>, 'id'>>,
+      );
+    }
+
+    return { applied: true };
+  }
+
   /**
    * Update FHIR identifiers from a partial notification update.
    * Replaces identifier values for known systems when new values are provided.