@@ -112,20 +112,17 @@ func (l *Listener) ProcessEvent(w http.ResponseWriter, req *http.Request) {
112112 return
113113 }
114114
115- w .WriteHeader (http .StatusOK )
116- _ , _ = fmt .Fprintln (w , "received event" )
117- _ , _ = fmt .Fprintln (w )
118- _ , _ = fmt .Fprintln (w , obj .String ())
119- _ , _ = fmt .Fprintln (w , ev .String ())
120-
121115 createIncident := ev .Severity != event .SeverityNone && ev .Severity != event .SeverityOK
122116 currentIncident , created , err := incident .GetCurrent (l .db , obj , l .logs .GetChildLogger ("incident" ), l .runtimeConfig , l .configFile , createIncident )
123117 if err != nil {
118+ w .WriteHeader (http .StatusInternalServerError )
124119 _ , _ = fmt .Fprintln (w , err )
125120 return
126121 }
127122
128123 if currentIncident == nil {
124+ w .WriteHeader (http .StatusNotAcceptable )
125+
129126 if ev .Type == event .TypeAcknowledgement {
130127 msg := fmt .Sprintf ("%q doesn't have active incident. Ignoring acknowledgement event from source %d" , obj .DisplayName (), ev .SourceId )
131128 _ , _ = fmt .Fprintln (w , msg )
@@ -148,10 +145,13 @@ func (l *Listener) ProcessEvent(w http.ResponseWriter, req *http.Request) {
148145 l .logger .Infof ("Processing event" )
149146
150147 if err := currentIncident .ProcessEvent (ev , created ); err != nil {
148+ w .WriteHeader (http .StatusInternalServerError )
151149 _ , _ = fmt .Fprintln (w , err )
152150 return
153151 }
154152
153+ w .WriteHeader (http .StatusOK )
154+ _ , _ = fmt .Fprintln (w , "event processed successfully" )
155155 _ , _ = fmt .Fprintln (w )
156156}
157157
0 commit comments