Merge pull request #148 from vijeyash1/main

azure container repository webhook support

agent/container/cfg.yaml

@@ -1,6 +1,6 @@
 package: api
 generate:
-  chi-server: true
+  gin-server: true
   models: true
   embedded-spec: true
 output: agent/container/api/agent.gen.go

agent/container/openapi.yaml

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

agent/container/pkg/application/application.go

@@ -7,7 +7,7 @@ import (
 	"log"
 	"net/http"
 
-	"github.com/go-chi/chi/v5"
+	"github.com/gin-gonic/gin"
 	"github.com/intelops/kubviz/agent/container/pkg/clients"
 	"github.com/intelops/kubviz/agent/container/pkg/config"
 	"github.com/intelops/kubviz/agent/container/pkg/handler"
@@ -42,17 +42,12 @@ func New() *Application {
 		log.Fatalf("API Handler initialisation failed: %v", err)
 	}
 
-	mux := chi.NewMux()
-	apiServer.BindRequest(mux)
-	chi.Walk(mux, func(method string, route string, handler http.Handler, middlewares ...func(http.Handler) http.Handler) error {
-		fmt.Printf("[%s]: '%s' has %d middlewares.\n", method, route, len(middlewares))
-		return nil
-	})
+	r := gin.Default()
+	apiServer.BindRequest(r)
+
 	httpServer := &http.Server{
-		// TODO: remove hardcoding
-		// Addr:    fmt.Sprintf("0.0.0.0:%d", cfg.Port),
 		Addr:    fmt.Sprintf(":%d", 8082),
-		Handler: mux,
+		Handler: r,
 	}
 
 	return &Application{
@@ -65,8 +60,6 @@ func New() *Application {
 }
 
 func (app *Application) Start() {
-	// TODO: remove hard coding
-	// log.Printf("Starting server at %v", app.httpServer.Addr)
 	log.Printf("Starting server at %v", 8082)
 	var err error
 	if err = app.httpServer.ListenAndServe(); err != nil && errors.Is(err, http.ErrServerClosed) {

agent/container/pkg/application/github.go

@@ -6,7 +6,6 @@ import (
 	"log"
 
 	"github.com/intelops/kubviz/model"
-	v1 "github.com/vijeyash1/go-github-container/v1"
 )
 
 // GithubContainerWatch monitors and publishes container image details from a specified GitHub organization's repositories.
@@ -24,7 +23,7 @@ func (app *Application) GithubContainerWatch() {
 	}
 
 	// Create a new GitHub client with the provided organization and token.
-	client := v1.NewGithubClient(app.GithubConfig.Org, app.GithubConfig.Token)
+	client := NewGithubClient(app.GithubConfig.Org, app.GithubConfig.Token)
 
 	// Fetch the list of packages (repositories) from the GitHub organization.
 	packages, err := client.FetchPackages()
@@ -61,7 +60,7 @@ func (app *Application) GithubContainerWatch() {
 }
 
 // BuildImageDetails constructs a model.GithubImage from the given v1.Package and v1.Version.
-func BuildImageDetails(pkg v1.Package, version v1.Version) model.GithubImage {
+func BuildImageDetails(pkg Package, version Version) model.GithubImage {
 	// Create and return a new GithubImage object using the provided package and version information.
 	return model.GithubImage{
 		PackageId:    fmt.Sprint(pkg.ID),     // Convert the package ID to a string and set it as PackageId.