Revert "Clean await detector data after each method and publication"

This reverts commit 70a7d5e.
monti-apm · Oct 16, 2024 · 87cc521 · 87cc521
1 parent 70a7d5e
commit 87cc521
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 27 deletions.
diff --git a/lib/hijack/wrap_session.js b/lib/hijack/wrap_session.js
@@ -156,9 +156,6 @@ export function wrapSession (sessionProto) {
           Kadira.tracer.event(kadiraInfo.trace, EventType.Complete);
         }
 
-        awaitDetector.clean(kadiraInfo.awaitDetectorStore);
-        kadiraInfo.awaitDetectorStore = undefined;
-
         // processing the message
         let trace = Kadira.tracer.buildTrace(kadiraInfo.trace);
         Kadira.EventBus.emit('method', 'methodCompleted', trace, this);
@@ -185,14 +182,7 @@ Meteor.server.publish_handlers = new Proxy(Meteor.server.publish_handlers, {
     }
 
     return function (...args) {
-      return awaitDetector.detect(() => {
-        let info = Kadira._getInfo();
-        if (info) {
-          info.awaitDetectorStore = awaitDetector.getStore();
-        }
-
-        return origMethod.apply(this, args);
-      });
+      return awaitDetector.detect(() => origMethod.apply(this, args));
     };
   }
 });
@@ -215,14 +205,7 @@ Meteor.methods = function (methodMap) {
 function wrapMethodHandlerForErrors (name, originalHandler, methodMap) {
   methodMap[name] = function () {
     try {
-      return awaitDetector.detect(() => {
-        let info = Kadira._getInfo();
-        if (info) {
-          info.awaitDetectorStore = awaitDetector.getStore();
-        }
-
-        return originalHandler.apply(this, arguments);
-      });
+      return awaitDetector.detect(() => originalHandler.apply(this, arguments));
     } catch (ex) {
       if (ex && Kadira._getInfo()) {
         // sometimes error may be just a string or a primitive

diff --git a/lib/hijack/wrap_subscription.js b/lib/hijack/wrap_subscription.js
@@ -2,7 +2,6 @@ import { MeteorDebugIgnore } from './error';
 import { _ } from 'meteor/underscore';
 import { runWithEnvironment } from '../async/als';
 import { EventType } from '../constants';
-import { awaitDetector } from '../async/async-hook';
 
 export function wrapSubscription (subscriptionProto) {
   let originalRunHandler = subscriptionProto._runHandler;
@@ -41,9 +40,6 @@ export function wrapSubscription (subscriptionProto) {
         Kadira.tracer.endLastEvent(kadiraInfo.trace);
         Kadira.tracer.event(kadiraInfo.trace, EventType.Complete);
         trace = Kadira.tracer.buildTrace(kadiraInfo.trace);
-
-        awaitDetector.clean(kadiraInfo.awaitDetectorStore);
-        kadiraInfo.awaitDetectorStore = undefined;
       }
 
       Kadira.EventBus.emit('pubsub', 'subCompleted', trace, this._session, this);
@@ -72,9 +68,6 @@ export function wrapSubscription (subscriptionProto) {
       Kadira.tracer.event(kadiraInfo.trace, EventType.Error, {error: errorForApm});
       let trace = Kadira.tracer.buildTrace(kadiraInfo.trace);
 
-      awaitDetector.clean(kadiraInfo.awaitDetectorStore);
-      kadiraInfo.awaitDetectorStore = undefined;
-
       Kadira.models.pubsub._trackError(this._session, this, trace);
 
       // error tracking can be disabled and if there is a trace

diff --git a/package.js b/package.js
@@ -9,7 +9,7 @@ Package.describe({
 
 let npmModules = {
   debug: '0.8.1',
-  '@monti-apm/core': '2.0.0-beta.6',
+  '@monti-apm/core': '2.0.0-beta.5',
   'lru-cache': '5.1.1',
   'json-stringify-safe': '5.0.1',
   'monti-apm-sketches-js': '0.0.3',