RtmpFromFile not playing video when url is a firebase storage video

[rahulmitra-ncompass]

Screen showing black when trying to stream a url fron firebase storage

[pedroSG94]

Hello,

I don't know the reason but that class use the MediaExtractor class to do it. Maybe that class no support the way firebease share videos.
https://developer.android.com/reference/android/media/MediaExtractor#setDataSource(java.lang.String)

Try to reproduce the video using VLC for example and make sure that you don't need auth or similar.

[rahulmitra-ncompass]

we are already using setDataSource

[pedroSG94]

In that case maybe that url is not supported by media extractor.
If you have an url example I could try investigate about it

[rahulmitra-ncompass]

https://firebasestorage.googleapis.com/v0/b/yoimo-live-staging.appspot.com/o/uploads%2Fchannels%2FL3uoqJhZM347PftzZgCX%2FholdingVideos%2FSports%20Hype%20Video%2030%20Sec.mp4?alt=media&token=3aae76e7-a597-47a6-96e9-2dcda0a01e58

here is a sample URL

[pedroSG94]

Hello,

That url is working for me. I'm using it in the app example like this:

  private fun prepare(): Boolean {
    filePath = Uri.parse("https://firebasestorage.googleapis.com/v0/b/yoimo-live-staging.appspot.com/o/uploads%2Fchannels%2FL3uoqJhZM347PftzZgCX%2FholdingVideos%2FSports%20Hype%20Video%2030%20Sec.mp4?alt=media&token=3aae76e7-a597-47a6-96e9-2dcda0a01e58")
    if (filePath == null) return false
    var result = genericFromFile.prepareVideo(applicationContext, filePath)
    result = result or genericFromFile.prepareAudio(applicationContext, filePath)
    return result
  }

[rahulmitra-ncompass]

This is the code we are using to display video

public void setVideoToStream(String videoPath) {
        try {
            File file = new File(videoPath);
            if (!file.exists()) {
                Toast.makeText(context, "Video file not found!", Toast.LENGTH_SHORT).show();
                return;
            }
            Log.d("LiveStream", "setVideoToStream: " + videoPath);

            // Stop any ongoing streams
            if (rtmpCamera2 != null && rtmpCamera2.isStreaming()) {
                rtmpCamera2.stopStream();
                rtmpCamera2.getGlInterface().clearFilters();
            }
            if (rtmpFromFile != null && rtmpFromFile.isStreaming()) {
                rtmpFromFile.stopStream();
            }

            // Use MediaMetadataRetriever to detect audio properties
            MediaMetadataRetriever retriever = new MediaMetadataRetriever();
            retriever.setDataSource(videoPath);

            String sampleRateStr = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_SAMPLERATE);
            String channelStr = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_NUM_TRACKS); // sometimes not reliable
            String mime = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_MIMETYPE);

            int sampleRate = (sampleRateStr != null) ? Integer.parseInt(sampleRateStr) : 44100;
            boolean isStereo = (channelStr != null && Integer.parseInt(channelStr) > 1);

            Log.d("LiveStream", "Audio properties → SampleRate: " + sampleRate + " Stereo: " + isStereo + " Mime: " + mime);

            // Decoder callbacks
            VideoDecoderInterface videoDecoder = () -> Log.i("VideoDecoder", "Video decoding finished");
            AudioDecoderInterface audioDecoder = () -> Log.i("AudioDecoder", "Audio decoding finished");

            rtmpFromFile = new RtmpFromFile(surfaceView, LiveStreamActivity.this, videoDecoder, audioDecoder);
            rtmpFromFile.setLoopMode(isStreamLooped);

            Uri videoUri = Uri.fromFile(file);


            // Prepare video + audio (with auto-detected params)
            if (rtmpFromFile.prepareVideo(getApplicationContext(), videoUri) &&
                    rtmpFromFile.prepareAudio(getApplicationContext(), videoUri)) {

                if (!rtmpFromFile.isAudioDeviceEnabled()) {
                    rtmpFromFile.playAudioDevice();
                }

                isHoldingVideo = true;
                scoreboardBakingFunctionality(false);
                changeRecordButtonUI(true);

                rtmpFromFile.startStream(rtmpUrl);
                Log.d("LiveStream", "Streaming started with sampleRate=" + sampleRate + " stereo=" + isStereo);
            } else {
                Toast.makeText(context, "Failed to prepare video/audio!", Toast.LENGTH_SHORT).show();
            }

        } catch (Exception e) {
            Toast.makeText(context, "Error: " + e.toString(), Toast.LENGTH_LONG).show();
            Log.e("LiveStream", "setVideoToStream error", e);
        }
    }

