Skip to content

Commit 3ff15fb

Browse files
committed
ref: Avoid some usage of SyncPromise where not needed
We make quite heavy use of it in event processing, not touching this for now, but in other places it should not be needed IMHO.
1 parent 28d183a commit 3ff15fb

File tree

5 files changed

+11
-12
lines changed

5 files changed

+11
-12
lines changed

packages/browser/src/transports/fetch.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import type { Transport, TransportMakeRequestResponse, TransportRequest } from '@sentry/core';
2-
import { createTransport, rejectedSyncPromise } from '@sentry/core';
2+
import { createTransport } from '@sentry/core';
33
import { clearCachedImplementation, getNativeImplementation } from '@sentry-internal/browser-utils';
44
import type { WINDOW } from '../helpers';
55
import type { BrowserTransportOptions } from './types';
@@ -41,7 +41,7 @@ export function makeFetchTransport(
4141

4242
if (!nativeFetch) {
4343
clearCachedImplementation('fetch');
44-
return rejectedSyncPromise('No fetch implementation available');
44+
return Promise.reject('No fetch implementation available');
4545
}
4646

4747
try {
@@ -61,7 +61,7 @@ export function makeFetchTransport(
6161
clearCachedImplementation('fetch');
6262
pendingBodySize -= requestSize;
6363
pendingCount--;
64-
return rejectedSyncPromise(e);
64+
return Promise.reject(e);
6565
}
6666
}
6767

packages/bun/src/transports/index.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import type { BaseTransportOptions, Transport, TransportMakeRequestResponse, TransportRequest } from '@sentry/core';
2-
import { createTransport, rejectedSyncPromise, suppressTracing } from '@sentry/core';
2+
import { createTransport, suppressTracing } from '@sentry/core';
33

44
export interface BunTransportOptions extends BaseTransportOptions {
55
/** Custom headers for the transport. Used by the XHRTransport and FetchTransport */
@@ -30,7 +30,7 @@ export function makeFetchTransport(options: BunTransportOptions): Transport {
3030
});
3131
});
3232
} catch (e) {
33-
return rejectedSyncPromise(e);
33+
return Promise.reject(e);
3434
}
3535
}
3636

packages/core/src/transports/base.ts

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ import {
1616
} from '../utils/envelope';
1717
import { type PromiseBuffer, makePromiseBuffer, SENTRY_BUFFER_FULL_ERROR } from '../utils/promisebuffer';
1818
import { type RateLimits, isRateLimited, updateRateLimits } from '../utils/ratelimit';
19-
import { resolvedSyncPromise } from '../utils/syncpromise';
2019

2120
export const DEFAULT_TRANSPORT_BUFFER_SIZE = 64;
2221

@@ -51,7 +50,7 @@ export function createTransport(
5150

5251
// Skip sending if envelope is empty after filtering out rate limited events
5352
if (filteredEnvelopeItems.length === 0) {
54-
return resolvedSyncPromise({});
53+
return Promise.resolve({});
5554
}
5655

5756
const filteredEnvelope: Envelope = createEnvelope(envelope[0], filteredEnvelopeItems as (typeof envelope)[1]);
@@ -87,7 +86,7 @@ export function createTransport(
8786
if (error === SENTRY_BUFFER_FULL_ERROR) {
8887
DEBUG_BUILD && debug.error('Skipped sending event because buffer is full.');
8988
recordEnvelopeLoss('queue_overflow');
90-
return resolvedSyncPromise({});
89+
return Promise.resolve({});
9190
} else {
9291
throw error;
9392
}

packages/deno/src/transports/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ export function makeFetchTransport(options: DenoTransportOptions): Transport {
4848
});
4949
});
5050
} catch (e) {
51-
return rejectedSyncPromise(e);
51+
return Promise.reject(e);
5252
}
5353
}
5454

packages/replay-internal/src/util/sendReplayRequest.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import type { RateLimits, ReplayEvent, TransportMakeRequestResponse } from '@sentry/core';
2-
import { getClient, getCurrentScope, isRateLimited, resolvedSyncPromise, updateRateLimits } from '@sentry/core';
2+
import { getClient, getCurrentScope, isRateLimited, updateRateLimits } from '@sentry/core';
33
import { REPLAY_EVENT_NAME, UNABLE_TO_SEND_REPLAY } from '../constants';
44
import { DEBUG_BUILD } from '../debug-build';
55
import type { SendReplayData } from '../types';
@@ -34,7 +34,7 @@ export async function sendReplayRequest({
3434
const dsn = client?.getDsn();
3535

3636
if (!client || !transport || !dsn || !session.sampled) {
37-
return resolvedSyncPromise({});
37+
return Promise.resolve({});
3838
}
3939

4040
const baseEvent: ReplayEvent = {
@@ -55,7 +55,7 @@ export async function sendReplayRequest({
5555
// Taken from baseclient's `_processEvent` method, where this is handled for errors/transactions
5656
client.recordDroppedEvent('event_processor', 'replay');
5757
DEBUG_BUILD && debug.log('An event processor returned `null`, will not send event.');
58-
return resolvedSyncPromise({});
58+
return Promise.resolve({});
5959
}
6060

6161
/*

0 commit comments

Comments
 (0)