datachannel

Datachannels middlewares

ion-sfu supports datachannels middlewares similar to the net/http standard library handlers.

API

Middleware

To create a datachannel middleware, just follow below pattern:

func SubscriberAPI(next sfu.MessageProcessor) sfu.MessageProcessor {
	return sfu.ProcessFunc(func(ctx context.Context, args sfu.ProcessArgs) {
              next.Process(ctx,args)
	}
}

Init middlewares

To initialize the middlewares you need to declare them after sfu initialization:

s := sfu.NewSFU(conf)
dc := s.NewDatachannel(sfu.APIChannelLabel)
dc.Use(datachannel.KeepAlive(5*time.Second), datachannel.SubscriberAPI)
// This callback is optional
dc.OnMessage(func(ctx context.Context, msg webrtc.DataChannelMessage, in *webrtc.DataChannel, out []*webrtc.DataChannel) {
})

Datachannels created in this way will be negotiated on peer join in the Subscriber peer connection. Clients can then get a reference to the channel by using the ondatachannel event handler.