import { FeedOptions, Item, ItemDefinition, QueryIterator, Resource } from "@azure/cosmos";
import { QueryCopilotSampleContainerId, QueryCopilotSampleDatabaseId } from "Common/Constants";
import { handleError } from "Common/ErrorHandlingUtils";
import { sampleDataClient } from "Common/SampleDataClient";
import { getPartitionKeyValue } from "Common/dataAccess/getPartitionKeyValue";
import { getCommonQueryOptions } from "Common/dataAccess/queryDocuments";
import { DatabaseAccount } from "Contracts/DataModels";
import DocumentId from "Explorer/Tree/DocumentId";
import { AppStateComponentNames, loadState, saveState } from "Shared/AppStatePersistenceUtility";
import { logConsoleProgress } from "Utils/NotificationConsoleUtils";
import * as StringUtility from "../../Shared/StringUtility";

export interface SuggestedPrompt {
  id: number;
  text: string;
}

export const querySampleDocuments = (query: string, options: FeedOptions): QueryIterator<ItemDefinition & Resource> => {
  options = getCommonQueryOptions(options);
  return sampleDataClient()
    .database(QueryCopilotSampleDatabaseId)
    .container(QueryCopilotSampleContainerId)
    .items.query(query, options);
};

export const readSampleDocument = async (documentId: DocumentId): Promise<Item> => {
  const clearMessage = logConsoleProgress(`Reading item ${documentId.id()}`);

  try {
    const response = await sampleDataClient()
      .database(QueryCopilotSampleDatabaseId)
      .container(QueryCopilotSampleContainerId)
      .item(documentId.id(), getPartitionKeyValue(documentId))
      .read();

    return response?.resource;
  } catch (error) {
    handleError(error, "ReadDocument", `Failed to read item ${documentId.id()}`);
    throw error;
  } finally {
    clearMessage();
  }
};

export const getSampleDatabaseSuggestedPrompts = (): SuggestedPrompt[] => {
  return [
    { id: 1, text: 'Show all products that have the word "ultra" in the name or description' },
    { id: 2, text: "What are all of the possible categories for the products, and their counts?" },
    { id: 3, text: 'Show me all products that have been reviewed by someone with a username that contains "bob"' },
  ];
};

export const getSuggestedPrompts = (): SuggestedPrompt[] => {
  return [
    { id: 1, text: "Show the first 10 items" },
    { id: 2, text: 'Count all the items in my data as "numItems"' },
    { id: 3, text: "Find the oldest item added to my collection" },
  ];
};

// Prompt history persistence
export enum CopilotSubComponentNames {
  promptHistory = "PromptHistory",
  toggleStatus = "ToggleStatus",
}

const getLegacyHistoryKey = (databaseAccount: DatabaseAccount): string =>
  `${databaseAccount?.id}-queryCopilotHistories`;
const getLegacyToggleStatusKey = (databaseAccount: DatabaseAccount): string =>
  `${databaseAccount?.id}-queryCopilotToggleStatus`;

// Migration only needs to run once
let hasMigrated = false;
// Migrate old prompt history to new format
export const migrateCopilotPersistence = (databaseAccount: DatabaseAccount): void => {
  if (hasMigrated) {
    return;
  }

  let key = getLegacyHistoryKey(databaseAccount);
  let item = localStorage.getItem(key);
  if (item !== undefined && item !== null) {
    const historyItems = item.split("|");
    saveState(
      {
        componentName: AppStateComponentNames.QueryCopilot,
        subComponentName: CopilotSubComponentNames.promptHistory,
        globalAccountName: databaseAccount.name,
        databaseName: undefined,
        containerName: undefined,
      },
      historyItems,
    );

    localStorage.removeItem(key);
  }

  key = getLegacyToggleStatusKey(databaseAccount);
  item = localStorage.getItem(key);
  if (item !== undefined && item !== null) {
    saveState(
      {
        componentName: AppStateComponentNames.QueryCopilot,
        subComponentName: CopilotSubComponentNames.toggleStatus,
        globalAccountName: databaseAccount.name,
        databaseName: undefined,
        containerName: undefined,
      },
      StringUtility.toBoolean(item),
    );

    localStorage.removeItem(key);
  }

  hasMigrated = true;
};

export const readPromptHistory = (databaseAccount: DatabaseAccount): string[] => {
  migrateCopilotPersistence(databaseAccount);
  return (
    (loadState({
      componentName: AppStateComponentNames.QueryCopilot,
      subComponentName: CopilotSubComponentNames.promptHistory,
      globalAccountName: databaseAccount.name,
      databaseName: undefined,
      containerName: undefined,
    }) as string[]) || []
  );
};

export const savePromptHistory = (databaseAccount: DatabaseAccount, historyItems: string[]): void => {
  saveState(
    {
      componentName: AppStateComponentNames.QueryCopilot,
      subComponentName: CopilotSubComponentNames.promptHistory,
      globalAccountName: databaseAccount.name,
      databaseName: undefined,
      containerName: undefined,
    },
    historyItems,
  );
};

export const readCopilotToggleStatus = (databaseAccount: DatabaseAccount): boolean => {
  migrateCopilotPersistence(databaseAccount);
  return !!loadState({
    componentName: AppStateComponentNames.QueryCopilot,
    subComponentName: CopilotSubComponentNames.toggleStatus,
    globalAccountName: databaseAccount.name,
    databaseName: undefined,
    containerName: undefined,
  }) as boolean;
};

export const saveCopilotToggleStatus = (databaseAccount: DatabaseAccount, status: boolean): void => {
  saveState(
    {
      componentName: AppStateComponentNames.QueryCopilot,
      subComponentName: CopilotSubComponentNames.toggleStatus,
      globalAccountName: databaseAccount.name,
      databaseName: undefined,
      containerName: undefined,
    },
    status,
  );
};