import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;

import javax.swing.*;

/**
This program shows how to use sockets to send plain text
mail messages.
*/
public class VideoClient
{  
	static LoginFrame framelog;
	static ClientFrame frame;
	static ControlFrame cframe;
	static boolean aux = false;
	static Socket s;
	static BufferedReader input;
	static PrintWriter output;
	static String[] readarrayaux; 
	
	public static void main(String[] args)
	{  
		framelog = new LoginFrame();
		
	       framelog.addWindowListener(new WindowAdapter() {
	           public void windowClosing(WindowEvent e) {
	        	   framelog.closeServer(s);
	               System.exit(0);
	           }
	       });
		
		framelog.setVisible(true);
		//frame = new ClientFrame();
		//frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		//frame1.setVisible(true);
		
	}
	
	public static void visible(){
		//framelog.setVisible(false);
		framelog.dispose();
		frame = new ClientFrame();
	       frame.addWindowListener(new WindowAdapter() {
	           public void windowClosing(WindowEvent e) {
	        	   frame.closeServer(s);
	               System.exit(0);
	           }
	       });
		frame.setVisible(true);
	}
	
	public static void visibledos(int i){
		//framelog.setVisible(false);
		if (i==2){
			cframe.dispose();
			cframe = new ControlFrame(2);
		}
		else if (i==3){
			cframe.dispose();
			cframe = new ControlFrame(1);
		}
		else {
			cframe = new ControlFrame(1);
		}
		frame.enable(false);
	       cframe.addWindowListener(new WindowAdapter() {
	           public void windowClosing(WindowEvent e) {
	        	   try {
					videofunc.send("NEWCONFIG",VideoClient.output);
		        	ClientFrame.status = false;
		        	frame.enable(true);
		        	cframe.dispose();
	        	   } catch (IOException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
	        	   };
	           }
	       });
		cframe.setVisible(true);
	}
	
	public static void crearsocket(String ip, int port) throws IOException
		{
			s = new Socket(ip, port);
			input = new BufferedReader(new InputStreamReader(s.getInputStream()));
			output = new PrintWriter(s.getOutputStream(), true /* autoFlush */);
			aux=true;
		}
	
	public static void openflash(String dir){
        java.awt.Desktop desktop = java.awt.Desktop.getDesktop();
        try {

                java.net.URI uri = new java.net.URI(dir);
                desktop.browse(uri);
            }
            catch ( Exception e ) {

                System.err.println( e.getMessage() );
            }
    }
		
}

/**
The frame for the mail GUI.
*/
class LoginFrame extends JFrame
{  
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	public LoginFrame()
	{  
   setSize(300, 150);
   setTitle("Log In");
   setLocationRelativeTo(null);

   getContentPane().setLayout(new GridBagLayout());

   GridBagConstraints gbc = new GridBagConstraints();
   gbc.fill = GridBagConstraints.HORIZONTAL;
   gbc.weightx = 0;
   gbc.weighty = 0;

   gbc.weightx = 0;
   videofunc.add(this,new JLabel("IP Server:"), gbc, 0, 0, 1, 1);
   gbc.weightx = 100;
   ipserv = new JTextField("190.164.108.21", 20);
   videofunc.add(this,ipserv, gbc, 1, 0, 1, 1);
   
   gbc.weightx = 0;
   videofunc.add(this,new JLabel("Puerto:"), gbc, 0, 1, 1, 1);
   gbc.weightx = 100;
   port = new JTextField("8189",20);
   videofunc.add(this,port, gbc, 1, 1, 1, 1);

   gbc.weightx = 0;
   videofunc.add(this,new JLabel("Pass:"), gbc, 0, 2, 1, 1);
   gbc.weightx = 100;
   pass = new JPasswordField("now",20);
   videofunc.add(this,pass, gbc, 1, 2, 1, 1);

   gbc.fill = GridBagConstraints.BOTH;
   
   gbc.weighty = 0;
   JButton sendButton = new JButton("Log In");
   sendButton.addActionListener(new
      ActionListener()
      {
         public void actionPerformed(ActionEvent evt)
         {  
            new 
               Thread()
               {
                  public void run()
                  {  
                	  if(!VideoClient.aux){
	                	  try {
	                		  String puerto = port.getText();
	                		  int portn = Integer.parseInt(puerto);
	                		  //System.out.println(puerto);
	                		  //System.out.print(portn);
	                		  VideoClient.crearsocket(ipserv.getText(), portn);
	                		  VideoClient.aux=true; 
	                		  //Verify();
	               	  	  }
	                	  catch (IOException e) {
	                		  JOptionPane.showMessageDialog(null,"Can't create socket");
	                		  e.printStackTrace();
	                	  }
                	  }
                	  Verify();
                  }
               } .start();
         }
      });
   JPanel buttonPanel = new JPanel();
   buttonPanel.add(sendButton);
   videofunc.add(this,buttonPanel, gbc, 0, 8, 2, 1);
	}

