quay agent changes

agent/container/cfg.yaml

@@ -3,4 +3,4 @@ generate:
   gin-server: true
   models: true
   embedded-spec: true
-output: agent/container/api/agent.gen.go
+output: api/agent.gen.go

agent/container/openapi.yaml

@@ -45,4 +45,13 @@ paths:
         '200':
           description: OK
 
+  /event/quay/container:
+    post:
+      tags:
+        - public
+      summary: Post quay Container Registry webhook events
+      responses:
+        '200':
+          description: OK
+
 # oapi-codegen -config ./cfg.yaml ./openapi.yaml

agent/container/pkg/handler/api_handler.go

@@ -35,6 +35,7 @@ func (ah *APIHandler) BindRequest(r *gin.Engine) {
 		apiGroup.GET("/status", ah.GetStatus)
 		apiGroup.POST("/event/docker/hub", ah.PostEventDockerHub)
 		apiGroup.POST("/event/azure/container", ah.PostEventAzureContainer)
+		apiGroup.POST("/event/quay/container", ah.PostEventQuayContainer)
 	}
 }
 

agent/container/pkg/handler/quay_handler.go

@@ -0,0 +1,40 @@
+package handler
+
+import (
+	"encoding/json"
+	"io"
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/intelops/kubviz/model"
+)
+
+func (ah *APIHandler) PostEventQuayContainer(c *gin.Context) {
+	defer func() {
+		_, _ = io.Copy(io.Discard, c.Request.Body)
+		_ = c.Request.Body.Close()
+	}()
+	payload, err := io.ReadAll(c.Request.Body)
+	if err != nil || len(payload) == 0 {
+		log.Printf("%v: %v", ErrReadingBody, err)
+		c.Status(http.StatusBadRequest)
+		return
+	}
+	var pushEvent model.QuayImagePushPayload
+	err = json.Unmarshal(payload, &pushEvent)
+	if err != nil {
+		log.Printf("%v: %v", ErrInvalidPayload, err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Bad Request"})
+		return
+	}
+	log.Printf("Received event from Quay Container Registry: %v", pushEvent)
+
+	err = ah.conn.Publish(payload, "Quay_Container_Registry")
+	if err != nil {
+		log.Printf("%v: %v", ErrPublishToNats, err)
+		c.Status(http.StatusInternalServerError)
+		return
+	}
+	c.Status(http.StatusOK)
+}

model/quay.go

@@ -0,0 +1,10 @@
+package model
+
+type QuayImagePushPayload struct {
+	Name        string   `json:"name"`
+	Repository  string   `json:"repository"`
+	Namespace   string   `json:"namespace"`
+	DockerURL   string   `json:"docker_url"`
+	Homepage    string   `json:"homepage"`
+	UpdatedTags []string `json:"updated_tags"`
+}