/*
 *  $Revision: 1353 $
 *  $Author: tgutwin $
 *  $Date: 2020-06-08 20:11:56 -0700 (Mon, 08 Jun 2020) $
 *  $URL: svn://fred.webarts.bc.ca/open/trunk/projects/WebARTS/ca/bc/webarts/tools/sockets/JOrbisSocketServer.java $
 */
/*
 *
 *  Written by Tom Gutwin - WebARTS Design.
 *  Copyright (C) 2014 WebARTS Design, North Vancouver Canada
 *  http://www.webarts.bc.ca
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without_ even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */
package ca.bc.webarts.tools.sockets;

import java.io.DataInputStream;
import java.io.PrintStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

import com.jcraft.jogg.*;

import com.jcraft.jorbis.*;

import ca.bc.webarts.JOggPlayerListener;


/**
 * A Multi-Threaded TCP Socket server that listens for requests and then performs Ogg  Vorbis playing functions
 * (wrapped in the {@link PirateTunesClientThread PirateTunesClientThread}) on the server.
 * It acts as a Network based relay of requests.
 * It works well with its companion class {@link ca.bc.webarts.tools.sockets.TCPSocketClient TCPSocketClient}. <br><br>
 *
 * This class has a main method to execute directly as an app listening on its {@link #DEFAULT_PORT DEFAULT_port} {@link #DEFAULT_PORT 44444}.<pre>
 *         java ca.bc.webarts.tools.sockets.TCPSocketServer [portNumber]
 *              - portNumber is optional</pre>
 * Its default function is to take  whatever message
 * is sent and <b>execute it directly on the commanline</b>. You should change this to whatever you want. <br><br>
 * It can also be wrapped in another java class<br>Example usage :<br>
 * <pre>    TCPSocketServer tcpServer = new TCPSocketServer(portToUse);

    int i = 0;
    boolean posted = false;
    while (tcpServer.getSocket()!=null)
    {
      try
      {
        // Listening  for another client connection
        if (debug_>1) System.out.println("Accepting new connections ");
         posted = tcpServer.postConnection(tcpServer.getSocket().accept());

        //if (debug_>1) System.out.println("connectionPosted> "+posted);
        if (!posted)
        {
          if (debug_>0) System.out.println(" NOT Posted: ClientThreads MAXXED: ");
        }
      }
      catch (IOException e)
      {
        System.out.println(e);
      }
    }
  </pre>
 **/public class JOrbisSocketServer extends ca.bc.webarts.tools.sockets.TCPSocketServer
{
  protected static String clientThreadClassname_ = "ca.bc.webarts.tools.sockets.PirateTunesClientThread";
  protected static JOggPlayerListener player_ = JOggPlayerListener.getInstance();

  /** Default constructor that uses default server and port. **/
  public JOrbisSocketServer()
  {
    super();
    setClientThreadClassname();
  }


  /** Constructor that uses sets a specified server and port. **/
  public JOrbisSocketServer( int portNum)
  {
    super(portNum);
    setClientThreadClassname();
  }


  /** Gets an instantiated ClientThread connected tothe assigned socket. **/
  @Override
  public ClientThread getClientThreadInstance()
  {
    setClientThreadClassname();
    System.out.println("  JOrbisSocketServer: Getting new instance of PirateTunesClientThread");
    PirateTunesClientThread pt = new PirateTunesClientThread(clientSocket_);
    //pt.setPlayer(player_);
    return pt;
  }


  public static void setClientThreadClassname(){setClientThreadClassname(getClientThreadClassname());}


  public static void main(String[] args)
  {
    int portToUse= TCPSocketServer.DEFAULT_PORT;
    if (args.length < 1)
    {
      System.out.println("Usage: java ca.bc.webarts.tools.sockets.JOrbisSocketServer <portNumber>\n" +
                         "       Using DEFAULT port number=" + portToUse);
    }
    else
    {
      System.out.println("JOrbisSocketServer Starting." );
      if (args.length >0)
        try {  portToUse= Integer.valueOf(args[0]).intValue();System.out.println("       Using port number=" + portToUse);}
        catch (Exception ex)
        {
          System.out.println("      ERROR: ya gotta gimme a number to use for the listeningPORT\n      Please try again if you want a non-Defaultport" );
        }
      else
        {
          // use defaults for port
          System.out.println("Usage: java ca.bc.webarts.tools.sockets.JOrbisSocketServer <portNumber>\n" +
                             "       Using DEFAULT port number=" + portToUse);
        }
    }
    JOrbisSocketServer jorbisServer = new JOrbisSocketServer(portToUse);

    int i = 0;
    boolean posted = false;
    while (jorbisServer.getSocket()!=null)
    {
      try
      {
        // Listening  for another client connection
        if (debug_>1) System.out.println("\n*\n*\n*\n  JOrbisSocketServer: Accepting new connections !\n*\n*\n*");
        posted = jorbisServer.postConnection(jorbisServer.getSocket().accept()); // accept blocks until a connection comes in

        //if (debug_>1) System.out.println("connectionPosted> "+posted);
        if (!posted)
        {
          if (debug_>0) System.out.println("   NOT Posted: ClientThreads MAXXED: ");
        }
      }
      catch (IOException e)
      {
        System.out.println(e);
      }
      i++;
    }
    if (debug_>0) System.out.println("Done, Exiting");
  }
}