// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

import {
  CURRENT_VERSION,
  type CircuitGroup as CircuitData,
} from "../data-structures/circuit.js";
import {
  IDocFile,
  IOperationInfo,
  ICircuitConfig,
  IPackageGraphSources,
  IProgramConfig as wasmIProgramConfig,
  TargetProfile,
  type VSDiagnostic,
  ProjectType,
} from "../../lib/web/qsc_wasm.js";
import { log } from "../log.js";
import type {
  IServiceProxy,
  ServiceProtocol,
  ServiceState,
} from "../workers/types.js";
import { eventStringToMsg } from "./common.js";
import {
  IQscEventTarget,
  QscEventData,
  QscEvents,
  makeEvent,
} from "./events.js";
import { callAndTransformExceptions } from "../diagnostics.js";

type Wasm = typeof import("../../lib/web/qsc_wasm.js");

// These need to be async/promise results for when communicating across a WebWorker, however
// for running the compiler in the same thread the result will be synchronous (a resolved promise).
export interface ICompiler {
  checkCode(code: string): Promise<VSDiagnostic[]>;

  getAst(program: ProgramConfig): Promise<string>;

  getHir(program: ProgramConfig): Promise<string>;

  getRir(program: ProgramConfig): Promise<string[]>;

  run(
    program: ProgramConfig,
    expr: string,
    shots: number,
    eventHandler: IQscEventTarget,
  ): Promise<void>;

  runWithNoise(
    program: ProgramConfig,
    expr: string,
    shots: number,
    pauliNoise: number[],
    qubitLoss: number,
    eventHandler: IQscEventTarget,
  ): Promise<void>;

  getQir(program: ProgramConfig): Promise<string>;

  getEstimates(
    program: ProgramConfig,
    expr: string,
    params: string,
  ): Promise<string>;

  getCircuit(
    program: ProgramConfig,
    config: ICircuitConfig,
    operation?: IOperationInfo,
  ): Promise<CircuitData>;

  getDocumentation(additionalProgram?: ProgramConfig): Promise<IDocFile[]>;

  getLibrarySummaries(): Promise<string>;

  checkExerciseSolution(
    userCode: string,
    exerciseSources: string[],
    eventHandler: IQscEventTarget,
  ): Promise<boolean>;
}

/**
 * Type definition for the configuration of a program.
 * If adding new properties, make them optional to maintain backward compatibility.
 */
export type ProgramConfig = (
  | {
      /** An array of source objects, each containing a name and contents. */
      sources: [string, string][];
      /** An array of language features to be opted in to in this compilation. */
      languageFeatures: string[];
    }
  | {
      /** Sources from all resolved dependencies, along with their languageFeatures configuration */
      packageGraphSources: IPackageGraphSources;
    }
) & {
  /** Target compilation profile. */
  profile?: TargetProfile;
  /** The type of project. This is used to determine how to load the project. */
  projectType?: ProjectType;
};

// WebWorker also support being explicitly terminated to tear down the worker thread
export type ICompilerWorker = ICompiler & IServiceProxy;
export type CompilerState = ServiceState;

export class Compiler implements ICompiler {
  private wasm: Wasm;

  constructor(wasm: Wasm) {
    log.info("Constructing a Compiler instance");
    this.wasm = wasm;
    globalThis.qscGitHash = this.wasm.git_hash();
  }

  // Note: This function does not support project mode.
  // see https://github.com/microsoft/qdk/pull/849#discussion_r1409821143
  async checkCode(code: string): Promise<VSDiagnostic[]> {
    let diags: VSDiagnostic[] = [];
    const languageService = new this.wasm.LanguageService();
    const work = languageService.start_background_work(
      (uri: string, version: number | undefined, errors: VSDiagnostic[]) => {
        diags = errors;
      },
      () => {
        // do nothing; test callables are not reported in checkCode
      },
      {
        readFile: async () => null,
        listDirectory: async () => [],
        resolvePath: async () => null,
        fetchGithub: async () => "",
        findManifestDirectory: async () => null,
      },
    );
    languageService.update_document("code", 1, code, "qsharp");
    // Yield to let the language service background worker handle the update
    await Promise.resolve();
    languageService.stop_background_work();
    await work;
    languageService.free();
    return diags;
  }

  async getAst(program: ProgramConfig): Promise<string> {
    const config = toWasmProgramConfig(program, "unrestricted");
    return callAndTransformExceptions(async () => this.wasm.get_ast(config));
  }

  async getHir(program: ProgramConfig): Promise<string> {
    const config = toWasmProgramConfig(program, "unrestricted");
    return callAndTransformExceptions(async () => this.wasm.get_hir(config));
  }

  async getRir(program: ProgramConfig): Promise<string[]> {
    const config = toWasmProgramConfig(program, "adaptive_ri");
    return callAndTransformExceptions(async () => this.wasm.get_rir(config));
  }

  async run(
    program: ProgramConfig,
    expr: string,
    shots: number,
    eventHandler: IQscEventTarget,
  ): Promise<void> {
    // All results are communicated as events, but if there is a compiler error (e.g. an invalid
    // entry expression or similar), it may throw on run. The caller should expect this promise
    // may reject without all shots running or events firing.
    await callAndTransformExceptions(async () =>
      this.wasm.run(
        toWasmProgramConfig(program, "unrestricted"),
        expr,
        (msg: string) => onCompilerEvent(msg, eventHandler!),
        shots!,
      ),
    );
  }

