AlivcLivePusher.java

package com.alivc.live.pusher;

import android.content.Context;
import android.view.SurfaceView;
import android.widget.FrameLayout;

import com.alivc.component.custom.AlivcLivePushCustomAudioFilter;
import com.alivc.component.custom.AlivcLivePushCustomDetect;
import com.alivc.component.custom.AlivcLivePushCustomFilter;
import com.alivc.live.annotations.AlivcLiveMode;
import com.alivc.live.utils.AlivcLiveURLTools;
import com.alivc.live.utils.ReflectUtil;

@CalledByNative
public class AlivcLivePusher implements ILivePusher {
    private ILivePusher mImpl = null;

    private static final String BASIC_PUSHER_IMPL_CLASS = "com.alivc.live.pusher.AlivcLivePusherBasicImpl";
    private static final String INTERACTIVE_PUSHER_IMPL_CLASS = "com.alivc.live.pusher.rtc.AlivcRTCLivePusherImpl";

    @Override
    public void init(Context context, AlivcLivePushConfig config) throws IllegalArgumentException, IllegalStateException {
        AlivcLivePushInstance.loadInstance(context);

        if (config == null) {
            throw new IllegalArgumentException("Invalid parameter, config is null.");
        }

        reflectInitPusher(config.getLivePushMode());
        setLivePusherReference(this);

        if (mImpl == null) {
            return;
        }
        mImpl.init(context, config);
    }

    private void reflectInitPusher(AlivcLiveMode mode) {
        Object playerInstance = null;

        if (mode == AlivcLiveMode.AlivcLiveInteractiveMode) {
            playerInstance = ReflectUtil.reflectInit(INTERACTIVE_PUSHER_IMPL_CLASS, null, null);
        } else {
            playerInstance = ReflectUtil.reflectInit(BASIC_PUSHER_IMPL_CLASS, null, null);
        }

        if (playerInstance == null) {
            throw new RuntimeException("init live pusher error! now not support mode: " + mode);
        }

        mImpl = (ILivePusher) playerInstance;
    }

