package com.upc.pbe.upcnews;

import io.vov.vitamio.MediaPlayer;
import io.vov.vitamio.R;
import io.vov.vitamio.widget.MediaController;
import io.vov.vitamio.widget.VideoView;

import java.io.BufferedInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.ArrayList;

import android.app.Activity;
import android.app.ProgressDialog;
import android.content.res.Configuration;
import android.net.TrafficStats;
import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Toast;

//Tercera activitat principal, executa la reproduccio del video sencer
public class VideoActivity extends Activity {
	
	private final static String TAG = "VideoActivity";
	private VideoView video;
	private HLS h = null;
	private String filePath;
	private BandwidthMeasurer bm;
	private ProgressDialog pd;
	ArrayList<String> queue;
	ArrayList<String> playedQueue;
	int currentPos;
	boolean ended;
	boolean buffering;


	@Override
	public void onCreate(Bundle savedInstanceState) {
		
		//Creem el layout
		
		super.onCreate(savedInstanceState);
		//Necesario para las libs
		if (!io.vov.vitamio.LibsChecker.checkVitamioLibs(this))
		{
			return;
		}
		setContentView(R.layout.activity_video);
		currentPos = 0;
		queue = new ArrayList<String>();
		playedQueue = new ArrayList<String>();
		buffering = true;
		ended = false;
		filePath = ((UpcApp)getApplication()).getLocalPath();
		video = (VideoView) findViewById(R.id.VideoView1);
		//Creem un listener associat al fi de l'activitat (el fi de cada ts)
		io.vov.vitamio.widget.MediaController mc = new MediaController(this);
		video.setOnCompletionListener(new MediaPlayer.OnCompletionListener() {
		    public void onCompletion(MediaPlayer mp) {
		    	//Al acabar cada ts, reproduit el seguent
				playNext();
		    } 
		});
		mc.setOnFFLeftListener(new View.OnClickListener() {
			public void onClick(View v) {
				Log.d(TAG, "FFLEFT");
				playPrevious();
			}
		});
		mc.setOnFFRightListener(new View.OnClickListener() {
			public void onClick(View v) {
				Log.d(TAG, "FFRIGHT");
				playNext();
			}
		});
		video.setVideoQuality(MediaPlayer.VIDEOQUALITY_HIGH);
		//Creem un gestor HLS, carreguem el video i iniciem la reproduccio
		h = ((UpcApp)getApplication()).getHLS();
		h.loadVideo();
		video.setMediaController(mc);
		bm = new BandwidthMeasurer();
		downloadSegment(getNext());
	}
	
	public String getNext() 
	{
			return h.next();
	}
	
	public void toggleBuffering(boolean b)
	{
		if(b)
		{
			buffering = true;
			if(pd == null)
			{
				pd = new ProgressDialog(VideoActivity.this);
				pd.setCancelable(false);
				pd.setMessage(getString(R.string.buffering_text));
			}
			pd.show();
		}
		else
		{
			buffering = false;
			pd.dismiss();
		}
	}
	
	public void quitPlayer()
	{
		video.stopPlayback();
		super.finish();
		return;
	}
	
	public void buffer()
	{
		toggleBuffering(true);
		video.suspend();
	}
	public void play(String path)
	{
		toggleBuffering(false);
		video.setVideoPath(path);
		video.start();
		video.requestFocus();
	}
	
	public void playNext()
	{
		if(++currentPos > 0)
		{
			currentPos = 0;
		}
		if(currentPos == 0)
		{
			playedQueue.add(queue.get(0));
			queue.remove(0);
	    	if(ended && queue.isEmpty())
	    	{
	    		quitPlayer();
	    	}
	    	if(queue.isEmpty())
	    	{
	    		buffer();
	    	}
	    	else
	    	{
	    		play(queue.get(0));
	    	}
		}
		else if(currentPos < 0)
		{
			play(playedQueue.get(playedQueue.size() + currentPos));
		}
	}
	
	public void playPrevious()
	{
		if(playedQueue.isEmpty())
		{
			play(queue.get(0));
			return;
		}
		else if(playedQueue.size() + (--currentPos) < 0)
    	{
    		currentPos++;
    	}
    	play(playedQueue.get(playedQueue.size() + currentPos));
	}
	
	public void downloadSegment(String url)
	{
		DescarregaSegment ds = new DescarregaSegment();
		try
		{
			ds.execute(new URL(url));
		}
		catch (MalformedURLException e)
		{
			Toast.makeText(this, "URL malformada", Toast.LENGTH_LONG).show();
		}
	}
	public void showNotFound(String url)
	{
		Toast.makeText(this, "No s'ha trobat el segment " + url, Toast.LENGTH_LONG).show();
	}
	
	@Override
	public void onConfigurationChanged(Configuration newConfig) {
		if (video != null)
			video.setVideoLayout(VideoView.VIDEO_LAYOUT_SCALE, 0);
		super.onConfigurationChanged(newConfig);
	}
	
	public class DescarregaSegment extends AsyncTask<URL, Void, Void>
	{
		final static String TAG = "DescarregaSegment";
		private long bps;
		boolean failed;
		String url;
		
		public DescarregaSegment()
		{
			bps = 0;
			failed = false;
		}
		
		@Override
		protected void onPreExecute() 
		{
			if(queue.isEmpty() && !ended)
			{
				buffer();
			}
		}
		
		@Override
		protected Void doInBackground(URL... urls)
		{
			Long downloaded = Long.valueOf(0);
			long startTime = System.currentTimeMillis();
			long segmentBytes = TrafficStats.getTotalRxBytes();
			String fileName = urls[0].toString().substring(urls[0].toString().lastIndexOf("/"));
			// Iniciem la connexi� i creem els Streams
			try 
			{
				FileOutputStream out = new FileOutputStream(filePath + fileName,true);
				BufferedInputStream in = new BufferedInputStream(urls[0].openStream());
				Log.d(TAG, "\nDescarregant: \n");
				Log.d(TAG, ">> URL: " + urls[0]);
				byte data[] = new byte[102400];
	            int count;
	            while ((count = in.read(data)) != -1) 
	            {
	                downloaded += count;
	                out.write(data, 0, count);
	            }
				out.flush();
				out.close();
				in.close();
				bps = (long) bm.Measure(segmentBytes, startTime);
				Log.d(TAG, "Descarrega finalitzada");
				queue.add(filePath + fileName);
			}
			catch(IOException e)
			{
				url = urls[0].toString();
				failed = true;
				this.cancel(true);
				return null;
			}
			return null;
		 }
		 protected void onPostExecute(Void v) 
		 {
			 if(ended)
			 {
					return;
			 }
			 if(failed)
			 {
				 failed = false;
				 showNotFound(url);
			 }
			 else if(!queue.isEmpty() && buffering)
			 {
				 play(queue.get(0));
			 }
			 String newSegment = null;
			 h.updateQuality((long) bps);
			 newSegment = getNext();
			 if(newSegment == null)
			 {
				 ended = true;
			 }
			 else
			 {
				downloadSegment(newSegment); 
			 }
			 return;
	     }
	}
	
}