[pedroSG94]

Hello,

Since the url is not a local file you can't use that code. Try this (basically remove all reference to File class and MediaMetadataRetriever that maybe don't support https files, you can check it yourself):

  public void setVideoToStream(String videoPath) {
    try {
      //it is not a local file, remove it
//      File file = new File(videoPath);
//      if (!file.exists()) {
//        Toast.makeText(context, "Video file not found!", Toast.LENGTH_SHORT).show();
//        return;
//      }
      Log.d("LiveStream", "setVideoToStream: " + videoPath);

      // Stop any ongoing streams
      if (rtmpCamera2 != null && rtmpCamera2.isStreaming()) {
        rtmpCamera2.stopStream();
        rtmpCamera2.getGlInterface().clearFilters();
      }
      if (rtmpFromFile != null && rtmpFromFile.isStreaming()) {
        rtmpFromFile.stopStream();
      }

      // Use MediaMetadataRetriever to detect audio properties
      //remove because maybe you can't extract metadata from a remote file, test it and discard if no possible
//      MediaMetadataRetriever retriever = new MediaMetadataRetriever();
//      retriever.setDataSource(videoPath);
//
//      String sampleRateStr = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_SAMPLERATE);
//      String channelStr = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_NUM_TRACKS); // sometimes not reliable
//      String mime = retriever.extractMetadata(MediaMetadataRetriever.METADATA_KEY_MIMETYPE);
//
//      int sampleRate = (sampleRateStr != null) ? Integer.parseInt(sampleRateStr) : 44100;
//      boolean isStereo = (channelStr != null && Integer.parseInt(channelStr) > 1);

//      Log.d("LiveStream", "Audio properties → SampleRate: " + sampleRate + " Stereo: " + isStereo + " Mime: " + mime);

      // Decoder callbacks
      VideoDecoderInterface videoDecoder = () -> Log.i("VideoDecoder", "Video decoding finished");
      AudioDecoderInterface audioDecoder = () -> Log.i("AudioDecoder", "Audio decoding finished");

      rtmpFromFile = new RtmpFromFile(surfaceView, LiveStreamActivity.this, videoDecoder, audioDecoder);
      rtmpFromFile.setLoopMode(isStreamLooped);

      Uri videoUri = Uri.parse(videoPath);


      // Prepare video + audio (with auto-detected params)
      if (rtmpFromFile.prepareVideo(getApplicationContext(), videoUri) &&
              rtmpFromFile.prepareAudio(getApplicationContext(), videoUri)) {

        if (!rtmpFromFile.isAudioDeviceEnabled()) {
          rtmpFromFile.playAudioDevice();
        }

        isHoldingVideo = true;
        scoreboardBakingFunctionality(false);
        changeRecordButtonUI(true);

        rtmpFromFile.startStream(rtmpUrl);
//        Log.d("LiveStream", "Streaming started with sampleRate=" + sampleRate + " stereo=" + isStereo);
      } else {
        Toast.makeText(context, "Failed to prepare video/audio!", Toast.LENGTH_SHORT).show();
      }

    } catch (Exception e) {
      Toast.makeText(context, "Error: " + e.toString(), Toast.LENGTH_LONG).show();
      Log.e("LiveStream", "setVideoToStream error", e);
    }
  }

[rahulmitra-ncompass]

So, the thing is we are actually downloading the video first then streaming it from the downloaded file (this is actually our requirement). So this is the code for downloading the video