	public void closeServer(Socket s) {
		
				if(s!=null)
					try {
						s.close();
					} catch (IOException e) {
						e.printStackTrace();
					}
		
	}

	class RedLabel implements Runnable {
		private static final long serialVersionUID = 1L;
		private Thread t;
		private JComponent test;
		  public RedLabel(JComponent asd) {
		    this.test = asd;
		    t = new Thread(this);
		    t.start(); 
		  }
		  public void PaintComp(JComponent x, Color color) {
			    x.setBackground(color);
			  }
		  public void run() {
		    	  PaintComp(test, Color.RED);
		    	  try {
		    	  Thread.sleep(2000);
		    	  } catch(InterruptedException e) { }
		    	  PaintComp(test, Color.WHITE);
		    	  }
		}

		public boolean TestFields(){
		int i=0;
		   if(pass.getText().equals("")){
			   new RedLabel(pass);
				i=1;
		   }
		   if(ipserv.getText().equals("")){
			   new RedLabel(ipserv);
			   i=1;
		   }
		   if(port.getText().equals("")){
			   new RedLabel(port);
			   i=1;
		   }
		   if(i==1)return true;
		   else return false;
		}
		
		public void Verify()
		{  
		String lnread;
		
	   try
	   {  
		   if(TestFields())return;   
		   
	      String auth64 = pass.getText();

	      videofunc.sendpass(auth64, VideoClient.output);
	      String status = videofunc.receiveline(VideoClient.input);
	      
	      //CORRER INTERFAZ DE CLIENTE
	      if (status.compareTo("access")==0)
	    	  {	
	    	  JOptionPane.showMessageDialog(null, "Authentication Successful");
	    	  VideoClient.aux=false;
	      	  //VideoClient.visible();
	      	  lnread = videofunc.receiveline(VideoClient.input);
	      	  int max = Integer.parseInt(lnread);
	    	  //JOptionPane.showMessageDialog(null, lnread);
	      		VideoClient.readarrayaux=new String[max];
	      	  for(int i=0;i<max;i++){
	      		lnread = videofunc.receiveline(VideoClient.input);
	      		VideoClient.readarrayaux[i]=lnread;
	      		//System.out.println(VideoClient.readarrayaux[i]);
	      		/*ClientFrame.communication.append(lnread);
	      	    ClientFrame.communication.append("\n");*/
	      	  }
	      	 VideoClient.visible();
	      }
	      else JOptionPane.showMessageDialog(null, "Incorrect IP/Password ");
	      
	   }
	   catch (IOException e)
	   {  
	      e.printStackTrace();
	   }
		}
		
		private JTextField ipserv;
		private JTextField port;
		private JTextField pass;
}


class ClientFrame extends JFrame
{  
/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	static boolean status = false;
	boolean video = true;
	
	public ClientFrame()
	{  
		setSize(WIDTH, HEIGHT);
		   setTitle("Video Streaming Client");
		   setLocationRelativeTo(null);
		   getContentPane().setLayout(new GridBagLayout());
		   
		   GridBagConstraints gbc = new GridBagConstraints();
		   gbc.fill = GridBagConstraints.HORIZONTAL;
		   gbc.weightx = 0;
		   gbc.weighty = 0;

		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Video Size:"), gbc, 0, 1, 1, 1);
		   gbc.weightx = 100;
		   String[] videoSizeS = { "640x480", "320x240", "160x128", "352x288", "176x144" };
		   videoSize = new JComboBox(videoSizeS);
		   videofunc.add(this,videoSize, gbc, 1, 1, 1, 1);

		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Video BitRate (kb/s):"), gbc, 0, 2, 1, 1);
		   gbc.weightx = 100;
		   String[] videoBitRateS = { "16", "32","64","128","256","512" };
		   videoBitRate = new JComboBox(videoBitRateS);
		   videofunc.add(this,videoBitRate, gbc, 1, 2, 1, 1);
		   
		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Video Buffer Size (kb):"), gbc, 0, 3, 1, 1);
		   gbc.weightx = 100;
		   String[] videoBufferSizeS = {"1", "5", "10", "20", "40", "100", "200",  "400"};
		   videoBufferSize = new JComboBox(videoBufferSizeS);
		   videofunc.add(this,videoBufferSize, gbc, 1, 3, 1, 1);
		   
		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Video FrameRate (1/s):"), gbc, 0, 4, 1, 1);
		   gbc.weightx = 100;
		   String[] videoFrameRateS = {"12.98", "23.98", "29.98" };
		   videoFrameRate = new JComboBox(videoFrameRateS);
		   videofunc.add(this,videoFrameRate, gbc, 1, 4, 1, 1);
		   
		   gbc.weightx = 100;
		   noVideo = new JCheckBox("No Video");
		   videofunc.add(this,noVideo, gbc, 1, 5, 1, 1);
		   
		   
		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Audio Channels:"), gbc, 0, 6, 1, 1);
 		   gbc.weightx = 100;
		   String[] audiochannelS = { "1", "2"};
		   audioChannels = new JComboBox(audiochannelS);
		   videofunc.add(this,audioChannels, gbc, 1, 6, 1, 1);

		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Audio Sample Rate:"), gbc, 0, 7, 1, 1);
		   gbc.weightx = 100;
		   String[] audiosamplerateS = { "11025","22050", "44100" };
		   audioSampleRate = new JComboBox(audiosamplerateS);
		   videofunc.add(this,audioSampleRate, gbc, 1, 7, 1, 1);
		   
		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("Audio Bit Rate (kb/s):"), gbc, 0, 8, 1, 1);
		   gbc.weightx = 100;
		   String[] audiobitrateS = { "4", "8" ,"16", "32", "96", "128", "160", "192" };
		   AudioBitRate = new JComboBox(audiobitrateS);
		   videofunc.add(this,AudioBitRate, gbc, 1, 8, 1, 1);
		   
