import {
  getKrispApi as getKrispContractApi,
  KrispApiError,
} from "@automate.ax/integration-contracts/krisp"
import {
  retryableActionError,
  terminalActionError,
} from "../../automation/actions"

/**
 * Creates a Krisp client whose failures carry action retry disposition.
 *
 * @param secret - Stored Krisp account secret.
 */
export function getKrispActionApi(secret: Record<string, unknown>) {
  const api = getKrispContractApi(secret)
  const request = api.request.bind(api)
  api.request = async (path, options) => {
    try {
      return await request(path, options)
    } catch (error) {
      throw classifyKrispApiError(error, path)
    }
  }
  return api
}

/**
 * Maps documented Krisp failures without replacing their provider identity.
 *
 * @param error - Provider request failure.
 * @param path - Requested path relative to the Krisp API root.
 */
function classifyKrispApiError(error: unknown, path: string) {
  if (!(error instanceof KrispApiError)) return error
  if (
    error.status === 429 ||
    (error.status === 400 && path === "import" && isActionInProcess(error.body))
  ) {
    return retryableActionError(error, {
      retryAt:
        error.retryAfter === undefined
          ? undefined
          : new Date(Date.now() + error.retryAfter * 1_000),
    })
  }
  if (error.status === 409) return error
  return error.status < 500 ? terminalActionError(error) : error
}

/**
 * Checks Krisp's documented concurrent-import response.
 *
 * @param body - Normalized provider error body.
 */
function isActionInProcess(body: unknown) {
  return (
    typeof body === "object" &&
    body !== null &&
    "error" in body &&
    body.error === "Action is still in process"
  )
}