refactor base abstract methods

pedroSG94 · Oct 12, 2023 · d5576da · d5576da
1 parent 1a19e74
commit d5576da
Show file tree

Hide file tree

Showing 40 changed files with 651 additions and 2,134 deletions.
diff --git a/app/src/main/java/com/pedro/streamer/customexample/RtmpActivity.java b/app/src/main/java/com/pedro/streamer/customexample/RtmpActivity.java
@@ -228,7 +228,7 @@ public void onClick(View v) {
         String user = etWowzaUser.getText().toString();
         String password = etWowzaPassword.getText().toString();
         if (!user.isEmpty() && !password.isEmpty()) {
-          rtmpCamera1.setAuthorization(user, password);
+          rtmpCamera1.getStreamClient().setAuthorization(user, password);
         }
         if (rtmpCamera1.isRecording() || prepareEncoders()) {
           rtmpCamera1.startStream(etUrl.getText().toString());

diff --git a/app/src/main/java/com/pedro/streamer/customexample/RtspActivity.java b/app/src/main/java/com/pedro/streamer/customexample/RtspActivity.java
@@ -229,14 +229,14 @@ public void onClick(View v) {
       if (!rtspCamera1.isStreaming()) {
         bStartStop.setText(getResources().getString(R.string.stop_button));
         if (rbTcp.isChecked()) {
-          rtspCamera1.setProtocol(Protocol.TCP);
+          rtspCamera1.getStreamClient().setProtocol(Protocol.TCP);
         } else {
-          rtspCamera1.setProtocol(Protocol.UDP);
+          rtspCamera1.getStreamClient().setProtocol(Protocol.UDP);
         }
         String user = etWowzaUser.getText().toString();
         String password = etWowzaPassword.getText().toString();
         if (!user.isEmpty() && !password.isEmpty()) {
-          rtspCamera1.setAuthorization(user, password);
+          rtspCamera1.getStreamClient().setAuthorization(user, password);
         }
         if (rtspCamera1.isRecording() || prepareEncoders()) {
           rtspCamera1.startStream(etUrl.getText().toString());

diff --git a/app/src/main/java/com/pedro/streamer/defaultexample/ExampleRtmpActivity.java b/app/src/main/java/com/pedro/streamer/defaultexample/ExampleRtmpActivity.java
@@ -70,7 +70,7 @@ protected void onCreate(Bundle savedInstanceState) {
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_rtmp);
     rtmpCamera1 = new RtmpCamera1(surfaceView, this);
-    rtmpCamera1.setReTries(10);
+    rtmpCamera1.getStreamClient().setReTries(10);
     surfaceView.getHolder().addCallback(this);
   }
 

diff --git a/app/src/main/java/com/pedro/streamer/defaultexample/ExampleRtspActivity.java b/app/src/main/java/com/pedro/streamer/defaultexample/ExampleRtspActivity.java
@@ -72,7 +72,7 @@ protected void onCreate(Bundle savedInstanceState) {
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_rtsp);
     rtspCamera1 = new RtspCamera1(surfaceView, this);
-    rtspCamera1.setReTries(10);
+    rtspCamera1.getStreamClient().setReTries(10);
     surfaceView.getHolder().addCallback(this);
   }
 

diff --git a/app/src/main/java/com/pedro/streamer/defaultexample/ExampleSrtActivity.java b/app/src/main/java/com/pedro/streamer/defaultexample/ExampleSrtActivity.java
@@ -72,7 +72,7 @@ protected void onCreate(Bundle savedInstanceState) {
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_srt);
     srtCamera1 = new SrtCamera1(surfaceView, this);
-    srtCamera1.setReTries(10);
+    srtCamera1.getStreamClient().setReTries(10);
     surfaceView.getHolder().addCallback(this);
   }
 

diff --git a/app/src/main/java/com/pedro/streamer/surfacemodeexample/SurfaceModeRtmpActivity.java b/app/src/main/java/com/pedro/streamer/surfacemodeexample/SurfaceModeRtmpActivity.java
@@ -72,7 +72,7 @@ protected void onCreate(Bundle savedInstanceState) {
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_rtmp);
     rtmpCamera2 = new RtmpCamera2(surfaceView, this);
-    rtmpCamera2.setReTries(10);
+    rtmpCamera2.getStreamClient().setReTries(10);
     surfaceView.getHolder().addCallback(this);
   }
 

diff --git a/app/src/main/java/com/pedro/streamer/surfacemodeexample/SurfaceModeRtspActivity.java b/app/src/main/java/com/pedro/streamer/surfacemodeexample/SurfaceModeRtspActivity.java
@@ -75,7 +75,7 @@ protected void onCreate(Bundle savedInstanceState) {
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_rtsp);
     rtspCamera2 = new RtspCamera2(surfaceView, this);
-    rtspCamera2.setReTries(10);
+    rtspCamera2.getStreamClient().setReTries(10);
     surfaceView.getHolder().addCallback(this);
   }
 

