diff --git a/packages/core/src/transports/base.ts b/packages/core/src/transports/base.ts index 4a3be77e8531..19a92ebc8599 100644 --- a/packages/core/src/transports/base.ts +++ b/packages/core/src/transports/base.ts @@ -24,6 +24,8 @@ import { updateRateLimits, } from '@sentry/utils'; +import { getCurrentHub } from '../hub'; + export const DEFAULT_TRANSPORT_BUFFER_SIZE = 30; /** @@ -40,11 +42,14 @@ export function createTransport( ), ): Transport { let rateLimits: RateLimits = {}; - const flush = (timeout?: number): PromiseLike => buffer.drain(timeout); + const client = getCurrentHub().getClient(); function send(envelope: Envelope): PromiseLike { const filteredEnvelopeItems: EnvelopeItem[] = []; + if (client && client.emit) { + client.emit('beforeEnvelope', envelope); + } // Drop rate limited items from envelope forEachEnvelopeItem(envelope, (item, type) => {