/*
 * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
 * @generated-id: 72bfd98dad7d
 */

import { workflowsExecutionsBatchCancelWorkflowExecutions } from "../funcs/workflowsExecutionsBatchCancelWorkflowExecutions.js";
import { workflowsExecutionsBatchTerminateWorkflowExecutions } from "../funcs/workflowsExecutionsBatchTerminateWorkflowExecutions.js";
import { workflowsExecutionsCancelWorkflowExecution } from "../funcs/workflowsExecutionsCancelWorkflowExecution.js";
import { workflowsExecutionsGetWorkflowExecution } from "../funcs/workflowsExecutionsGetWorkflowExecution.js";
import { workflowsExecutionsGetWorkflowExecutionHistory } from "../funcs/workflowsExecutionsGetWorkflowExecutionHistory.js";
import { workflowsExecutionsGetWorkflowExecutionTraceEvents } from "../funcs/workflowsExecutionsGetWorkflowExecutionTraceEvents.js";
import { workflowsExecutionsGetWorkflowExecutionTraceOtel } from "../funcs/workflowsExecutionsGetWorkflowExecutionTraceOtel.js";
import { workflowsExecutionsGetWorkflowExecutionTraceSummary } from "../funcs/workflowsExecutionsGetWorkflowExecutionTraceSummary.js";
import { workflowsExecutionsQueryWorkflowExecution } from "../funcs/workflowsExecutionsQueryWorkflowExecution.js";
import { workflowsExecutionsResetWorkflow } from "../funcs/workflowsExecutionsResetWorkflow.js";
import { workflowsExecutionsSignalWorkflowExecution } from "../funcs/workflowsExecutionsSignalWorkflowExecution.js";
import { workflowsExecutionsStream } from "../funcs/workflowsExecutionsStream.js";
import { workflowsExecutionsTerminateWorkflowExecution } from "../funcs/workflowsExecutionsTerminateWorkflowExecution.js";
import { workflowsExecutionsUpdateWorkflowExecution } from "../funcs/workflowsExecutionsUpdateWorkflowExecution.js";
import { EventStream } from "../lib/event-streams.js";
import { ClientSDK, RequestOptions } from "../lib/sdks.js";
import * as components from "../models/components/index.js";
import * as operations from "../models/operations/index.js";
import { unwrapAsync } from "../types/fp.js";

export class Executions extends ClientSDK {
  /**
   * Get Workflow Execution
   */
  async getWorkflowExecution(
    request:
      operations.GetWorkflowExecutionV1WorkflowsExecutionsExecutionIdGetRequest,
    options?: RequestOptions,
  ): Promise<components.WorkflowExecutionResponse> {
    return unwrapAsync(workflowsExecutionsGetWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Get Workflow Execution History
   */
  async getWorkflowExecutionHistory(
    request:
      operations.GetWorkflowExecutionHistoryV1WorkflowsExecutionsExecutionIdHistoryGetRequest,
    options?: RequestOptions,
  ): Promise<any> {
    return unwrapAsync(workflowsExecutionsGetWorkflowExecutionHistory(
      this,
      request,
      options,
    ));
  }

  /**
   * Signal Workflow Execution
   */
  async signalWorkflowExecution(
    request:
      operations.SignalWorkflowExecutionV1WorkflowsExecutionsExecutionIdSignalsPostRequest,
    options?: RequestOptions,
  ): Promise<components.SignalWorkflowResponse> {
    return unwrapAsync(workflowsExecutionsSignalWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Query Workflow Execution
   */
  async queryWorkflowExecution(
    request:
      operations.QueryWorkflowExecutionV1WorkflowsExecutionsExecutionIdQueriesPostRequest,
    options?: RequestOptions,
  ): Promise<components.QueryWorkflowResponse> {
    return unwrapAsync(workflowsExecutionsQueryWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Terminate Workflow Execution
   */
  async terminateWorkflowExecution(
    request:
      operations.TerminateWorkflowExecutionV1WorkflowsExecutionsExecutionIdTerminatePostRequest,
    options?: RequestOptions,
  ): Promise<void> {
    return unwrapAsync(workflowsExecutionsTerminateWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Batch Terminate Workflow Executions
   */
  async batchTerminateWorkflowExecutions(
    request: components.BatchExecutionBody,
    options?: RequestOptions,
  ): Promise<components.BatchExecutionResponse> {
    return unwrapAsync(workflowsExecutionsBatchTerminateWorkflowExecutions(
      this,
      request,
      options,
    ));
  }

  /**
   * Cancel Workflow Execution
   */
  async cancelWorkflowExecution(
    request:
      operations.CancelWorkflowExecutionV1WorkflowsExecutionsExecutionIdCancelPostRequest,
    options?: RequestOptions,
  ): Promise<void> {
    return unwrapAsync(workflowsExecutionsCancelWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Batch Cancel Workflow Executions
   */
  async batchCancelWorkflowExecutions(
    request: components.BatchExecutionBody,
    options?: RequestOptions,
  ): Promise<components.BatchExecutionResponse> {
    return unwrapAsync(workflowsExecutionsBatchCancelWorkflowExecutions(
      this,
      request,
      options,
    ));
  }

  /**
   * Reset Workflow
   */
  async resetWorkflow(
    request:
      operations.ResetWorkflowV1WorkflowsExecutionsExecutionIdResetPostRequest,
    options?: RequestOptions,
  ): Promise<void> {
    return unwrapAsync(workflowsExecutionsResetWorkflow(
      this,
      request,
      options,
    ));
  }

  /**
   * Update Workflow Execution
   */
  async updateWorkflowExecution(
    request:
      operations.UpdateWorkflowExecutionV1WorkflowsExecutionsExecutionIdUpdatesPostRequest,
    options?: RequestOptions,
  ): Promise<components.UpdateWorkflowResponse> {
    return unwrapAsync(workflowsExecutionsUpdateWorkflowExecution(
      this,
      request,
      options,
    ));
  }

  /**
   * Get Workflow Execution Trace Otel
   */
  async getWorkflowExecutionTraceOtel(
    request: operations.GetWorkflowExecutionTraceOtelRequest,
    options?: RequestOptions,
  ): Promise<components.WorkflowExecutionTraceOTelResponse> {
    return unwrapAsync(workflowsExecutionsGetWorkflowExecutionTraceOtel(
      this,
      request,
      options,
    ));
  }

  /**
   * Get Workflow Execution Trace Summary
   */
  async getWorkflowExecutionTraceSummary(
    request: operations.GetWorkflowExecutionTraceSummaryRequest,
    options?: RequestOptions,
  ): Promise<components.WorkflowExecutionTraceSummaryResponse> {
    return unwrapAsync(workflowsExecutionsGetWorkflowExecutionTraceSummary(
      this,
      request,
      options,
    ));
  }

  /**
   * Get Workflow Execution Trace Events
   */
  async getWorkflowExecutionTraceEvents(
    request: operations.GetWorkflowExecutionTraceEventsRequest,
    options?: RequestOptions,
  ): Promise<components.WorkflowExecutionTraceEventsResponse> {
    return unwrapAsync(workflowsExecutionsGetWorkflowExecutionTraceEvents(
      this,
      request,
      options,
    ));
  }

  /**
   * Stream
   */
  async stream(
    request: operations.StreamV1WorkflowsExecutionsExecutionIdStreamGetRequest,
    options?: RequestOptions,
  ): Promise<
    EventStream<
      operations.StreamV1WorkflowsExecutionsExecutionIdStreamGetResponseBody
    >
  > {
    return unwrapAsync(workflowsExecutionsStream(
      this,
      request,
      options,
    ));
  }
}