extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-02-27 07:30:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

chore: add a single message to signal server

Browse Source
This commit is contained in:
braginini 2021-04-19 14:19:09 +02:00
parent 8ca77faab5
commit 44cbfa16a8
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
signal/signal.go
View File

@ -29,7 +29,18 @@ func NewServer() *SignalExchangeServer {
}
}
func (s *SignalExchangeServer) Connect(context.Context, *proto.Message) (*proto.Message, error) {
func (s *SignalExchangeServer) Connect(ctx context.Context, msg *proto.Message) (*proto.Message, error) {
if dstPeer, found := s.registry.Peers[msg.RemoteKey]; found {
//forward the message to the target peer
err := dstPeer.Stream.Send(msg)
if err != nil {
log.Errorf("error while forwarding message from peer [%s] to peer [%s]", p.Id, msg.RemoteKey)
//todo respond to the sender?
}
} else {
log.Warnf("message from peer [%s] can't be forwarded to peer [%s] because destination peer is not connected", p.Id, msg.RemoteKey)
//todo respond to the sender?
}
return &proto.Message{}, nil
}