ZoomSDKAudioRawDataHelper.java

Go to the documentation of this file.

package us.zoom.sdk;
 
import com.zipow.videobox.confapp.enums.CONF_CMD;
 
import java.lang.ref.WeakReference;
import java.nio.ByteBuffer;
 
import us.zoom.common.crossplatform.cmmlib.BuildConfig;
import us.zoom.core.helper.ZMLog;
import us.zoom.internal.ErrorCodeMapping;
import us.zoom.internal.RTCConference;
import us.zoom.internal.event.RTCConferenceEventUI;
import us.zoom.internal.event.RTCVideoRawDataDelegate;
import us.zoom.internal.event.SDKConfUIEventHandler;
import us.zoom.internal.helper.SDKMeetingInterfaceHelper;
import us.zoom.internal.impl.ZoomSDKAudioRawDataSender;
import us.zoom.internal.jni.helper.ZoomMeetingSDKBridgeHelper;

public class ZoomSDKAudioRawDataHelper implements IZoomSDKAudioRawDataHelper {
 
    private static final String TAG = "ZoomSDKAudioRawDataHelper";
    private WeakReference<IZoomSDKAudioRawDataDelegate> weakReference;
 
    private IZoomSDKVirtualAudioMicEvent virtualAudioMic;
 
    private RTCVideoRawDataDelegate rtcAudioRawDataDelegate;
 
    SDKConfUIEventHandler.ISDKConfUIListener simpleConfUIListener = new SDKConfUIEventHandler.SimpleSDKConfUIListener() {
        @Override
        public boolean onConfStatusChanged2(int cmd, long ret) {
            if (cmd == CONF_CMD.CMD_CONF_LEAVE_COMPLETE) {
                onConfLeave();
            } else if (cmd == CONF_CMD.CMD_CONF_SILENTMODE_CHANGED) {
                if (SDKMeetingInterfaceHelper.isInSlientMode()) {
                    unSubscribe();
                }
            }
            return true;
        }
    };
 
    private void onConfLeave() {
        unSubscribe();
        SDKConfUIEventHandler.getInstance().removeListener(simpleConfUIListener);
        virtualAudioMic=null;
    }
 
    RTCVideoRawDataDelegate.SimpleRTCVideoRawDataListener audioRawdataListener = new RTCVideoRawDataDelegate.SimpleRTCVideoRawDataListener() {
 
        public void onUninitialize() {
            if (null != virtualAudioMic) {
                virtualAudioMic.onMicUninitialized();
            }
        }
 
        public void onDeviceInitialize(long nativeHandle) {
            if (null != virtualAudioMic) {
                IZoomSDKAudioRawDataSender sender = new ZoomSDKAudioRawDataSender(nativeHandle);
                virtualAudioMic.onMicInitialize(sender);
            }
        }
 
        public void onStartSendData() {
            if (null != virtualAudioMic) {
                virtualAudioMic.onMicStartSend();
            }
        }
 
        public void onStopSendData() {
            if (null != virtualAudioMic) {
                virtualAudioMic.onMicStopSend();
            }
        }
 
        public void onDeviceUninitialize() {
            if (null != virtualAudioMic) {
                virtualAudioMic.onMicUninitialized();
            }
        }
    };
 
