fix sentry replay skipping

Author: neSpecc

workers/sentry/src/index.ts

@@ -67,10 +67,12 @@ export default class SentryEventWorker extends Worker {
 
   /**
    * Filter out binary items that crash parseEnvelope
+   * Also filters out all Sentry Replay events (replay_event and replay_recording)
    */
   private filterOutBinaryItems(rawEvent: string): string {
     const lines = rawEvent.split('\n');
     const filteredLines = [];
+    let isInReplayBlock = false;
 
     for (let i = 0; i < lines.length; i++) {
       const line = lines[i];
@@ -90,17 +92,42 @@ export default class SentryEventWorker extends Worker {
         // Try to parse as JSON to check if it's a header
         const parsed = JSON.parse(line);
 
-        // If it's a replay header, skip this line and the next one (payload)
+        // Check if this is a replay event type
         if (parsed.type === 'replay_recording' || parsed.type === 'replay_event') {
-          // Skip the next line too (which would be the payload)
-          i++;
+          // Mark that we're in a replay block and skip this line
+          isInReplayBlock = true;
           continue;
         }
 
-        // Keep valid headers and other JSON data
-        filteredLines.push(line);
+        // If we're in a replay block, check if this is still part of it
+        if (isInReplayBlock) {
+          // Check if this line is part of replay data (segment_id, length, etc.)
+          if ('segment_id' in parsed || ('length' in parsed && parsed.type !== 'event') || 'replay_id' in parsed) {
+            // Still in replay block, skip this line
+            continue;
+          }
+
+          // If it's a new envelope item (like event), we've exited the replay block
+          if (parsed.type === 'event' || parsed.type === 'transaction' || parsed.type === 'session') {
+            isInReplayBlock = false;
+          } else {
+            // Unknown type, assume we're still in replay block
+            continue;
+          }
+        }
+
+        // Keep valid headers and other JSON data (not in replay block)
+        if (!isInReplayBlock) {
+          filteredLines.push(line);
+        }
       } catch {
-        // If line doesn't parse as JSON, it might be binary data - skip it
+        // If line doesn't parse as JSON, it might be binary data
+        // If we're in a replay block, skip it (it's part of replay recording)
+        if (isInReplayBlock) {
+          continue;
+        }
+
+        // If not in replay block and not JSON, it might be corrupted data - skip it
         continue;
       }
     }

workers/sentry/tests/index.test.ts

@@ -852,6 +852,82 @@ describe('SentryEventWorker', () => {
         }),
       });
     });
+
+    it('should ignore envelope with only replay_event and replay_recording items', async () => {
+      /**
+       * Test case based on real-world scenario where envelope contains only replay data
+       * This should not crash with "Unexpected end of JSON input" error
+       */
+      const envelopeLines = [
+        // Envelope header
+        JSON.stringify({
+          /* eslint-disable @typescript-eslint/naming-convention */
+          event_id: '62680958b3ab4497886375e06533d86a',
+          sent_at: '2025-12-24T13:16:34.580Z',
+          /* eslint-enable @typescript-eslint/naming-convention */
+          sdk: { name: 'sentry.javascript.react', version: '10.22.0' },
+        }),
+        // Replay event item header - should be filtered out
+        JSON.stringify({ type: 'replay_event' }),
+        // Replay event item payload (large JSON) - should be filtered out
+        JSON.stringify({
+          /* eslint-disable @typescript-eslint/naming-convention */
+          type: 'replay_event',
+          replay_start_timestamp: 1766582182.757,
+          timestamp: 1766582194.579,
+          error_ids: [],
+          trace_ids: [],
+          urls: ['https://my.huntio.ru/applicants', 'https://my.huntio.ru/applicants/1270067'],
+          replay_id: '62680958b3ab4497886375e06533d86a',
+          segment_id: 1,
+          replay_type: 'session',
+          request: {
+            url: 'https://my.huntio.ru/applicants/1270067',
+            headers: {
+              'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
+            },
+          },
+          event_id: '62680958b3ab4497886375e06533d86a',
+          environment: 'production',
+          release: '1.0.7',
+          sdk: {
+            integrations: ['InboundFilters', 'FunctionToString', 'BrowserApiErrors', 'Breadcrumbs'],
+            name: 'sentry.javascript.react',
+            version: '10.22.0',
+            settings: { infer_ip: 'auto' },
+          },
+          user: {
+            id: 487,
+            email: '[email protected]',
+            username: 'Прохорова Наталья',
+          },
+          contexts: { react: { version: '19.1.0' } },
+          transaction: '/applicants/1270067',
+          platform: 'javascript',
+          /* eslint-enable @typescript-eslint/naming-convention */
+        }),
+        // Replay recording item header - should be filtered out
+        JSON.stringify({ type: 'replay_recording', length: 16385 }),
+        // Segment ID - should be filtered out
+        JSON.stringify({ segment_id: 1 }),
+        // Binary data (simulated) - should be filtered out
+        'xnFWy@v$xAlJ=&fS~¾˶IJ<Dڒ%8yX]]ˣ·9V|JGd!+%fF',
+      ];
+
+      const envelopeString = envelopeLines.join('\n');
+
+      // Should not throw "Unexpected end of JSON input" error
+      await worker.handle({
+        payload: {
+          envelope: b64encode(envelopeString),
+        },
+        projectId: '123',
+        catcherType: 'external/sentry',
+      });
+
+      // Should not send any tasks since all items were replay-related and filtered out
+      expect(mockedAmqpChannel.sendToQueue).not.toHaveBeenCalled();
+    });
   });
 
   describe('envelope parsing', () => {