[signal] Fix registry not found (#3342)

pascal-fischer · web-flow · commit c974c12d652f · 2025-02-18T14:23:34.000+01:00
diff --git a/signal/server/signal.go b/signal/server/signal.go
@@ -160,6 +160,7 @@ func (s *Server) forwardMessageToPeer(ctx context.Context, msg *proto.EncryptedM
 		s.metrics.MessageForwardFailures.Add(ctx, 1, metric.WithAttributes(attribute.String(labelType, labelTypeNotConnected)))
 		log.Debugf("message from peer [%s] can't be forwarded to peer [%s] because destination peer is not connected", msg.Key, msg.RemoteKey)
 		// todo respond to the sender?
+		return
 	}
 
 	s.metrics.GetRegistrationDelay.Record(ctx, float64(time.Since(getRegistrationStart).Nanoseconds())/1e6, metric.WithAttributes(attribute.String(labelType, labelTypeStream), attribute.String(labelRegistrationStatus, labelRegistrationFound)))

Original file line number	Diff line number	Diff line change
`@@ -160,6 +160,7 @@ func (s Server) forwardMessageToPeer(ctx context.Context, msg proto.EncryptedM`
`160`	`160`	`s.metrics.MessageForwardFailures.Add(ctx, 1, metric.WithAttributes(attribute.String(labelType, labelTypeNotConnected)))`
`161`	`161`	`log.Debugf("message from peer [%s] can't be forwarded to peer [%s] because destination peer is not connected", msg.Key, msg.RemoteKey)`
`162`	`162`	`// todo respond to the sender?`
	`163`	`+ return`
`163`	`164`	`}`
`164`	`165`
`165`	`166`	`s.metrics.GetRegistrationDelay.Record(ctx, float64(time.Since(getRegistrationStart).Nanoseconds())/1e6, metric.WithAttributes(attribute.String(labelType, labelTypeStream), attribute.String(labelRegistrationStatus, labelRegistrationFound)))`