Class ArvoMachine<TId, TVersion, TSelfContract, TServiceContract, TLogic>

constructor

• new ArvoMachine<
      TId extends string,
      TVersion extends `${number}.${number}.${number}`,
      TSelfContract extends
          VersionedArvoContract<ArvoOrchestratorContract, TVersion>,
      TServiceContract extends
          Record<
              string,
              VersionedArvoContract<
                  ArvoContract<
                      string,
                      string,
                      Record<
                          `${number}.${number}.${number}`,
                          { accepts: ZodTypeAny; emits: Record<string, z.ZodTypeAny> },
                      >,
                      Record<string, any>,
                  >,
                  `${number}.${number}.${number}`,
              >,
          >,
      TLogic extends AnyActorLogic,
  >(
      id: TId,
      version: TVersion,
      contracts: { self: TSelfContract; services: TServiceContract },
      logic: TLogic,
      requiresResourceLocking?: boolean,
  ): ArvoMachine<TId, TVersion, TSelfContract, TServiceContract, TLogic>

  Type Parameters

  • TId extends string
  • TVersion extends `${number}.${number}.${number}`
  • TSelfContract extends VersionedArvoContract<ArvoOrchestratorContract, TVersion>
  • TServiceContract extends Record<
        string,
        VersionedArvoContract<
            ArvoContract<
                string,
                string,
                Record<
                    `${number}.${number}.${number}`,
                    { accepts: ZodTypeAny; emits: Record<string, z.ZodTypeAny> },
                >,
                Record<string, any>,
            >,
            `${number}.${number}.${number}`,
        >,
    >
  • TLogic extends AnyActorLogic

  Parameters

  • id: TId
  • version: TVersion
  • contracts: { self: TSelfContract; services: TServiceContract }
  • logic: TLogic
  • requiresResourceLocking: boolean = true

  Returns ArvoMachine<TId, TVersion, TSelfContract, TServiceContract, TLogic>

Readonlycontracts

Readonlyid

Readonlylogic

ReadonlyrequiresResourceLocking

Readonlyversion

source

• get source(): TSelfContract["accepts"]["type"]

  Gets the event type that this machine accepts, as defined in its contract.

  Returns TSelfContract["accepts"]["type"]

validateInput

• validateInput(event: ArvoEvent, span?: Span): EventValidationResult

  Validates an event against the machine's contracts and data schemas. Performs validation for both self-contract events and service contract events.

  Parameters

  • event: ArvoEvent

    The event to validate

    See validateInputEvent for more infromation

  • Optionalspan: Span

  Returns EventValidationResult