private void downloadVideo(String videoUrl) {
        try {
            // Use internal storage instead of external to avoid permission issues
            File outputDir = new File(getFilesDir(), "videos");
            if (!outputDir.exists()) {
                outputDir.mkdirs();
            }

            File outputFile = new File(outputDir, "temp_holding_video.mp4");

            // Delete existing file if present
            if (outputFile.exists()) {
                outputFile.delete();
            }
            outputFile.createNewFile();

            HttpURLConnection connection = (HttpURLConnection) new URL(videoUrl).openConnection();
            connection.setConnectTimeout(10000); // 10 seconds
            connection.setReadTimeout(30000);    // 30 seconds
            connection.setRequestMethod("GET");
            connection.setDoInput(true);

            int responseCode = connection.getResponseCode();
            if (responseCode != HttpURLConnection.HTTP_OK) {
                throw new IOException("HTTP error code: " + responseCode);
            }

            try (InputStream input = connection.getInputStream();
                 FileOutputStream output = new FileOutputStream(outputFile)) {

                byte[] buffer = new byte[8192]; // Increased buffer size
                int len;
                long totalBytes = 0;

                while ((len = input.read(buffer)) != -1) {
                    output.write(buffer, 0, len);
                    totalBytes += len;
                }

                Log.d("VideoDownload", "Downloaded " + totalBytes + " bytes");
            } finally {
                connection.disconnect();
            }

            // Verify file was downloaded successfully
            if (!outputFile.exists() || outputFile.length() == 0) {
                throw new IOException("File download failed or file is empty");
            }

            runOnUiThread(() -> {
                try {
                    rtmpCamera2.startPreview();
                    setVideoToStream(outputFile.getAbsolutePath());
                } catch (Exception e) {
                    Log.e("VideoStream", "Error setting video to stream", e);
                    Toast.makeText(context, "Error starting video stream: " + e.getMessage(),
                            Toast.LENGTH_LONG).show();
                }
            });

        } catch (Exception e) {
            Log.e("VideoDownload", "Download error", e);
            runOnUiThread(() ->
                    Toast.makeText(context, "Download error: " + e.getMessage(),
                            Toast.LENGTH_LONG).show()
            );
        }
    }

There are some points to note here:-

1. This flow is working for a public url perfectly the issue is only arising for firebase storage urls.
2. Below is another flow where we are downloading and playing the video (in exoplayer), but here the firebase storage urls as well as pulic urls are working properly

private void downloadAndCacheVideo(String videoUrl) {
        try {
            File outputDir = new File(context.getFilesDir(), "holding_videos");
            if (!outputDir.exists()) {
                outputDir.mkdirs();
            }

            // Hash filename from URL to avoid duplicates
            String fileName = String.valueOf(videoUrl.hashCode()) + ".mp4";
            File outputFile = new File(outputDir, fileName);

            // Skip if already downloaded
            if (outputFile.exists() && outputFile.length() > 0) {
                localVideoMap.put(videoUrl, outputFile.getAbsolutePath());
                return;
            }

            HttpURLConnection connection = (HttpURLConnection) new URL(videoUrl).openConnection();
            connection.setConnectTimeout(10000);
            connection.setReadTimeout(30000);
            connection.setRequestMethod("GET");
            connection.setDoInput(true);

            int responseCode = connection.getResponseCode();
            if (responseCode != HttpURLConnection.HTTP_OK) {
                throw new IOException("HTTP error: " + responseCode);
            }

            try (InputStream input = connection.getInputStream();
                 FileOutputStream output = new FileOutputStream(outputFile)) {
                byte[] buffer = new byte[8192];
                int len;
                while ((len = input.read(buffer)) != -1) {
                    output.write(buffer, 0, len);
                }
            } finally {
                connection.disconnect();
            }

            // store mapping
            localVideoMap.put(videoUrl, outputFile.getAbsolutePath());
            Log.d("VideoCache", "Cached " + videoUrl + " -> " + outputFile.getAbsolutePath());

        } catch (Exception e) {
            Log.e("VideoCache", "Error caching video: " + videoUrl, e);
        }
    }

