wow-core/me.ahoo.wow.modeling.command/CommandFunction

CommandFunction

class CommandFunction<C : Any>(val delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>, commandAggregate: CommandAggregate<C, *>, afterCommandFunctions: List<AfterCommandFunction<C>>) : AbstractCommandFunction<C> , Decorator<MessageFunction<C, ServerCommandExchange<*>, Mono<*>>>

A concrete implementation of command function that wraps a delegate message function.

This class provides command execution by delegating to an underlying message function, with support for after-command functions and proper checkpointing for debugging.

Parameters

The type of the command aggregate.

commandAggregate

The command aggregate instance.

afterCommandFunctions

List of after-command functions to execute.

Constructors

CommandFunction

constructor(delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>, commandAggregate: CommandAggregate<C, *>, afterCommandFunctions: List<AfterCommandFunction<C>>)

Creates a new CommandFunction with the specified delegate and configuration.

Properties

commandAggregate

val commandAggregate: CommandAggregate<C, *>

The command aggregate instance this function belongs to.

contextName

open override val contextName: String

delegate

open override val delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>

The underlying message function that handles the command.

functionKind

open override val functionKind: FunctionKind

name

open override val name: String

processor

open override val processor: C

The processor instance that contains the actual business logic for handling messages.

processorName

open override val processorName: String

The name of the processor class, derived from the simple name of the processor's class.

qualifiedName

open override val qualifiedName: String

The fully qualified name of the function, formatted as "processorName.functionName(supportedTypeSimpleName)". This provides a unique identifier for the function.

supportedTopics

open override val supportedTopics: Set<NamedAggregate>

The set of named aggregates (topics) that this function supports. The function will only process messages that match one of these aggregates.

supportedType

open override val supportedType: Class<*>

The class type of message bodies that this function can process. Used to determine if a message is supported by checking if the message body is an instance of this type.

Functions

getAnnotation

open override fun <A : Annotation> getAnnotation(annotationClass: Class<A>): A?

Retrieves an annotation of the specified type from the function's metadata.

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

Gets the context alias prefix for this bounded context.

handle

open fun handle(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Handles the message exchange by invoking the function. This method provides an alternative way to process the exchange.

invoke

open operator override fun invoke(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Invokes the command function and returns a domain event stream.

invokeCommand

open override fun invokeCommand(exchange: ServerCommandExchange<*>): Mono<*>

Invokes the delegate command function with checkpointing for debugging.

isEmpty

open fun isEmpty(): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

isSameFunction

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

isWaitingForFunction

fun NamedFunctionInfo?.isWaitingForFunction(function: FunctionInfo): Boolean

Checks if a function matches the criteria specified by this NamedFunctionInfo. Used to determine if a wait strategy should be notified about a specific function execution. Returns true if all specified criteria (context, processor, name) match or are not specified.

supportMessage

open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean

Checks if the given message is supported by this function. A message is supported if its body is an instance of the supported type and its aggregate matches one of the supported topics.

toString

open override fun toString(): String

toWaitSignal

fun FunctionInfo.toWaitSignal(id: String, waitCommandId: String, commandId: String, aggregateId: AggregateId, stage: CommandStage, isLastProjection: Boolean = false, aggregateVersion: Int? = null, errorCode: String = ErrorCodes.SUCCEEDED, errorMsg: String = ErrorCodes.SUCCEEDED_MESSAGE, bindingErrors: List<BindingError> = emptyList(), result: Map<String, Any> = emptyMap(), commands: List<String> = listOf(), signalTime: Long = System.currentTimeMillis()): WaitSignal