TiSound.java

/**
 * Titanium SDK
 * Copyright TiDev, Inc. 04/07/2022-Present. All Rights Reserved.
 * Licensed under the terms of the Apache Public License
 * Please see the LICENSE included with this distribution for details.
 */
package ti.modules.titanium.media;

import java.io.IOException;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;

import org.appcelerator.kroll.KrollDict;
import org.appcelerator.kroll.KrollPropertyChange;
import org.appcelerator.kroll.KrollProxy;
import org.appcelerator.kroll.KrollProxyListener;
import org.appcelerator.kroll.common.Log;
import org.appcelerator.titanium.TiApplication;
import org.appcelerator.titanium.TiC;
import org.appcelerator.titanium.util.TiConvert;
import org.appcelerator.titanium.util.TiRHelper;

import android.content.Context;
import android.content.res.AssetFileDescriptor;
import android.media.AudioAttributes;
import android.media.AudioManager;
import android.media.MediaPlayer;
import android.net.Uri;
import android.webkit.URLUtil;

public class TiSound implements MediaPlayer.OnCompletionListener, MediaPlayer.OnErrorListener, KrollProxyListener,
								MediaPlayer.OnBufferingUpdateListener, MediaPlayer.OnInfoListener,
								MediaPlayer.OnPreparedListener
{
	private static final String TAG = "TiSound";

	public static final int STATE_BUFFERING = 0;   // current playback is in the buffering from the network state
	public static final int STATE_INITIALIZED = 1; // current playback is in the initialization state
	public static final int STATE_PAUSED = 2;      // current playback is in the paused state
	public static final int STATE_PLAYING = 3;     // current playback is in the playing state
	public static final int STATE_STARTING = 4;    // current playback is in the starting playback state
	public static final int STATE_STOPPED = 5;     // current playback is in the stopped state
	public static final int STATE_STOPPING = 6;    // current playback is in the stopping state
	public static final int STATE_WAITING_FOR_DATA =
		7; // current playback is in the waiting for audio data from the network state
	public static final int STATE_WAITING_FOR_QUEUE =
		8; //	current playback is in the waiting for audio data to fill the queue state

	public static final String STATE_BUFFERING_DESC =
		"buffering"; // current playback is in the buffering from the network state
	public static final String STATE_INITIALIZED_DESC =
		"initialized";                                           // current playback is in the initialization state
	public static final String STATE_PAUSED_DESC = "paused";     // current playback is in the paused state
	public static final String STATE_PLAYING_DESC = "playing";   // current playback is in the playing state
	public static final String STATE_STARTING_DESC = "starting"; // current playback is in the starting playback state
	public static final String STATE_STOPPED_DESC = "stopped";   // current playback is in the stopped state
	public static final String STATE_STOPPING_DESC = "stopping"; // current playback is in the stopping state
	public static final String STATE_WAITING_FOR_DATA_DESC =
		"waiting for data"; // current playback is in the waiting for audio data from the network state
	public static final String STATE_WAITING_FOR_QUEUE_DESC =
		"waiting for queue"; //	current playback is in the waiting for audio data to fill the queue state

	public static final int AUDIO_TYPE_MEDIA = 0;
	public static final int AUDIO_TYPE_ALARM = 1;
	public static final int AUDIO_TYPE_SIGNALLING = 2;
	public static final int AUDIO_TYPE_RING = 3;
	public static final int AUDIO_TYPE_VOICE = 4;
	public static final int AUDIO_TYPE_NOTIFICATION = 5;

	public static final String EVENT_COMPLETE = "complete";
	public static final String EVENT_ERROR = "error";
	public static final String EVENT_CHANGE = "change";
	public static final String EVENT_PROGRESS = "progress";

	public static final String EVENT_COMPLETE_JSON = "{ type : '" + EVENT_COMPLETE + "' }";

	private boolean paused = false;
	private boolean looping = false;

	protected KrollProxy proxy;
	protected MediaPlayer mp;
	protected float volume;
	protected boolean playOnResume;
	protected boolean remote;
	protected Timer progressTimer;

	private boolean pausePending = false;
	private boolean stopPending = false;
	private boolean playPending = false;
	private boolean prepareRequired = false;
	public static boolean audioFocus;

	public TiSound(KrollProxy proxy)
	{
		this.proxy = proxy;
		this.playOnResume = false;
		this.remote = false;
	}

	protected void initializeAndPlay() throws IOException
	{
		try {
			mp = new MediaPlayer();

			int audioType = TiConvert.toInt(proxy.getProperty(TiC.PROPERTY_AUDIO_TYPE));
			int usage = -1;
			switch (audioType) {
				case AUDIO_TYPE_ALARM:
					usage = AudioAttributes.USAGE_ALARM;
					break;
				case AUDIO_TYPE_SIGNALLING:
					usage = AudioAttributes.USAGE_VOICE_COMMUNICATION_SIGNALLING;
					break;
				case AUDIO_TYPE_RING:
					usage = AudioAttributes.USAGE_NOTIFICATION_RINGTONE;
					break;
				case AUDIO_TYPE_VOICE:
					usage = AudioAttributes.USAGE_VOICE_COMMUNICATION;
					break;
				case AUDIO_TYPE_NOTIFICATION:
					usage = AudioAttributes.USAGE_NOTIFICATION;
					break;
				case AUDIO_TYPE_MEDIA:
				default:
					usage = AudioAttributes.USAGE_MEDIA;
			}
			if (usage != -1) {
				AudioAttributes attributes = new AudioAttributes.Builder().setUsage(usage).build();
				mp.setAudioAttributes(attributes);
			} else {
				Log.w(TAG, "unable to set setAudioAttributes()");
			}

			String url = TiConvert.toString(proxy.getProperty(TiC.PROPERTY_URL));
			boolean isAsset = URLUtil.isAssetUrl(url);
			if (isAsset || url.startsWith("android.resource")) {
				Context context = TiApplication.getInstance();
				AssetFileDescriptor afd = null;
				try {
					if (isAsset) {
						String path = url.substring(TiConvert.ASSET_URL.length());
						afd = context.getAssets().openFd(path);
					} else {
						Uri uri = Uri.parse(url);
						afd = context.getResources().openRawResourceFd(
							TiRHelper.getResource("raw." + uri.getLastPathSegment()));
					}
					mp.setDataSource(afd.getFileDescriptor(), afd.getStartOffset(), afd.getLength());
				} catch (Exception e) {
					Log.e(TAG, "Error setting file descriptor: ", e);
				} finally {
					if (afd != null) {
						afd.close();
					}
				}
			} else {
				Uri uri = Uri.parse(url);
				if (uri.getScheme().equals(TiC.PROPERTY_FILE)) {
					mp.setDataSource(uri.getPath());
				} else {
					remote = true;
					mp.setDataSource(url);
				}
			}

			String loop = TiConvert.toString(proxy.getProperty(TiC.PROPERTY_LOOPING));
			if (loop != null) {
				looping = Boolean.parseBoolean(loop);
				mp.setLooping(looping);
			}
			mp.setOnCompletionListener(this);
			mp.setOnErrorListener(this);
			mp.setOnInfoListener(this);
			mp.setOnBufferingUpdateListener(this);

			if (remote) { // try async
				mp.setOnPreparedListener(this);
				mp.prepareAsync();
				playPending = true;
			} else {
				mp.prepare();
				setState(STATE_INITIALIZED);
				setVolume(volume);
				if (proxy.hasProperty(TiC.PROPERTY_TIME)) {
					setTime(TiConvert.toInt(proxy.getProperty(TiC.PROPERTY_TIME)));
				}
				startPlaying();
			}

		} catch (Throwable t) {
			Log.w(TAG, "Issue while initializing : ", t);
			release();
			setState(STATE_STOPPED);
		}
	}

	public boolean isLooping()
	{
		return looping;
	}

	public boolean isPaused()
	{
		return paused;
	}

	public boolean isPlaying()
	{
		boolean result = false;
		if (mp != null) {
			result = mp.isPlaying();
		}
		return result;
	}

	public void pause()
	{
		try {
			if (mp != null) {
				if (mp.isPlaying()) {
					Log.d(TAG, "audio is playing, pause", Log.DEBUG_MODE);
					stopProgressTimer();
					mp.pause();
					paused = true;
					setState(STATE_PAUSED);
				} else if (playPending) {
					pausePending = true;
				}
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while pausing : ", t);
		}
	}

	public void play()
	{
		try {
			if (mp == null) {
				setState(STATE_STARTING);
				initializeAndPlay();
			} else {
				if (prepareRequired) {
					prepareAndPlay();
				} else {
					startPlaying();
				}
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while playing : ", t);
			reset();
		}
	}

	private void prepareAndPlay() throws IllegalStateException, IOException
	{
		prepareRequired = false;
		if (remote) {
			playPending = true;
			mp.setOnPreparedListener(new MediaPlayer.OnPreparedListener() {
				@Override
				public void onPrepared(MediaPlayer mp)
				{
					mp.setOnPreparedListener(null);
					mp.seekTo(0);
					playPending = false;
					if (!stopPending && !pausePending) {
						startPlaying();
					}
					pausePending = false;
					stopPending = false;
				}
			});
			mp.prepareAsync();
		} else {
			mp.prepare();
			mp.seekTo(0);
			startPlaying();
		}
	}

	public void reset()
	{
		try {
			if (mp != null && (mp.isPlaying() || isPaused())) {
				stopProgressTimer();

				setState(STATE_STOPPING);
				mp.seekTo(0);
				looping = false;
				paused = false;
				setState(STATE_STOPPED);
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while resetting : ", t);
		}
	}

	public int getAudioSessionId()
	{
		if (mp != null) {
			return mp.getAudioSessionId();
		}
		return 0;
	}

	public void release()
	{
		try {
			if (mp != null) {
				stopProgressTimer();
				mp.setOnCompletionListener(null);
				mp.setOnErrorListener(null);
				mp.setOnBufferingUpdateListener(null);
				mp.setOnInfoListener(null);

				mp.reset();
				mp.release();
				mp = null;
				Log.d(TAG, "Native resources released.", Log.DEBUG_MODE);
				remote = false;
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while releasing : ", t);
		}
	}

	public void setLooping(boolean loop)
	{
		try {
			if (loop != looping) {
				if (mp != null) {
					mp.setLooping(loop);
				}
				looping = loop;
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while configuring looping : ", t);
		}
	}

	public void setVolume(float volume)
	{
		try {
			if (volume < 0.0f) {
				this.volume = 0.0f;
				Log.w(TAG, "Attempt to set volume less than 0.0. Volume set to 0.0");
			} else if (volume > 1.0) {
				this.volume = 1.0f;
				proxy.setProperty(TiC.PROPERTY_VOLUME, volume);
				Log.w(TAG, "Attempt to set volume greater than 1.0. Volume set to 1.0");
			} else {
				this.volume = volume; // Store in 0.0 to 1.0, scale when setting hw
			}
			if (mp != null) {
				float scaledVolume = this.volume;
				mp.setVolume(scaledVolume, scaledVolume);
			}
		} catch (Throwable t) {
			Log.w(TAG, "Issue while setting volume : ", t);
		}
	}

	public int getDuration()
	{
		int duration = 0;
		if (mp != null && !playPending) {
			duration = mp.getDuration(); // Can only get duration after the media player is initialized.
		}
		return duration;
	}

	public boolean isMuted()
	{
		AudioManager audioManager =
			(AudioManager) TiApplication.getInstance().getApplicationContext().getSystemService(Context.AUDIO_SERVICE);

		return audioManager.getRingerMode() == AudioManager.RINGER_MODE_SILENT;
	}

	public void setMuted(boolean muted)
	{
		if (mp != null) {
			float scale = muted ? 0.0f : 1.0f;
			mp.setVolume(scale, scale);
		}
	}

	public int getTime()
	{
		int time = 0;

		if (mp != null) {
			time = mp.getCurrentPosition();
		} else {
			time = TiConvert.toInt(proxy.getProperty(TiC.PROPERTY_TIME));
		}

		return time;
	}

	public void setTime(int position)
	{
		if (position < 0) {
			position = 0;
		}

		if (mp != null) {
			int duration = mp.getDuration();
			if (position > duration) {
				position = duration;
			}

			try {
				if (mp.getDuration() >= 0) {
					mp.seekTo(position);
				}
			} catch (IllegalStateException e) {
				Log.w(TAG, "Error calling seekTo() in an incorrect state. Ignoring.");
			}
		}

		proxy.setProperty(TiC.PROPERTY_TIME, position);
	}

	private void setState(int state)
	{
		proxy.setProperty("state", state);
		String stateDescription = "";

		switch (state) {
			case STATE_BUFFERING:
				stateDescription = STATE_BUFFERING_DESC;
				break;
			case STATE_INITIALIZED:
				stateDescription = STATE_INITIALIZED_DESC;
				break;
			case STATE_PAUSED:
				stateDescription = STATE_PAUSED_DESC;
				break;
			case STATE_PLAYING:
				stateDescription = STATE_PLAYING_DESC;
				break;
			case STATE_STARTING:
				stateDescription = STATE_STARTING_DESC;
				break;
			case STATE_STOPPED:
				stateDescription = STATE_STOPPED_DESC;
				break;
			case STATE_STOPPING:
				stateDescription = STATE_STOPPING_DESC;
				break;
			case STATE_WAITING_FOR_DATA:
				stateDescription = STATE_WAITING_FOR_DATA_DESC;
				break;
			case STATE_WAITING_FOR_QUEUE:
				stateDescription = STATE_WAITING_FOR_QUEUE_DESC;
				break;
		}

		proxy.setProperty("stateDescription", stateDescription);
		Log.d(TAG, "Audio state changed: " + stateDescription, Log.DEBUG_MODE);

		KrollDict data = new KrollDict();
		data.put("state", state);
		data.put("description", stateDescription);
		proxy.fireEvent(EVENT_CHANGE, data);
	}

	public void stop()
	{
		try {
			if (mp != null) {

				if (mp.isPlaying() || isPaused()) {
					Log.d(TAG, "audio is playing, stop()", Log.DEBUG_MODE);
					setState(STATE_STOPPING);
					mp.stop();
					setState(STATE_STOPPED);
					stopProgressTimer();
					prepareRequired = true;
				} else if (playPending) {
					stopPending = true;
				}

				if (isPaused()) {
					paused = false;
				}
			}
		} catch (Throwable t) {
			Log.e(TAG, "Error : ", t);
		}
	}

	public void onCompletion(MediaPlayer mp)
	{
		KrollDict data = new KrollDict();
		data.putCodeAndMessage(TiC.ERROR_CODE_NO_ERROR, null);
		proxy.fireEvent(EVENT_COMPLETE, data);
		stop();
	}

	@Override
	public boolean onInfo(MediaPlayer mp, int what, int extra)
	{
		String msg = "Unknown media issue.";

		switch (what) {
			case MediaPlayer.MEDIA_INFO_BAD_INTERLEAVING:
				msg = "Stream not interleaved or interleaved improperly.";
				break;
			case MediaPlayer.MEDIA_INFO_NOT_SEEKABLE:
				msg = "Stream does not support seeking";
				break;
			case MediaPlayer.MEDIA_INFO_UNKNOWN:
				msg = "Unknown media issue";
				break;
			case MediaPlayer.MEDIA_INFO_VIDEO_TRACK_LAGGING:
				msg = "Video is too complex for decoder, video lagging."; // shouldn't occur, but covering bases.
				break;
		}

		KrollDict data = new KrollDict();
		data.putCodeAndMessage(TiC.ERROR_CODE_UNKNOWN, msg);
		proxy.fireEvent(EVENT_ERROR, data);

		return true;
	}

	@Override
	public boolean onError(MediaPlayer mp, int what, int extra)
	{
		int code = what;
		if (what == 0) {
			code = -1;
		}
		String msg = "Unknown media error.";
		if (what == MediaPlayer.MEDIA_ERROR_SERVER_DIED) {
			msg = "Media server died";
		}
		release();

		KrollDict data = new KrollDict();
		data.putCodeAndMessage(code, msg);
		proxy.fireEvent(EVENT_ERROR, data);

		return true;
	}

	@Override
	public void onBufferingUpdate(MediaPlayer mp, int percent)
	{
		Log.d(TAG, "Buffering: " + percent + "%", Log.DEBUG_MODE);
	}

	private void startProgressTimer()
	{
		if (progressTimer != null) {
			progressTimer.cancel();
		}
		progressTimer = new Timer(true);

		progressTimer.schedule(new TimerTask() {
			@Override
			public void run()
			{
				try {
					if (mp != null && mp.isPlaying()) {
						int position = mp.getCurrentPosition();
						KrollDict event = new KrollDict();
						event.put("progress", position);
						proxy.fireEvent(EVENT_PROGRESS, event);
					}
				} catch (Throwable t) {
					Log.e(TAG, "Issue while progressTimer run: ", t);
				}
			}
		}, 1000, 1000);
	}

	private void stopProgressTimer()
	{
		if (progressTimer != null) {
			progressTimer.cancel();
			progressTimer = null;
		}
	}

	public void onDestroy()
	{
		if (mp != null) {
			// Before we stop, make sure that timer is stopped
			stopProgressTimer();
			mp.release();
			mp = null;
		}
		// TitaniumMedia clears out the references after onDestroy.
	}

	public void onPause()
	{
		if (mp != null) {
			if (isPlaying()) {
				pause();
				playOnResume = true;
			}
		}
	}

	public void onResume()
	{
		if (mp != null) {
			if (playOnResume) {
				requestAudioFocus(audioFocus);
				play();
				playOnResume = false;
			}
		}
	}

	@Override
	public void listenerAdded(String type, int count, KrollProxy proxy)
	{
	}

	@Override
	public void listenerRemoved(String type, int count, KrollProxy proxy)
	{
	}

	@Override
	public void processProperties(KrollDict d)
	{
		if (d.containsKey(TiC.PROPERTY_VOLUME)) {
			setVolume(TiConvert.toFloat(d, TiC.PROPERTY_VOLUME, 1.0f));
		}
	}

	@Override
	public void propertyChanged(String key, Object oldValue, Object newValue, KrollProxy proxy)
	{
		if (TiC.PROPERTY_VOLUME.equals(key)) {
			setVolume(TiConvert.toFloat(newValue, 1.0f));
		} else if (TiC.PROPERTY_TIME.equals(key)) {
			setTime(TiConvert.toInt(newValue));
		}
	}

	@Override
	public void propertiesChanged(List<KrollPropertyChange> changes, KrollProxy proxy)
	{
		for (KrollPropertyChange change : changes) {
			propertyChanged(change.getName(), change.getOldValue(), change.getNewValue(), proxy);
		}
	}

	private void startPlaying()
	{
		if (mp != null) {
			if (!isPlaying() && !playPending) {
				Log.d(TAG, "audio is not playing, starting.", Log.DEBUG_MODE);
				Log.d(TAG, "Play: Volume set to " + volume, Log.DEBUG_MODE);
				mp.start();
				paused = false;
				startProgressTimer();
			}
			requestAudioFocus(audioFocus);
			setState(STATE_PLAYING);
		}
	}

	@Override
	public void onPrepared(MediaPlayer mp)
	{
		mp.setOnPreparedListener(null);
		setState(STATE_INITIALIZED);
		setVolume(volume);
		if (proxy.hasProperty(TiC.PROPERTY_TIME)) {
			setTime(TiConvert.toInt(proxy.getProperty(TiC.PROPERTY_TIME)));
		}
		playPending = false;
		if (!pausePending && !stopPending) {
			try {
				startPlaying();
			} catch (Throwable t) {
				Log.w(TAG, "Issue while playing : ", t);
				reset();
			}
		}
		pausePending = false;
		stopPending = false;
	}

	private boolean requestAudioFocus(boolean focus)
	{
		if (!focus)
			return false;
		AudioManager audioManager =
			(AudioManager) TiApplication.getInstance().getApplicationContext().getSystemService(Context.AUDIO_SERVICE);
		return audioManager != null
			&& audioManager.requestAudioFocus(null, AudioManager.STREAM_MUSIC, AudioManager.AUDIOFOCUS_GAIN)
				   == AudioManager.AUDIOFOCUS_REQUEST_GRANTED;
	}
}