relax elasticsearch consumer's definition of an error, make it accept…

… all 200s as a valid response from the server
smithy-security · Oct 2, 2024 · 2d96134 · 2d96134
1 parent dc70704
commit 2d96134
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/components/consumers/elasticsearch/main.go b/components/consumers/elasticsearch/main.go
@@ -89,7 +89,7 @@ func main() {
 					log.Fatal("Could not parse raw issue", err)
 				}
 				res, err := es.Index(esIndex, bytes.NewBuffer(b))
-				if err != nil || res.StatusCode != 200 || res.IsError() {
+				if err != nil || res.StatusCode > 299 || res.IsError() {
 					log.Fatalf("could not push raw issue to index: %s, status code received: %d, elasticsearch result: %s, error:%s", esIndex, res.StatusCode, dumpStringResponse(res), err)
 				}
 			}
@@ -111,7 +111,7 @@ func main() {
 					log.Fatalf("Could not parse enriched issue error:%s", err)
 				}
 				res, err := es.Index(esIndex, bytes.NewBuffer(b))
-				if err != nil || res.StatusCode != 200 || res.IsError() {
+				if err != nil || res.StatusCode > 299 || res.IsError() {
 					log.Fatalf("could not push enriched issue to index: %s, status code received: %d, elasticsearch result: %s, error:%s", esIndex, res.StatusCode, dumpStringResponse(res), err)
 				}
 			}