		   gbc.weightx = 100;
		   noAudio = new JCheckBox("No Audio");
		   videofunc.add(this,noAudio, gbc, 1, 9, 1, 1);

		   gbc.weightx = 0;
		   videofunc.add(this,new JLabel("File Name:"), gbc, 0, 10, 1, 1);
		   gbc.weightx = 100;
		   filenames = new JComboBox(VideoClient.readarrayaux);
		   videofunc.add(this,filenames, gbc, 1, 10, 1, 1);
		   
		   
		   JButton sendButton = new JButton("Send Request");
		   sendButton.addActionListener(new
		      ActionListener()
		      {
		         public void actionPerformed(ActionEvent evt)
		         {  
		            new 
		               Thread()
		               {
		                  public void run()
		                  {  
	                		  if(!status){
	                			  startStream();
								  status=true;
	                		  }
		                  }
		               }.start();
		         }            
		      });
		   JPanel buttonPanel = new JPanel();
		   gbc.weightx = 0;
		   buttonPanel.add(sendButton);
		   videofunc.add(this,buttonPanel, gbc, 0, 12, 2, 1);
		   /*
		   JButton stopButton = new JButton("Stop Stream");
		   stopButton.addActionListener(new
		      ActionListener()
		      {
		         public void actionPerformed(ActionEvent evt)
		         {  
		            new 
		               Thread()
		               {
		                  public void run()
		                  {   
		                	  try {
		                		  if(status){
								videofunc.send("NEWCONFIG",VideoClient.output);
								status=false;
		                		  }
							} catch (IOException e) {
								e.printStackTrace();
							}
		                  }
		               }.start();
		         }            
		      });
		   JPanel stopPanel = new JPanel();
		   //gbc.weightx = 10;
		   stopPanel.add(stopButton);
		   videofunc.add(this,stopPanel, gbc, 1, 11, 1, 1);*/
		   
		   gbc.fill = GridBagConstraints.HORIZONTAL;
		  
		}
	
	public void closeServer(Socket s) {
				
				if(s!=null)
					
					try {
						videofunc.send("DESTROY",VideoClient.output);
						s.close();
					} catch (IOException e) {
						e.printStackTrace();
					}
		
	}

/**
   Add a component to this frame.
   @param c the component to add
   @param gbc the grid bag constraints
   @param x the grid bag column
   @param y the grid bag row
   @param w the number of grid bag columns spanned
   @param h the number of grid bag rows spanned
*/
	
	public void startStream()
		{
		try	
			{
			//JOptionPane.showMessageDialog(null,(String) videoSize.getSelectedItem());
			videofunc.send((String) videoSize.getSelectedItem(),VideoClient.output);
			videofunc.send((String) videoBitRate.getSelectedItem(),VideoClient.output);
			videofunc.send((String) videoBufferSize.getSelectedItem(),VideoClient.output);
			videofunc.send((String) videoFrameRate.getSelectedItem(),VideoClient.output);
			if(noVideo.isSelected())
				videofunc.send("NoVideo",VideoClient.output);
			else
				videofunc.send("#NoVideo",VideoClient.output);

			videofunc.send((String) audioChannels.getSelectedItem(),VideoClient.output);
			videofunc.send((String) audioSampleRate.getSelectedItem(),VideoClient.output);
			videofunc.send((String) AudioBitRate.getSelectedItem(),VideoClient.output);
			if(noAudio.isSelected())
				videofunc.send("NoAudio",VideoClient.output);
			else
				videofunc.send("#NoAudio",VideoClient.output);
			videofunc.send((String) filenames.getSelectedItem(),VideoClient.output);

		     InetAddress inetAdd = VideoClient.s.getInetAddress();
		     String remoteIP = inetAdd.getHostAddress();
			 VideoClient.openflash("http://"+ remoteIP +":8090/test.swf");  //   ?buffer=5
			 VideoClient.visibledos(1);
			 
		}
		catch (IOException e)
		   {  
		      e.printStackTrace();
		   }
		}