public void playFullVideoAt(int position, boolean loop) {
        if (recyclerView == null) return;
        if (position < 0 || position >= imageBinaries.size()) return;

        Pair<Pair<Drawable, String>, String> item = imageBinaries.get(position);
        if (!"video".equals(item.second)) return;

        ViewHolder holder = (ViewHolder) recyclerView.findViewHolderForAdapterPosition(position);
        if (holder == null) return;

        String remoteUrl = item.first.second;
        String localPath = localVideoMap.get(remoteUrl);
        if (localPath == null) return;

        // Stop preview if running
        if (currentlyPlayingVideo != null) {
            ExoPlayer prevPlayer = (ExoPlayer) currentlyPlayingVideo.getPlayer();
            if (prevPlayer != null) {
                prevPlayer.pause();
            }
            currentlyPlayingVideo.setVisibility(View.GONE);
        }

        currentlyPlayingVideo = holder.videoView;

        // Prepare full playback
        holder.holdingLabel.setVisibility(View.GONE);
        holder.imageView.setVisibility(View.GONE);
        holder.videoView.setVisibility(View.VISIBLE);

        if (holder.isPlayerReady && !holder.isPreparingPlayer) {
            holder.player.setRepeatMode(loop ? Player.REPEAT_MODE_ONE : Player.REPEAT_MODE_OFF);
            holder.player.seekTo(0);
            holder.player.play();
        }

        // Cancel preview stop callbacks
        if (currentRunnable != null) {
            videoHandler.removeCallbacks(currentRunnable);
            currentRunnable = null;
        }
    }

[rahulmitra-ncompass]

Can you please help with this issue ?

[pedroSG94]

Hello,

I tested this and it is working for me. You only need modify a bit the FromFileActivity class.
In the app example I did this method (basically a copy paste of your download method):

fun downloadVideo(url: String): String {
    // Use internal storage instead of external to avoid permission issues
    val outputDir = File(getFilesDir(), "videos")
    if (!outputDir.exists()) {
      outputDir.mkdirs()
    }

    val outputFile = File(outputDir, "temp_holding_video.mp4")


    // Delete existing file if present
    if (outputFile.exists()) {
      outputFile.delete()
    }
    outputFile.createNewFile()

    val connection = URL(url).openConnection() as HttpURLConnection
    connection.setConnectTimeout(10000) // 10 seconds
    connection.setReadTimeout(30000) // 30 seconds
    connection.setRequestMethod("GET")
    connection.setDoInput(true)

    val responseCode = connection.getResponseCode()
    if (responseCode != HttpURLConnection.HTTP_OK) {
      throw IOException("HTTP error code: " + responseCode)
    }

    try {
      connection.getInputStream().use { input ->
        FileOutputStream(outputFile).use { output ->
          val buffer = ByteArray(8192) // Increased buffer size
          var len: Int
          var totalBytes: Long = 0

          while ((input.read(buffer).also { len = it }) != -1) {
            output.write(buffer, 0, len)
            totalBytes += len.toLong()
          }
          Log.d("VideoDownload", "Downloaded " + totalBytes + " bytes")
        }
      }
    } finally {
      connection.disconnect()
    }


    // Verify file was downloaded successfully
    if (!outputFile.exists() || outputFile.length() == 0L) {
      throw IOException("File download failed or file is empty")
    }
    return outputFile.absolutePath
  }

Replace the logic of select file:

    bSelectFile.setOnClickListener {
      Thread {
        filePath = Uri.fromFile(File(downloadVideo("https://firebasestorage.googleapis.com/v0/b/yoimo-live-staging.appspot.com/o/uploads%2Fchannels%2FL3uoqJhZM347PftzZgCX%2FholdingVideos%2FSports%20Hype%20Video%2030%20Sec.mp4?alt=media&token=3aae76e7-a597-47a6-96e9-2dcda0a01e58")))
      }.start()
    }

All ready to test:

• Launch the app example in from file example.
• Press select file button (right-bottom button).
• Wait until the log of downloaded file show (Downloaded xxx bytes)
• Press start stream or record button to test if all is working fine.

[rahulmitra-ncompass]

Issue is fixed now.
Thank you

[pedroSG94]

Closed as solved