Netpulse_SasS/server/internal/store/queues_verdict_test.go

package store

import (
	"strings"
	"testing"
	"time"
)

// Перевіряється не форматування, а саме рішення: що сторінка називає
// бідою. Помилка тут не впаде складанням і не з'явиться в логах — вона
// просто одного разу промовчить про втрачені дані.

func queueFactsFixture() *QueueFacts {
	return &QueueFacts{At: time.Now(), WindowSec: 3600}
}

func findCard(t *testing.T, r *QueueReport, key string) QueueCard {
	t.Helper()
	for _, c := range r.Cards {
		if c.Key == key {
			return c
		}
	}
	t.Fatalf("картки %q немає у звіті", key)
	return QueueCard{}
}

func TestIdleSystemReportsOK(t *testing.T) {
	r := BuildQueueReport(queueFactsFixture(), QueueDeltas{})
	if r.Level != LevelOK {
		t.Fatalf("порожня система дала рівень %q: %s", r.Level, r.Headline)
	}
	if r.Headline != "Усе встигає" {
		t.Fatalf("заголовок: %q", r.Headline)
	}
}

// Глибина сама по собі не діагноз: черга, що стабільно тримає сотню й
// стільки ж обробляє, здорова. Саме це найлегше зіпсувати порогом «100».
func TestDeepButHealthyQueueStaysOK(t *testing.T) {
	f := queueFactsFixture()
	f.Jobs = JobsQueueFacts{
		Queued: 100, Running: 4, OldestQueuedSec: 40,
		Arrived: 300, Finished: 300,
	}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "ncm.jobs")
	if c.Level != LevelOK {
		t.Fatalf("рівень %q, висновок: %s", c.Level, c.Verdict)
	}
}

func TestGrowingQueueWarns(t *testing.T) {
	f := queueFactsFixture()
	f.Jobs = JobsQueueFacts{Queued: 300, OldestQueuedSec: 90, Arrived: 300, Finished: 100}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "ncm.jobs")
	if c.Level != LevelWarn {
		t.Fatalf("рівень %q, висновок: %s", c.Level, c.Verdict)
	}
}

// Втрата важливіша за довжину: прибрані прибиральником завдання роблять
// картку червоною навіть за порожньої черги.
func TestReapedJobsAreCritical(t *testing.T) {
	f := queueFactsFixture()
	f.Jobs = JobsQueueFacts{Arrived: 12, Finished: 12, Failed: 3, Reaped: 3}
	r := BuildQueueReport(f, QueueDeltas{})
	c := findCard(t, r, "ncm.jobs")
	if c.Level != LevelCrit || c.LossKind != LossDrop {
		t.Fatalf("рівень %q, втрата %q", c.Level, c.LossKind)
	}
	if r.Level != LevelCrit || !strings.Contains(r.Headline, c.Title) {
		t.Fatalf("заголовок не назвав місце: %q", r.Headline)
	}
	if r.Cards[0].Key != "ncm.jobs" {
		t.Fatalf("найгірша картка не перша: %q", r.Cards[0].Key)
	}
}

// Накопичувальний лічильник без приросту — не привід кричати: він
// ненульовий від старту зонда й після давно полагодженої аварії.
func TestDroppedWithoutGrowthOnlyWarns(t *testing.T) {
	f := queueFactsFixture()
	dropped := int64(4200)
	depth := 0
	f.Agents = []AgentQueueFacts{{
		ID: "a1", Name: "Зонд", Status: "online",
		QueueDepth: &depth, Dropped: &dropped,
	}}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{ObservedSec: 120}), "agents.buffer")
	if c.Level != LevelWarn {
		t.Fatalf("рівень %q, висновок: %s", c.Level, c.Verdict)
	}

	d := QueueDeltas{ObservedSec: 120, AgentDropped: map[string]int64{"a1": 17}}
	c = findCard(t, BuildQueueReport(f, d), "agents.buffer")
	if c.Level != LevelCrit {
		t.Fatalf("свіжі втрати дали рівень %q", c.Level)
	}
	if len(c.Where) == 0 {
		t.Fatal("не названо, який саме зонд викидає")
	}
}

// Офлайн зонд із хостами — це не «черга росте», це «нічого не збирається».
func TestOfflineAgentWithDevicesIsCritical(t *testing.T) {
	f := queueFactsFixture()
	f.Agents = []AgentQueueFacts{{ID: "a1", Name: "Зонд", Status: "offline", Devices: 42, HeartbeatSec: 900}}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "agents.link")
	if c.Level != LevelCrit || !strings.Contains(c.Verdict, "42") {
		t.Fatalf("рівень %q, висновок: %s", c.Level, c.Verdict)
	}
}

// Величина, якої ніхто не міряє, має бути названа вголос.
func TestBlindSpotsAreListed(t *testing.T) {
	r := BuildQueueReport(queueFactsFixture(), QueueDeltas{})
	if len(r.BlindSpots) == 0 {
		t.Fatal("перелік сліпих зон порожній")
	}
	var syslog bool
	for _, s := range r.BlindSpots {
		if strings.Contains(s, "syslog") {
			syslog = true
		}
	}
	if !syslog {
		t.Fatal("втрати syslog на зонді не згадано")
	}
}

func TestSkippedCheckCycleIsLoss(t *testing.T) {
	f := queueFactsFixture()
	f.Checks = ChecksFacts{Enabled: 500, Skipped: 7}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "agents.scheduler")
	// Пропуск такту — завжди втрата вимірювання, незалежно від масштабу.
	if c.LossKind != LossDrop {
		t.Fatalf("втрата %q", c.LossKind)
	}
	if c.Level == LevelOK {
		t.Fatalf("пропуск такту не може бути зеленим: %q", c.Level)
	}
}

// Один пропуск із сімнадцяти чеків — привід подивитись, а не аварія.
//
// Тест саме на калібрування, а не на формулювання: сторінка, яка
// світить червоним від повільного пінга, вчить не дивитись на неї
// взагалі — і тоді вона не спрацює тоді, коли справді знадобиться.
func TestSingleSkippedCheckIsNotCritical(t *testing.T) {
	f := queueFactsFixture()
	f.Checks = ChecksFacts{Enabled: 17, Skipped: 1}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "agents.scheduler")
	if c.Level != LevelWarn {
		t.Fatalf("очікували попередження, отримали %q", c.Level)
	}
}

// А десята частина — уже аварія: пропуски стали системними.
func TestSkippedShareBecomesCritical(t *testing.T) {
	f := queueFactsFixture()
	f.Checks = ChecksFacts{Enabled: 20, Skipped: 2}
	c := findCard(t, BuildQueueReport(f, QueueDeltas{}), "agents.scheduler")
	if c.Level != LevelCrit {
		t.Fatalf("очікували критичний, отримали %q", c.Level)
	}
}