feat(backend): enforce sibling-device envelope coverage on send and edit (#188)

apps/backend/src/__tests__/auth.integration.test.ts

@@ -37,6 +37,20 @@ vi.mock('@stellar/stellar-sdk', () => ({
   },
 }));
 
+vi.mock('../services/pushNotification.js', () => ({
+  dispatchOfflinePush: vi.fn().mockResolvedValue(undefined),
+  reenableExpiredBackoffs: vi.fn().mockResolvedValue(undefined),
+  FILE_CONTENT_TYPES: new Set<string>(),
+}));
+
+vi.mock('../services/deliveryPipeline.js', () => ({
+  deliverMessage: vi.fn().mockResolvedValue(undefined),
+}));
+
+vi.mock('../services/deviceDelivery.js', () => ({
+  publishToDevice: vi.fn().mockResolvedValue(undefined),
+}));
+
 // ── Import app after mocks are registered ─────────────────────────────────
 
 const { app } = await import('../app.js');

apps/backend/src/__tests__/health.test.ts

@@ -17,6 +17,20 @@ vi.mock('../db/index.js', () => ({
   },
 }));
 
+vi.mock('../services/pushNotification.js', () => ({
+  dispatchOfflinePush: vi.fn().mockResolvedValue(undefined),
+  reenableExpiredBackoffs: vi.fn().mockResolvedValue(undefined),
+  FILE_CONTENT_TYPES: new Set<string>(),
+}));
+
+vi.mock('../services/deliveryPipeline.js', () => ({
+  deliverMessage: vi.fn().mockResolvedValue(undefined),
+}));
+
+vi.mock('../services/deviceDelivery.js', () => ({
+  publishToDevice: vi.fn().mockResolvedValue(undefined),
+}));
+
 const { app } = await import('../app.js');
 
 beforeEach(() => {

apps/backend/src/__tests__/messageEdit.test.ts

@@ -42,9 +42,34 @@ vi.mock('../lib/conversationCache.js', () => ({
   invalidateConversationCaches: vi.fn().mockResolvedValue(undefined),
 }));
 
+vi.mock('../lib/redis.js', () => ({ redis: null }));
+
+vi.mock('../services/pushNotification.js', () => ({
+  dispatchOfflinePush: vi.fn().mockResolvedValue(undefined),
+  FILE_CONTENT_TYPES: new Set<string>(),
+}));
+
+vi.mock('../services/deliveryPipeline.js', () => ({
+  deliverMessage: vi.fn(
+    async (
+      io: { to: (r: string) => { emit: (e: string, d: unknown) => void } },
+      message: unknown,
+      conversationId: string,
+    ) => {
+      io.to(conversationId).emit('new_message', message);
+    },
+  ),
+}));
+
+vi.mock('../services/deviceDelivery.js', () => ({
+  publishToDevice: vi.fn().mockResolvedValue(undefined),
+}));
+
 vi.mock('drizzle-orm', () => ({
   and: vi.fn((...args: unknown[]) => args),
   eq: vi.fn((col: unknown, val: unknown) => ({ col, val })),
+  ne: vi.fn((col: unknown, val: unknown) => ({ col, val, op: 'ne' })),
+  isNull: vi.fn((col: unknown) => ({ col, op: 'isNull' })),
   lt: vi.fn(),
   desc: vi.fn(),
   sql: vi.fn(),

apps/backend/src/__tests__/readReceipts.test.ts

@@ -35,6 +35,23 @@ vi.mock('drizzle-orm', () => ({
   isNull: vi.fn((col: unknown) => ({ col, op: 'isNull' })),
   lt: vi.fn(),
   desc: vi.fn(),
+  sql: vi.fn(),
+  inArray: vi.fn((col: unknown, vals: unknown) => ({ col, vals })),
+}));
+
+vi.mock('../lib/redis.js', () => ({ redis: null }));
+
+vi.mock('../services/pushNotification.js', () => ({
+  dispatchOfflinePush: vi.fn().mockResolvedValue(undefined),
+  FILE_CONTENT_TYPES: new Set<string>(),
+}));
+
+vi.mock('../services/deliveryPipeline.js', () => ({
+  deliverMessage: vi.fn().mockResolvedValue(undefined),
+}));
+
+vi.mock('../services/deviceDelivery.js', () => ({
+  publishToDevice: vi.fn().mockResolvedValue(undefined),
   inArray: vi.fn((col: unknown, vals: unknown) => ({ col, vals })),
   sql: vi.fn(),
 }));

apps/backend/src/__tests__/resume.socket.test.ts

@@ -47,6 +47,19 @@ vi.mock('../services/resumeStream.js', () => ({
   publishEphemeral: mockPublish,
 }));
 
+vi.mock('../services/pushNotification.js', () => ({
+  dispatchOfflinePush: vi.fn().mockResolvedValue(undefined),
+  FILE_CONTENT_TYPES: new Set<string>(),
+}));
+
+vi.mock('../services/deliveryPipeline.js', () => ({
+  deliverMessage: vi.fn().mockResolvedValue(undefined),
+}));
+
+vi.mock('../services/deviceDelivery.js', () => ({
+  publishToDevice: vi.fn().mockResolvedValue(undefined),
+}));
+
 // ── Helpers ──────────────────────────────────────────────────────────────────
 
 function makeSocket(userId: string) {