From c16a95e83d748cee8c8492f36b575e8ee7e5d33e Mon Sep 17 00:00:00 2001 From: MishkaRogachev Date: Mon, 31 Jul 2023 18:19:40 +0400 Subject: [PATCH] fix: calc counts for timestamps --- protocol/messenger_community_metrics.go | 1 + protocol/messenger_community_metrics_test.go | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/protocol/messenger_community_metrics.go b/protocol/messenger_community_metrics.go index 51c578d5ecb..9e00ad06fb0 100644 --- a/protocol/messenger_community_metrics.go +++ b/protocol/messenger_community_metrics.go @@ -55,6 +55,7 @@ func (m *Messenger) collectCommunityMessagesTimestamps(request *requests.Communi StartTimestamp: sourceInterval.StartTimestamp, EndTimestamp: sourceInterval.EndTimestamp, Timestamps: timestamps, + Count: len(timestamps), } } diff --git a/protocol/messenger_community_metrics_test.go b/protocol/messenger_community_metrics_test.go index 0445311efc2..603e6a38a30 100644 --- a/protocol/messenger_community_metrics_test.go +++ b/protocol/messenger_community_metrics_test.go @@ -189,6 +189,10 @@ func (s *MessengerCommunityMetricsSuite) TestCollectCommunityMessagesTimestamps( s.Require().Len(resp.Intervals, 3) + s.Require().Equal(resp.Intervals[0].Count, 3) + s.Require().Equal(resp.Intervals[1].Count, 2) + s.Require().Equal(resp.Intervals[2].Count, 1) + s.Require().Equal(resp.Intervals[0].Timestamps, []uint64{1690372000, 1690372100, 1690372200}) s.Require().Equal(resp.Intervals[1].Timestamps, []uint64{1690372700, 1690372800}) s.Require().Equal(resp.Intervals[2].Timestamps, []uint64{1690373000})