package src.org.sipdroid.media;

import java.io.IOException;

import java.net.SocketException;

import org.sipdroid.sipua.UserAgent;

import org.sipdroid.sipua.ui.Receiver;

import org.sipdroid.sipua.ui.Sipdroid;

import org.sipdroid.pjlib.Codec;

import src.org.sipdroid.net.RtpPacket;

import src.org.sipdroid.net.RtpSocket;

import src.org.sipdroid.net.SipdroidSocket;

import android.os.PowerManager;

public class RtpStreamReceiver extends Thread {

	/** Payload type */

	int p_type;

	RtpSocket rtp_socket = null;

	public RtpStreamReceiver(SipdroidSocket socket, int payload_type) {

		init(socket);

		p_type = payload_type;

	/** Inits the RtpStreamReceiver */

	private void init(SipdroidSocket socket) {

		if (socket != null)

			rtp_socket = new RtpSocket(socket);

		if (Receiver.headset > 0 && mode == AudioManager.MODE_NORMAL)

			return old;

		setMode(speakermode = mode);

	static void setStreamVolume(final int stream,final int vol,final int flags) {

        (new Thread() {

			public void run() {

				AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);

				am.setStreamVolume(stream, vol, flags);

				if (stream == AudioManager.STREAM_MUSIC) restored = true;

			}

        }).start();

	}

	static boolean restored;

		switch (am.getMode()) {

		case AudioManager.MODE_IN_CALL:

				setStreamVolume(AudioManager.STREAM_RING,(int)(

						am.getStreamMaxVolume(AudioManager.STREAM_RING)*

						org.sipdroid.sipua.ui.Settings.getEarGain()), 0);

				track.setStereoVolume(AudioTrack.getMaxVolume()*

						org.sipdroid.sipua.ui.Settings.getEarGain()

						,AudioTrack.getMaxVolume()*

						org.sipdroid.sipua.ui.Settings.getEarGain());

				break;

		case AudioManager.MODE_NORMAL:

				track.setStereoVolume(AudioTrack.getMaxVolume(),AudioTrack.getMaxVolume());

				break;

		}

		setStreamVolume(AudioManager.STREAM_MUSIC,

				PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("volume"+speakermode, 

				am.getStreamMaxVolume(AudioManager.STREAM_MUSIC)*

				(speakermode == AudioManager.MODE_NORMAL?4:3)/4

		if (restored) {

			Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();

			edit.putInt("volume"+speakermode,am.getStreamVolume(AudioManager.STREAM_MUSIC));

			edit.commit();

		}

		if (!PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("oldvalid",false)) {

			if (!PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).contains("oldvibrate2"))

			Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();

	public static void setMode(int mode) {

		Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();

		edit.putBoolean("setmode", mode != AudioManager.MODE_NORMAL);

		edit.commit();

		AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);

		am.setMode(mode);

	}

	public static void restoreMode() {

		if (PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("setmode",true)) {

			if (Receiver.pstn_state == null || Receiver.pstn_state.equals("IDLE"))

				setMode(AudioManager.MODE_NORMAL);

			else {

				Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();

				edit.putBoolean("setmode", false);

				edit.commit();

			}

		}

	}

	public static void restoreSettings() {

		if (PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("oldvalid",true)) {

			AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);

	        ContentResolver cr = Receiver.mContext.getContentResolver();

			int oldvibrate = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldvibrate",0);

			int oldvibrate2 = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldvibrate2",0);

			int oldpolicy = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldpolicy",0);

			am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,oldvibrate);

			am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,oldvibrate2);

			Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY, oldpolicy);

			setStreamVolume(AudioManager.STREAM_RING, PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldring",0), 0);

			Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();

			edit.putBoolean("oldvalid", false);

			edit.commit();

			PowerManager pm = (PowerManager) Receiver.mContext.getSystemService(Context.POWER_SERVICE);

			PowerManager.WakeLock wl = pm.newWakeLock(PowerManager.SCREEN_BRIGHT_WAKE_LOCK |

					PowerManager.ACQUIRE_CAUSES_WAKEUP, "Sipdroid.RtpStreamReceiver");

			wl.acquire(1000);

		}

		restoreMode();

	public static int timeout;

	void empty() {

		try {

			rtp_socket.getDatagramSocket().setSoTimeout(1);

			for (;;)

				rtp_socket.receive(rtp_packet);

		} catch (SocketException e2) {

			if (!Sipdroid.release) e2.printStackTrace();

		} catch (IOException e) {

		}

		try {

			rtp_socket.getDatagramSocket().setSoTimeout(1000);

		} catch (SocketException e2) {

			if (!Sipdroid.release) e2.printStackTrace();

		}

	}

	RtpPacket rtp_packet;

	AudioTrack track;

		boolean nodata = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("nodata",false);

		if (rtp_socket == null) {

			if (DEBUG)

				println("ERROR: RTP socket is null");

			return;

		}

		byte[] buffer = new byte[BUFFER_SIZE+12];

		byte[] buffer_gsm = new byte[33+12];

		int i;

		rtp_packet = new RtpPacket(buffer, 0);

		if (DEBUG)

			println("Reading blocks of max " + buffer.length + " bytes");

		running = true;

		speakermode = Receiver.docked > 0?AudioManager.MODE_NORMAL:AudioManager.MODE_IN_CALL;

		restored = false;