/**
   Sends a string to the socket and echoes it in the
   communication text area.
   @param s the string to send.
*/
	

	static JTextArea communication;
	
	private JComboBox videoSize;
	private JComboBox videoBitRate;
	private JComboBox videoBufferSize;
	private JComboBox videoFrameRate;
	private JCheckBox noVideo;
	
	private JComboBox audioChannels;
	private JComboBox audioSampleRate;
	private JComboBox AudioBitRate;
	private JCheckBox noAudio;
	
	private JComboBox filenames;
	//private JTextField name;
	
	public static final int WIDTH = 500;
	public static final int HEIGHT = 350;  
}

class ControlFrame extends JFrame{

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	boolean pause = false;
	
	public ControlFrame(int i)
	{  
		   setSize(400, 100);
		   setTitle("Control Panel");
		   setLocationRelativeTo(null);
		   getContentPane().setLayout(new GridBagLayout());
		   
		   GridBagConstraints gbc = new GridBagConstraints();
		   gbc.fill = GridBagConstraints.HORIZONTAL;
		   gbc.weightx = 0;
		   gbc.weighty = 0;
		   
		   if (i==1){
		   final JButton pauseButton = new JButton("Pause");
		   pauseButton.addActionListener(new
		      ActionListener()
		      {
		         public void actionPerformed(ActionEvent evt)
		         {  
		            new 
		               Thread()
		               {
		                  public void run()
		                  {   
		                	  try {
		                		  if(ClientFrame.status){
								  videofunc.send("PAUSE",VideoClient.output);
								  //pauseButton.setLabel("Play");
								  VideoClient.visibledos(2);
		                		  }
							} catch (IOException e) {
								e.printStackTrace();
							}
		                  }
		               }.start();
		         }            
		      });
		   JPanel pausePanel = new JPanel();
		   pausePanel.add(pauseButton);
		   videofunc.add(this,pausePanel, gbc, 0, 0, 1, 1);
		   }
		   
		   else {
			   JButton playButton = new JButton("Play");
			   playButton.addActionListener(new ActionListener()
			      {
			         public void actionPerformed(ActionEvent evt)
			         {  
			            new Thread()
			               {
			                  public void run()
			                  {   
			                	  try {
			                		  if(ClientFrame.status){
									videofunc.send("RESUME",VideoClient.output);
									VideoClient.visibledos(3);
			                		  }
								} catch (IOException e) {
									e.printStackTrace();
								}
			                  }
			               }.start();
			         }            
			      });
			   JPanel playPanel = new JPanel();
			   playPanel.add(playButton);
			   videofunc.add(this,playPanel, gbc, 0, 0, 1, 1);
			   
		   }

		   JButton stopButton = new JButton("Stop");
		   stopButton.addActionListener(new
		      ActionListener()
		      {
		         public void actionPerformed(ActionEvent evt)
		         {  
		            new 
		               Thread()
		               {
		                  public void run()
		                  {   
		                	  try {
		                		  if(ClientFrame.status){
								videofunc.send("NEWCONFIG",VideoClient.output);
								ClientFrame.status=false;
								VideoClient.frame.enable(true);
						        VideoClient.cframe.dispose();
		                		  }
							} catch (IOException e) {
								e.printStackTrace();
							}
		                  }
		               }.start();
		         }            
		      });
		   JPanel stopPanel = new JPanel();
		   stopPanel.add(stopButton);
		   videofunc.add(this,stopPanel, gbc, 1, 0, 1, 1);
		   
		   gbc.fill = GridBagConstraints.HORIZONTAL;
		}
	
	    
}


class videofunc{
	static void add(JFrame fr,Component c, GridBagConstraints gbc,int x, int y, int w, int h)
			{  
			gbc.gridx = x;
			gbc.gridy = y;
			gbc.gridwidth = w;
			gbc.gridheight = h;
			fr.add(c, gbc);
			}

	public static void send(String s, PrintWriter out) throws IOException
	{  
			out.println(s);
	}

	public static void sendpass(String s, PrintWriter out) throws IOException
	{  
			out.println(s);
	}

/**
Receives a string from the socket and displays it
in the communication text area.
*/

	public static String receiveline(BufferedReader in) throws IOException
	{
	String line = in.readLine();
	//System.out.println(line);
    return line;
	}
}