add compatibility for janus 1.x

Signed-off-by: Marcel Hibbe <dev@mhibbe.de>
This commit is contained in:
Marcel Hibbe 2024-02-27 16:46:22 +01:00
parent abe9a9d5fb
commit fcf6c845a7
No known key found for this signature in database
GPG key ID: C793F8B59F43CE7B

View file

@ -398,8 +398,7 @@ public class PeerConnectionWrapper {
@Override @Override
public void onStateChange() { public void onStateChange() {
if (dataChannel != null && if (dataChannel != null &&
dataChannel.state() == DataChannel.State.OPEN && dataChannel.state() == DataChannel.State.OPEN) {
"status".equals(dataChannel.label())) {
sendInitialMediaStatus(); sendInitialMediaStatus();
} }
} }
@ -535,10 +534,12 @@ public class PeerConnectionWrapper {
@Override @Override
public void onDataChannel(DataChannel dataChannel) { public void onDataChannel(DataChannel dataChannel) {
if ("status".equals(dataChannel.label()) || "JanusDataChannel".equals(dataChannel.label())) { if (PeerConnectionWrapper.this.dataChannel != null) {
PeerConnectionWrapper.this.dataChannel = dataChannel; Log.w(TAG, "Data channel with label " + PeerConnectionWrapper.this.dataChannel.label()
PeerConnectionWrapper.this.dataChannel.registerObserver(new MagicDataChannelObserver()); + " exists, but received onDataChannel event for DataChannel with label " + dataChannel.label());
} }
PeerConnectionWrapper.this.dataChannel = dataChannel;
PeerConnectionWrapper.this.dataChannel.registerObserver(new MagicDataChannelObserver());
} }
@Override @Override