@@ -19,93 +19,96 @@ vi.mock('../utils/http_request_handler/request_handler.node', () => {
1919} ) ;
2020
2121vi . mock ( './odp_manager_factory' , ( ) => {
22- return { getOdpManager : vi . fn ( ) . mockImplementation ( ( ) => ( { } ) ) } ;
22+ return {
23+ getOdpManager : vi . fn ( ) . mockImplementation ( ( ) => ( { } ) ) ,
24+ getOpaqueOdpManager : vi . fn ( ) . mockImplementation ( ( ) => ( { } ) )
25+ } ;
2326} ) ;
2427
2528
2629import { describe , it , expect , beforeEach , vi } from 'vitest' ;
27- import { getOdpManager , OdpManagerOptions } from './odp_manager_factory' ;
30+ import { getOpaqueOdpManager , OdpManagerOptions } from './odp_manager_factory' ;
2831import { NODE_DEFAULT_API_TIMEOUT , NODE_DEFAULT_BATCH_SIZE , NODE_DEFAULT_FLUSH_INTERVAL , createOdpManager } from './odp_manager_factory.node' ;
2932import { NodeRequestHandler } from '../utils/http_request_handler/request_handler.node' ;
3033import { eventApiRequestGenerator } from './event_manager/odp_event_api_manager' ;
3134
3235describe ( 'createOdpManager' , ( ) => {
3336 const MockNodeRequestHandler = vi . mocked ( NodeRequestHandler ) ;
34- const mockGetOdpManager = vi . mocked ( getOdpManager ) ;
37+ const mockGetOpaqueOdpManager = vi . mocked ( getOpaqueOdpManager ) ;
3538
3639 beforeEach ( ( ) => {
3740 MockNodeRequestHandler . mockClear ( ) ;
38- mockGetOdpManager . mockClear ( ) ;
41+ mockGetOpaqueOdpManager . mockClear ( ) ;
3942 } ) ;
4043
4144 it ( 'should use NodeRequestHandler with the provided timeout as the segment request handler' , ( ) => {
4245 const odpManager = createOdpManager ( { segmentsApiTimeout : 3456 } ) ;
43- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
44- const { segmentRequestHandler } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
46+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
47+ const { segmentRequestHandler } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
4548 expect ( segmentRequestHandler ) . toBe ( MockNodeRequestHandler . mock . instances [ 0 ] ) ;
4649 const requestHandlerOptions = MockNodeRequestHandler . mock . calls [ 0 ] [ 0 ] ;
4750 expect ( requestHandlerOptions ?. timeout ) . toBe ( 3456 ) ;
4851 } ) ;
4952
5053 it ( 'should use NodeRequestHandler with the node default timeout as the segment request handler' , ( ) => {
5154 const odpManager = createOdpManager ( { } ) ;
52- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
53- const { segmentRequestHandler } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
55+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
56+ const { segmentRequestHandler } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
5457 expect ( segmentRequestHandler ) . toBe ( MockNodeRequestHandler . mock . instances [ 0 ] ) ;
5558 const requestHandlerOptions = MockNodeRequestHandler . mock . calls [ 0 ] [ 0 ] ;
5659 expect ( requestHandlerOptions ?. timeout ) . toBe ( NODE_DEFAULT_API_TIMEOUT ) ;
5760 } ) ;
5861
5962 it ( 'should use NodeRequestHandler with the provided timeout as the event request handler' , ( ) => {
6063 const odpManager = createOdpManager ( { eventApiTimeout : 2345 } ) ;
61- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
62- const { eventRequestHandler } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
64+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
65+ const { eventRequestHandler } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
6366 expect ( eventRequestHandler ) . toBe ( MockNodeRequestHandler . mock . instances [ 1 ] ) ;
6467 const requestHandlerOptions = MockNodeRequestHandler . mock . calls [ 1 ] [ 0 ] ;
6568 expect ( requestHandlerOptions ?. timeout ) . toBe ( 2345 ) ;
6669 } ) ;
6770
6871 it ( 'should use NodeRequestHandler with the node default timeout as the event request handler' , ( ) => {
6972 const odpManager = createOdpManager ( { } ) ;
70- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
71- const { eventRequestHandler } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
73+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
74+ const { eventRequestHandler } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
7275 expect ( eventRequestHandler ) . toBe ( MockNodeRequestHandler . mock . instances [ 1 ] ) ;
7376 const requestHandlerOptions = MockNodeRequestHandler . mock . calls [ 1 ] [ 0 ] ;
7477 expect ( requestHandlerOptions ?. timeout ) . toBe ( NODE_DEFAULT_API_TIMEOUT ) ;
7578 } ) ;
7679
7780 it ( 'uses the event api request generator' , ( ) => {
7881 const odpManager = createOdpManager ( { } ) ;
79- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
80- const { eventRequestGenerator } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
82+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
83+ const { eventRequestGenerator } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
8184 expect ( eventRequestGenerator ) . toBe ( eventApiRequestGenerator ) ;
8285 } ) ;
8386
8487 it ( 'should use the provided eventBatchSize' , ( ) => {
8588 const odpManager = createOdpManager ( { eventBatchSize : 99 } ) ;
86- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
87- const { eventBatchSize } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
89+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
90+ const { eventBatchSize } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
8891 expect ( eventBatchSize ) . toBe ( 99 ) ;
8992 } ) ;
9093
9194 it ( 'should use the node default eventBatchSize if none provided' , ( ) => {
9295 const odpManager = createOdpManager ( { } ) ;
93- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
94- const { eventBatchSize } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
96+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
97+ const { eventBatchSize } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
9598 expect ( eventBatchSize ) . toBe ( NODE_DEFAULT_BATCH_SIZE ) ;
9699 } ) ;
97100
98101 it ( 'should use the provided eventFlushInterval' , ( ) => {
99102 const odpManager = createOdpManager ( { eventFlushInterval : 9999 } ) ;
100- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
101- const { eventFlushInterval } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
103+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
104+ const { eventFlushInterval } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
102105 expect ( eventFlushInterval ) . toBe ( 9999 ) ;
103106 } ) ;
104107
105108 it ( 'should use the node default eventFlushInterval if none provided' , ( ) => {
106109 const odpManager = createOdpManager ( { } ) ;
107- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
108- const { eventFlushInterval } = mockGetOdpManager . mock . calls [ 0 ] [ 0 ] ;
110+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
111+ const { eventFlushInterval } = mockGetOpaqueOdpManager . mock . calls [ 0 ] [ 0 ] ;
109112 expect ( eventFlushInterval ) . toBe ( NODE_DEFAULT_FLUSH_INTERVAL ) ;
110113 } ) ;
111114
@@ -119,7 +122,7 @@ describe('createOdpManager', () => {
119122 userAgentParser : { } as any ,
120123 } ;
121124 const odpManager = createOdpManager ( options ) ;
122- expect ( odpManager ) . toBe ( mockGetOdpManager . mock . results [ 0 ] . value ) ;
123- expect ( mockGetOdpManager ) . toHaveBeenNthCalledWith ( 1 , expect . objectContaining ( options ) ) ;
125+ expect ( odpManager ) . toBe ( mockGetOpaqueOdpManager . mock . results [ 0 ] . value ) ;
126+ expect ( mockGetOpaqueOdpManager ) . toHaveBeenNthCalledWith ( 1 , expect . objectContaining ( options ) ) ;
124127 } ) ;
125128} ) ;
0 commit comments