fix tests

Author: aphralG

internal/bus/message_pipe.go

@@ -144,7 +144,6 @@ func (p *MessagePipe) Run(ctx context.Context) {
 				case ConnectionAgentConfigUpdateTopic:
 					p.handleConnectionAgentConfigUpdateTopic(m.ctx, m.message)
 				default:
-					slog.InfoContext(ctx, "Publishing message", "topic", m.message.Topic, "message----", m.message)
 					p.bus.Publish(m.message.Topic, m.ctx, m.message)
 				}
 			}
@@ -193,7 +192,7 @@ func (p *MessagePipe) Reconfigure(ctx context.Context, agentConfig *mpi.AgentCon
 
 	// Reconfigure each plugin with the new agent config
 	for _, plugin := range p.plugins {
-		slog.InfoContext(ctx, "Reconfigure plugin", "plugin", plugin.Info().Name)
+		slog.DebugContext(ctx, "Reconfigure plugin", "plugin", plugin.Info().Name)
 		reconfigureError = plugin.Reconfigure(ctx, p.agentConfig)
 		if reconfigureError != nil {
 			slog.ErrorContext(ctx, "Reconfigure plugin failed", "plugin", plugin.Info().Name)
@@ -221,7 +220,7 @@ func (p *MessagePipe) Reconfigure(ctx context.Context, agentConfig *mpi.AgentCon
 		}
 	}
 
-	slog.InfoContext(ctx, "Finished reconfigure plugin", "plugins", p.plugins)
+	slog.InfoContext(ctx, "Finished reconfiguring plugins", "plugins", p.plugins)
 	if topic == AgentConfigUpdateTopic {
 		response := p.createDataPlaneResponse(correlationID, mpi.CommandResponse_COMMAND_STATUS_OK,
 			"Successfully updated agent config", "")

internal/collector/otel_collector_plugin.go

@@ -214,9 +214,15 @@ func (oc *Collector) Reconfigure(ctx context.Context, agentConfig *config.Config
 	oc.agentConfigMutex.Lock()
 	defer oc.agentConfigMutex.Unlock()
 
-	if !reflect.DeepEqual(oc.config.Collector.Extensions.HeadersSetter.Headers,
-		agentConfig.Collector.Extensions.HeadersSetter.Headers) {
-		slog.DebugContext(ctx, "OTel collector headers have changed, restarting collector")
+	if oc.config.Collector != nil && oc.config.Collector.Extensions.HeadersSetter != nil &&
+		oc.config.Collector.Extensions.HeadersSetter.Headers != nil {
+		if !reflect.DeepEqual(oc.config.Collector.Extensions.HeadersSetter.Headers,
+			agentConfig.Collector.Extensions.HeadersSetter.Headers) {
+			slog.InfoContext(ctx, "OTel collector headers have changed, restarting collector")
+			oc.config = agentConfig
+			oc.restartCollector(ctx)
+		}
+	} else {
 		oc.config = agentConfig
 		oc.restartCollector(ctx)
 	}

internal/resource/resource_plugin.go

@@ -29,7 +29,7 @@ type Resource struct {
 	messagePipe      bus.MessagePipeInterface
 	resourceService  resourceServiceInterface
 	agentConfig      *config.Config
-	agentConfigMutex *sync.Mutex
+	agentConfigMutex sync.Mutex
 }
 
 type errResponse struct {