Merge branch 'develop' into lforst-sourcemap-debug-meta

Author: Luca Forstner

package.json

@@ -52,6 +52,7 @@
     "packages/react",
     "packages/remix",
     "packages/replay",
+    "packages/replay-worker",
     "packages/serverless",
     "packages/svelte",
     "packages/tracing",

packages/browser/src/integrations/dedupe.ts

@@ -23,6 +23,12 @@ export class Dedupe implements Integration {
    */
   public setupOnce(addGlobalEventProcessor: (callback: EventProcessor) => void, getCurrentHub: () => Hub): void {
     const eventProcessor: EventProcessor = currentEvent => {
+      // We want to ignore any non-error type events, e.g. transactions or replays
+      // These should never be deduped, and also not be compared against as _previousEvent.
+      if (currentEvent.type) {
+        return currentEvent;
+      }
+
       const self = getCurrentHub().getIntegration(Dedupe);
       if (self) {
         // Juuust in case something goes wrong

packages/browser/test/integration/suites/api.js

@@ -112,12 +112,26 @@ describe('API', function () {
 
       // Same exceptions, different stacktrace (different line number), don't dedupe
       throwSameConsecutiveErrors('bar');
+
+      // Same exception, with transaction in between, dedupe
+      throwError();
+      Sentry.captureEvent({
+        event_id: 'aa3ff046696b4bc6b609ce6d28fde9e2',
+        message: 'someMessage',
+        transaction: 'wat',
+        type: 'transaction',
+      });
+      throwError();
     }).then(function (summary) {
+      // We have a length of one here since transactions don't go through beforeSend
+      // and we add events to summary in beforeSend
+      assert.equal(summary.events.length, 6);
       assert.match(summary.events[0].exception.values[0].value, /Exception no \d+/);
       assert.match(summary.events[1].exception.values[0].value, /Exception no \d+/);
       assert.equal(summary.events[2].exception.values[0].value, 'foo');
       assert.equal(summary.events[3].exception.values[0].value, 'bar');
       assert.equal(summary.events[4].exception.values[0].value, 'bar');
+      assert.equal(summary.events[5].exception.values[0].value, 'foo');
     });
   });
 

packages/integrations/src/dedupe.ts

@@ -23,6 +23,12 @@ export class Dedupe implements Integration {
    */
   public setupOnce(addGlobalEventProcessor: (callback: EventProcessor) => void, getCurrentHub: () => Hub): void {
     const eventProcessor: EventProcessor = currentEvent => {
+      // We want to ignore any non-error type events, e.g. transactions or replays
+      // These should never be deduped, and also not be compared against as _previousEvent.
+      if (currentEvent.type) {
+        return currentEvent;
+      }
+
       const self = getCurrentHub().getIntegration(Dedupe);
       if (self) {
         // Juuust in case something goes wrong

packages/integrations/test/dedupe.test.ts

@@ -1,6 +1,6 @@
-import type { Event as SentryEvent, Exception, StackFrame, Stacktrace } from '@sentry/types';
+import type { Event as SentryEvent, EventProcessor, Exception, Hub, StackFrame, Stacktrace } from '@sentry/types';
 
-import { _shouldDropEvent } from '../src/dedupe';
+import { _shouldDropEvent, Dedupe } from '../src/dedupe';
 
 type EventWithException = SentryEvent & {
   exception: {
@@ -175,4 +175,48 @@ describe('Dedupe', () => {
       expect(_shouldDropEvent(eventB, eventC)).toBe(false);
     });
   });
+
+  describe('setupOnce', () => {
+    let dedupeFunc: EventProcessor;
+
+    beforeEach(function () {
+      const integration = new Dedupe();
+      const addGlobalEventProcessor = (callback: EventProcessor) => {
+        dedupeFunc = callback;
+      };
+
+      const getCurrentHub = () => {
+        return {
+          getIntegration() {
+            return integration;
+          },
+        } as unknown as Hub;
+      };
+
+      integration.setupOnce(addGlobalEventProcessor, getCurrentHub);
+    });
+
+    it('ignores consecutive errors', () => {
+      expect(dedupeFunc(clone(exceptionEvent), {})).not.toBeNull();
+      expect(dedupeFunc(clone(exceptionEvent), {})).toBeNull();
+      expect(dedupeFunc(clone(exceptionEvent), {})).toBeNull();
+    });
+
+    it('ignores transactions between errors', () => {
+      expect(dedupeFunc(clone(exceptionEvent), {})).not.toBeNull();
+      expect(
+        dedupeFunc(
+          {
+            event_id: 'aa3ff046696b4bc6b609ce6d28fde9e2',
+            message: 'someMessage',
+            transaction: 'wat',
+            type: 'transaction',
+          },
+          {},
+        ),
+      ).not.toBeNull();
+      expect(dedupeFunc(clone(exceptionEvent), {})).toBeNull();
+      expect(dedupeFunc(clone(exceptionEvent), {})).toBeNull();
+    });
+  });
 });

packages/replay-worker/.eslintignore

@@ -0,0 +1 @@
+vendor

packages/replay-worker/.eslintrc.js

@@ -0,0 +1,17 @@
+// Note: All paths are relative to the directory in which eslint is being run, rather than the directory where this file
+// lives
+
+// ESLint config docs: https://eslint.org/docs/user-guide/configuring/
+
+module.exports = {
+  extends: ['../../.eslintrc.js'],
+  overrides: [
+    {
+      files: ['src/**/*.ts'],
+      rules: {
+        // We cannot use backticks, as that conflicts with the stringified worker
+        'prefer-template': 'off',
+      },
+    },
+  ],
+};

packages/replay-worker/.gitignore

@@ -0,0 +1,5 @@
+node_modules
+/*.tgz
+.eslintcache
+build
+!vendor/*.d.ts

packages/replay-worker/LICENSE

@@ -0,0 +1,14 @@
+Copyright (c) 2023 Sentry (https://sentry.io) and individual contributors. All rights reserved.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated
+documentation files (the "Software"), to deal in the Software without restriction, including without limitation the
+rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit
+persons to whom the Software is furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all copies or substantial portions of the
+Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE
+WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

packages/replay-worker/README.md

@@ -0,0 +1,12 @@
+<p align="center">
+  <a href="https://sentry.io/?utm_source=github&utm_medium=logo" target="_blank">
+    <img src="https://sentry-brand.storage.googleapis.com/sentry-wordmark-dark-280x84.png" alt="Sentry" width="280" height="84">
+  </a>
+</p>
+
+# Sentry Session Replay Worker
+
+This is an internal package that is used by @sentry/replay.
+It generates a web worker and converts it to a string, so that we can process it easier in replay.
+
+By extracting this into a dedicated (private, internal) package, we can streamline the build of replay.

packages/replay-worker/jest.config.js

@@ -0,0 +1 @@
+module.exports = require('../../jest/jest.config.js');

packages/replay-worker/package.json

@@ -0,0 +1,51 @@
+{
+  "name": "@sentry-internal/replay-worker",
+  "version": "7.37.2",
+  "description": "Worker for @sentry/replay",
+  "main": "build/index.js",
+  "module": "build/index.js",
+  "sideEffects": false,
+  "private": true,
+  "scripts": {
+    "build": "yarn build:transpile",
+    "build:transpile": "rollup -c rollup.worker.config.js",
+    "build:types": "yarn build:transpile",
+    "build:dev": "yarn build",
+    "build:watch": "run-p build:transpile:watch",
+    "build:dev:watch": "run-p build:watch",
+    "build:transpile:watch": "yarn build:rollup --watch",
+    "clean": "rimraf build",
+    "fix": "run-s fix:eslint fix:prettier",
+    "fix:eslint": "eslint . --format stylish --fix",
+    "fix:prettier": "prettier --write \"{src,test}/**/*.ts\"",
+    "lint": "run-s lint:prettier lint:eslint",
+    "lint:eslint": "eslint . --format stylish",
+    "lint:prettier": "prettier --check \"{src,test}/**/*.ts\"",
+    "test": "jest",
+    "test:watch": "jest --watch"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/getsentry/sentry-javascript.git"
+  },
+  "author": "Sentry",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/getsentry/sentry-javascript/issues"
+  },
+  "homepage": "https://docs.sentry.io/platforms/javascript/session-replay/",
+  "devDependencies": {
+    "@types/pako": "^2.0.0",
+    "rollup-plugin-copy": "~3.4.0",
+    "tslib": "^1.9.3"
+  },
+  "dependencies": {
+    "pako": "^2.1.0"
+  },
+  "engines": {
+    "node": ">=12"
+  },
+  "volta": {
+    "extends": "../../package.json"
+  }
+}

packages/replay/rollup.config.worker.js renamed to packages/replay-worker/rollup.worker.config.js

@@ -4,15 +4,16 @@ import resolve from '@rollup/plugin-node-resolve';
 import typescript from '@rollup/plugin-typescript';
 import { defineConfig } from 'rollup';
 import { terser } from 'rollup-plugin-terser';
+import copy from 'rollup-plugin-copy';
 
 const config = defineConfig({
-  input: ['./worker/src/worker.ts'],
+  input: ['./src/worker.ts'],
   output: {
-    dir: './src/worker/',
+    dir: './build/',
     format: 'esm',
   },
   plugins: [
-    typescript({ tsconfig: './tsconfig.worker.json' }),
+    typescript({ tsconfig: './tsconfig.json', inlineSourceMap: false, sourceMap: false, inlineSources: false }),
     resolve(),
     terser({
       mangle: {
@@ -25,6 +26,9 @@ const config = defineConfig({
         return `export default \`${code}\`;`;
       },
     },
+    copy({
+      targets: [{ src: 'vendor/*', dest: 'build' }],
+    }),
   ],
 });
 

packages/replay/worker/src/Compressor.ts renamed to packages/replay-worker/src/Compressor.ts

@@ -1,5 +1,8 @@
-import { constants, Deflate } from 'pako';
+import { constants, Deflate, deflate } from 'pako';
 
+/**
+ * A stateful compressor that can be used to batch compress events.
+ */
 export class Compressor {
   /**
    * pako deflator instance
@@ -15,10 +18,16 @@ export class Compressor {
     this._init();
   }
 
+  /**
+   * Clear the compressor buffer.
+   */
   public clear(): void {
     this._init();
   }
 
+  /**
+   * Add an event to the compressor buffer.
+   */
   public addEvent(data: string): void {
     if (!data) {
       throw new Error('Adding invalid event');
@@ -34,6 +43,9 @@ export class Compressor {
     this._hasEvents = true;
   }
 
+  /**
+   * Finish compression of the current buffer.
+   */
   public finish(): Uint8Array {
     // We should always have a list, it can be empty
     this.deflate.push(']', constants.Z_FINISH);
@@ -51,6 +63,9 @@ export class Compressor {
     return result;
   }
 
+  /**
+   * Re-initialize the compressor buffer.
+   */
   private _init(): void {
     this._hasEvents = false;
     this.deflate = new Deflate();
@@ -59,3 +74,10 @@ export class Compressor {
     this.deflate.push('[', constants.Z_NO_FLUSH);
   }
 }
+
+/**
+ * Compress a string.
+ */
+export function compress(data: string): Uint8Array {
+  return deflate(data);
+}

packages/replay/worker/src/handleMessage.ts renamed to packages/replay-worker/src/handleMessage.ts

@@ -1,18 +1,18 @@
 /* eslint-disable @typescript-eslint/no-unsafe-member-access */
-import { Compressor } from './Compressor';
+import { compress, Compressor } from './Compressor';
 
 const compressor = new Compressor();
 
 interface Handlers {
   clear: () => void;
   addEvent: (data: string) => void;
-  finish: () => void;
+  finish: () => Uint8Array;
+  compress: (data: string) => Uint8Array;
 }
 
 const handlers: Handlers = {
   clear: () => {
     compressor.clear();
-    return '';
   },
 
   addEvent: (data: string) => {
@@ -22,8 +22,15 @@ const handlers: Handlers = {
   finish: () => {
     return compressor.finish();
   },
+
+  compress: (data: string) => {
+    return compress(data);
+  },
 };
 
+/**
+ * Handler for worker messages.
+ */
 export function handleMessage(e: MessageEvent): void {
   const method = e.data.method as string;
   const id = e.data.id as number;

packages/replay/worker/src/worker.ts renamed to packages/replay-worker/src/worker.ts

@@ -0,0 +1,7 @@
+// TODO Once https://github.com/microsoft/TypeScript/issues/33094 is done (if it ever is), this file can disappear, as
+// it's purely a placeholder to satisfy VSCode.
+{
+  "extends": "../tsconfig.test.json",
+
+  "include": ["./**/*"]
+}

packages/replay-worker/test/tsconfig.json

@@ -1,8 +1,8 @@
 import pako from 'pako';
 
-import { Compressor } from '../../../worker/src/Compressor';
+import { Compressor } from '../../src/Compressor';
 
-describe('Unit | worker | Compressor', () => {
+describe('Compressor', () => {
   it('compresses multiple events', () => {
     const compressor = new Compressor();
 

packages/replay/test/unit/worker/Compressor.test.ts renamed to packages/replay-worker/test/unit/Compressor.test.ts

@@ -0,0 +1,11 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "module": "esnext",
+    "lib": ["webworker", "scripthost"],
+    "esModuleInterop": true,
+    "target": "es6",
+    "strictPropertyInitialization": false
+  },
+  "include": ["src/**/*.ts"]
+}

packages/replay-worker/tsconfig.json

@@ -0,0 +1,7 @@
+{
+  "extends": "./tsconfig.json",
+  "include": ["test/**/*.ts"],
+  "compilerOptions": {
+    "types": ["node", "jest"]
+  }
+}

packages/replay-worker/tsconfig.test.json

@@ -0,0 +1 @@
+export function getWorkerURL(): string;