Merge branch 'v3' into fix-manifest-file-updates

Author: aphralG

internal/collector/nginxplusreceiver/factory.go

@@ -19,6 +19,7 @@ import (
 	"github.com/nginx/agent/v3/internal/collector/nginxplusreceiver/internal/metadata"
 )
 
+// nolint: ireturn
 const defaultTimeout = 10 * time.Second
 
 // nolint: ireturn

internal/watcher/instance/nginx_process_parser.go

@@ -136,6 +136,8 @@ func (npp *NginxProcessParser) getInfo(ctx context.Context, proc *nginxprocess.P
 		}
 	}
 
+	confPath := getConfPathFromCommand(proc.Cmd)
+
 	var nginxInfo *Info
 
 	outputBuffer, err := npp.executer.RunCmd(ctx, exePath, "-V")
@@ -148,6 +150,10 @@ func (npp *NginxProcessParser) getInfo(ctx context.Context, proc *nginxprocess.P
 	nginxInfo.ExePath = exePath
 	nginxInfo.ProcessID = proc.PID
 
+	if nginxInfo.ConfPath = getNginxConfPath(ctx, nginxInfo); confPath != "" {
+		nginxInfo.ConfPath = confPath
+	}
+
 	loadableModules := getLoadableModules(nginxInfo)
 	nginxInfo.LoadableModules = loadableModules
 
@@ -268,7 +274,6 @@ func parseNginxVersionCommandOutput(ctx context.Context, output *bytes.Buffer) *
 	}
 
 	nginxInfo.Prefix = getNginxPrefix(ctx, nginxInfo)
-	nginxInfo.ConfPath = getNginxConfPath(ctx, nginxInfo)
 
 	return nginxInfo
 }
@@ -392,3 +397,17 @@ func convertToMap(processes []*nginxprocess.Process) map[int32]*nginxprocess.Pro
 
 	return processesByPID
 }
+
+func getConfPathFromCommand(command string) string {
+	commands := strings.Split(command, " ")
+
+	for i, command := range commands {
+		if command == "-c" {
+			if i < len(commands)-1 {
+				return commands[i+1]
+			}
+		}
+	}
+
+	return ""
+}

internal/watcher/instance/nginx_process_parser_test.go

@@ -616,3 +616,14 @@ func TestNginxProcessParser_GetExe(t *testing.T) {
 		})
 	}
 }
+
+func TestGetConfigPathFromCommand(t *testing.T) {
+	result := getConfPathFromCommand("nginx: master process nginx -c /tmp/nginx.conf")
+	assert.Equal(t, "/tmp/nginx.conf", result)
+
+	result = getConfPathFromCommand("nginx: master process nginx -c")
+	assert.Equal(t, "", result)
+
+	result = getConfPathFromCommand("")
+	assert.Equal(t, "", result)
+}

pkg/files/file_helpers.go

@@ -8,15 +8,15 @@ package files
 
 import (
 	"cmp"
+	"crypto/sha256"
 	"crypto/x509"
+	"encoding/base64"
 	"fmt"
 	"net"
 	"os"
 	"slices"
 	"strconv"
 
-	"github.com/google/uuid"
-
 	mpi "github.com/nginx/agent/v3/api/grpc/mpi/v1"
 	"github.com/nginx/agent/v3/internal/datasource/cert"
 	"google.golang.org/protobuf/types/known/timestamppb"
@@ -135,7 +135,10 @@ func GenerateConfigVersion(fileSlice []*mpi.File) string {
 
 // GenerateHash returns the hash value of a file's contents.
 func GenerateHash(b []byte) string {
-	return uuid.NewMD5(uuid.Nil, b).String()
+	hash := sha256.New()
+	hash.Write(b)
+
+	return base64.StdEncoding.EncodeToString(hash.Sum(nil))
 }
 
 // ConvertToMapOfFiles converts a list of files to a map of files with the file name as the key

pkg/files/file_helpers_test.go

@@ -6,12 +6,13 @@
 package files
 
 import (
+	"crypto/sha256"
 	"crypto/x509"
+	"encoding/base64"
 	"net"
 	"os"
 	"testing"
 
-	"github.com/google/uuid"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -136,6 +137,10 @@ func Test_GenerateConfigVersion(t *testing.T) {
 }
 
 func TestGenerateHash(t *testing.T) {
+	hash1 := sha256.New()
+	hash2 := sha256.New()
+	hash1.Write([]byte(""))
+	hash2.Write([]byte("test"))
 	tests := []struct {
 		name     string
 		expected string
@@ -144,12 +149,12 @@ func TestGenerateHash(t *testing.T) {
 		{
 			name:     "Test 1: empty byte slice",
 			input:    []byte{},
-			expected: uuid.NewMD5(uuid.Nil, []byte("")).String(),
+			expected: base64.StdEncoding.EncodeToString(hash1.Sum(nil)),
 		},
 		{
 			name:     "Test 2: non-empty byte slice",
 			input:    []byte("test"),
-			expected: uuid.NewMD5(uuid.Nil, []byte("test")).String(),
+			expected: base64.StdEncoding.EncodeToString(hash2.Sum(nil)),
 		},
 	}