feat: await beforeCommit, onCommitted

tonyfromundefined · Apr 15, 2024 · ad05bce · ad05bce
1 parent a8ae5ca
commit ad05bce
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/packages/eventive/src/EventivePlugin.ts b/packages/eventive/src/EventivePlugin.ts
@@ -4,6 +4,12 @@ export type EventivePlugin<
   DomainEvent extends BaseDomainEvent<string, {}>,
   State extends {}
 > = {
-  beforeCommit?(args: { event: DomainEvent; entity: BaseEntity<State> }): void;
-  onCommitted?(args: { event: DomainEvent; entity: BaseEntity<State> }): void;
+  beforeCommit?(args: {
+    event: DomainEvent;
+    entity: BaseEntity<State>;
+  }): void | Promise<void>;
+  onCommitted?(args: {
+    event: DomainEvent;
+    entity: BaseEntity<State>;
+  }): void | Promise<void>;
 };
diff --git a/packages/eventive/src/eventive.ts b/packages/eventive/src/eventive.ts
@@ -125,7 +125,7 @@ export function eventive<
     entity: BaseEntity<State>;
   }) => {
     for (const plugin of plugins) {
-      plugin.beforeCommit?.({
+      await plugin.beforeCommit?.({
         event: options.mapper?.(event) ?? event,
         entity,
       });
@@ -144,7 +144,7 @@ export function eventive<
     }
 
     for (const plugin of plugins) {
-      plugin.onCommitted?.({
+      await plugin.onCommitted?.({
         event: options.mapper?.(event) ?? event,
         entity,
       });