fix event-type filtration bug

foram-splunk · foram-splunk · commit 684c1aec3851 · 2022-07-04T17:46:02.000+05:30
diff --git a/eventrouter/default.go b/eventrouter/default.go
@@ -32,6 +32,10 @@ func New(appCache cache.Cache, sink eventsink.Sink, config *Config) (Router, err
 }
 
 func (r *router) Route(msg *events.Envelope) error {
+	if _, ok := r.selectedEvents[eventType.String()]; !ok {
+		// Ignore this event since we are not interested
+		return nil
+	}
 	_ = r.sink.Write(msg)
 
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,10 @@ func New(appCache cache.Cache, sink eventsink.Sink, config *Config) (Router, err`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`func (r router) Route(msg events.Envelope) error {`
	`35`	`+ if _, ok := r.selectedEvents[eventType.String()]; !ok {`
	`36`	`+ // Ignore this event since we are not interested`
	`37`	`+ return nil`
	`38`	`+ }`
`35`	`39`	`_ = r.sink.Write(msg)`
`36`	`40`
`37`	`41`	`return nil`