fix: avoid empty node metrics race in CT (collect on start + poll). Refs EventHub/EventHubBack#47

src/infra/node_monitor.erl

@@ -41,8 +41,8 @@ init([]) ->
   mnesia:wait_for_tables([node_metric], 5000),
   % Создаём ETS-таблицу для кеширования предыдущих значений io
   ets:new(?IO_CACHE_TAB, [named_table, public, set, {keypos, 1}]),
-  % Запускаем периодический сбор метрик и очистку
-  schedule_collect(),
+  % Первый сбор сразу (иначе окно ~5с без метрик), далее по интервалу.
+  self() ! collect,
   schedule_cleanup(),
   {ok, #{}}.
 

test/api/admins/admin_stats_tests.erl

@@ -227,6 +227,25 @@ test_calendar_stats(Token) ->
 
 test_node_metrics_history(Token) ->
   ct:pal(" TEST: Node metrics history"),
+  %% node_monitor пишет раз в 5с; в быстром CI stats-кейс может успеть раньше.
+  case whereis(node_monitor) of
+    undefined -> ok;
+    Pid when is_pid(Pid) -> Pid ! collect
+  end,
+  Metrics = wait_node_metrics(Token, 20, 500),
+  ?assert(is_list(Metrics)),
+  ?assert(length(Metrics) >= 1),
+  First = hd(Metrics),
+  ?assert(maps:is_key(<<"timestamp">>, First)),
+  ?assert(maps:is_key(<<"node">>, First)),
+  ?assert(maps:is_key(<<"memory_total">>, First)),
+  ?assert(maps:is_key(<<"memory_available">>, First)),
+  ?assert(maps:is_key(<<"cpu_utilization">>, First)),
+  ct:pal(" OK: ~p metrics received", [length(Metrics)]).
+
+wait_node_metrics(_Token, 0, _SleepMs) ->
+  [];
+wait_node_metrics(Token, Attempts, SleepMs) ->
   Now = calendar:universal_time(),
   FromSec = calendar:datetime_to_gregorian_seconds(Now) - 300,
   ToSec   = calendar:datetime_to_gregorian_seconds(Now) + 300,
@@ -237,17 +256,13 @@ test_node_metrics_history(Token) ->
   Path = <<"/v1/admin/nodes/metrics?from=", From/binary, "&to=", To/binary>>,
   {ok, 200, _, Body} = api_test_runner:admin_request(get, Path, Token, <<"">>),
   Metrics = jsx:decode(list_to_binary(Body), [return_maps]),
-  ?assert(is_list(Metrics)),
-  % Так как монитор работает, метрики уже должны быть
-  ?assert(length(Metrics) >= 1),
-  % Проверяем структуру первой метрики
-  First = hd(Metrics),
-  ?assert(maps:is_key(<<"timestamp">>, First)),
-  ?assert(maps:is_key(<<"node">>, First)),
-  ?assert(maps:is_key(<<"memory_total">>, First)),
-  ?assert(maps:is_key(<<"memory_available">>, First)),
-  ?assert(maps:is_key(<<"cpu_utilization">>, First)),
-  ct:pal(" OK: ~p metrics received", [length(Metrics)]).
+  case is_list(Metrics) andalso length(Metrics) >= 1 of
+    true ->
+      Metrics;
+    false ->
+      timer:sleep(SleepMs),
+      wait_node_metrics(Token, Attempts - 1, SleepMs)
+  end.
 
 test_avg_ticket_resolution_after_close(Token, UserToken) ->
   ct:pal(" TEST: avg_ticket_resolution_h after closing ticket"),