    RTCConferenceEventUI.SimpleRTCConferenceEventUIListener eventUIListener = new RTCConferenceEventUI.SimpleRTCConferenceEventUIListener() {
 
        @Override
        public void onMixedAudioRawDataReceived(ByteBuffer buffer, int bufferLen, int sampleRate,int channel,long timeStamp, long nativeHandle) {
 
            if (null != weakReference) {
                IZoomSDKAudioRawDataDelegate dataDelegate = weakReference.get();
                if (null != dataDelegate) {
                    ZoomSDKAudioRawData rawData = new ZoomSDKAudioRawData(buffer, bufferLen, sampleRate,channel,timeStamp, nativeHandle);
                    dataDelegate.onMixedAudioRawDataReceived(rawData);
                } else {
                    if (BuildConfig.LOG_ENABLE) {
                        ZMLog.d(TAG, "onMixedAudioRawDataReceived dataDelegate is null");
                    }
                }
            }
        }
 
        @Override
        public void onOneWayAudioRawDataReceivedImpl(ByteBuffer buffer, int bufferLen, int sampleRate, int channel, int userId,long timeStamp, long nativeHandle) {
            if (null != weakReference) {
                IZoomSDKAudioRawDataDelegate dataDelegate = weakReference.get();
                if (null != dataDelegate) {
                    ZoomSDKAudioRawData rawData = new ZoomSDKAudioRawData(buffer, bufferLen, sampleRate,channel,timeStamp,nativeHandle);
                    dataDelegate.onOneWayAudioRawDataReceived(rawData, userId);
                } else {
                    if (BuildConfig.LOG_ENABLE) {
                        ZMLog.d(TAG, "onOneWayAudioRawDataReceivedImpl dataDelegate is null");
                    }
                }
            }
        }
 
        @Override
        public void onShareAudioRawDataReceived(ByteBuffer buffer, int bufferLen, int sampleRate, int channel,long timeStamp, long userId, long nativeHandle) {
            if (null != weakReference) {
                IZoomSDKAudioRawDataDelegate dataDelegate = weakReference.get();
                if (null != dataDelegate) {
                    ZoomSDKAudioRawData rawData = new ZoomSDKAudioRawData(buffer, bufferLen, sampleRate,channel,timeStamp, nativeHandle);
                    dataDelegate.onShareAudioRawDataReceived(rawData, userId);
                } else {
                    if (BuildConfig.LOG_ENABLE) {
                        ZMLog.d(TAG, "onShareAudioRawDataReceived dataDelegate is null");
                    }
                }
            }
        }
    };
 
 
    public ZoomSDKAudioRawDataHelper() {
 
    }
 
    @Override
    public MobileRTCRawDataError subscribe(IZoomSDKAudioRawDataDelegate delegate) {
        if (SDKMeetingInterfaceHelper.isInSlientMode()) {
            return MobileRTCRawDataError.MobileRTCRawData_WrongUsage;
        }
 
        if (null == RTCConference.getInstance()) {
            return MobileRTCRawDataError.MobileRTCRawData_Uninitialized;
        }
        RTCConferenceEventUI.getInstance().addListener(eventUIListener);
        weakReference = new WeakReference<>(delegate);
        int ret = RTCConference.getInstance().getAudioRawDataHelper().start();
        MobileRTCRawDataError error= ErrorCodeMapping.mapping(ret);
        ZoomMeetingSDKBridgeHelper.getInstance().trackingMSDKInteractEvent(TAG, "subscribe", error.ordinal());
        return error;
    }
 
    @Override
    public MobileRTCRawDataError unSubscribe() {
        if (null == RTCConference.getInstance()) {
            return MobileRTCRawDataError.MobileRTCRawData_Uninitialized;
        }
        RTCConferenceEventUI.getInstance().removeListener(eventUIListener);
        weakReference = null;
        int ret = RTCConference.getInstance().getAudioRawDataHelper().stop();
        MobileRTCRawDataError error= ErrorCodeMapping.mapping(ret);
        ZoomMeetingSDKBridgeHelper.getInstance().trackingMSDKInteractEvent(TAG, "unSubscribe", error.ordinal());
        return error;
    }
 
    @Override
    public MobileRTCRawDataError setExternalAudioSource(IZoomSDKVirtualAudioMicEvent audioMic) {
        if (null == RTCConference.getInstance()) {
            return MobileRTCRawDataError.MobileRTCRawData_Uninitialized;
        }
 
        if (SDKMeetingInterfaceHelper.isInSlientMode()) {
            return MobileRTCRawDataError.MobileRTCRawData_WrongUsage;
        }
        if (this.virtualAudioMic == audioMic) {
            return MobileRTCRawDataError.MobileRTCRawData_Invalid_Param;
        }
        this.virtualAudioMic = audioMic;
 
        int result = 0;
        if (null == audioMic) {
            result = RTCConference.getInstance().getAudioRawDataHelper().setVirtualAudioMic(0);
            rtcAudioRawDataDelegate = null;
        } else {
            rtcAudioRawDataDelegate = new RTCVideoRawDataDelegate(audioRawdataListener);
            result = RTCConference.getInstance().getAudioRawDataHelper().setVirtualAudioMic(rtcAudioRawDataDelegate.getRecevHandle());
        }
        if (result != 0) {
            this.virtualAudioMic = null;
        }
        MobileRTCRawDataError error= ErrorCodeMapping.mapping(result);
        ZoomMeetingSDKBridgeHelper.getInstance().trackingMSDKInteractEvent(TAG, "setExternalAudioSource", error.ordinal());
        return error;
    }
}