get image before send to analysis

.github/workflows/ci.yml

@@ -15,10 +15,10 @@ jobs:
 
     steps:
 
-    - name: Set up Go 1.14
+    - name: Set up Go 1.15
       uses: actions/setup-go@v1
       with:
-        go-version: 1.14
+        go-version: 1.15
 
     - name: Check out code
       uses: actions/checkout@v1

Makefile

@@ -24,7 +24,7 @@ DOCKER_TAG ?= $(shell echo ${VERSION} | sed 's/\//-/')
 GOLANGCI_VERSION = 1.21.0
 LICENSEI_VERSION = 0.1.0
 
-GOLANG_VERSION = 1.13
+GOLANG_VERSION = 1.15
 
 .PHONY: clean
 clean: ## Clean the working area and the project

pkg/anchore/client.go

@@ -21,6 +21,7 @@ import (
 	"fmt"
 	"io/ioutil"
 	"net/http"
+	"net/url"
 	"os"
 
 	"github.com/banzaicloud/anchore-image-validator/pkg/apis/security/v1alpha1"
@@ -64,7 +65,7 @@ func anchoreRequest(path string, bodyParams map[string]string, method string) ([
 	logrus.WithFields(logrus.Fields{
 		"url":        fullURL,
 		"bodyParams": bodyParams,
-	}).Info("Sending request")
+	}).Debug("Sending request")
 
 	req.Header.Add("Content-Type", "application/json")
 	resp, err := client.Do(req)
@@ -78,7 +79,7 @@ func anchoreRequest(path string, bodyParams map[string]string, method string) ([
 
 	logrus.WithFields(logrus.Fields{
 		"response": string(bodyText),
-	}).Info("Anchore Response Body")
+	}).Debug("Anchore Response Body")
 
 	if err != nil {
 		return nil, fmt.Errorf("failed to complete request to Anchore: %v", err)
@@ -92,7 +93,13 @@ func anchoreRequest(path string, bodyParams map[string]string, method string) ([
 }
 
 func getStatus(digest string, tag string) bool {
-	path := fmt.Sprintf("/v1/images/%s/check?history=false&detail=false&tag=%s", digest, tag)
+	params := url.Values{}
+	params.Add("history", "false")
+	params.Add("datall", "false")
+	params.Add("tag", tag)
+
+	path := fmt.Sprintf("/v1/images/%s/check?%s", digest, params.Encode())
+
 	body, err := anchoreRequest(path, nil, "GET")
 
 	if err != nil {
@@ -113,9 +120,42 @@ func getStatus(digest string, tag string) bool {
 	return result[0][digest][resultIndex][0].Status == "pass"
 }
 
+func getImage(imageRef string) (Image, error) {
+	params := url.Values{}
+	params.Add("fulltag", imageRef)
+	params.Add("history", "false")
+	path := fmt.Sprintf("/v1/images?%s", params.Encode())
+
+	body, err := anchoreRequest(path, nil, "GET")
+
+	if err != nil {
+		return Image{}, err
+	}
+
+	var images []Image
+	err = json.Unmarshal(body, &images)
+	if err != nil {
+		return Image{}, fmt.Errorf("failed to unmarshal JSON from response: %v", err)
+	}
+
+	return images[0], nil
+}
+
 func getOrAddImage(imageRef string) (Image, error) {
+	image, err := getImage(imageRef)
+	if err == nil {
+		logrus.WithFields(logrus.Fields{
+			"Image": imageRef,
+		}).Info("Image has already sent to scan")
+		return image, nil
+	}
+
+	logrus.WithFields(logrus.Fields{
+		"Image": imageRef,
+	}).Info("Image hasn't sent to scan yet, sending it")
+
 	params := map[string]string{"tag": imageRef}
-	body, err := anchoreRequest("/v1/images?history=false", params, "POST")
+	body, err := anchoreRequest("/v1/images", params, "POST")
 
 	if err != nil {
 		return Image{}, err
@@ -130,7 +170,7 @@ func getOrAddImage(imageRef string) (Image, error) {
 
 	logrus.WithFields(logrus.Fields{
 		"Image": images[0],
-	}).Info("Get or Added image")
+	}).Debug("Image to add")
 
 	return images[0], nil
 }