server/internal/handlers/agent_config_test.go

Rama main · réplica de lectura del repositorio original.

package handlers_test

import (
	"encoding/json"
	"net/http"
	"net/http/httptest"
	"testing"
	"time"

	dbpkg "blackbox/server/internal/db"
	"blackbox/server/internal/handlers"
	"blackbox/server/internal/middleware"
	"blackbox/server/internal/models"
	"github.com/stretchr/testify/require"
	"gorm.io/gorm"
)

func newAgentConfigTestDB(t *testing.T) *gorm.DB {
	t.Helper()
	db, err := dbpkg.Init(":memory:")
	require.NoError(t, err)
	sqlDB, err := db.DB()
	require.NoError(t, err)
	t.Cleanup(func() { _ = sqlDB.Close() })
	return db
}

func TestAgentConfig_ReadsFromDataSourceInstances(t *testing.T) {
	db := newAgentConfigTestDB(t)

	nodeName := "homelab-01"
	cfgJSON, err := json.Marshal(map[string]any{"redact_secrets": false})
	require.NoError(t, err)
	result := db.Create(&models.DataSourceInstance{
		ID: "fw1", Type: "filewatcher", Scope: "agent", NodeID: &nodeName,
		Name: "File Watcher", Config: string(cfgJSON), Enabled: true,
	})
	require.NoError(t, result.Error)
	unitsCfg, err := json.Marshal(map[string]any{"units": []string{"nginx.service"}})
	require.NoError(t, err)
	result = db.Create(&models.DataSourceInstance{
		ID: "sys1", Type: "systemd", Scope: "agent", NodeID: &nodeName,
		Name: "Systemd", Config: string(unitsCfg), Enabled: true,
	})
	require.NoError(t, result.Error)
	result = db.Create(&models.Node{ID: "n1", Name: nodeName, LastSeen: time.Now(), Capabilities: "[]"})
	require.NoError(t, result.Error)

	// Use the AgentAuth middleware so the node name is set in context (authenticated path),
	// which is required for capabilities to be stored.
	agentToken := "test-secret-token"
	authCfg, err := middleware.NewAgentAuthConfig(nodeName + "=" + agentToken)
	require.NoError(t, err)
	handler := middleware.AgentAuth(authCfg)(handlers.AgentConfig(db))

	req := httptest.NewRequest(http.MethodGet, "/api/agent/config", nil)
	req.Header.Set("X-Blackbox-Node-Name", nodeName)
	req.Header.Set("X-Blackbox-Agent-Key", agentToken)
	req.Header.Set("X-Blackbox-Agent-Capabilities", "docker,systemd,filewatcher")
	w := httptest.NewRecorder()
	handler.ServeHTTP(w, req)
	require.Equal(t, http.StatusOK, w.Code)

	var resp map[string]any
	require.NoError(t, json.Unmarshal(w.Body.Bytes(), &resp))
	require.Equal(t, true, resp["file_watcher_enabled"])
	require.Equal(t, false, resp["file_watcher_redact_secrets"])
	v, ok := resp["systemd_units"]
	require.True(t, ok)
	units, ok := v.([]any)
	require.True(t, ok)
	require.NotEmpty(t, units)
	require.Equal(t, "nginx.service", units[0])

	// Capabilities stored on node
	var node models.Node
	require.NoError(t, db.Where("name = ?", nodeName).First(&node).Error)
	var caps []string
	require.NoError(t, json.Unmarshal([]byte(node.Capabilities), &caps))
	require.ElementsMatch(t, []string{"docker", "systemd", "filewatcher"}, caps)
}

func TestAgentConfig_DegenerateCapabilitiesHeaderDoesNotOverwriteStoredCapabilities(t *testing.T) {
	db := newAgentConfigTestDB(t)
	nodeName := "homelab-01"
	result := db.Create(&models.Node{ID: "n1", Name: nodeName, LastSeen: time.Now(), Capabilities: `["docker"]`})
	require.NoError(t, result.Error)

	agentToken := "test-secret-token"
	authCfg, err := middleware.NewAgentAuthConfig(nodeName + "=" + agentToken)
	require.NoError(t, err)
	handler := middleware.AgentAuth(authCfg)(handlers.AgentConfig(db))

	req := httptest.NewRequest(http.MethodGet, "/api/agent/config", nil)
	req.Header.Set("X-Blackbox-Node-Name", nodeName)
	req.Header.Set("X-Blackbox-Agent-Key", agentToken)
	req.Header.Set("X-Blackbox-Agent-Capabilities", " , , ")
	w := httptest.NewRecorder()
	handler.ServeHTTP(w, req)
	require.Equal(t, http.StatusOK, w.Code)

	var node models.Node
	require.NoError(t, db.Where("name = ?", nodeName).First(&node).Error)
	var caps []string
	require.NoError(t, json.Unmarshal([]byte(node.Capabilities), &caps))
	require.Equal(t, []string{"docker"}, caps)
}