feat: Clean up event after publishing

Author: tonybka

domain/event/event_storage.go

@@ -25,3 +25,7 @@ func (storage *EventStorage) AddEvent(dataModel string, domainEvent IBaseDomainE
 func (storage *EventStorage) GetPendingEvents(dataModel string) []IBaseDomainEvent {
 	return storage.pendingEvents[dataModel]
 }
+
+func (storage *EventStorage) CleanupPendingEvents(dataModel string) {
+	storage.pendingEvents[dataModel] = nil
+}

persistence/trigger/model_hooks.go

@@ -11,13 +11,14 @@ import (
 // modelHooks get called whenever there is new create-or-update event triggered
 func modelHooks(pid uint, table string, rowID uint, action string) error {
 	pendingEvents := event.EventSource.GetPendingEvents(table)
-
-	publisher := event.GetDomainEventPublisher()
-	err := publisher.Publish(pendingEvents...)
-	if err != nil {
-		return err
+	if len(pendingEvents) > 0 {
+		publisher := event.GetDomainEventPublisher()
+		err := publisher.Publish(pendingEvents...)
+		if err != nil {
+			return err
+		}
+		event.EventSource.CleanupPendingEvents(table)
 	}
-
 	return nil
 }