test

Author: aphralG

Makefile

@@ -60,10 +60,10 @@ APK_PACKAGE := ./build/$(PACKAGE_NAME).apk
 DEB_PACKAGE := ./build/$(PACKAGE_NAME).deb
 RPM_PACKAGE := ./build/$(PACKAGE_NAME).rpm
 
-MOCK_MANAGEMENT_PLANE_CONFIG_DIRECTORY ?= 
-MOCK_MANAGEMENT_PLANE_LOG_LEVEL ?= INFO
-MOCK_MANAGEMENT_PLANE_GRPC_ADDRESS ?= 127.0.0.1:0
-MOCK_MANAGEMENT_PLANE_API_ADDRESS ?= 127.0.0.1:0
+MOCK_MANAGEMENT_PLANE_CONFIG_DIRECTORY ?= /mnt/hgfs/go/configs/
+MOCK_MANAGEMENT_PLANE_LOG_LEVEL ?= DEBUG
+MOCK_MANAGEMENT_PLANE_GRPC_ADDRESS ?= 127.0.0.1:9091
+MOCK_MANAGEMENT_PLANE_API_ADDRESS ?= 127.0.0.1:9092
 OLD_BENCHMARK_RESULTS_FILE ?= $(TEST_BUILD_DIR)/benchmark.txt
 
 uname_m    := $(shell uname -m)

internal/watcher/watcher_plugin.go

@@ -219,9 +219,10 @@ func (w *Watcher) monitorWatchers(ctx context.Context) {
 			w.handleInstanceUpdates(newCtx, message)
 		case message := <-w.nginxConfigContextChannel:
 			newCtx := context.WithValue(ctx, logger.CorrelationIDContextKey, message.CorrelationID)
-			slog.Info("============= Nginx Config Context Channel got Context")
-			// w.watcherMutex.Lock()
+			slog.Info("============= Nginx Config Context Channel")
+			w.watcherMutex.Lock()
 			if !slices.Contains(w.instancesWithConfigApplyInProgress, message.NginxConfigContext.InstanceID) {
+				slog.Info("============= Nginx Config Context update")
 				slog.DebugContext(
 					newCtx,
 					"Updated NGINX config context",
@@ -239,7 +240,8 @@ func (w *Watcher) monitorWatchers(ctx context.Context) {
 					"nginx_config_context", message.NginxConfigContext,
 				)
 			}
-			// w.watcherMutex.Unlock()
+			w.watcherMutex.Unlock()
+			slog.Info("============= Nginx Config Unlock")
 		case message := <-w.instanceHealthChannel:
 			newCtx := context.WithValue(ctx, logger.CorrelationIDContextKey, message.CorrelationID)
 			w.messagePipe.Process(newCtx, &bus.Message{

nginx-agent.conf

@@ -6,7 +6,7 @@
 
 log:
   # set log level (error, info, debug; default "info")
-  level: info
+  level: debug
   # set log path. if empty, don't log to file.
   path: /var/log/nginx-agent/
 
@@ -17,6 +17,14 @@ allowed_directories:
     - /var/run/nginx
     - /var/log/nginx
 
+command:
+    server:
+        # the server host to connect to in order to send and receive commands e.g. config apply instructions
+        host: 127.0.0.1
+        # the server port to connect to in order to send and receive commands e.g. config apply instructions
+        port: 9091
+        # the type of connection. Options are "grpc" or "http"
+        type: grpc
 ## command server settings 
 # command:
 #  server: