Icecast and Shoutcast metadata detect [Android]

.gitignore

@@ -52,3 +52,9 @@ xcuserdata/
 *.dSYM
 example/ios/Pods
 /ios/RNTrackPlayer.xcodeproj/project.xcworkspace/xcshareddata/IDEWorkspaceChecks.plist
+
+
+## Visual Code Project
+*.settings
+*.classpath
+*.project

android/build.gradle

@@ -12,14 +12,15 @@ buildscript {
 
 apply plugin: 'com.android.library'
 
-boolean dash = false, hls = false, smoothstreaming = false
+boolean dash = false, hls = false, smoothstreaming = false, icy = false
 
 File file = file('../../../track-player.json')
 if(file.exists()) {
     def json = new JsonSlurper().parseText(file.text)
     dash = json.dash ?: dash
     hls = json.hls ?: hls
     smoothstreaming = json.smoothstreaming ?: smoothstreaming
+    icy = json.icy ?: icy
 }
 
 android {
@@ -83,6 +84,13 @@ dependencies {
     } else {
         compileOnly 'com.google.android.exoplayer:exoplayer-smoothstreaming:2.9.2'
     }
+
+    // ExoPlayer Icy Extension
+    if (icy) {
+        implementation 'saschpe.android:exoplayer2-ext-icy:2.1.0'
+    } else {
+        compileOnly 'saschpe.android:exoplayer2-ext-icy:2.1.0'
+    }
 
     // Make sure we're using at least the support library 27.1.1
     implementation 'com.android.support:support-compat:27.1.1'

android/src/main/java/com/guichaguri/trackplayer/module/MusicEvents.java

@@ -35,6 +35,7 @@ public class MusicEvents extends BroadcastReceiver {
     public static final String PLAYBACK_QUEUE_ENDED = "playback-queue-ended";
     public static final String PLAYBACK_ERROR = "playback-error";
     public static final String PLAYBACK_UNBIND = "playback-unbind";
+    public static final String PLAYBACK_METADATA = "playback-metadata-received";
 
     private final ReactContext reactContext;
 

android/src/main/java/com/guichaguri/trackplayer/service/metadata/IcyEvents.java

@@ -0,0 +1,65 @@
+package com.guichaguri.trackplayer.service.metadata;
+
+import android.os.Bundle;
+import com.facebook.react.modules.network.OkHttpClientProvider;
+import com.guichaguri.trackplayer.module.MusicEvents;
+import com.guichaguri.trackplayer.service.MusicService;
+import com.google.android.exoplayer2.upstream.DataSource;
+import saschpe.exoplayer2.ext.icy.IcyHttpDataSource;
+import saschpe.exoplayer2.ext.icy.IcyHttpDataSourceFactory;
+
+import java.util.HashMap;
+
+public class IcyEvents implements IcyHttpDataSource.IcyMetadataListener, IcyHttpDataSource.IcyHeadersListener {
+
+    private final MusicService service;
+    private final DataSource.Factory ds;
+
+    public IcyEvents(MusicService service, String userAgent) {
+        this.service = service;
+
+        this.ds = new IcyHttpDataSourceFactory.Builder(OkHttpClientProvider.getOkHttpClient())
+        .setUserAgent(userAgent)
+        .setIcyMetadataChangeListener(this)
+        .setIcyHeadersListener(this)
+        .build();
+    }
+
+    public DataSource.Factory getIcyDataSource() {
+        return ds;
+    }
+
+    @Override
+    public void onIcyMetaData(IcyHttpDataSource.IcyMetadata metadata) {
+        Bundle bundle = new Bundle();
+        Bundle fullMetadata = new Bundle();
+
+        bundle.putString("type", "icy-metadata");
+        bundle.putString("title", metadata.getStreamTitle());
+        bundle.putString("url", metadata.getStreamUrl());
+
+        HashMap<String, String> data = metadata.getMetadata();
+        for(String key : data.keySet()) {
+            fullMetadata.putString(key, data.get(key));
+        }
+
+        bundle.putBundle("metadata", fullMetadata);
+
+        service.emit(MusicEvents.PLAYBACK_METADATA, bundle);
+    }
+
+    @Override
+    public void onIcyHeaders(IcyHttpDataSource.IcyHeaders headers) {
+        Bundle bundle = new Bundle();
+
+        bundle.putString("type", "icy-headers");
+        bundle.putString("name", headers.getName());
+        bundle.putString("genre", headers.getGenre());
+        bundle.putString("url", headers.getUrl());
+        bundle.putInt("bitrate", headers.getBitRate());
+        bundle.putBoolean("public", headers.isPublic());
+
+        service.emit(MusicEvents.PLAYBACK_METADATA, bundle);
+    }
+
+}

android/src/main/java/com/guichaguri/trackplayer/service/models/Track.java

@@ -7,6 +7,7 @@
 import android.support.v4.media.MediaMetadataCompat;
 import android.support.v4.media.RatingCompat;
 import android.support.v4.media.session.MediaSessionCompat.QueueItem;
+import com.facebook.react.modules.network.OkHttpClientProvider;
 import com.google.android.exoplayer2.source.ExtractorMediaSource;
 import com.google.android.exoplayer2.source.MediaSource;
 import com.google.android.exoplayer2.source.dash.DashMediaSource;
@@ -16,7 +17,10 @@
 import com.google.android.exoplayer2.source.smoothstreaming.SsMediaSource;
 import com.google.android.exoplayer2.upstream.*;
 import com.google.android.exoplayer2.util.Util;
+import com.guichaguri.trackplayer.service.MusicManager;
+import com.guichaguri.trackplayer.service.MusicService;
 import com.guichaguri.trackplayer.service.Utils;
+import com.guichaguri.trackplayer.service.metadata.IcyEvents;
 import com.guichaguri.trackplayer.service.player.LocalPlayback;
 
 import java.io.IOException;
@@ -138,7 +142,7 @@ public QueueItem toQueueItem() {
         return new QueueItem(descr, queueId);
     }
 
-    public MediaSource toMediaSource(Context ctx, LocalPlayback playback) {
+    public MediaSource toMediaSource(MusicService ctx, LocalPlayback playback) {
         // Updates the user agent if not set
         if(userAgent == null || !userAgent.isEmpty())
             userAgent = Util.getUserAgent(ctx, "react-native-track-player");
@@ -166,6 +170,15 @@ public DataSource createDataSource() {
             // Creates a local source factory
             ds = new DefaultDataSourceFactory(ctx, userAgent);
 
+        } else if(type == TrackType.ICY) {
+
+            // Creates a data source that intercepts icy metadata
+            IcyEvents listener = new IcyEvents(ctx, userAgent);
+
+            ds = new DefaultDataSourceFactory(ctx, null, listener.getIcyDataSource());
+
+            ds = playback.enableCaching(ds);
+
         } else {
 
             // Creates a default http source factory, enabling cross protocol redirects

android/src/main/java/com/guichaguri/trackplayer/service/models/TrackType.java

@@ -23,7 +23,12 @@ public enum TrackType {
     /**
      * The SmoothStreaming media type for adaptive streams. Should be used with SmoothStreaming manifests
      */
-    SMOOTH_STREAMING("smoothstreaming");
+    SMOOTH_STREAMING("smoothstreaming"),
+
+    /**
+     * The Icy media type. Should be used for Icecast/Shoutcast streams
+     */
+    ICY("icy");
 
 
     public final String name;

android/src/main/java/com/guichaguri/trackplayer/service/player/ExoPlayback.java

@@ -14,8 +14,10 @@
 import com.google.android.exoplayer2.source.TrackGroupArray;
 import com.google.android.exoplayer2.trackselection.TrackSelectionArray;
 import com.guichaguri.trackplayer.service.MusicManager;
+import com.guichaguri.trackplayer.service.MusicService;
 import com.guichaguri.trackplayer.service.Utils;
 import com.guichaguri.trackplayer.service.models.Track;
+import saschpe.exoplayer2.ext.icy.IcyHttpDataSource.IcyMetadataListener;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
@@ -26,7 +28,7 @@
  */
 public abstract class ExoPlayback<T extends Player> implements EventListener {
 
-    protected final Context context;
+    protected final MusicService context;
     protected final MusicManager manager;
     protected final T player;
 
@@ -37,7 +39,7 @@ public abstract class ExoPlayback<T extends Player> implements EventListener {
     protected long lastKnownPosition = C.POSITION_UNSET;
     protected int previousState = PlaybackStateCompat.STATE_NONE;
 
-    public ExoPlayback(Context context, MusicManager manager, T player) {
+    public ExoPlayback(MusicService context, MusicManager manager, T player) {
         this.context = context;
         this.manager = manager;
         this.player = player;

android/src/main/java/com/guichaguri/trackplayer/service/player/LocalPlayback.java

@@ -1,6 +1,5 @@
 package com.guichaguri.trackplayer.service.player;
 
-import android.content.Context;
 import android.util.Log;
 import com.facebook.react.bridge.Promise;
 import com.google.android.exoplayer2.C;
@@ -15,8 +14,10 @@
 import com.google.android.exoplayer2.upstream.cache.LeastRecentlyUsedCacheEvictor;
 import com.google.android.exoplayer2.upstream.cache.SimpleCache;
 import com.guichaguri.trackplayer.service.MusicManager;
+import com.guichaguri.trackplayer.service.MusicService;
 import com.guichaguri.trackplayer.service.Utils;
 import com.guichaguri.trackplayer.service.models.Track;
+
 import java.io.File;
 import java.util.ArrayList;
 import java.util.Collection;
@@ -34,7 +35,7 @@ public class LocalPlayback extends ExoPlayback<SimpleExoPlayer> {
     private ConcatenatingMediaSource source;
     private boolean prepared = false;
 
-    public LocalPlayback(Context context, MusicManager manager, SimpleExoPlayer player, long maxCacheSize) {
+    public LocalPlayback(MusicService context, MusicManager manager, SimpleExoPlayer player, long maxCacheSize) {
         super(context, manager, player);
         this.cacheMaxSize = maxCacheSize;
     }