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

import * as z from "zod/v4";
import { remap as remap$ } from "../../lib/primitives.js";
import { safeParse } from "../../lib/schemas.js";
import { ClosedEnum } from "../../types/enums.js";
import { Result as SafeParseResult } from "../../types/fp.js";
import { smartUnion } from "../../types/smartUnion.js";
import * as components from "../components/index.js";
import { SDKValidationError } from "../errors/sdkvalidationerror.js";

export const Scope = {
  Activity: "activity",
  Workflow: "workflow",
  Wildcard: "*",
} as const;
export type Scope = ClosedEnum<typeof Scope>;

export type GetStreamEventsV1WorkflowsEventsStreamGetRequest = {
  scope?: Scope | undefined;
  activityName?: string | undefined;
  activityId?: string | undefined;
  workflowName?: string | undefined;
  workflowExecId?: string | undefined;
  rootWorkflowExecId?: string | undefined;
  parentWorkflowExecId?: string | undefined;
  stream?: string | undefined;
  startSeq?: number | undefined;
  metadataFilters?: { [k: string]: any } | null | undefined;
  workflowEventTypes?: Array<components.WorkflowEventType> | null | undefined;
  lastEventId?: string | null | undefined;
};

export type GetStreamEventsV1WorkflowsEventsStreamGetData =
  | components.StreamEventSsePayload
  | components.WorkflowStreamError;

/**
 * Stream of Server-Sent Events (SSE)
 */
export type GetStreamEventsV1WorkflowsEventsStreamGetResponseBody = {
  /**
   * SSE event name. `error` indicates the stream failed after HTTP 200.
   */
  event?: string | undefined;
  data?:
    | components.StreamEventSsePayload
    | components.WorkflowStreamError
    | undefined;
  id?: string | undefined;
  retry?: number | undefined;
};

/** @internal */
export const Scope$outboundSchema: z.ZodEnum<typeof Scope> = z.enum(Scope);

/** @internal */
export type GetStreamEventsV1WorkflowsEventsStreamGetRequest$Outbound = {
  scope: string;
  activity_name: string;
  activity_id: string;
  workflow_name: string;
  workflow_exec_id: string;
  root_workflow_exec_id: string;
  parent_workflow_exec_id: string;
  stream: string;
  start_seq: number;
  metadata_filters?: { [k: string]: any } | null | undefined;
  workflow_event_types?: Array<string> | null | undefined;
  "last-event-id"?: string | null | undefined;
};

/** @internal */
export const GetStreamEventsV1WorkflowsEventsStreamGetRequest$outboundSchema:
  z.ZodType<
    GetStreamEventsV1WorkflowsEventsStreamGetRequest$Outbound,
    GetStreamEventsV1WorkflowsEventsStreamGetRequest
  > = z.object({
    scope: Scope$outboundSchema.default("*"),
    activityName: z.string().default("*"),
    activityId: z.string().default("*"),
    workflowName: z.string().default("*"),
    workflowExecId: z.string().default("*"),
    rootWorkflowExecId: z.string().default("*"),
    parentWorkflowExecId: z.string().default("*"),
    stream: z.string().default("*"),
    startSeq: z.int().default(0),
    metadataFilters: z.nullable(z.record(z.string(), z.any())).optional(),
    workflowEventTypes: z.nullable(
      z.array(components.WorkflowEventType$outboundSchema),
    ).optional(),
    lastEventId: z.nullable(z.string()).optional(),
  }).transform((v) => {
    return remap$(v, {
      activityName: "activity_name",
      activityId: "activity_id",
      workflowName: "workflow_name",
      workflowExecId: "workflow_exec_id",
      rootWorkflowExecId: "root_workflow_exec_id",
      parentWorkflowExecId: "parent_workflow_exec_id",
      startSeq: "start_seq",
      metadataFilters: "metadata_filters",
      workflowEventTypes: "workflow_event_types",
      lastEventId: "last-event-id",
    });
  });

export function getStreamEventsV1WorkflowsEventsStreamGetRequestToJSON(
  getStreamEventsV1WorkflowsEventsStreamGetRequest:
    GetStreamEventsV1WorkflowsEventsStreamGetRequest,
): string {
  return JSON.stringify(
    GetStreamEventsV1WorkflowsEventsStreamGetRequest$outboundSchema.parse(
      getStreamEventsV1WorkflowsEventsStreamGetRequest,
    ),
  );
}

/** @internal */
export const GetStreamEventsV1WorkflowsEventsStreamGetData$inboundSchema:
  z.ZodType<GetStreamEventsV1WorkflowsEventsStreamGetData, unknown> =
    smartUnion([
      components.StreamEventSsePayload$inboundSchema,
      components.WorkflowStreamError$inboundSchema,
    ]);

export function getStreamEventsV1WorkflowsEventsStreamGetDataFromJSON(
  jsonString: string,
): SafeParseResult<
  GetStreamEventsV1WorkflowsEventsStreamGetData,
  SDKValidationError
> {
  return safeParse(
    jsonString,
    (x) =>
      GetStreamEventsV1WorkflowsEventsStreamGetData$inboundSchema.parse(
        JSON.parse(x),
      ),
    `Failed to parse 'GetStreamEventsV1WorkflowsEventsStreamGetData' from JSON`,
  );
}

/** @internal */
export const GetStreamEventsV1WorkflowsEventsStreamGetResponseBody$inboundSchema:
  z.ZodType<GetStreamEventsV1WorkflowsEventsStreamGetResponseBody, unknown> = z
    .object({
      event: z.string().optional(),
      data: z.string().optional().transform((v, ctx) => {
        if (v === undefined) return undefined;
        try {
          return JSON.parse(v);
        } catch (err) {
          ctx.addIssue({
            input: v,
            code: "custom",
            message: `malformed json: ${err}`,
          });
          return z.NEVER;
        }
      }).pipe(
        smartUnion([
          components.StreamEventSsePayload$inboundSchema,
          components.WorkflowStreamError$inboundSchema,
        ]).optional(),
      ),
      id: z.string().optional(),
      retry: z.int().optional(),
    });

export function getStreamEventsV1WorkflowsEventsStreamGetResponseBodyFromJSON(
  jsonString: string,
): SafeParseResult<
  GetStreamEventsV1WorkflowsEventsStreamGetResponseBody,
  SDKValidationError
> {
  return safeParse(
    jsonString,
    (x) =>
      GetStreamEventsV1WorkflowsEventsStreamGetResponseBody$inboundSchema.parse(
        JSON.parse(x),
      ),
    `Failed to parse 'GetStreamEventsV1WorkflowsEventsStreamGetResponseBody' from JSON`,
  );
}