refactor(relay): make relay more compliant to current workflow (#537)

* refactor(relay): refactor relay * refactor(relay): fix server * refactor(relay): fix lint * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update cmd/signal/grpc/server/server.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * Update pkg/sfu/publisher.go Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com> * refactor(relay): fix dependency Co-authored-by: Tarrence van As <tarrencev@users.noreply.github.com>
ionorg · Jun 4, 2021 · b29c73e · b29c73e
1 parent c767713
commit b29c73e
Show file tree

Hide file tree

Showing 7 changed files with 510 additions and 435 deletions.
diff --git a/cmd/signal/grpc/server/server.go b/cmd/signal/grpc/server/server.go
@@ -149,12 +149,10 @@ func (s *SFUServer) Signal(stream pb.SFU_SignalServer) error {
 
 			_, nopub := payload.Join.Config["NoPublish"]
 			_, nosub := payload.Join.Config["NoSubscribe"]
-			_, relay := payload.Join.Config["Relay"]
 
 			cfg := sfu.JoinConfig{
 				NoPublish:   nopub,
 				NoSubscribe: nosub,
-				Relay:       relay,
 			}
 			err = peer.Join(payload.Join.Sid, payload.Join.Uid, cfg)
 			if err != nil {

diff --git a/pkg/middlewares/datachannel/subscriberapi.go b/pkg/middlewares/datachannel/subscriberapi.go
@@ -86,7 +86,7 @@ func sendMessage(streamID string, peer sfu.Peer, layers []string, activeLayer in
 		sfu.Logger.Error(err, "unable to marshal active layer message")
 	}
 
-	if err := peer.SendDCMessage(sfu.APIChannelLabel, &bytes); err != nil {
+	if err := peer.SendDCMessage(sfu.APIChannelLabel, bytes); err != nil {
 		sfu.Logger.Error(err, "unable to send ActiveLayerMessage to peer", "peer_id", peer.ID())
 	}
 }