@elastic/apm-rum-core - npm Package Compare versions

Comparing version 5.12.0 to 5.12.1

CHANGELOG.md

@@ -6,2 +6,13 @@ # Change Log
 
+## [5.12.1](https://github.com/elastic/apm-agent-rum-js/compare/@elastic/apm-rum-core@5.12.0...@elastic/apm-rum-core@5.12.1) (2021-07-15)
+
+
+### Bug Fixes
+
+* **rum-core:** ensure apmRequest is called for events ([#1055](https://github.com/elastic/apm-agent-rum-js/issues/1055)) ([7ae7e39](https://github.com/elastic/apm-agent-rum-js/commit/7ae7e395fc5cb45252b1fa92c6ef8675e98e0249))
+
+
+
+
+
 # [5.12.0](https://github.com/elastic/apm-agent-rum-js/compare/@elastic/apm-rum-core@5.11.0...@elastic/apm-rum-core@5.12.0) (2021-07-13)
@@ -8,0 +19,0 @@

dist/es/common/apm-server.js

@@ -63,3 +63,8 @@ import Queue from './queue';
 
-    return compressPayload(payload, headers).catch(function (error) {
+    var params = {
+      payload: payload,
+      headers: headers,
+      beforeSend: apmRequest
+    };
+    return compressPayload(params).catch(function (error) {
       if (__DEV__) {
@@ -69,7 +74,3 @@ _this2._loggingService.debug('Compressing the payload using CompressionStream API failed', error.message);
 
-      return {
-        payload: payload,
-        headers: headers,
-        beforeSend: apmRequest
-      };
+      return params;
     }).then(function (result) {
@@ -76,0 +77,0 @@ return _this2._makeHttpRequest('POST', endPoint, result);

dist/es/common/compress.js

@@ -295,3 +295,3 @@ import { Promise } from './polyfills';
 }
-export function compressPayload(payload, headers, type) {
+export function compressPayload(params, type) {
   if (type === void 0) {
@@ -304,8 +304,8 @@ type = 'gzip';
     if (!isCompressionStreamSupported) {
-      return resolve({
-        payload: payload,
-        headers: headers
-      });
+      return resolve(params);
     }
 
+    var payload = params.payload,
+        headers = params.headers,
+        beforeSend = params.beforeSend;
     var payloadStream = new Blob([payload]).stream();
@@ -317,3 +317,4 @@ var compressedStream = payloadStream.pipeThrough(new CompressionStream(type));
         payload: payload,
-        headers: headers
+        headers: headers,
+        beforeSend: beforeSend
       });
@@ -320,0 +321,0 @@ });

dist/lib/common/apm-server.js

@@ -80,3 +80,8 @@ "use strict";
 
-    return (0, _compress.compressPayload)(payload, headers).catch(function (error) {
+    var params = {
+      payload: payload,
+      headers: headers,
+      beforeSend: apmRequest
+    };
+    return (0, _compress.compressPayload)(params).catch(function (error) {
       if (_state.__DEV__) {
@@ -86,7 +91,3 @@ _this2._loggingService.debug('Compressing the payload using CompressionStream API failed', error.message);
 
-      return {
-        payload: payload,
-        headers: headers,
-        beforeSend: apmRequest
-      };
+      return params;
     }).then(function (result) {
@@ -93,0 +94,0 @@ return _this2._makeHttpRequest('POST', endPoint, result);

dist/lib/common/compress.js

@@ -311,3 +311,3 @@ "use strict";
 
-function compressPayload(payload, headers, type) {
+function compressPayload(params, type) {
   if (type === void 0) {
@@ -320,8 +320,8 @@ type = 'gzip';
     if (!isCompressionStreamSupported) {
-      return resolve({
-        payload: payload,
-        headers: headers
-      });
+      return resolve(params);
     }
 
+    var payload = params.payload,
+        headers = params.headers,
+        beforeSend = params.beforeSend;
     var payloadStream = new Blob([payload]).stream();
@@ -333,3 +333,4 @@ var compressedStream = payloadStream.pipeThrough(new CompressionStream(type));
         payload: payload,
-        headers: headers
+        headers: headers,
+        beforeSend: beforeSend
       });
@@ -336,0 +337,0 @@ });

package.json

 {
   "name": "@elastic/apm-rum-core",
-  "version": "5.12.0",
+  "version": "5.12.1",
   "description": "Elastic apm core",
@@ -46,3 +46,3 @@ "license": "MIT",
   ],
-  "gitHead": "494377db88299c6856791275685c2836634ce48b"
+  "gitHead": "d1016d6d23190b82f97e27df2f3aafd70cc74d54"
 }

src/common/apm-server.js

@@ -85,3 +85,4 @@ /**
     const apmRequest = this._configService.get('apmRequest')
-    return compressPayload(payload, headers)
+    const params = { payload, headers, beforeSend: apmRequest }
+    return compressPayload(params)
       .catch(error => {
@@ -94,3 +95,3 @@ if (__DEV__) {
         }
-        return { payload, headers, beforeSend: apmRequest }
+        return params
       })
@@ -97,0 +98,0 @@ .then(result => this._makeHttpRequest('POST', endPoint, result))

src/common/compress.js

@@ -297,3 +297,3 @@ /**
  */
-export function compressPayload(payload, headers, type = 'gzip') {
+export function compressPayload(params, type = 'gzip') {
   const isCompressionStreamSupported = typeof CompressionStream === 'function'
@@ -306,5 +306,5 @@ return new Promise(resolve => {
     if (!isCompressionStreamSupported) {
-      return resolve({ payload, headers })
+      return resolve(params)
     }
-
+    const { payload, headers, beforeSend } = params
     /**
@@ -328,5 +328,5 @@ * create a blob with the original payload data and convert it
       headers['Content-Encoding'] = type
-      return resolve({ payload, headers })
+      return resolve({ payload, headers, beforeSend })
     })
   })
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

501286

increased by0.12%

Lines of code

14159

increased by0.04%

No dependency changes