Emit subscribed topics metric for Subscribe2 too

xmtp · Dec 29, 2023 · dc2259f · dc2259f
1 parent a11a279
commit dc2259f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/api/message/v1/service.go b/pkg/api/message/v1/service.go
@@ -280,6 +280,8 @@ func (s *Service) Subscribe2(stream proto.MessageApi_Subscribe2Server) error {
 			}
 			log.Info("updating subscription", zap.Int("num_content_topics", len(req.ContentTopics)))
 
+			metrics.EmitSubscribeTopicsLength(stream.Context(), log, len(req.ContentTopics))
+
 			topics := map[string]bool{}
 			for _, topic := range req.ContentTopics {
 				topics[topic] = true