//import chalk from "chalk";
import fs from "fs";
import { basename } from "path";
import ora from "ora";
import { error, success, warning } from "../../helper/consoleWrapper";
import { getCIName } from "../../helper/isCI";
import { isCI } from "../../helper/isCI";
import { isURL } from "../../helper/isURL";
import { ApiReferenceOperationType, ApiReferenceSourceType, ImportCommandOptions } from "../../models";
import { ApiResponse } from "../../models/api-response";
import { ImportApiReferenceSummary } from "../../models/import.model";
import d360APIFetch from "../d360APIFetch";

export default async function importFlow(options: ImportCommandOptions) {
  const spinner = ora({ text: "Importing..", stream: process.stdout, isEnabled: !isCI() && process.stdout.isTTY });
  spinner.start();
  const formData = getImportRequestFormData(options);
  const requestOptions = {
    method: "POST",
    body: formData,
    headers: new Headers({
      api_token: options.apiKey,
    }),
  };
  let requestUrl = `/v2/apidocs/import/${options.userId}`;
  if (options.publish) {
    requestUrl += `/?publishArticles=true`;
  }
  const response = await d360APIFetch<ApiResponse<ImportApiReferenceSummary>>(requestUrl, requestOptions);
  spinner.stop();
  handleImportResponse(response);
}

function getImportRequestFormData(options: ImportCommandOptions) {
  const formData = new FormData();
  if (!isURL(options.path)) {
    const fileBuffer = fs.readFileSync(options.path);
    formData.append("file", new Blob([fileBuffer]), basename(options.path));
  } else {
    formData.append("url", options.path);
  }
  formData.append("projectVersionId", options.versionId);
  formData.append("sourceType", String(ApiReferenceSourceType.CommandLine));
  formData.append("operationType", String(ApiReferenceOperationType.Import));
  formData.append("ciName", getCIName() ?? "command-line");
  if (options.force) {
    formData.append("proceedAnyway", "true");
  }
  return formData;
}

function handleImportResponse(response: ApiResponse<ImportApiReferenceSummary>) {
  if (response?.success) {
    const importWarnings = response?.result?.warnings;
    const importErrors = response?.result?.errors;
    const isServersAvailable = response?.result?.is_server_available;
    const apiDefinitionImported = response?.result?.api_definition_id != null ? true : false;
    if (importErrors == null && importWarnings == null && apiDefinitionImported == true) {
      success("Import Successful!");
    } else if (isServersAvailable != true && importWarnings.length < 1 && importErrors.length < 1) {
      showServerUnAwailableWarning(true);
    } else if (importWarnings.length > 0 && importErrors.length > 0) {
      error(
        `Import failed! We found ${importWarnings.length} alert(s) and ${importErrors.length} errors. You can use --force to force import your spec file`,
      );
      if (isServersAvailable == false) {
        showServerUnAwailableWarning(false);
      }
    } else if (importWarnings.length > 0) {
      error(`Import failed! We found ${importWarnings.length} alert(s). You can use --force to force import your spec file`);
      if (isServersAvailable == false) {
        showServerUnAwailableWarning(false);
      }
    } else if (importErrors.length > 0) {
      error(`Import failed! We found ${importErrors.length} errors. You can use --force to force import your spec file`);
      if (isServersAvailable == false) {
        showServerUnAwailableWarning(false);
      }
    }
  }
}
function showServerUnAwailableWarning(withForceInfo: boolean) {
  if (withForceInfo) {
    warning(
      "You may not be able to use try-it feature. Looks like server variables aren’t defined in your OpenAPI Specification file. You can use --force to force import your spec file",
    );
  } else {
    warning("You may not be able to use try-it feature. Looks like server variables aren't defined in your OpenAPI Specification file.");
  }
}