Class ArvoEventHandler<TContract>

constructor

• new ArvoEventHandler<
      TContract extends
          ArvoContract<
              string,
              string,
              Record<
                  `${number}.${number}.${number}`,
                  { accepts: ZodTypeAny; emits: Record<string, z.ZodTypeAny> },
              >,
              Record<string, any>,
          >,
  >(
      param: ArvoEventHandlerParam<TContract>,
  ): ArvoEventHandler<TContract>

  Type Parameters

  • TContract extends ArvoContract<
        string,
        string,
        Record<
            `${number}.${number}.${number}`,
            { accepts: ZodTypeAny; emits: Record<string, z.ZodTypeAny> },
        >,
        Record<string, any>,
    >

  Parameters

  • param: ArvoEventHandlerParam<TContract>

  Returns ArvoEventHandler<TContract>

Readonlycontract

ReadonlydefaultEventEmissionDomains

Readonlyexecutionunits

Readonlyhandler

ReadonlyspanOptions

domain

• get domain(): string | null

  The contract-defined domain for the handler

  Returns string | null

source

• get source(): TContract["type"]

  The source identifier for events produced by this handler

  Returns TContract["type"]

systemErrorSchema

• get systemErrorSchema(): ArvoContractRecord<
      `sys.${string}.error`,
      ZodObject<
          {
              errorMessage: ZodString;
              errorName: ZodString;
              errorStack: ZodNullable<ZodString>;
          },
          "strip",
          ZodTypeAny,
          { errorMessage: string; errorName: string; errorStack: string
          | null },
          { errorMessage: string; errorName: string; errorStack: string | null },
      >,
  >

  Provides access to the system error event schema configuration.

  Returns ArvoContractRecord<
      `sys.${string}.error`,
      ZodObject<
          {
              errorMessage: ZodString;
              errorName: ZodString;
              errorStack: ZodNullable<ZodString>;
          },
          "strip",
          ZodTypeAny,
          { errorMessage: string; errorName: string; errorStack: string
          | null },
          { errorMessage: string; errorName: string; errorStack: string | null },
      >,
  >

execute

• execute(
      event: ArvoEvent,
      opentelemetry?: ArvoEventHandlerOpenTelemetryOptions,
  ): Promise<
      {
          events: ArvoEvent<
              Record<string, any>,
              Record<string, string | number | boolean | null>,
              string,
          >[];
      },
  >

  Processes an incoming event according to the handler's contract specifications. This method handles the complete lifecycle of event processing including validation, execution, error handling, and multi-domain event broadcasting, while maintaining detailed telemetry through OpenTelemetry.

  Parameters

  • event: ArvoEvent
  • Optionalopentelemetry: ArvoEventHandlerOpenTelemetryOptions

  Returns Promise<
      {
          events: ArvoEvent<
              Record<string, any>,
              Record<string, string | number | boolean | null>,
              string,
          >[];
      },
  >

  Throws

  when input or output event data violates the contract schema, or when event emission fails due to invalid data

  Throws

  when event type doesn't match contract type, when the contract version expected by the event does not exist in handler configuration, or when contract URI mismatch occurs

  Throws

  for explicitly handled runtime errors that should bubble up