wow-core/me.ahoo.wow.modeling.matedata/CommandAggregateMetadata

CommandAggregateMetadata

data class CommandAggregateMetadata<C : Any>(val aggregateType: Class<C>, val namedAggregate: NamedAggregate, val constructorAccessor: ConstructorAccessor<C>, val mountedCommands: Set<Class<*>>, val commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, val errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, val afterCommandFunctionRegistry: List<AfterCommandFunctionMetadata<C>> = emptyList()) : NamedTypedAggregate<C> , NamedAggregateDecorator, Metadata, ProcessorInfo

Represents the metadata for a command aggregate, containing all information needed to process commands.

This data class holds the configuration and function registries for a command aggregate, including constructor accessors, command handlers, error handlers, and after-command functions. It provides utilities to convert these into executable message functions.

Parameters

C

The type of the command aggregate.

Constructors

CommandAggregateMetadata

constructor(aggregateType: Class<C>, namedAggregate: NamedAggregate, constructorAccessor: ConstructorAccessor<C>, mountedCommands: Set<Class<*>>, commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, afterCommandFunctionRegistry: List<AfterCommandFunctionMetadata<C>> = emptyList())

Creates a new CommandAggregateMetadata with the specified properties.

Properties

afterCommandFunctionRegistry

val afterCommandFunctionRegistry: List<AfterCommandFunctionMetadata<C>>

List of after-command function metadata.

open val aggregateName: String

open override val aggregateType: Class<C>

The class of the command aggregate.

commandFunctionRegistry

val commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>

Map of command types to their function metadata for command handling.

constructorAccessor

val constructorAccessor: ConstructorAccessor<C>

The accessor for creating command aggregate instances.

open val contextName: String

errorFunctionRegistry

val errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>

Map of error types to their function metadata for error handling.

mountedCommands

val mountedCommands: Set<Class<*>>

Set of command types that are mounted on this aggregate.

open override val namedAggregate: NamedAggregate

The named aggregate that this command aggregate belongs to.

open override val processorName: String

The name of this processor, used for identification in processing contexts.

registeredCommands

val registeredCommands: List<Class<*>>

The list of all registered commands for this aggregate, including both function-registered and mounted commands.

registeredDeleteAggregate

val registeredDeleteAggregate: Boolean

Indicates whether delete aggregate functionality is registered for this command aggregate.

registeredRecoverAggregate

val registeredRecoverAggregate: Boolean

Indicates whether recover aggregate functionality is registered for this command aggregate.

Functions

fun NamedAggregate.aggregateId(id: String = generateId(), tenantId: String = TenantId.DEFAULT_TENANT_ID): DefaultAggregateId

Creates an AggregateId for this NamedAggregate with the specified parameters.

fun <T> NamedAggregate.aggregateType(): Class<T>?

Finds the aggregate type class associated with this named aggregate.

asAggregateMetadata

fun <C : Any, S : Any> NamedAggregate.asAggregateMetadata(): AggregateMetadata<C, S>

Converts this NamedAggregate to its corresponding AggregateMetadata.

open operator override fun equals(other: Any?): Boolean

fun NamedAggregate.generateId(): String

Generates a unique ID string for this NamedAggregate.

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.

open override fun hashCode(): Int

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

requiredAggregateType

fun <T> NamedAggregate.requiredAggregateType(): Class<T>

Finds the aggregate type class associated with this named aggregate, throwing an exception if not found.

toCommandFunctionRegistry

fun toCommandFunctionRegistry(commandAggregate: CommandAggregate<C, *>): Map<Class<*>, MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>>>

toErrorFunctionRegistry

fun toErrorFunctionRegistry(commandAggregate: CommandAggregate<C, *>): Map<Class<*>, MessageFunction<C, ServerCommandExchange<*>, Mono<*>>>

Converts the error function registry into executable message functions.

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

Extension function to convert a NamedAggregate to an EventNamedAggregate.

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

Converts this NamedAggregate to its string representation.

open override fun toString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

Converts this NamedAggregate to a string representation using the context alias.