// Copyright (c) Microsoft Corporation. All rights reserved.

// Licensed under the MIT License.

import { IWorkspaceService } from './common/application/types';

import { isTestExecution } from './common/constants';

import { DeprecatePythonPath } from './common/experiments/groups';

import { traceError } from './common/logger';

import { ITerminalHelper } from './common/terminal/types';

import {

IConfigurationService,

IExperimentService,

IInterpreterPathService,

InspectInterpreterSettingType,

Resource,

} from './common/types';

import { IStopWatch } from './common/utils/stopWatch';

import { IInterpreterAutoSelectionService } from './interpreter/autoSelection/types';

import { ICondaService, IInterpreterService } from './interpreter/contracts';

import { IServiceContainer } from './ioc/types';

import { PythonEnvironment } from './pythonEnvironments/info';

import { sendTelemetryEvent } from './telemetry';

import { EventName } from './telemetry/constants';

import { EditorLoadTelemetry } from './telemetry/types';

import { IStartupDurations } from './types';

export async function sendStartupTelemetry(

activatedPromise: Promise<any>,

durations: IStartupDurations,

stopWatch: IStopWatch,

serviceContainer: IServiceContainer,

) {

if (isTestExecution()) {

return;

}

try {

await activatedPromise;

durations.totalNonBlockingActivateTime = stopWatch.elapsedTime - durations.startActivateTime;

const props = await getActivationTelemetryProps(serviceContainer);

sendTelemetryEvent(EventName.EDITOR_LOAD, durations, props);

} catch (ex) {

traceError('sendStartupTelemetry() failed.', ex);

}

}

export async function sendErrorTelemetry(

ex: Error,

durations: IStartupDurations,

serviceContainer?: IServiceContainer,

) {

try {

let props: any = {};

if (serviceContainer) {

try {

props = await getActivationTelemetryProps(serviceContainer);

} catch (ex) {

traceError('getActivationTelemetryProps() failed.', ex);

}

}

sendTelemetryEvent(EventName.EDITOR_LOAD, durations, props, ex);

} catch (exc2) {

traceError('sendErrorTelemetry() failed.', exc2);

}

}

function isUsingGlobalInterpreterInWorkspace(currentPythonPath: string, serviceContainer: IServiceContainer): boolean {

const service = serviceContainer.get<IInterpreterAutoSelectionService>(IInterpreterAutoSelectionService);

const globalInterpreter = service.getAutoSelectedInterpreter(undefined);

if (!globalInterpreter) {

return false;

}

return currentPythonPath === globalInterpreter.path;

}

export function hasUserDefinedPythonPath(resource: Resource, serviceContainer: IServiceContainer) {

const abExperiments = serviceContainer.get<IExperimentService>(IExperimentService);

const workspaceService = serviceContainer.get<IWorkspaceService>(IWorkspaceService);

const interpreterPathService = serviceContainer.get<IInterpreterPathService>(IInterpreterPathService);

let settings: InspectInterpreterSettingType;

if (abExperiments.inExperimentSync(DeprecatePythonPath.experiment)) {

settings = interpreterPathService.inspect(resource);

} else {

settings = workspaceService.getConfiguration('python', resource)!.inspect<string>('pythonPath')!;

}

return (settings.workspaceFolderValue && settings.workspaceFolderValue !== 'python') ||

(settings.workspaceValue && settings.workspaceValue !== 'python') ||

(settings.globalValue && settings.globalValue !== 'python')

? true

: false;

}

async function getActivationTelemetryProps(serviceContainer: IServiceContainer): Promise<EditorLoadTelemetry> {

// TODO: Not all of this data is showing up in the database...

// TODO: If any one of these parts fails we send no info. We should

// be able to partially populate as much as possible instead

// (through granular try-catch statements).

const terminalHelper = serviceContainer.get<ITerminalHelper>(ITerminalHelper);

const terminalShellType = terminalHelper.identifyTerminalShell();

const condaLocator = serviceContainer.get<ICondaService>(ICondaService);

const interpreterService = serviceContainer.get<IInterpreterService>(IInterpreterService);

const workspaceService = serviceContainer.get<IWorkspaceService>(IWorkspaceService);

const configurationService = serviceContainer.get<IConfigurationService>(IConfigurationService);

const mainWorkspaceUri = workspaceService.hasWorkspaceFolders

? workspaceService.workspaceFolders![0].uri

: undefined;

const settings = configurationService.getSettings(mainWorkspaceUri);

const [condaVersion, interpreter, hasPython3] = await Promise.all([

condaLocator

.getCondaVersion()

.then((ver) => (ver ? ver.raw : ''))

.catch<string>(() => ''),

interpreterService.getActiveInterpreter().catch<PythonEnvironment | undefined>(() => undefined),

interpreterService.hasInterpreters(async (item) => item.version?.major === 3),

]);

const workspaceFolderCount = workspaceService.hasWorkspaceFolders ? workspaceService.workspaceFolders!.length : 0;

const pythonVersion = interpreter && interpreter.version ? interpreter.version.raw : undefined;

const interpreterType = interpreter ? interpreter.envType : undefined;

const usingUserDefinedInterpreter = hasUserDefinedPythonPath(mainWorkspaceUri, serviceContainer);

const usingGlobalInterpreter = isUsingGlobalInterpreterInWorkspace(settings.pythonPath, serviceContainer);

return {

condaVersion,

terminal: terminalShellType,

pythonVersion,

interpreterType,

workspaceFolderCount,

hasPython3,

usingUserDefinedInterpreter,

usingGlobalInterpreter,

};

}