ZoomSDKRenderer.java

Go to the documentation of this file.

package us.zoom.sdk;
 
import com.zipow.videobox.confapp.enums.CONF_CMD;
import com.zipow.videobox.confapp.CmmUser;
import com.zipow.videobox.confapp.VideoSessionMgr;
import com.zipow.videobox.conference.jni.confinst.IConfInst;
import com.zipow.videobox.conference.module.confinst.ZmConfInstMgr;
 
import java.nio.ByteBuffer;
 
import us.zoom.internal.ErrorCodeMapping;
import us.zoom.internal.RTCConference;
import us.zoom.internal.event.RTCVideoRawDataDelegate;
import us.zoom.internal.event.SDKConfUIEventHandler;
import us.zoom.internal.helper.SDKMeetingInterfaceHelper;
 

public class ZoomSDKRenderer implements IZoomSDKRenderer {
 
    private final static String TAG = ZoomSDKRenderer.class.getSimpleName();
 
    private RTCVideoRawDataDelegate rtcVideoRawDataDelegate;
 
    private IZoomSDKVideoRawDataDelegate delegate;
 
    private ZoomSDKVideoResolution mResolution = ZoomSDKVideoResolution.VideoResolution_90P;
 
    private ZoomSDKRawDataType mRawDataType;
 
    private int mSubscribeId = -1;
 
