@@ -16,7 +16,7 @@ import { afterEach, describe, expect, it, vi } from 'vitest';
16
16
import { SENTRY_TRACE_STATE_DSC } from '../../../../packages/opentelemetry/src/constants' ;
17
17
import { startInactiveSpan , startSpan } from '../../../../packages/opentelemetry/src/trace' ;
18
18
import { makeTraceState } from '../../../../packages/opentelemetry/src/utils/makeTraceState' ;
19
- import { cleanupOtel , getProvider , getSpanProcessor , mockSdkInit } from '../helpers/mockSdkInit' ;
19
+ import { cleanupOtel , getSpanProcessor , mockSdkInit } from '../helpers/mockSdkInit' ;
20
20
import type { TestClientInterface } from '../helpers/TestClient' ;
21
21
22
22
describe ( 'Integration | Transactions' , ( ) => {
@@ -514,7 +514,6 @@ describe('Integration | Transactions', () => {
514
514
} ,
515
515
} ) ;
516
516
517
- const provider = getProvider ( ) ;
518
517
const spanProcessor = getSpanProcessor ( ) ;
519
518
520
519
const exporter = spanProcessor ? spanProcessor [ '_exporter' ] : undefined ;
@@ -548,57 +547,56 @@ describe('Integration | Transactions', () => {
548
547
expect ( finishedSpans . length ) . toBe ( 0 ) ;
549
548
} ) ;
550
549
551
- it ( 'collects child spans that are finished within 5 minutes their parent span has been sent' , async ( ) => {
552
- const timeout = 5 * 60 * 1000 ;
553
- const now = Date . now ( ) ;
554
- vi . useFakeTimers ( ) ;
555
- vi . setSystemTime ( now ) ;
550
+ it ( 'collects child spans that are finished within 5 minutes their parent span has been sent' , async ( ) => {
551
+ const timeout = 5 * 60 * 1000 ;
552
+ const now = Date . now ( ) ;
553
+ vi . useFakeTimers ( ) ;
554
+ vi . setSystemTime ( now ) ;
556
555
557
- const logs : unknown [ ] = [ ] ;
558
- vi . spyOn ( logger , 'log' ) . mockImplementation ( msg => logs . push ( msg ) ) ;
556
+ const logs : unknown [ ] = [ ] ;
557
+ vi . spyOn ( logger , 'log' ) . mockImplementation ( msg => logs . push ( msg ) ) ;
559
558
560
- const transactions : Event [ ] = [ ] ;
559
+ const transactions : Event [ ] = [ ] ;
561
560
562
- mockSdkInit ( {
563
- tracesSampleRate : 1 ,
564
- beforeSendTransaction : event => {
565
- transactions . push ( event ) ;
566
- return null ;
567
- } ,
568
- } ) ;
561
+ mockSdkInit ( {
562
+ tracesSampleRate : 1 ,
563
+ beforeSendTransaction : event => {
564
+ transactions . push ( event ) ;
565
+ return null ;
566
+ } ,
567
+ } ) ;
569
568
570
- const provider = getProvider ( ) ;
571
- const spanProcessor = getSpanProcessor ( ) ;
569
+ const spanProcessor = getSpanProcessor ( ) ;
572
570
573
- const exporter = spanProcessor ? spanProcessor [ '_exporter' ] : undefined ;
571
+ const exporter = spanProcessor ? spanProcessor [ '_exporter' ] : undefined ;
574
572
575
- if ( ! exporter ) {
576
- throw new Error ( 'No exporter found, aborting test...' ) ;
577
- }
573
+ if ( ! exporter ) {
574
+ throw new Error ( 'No exporter found, aborting test...' ) ;
575
+ }
578
576
579
- startSpanManual ( { name : 'test name' } , async span => {
580
- const subSpan = startInactiveSpan ( { name : 'inner span 1' } ) ;
581
- subSpan . end ( ) ;
577
+ startSpanManual ( { name : 'test name' } , async span => {
578
+ const subSpan = startInactiveSpan ( { name : 'inner span 1' } ) ;
579
+ subSpan . end ( ) ;
582
580
583
- const subSpan2 = startInactiveSpan ( { name : 'inner span 2' } ) ;
581
+ const subSpan2 = startInactiveSpan ( { name : 'inner span 2' } ) ;
584
582
585
- span . end ( ) ;
583
+ span . end ( ) ;
586
584
587
- setTimeout ( ( ) => {
588
- subSpan2 . end ( ) ;
589
- } , timeout - 2 ) ;
590
- } ) ;
585
+ setTimeout ( ( ) => {
586
+ subSpan2 . end ( ) ;
587
+ } , timeout - 2 ) ;
588
+ } ) ;
591
589
592
- vi . advanceTimersByTime ( timeout - 1 ) ;
590
+ vi . advanceTimersByTime ( timeout - 1 ) ;
593
591
594
- expect ( transactions ) . toHaveLength ( 2 ) ;
595
- expect ( transactions [ 0 ] ?. spans ) . toHaveLength ( 1 ) ;
592
+ expect ( transactions ) . toHaveLength ( 2 ) ;
593
+ expect ( transactions [ 0 ] ?. spans ) . toHaveLength ( 1 ) ;
596
594
597
- const finishedSpans : any = exporter [ '_finishedSpanBuckets' ] . flatMap ( bucket =>
598
- bucket ? Array . from ( bucket . spans ) : [ ] ,
599
- ) ;
600
- expect ( finishedSpans . length ) . toBe ( 0 ) ;
601
- } ) ;
595
+ const finishedSpans : any = exporter [ '_finishedSpanBuckets' ] . flatMap ( bucket =>
596
+ bucket ? Array . from ( bucket . spans ) : [ ] ,
597
+ ) ;
598
+ expect ( finishedSpans . length ) . toBe ( 0 ) ;
599
+ } ) ;
602
600
603
601
it ( 'discards child spans that are finished after 5 minutes their parent span has been sent' , async ( ) => {
604
602
const timeout = 5 * 60 * 1000 ;
@@ -619,7 +617,6 @@ it('collects child spans that are finished within 5 minutes their parent span ha
619
617
} ,
620
618
} ) ;
621
619
622
- const provider = getProvider ( ) ;
623
620
const spanProcessor = getSpanProcessor ( ) ;
624
621
625
622
const exporter = spanProcessor ? spanProcessor [ '_exporter' ] : undefined ;
0 commit comments