import { handleApiError } from "./api-error.ts";
import type { CloudflareApi } from "./api.ts";
import type { Binding } from "./bindings.ts";

export interface WorkflowProps {
  /**
   * Name of the workflow
   *
   * @maxLength 64
   * @minLength 1
   * @default - className if provided, otherwise id
   */
  workflowName?: string;
  /**
   * Name of the class that implements the workflow
   *
   * @maxLength 255
   * @minLength 1
   * @default - workflowName if provided, otherwise id
   */
  className?: string;
  /**
   * Name of the script containing the workflow implementation
   *
   * @default - bound worker script
   */
  scriptName?: string;
  /**
   * Limits for the workflow instance
   */
  limits?: {
    /**
     * Maximum number of steps per workflow instance.
     *
     * Workers Free: 1,024 (not configurable)
     * Workers Paid: 10,000 default, configurable up to 25,000
     *
     * @see https://developers.cloudflare.com/workflows/reference/limits/
     */
    steps?: number;
  };
  dev?: {
    /**
     * Whether to run the workflow remotely instead of locally
     * @default false
     */
    remote?: boolean;
  };
}

export type Workflow<PARAMS = unknown> = {
  type: "workflow";
  /**
   * Phantom property to preserve workflow params at the type level.
   * No value exists.
   */
  _PARAMS: PARAMS;
  id: string;
  workflowName: string;
  className: string;
  scriptName?: string;
  limits?: {
    steps?: number;
  };
};

export function isWorkflow(binding: Binding): binding is Workflow {
  return typeof binding === "object" && binding.type === "workflow";
}

/**
 * Creates a workflow binding for orchestrating and automating tasks.
 *
 * @example
 * ```ts
 * // Create a basic workflow
 * const workflow = Workflow("my-workflow", {
 *   workflowName: "my-workflow",
 *   className: "MyWorkflow"
 * });
 * ```
 */
export function Workflow<PARAMS = unknown>(
  id: string,
  props: WorkflowProps = {},
): Workflow<PARAMS> {
  const workflowName = props.workflowName ?? props.className ?? id;
  const className = props.className ?? workflowName;

  return {
    type: "workflow",
    _PARAMS: undefined!,
    id,
    workflowName,
    className,
    scriptName: props.scriptName,
    limits: props.limits,
  };
}

export interface WorkflowMetadata {
  id: string; // uuid
  class_name: string;
  created_on: string; // date-time
  modified_on: string; // date-time
  name: string; // maxLength: 64, minLength: 1
  script_name: string;
  triggered_on: string; // date-time
  version_id: string; // uuid
}

export async function upsertWorkflow(
  api: CloudflareApi,
  props: WorkflowProps & {
    workflowName: string;
    scriptName: string;
  },
) {
  const response = await api.put(
    `/accounts/${api.accountId}/workflows/${props.workflowName}`,
    {
      class_name: props.className,
      script_name: props.scriptName,
    },
  );

  if (!response.ok) {
    await handleApiError(response, "create", "workflow", props.workflowName);
  }

  const body = (await response.json()) as {
    result: WorkflowMetadata;
  };

  return body.result;
}

export async function deleteWorkflow(api: CloudflareApi, name: string) {
  const response = await api.delete(
    `/accounts/${api.accountId}/workflows/${name}`,
  );
  if (!response.ok && response.status !== 404) {
    await handleApiError(response, "delete", "workflow", name);
  }
}