fix(aggregate members): fixed typo and support for no aggregate members

Author: rmolinamir

lib/core/src/aggregates/aggregate-member.ts

@@ -54,7 +54,7 @@ AggregateMember.getMembers = function <AggregateMember = unknown>(
   if (!AggregateMember.hasMembers(anObject)) {
     const name = anObject.name || anObject.constructor?.name || 'Object';
     throw new InvalidOperationException(
-      `${name} does not have an aggregate members.`
+      `${name} does not have aggregate members.`
     );
   }
 

lib/core/src/domain-events/event-sink.ts

@@ -48,10 +48,9 @@ export class EventSink<DomainEvent extends ObjectLiteral> {
       const aggregateId = this.getAggregateIdFrom(entity);
       if (aggregateId) events.push(...(sink.get(aggregateId) || []));
 
-      const aggregateMembers = this.getAggregateMembersFrom(entity);
-
       // Assuming aggregate members will be nested only one level deep at most
       // instead of recursively traversing the aggregate members.
+      const aggregateMembers = this.getAggregateMembersFrom(entity);
       for (const aggregateMember of aggregateMembers) {
         if (this.isIterable(aggregateMember)) {
           for (const childEntity of aggregateMember) {
@@ -138,7 +137,11 @@ export class EventSink<DomainEvent extends ObjectLiteral> {
    * Returns the aggregate id of an object.
    */
   private static getAggregateMembersFrom(anEntity: Entity) {
-    return AggregateMember.getMembers<Entity | Iterable<Entity>>(anEntity);
+    try {
+      return AggregateMember.getMembers<Entity | Iterable<Entity>>(anEntity);
+    } catch {
+      return [];
+    }
   }
 
   /**