@@ -24,8 +24,8 @@ describe("Telemetry", () => {
24
24
hasCredentials : MockedFunction < ( ) => boolean > ;
25
25
} ;
26
26
let mockEventCache : {
27
- getEvents : MockedFunction < ( ) => BaseEvent [ ] > ;
28
- clearEvents : MockedFunction < ( ) => Promise < void > > ;
27
+ getEvents : MockedFunction < ( ) => { id : number ; event : BaseEvent } [ ] > ;
28
+ removeEvents : MockedFunction < ( ids : number [ ] ) => Promise < void > > ;
29
29
appendEvents : MockedFunction < ( events : BaseEvent [ ] ) => Promise < void > > ;
30
30
} ;
31
31
let session : Session ;
@@ -74,23 +74,23 @@ describe("Telemetry", () => {
74
74
// Helper function to verify mock calls to reduce duplication
75
75
function verifyMockCalls ( {
76
76
sendEventsCalls = 0 ,
77
- clearEventsCalls = 0 ,
77
+ removeEventsCalls = 0 ,
78
78
appendEventsCalls = 0 ,
79
79
sendEventsCalledWith = undefined ,
80
80
appendEventsCalledWith = undefined ,
81
81
} : {
82
82
sendEventsCalls ?: number ;
83
- clearEventsCalls ?: number ;
83
+ removeEventsCalls ?: number ;
84
84
appendEventsCalls ?: number ;
85
85
sendEventsCalledWith ?: BaseEvent [ ] | undefined ;
86
86
appendEventsCalledWith ?: BaseEvent [ ] | undefined ;
87
87
} = { } ) : void {
88
88
const { calls : sendEvents } = mockApiClient . sendEvents . mock ;
89
- const { calls : clearEvents } = mockEventCache . clearEvents . mock ;
89
+ const { calls : removeEvents } = mockEventCache . removeEvents . mock ;
90
90
const { calls : appendEvents } = mockEventCache . appendEvents . mock ;
91
91
92
92
expect ( sendEvents . length ) . toBe ( sendEventsCalls ) ;
93
- expect ( clearEvents . length ) . toBe ( clearEventsCalls ) ;
93
+ expect ( removeEvents . length ) . toBe ( removeEventsCalls ) ;
94
94
expect ( appendEvents . length ) . toBe ( appendEventsCalls ) ;
95
95
96
96
if ( sendEventsCalledWith ) {
@@ -123,7 +123,7 @@ describe("Telemetry", () => {
123
123
// Setup mocked EventCache
124
124
mockEventCache = new MockEventCache ( ) as unknown as typeof mockEventCache ;
125
125
mockEventCache . getEvents = vi . fn ( ) . mockReturnValue ( [ ] ) ;
126
- mockEventCache . clearEvents = vi . fn ( ) . mockResolvedValue ( undefined ) ;
126
+ mockEventCache . removeEvents = vi . fn ( ) . mockResolvedValue ( undefined ) ;
127
127
mockEventCache . appendEvents = vi . fn ( ) . mockResolvedValue ( undefined ) ;
128
128
MockEventCache . getInstance = vi . fn ( ) . mockReturnValue ( mockEventCache as unknown as EventCache ) ;
129
129
@@ -159,7 +159,7 @@ describe("Telemetry", () => {
159
159
160
160
verifyMockCalls ( {
161
161
sendEventsCalls : 1 ,
162
- clearEventsCalls : 1 ,
162
+ removeEventsCalls : 1 ,
163
163
sendEventsCalledWith : [ testEvent ] ,
164
164
} ) ;
165
165
} ) ;
@@ -192,15 +192,15 @@ describe("Telemetry", () => {
192
192
} ) ;
193
193
194
194
// Set up mock to return cached events
195
- mockEventCache . getEvents . mockReturnValueOnce ( [ cachedEvent ] ) ;
195
+ mockEventCache . getEvents . mockReturnValueOnce ( [ { id : 0 , event : cachedEvent } ] ) ;
196
196
197
197
await telemetry . setupPromise ;
198
198
199
199
await emitEventsForTest ( [ newEvent ] ) ;
200
200
201
201
verifyMockCalls ( {
202
202
sendEventsCalls : 1 ,
203
- clearEventsCalls : 1 ,
203
+ removeEventsCalls : 1 ,
204
204
sendEventsCalledWith : [ cachedEvent , newEvent ] ,
205
205
} ) ;
206
206
} ) ;
0 commit comments