fix event-type filtration bug

foram-splunk · foram-splunk · commit e37285b7ec33 · 2022-07-04T18:09:33.000+05:30
diff --git a/eventrouter/default.go b/eventrouter/default.go
@@ -32,10 +32,13 @@ func New(appCache cache.Cache, sink eventsink.Sink, config *Config) (Router, err
 }
 
 func (r *router) Route(msg *events.Envelope) error {
+	eventType := msg.GetEventType()
+
 	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,10 +32,13 @@ 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`	`+ eventType := msg.GetEventType()`
	`36`	`+`
`35`	`37`	`if _, ok := r.selectedEvents[eventType.String()]; !ok {`
`36`	`38`	`// Ignore this event since we are not interested`
`37`	`39`	`return nil`
`38`	`40`	`}`
	`41`	`+`
`39`	`42`	`_ = r.sink.Write(msg)`
`40`	`43`
`41`	`44`	`return nil`