Skip to content

Commit d844968

Browse files
committed
feat(core): Introduce startActiveSpanManual
1 parent cf75ffe commit d844968

File tree

6 files changed

+77
-21
lines changed

6 files changed

+77
-21
lines changed

packages/browser/src/exports.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ export {
4040
getActiveSpan,
4141
startSpan,
4242
startInactiveSpan,
43+
startSpanManual,
4344
SDK_VERSION,
4445
setContext,
4546
setExtra,

packages/core/src/tracing/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,6 @@ export { extractTraceparentData, getActiveTransaction } from './utils';
77
export { SpanStatus } from './spanstatus';
88
export type { SpanStatusType } from './span';
99
// eslint-disable-next-line deprecation/deprecation
10-
export { trace, getActiveSpan, startSpan, startInactiveSpan, startActiveSpan } from './trace';
10+
export { trace, getActiveSpan, startSpan, startInactiveSpan, startActiveSpan, startSpanManual } from './trace';
1111
export { getDynamicSamplingContextFromClient } from './dynamicSamplingContext';
1212
export { setMeasurement } from './measurement';

packages/core/src/tracing/trace.ts

Lines changed: 72 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
import type { TransactionContext } from '@sentry/types';
22
import { isThenable } from '@sentry/utils';
33

4+
import type { Hub } from '../hub';
45
import { getCurrentHub } from '../hub';
56
import { hasTracingEnabled } from '../utils/hasTracingEnabled';
67
import type { Span } from './span';
@@ -23,15 +24,10 @@ export function trace<T>(
2324
// eslint-disable-next-line @typescript-eslint/no-empty-function
2425
onError: (error: unknown) => void = () => {},
2526
): T {
26-
const ctx = { ...context };
27-
// If a name is set and a description is not, set the description to the name.
28-
if (ctx.name !== undefined && ctx.description === undefined) {
29-
ctx.description = ctx.name;
30-
}
27+
const ctx = normalizeContext(context);
3128

3229
const hub = getCurrentHub();
3330
const scope = hub.getScope();
34-
3531
const parentSpan = scope.getSpan();
3632

3733
function createChildSpanOrTransaction(): Span | undefined {
@@ -42,6 +38,7 @@ export function trace<T>(
4238
}
4339

4440
const activeSpan = createChildSpanOrTransaction();
41+
4542
scope.setSpan(activeSpan);
4643

4744
function finishAndSetSpan(): void {
@@ -89,25 +86,13 @@ export function trace<T>(
8986
* and the `span` returned from the callback will be undefined.
9087
*/
9188
export function startSpan<T>(context: TransactionContext, callback: (span: Span | undefined) => T): T {
92-
const ctx = { ...context };
93-
// If a name is set and a description is not, set the description to the name.
94-
if (ctx.name !== undefined && ctx.description === undefined) {
95-
ctx.description = ctx.name;
96-
}
89+
const ctx = normalizeContext(context);
9790

9891
const hub = getCurrentHub();
9992
const scope = hub.getScope();
100-
10193
const parentSpan = scope.getSpan();
10294

103-
function createChildSpanOrTransaction(): Span | undefined {
104-
if (!hasTracingEnabled()) {
105-
return undefined;
106-
}
107-
return parentSpan ? parentSpan.startChild(ctx) : hub.startTransaction(ctx);
108-
}
109-
110-
const activeSpan = createChildSpanOrTransaction();
95+
const activeSpan = createChildSpanOrTransaction(hub, parentSpan, ctx);
11196
scope.setSpan(activeSpan);
11297

11398
function finishAndSetSpan(): void {
@@ -146,6 +131,52 @@ export function startSpan<T>(context: TransactionContext, callback: (span: Span
146131
*/
147132
export const startActiveSpan = startSpan;
148133

134+
/**
135+
* Similar to `Sentry.startSpan`. Wraps a function with a transaction/span, but does not finish the span
136+
* after the function is done automatically.
137+
*
138+
* The created span is the active span and will be used as parent by other spans created inside the function
139+
* and can be accessed via `Sentry.getActiveSpan()`, as long as the function is executed while the scope is active.
140+
*
141+
* Note that if you have not enabled tracing extensions via `addTracingExtensions`
142+
* or you didn't set `tracesSampleRate`, this function will not generate spans
143+
* and the `span` returned from the callback will be undefined.
144+
*/
145+
export function startSpanManual<T>(
146+
context: TransactionContext,
147+
callback: (span: Span | undefined, finish: () => void) => T,
148+
): T {
149+
const ctx = normalizeContext(context);
150+
151+
const hub = getCurrentHub();
152+
const scope = hub.getScope();
153+
const parentSpan = scope.getSpan();
154+
155+
const activeSpan = createChildSpanOrTransaction(hub, parentSpan, ctx);
156+
scope.setSpan(activeSpan);
157+
158+
function finishAndSetSpan(): void {
159+
activeSpan && activeSpan.finish();
160+
hub.getScope().setSpan(parentSpan);
161+
}
162+
163+
let maybePromiseResult: T;
164+
try {
165+
maybePromiseResult = callback(activeSpan, finishAndSetSpan);
166+
} catch (e) {
167+
activeSpan && activeSpan.setStatus('internal_error');
168+
throw e;
169+
}
170+
171+
if (isThenable(maybePromiseResult)) {
172+
Promise.resolve(maybePromiseResult).then(undefined, () => {
173+
activeSpan && activeSpan.setStatus('internal_error');
174+
});
175+
}
176+
177+
return maybePromiseResult;
178+
}
179+
149180
/**
150181
* Creates a span. This span is not set as active, so will not get automatic instrumentation spans
151182
* as children or be able to be accessed via `Sentry.getSpan()`.
@@ -178,3 +209,24 @@ export function startInactiveSpan(context: TransactionContext): Span | undefined
178209
export function getActiveSpan(): Span | undefined {
179210
return getCurrentHub().getScope().getSpan();
180211
}
212+
213+
function createChildSpanOrTransaction(
214+
hub: Hub,
215+
parentSpan: Span | undefined,
216+
ctx: TransactionContext,
217+
): Span | undefined {
218+
if (!hasTracingEnabled()) {
219+
return undefined;
220+
}
221+
return parentSpan ? parentSpan.startChild(ctx) : hub.startTransaction(ctx);
222+
}
223+
224+
function normalizeContext(context: TransactionContext): TransactionContext {
225+
const ctx = { ...context };
226+
// If a name is set and a description is not, set the description to the name.
227+
if (ctx.name !== undefined && ctx.description === undefined) {
228+
ctx.description = ctx.name;
229+
}
230+
231+
return ctx;
232+
}

packages/node/src/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ export {
6060
// eslint-disable-next-line deprecation/deprecation
6161
startActiveSpan,
6262
startInactiveSpan,
63+
startSpanManual,
6364
} from '@sentry/core';
6465
export type { SpanStatusType } from '@sentry/core';
6566
export { autoDiscoverNodePerformanceMonitoringIntegrations } from './tracing';

packages/serverless/src/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,4 +55,5 @@ export {
5555
// eslint-disable-next-line deprecation/deprecation
5656
startActiveSpan,
5757
startInactiveSpan,
58+
startSpanManual,
5859
} from '@sentry/node';

packages/sveltekit/src/server/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ export {
5050
// eslint-disable-next-line deprecation/deprecation
5151
startActiveSpan,
5252
startInactiveSpan,
53+
startSpanManual,
5354
} from '@sentry/node';
5455

5556
// We can still leave this for the carrier init and type exports

0 commit comments

Comments
 (0)