🧹 add label to k8s manifest assets when discovered via git (#5780)

Author: vjeffrey

providers-sdk/v1/plugin/git.go

@@ -14,6 +14,8 @@ import (
 	"go.mondoo.com/cnquery/v11/providers-sdk/v1/vault"
 )
 
+const GitUrlOptionKey = "git-http-url" // used for tracking the link to the git repo for later reference
+
 func NewGitClone(asset *inventory.Asset) (string, func(), error) {
 	cc := asset.Connections[0]
 
@@ -40,6 +42,7 @@ func NewGitClone(asset *inventory.Asset) (string, func(), error) {
 	// gitlab: git clone https://oauth2:ACCESS_TOKEN@somegitlab.com/vendor/package.git
 	// if sshUrl := cc.Options["ssh-url"]; sshUrl != "" { ... not doing ssh url right now
 	if httpUrl := cc.Options["http-url"]; httpUrl != "" {
+		cc.Options[GitUrlOptionKey] = httpUrl // stick this on the asset connection options so we can reference it later
 		u, err := url.Parse(httpUrl)
 		if err != nil {
 			return "", nil, errors.New("failed to parse url for git repo: " + httpUrl)

providers/k8s/connection/manifest/connection.go

@@ -8,6 +8,7 @@ import (
 	"encoding/hex"
 	"os"
 	"path/filepath"
+	"strings"
 
 	"github.com/pkg/errors"
 	"go.mondoo.com/cnquery/v11/providers-sdk/v1/inventory"
@@ -106,7 +107,14 @@ func NewConnection(id uint32, asset *inventory.Asset, opts ...Option) (shared.Co
 	if asset.Name == "" {
 		asset.Name = clusterName
 	}
-
+	if gitPath := asset.Connections[0].Options[plugin.GitUrlOptionKey]; gitPath != "" {
+		// if the GitUrlOptionKey is present, we want to sanitize the url and add it to the
+		// asset labels so that we can later reference the git url where this object was found
+		if asset.Labels == nil {
+			asset.Labels = make(map[string]string)
+		}
+		asset.Labels[plugin.GitUrlOptionKey] = trimGitPath(gitPath)
+	}
 	c.ManifestParser, err = shared.NewManifestParser(manifest, c.namespace, "")
 	if err != nil {
 		return nil, err
@@ -115,6 +123,10 @@ func NewConnection(id uint32, asset *inventory.Asset, opts ...Option) (shared.Co
 	return c, nil
 }
 
+func trimGitPath(gitPath string) string {
+	return strings.TrimSuffix(gitPath, ".git")
+}
+
 func (c *Connection) Close() {
 	if c.closer != nil {
 		c.closer()