[bug] Fix monitoring config reloading (#8261) (#8291)

* [bug] Fix monitoring config reloading

(cherry picked from commit f021558)

Co-authored-by: Khushi Jain <[email protected]>

Author: mergify[bot]

internal/pkg/agent/application/monitoring/v1_monitor.go

@@ -129,9 +129,15 @@ func (b *BeatsMonitor) Reload(rawConfig *config.Config) error {
 		return nil
 	}
 
-	if err := rawConfig.UnpackTo(&b.config); err != nil {
+	newConfig := monitoringConfig{
+		C: monitoringCfg.DefaultConfig(),
+	}
+
+	if err := rawConfig.UnpackTo(&newConfig); err != nil {
 		return errors.New(err, "failed to unpack monitoring config during reload")
 	}
+
+	b.config = &newConfig
 	return nil
 }
 
@@ -451,6 +457,7 @@ func (b *BeatsMonitor) injectLogsInput(cfg map[string]interface{}, componentInfo
 		useOutputKey: monitoringOutput,
 		"streams":    streams,
 	}
+
 	// Make sure we don't set anything until the configuration is stable if the otel manager isn't enabled
 	if b.config.C.RuntimeManager != monitoringCfg.DefaultRuntimeManager {
 		input["_runtime_experimental"] = b.config.C.RuntimeManager

internal/pkg/agent/application/monitoring/v1_monitor_test.go

@@ -22,6 +22,7 @@ import (
 
 	"github.com/elastic/elastic-agent-libs/mapstr"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/application/info"
+	"github.com/elastic/elastic-agent/internal/pkg/config"
 	monitoringcfg "github.com/elastic/elastic-agent/internal/pkg/core/monitoring/config"
 	"github.com/elastic/elastic-agent/pkg/component"
 )
@@ -1064,3 +1065,29 @@ type AddFields struct {
 	Fields Fields `json:"fields"`
 	Target string `json:"target"`
 }
+
+// This test ensures if any field under [agent.monitoring] is unset,
+// it falls back to the default value defined in monitoringCfg.DefaultConfig()
+func TestMonitorReload(t *testing.T) {
+	// set log and metric monitoring to false
+	monitorcfg := monitoringcfg.DefaultConfig()
+	monitorcfg.MonitorLogs = false
+	monitorcfg.MonitorMetrics = false
+
+	beatsMonitor := New(true, "", monitorcfg, nil)
+	assert.Equal(t, beatsMonitor.config.C.MonitorLogs, false)
+	assert.Equal(t, beatsMonitor.config.C.MonitorLogs, false)
+
+	// unset logs and metrics
+	agentConfig := `
+agent.monitoring:
+  enabled: true
+`
+	conf := config.MustNewConfigFrom(agentConfig)
+	// Reload will set unset fields to default
+	err := beatsMonitor.Reload(conf)
+	require.NoError(t, err)
+
+	assert.Equal(t, beatsMonitor.config.C.MonitorLogs, true)
+	assert.Equal(t, beatsMonitor.config.C.MonitorMetrics, true)
+}