add tests for telemetry

Author: Hweinstock

packages/core/src/shared/telemetry/vscodeTelemetry.json

@@ -1,5 +1,10 @@
 {
     "types": [
+        {
+            "name": "size",
+            "type": "int",
+            "description": "A generic size for when units are clear"
+        },
         {
             "name": "amazonGenerateApproachLatency",
             "type": "double",
@@ -372,6 +377,16 @@
                 }
             ]
         },
+        {
+            "name": "ide_logActiveProcesses",
+            "description": "Emitted when user invokes logActiveProcesses command",
+            "metadata": [
+                {
+                    "type": "size",
+                    "required": true
+                }
+            ]
+        },
         {
             "name": "vscode_executeCommand",
             "description": "Emitted whenever a registered Toolkit command is executed",

packages/core/src/shared/utilities/processUtils.ts

@@ -8,6 +8,7 @@ import * as logger from '../logger'
 import { Timeout, CancellationError, waitUntil } from './timeoutUtils'
 import { PollingSet } from './pollingSet'
 import { getLogger } from '../logger/logger'
+import { telemetry } from '../telemetry'
 
 export interface RunParameterContext {
     /** Reports an error parsed from the stdin/stdout streams. */
@@ -161,15 +162,18 @@ export class ChildProcessTracker {
     }
 
     public async logAllUsage(): Promise<void> {
-        if (this.size === 0) {
-            this.logger.info('No Active Subprocesses')
-            return
-        }
-        const usage = await this.getAllUsage()
-        const logMsg = Array.from(usage.entries()).reduce((acc, [pid, stats]) => {
-            return acc + `Process ${pid}: ${stats.cpu}% cpu, ${stats.memory} MB of memory\n`
-        }, '')
-        this.logger.info(`Active Subprocesses (${this.size} active)\n${logMsg}`)
+        telemetry.ide_logActiveProcesses.run(async (span) => {
+            span.record({ size: this.size })
+            if (this.size === 0) {
+                this.logger.info('No Active Subprocesses')
+                return
+            }
+            const usage = await this.getAllUsage()
+            const logMsg = Array.from(usage.entries()).reduce((acc, [pid, stats]) => {
+                return acc + `Process ${pid}: ${stats.cpu}% cpu, ${stats.memory} MB of memory\n`
+            }, '')
+            this.logger.info(`Active Subprocesses (${this.size} active)\n${logMsg}`)
+        })
     }
 
     public async getUsage(pid: pid): Promise<ProcessStats> {

packages/core/src/test/shared/utilities/processUtils.test.ts

@@ -19,7 +19,7 @@ import { sleep } from '../../../shared/utilities/timeoutUtils'
 import { Timeout, waitUntil } from '../../../shared/utilities/timeoutUtils'
 import { fs } from '../../../shared'
 import * as FakeTimers from '@sinonjs/fake-timers'
-import { installFakeClock } from '../../testUtil'
+import { assertTelemetry, installFakeClock } from '../../testUtil'
 import { isWin } from '../../../shared/vscode/env'
 import { assertLogsContain } from '../../globalSetup.test'
 
@@ -537,4 +537,20 @@ describe('ChildProcessTracker', function () {
         await tracker.logAllUsage()
         assertLogsContain('No Active Subprocesses', false, 'info')
     })
+
+    it('logAllUsage emits telemetry with size equal to number of processes (empty)', async function () {
+        await tracker.logAllUsage()
+        assertTelemetry('ide_logActiveProcesses', { size: 0 })
+    })
+
+    it('logsAllUsage emits telemetry to number of processes (nonempty)', async function () {
+        const size = 10
+        for (const _ of Array.from({ length: size })) {
+            const runningProcess = startSleepProcess()
+            tracker.add(runningProcess.childProcess)
+        }
+
+        await tracker.logAllUsage()
+        assertTelemetry('ide_logActiveProcesses', { size: size })
+    })
 })