    @Override
    public void destroy() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.destroy();
    }

    @Override
    public void setLivePusherReference(AlivcLivePusher livePusher) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePusherReference(livePusher);
    }

    @Override
    public void startPreview(SurfaceView surfaceView) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startPreview(surfaceView);
    }

    @Override
    public void startPreviewAsync(SurfaceView surfaceView) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startPreviewAsync(surfaceView);
    }

    @Override
    public void startPreview(Context context, FrameLayout frameLayout, boolean isAnchor) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startPreview(context, frameLayout, isAnchor);
    }

    @Override
    public void stopPreview() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.stopPreview();
    }

    @Override
    public void startPush(String url) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startPush(AlivcLiveURLTools.trimUrl(url));
    }

    @Override
    public void startPushAsync(String url) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startPushAsync(AlivcLiveURLTools.trimUrl(url));
    }

    @Override
    public void restartPush() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.restartPush();
    }

    @Override
    public void restartPushAsync() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.restartPushAsync();
    }

    @Override
    public void reconnectPushAsync(String url) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.reconnectPushAsync(AlivcLiveURLTools.trimUrl(url));
    }

    @Override
    public void stopPush() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.stopPush();
    }

    @Override
    public void pause() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.pause();
    }

    @Override
    public void resume() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.resume();
    }

    @Override
    public void resumeAsync() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.resumeAsync();
    }

    @Override
    public void switchCamera() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.switchCamera();
    }

    @Override
    public void setAutoFocus(boolean autoFocus) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setAutoFocus(autoFocus);
    }

    @Override
    public void focusCameraAtAdjustedPoint(float x, float y, boolean autoFocus) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.focusCameraAtAdjustedPoint(x, y, autoFocus);
    }

    @Override
    public void setZoom(int zoom) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setZoom(zoom);
    }

    @Override
    public int getMaxZoom() throws IllegalStateException {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.getMaxZoom();
    }

    @Override
    public int getCurrentZoom() throws IllegalStateException {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.getCurrentZoom();
    }

    @Override
    public void setMute(boolean mute) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setMute(mute);
    }

    @Override
    public void setFlash(boolean flash) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setFlash(flash);
    }

    @Override
    public void setPushMirror(boolean mirror) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setPushMirror(mirror);
    }

    @Override
    public void setPreviewMirror(boolean mirror) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setPreviewMirror(mirror);
    }

    @Override
    public void setTargetVideoBitrate(int targetVideoBitrate) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setTargetVideoBitrate(targetVideoBitrate);
    }

    @Override
    public void setMinVideoBitrate(int minVideoBitrate) throws IllegalArgumentException, IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setMinVideoBitrate(minVideoBitrate);
    }

    @Override
    public void refreshPushURLToken(String url) {
        if (mImpl == null) {
            return;
        }
        mImpl.refreshPushURLToken(url);
    }

    @Override
    public boolean isCameraSupportAutoFocus() {
        if (mImpl == null) {
            return false;
        }
        return mImpl.isCameraSupportAutoFocus();
    }

    @Override
    public boolean isCameraSupportFlash() {
        if (mImpl == null) {
            return false;
        }
        return mImpl.isCameraSupportFlash();
    }

    @Override
    public boolean isPushing() throws IllegalStateException {
        if (mImpl == null) {
            return false;
        }
        return mImpl.isPushing();
    }

    @Override
    public boolean isNetworkPushing() throws IllegalStateException {
        if (mImpl == null) {
            return false;
        }
        return mImpl.isNetworkPushing();
    }

    @Override
    public void setCustomDetect(AlivcLivePushCustomDetect customVideoDetect) {
        if (mImpl == null) {
            return;
        }
        mImpl.setCustomDetect(customVideoDetect);
    }

    @Override
    public void setCustomFilter(AlivcLivePushCustomFilter customVideoFilter) {
        if (mImpl == null) {
            return;
        }
        mImpl.setCustomFilter(customVideoFilter);
    }

    @Override
    public void setCustomAudioFilter(AlivcLivePushCustomAudioFilter customAudioFilter) {
        if (mImpl == null) {
            return;
        }
        mImpl.setCustomAudioFilter(customAudioFilter);
    }

    @Override
    public AlivcLivePushStats getCurrentStatus() {
        if (mImpl == null) {
            return AlivcLivePushStats.IDLE;
        }
        return mImpl.getCurrentStatus();
    }

    @Override
    public void setLivePushErrorListener(AlivcLivePushErrorListener errorListener) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePushErrorListener(errorListener);
    }

    @Override
    public void setLivePushInfoListener(AlivcLivePushInfoListener infoListener) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePushInfoListener(infoListener);
    }

    @Override
    public void setLivePushNetworkListener(AlivcLivePushNetworkListener networkListener) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePushNetworkListener(networkListener);
    }

    @Override
    public void setLivePushBGMListener(AlivcLivePushBGMListener pushBGMListener) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePushBGMListener(pushBGMListener);
    }

    @Override
    public void setLivePushRenderContextListener(AlivcLivePusherRenderContextListener renderCtxListener) {
        if (mImpl == null) {
            return;
        }
        mImpl.setLivePushRenderContextListener(renderCtxListener);
    }

    @Override
    public AlivcLivePushStatsInfo getLivePushStatsInfo() throws IllegalStateException {
        if (mImpl == null) {
            return null;
        }
        return mImpl.getLivePushStatsInfo();
    }

    @Override
    public String getPushUrl() {
        if (mImpl == null) {
            return "";
        }
        return mImpl.getPushUrl();
    }

    @Override
    public void setPreviewOrientation(AlivcPreviewOrientationEnum orientation) {
        if (mImpl == null) {
            return;
        }
        mImpl.setPreviewOrientation(orientation);
    }

    @Override
    public int setAudioEffectVoiceChangeMode(AlivcLivePushAudioEffectVoiceChangeMode mode) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.setAudioEffectVoiceChangeMode(mode);
    }

    @Override
    public int setAudioEffectReverbMode(AlivcLivePushAudioEffectReverbMode mode) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.setAudioEffectReverbMode(mode);
    }

    @Override
    public void startBGMAsync(String path) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.startBGMAsync(path);
    }

    @Override
    public void stopBGMAsync() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.stopBGMAsync();
    }

    @Override
    public void pauseBGM() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.pauseBGM();
    }

    @Override
    public void resumeBGM() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.resumeBGM();
    }

    @Override
    public void setBGMLoop(boolean isLoop) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setBGMLoop(isLoop);
    }

    @Override
    public void setBGMEarsBack(boolean isOpen) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setBGMEarsBack(isOpen);
    }

    @Override
    public void setBGMVolume(int volume) throws IllegalStateException, IllegalArgumentException {
        if (mImpl == null) {
            return;
        }
        mImpl.setBGMVolume(volume);
    }

    @Override
    public void setCaptureVolume(int volume) throws IllegalStateException, IllegalArgumentException {
        if (mImpl == null) {
            return;
        }
        mImpl.setCaptureVolume(volume);
    }

    @Override
    public void setAudioDenoise(boolean on) {
        if (mImpl == null) {
            return;
        }
        mImpl.setAudioDenoise(on);
    }

    @Override
    public int startIntelligentDenoise() {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.startIntelligentDenoise();
    }

    @Override
    public int stopIntelligentDenoise() {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.stopIntelligentDenoise();
    }

    @Override
    public void setQualityMode(AlivcQualityModeEnum mode) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setQualityMode(mode);
    }

    @Override
    public void setPreviewMode(AlivcPreviewDisplayMode mode) throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.setPreviewMode(mode);
    }

    @Override
    public void pauseScreenCapture() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.pauseScreenCapture();
    }

    @Override
    public void resumeScreenCapture() throws IllegalStateException {
        if (mImpl == null) {
            return;
        }
        mImpl.resumeScreenCapture();
    }

    @Override
    public AlivcLivePushError getLastError() {
        if (mImpl == null) {
            return AlivcLivePushError.ALIVC_COMMON_RETURN_SUCCESS;
        }
        return mImpl.getLastError();
    }

    @Override
    public void changeResolution(AlivcResolutionEnum resolution) {
        if (mImpl == null) {
            return;
        }
        mImpl.changeResolution(resolution);
    }

    @Override
    public void addWaterMark(String path, float x, float y, float width) {
        if (mImpl == null) {
            return;
        }
        mImpl.addWaterMark(path, x, y, width);
    }

    @Override
    public void setWatermarkVisible(boolean visible) {
        if (mImpl == null) {
            return;
        }
        mImpl.setWatermarkVisible(visible);
    }

    @Override
    public int startCamera(SurfaceView surfaceView) throws IllegalStateException {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.startCamera(surfaceView);
    }

    @Override
    public void stopCamera() {
        if (mImpl == null) {
            return;
        }
        mImpl.stopCamera();
    }

    @Override
    public void setScreenOrientation(int orientation) {
        if (mImpl == null) {
            return;
        }
        mImpl.setScreenOrientation(orientation);
    }

    @Override
    public int startCameraMix(float x, float y, float w, float h) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.startCameraMix(x, y, w, h);
    }

    @Override
    public void stopCameraMix() {
        if (mImpl == null) {
            return;
        }
        mImpl.stopCameraMix();
    }

    @Override
    public void snapshot(int count, int interval, AlivcSnapshotListener listener) {
        if (mImpl == null) {
            return;
        }
        mImpl.snapshot(count, interval, listener);
    }

    @Override
    public void inputStreamVideoPtr(long dataPtr, int width, int height, int stride, int size, long pts, int rotation) {
        if (mImpl == null) {
            return;
        }
        mImpl.inputStreamVideoPtr(dataPtr, width, height, stride, size, pts, rotation);
    }

    @Override
    public void inputStreamVideoData(byte[] data, int width, int height, int stride, int size, long pts, int rotation) {
        if (mImpl == null) {
            return;
        }
        mImpl.inputStreamVideoData(data, width, height, stride, size, pts, rotation);
    }

    @Override
    public void inputStreamAudioPtr(long dataPtr, int size, int sampleRate, int channels, long pts) {
        if (mImpl == null) {
            return;
        }
        mImpl.inputStreamAudioPtr(dataPtr, size, sampleRate, channels, pts);
    }

    @Override
    public void inputStreamAudioData(byte[] data, int size, int sampleRate, int channels, long pts) {
        if (mImpl == null) {
            return;
        }
        mImpl.inputStreamAudioData(data, size, sampleRate, channels, pts);
    }

    @Override
    public int addDynamicsAddons(String path, float x, float y, float w, float h) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.addDynamicsAddons(path, x, y, w, h);
    }

    @Override
    public void removeDynamicsAddons(int id) {
        if (mImpl == null) {
            return;
        }
        mImpl.removeDynamicsAddons(id);
    }

    @Override
    public void setExposure(int exposure) {
        if (mImpl == null) {
            return;
        }
        mImpl.setExposure(exposure);
    }

    @Override
    public int getCurrentExposure() {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.getCurrentExposure();
    }

    @Override
    public int getSupportedMinExposure() {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.getSupportedMinExposure();
    }

    @Override
    public int getSupportedMaxExposure() {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.getSupportedMaxExposure();
    }

    @Override
    public void sendMessage(String info, int repeat, int delay, boolean isKeyFrame) {
        if (mImpl == null) {
            return;
        }
        mImpl.sendMessage(info, repeat, delay, isKeyFrame);
    }

    @Override
    public int setLiveMixTranscodingConfig(AlivcLiveTranscodingConfig config) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.setLiveMixTranscodingConfig(config);
    }

    @Override
    public int muteLocalCamera(boolean mute) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.muteLocalCamera(mute);
    }

    @Override
    public int enableSpeakerphone(boolean enable) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.enableSpeakerphone(enable);
    }

    @Override
    public boolean isSpeakerphoneOn() {
        if (mImpl == null) {
            return false;
        }
        return mImpl.isSpeakerphoneOn();
    }

    @Override
    public int enableAudioVolumeIndication(int interval, int smooth, int reportVad) {
        if (mImpl == null) {
            return -1;
        }
        return mImpl.enableAudioVolumeIndication(interval, smooth, reportVad);
    }

    @Override
    public String getLiveTraceId() {
        if (mImpl == null) {
            return "";
        }
        return mImpl.getLiveTraceId();
    }
}
 // end of live_pusher