Method ProcessEvent

db/event_manager.go:104–126

Concurrent processing of all async event handlers registered for the event type

(ctx context.Context, event Event)

// Concurrent processing of all async event handlers registered for the event type
func (em *EventManager) ProcessEvent(ctx context.Context, event Event) {
	defer func() { <-em.activeCountChannel }()
	// Send event to all registered handlers concurrently.  WaitGroup blocks
	// until all are finished
	var wg sync.WaitGroup
	for _, handler := range em.eventHandlers[event.EventType()] {
		base.DebugfCtx(ctx, base.KeyEvents, "Event queue worker sending event %s to: %s", base.UD(event.String()), handler)
		wg.Add(1)
		go func(event Event, handler EventHandler) {
			defer wg.Done()
			//TODO: Currently we're not tracking success/fail from event handlers.  When this
			// is needed, could pass a channel to HandleEvent for tracking results
			if handler.HandleEvent(ctx, event) {
				em.IncrementEventsProcessedSuccess(1)
			} else {
				em.IncrementEventsProcessedFail(1)
			}
			base.TracefCtx(ctx, base.KeyAll, "Webhook event processed %s", event)

		}(event, handler)
	}
	wg.Wait()
}

// Register a new event handler to the EventManager.  The event manager will route events of
// type eventType to the handler.