    private boolean isSubscribed = false;
 
 
    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();
        if (null != rtcVideoRawDataDelegate) {
            rtcVideoRawDataDelegate.release();
            rtcVideoRawDataDelegate = null;
        }
        SDKConfUIEventHandler.getInstance().removeListener(simpleConfUIListener);
    }
 
 
    private RTCVideoRawDataDelegate.RTCVideoRawDataListener listener = new RTCVideoRawDataDelegate.SimpleRTCVideoRawDataListener() {
 
 
        @Override
        public void onSubscribedVideoUserDataOn() {
            if (null != delegate) {
                delegate.onUserRawDataStatusChanged(IZoomSDKVideoRawDataDelegate.UserRawDataStatus.RawData_On);
            }
        }
 
        @Override
        public void onSubscribedVideoUserDataOff() {
            if (null != delegate) {
                delegate.onUserRawDataStatusChanged(IZoomSDKVideoRawDataDelegate.UserRawDataStatus.RawData_Off);
            }
        }
 
        @Override
        public void onSubscribedShareUserDataOff() {
            if (null != delegate) {
                delegate.onUserRawDataStatusChanged(IZoomSDKVideoRawDataDelegate.UserRawDataStatus.RawData_Off);
            }
        }
 
        @Override
        public void onSubscribedShareUserDataOn() {
            if (null != delegate) {
                delegate.onUserRawDataStatusChanged(IZoomSDKVideoRawDataDelegate.UserRawDataStatus.RawData_On);
            }
        }
 
 
        @Override
        public void onVideoRawDataReceived(ByteBuffer yBuffer, ByteBuffer uBuffer, ByteBuffer vBuffer, ByteBuffer aBuffer, boolean isLimited, int streamWidth, int streamHeight, int rotation,long timeStamp, long nativeHandle, long nativeYHandle, long nativeUHandle, long nativeVHandle, long nativeAHandle) {
            if (null != delegate && mRawDataType == ZoomSDKRawDataType.RAW_DATA_TYPE_VIDEO) {
                ZoomSDKVideoRawData rawData = new ZoomSDKVideoRawData(yBuffer, uBuffer, vBuffer, aBuffer, isLimited, streamWidth, streamHeight, rotation,timeStamp, ZoomSDKVideoRawData.FORMAT_TYPE_I420, nativeHandle, nativeYHandle, nativeUHandle, nativeVHandle, nativeAHandle);
                delegate.onVideoRawDataFrame(rawData);
            }
        }
 
        @Override
        public void onShareRawDataReceived(ByteBuffer yBuffer, ByteBuffer uBuffer, ByteBuffer vBuffer, boolean isLimited, int streamWidth, int streamHeight, int rotation,long timeStamp, long nativeHandle, long nativeYHandle, long nativeUHandle, long nativeVHandle) {
            if (null != delegate && mRawDataType == ZoomSDKRawDataType.RAW_DATA_TYPE_SHARE) {
                ZoomSDKVideoRawData rawData = new ZoomSDKVideoRawData(yBuffer, uBuffer, vBuffer, isLimited, streamWidth, streamHeight, rotation,timeStamp, ZoomSDKVideoRawData.FORMAT_TYPE_I420, nativeHandle, nativeYHandle, nativeUHandle, nativeVHandle);
                delegate.onVideoRawDataFrame(rawData);
            }
        }
    };

    public ZoomSDKRenderer(IZoomSDKVideoRawDataDelegate dataDelegate) {
        this.delegate = dataDelegate;
        SDKConfUIEventHandler.getInstance().addListener(simpleConfUIListener);
        rtcVideoRawDataDelegate = new RTCVideoRawDataDelegate(listener);
    }

    public void setRawDataResolution(ZoomSDKVideoResolution resolution) {
        if (null == resolution) {
            return;
        }
        if (resolution != this.mResolution) {
            this.mResolution = resolution;
            if (isSubscribed) {
                subscribe(mSubscribeId, mRawDataType);
            }
        }
    }
 
 
    public MobileRTCRawDataError subscribe(long subscribeId, ZoomSDKRawDataType type) {
 
        if (SDKMeetingInterfaceHelper.isInSlientMode()) {
            return MobileRTCRawDataError.MobileRTCRawData_WrongUsage;
        }
 
        int id = (int) subscribeId;
 
        RTCConference conference = RTCConference.getInstance();
 
        if (null == conference) {
            return MobileRTCRawDataError.MobileRTCRawData_Uninitialized;
        }
        if (null == rtcVideoRawDataDelegate) {
            return MobileRTCRawDataError.MobileRTCRawData_WrongUsage;
        }
 
 
        //resubscribe
        if ((mSubscribeId >= 0 && mSubscribeId != id) || (null != mRawDataType && mRawDataType != type)) {
            unSubscribe();
        }
 
        //start preview
        if (id == 0 && type == ZoomSDKRawDataType.RAW_DATA_TYPE_VIDEO) {
            if (ZoomSDK.getInstance().getMeetingService().getMeetingStatus() == MeetingStatus.MEETING_STATUS_INMEETING) {
                VideoSessionMgr videoMgr = ZmConfInstMgr.getInstance().getCurrentConfInst().getVideoObj();
                if (null != videoMgr) {
                    CmmUser user = ZmConfInstMgr.getInstance().getCurrentConfInst().getMyself();
                    if (null != user) {
                        id = (int) ZmConfInstMgr.getInstance().getCurrentConfInst().getMyself().getNodeId();
                    }
                }
            }
        }
 
        int result = MobileRTCRawDataError.MobileRTCRawData_Success.ordinal();
        int size = mResolution.getValue();
 
        if (type == ZoomSDKRawDataType.RAW_DATA_TYPE_VIDEO) {
            result = conference.getVideoRawDataHelper().subscribe(id, size, rtcVideoRawDataDelegate.getRecevHandle());
        } else if (type == ZoomSDKRawDataType.RAW_DATA_TYPE_SHARE) {
            result = conference.getShareRawDataHelper().subscribe(id, size, rtcVideoRawDataDelegate.getRecevHandle());
        }
 
        if (result == MobileRTCRawDataError.MobileRTCRawData_Success.ordinal()) {
            this.mSubscribeId = id;
            mRawDataType = type;
            isSubscribed = true;
        }
        return ErrorCodeMapping.mapping(result);
    }
 

    public MobileRTCRawDataError unSubscribe() {
        RTCConference conference = RTCConference.getInstance();
        if (null == conference || null == mRawDataType) {
            return MobileRTCRawDataError.MobileRTCRawData_Uninitialized;
        }
 
        if (!isSubscribed) {
            return MobileRTCRawDataError.MobileRTCRawData_Success;
        }
 
        if (null == rtcVideoRawDataDelegate) {
            return MobileRTCRawDataError.MobileRTCRawData_WrongUsage;
        }
 
        int result = MobileRTCSDKError.SDKERR_SUCCESS.ordinal();
 
        if (mSubscribeId == 0) {
            IConfInst confMgr = ZmConfInstMgr.getInstance().getCurrentConfInst();
            if (null != confMgr) {
                CmmUser mySelf = confMgr.getMyself();
                if (null != mySelf) {
                    mSubscribeId = (int) mySelf.getNodeId();
                }
            }
        }
        if (mRawDataType == ZoomSDKRawDataType.RAW_DATA_TYPE_VIDEO) {
            result = conference.getVideoRawDataHelper().unSubscribe(mSubscribeId, rtcVideoRawDataDelegate.getRecevHandle());
        } else if (mRawDataType == ZoomSDKRawDataType.RAW_DATA_TYPE_SHARE) {
            result = conference.getShareRawDataHelper().unSubscribe(mSubscribeId, rtcVideoRawDataDelegate.getRecevHandle());
        }
 
        if (result == MobileRTCSDKError.SDKERR_SUCCESS.ordinal()) {
            isSubscribed = false;
            mSubscribeId = -1;
            mRawDataType = null;
            mResolution = ZoomSDKVideoResolution.VideoResolution_90P;
        }
 
        return ErrorCodeMapping.mapping(result);
    }

    public ZoomSDKVideoResolution getResolution() {
        return mResolution;
    }

    @Override
    public ZoomSDKRawDataType getRawDataType() {
        return mRawDataType;
    }

    public long getSubscribeId() {
        return mSubscribeId;
    }
}