  async runWithNoise(
    program: ProgramConfig,
    expr: string,
    shots: number,
    pauliNoise: number[],
    qubitLoss: number,
    eventHandler: IQscEventTarget,
  ): Promise<void> {
    await callAndTransformExceptions(async () =>
      this.wasm.runWithNoise(
        toWasmProgramConfig(program, "unrestricted"),
        expr,
        (msg: string) => onCompilerEvent(msg, eventHandler!),
        shots!,
        pauliNoise,
        qubitLoss,
      ),
    );
  }

  async getQir(program: ProgramConfig): Promise<string> {
    return callAndTransformExceptions(async () =>
      this.wasm.get_qir(toWasmProgramConfig(program, "base")),
    );
  }

  async getEstimates(
    program: ProgramConfig,
    expr: string,
    params: string,
  ): Promise<string> {
    return callAndTransformExceptions(async () =>
      this.wasm.get_estimates(
        toWasmProgramConfig(program, "unrestricted"),
        expr,
        params,
      ),
    );
  }

  async getCircuit(
    program: ProgramConfig,
    config: ICircuitConfig,
    operation?: IOperationInfo,
  ): Promise<CircuitData> {
    const circuit = await callAndTransformExceptions(async () =>
      this.wasm.get_circuit(
        toWasmProgramConfig(program, "unrestricted"),
        operation,
        config,
      ),
    );
    return {
      circuits: [circuit],
      version: CURRENT_VERSION,
    };
  }

  // Returns all autogenerated documentation files for the standard library
  // and loaded project (if requested). This include file names and metadata,
  // including specially formatted table of content file.
  async getDocumentation(
    additionalProgram?: ProgramConfig,
  ): Promise<IDocFile[]> {
    return this.wasm.generate_docs(
      additionalProgram &&
        toWasmProgramConfig(additionalProgram, "unrestricted"),
    );
  }

  async getLibrarySummaries(): Promise<string> {
    return this.wasm.get_library_summaries();
  }

  async checkExerciseSolution(
    userCode: string,
    exerciseSources: string[],
    eventHandler: IQscEventTarget,
  ): Promise<boolean> {
    const success = this.wasm.check_exercise_solution(
      userCode,
      exerciseSources,
      (msg: string) => onCompilerEvent(msg, eventHandler),
    );

    return success;
  }
}

/**
 * Fills in the defaults, to convert from the backwards-compatible ProgramConfig,
 * to the IProgramConfig type that the wasm layer expects
 */
export function toWasmProgramConfig(
  program: ProgramConfig,
  defaultProfile: TargetProfile,
): Required<wasmIProgramConfig> {
  let packageGraphSources: IPackageGraphSources;

  if ("sources" in program) {
    // The simpler type is used, where there are no dependencies and only a list
    // of sources is passed in.
    packageGraphSources = {
      root: {
        sources: program.sources,
        languageFeatures: program.languageFeatures || [],
        dependencies: {},
      },
      packages: {},
      hasManifest: false, // "sources" is only used in scenarios where there is no manifest
    };
  } else {
    // A full package graph is passed in.
    packageGraphSources = program.packageGraphSources;
  }

  return {
    packageGraphSources,
    profile: program.profile || defaultProfile,
    projectType: program.projectType || "qsharp",
  };
}

export function onCompilerEvent(msg: string, eventTarget: IQscEventTarget) {
  const qscMsg = eventStringToMsg(msg);
  if (!qscMsg) {
    log.error("Unknown event message: %s", msg);
    return;
  }

  let qscEvent: QscEvents;

  const msgType = qscMsg.type;
  switch (msgType) {
    case "Message":
      qscEvent = makeEvent("Message", qscMsg.message);
      break;
    case "DumpMachine":
      qscEvent = makeEvent("DumpMachine", {
        state: qscMsg.state,
        stateLatex: qscMsg.stateLatex,
        qubitCount: qscMsg.qubitCount,
      });
      break;
    case "Result":
      qscEvent = makeEvent("Result", qscMsg.result);
      break;
    case "Matrix":
      qscEvent = makeEvent("Matrix", {
        matrix: qscMsg.matrix,
        matrixLatex: qscMsg.matrixLatex,
      });
      break;
    default:
      log.never(msgType);
      throw "Unexpected message type";
  }
  log.debug("worker dispatching event " + JSON.stringify(qscEvent));
  eventTarget.dispatchEvent(qscEvent);
}

/** The protocol definition to allow running the compiler in a worker. */
export const compilerProtocol: ServiceProtocol<ICompiler, QscEventData> = {
  class: Compiler,
  methods: {
    checkCode: "request",
    getAst: "request",
    getHir: "request",
    getRir: "request",
    getQir: "request",
    getEstimates: "request",
    getCircuit: "request",
    getDocumentation: "request",
    getLibrarySummaries: "request",
    run: "requestWithProgress",
    runWithNoise: "requestWithProgress",
    checkExerciseSolution: "requestWithProgress",
  },
  eventNames: ["DumpMachine", "Matrix", "Message", "Result"],
};