// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for details.

import * as vscode from "vscode";
import { TelemetryHelper } from "../../../common/telemetryHelper";
import { Telemetry } from "../../../common/telemetry";
import { ExtensionConfigManager } from "../../extensionConfigManager";
import { IConfig, retryDownloadConfig } from "../remoteConfigHelper";
import { IExperiment } from "./IExperiment";

export enum ExperimentStatuses {
    ENABLED = "enabled",
    DISABLED = "disabled",
    FAILED = "failed",
}

export interface ExperimentConfig extends IConfig {
    experimentName: string;
    popCoveragePercent: number;
    enabled: boolean;
}

export interface ExperimentParameters extends ExperimentConfig {
    [key: string]: any;
    extensionId?: string;
}

export interface ExperimentResult {
    resultStatus: ExperimentStatuses;
    updatedExperimentParameters: ExperimentParameters;
    error?: Error;
}

export class ExperimentService implements vscode.Disposable {
    private static instance: ExperimentService | null;

    private readonly endpointURL: string;
    private downloadedExperimentsConfig: Array<ExperimentConfig> | null;
    private experimentsInstances!: Map<string, IExperiment>;
    private downloadConfigRequest: Promise<ExperimentConfig[]>;
    private cancellationTokenSource: vscode.CancellationTokenSource;

    public static create(): ExperimentService {
        if (!ExperimentService.instance) {
            ExperimentService.instance = new ExperimentService();
        }

        return ExperimentService.instance;
    }

    public async runExperiments(): Promise<void> {
        if (!this.downloadedExperimentsConfig) {
            this.downloadedExperimentsConfig = await this.downloadConfigRequest;
            this.experimentsInstances = await this.initializeExperimentsInstances();
        }

        const experimentResults: Array<ExperimentResult> = await Promise.all(
            this.downloadedExperimentsConfig.map(expConfig => this.executeExperiment(expConfig)),
        );

        this.sendExperimentTelemetry(experimentResults);
    }

    public dispose(): void {
        this.cancellationTokenSource.cancel();
        this.cancellationTokenSource.dispose();
        ExperimentService.instance = null;
    }

    private constructor() {
        this.endpointURL =
            "https://microsoft.github.io/vscode-react-native/experiments/experimentsConfig.json";
        this.cancellationTokenSource = new vscode.CancellationTokenSource();
        this.downloadedExperimentsConfig = null;

        this.downloadConfigRequest = retryDownloadConfig<ExperimentConfig[]>(
            this.endpointURL,
            this.cancellationTokenSource,
        );
    }

    private async executeExperiment(expConfig: ExperimentConfig): Promise<ExperimentResult> {
        const curExperimentParameters = ExtensionConfigManager.config.get(expConfig.experimentName);
        const expInstance = this.experimentsInstances.get(expConfig.experimentName);

        let expResult: ExperimentResult;
        if (expInstance && expConfig.enabled) {
            try {
                expResult = await expInstance.run(expConfig, curExperimentParameters);
                ExtensionConfigManager.config.set(
                    expConfig.experimentName,
                    expResult.updatedExperimentParameters,
                );
            } catch (err) {
                expResult = {
                    resultStatus: ExperimentStatuses.FAILED,
                    updatedExperimentParameters: expConfig,
                    error: err as Error,
                };
            }
        } else {
            expResult = {
                resultStatus: ExperimentStatuses.DISABLED,
                updatedExperimentParameters: expConfig,
            };
        }

        return expResult;
    }

    private async initializeExperimentsInstances(): Promise<Map<string, IExperiment>> {
        const expInstances = new Map<string, IExperiment>();

        if (this.downloadedExperimentsConfig) {
            for (const expConfig of this.downloadedExperimentsConfig) {
                try {
                    const expClass = await import(`./experiments/${expConfig.experimentName}`);
                    expInstances.set(expConfig.experimentName, new expClass.default());
                } catch (err) {
                    expConfig.enabled = false;
                }
            }
        }

        return expInstances;
    }

    private sendExperimentTelemetry(experimentsResults: ExperimentResult[]): void {
        const runExperimentsEvent = TelemetryHelper.createTelemetryEvent("runExperiments");

        experimentsResults.forEach(expResult => {
            if (expResult.resultStatus === ExperimentStatuses.FAILED && expResult.error) {
                TelemetryHelper.addTelemetryEventErrorProperty(
                    runExperimentsEvent,
                    expResult.error,
                    undefined,
                    `${expResult.updatedExperimentParameters.experimentName}.`,
                );
            } else {
                TelemetryHelper.addTelemetryEventProperty(
                    runExperimentsEvent,
                    expResult.updatedExperimentParameters.experimentName,
                    expResult.resultStatus,
                    false,
                );
            }
        });

        Telemetry.send(runExperimentsEvent);
    }
}