Function sendKernelTelemetry

src/kernels/types.ts:936–997

(kernel: KernelConnectionMetadata)

const capturedTelemetry = new Set<string>();
function sendKernelTelemetry(kernel: KernelConnectionMetadata) {
    if (capturedTelemetry.has(kernel.id)) {
        return;
    }
    capturedTelemetry.add(kernel.id);
    const kernelSpec = 'kernelSpec' in kernel ? kernel.kernelSpec : undefined;
    const language =
        kernelSpec?.language || (kernel.kind === 'startUsingPythonInterpreter' ? PYTHON_LANGUAGE : undefined);
    let argv0 = '';
    let argv = '';
    const interpreter = 'interpreter' in kernel ? kernel.interpreter : undefined;
    const separator = `<#>`;
    let isArgv0SameAsInterpreter: undefined | boolean = undefined;
    if (kernelSpec && Array.isArray(kernelSpec.argv) && kernelSpec.argv.length > 0) {
        argv0 = kernelSpec.argv[0];
        // eslint-disable-next-line local-rules/dont-use-fspath
        isArgv0SameAsInterpreter = argv0.toLowerCase() === interpreter?.uri?.fsPath?.toLowerCase();
        if (path.basename(argv0) !== argv0) {
            argv0 = `<P>${path.basename(argv0)}`;
        }
        argv = kernelSpec.argv
            .map((arg) => {
                if (arg.includes('/') || arg.includes('\\')) {
                    return `<P>${path.basename(arg)}`;
                }
                return arg;
            })
            .join(separator);
    }

    const kernelSpecHashPromise =
        'kernelSpec' in kernel && kernel.kernelSpec.specFile
            ? getTelemetrySafeHashedString(kernel.kernelSpec.specFile)
            : Promise.resolve('');
    const kernelIdHash = getTelemetrySafeHashedString(kernel.id);
    const serverIdHashPromise = isRemoteConnection(kernel)
        ? getTelemetrySafeHashedString(generateIdFromRemoteProvider(kernel.serverProviderHandle))
        : Promise.resolve('');
    const providerExtensionId = isRemoteConnection(kernel)
        ? kernel.serverProviderHandle.extensionId
        : JVSC_EXTENSION_ID;
    const baseUrlHashPromise = isRemoteConnection(kernel)
        ? getTelemetrySafeHashedString(kernel.baseUrl.toLowerCase())
        : Promise.resolve('');
    Promise.all([kernelSpecHashPromise, kernelIdHash, serverIdHashPromise, baseUrlHashPromise])
        .then(([kernelSpecHash, kernelId, serverIdHash, baseUrlHash]) =>
            sendTelemetryEvent(Telemetry.KernelSpec, undefined, {
                kernelId,
                serverIdHash,
                kernelSpecHash,
                baseUrlHash,
                providerExtensionId,
                kernelConnectionType: kernel.kind,
                kernelLanguage: language,
                envType: interpreter && getEnvironmentType(interpreter),
                isArgv0SameAsInterpreter,
                argv0,
                argv