target tests

Signed-off-by: Frank Jogeleit <frank.jogeleit@lovoo.com>

pkg/target/kinesis/kinesis.go

@@ -52,8 +52,7 @@ func (c *client) Send(result v1alpha2.PolicyReportResult) {
 	t := time.Unix(result.Timestamp.Seconds, int64(result.Timestamp.Nanos))
 	key := fmt.Sprintf("%s-%s-%s", result.Policy, result.ID, t.Format(time.RFC3339Nano))
 
-	err := c.kinesis.Upload(body, key)
-	if err != nil {
+	if err := c.kinesis.Upload(body, key); err != nil {
 		zap.L().Error("kinesis upload error", zap.String("name", c.Name()), zap.Error(err))
 		return
 	}

pkg/target/s3/s3.go

@@ -54,8 +54,7 @@ func (c *client) Send(result v1alpha2.PolicyReportResult) {
 	t := time.Unix(result.Timestamp.Seconds, int64(result.Timestamp.Nanos))
 	key := fmt.Sprintf("%s/%s/%s-%s-%s.json", c.prefix, t.Format("2006-01-02"), result.Policy, result.ID, t.Format(time.RFC3339Nano))
 
-	err := c.s3.Upload(body, key)
-	if err != nil {
+	if err := c.s3.Upload(body, key); err != nil {
 		zap.L().Error(c.Name()+": S3 Upload error", zap.Error(err))
 		return
 	}

pkg/target/ui/ui_test.go

@@ -60,4 +60,18 @@ func Test_UITarget(t *testing.T) {
 			t.Errorf("Unexpected Name %s", client.Name())
 		}
 	})
+	t.Run("Request Error", func(t *testing.T) {
+		callback := func(req *http.Request) {
+			t.Fail()
+		}
+
+		client := ui.NewClient(ui.Options{
+			ClientOptions: target.ClientOptions{
+				Name: "UI",
+			},
+			Host:       "\\localhost:8080",
+			HTTPClient: testClient{callback, 200},
+		})
+		client.Send(fixtures.CompleteTargetSendResult)
+	})
 }

pkg/target/webhook/webhook_test.go

@@ -76,4 +76,20 @@ func Test_UITarget(t *testing.T) {
 			t.Errorf("Unexpected Name %s", client.Name())
 		}
 	})
+	t.Run("Request Error", func(t *testing.T) {
+		callback := func(req *http.Request) error {
+			t.Fail()
+
+			return nil
+		}
+
+		client := webhook.NewClient(webhook.Options{
+			ClientOptions: target.ClientOptions{
+				Name: "UI",
+			},
+			Host:       "\\localhost:8080",
+			HTTPClient: testClient{callback, 200},
+		})
+		client.Send(fixtures.CompleteTargetSendResult)
+	})
 }