Skip to content

Commit 126994c

Browse files
committed
fix: tests
1 parent a480c94 commit 126994c

File tree

3 files changed

+13
-20
lines changed

3 files changed

+13
-20
lines changed

src/telemetry/telemetry.ts

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ export class Telemetry {
7474
});
7575

7676
this.commonProperties.device_id = await this.deviceIdPromise;
77+
this.commonProperties.is_container_env = (await this.isContainerized()) ? "true" : "false";
7778

7879
this.isBufferingEvents = false;
7980
}
@@ -105,15 +106,14 @@ export class Telemetry {
105106
* Gets the common properties for events
106107
* @returns Object containing common properties for all events
107108
*/
108-
public async getCommonProperties(): Promise<CommonProperties> {
109+
public getCommonProperties(): CommonProperties {
109110
return {
110111
...this.commonProperties,
111112
mcp_client_version: this.session.agentRunner?.version,
112113
mcp_client_name: this.session.agentRunner?.name,
113114
session_id: this.session.sessionId,
114115
config_atlas_auth: this.session.apiClient.hasCredentials() ? "true" : "false",
115116
config_connection_string: this.userConfig.connectionString ? "true" : "false",
116-
is_container_env: (await this.isContainerized()) ? "true" : "false",
117117
};
118118
}
119119

@@ -206,11 +206,10 @@ export class Telemetry {
206206
*/
207207
private async sendEvents(client: ApiClient, events: BaseEvent[]): Promise<EventResult> {
208208
try {
209-
const commonProperties = await this.getCommonProperties();
210209
await client.sendEvents(
211210
events.map((event) => ({
212211
...event,
213-
properties: { ...commonProperties, ...event.properties },
212+
properties: { ...this.getCommonProperties(), ...event.properties },
214213
}))
215214
);
216215
return { success: true };

tests/integration/telemetry.test.ts

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,12 @@ describe("Telemetry", () => {
1717
userConfig: config,
1818
});
1919

20-
const commonProperties = await telemetry.getCommonProperties();
21-
22-
expect(commonProperties.device_id).toBe(undefined);
20+
expect(telemetry.getCommonProperties().device_id).toBe(undefined);
2321
expect(telemetry["isBufferingEvents"]).toBe(true);
2422

2523
await telemetry.deviceIdPromise;
2624

27-
expect(commonProperties.device_id).toBe(actualHashedId);
25+
expect(telemetry.getCommonProperties().device_id).toBe(actualHashedId);
2826
expect(telemetry["isBufferingEvents"]).toBe(false);
2927
});
3028
});

tests/unit/telemetry.test.ts

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ describe("Telemetry", () => {
5555
}
5656

5757
// Helper function to verify mock calls to reduce duplication
58-
async function verifyMockCalls({
58+
function verifyMockCalls({
5959
sendEventsCalls = 0,
6060
clearEventsCalls = 0,
6161
appendEventsCalls = 0,
@@ -77,13 +77,11 @@ describe("Telemetry", () => {
7777
expect(appendEvents.length).toBe(appendEventsCalls);
7878

7979
if (sendEventsCalledWith) {
80-
const commonProperties = await telemetry.getCommonProperties();
81-
8280
expect(sendEvents[0]?.[0]).toEqual(
8381
sendEventsCalledWith.map((event) => ({
8482
...event,
8583
properties: {
86-
...commonProperties,
84+
...telemetry.getCommonProperties(),
8785
...event.properties,
8886
},
8987
}))
@@ -144,7 +142,7 @@ describe("Telemetry", () => {
144142

145143
await telemetry.emitEvents([testEvent]);
146144

147-
await verifyMockCalls({
145+
verifyMockCalls({
148146
sendEventsCalls: 1,
149147
clearEventsCalls: 1,
150148
sendEventsCalledWith: [testEvent],
@@ -158,7 +156,7 @@ describe("Telemetry", () => {
158156

159157
await telemetry.emitEvents([testEvent]);
160158

161-
await verifyMockCalls({
159+
verifyMockCalls({
162160
sendEventsCalls: 1,
163161
appendEventsCalls: 1,
164162
appendEventsCalledWith: [testEvent],
@@ -181,16 +179,14 @@ describe("Telemetry", () => {
181179

182180
await telemetry.emitEvents([newEvent]);
183181

184-
await verifyMockCalls({
182+
verifyMockCalls({
185183
sendEventsCalls: 1,
186184
clearEventsCalls: 1,
187185
sendEventsCalledWith: [cachedEvent, newEvent],
188186
});
189187
});
190188

191189
it("should correctly add common properties to events", () => {
192-
const commonProps = await telemetry.getCommonProperties();
193-
194190
// Use explicit type assertion
195191
const expectedProps: Record<string, string> = {
196192
mcp_client_version: "1.0.0",
@@ -201,7 +197,7 @@ describe("Telemetry", () => {
201197
device_id: hashedMachineId,
202198
};
203199

204-
expect(commonProps).toMatchObject(expectedProps);
200+
expect(telemetry.getCommonProperties()).toMatchObject(expectedProps);
205201
});
206202

207203
describe("machine ID resolution", () => {
@@ -302,7 +298,7 @@ describe("Telemetry", () => {
302298

303299
await telemetry.emitEvents([testEvent]);
304300

305-
await verifyMockCalls();
301+
verifyMockCalls();
306302
});
307303
});
308304

@@ -327,7 +323,7 @@ describe("Telemetry", () => {
327323

328324
await telemetry.emitEvents([testEvent]);
329325

330-
await verifyMockCalls();
326+
verifyMockCalls();
331327
});
332328
});
333329
});

0 commit comments

Comments
 (0)