diff --git a/library/src/main/java/com/pedro/library/base/Camera1Base.java b/library/src/main/java/com/pedro/library/base/Camera1Base.java
@@ -261,14 +261,6 @@ public boolean isAutoFocusEnabled() {
     return cameraManager.isAutoFocusEnabled();
   }
 
-  /**
-   * Basic auth developed to work with Wowza. No tested with other server
-   *
-   * @param user auth.
-   * @param password auth.
-   */
-  public abstract void setAuthorization(String user, String password);
-
   /**
    * Call this method before use @startStream. If not you will do a stream without video. NOTE:
    * Rotation with encoder is silence ignored in some devices.
@@ -780,53 +772,6 @@ public void stopStream() {
     }
   }
 
-  /**
-   * Retries to connect with the given delay. You can pass an optional backupUrl
-   * if you'd like to connect to your backup server instead of the original one.
-   * Given backupUrl replaces the original one.
-   */
-  public boolean reTry(long delay, String reason, @Nullable String backupUrl) {
-    boolean result = shouldRetry(reason);
-    if (result) {
-      requestKeyFrame();
-      reConnect(delay, backupUrl);
-    }
-    return result;
-  }
-
-  public boolean reTry(long delay, String reason) {
-    return reTry(delay, reason, null);
-  }
-
-  protected abstract boolean shouldRetry(String reason);
-
-  public abstract void setReTries(int reTries);
-
-  protected abstract void reConnect(long delay, @Nullable String backupUrl);
-
-  //cache control
-  public abstract boolean hasCongestion();
-
-  public abstract void resizeCache(int newSize) throws RuntimeException;
-
-  public abstract int getCacheSize();
-
-  public abstract long getSentAudioFrames();
-
-  public abstract long getSentVideoFrames();
-
-  public abstract long getDroppedAudioFrames();
-
-  public abstract long getDroppedVideoFrames();
-
-  public abstract void resetSentAudioFrames();
-
-  public abstract void resetSentVideoFrames();
-
-  public abstract void resetDroppedAudioFrames();
-
-  public abstract void resetDroppedVideoFrames();
-
   /**
    * Get supported preview resolutions of back camera in px.
    *
@@ -1017,10 +962,6 @@ public void setRecordController(BaseRecordController recordController) {
     if (!isRecording()) this.recordController = recordController;
   }
 
-  public abstract void setLogs(boolean enable);
-
-  public abstract void setCheckServerAlive(boolean enable);
-
   private final GetCameraData getCameraData = frame -> {
     videoEncoder.inputYUVData(frame);
   };

diff --git a/library/src/main/java/com/pedro/library/base/Camera2Base.java b/library/src/main/java/com/pedro/library/base/Camera2Base.java
@@ -301,14 +301,6 @@ public void setFocusDistance(float distance) {
     cameraManager.setFocusDistance(distance);
   }
 
-  /**
-   * Basic auth developed to work with Wowza. No tested with other server
-   *
-   * @param user auth.
-   * @param password auth.
-   */
-  public abstract void setAuthorization(String user, String password);
-
   /**
    * Call this method before use @startStream. If not you will do a stream without video.
    *
@@ -725,53 +717,6 @@ public void stopStream() {
     }
   }
 
-  /**
-   * Retries to connect with the given delay. You can pass an optional backupUrl
-   * if you'd like to connect to your backup server instead of the original one.
-   * Given backupUrl replaces the original one.
-   */
-  public boolean reTry(long delay, String reason, @Nullable String backupUrl) {
-    boolean result = shouldRetry(reason);
-    if (result) {
-      requestKeyFrame();
-      reConnect(delay, backupUrl);
-    }
-    return result;
-  }
-
-  public boolean reTry(long delay, String reason) {
-    return reTry(delay, reason, null);
-  }
-
-  protected abstract boolean shouldRetry(String reason);
-
-  public abstract void setReTries(int reTries);
-
-  protected abstract void reConnect(long delay, @Nullable String backupUrl);
-
-  //cache control
-  public abstract boolean hasCongestion();
-
-  public abstract void resizeCache(int newSize) throws RuntimeException;
-
-  public abstract int getCacheSize();
-
-  public abstract long getSentAudioFrames();
-
-  public abstract long getSentVideoFrames();
-
-  public abstract long getDroppedAudioFrames();
-
-  public abstract long getDroppedVideoFrames();
-
-  public abstract void resetSentAudioFrames();
-
-  public abstract void resetSentVideoFrames();
-
-  public abstract void resetDroppedAudioFrames();
-
-  public abstract void resetDroppedVideoFrames();
-
   /**
    * Get supported preview resolutions of back camera in px.
    *
@@ -1072,10 +1017,6 @@ public void setRecordController(BaseRecordController recordController) {
     if (!isRecording()) this.recordController = recordController;
   }
 
-  public abstract void setLogs(boolean enable);
-
-  public abstract void setCheckServerAlive(boolean enable);
-
   private final GetMicrophoneData getMicrophoneData = frame -> {
     audioEncoder.inputPCMData(frame);
   };

diff --git a/library/src/main/java/com/pedro/library/base/DisplayBase.java b/library/src/main/java/com/pedro/library/base/DisplayBase.java
@@ -147,14 +147,6 @@ public void setFpsListener(FpsListener.Callback callback) {
     fpsListener.setCallback(callback);
   }
 
-  /**
-   * Basic auth developed to work with Wowza. No tested with other server
-   *
-   * @param user auth.
-   * @param password auth.
-   */
-  public abstract void setAuthorization(String user, String password);
-
   /**
    * Call this method before use @startStream. If not you will do a stream without video.
    *
@@ -458,53 +450,6 @@ public void stopStream() {
     }
   }
 
-  /**
-   * Retries to connect with the given delay. You can pass an optional backupUrl
-   * if you'd like to connect to your backup server instead of the original one.
-   * Given backupUrl replaces the original one.
-   */
-  public boolean reTry(long delay, String reason, @Nullable String backupUrl) {
-    boolean result = shouldRetry(reason);
-    if (result) {
-      requestKeyFrame();
-      reConnect(delay, backupUrl);
-    }
-    return result;
-  }
-
-  public boolean reTry(long delay, String reason) {
-    return reTry(delay, reason, null);
-  }
-
-  protected abstract boolean shouldRetry(String reason);
-
-  public abstract void setReTries(int reTries);
-
-  protected abstract void reConnect(long delay, @Nullable String backupUrl);
-
-  //cache control
-  public abstract boolean hasCongestion();
-
-  public abstract void resizeCache(int newSize) throws RuntimeException;
-
-  public abstract int getCacheSize();
-
-  public abstract long getSentAudioFrames();
-
-  public abstract long getSentVideoFrames();
-
-  public abstract long getDroppedAudioFrames();
-
-  public abstract long getDroppedVideoFrames();
-
-  public abstract void resetSentAudioFrames();
-
-  public abstract void resetSentVideoFrames();
-
-  public abstract void resetDroppedAudioFrames();
-
-  public abstract void resetDroppedVideoFrames();
-
   public GlInterface getGlInterface() {
     if (glInterface != null) {
       return glInterface;
@@ -622,10 +567,6 @@ public void setRecordController(BaseRecordController recordController) {
     if (!isRecording()) this.recordController = recordController;
   }
 
-  public abstract void setLogs(boolean enable);
-
-  public abstract void setCheckServerAlive(boolean enable);
-
   private final GetMicrophoneData getMicrophoneData = frame -> {
     audioEncoder.inputPCMData(frame);
   };

diff --git a/library/src/main/java/com/pedro/library/base/FromFileBase.java b/library/src/main/java/com/pedro/library/base/FromFileBase.java
@@ -128,14 +128,6 @@ public void setFpsListener(FpsListener.Callback callback) {
     fpsListener.setCallback(callback);
   }
 
-  /**
-   * Basic auth developed to work with Wowza. No tested with other server
-   *
-   * @param user auth.
-   * @param password auth.
-   */
-  public abstract void setAuthorization(String user, String password);
-
   /**
    * @param filePath to video MP4 file.
    * @param bitRate H264 in bps.
@@ -421,53 +413,6 @@ public void requestKeyFrame() {
 
   protected abstract void stopStreamRtp();
 
-  /**
-   * Retries to connect with the given delay. You can pass an optional backupUrl
-   * if you'd like to connect to your backup server instead of the original one.
-   * Given backupUrl replaces the original one.
-   */
-  public boolean reTry(long delay, String reason, @Nullable String backupUrl) {
-    boolean result = shouldRetry(reason);
-    if (result) {
-      requestKeyFrame();
-      reConnect(delay, backupUrl);
-    }
-    return result;
-  }
-
-  public boolean reTry(long delay, String reason) {
-    return reTry(delay, reason, null);
-  }
-
-  protected abstract boolean shouldRetry(String reason);
-
-  public abstract void setReTries(int reTries);
-
-  protected abstract void reConnect(long delay, @Nullable String backupUrl);
-
-  //cache control
-  public abstract boolean hasCongestion();
-
-  public abstract void resizeCache(int newSize) throws RuntimeException;
-
-  public abstract int getCacheSize();
-
-  public abstract long getSentAudioFrames();
-
-  public abstract long getSentVideoFrames();
-
-  public abstract long getDroppedAudioFrames();
-
-  public abstract long getDroppedVideoFrames();
-
-  public abstract void resetSentAudioFrames();
-
-  public abstract void resetSentVideoFrames();
-
-  public abstract void resetDroppedAudioFrames();
-
-  public abstract void resetDroppedVideoFrames();
-
   /**
    * Stop stream started with @startStream.
    */
@@ -632,10 +577,6 @@ public void setRecordController(BaseRecordController recordController) {
     if (!isRecording()) this.recordController = recordController;
   }
 
-  public abstract void setLogs(boolean enable);
-
-  public abstract void setCheckServerAlive(boolean enable);
-
   private final GetMicrophoneData getMicrophoneData = frame -> {
     if (audioTrackPlayer != null) {
       audioTrackPlayer.write(frame.getBuffer(), frame.getOffset(), frame.getSize());