Netpulse_SasS/server/internal/store/device_detail_test.go

package store

import (
	"encoding/json"
	"testing"
	"time"
)

// Зіставлення ряду з перевіркою — висновок, а не факт зі схеми. Тест
// стереже саме ПОРЯДОК висновків: помилка тут не падає й не світиться,
// вона тихо показує людині не той шаблон, у який іти щось міняти.
func TestMatchOriginPriority(t *testing.T) {
	checks := []DeviceCheck{
		{
			ID: "icmp", CheckType: "icmp.ping", Origin: "template",
			TemplateID: "t1", TemplateName: "Доступність (ICMP)", Enabled: true,
			IntervalSec: 60, Params: json.RawMessage(`{"count":3}`),
			Metrics: []string{"icmp.rtt_avg", "icmp.loss_pct", "icmp.jitter"},
		},
		{
			ID: "get", CheckType: "snmp.get", Origin: "template",
			TemplateID: "t2", TemplateName: "Загальне (SNMP)", Enabled: true,
			IntervalSec: 60,
			Params: json.RawMessage(
				`{"oids":[{"oid":".1.3.6.1.2.1.1.3.0","metric_key":"sys.uptime_sec"}]}`),
			Metrics: []string{},
		},
		{
			ID: "if", CheckType: "snmp.if", Origin: "auto", AutoManaged: true,
			Enabled: true, IntervalSec: 60,
			Params:  json.RawMessage(`{"interfaces":[{"if_index":1,"interface_id":"IF-1"}]}`),
			Metrics: []string{"if.in_bps", "if.out_bps"},
		},
	}

	cases := []struct {
		name    string
		metric  LatestMetric
		wantID  string
		wantKnd string
	}{
		{
			// Ключ прямо названий у params — найнадійніше джерело.
			name:    "ключ метрики з params",
			metric:  LatestMetric{MetricKey: "sys.uptime_sec", PluginKey: "snmp"},
			wantID:  "get",
			wantKnd: "template",
		},
		{
			// Порт у переліку чека переважає збіг за довідником: обидва
			// вказують на snmp.if, але перший знає ще й ЯКИЙ порт.
			name: "порт із переліку чека",
			metric: LatestMetric{
				MetricKey: "if.in_bps", PluginKey: "snmp", InterfaceID: "IF-1",
			},
			wantID:  "if",
			wantKnd: "auto",
		},
		{
			// Той самий плагін snmp, що й у snmp.get, але ключ стоїть у
			// довіднику саме snmp.if — довідник має бути сильнішим за
			// збіг плагіна, інакше метрики портів приписались би до
			// шаблонного snmp.get.
			name: "довідник типу переважає плагін",
			metric: LatestMetric{
				MetricKey: "if.out_bps", PluginKey: "snmp", InterfaceID: "IF-9",
			},
			wantID:  "if",
			wantKnd: "auto",
		},
		{
			name:    "довідник icmp",
			metric:  LatestMetric{MetricKey: "icmp.jitter", PluginKey: "icmp"},
			wantID:  "icmp",
			wantKnd: "template",
		},
		{
			// Плагін збігається, ключа немає ніде — здогад, але кращий
			// за «невідомо»: чек icmp.ping у хоста один.
			name:    "тільки плагін",
			metric:  LatestMetric{MetricKey: "icmp.rtt_p95", PluginKey: "icmp"},
			wantID:  "icmp",
			wantKnd: "template",
		},
		{
			// Найважливіший випадок: серія є, чека немає. Саме такий
			// стан на стенді має 466 рядів if.* — і саме він виглядав
			// як «метрики беруться нізвідки».
			name:    "чека немає",
			metric:  LatestMetric{MetricKey: "cpu.util", PluginKey: "unknown"},
			wantID:  "",
			wantKnd: "none",
		},
	}

	for _, c := range cases {
		t.Run(c.name, func(t *testing.T) {
			got := matchOrigin(&c.metric, checks, map[string]string{})
			if got.CheckID != c.wantID {
				t.Errorf("check_id = %q, очікували %q", got.CheckID, c.wantID)
			}
			if got.Kind != c.wantKnd {
				t.Errorf("kind = %q, очікували %q", got.Kind, c.wantKnd)
			}
		})
	}
}

func TestIsStale(t *testing.T) {
	now := time.Date(2026, 8, 26, 12, 0, 0, 0, time.UTC)
	at := func(d time.Duration) *time.Time { t := now.Add(-d); return &t }

	cases := []struct {
		name string
		m    LatestMetric
		want bool
	}{
		{
			// Один пропуск у хвилинного чека — це життя, а не збій.
			name: "пропуск такту",
			m: LatestMetric{
				LastAt: at(90 * time.Second),
				Origin: MetricOrigin{IntervalSec: 60, Enabled: true},
			},
			want: false,
		},
		{
			// П'ятихвилинний чек: три такти — це чверть години, і саме
			// вони, а не нижня межа, вирішують.
			name: "три такти поспіль",
			m: LatestMetric{
				LastAt: at(20 * time.Minute),
				Origin: MetricOrigin{IntervalSec: 300, Enabled: true},
			},
			want: true,
		},
		{
			// Нижня межа тримає хвилинний чек у спокої довше, ніж три
			// такти: пропуск на такій частоті — не подія.
			name: "хвилинний чек, п'ять хвилин мовчання",
			m: LatestMetric{
				LastAt: at(5 * time.Minute),
				Origin: MetricOrigin{IntervalSec: 60, Enabled: true},
			},
			want: false,
		},
		{
			// Секундний чек не має ставати червоним щохвилини — нижня
			// межа порога тримає його в спокої.
			name: "дуже частий чек",
			m: LatestMetric{
				LastAt: at(2 * time.Minute),
				Origin: MetricOrigin{IntervalSec: 5, Enabled: true},
			},
			want: false,
		},
		{
			name: "ряд без чека, дані свіжі",
			m:    LatestMetric{LastAt: at(time.Minute), Origin: MetricOrigin{Kind: "none"}},
			want: false,
		},
		{
			name: "ряд без чека, дані вчорашні",
			m:    LatestMetric{LastAt: at(20 * time.Hour), Origin: MetricOrigin{Kind: "none"}},
			want: true,
		},
		{
			name: "жодної точки",
			m:    LatestMetric{Origin: MetricOrigin{IntervalSec: 60, Enabled: true}},
			want: true,
		},
	}

	for _, c := range cases {
		t.Run(c.name, func(t *testing.T) {
			if got := isStale(&c.m, now); got != c.want {
				t.Errorf("isStale = %v, очікували %v", got, c.want)
			}
		})
	}
}