		android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_AUDIO);

		am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);

        cr = Receiver.mContext.getContentResolver();

		saveSettings();

		Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY,Settings.System.WIFI_SLEEP_POLICY_NEVER);

		am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,AudioManager.VIBRATE_SETTING_OFF);

		am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,AudioManager.VIBRATE_SETTING_OFF);

		int oldvol = am.getStreamVolume(AudioManager.STREAM_MUSIC);

		track = new AudioTrack(AudioManager.STREAM_MUSIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT,

				BUFFER_SIZE*2*2, AudioTrack.MODE_STREAM);

		short lin[] = new short[BUFFER_SIZE];

		short lin2[] = new short[BUFFER_SIZE];

		int user, server, lserver, luser, cnt, todo, headroom, len = 0, seq = 0, cnt2 = 0, m = 1,

			expseq, getseq, vm = 1, gap, gseq;

		timeout = 1;

		boolean islate;

		user = 0;

		lserver = 0;

		luser = -8000;

		cnt = 0;

		switch (p_type) {

		case 3:

			Codec.init();

			break;

		case 0:

		case 8:

			G711.init();

			break;

		}

		ToneGenerator tg = new ToneGenerator(AudioManager.STREAM_MUSIC,(int)(ToneGenerator.MAX_VOLUME*2*org.sipdroid.sipua.ui.Settings.getEarGain()));

		if (Receiver.headset > 0 && Receiver.oRingtone != null) {

			ToneGenerator tg2 = new ToneGenerator(AudioManager.STREAM_RING,(int)(ToneGenerator.MAX_VOLUME*2*org.sipdroid.sipua.ui.Settings.getEarGain()));

			tg2.startTone(ToneGenerator.TONE_SUP_RINGTONE);

			System.gc();

			tg2.stopTone();

		} else

			System.gc();

			if (Receiver.call_state == UserAgent.UA_STATE_HOLD) {

				tg.stopTone();

				track.pause();

				while (running && Receiver.call_state == UserAgent.UA_STATE_HOLD) {

					try {

						sleep(1000);

					} catch (InterruptedException e1) {

					}

				}

				track.play();

				System.gc();

				timeout = 1;

				seq = 0;

			try {

				rtp_socket.receive(rtp_packet);

				if (timeout != 0) {

					tg.stopTone();

					track.pause();

					user += track.write(lin2,0,BUFFER_SIZE);

					user += track.write(lin2,0,BUFFER_SIZE);

					track.play();

					cnt += 2*BUFFER_SIZE;

					empty();

				}

				timeout = 0;

			} catch (IOException e) {

				if (timeout == 0 && nodata) {

					tg.startTone(ToneGenerator.TONE_SUP_RINGTONE);

				}

				rtp_socket.getDatagramSocket().disconnect();

				if (++timeout > 22) {

					Receiver.engine(Receiver.mContext).rejectcall();

					break;

			}

			if (running && timeout == 0) {		

				 gseq = rtp_packet.getSequenceNumber();

				 if (seq == gseq) {

					 m++;

					 continue;

				 }

				 server = track.getPlaybackHeadPosition();

				 headroom = user-server;

				 if (headroom > 1500)

					 cnt += len;

				 else

					 cnt = 0;

				 if (lserver == server)

					 cnt2++;

				 else

					 cnt2 = 0;

				 if (cnt <= 500 || cnt2 >= 2 || headroom - 875 < len) {

					 switch (rtp_packet.getPayloadType()) {

					 case 0:

						 len = rtp_packet.getPayloadLength();

						 G711.ulaw2linear(buffer, lin, len);

						 break;

					 case 8:

						 len = rtp_packet.getPayloadLength();

						 G711.alaw2linear(buffer, lin, len);

						 break;

					 case 3:

						 for (i = 12; i < 45; i++)

							 buffer_gsm[i] = buffer[i];

						 len = Codec.decode(buffer_gsm, lin, 0);

						 break;

					 }

		 			 if (speakermode == AudioManager.MODE_NORMAL)

		 				 calc(lin,0,len);

				 }

	 			 if (headroom < 250) { 

					todo = 875 - headroom;

					println("insert "+todo);

					user += track.write(lin2,0,todo);

				 } else

				 if (cnt > 500 && cnt2 < 2) {

					 todo = headroom - 875;

					 println("cut "+todo);

					 if (todo < len)

						 user += track.write(lin,todo,len-todo);

				 } else

					 user += track.write(lin,0,len);

				 if (seq != 0) {

					 getseq = gseq&0xff;

					 expseq = ++seq&0xff;

					 if (m == RtpStreamSender.m) vm = m;

					 gap = (getseq - expseq) & 0xff;

					 if (gap > 0) {

						 if (gap > 100) gap = 1;

						 loss += gap;

						 lost += gap;

						 good += gap - 1;

					 } else {

						 if (m < vm)

							 loss++;

						 if (islate)

							 late++;

					 }

					 good++;

					 if (good > 100) {

						 good *= 0.99;

						 lost *= 0.99;

						 loss *= 0.99;

						 late *= 0.99;

					 }

				 }

				 m = 1;

				 seq = gseq;

				 if (user >= luser + 8000 && Receiver.call_state == UserAgent.UA_STATE_INCALL) {

					 if (luser == -8000 || am.getMode() != speakermode) {

						 saveVolume();

						 setMode(speakermode);

						 restoreVolume();

					 }

					 luser = user;

				 }

				 lserver = server;

		saveVolume();

		setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);

		restoreSettings();

		setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);

		tg.stopTone();

		tg = new ToneGenerator(AudioManager.STREAM_RING,ToneGenerator.MAX_VOLUME/4*3);

			sleep(500);

		rtp_socket.close();

		rtp_socket = null;

		if (DEBUG)

			println("rtp receiver terminated");

		if (!Sipdroid.release) System.out.println("RtpStreamReceiver: " + str);