package mekanism.client.voice;

import javax.sound.sampled.AudioInputStream;
import javax.sound.sampled.AudioSystem;
import javax.sound.sampled.DataLine;
import javax.sound.sampled.TargetDataLine;

import mekanism.client.MekanismKeyHandler;
import cpw.mods.fml.relauncher.Side;
import cpw.mods.fml.relauncher.SideOnly;

@SideOnly(Side.CLIENT)
public class VoiceInput extends Thread
{
	public VoiceClient voiceClient;
	
	public DataLine.Info microphone;
	
	public TargetDataLine targetLine;
	
	public VoiceInput(VoiceClient client)
	{
		voiceClient = client;
		microphone = new DataLine.Info(TargetDataLine.class, voiceClient.format, 2200);
		
		setDaemon(true);
		setName("VoiceServer Client Input Thread");
	}
	
	@Override
	public void run()
	{
		try {
			targetLine = ((TargetDataLine)AudioSystem.getLine(microphone));
			targetLine.open(voiceClient.format, 2200);
			targetLine.start();
			AudioInputStream audioInput = new AudioInputStream(targetLine);
			
			boolean doFlush = false;
			
			while(voiceClient.running)
			{
				if(MekanismKeyHandler.voiceKey.pressed)
				{
					targetLine.flush();
					
					while(voiceClient.running && MekanismKeyHandler.voiceKey.pressed)
					{
						try {
							int availableBytes = audioInput.available();
							byte[] audioData = new byte[availableBytes > 2200 ? 2200 : availableBytes];
							int bytesRead = audioInput.read(audioData, 0, audioData.length);
							
							if(bytesRead > 0)
							{
								voiceClient.output.writeShort(audioData.length);
								voiceClient.output.write(audioData);
							}
						} catch(Exception e) {}
					}
					
					try {
						Thread.sleep(200L);
					} catch(Exception e) {}
					
					doFlush = true;
				}
				else if(doFlush)
				{
					try {
						voiceClient.output.flush();
					} catch(Exception e) {}
					
					doFlush = false;
				}
				
				try {
					Thread.sleep(20L);
				} catch(Exception e) {}
			}
			
			audioInput.close();
		} catch(Exception e) {
			System.err.println("[Mekanism] VoiceServer: Error while running client input thread.");
			e.printStackTrace();
		}
	}
	
	public void close()
	{
		targetLine.flush();
		targetLine.close();
	}
}