Update protos

dhurley · dhurley · commit fa92bddfc90f · 2025-02-14T14:17:26.000Z
diff --git a/api/grpc/mpi/v1/command.pb.go b/api/grpc/mpi/v1/command.pb.go
diff --git a/api/grpc/mpi/v1/command.pb.validate.go b/api/grpc/mpi/v1/command.pb.validate.go
diff --git a/api/grpc/mpi/v1/command.proto b/api/grpc/mpi/v1/command.proto
@@ -296,7 +296,7 @@ message InstanceRuntime {
     // the binary path location
     string binary_path = 2 [(buf.validate.field).string.prefix = "/"];
     // the config path location
-    optional string config_path = 3 [(buf.validate.field).string.prefix = "/"];
+    string config_path = 3 [(buf.validate.field).string.pattern = "^\\/.*|^$"];
     // more detailed runtime objects
     oneof details {
         // NGINX runtime configuration settings like stub_status, usually read from the NGINX config or NGINX process
diff --git a/docs/proto/protos.md b/docs/proto/protos.md
@@ -951,7 +951,7 @@ Meta-information relating to the reported instance
 | ----- | ---- | ----- | ----------- |
 | process_id | [int32](#int32) |  | the process identifier |
 | binary_path | [string](#string) |  | the binary path location |
-| config_path | [string](#string) | optional | the config path location |
+| config_path | [string](#string) |  | the config path location |
 | nginx_runtime_info | [NGINXRuntimeInfo](#mpi-v1-NGINXRuntimeInfo) |  | NGINX runtime configuration settings like stub_status, usually read from the NGINX config or NGINX process |
 | nginx_plus_runtime_info | [NGINXPlusRuntimeInfo](#mpi-v1-NGINXPlusRuntimeInfo) |  | NGINX Plus runtime configuration settings like api value, usually read from the NGINX config, NGINX process or NGINX Plus API |
 | nginx_app_protect_runtime_info | [NGINXAppProtectRuntimeInfo](#mpi-v1-NGINXAppProtectRuntimeInfo) |  | NGINX App Protect runtime information |
diff --git a/internal/resource/resource_plugin_test.go b/internal/resource/resource_plugin_test.go
@@ -37,15 +37,13 @@ import (
 func TestResource_Process(t *testing.T) {
 	ctx := context.Background()
 
-	configPath := protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetConfigPath()
-
 	updatedInstance := &mpi.Instance{
 		InstanceConfig: protos.GetNginxOssInstance([]string{}).GetInstanceConfig(),
 		InstanceMeta:   protos.GetNginxOssInstance([]string{}).GetInstanceMeta(),
 		InstanceRuntime: &mpi.InstanceRuntime{
 			ProcessId:  56789,
 			BinaryPath: protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetBinaryPath(),
-			ConfigPath: &configPath,
+			ConfigPath: protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetConfigPath(),
 			Details:    protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetDetails(),
 		},
 	}
diff --git a/internal/resource/resource_service_test.go b/internal/resource/resource_service_test.go
@@ -68,15 +68,14 @@ func TestResourceService_AddInstance(t *testing.T) {
 
 func TestResourceService_UpdateInstance(t *testing.T) {
 	ctx := context.Background()
-	configPath := protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetConfigPath()
 
 	updatedInstance := &v1.Instance{
 		InstanceConfig: protos.GetNginxOssInstance([]string{}).GetInstanceConfig(),
 		InstanceMeta:   protos.GetNginxOssInstance([]string{}).GetInstanceMeta(),
 		InstanceRuntime: &v1.InstanceRuntime{
 			ProcessId:  56789,
 			BinaryPath: protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetBinaryPath(),
-			ConfigPath: &configPath,
+			ConfigPath: protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetConfigPath(),
 			Details:    protos.GetNginxOssInstance([]string{}).GetInstanceRuntime().GetDetails(),
 		},
 	}
diff --git a/internal/watcher/instance/instance_watcher_service.go b/internal/watcher/instance/instance_watcher_service.go
@@ -317,7 +317,7 @@ func (iw *InstanceWatcherService) agentInstance(ctx context.Context) *mpi.Instan
 		InstanceRuntime: &mpi.InstanceRuntime{
 			ProcessId:  iw.executer.ProcessID(),
 			BinaryPath: processPath,
-			ConfigPath: &iw.agentConfig.Path,
+			ConfigPath: iw.agentConfig.Path,
 			Details:    nil,
 		},
 	}
diff --git a/internal/watcher/instance/nginx_app_protect_process_parser.go b/internal/watcher/instance/nginx_app_protect_process_parser.go
@@ -70,6 +70,7 @@ func (n NginxAppProtectProcessParser) Parse(
 				InstanceRuntime: &mpi.InstanceRuntime{
 					ProcessId:  process.PID,
 					BinaryPath: binaryPath,
+					ConfigPath: "",
 					Details: &mpi.InstanceRuntime_NginxAppProtectRuntimeInfo{
 						NginxAppProtectRuntimeInfo: &mpi.NGINXAppProtectRuntimeInfo{
 							Release:                n.release(ctx),
diff --git a/internal/watcher/instance/nginx_config_parser_benchmark_test.go b/internal/watcher/instance/nginx_config_parser_benchmark_test.go
@@ -54,7 +54,7 @@ func BenchmarkNginxConfigParser_Parse(b *testing.B) {
 								InstanceType: mpi.InstanceMeta_INSTANCE_TYPE_NGINX,
 							},
 							InstanceRuntime: &mpi.InstanceRuntime{
-								ConfigPath: &configFilePath,
+								ConfigPath: configFilePath,
 							},
 						},
 					)
@@ -115,7 +115,7 @@ func BenchmarkNginxConfigParserGeneratedConfig_Parse(b *testing.B) {
 							InstanceType: mpi.InstanceMeta_INSTANCE_TYPE_NGINX,
 						},
 						InstanceRuntime: &mpi.InstanceRuntime{
-							ConfigPath: &location,
+							ConfigPath: location,
 						},
 					},
 				)
diff --git a/internal/watcher/instance/nginx_config_parser_test.go b/internal/watcher/instance/nginx_config_parser_test.go
@@ -325,8 +325,7 @@ func TestNginxConfigParser_Parse(t *testing.T) {
 				FileMeta: fileMeta,
 			})
 
-			configPath := file.Name()
-			test.instance.InstanceRuntime.ConfigPath = &configPath
+			test.instance.InstanceRuntime.ConfigPath = file.Name()
 
 			agentConfig := types.AgentConfig()
 			agentConfig.AllowedDirectories = []string{dir}
diff --git a/internal/watcher/instance/nginx_process_parser.go b/internal/watcher/instance/nginx_process_parser.go
@@ -200,7 +200,7 @@ func convertInfoToInstance(nginxInfo Info) *mpi.Instance {
 		instanceRuntime = &mpi.InstanceRuntime{
 			ProcessId:  nginxInfo.ProcessID,
 			BinaryPath: nginxInfo.ExePath,
-			ConfigPath: &nginxInfo.ConfPath,
+			ConfigPath: nginxInfo.ConfPath,
 			Details: &mpi.InstanceRuntime_NginxRuntimeInfo{
 				NginxRuntimeInfo: &mpi.NGINXRuntimeInfo{
 					StubStatus: &mpi.APIDetails{
@@ -218,7 +218,7 @@ func convertInfoToInstance(nginxInfo Info) *mpi.Instance {
 		instanceRuntime = &mpi.InstanceRuntime{
 			ProcessId:  nginxInfo.ProcessID,
 			BinaryPath: nginxInfo.ExePath,
-			ConfigPath: &nginxInfo.ConfPath,
+			ConfigPath: nginxInfo.ConfPath,
 			Details: &mpi.InstanceRuntime_NginxPlusRuntimeInfo{
 				NginxPlusRuntimeInfo: &mpi.NGINXPlusRuntimeInfo{
 					StubStatus: &mpi.APIDetails{
diff --git a/internal/watcher/process/process_operator.go b/internal/watcher/process/process_operator.go
@@ -47,7 +47,7 @@ func nginxFilter(ctx context.Context, p *process.Process) bool {
 
 func napFilter(ctx context.Context, p *process.Process) bool {
 	name, _ := p.NameWithContext(ctx) // slow: shells out to ps
-	return name != "bd-socket-plugin"
+	return name == "bd-socket-plugin"
 }
 
 var _ ProcessOperatorInterface = (*ProcessOperator)(nil)
diff --git a/test/protos/instances.go b/test/protos/instances.go
@@ -37,14 +37,12 @@ func GetAgentInstance(processID int32, agentConfig *config.Config) *mpi.Instance
 		InstanceRuntime: &mpi.InstanceRuntime{
 			ProcessId:  processID,
 			BinaryPath: "/run/nginx-agent",
-			ConfigPath: &agentConfig.Path,
+			ConfigPath: agentConfig.Path,
 		},
 	}
 }
 
 func GetNginxOssInstance(expectedModules []string) *mpi.Instance {
-	configPath := "/usr/local/etc/nginx/nginx.conf"
-
 	return &mpi.Instance{
 		InstanceMeta: &mpi.InstanceMeta{
 			InstanceId:   ossInstanceID,
@@ -54,7 +52,7 @@ func GetNginxOssInstance(expectedModules []string) *mpi.Instance {
 		InstanceRuntime: &mpi.InstanceRuntime{
 			ProcessId:  processID,
 			BinaryPath: "/usr/local/Cellar/nginx/1.25.3/bin/nginx",
-			ConfigPath: &configPath,
+			ConfigPath: "/usr/local/etc/nginx/nginx.conf",
 			Details: &mpi.InstanceRuntime_NginxRuntimeInfo{
 				NginxRuntimeInfo: &mpi.NGINXRuntimeInfo{
 					StubStatus: &mpi.APIDetails{
@@ -80,8 +78,6 @@ func GetNginxOssInstance(expectedModules []string) *mpi.Instance {
 }
 
 func GetNginxPlusInstance(expectedModules []string) *mpi.Instance {
-	configPath := "/etc/nginx/nginx.conf"
-
 	return &mpi.Instance{
 		InstanceMeta: &mpi.InstanceMeta{
 			InstanceId:   plusInstanceID,
@@ -91,7 +87,7 @@ func GetNginxPlusInstance(expectedModules []string) *mpi.Instance {
 		InstanceRuntime: &mpi.InstanceRuntime{
 			ProcessId:  processID,
 			BinaryPath: "/usr/local/Cellar/nginx/1.25.3/bin/nginx",
-			ConfigPath: &configPath,
+			ConfigPath: "/etc/nginx/nginx.conf",
 			Details: &mpi.InstanceRuntime_NginxPlusRuntimeInfo{
 				NginxPlusRuntimeInfo: &mpi.NGINXPlusRuntimeInfo{
 					StubStatus: &mpi.APIDetails{

Original file line number	Diff line number	Diff line change
`@@ -317,7 +317,7 @@ func (iw InstanceWatcherService) agentInstance(ctx context.Context) mpi.Instan`
`317`	`317`	`InstanceRuntime: &mpi.InstanceRuntime{`
`318`	`318`	`ProcessId: iw.executer.ProcessID(),`
`319`	`319`	`BinaryPath: processPath,`
`320`		`- ConfigPath: &iw.agentConfig.Path,`
	`320`	`+ ConfigPath: iw.agentConfig.Path,`
`321`	`321`	`Details: nil,`
`322`	`322`	`},`
`323`	`323`	`}`