chore: add a single message to signal server

netbirdio · Apr 19, 2021 · b6f4566 · b6f4566
1 parent 88f495a
commit b6f4566
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/signal/signal.go b/signal/signal.go
@@ -31,8 +31,8 @@ func NewServer() *SignalExchangeServer {
 
 func (s *SignalExchangeServer) Connect(ctx context.Context, msg *proto.Message) (*proto.Message, error) {
 
-	if _, found := s.registry.Peers[msg.Key]; found {
-		return &proto.Message{}, nil
+	if _, found := s.registry.Peers[msg.Key]; !found {
+		return nil, fmt.Errorf("unknown peer %s", msg.Key)
 	}
 
 	if dstPeer, found := s.registry.Peers[msg.RemoteKey]; found {