/*
 *  -*-mode:java; c-basic-offset:2; indent-tabs-mode:nil -*-
 */
/*
 *  TOM Gutwin's fork of...
 *  JOrbisPlayer -- pure Java Ogg Vorbis player
 *
 *  Copyright (C) 2000 ymnk, JCraft,Inc.
 *
 *  Written by: 2000 ymnk<ymnk@jcraft.com>
 *
 *  Many thanks to
 *  Monty <monty@xiph.org> and
 *  The XIPHOPHORUS Company http://www.xiph.org/ .
 *  JOrbis has been based on their awesome works, Vorbis codec and
 *  JOrbisPlayer depends on JOrbis.
 *
 *  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;

import com.jcraft.jogg.*;

import com.jcraft.jorbis.*;
import java.applet.*;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;

import java.util.*;

import javax.sound.midi.*;
import javax.sound.sampled.*;
import javax.swing.*;


/**
 *  Description of the Class
 *
 * @author    tgutwin
 */
public class JOrbisPlayer extends JApplet implements ActionListener, Runnable
{

  /**  Description of the Field */
  final static int BUFSIZE = 4096 * 3;
  /**  Description of the Field */
  private int RETRY = 3;


  /**  Description of the Field */
  static AppletContext acontext = null;
  /**  Description of the Field */
  static int convsize = BUFSIZE * 2;
  /**  Description of the Field */
  static byte[] convbuffer = new byte[convsize];

  /**  Description of the Field */
  public boolean running_as_applet = true;

  /**  Description of the Field */
  Thread player = null;
  /**  Description of the Field */
  InputStream bitStream = null;

  /**  Description of the Field */
  int udp_port = -1;
  /**  Description of the Field */
  String udp_baddress = null;
  /**  Description of the Field */
  int retry = RETRY;

  /**  Description of the Field */
  String playlistfile = "playlist";

  /**  Description of the Field */
  boolean icestats = false;

  /**  Description of the Field */
  SyncState oy;
  /**  Description of the Field */
  StreamState os;
  /**  Description of the Field */
  Page og;
  /**  Description of the Field */
  Packet op;
  /**  Description of the Field */
  Info vi;
  /**  Description of the Field */
  Comment vc;
  /**  Description of the Field */
  DspState vd;
  /**  Description of the Field */
  Block vb;

  /**  Description of the Field */
  byte[] buffer = null;
  /**  Description of the Field */
  int bytes = 0;

  /**  Description of the Field */
  int format;
  /**  Description of the Field */
  int rate = 0;
  /**  Description of the Field */
  int channels = 0;
  /**  Description of the Field */
  int left_vol_scale = 100;
  /**  Description of the Field */
  int right_vol_scale = 100;
  /**  Description of the Field */
  SourceDataLine outputLine = null;
  /**  Description of the Field */
  String current_source = null;

  /**  Description of the Field */
  int frameSizeInBytes;
  /**  Description of the Field */
  int bufferLengthInBytes;

  /**  Description of the Field */
  boolean playonstartup = true;

  boolean playing_ = false;

  public boolean noGui = true;

  /**
     * These variables are used to distinguish stopped, paused, playing states.
     * We need them to control Thread.
     */
    public static final int UNKNOWN = -1;
    public static final int PLAYING = 0;
    public static final int PAUSED = 1;
    public static final int STOPPED = 2;
    public static final int OPENED = 3;
    public static final int SEEKING = 4;
    private int m_status = UNKNOWN;

  /**
   * Description of the Field
   */
  private boolean loopPaused_ = false;
  /**
   * Description of the Field
   */
  boolean timerRunning_ = false;


  /**  Description of the Field */
  public Vector playlist = new Vector();

  /**  Description of the Field */
  JPanel panel;
  /**  Description of the Field */
  JComboBox cb;
  /**  Description of the Field */
  JButton start_button;
  /**  Description of the Field */
  JButton stats_button;


  /**  Constructor for the JOrbisPlayer object */
  public JOrbisPlayer() { }


  /**
   *  The main program for the JOrbisPlayer class
   *
   * @param  arg  The command line arguments
   */
  public static void main(String[] arg)
  {

    JFrame frame = new JFrame("JOrbisPlayer");
    frame.setBackground(Color.lightGray);
    frame.setBackground(Color.white);
    frame.getContentPane().setLayout(new BorderLayout());

    frame.addWindowListener(
      new WindowAdapter()
      {
        public void windowClosing(WindowEvent e)
        {
          System.exit(0);
        }
      });//ende WindowListener

    JOrbisPlayer player = new JOrbisPlayer();
    player.noGui = false;
    player.running_as_applet = false;

    if (arg.length > 0)
    {
      for (int i = 0; i < arg.length; i++)
      {
        player.playlist.addElement(arg[i]);
      }
    }

    player.loadPlaylist();
    player.initUI();

    frame.getContentPane().add(player.panel);
    frame.pack();
    frame.setVisible(true);
    player.start();
  }


  /**
   *  Handles the gui action events
   *
   * @param  e  Description of the Parameter
   */
  public void actionPerformed(ActionEvent e)
  {

    if (e.getSource() == stats_button)
    {
      String item = (String) (cb.getSelectedItem());
      if (!item.startsWith("http://"))
      {
        return;
      }
      if (item.endsWith(".pls"))
      {
        item = fetch_pls(item);
        if (item == null)
        {
          return;
        }
      }
      else if (item.endsWith(".m3u"))
      {
        item = fetch_m3u(item);
        if (item == null)
        {
          return;
        }
      }
      byte[] foo = item.getBytes();
      for (int i = foo.length - 1; i >= 0; i--)
      {
        if (foo[i] == '/')
        {
          item = item.substring(0, i + 1) + "stats.xml";
          break;
        }
      }
      System.out.println(item);
      try
      {
        URL url = null;
        if (running_as_applet)
        {
          url = new URL(getCodeBase(), item);
        }
        else
        {
          url = new URL(item);
        }
        BufferedReader stats = new BufferedReader(new InputStreamReader(url.openConnection().getInputStream()));
        while (true)
        {
          String bar = stats.readLine();
          if (bar == null)
          {
            break;
          }
          System.out.println(bar);
        }
      }
      catch (Exception ee)
      {
        //System.err.println(ee);
      }
      return;
    }

    String command = ((JButton) (e.getSource())).getText();
    if (command.equals("start") && player == null)
    {
      play_sound();
    }
    else if (player != null)
    {
      stop_sound();
    }
  }


  /**
   *  Looks up the JComboBox item and returns the index of the item.
   *
   * @param  item  the combo box item string
   * @return       the index of the item.
   */
  private int item2index(String item)
  {
    for (int i = 0; i < cb.getItemCount(); i++)
    {
      String foo = (String) (cb.getItemAt(i));
      if (item.equals(foo))
      {
        return i;
      }
    }
    cb.addItem(item);
    return cb.getItemCount() - 1;
  }



  /**  Initializes  stuff. */
  public void init()
  {
    running_as_applet = !noGui ;

    if(!noGui) acontext = getAppletContext();

    String s = getParameter("jorbis.player.playlist");
    playlistfile = s;

    s = getParameter("jorbis.player.icestats");
    if (s != null && s.equals("yes"))
    {
      icestats = true;
    }

    loadPlaylist();
    if(!noGui) initUI();

    if (playlist.size() > 0)
    {
      s = getParameter("jorbis.player.playonstartup");
      if (s != null && s.equals("yes"))
      {
        playonstartup = true;
      }
    }

    if(!noGui) setBackground(Color.lightGray);
    //  setBackground(Color.white);
    if(!noGui) getContentPane().setLayout(new BorderLayout());
    if(!noGui) getContentPane().add(panel);
  }


  /**  Description of the Method */
  public void start()
  {
    if(!noGui) super.start();
    //if (playonstartup)
    {
      play_sound();
    }
  }


  /**  Main processing thread method for the JOrbisPlayer object */
  public void run()
  {
    Thread me = Thread.currentThread();
    System.out.println("   >Starting JOrbisPlayer Thread: "+ me.getId());
    int current_index = 0;
    String item = (String) playlist.get(current_index);
    if(cb!=null) item =  (String) (cb.getSelectedItem());
    if(start_button!=null) current_index = item2index(item);
    System.out.println("\n JOrbisPlayer Thread starting to play item: "+item);
    while (true)
    {
      if(cb!=null) item = (String) (cb.getItemAt(current_index));
      if(cb!=null) cb.setSelectedIndex(current_index);
      bitStream = selectSource(item);
      if (bitStream != null)
      {
        if (udp_port != -1)
        {
          play_udp_stream(me);
        }
        else
        {
          play_stream(me);
        }
      }
      if (player != me)
      {
        break;
      }
      bitStream = null;
      current_index++;
      if (current_index >= playlist.size())// cb.getItemCount())
      {
        current_index = 0;
      }
      if (playlist.size() <=0) //  cb.getItemCount() <= 0)
      {
        break;
      }
    }
    player = null;
    if(start_button!=null) start_button.setText("start");
    System.out.println("   <Exitingting JOrbisPlayer Thread: "+ me.getId());
  }


  protected void togglePause()
  {
    if (m_status == PLAYING)      pausePlayback();
    else if (m_status == PAUSED) resumePlayback();
  }


  /**
   * Pauses the playback.<br>
   *
   * Player Status = PAUSED.
   */
  protected void pausePlayback()
  {
      if (outputLine != null)
      {
          if (m_status == PLAYING)
          {
              outputLine.drain();    //flush();
              outputLine.stop();
              m_status = PAUSED;
              //log.info("pausePlayback() completed");
              //notifyEvent(BasicPlayerEvent.PAUSED, getEncodedStreamPosition(), -1, null);
          }
      }
  }

  /**
   * Resumes the playback.<br>
   *
   * Player Status = PLAYING.
   */
  protected void resumePlayback()
  {
      if (outputLine != null)
      {
          if (m_status == PAUSED)
          {
              outputLine.start();
              m_status = PLAYING;
              //log.info("resumePlayback() completed");
              //notifyEvent(BasicPlayerEvent.RESUMED, getEncodedStreamPosition(), -1, null);
          }
      }
  }


  /**
    * Set Method for class field 'loopPaused_'.
    *
    * @param loopPaused is the value to set this class field to.
    *
    **/
  public synchronized void setLoopPaused(boolean loopPaused)
  {
    this.loopPaused_ = loopPaused;
  }  // setLoopPaused Method


  /**
    * Get Method for class field 'loopPaused_'.
    *
    * @return boolean - The value the class field 'loopPaused_'.
    *
    **/
  public synchronized boolean getLoopPaused()
  {
    return loopPaused_;
  }  // getLoopPaused Method


  /**
   *  Gets the title attribute of the JOrbisPlayer object
   *
   * @return    The title value
   */
  public String getTitle()
  {
    return (String) (cb.getSelectedItem());
  }


  /**  Description of the Method */
  public void play_sound()
  {
    if (!noGui && player != null)
    {
      return;
    }
    player = new Thread(this);
    if(start_button!=null) start_button.setText("stop");
    player.start();
    m_status = PLAYING;
  }


  /**
    *  Stop the playback
    *  Player Status = STOPPED.
    **/
  public void stop()
  {
    if (player != null)
    {
      try
      {
        System.out.println(" Closing JOrbisPlayer.outputLines"+ Thread.currentThread().getId());
        outputLine.drain();
        outputLine.stop();
        outputLine.close();
        if (bitStream != null)
        {
          bitStream.close();
        }
      }
      catch (Exception e)
      {
        System.out.println(" error closing JOrbisPlayer output streams: "+e.getMessage());
      }
    }
    player = null;
    m_status = STOPPED;
  }


  /**  Description of the Method */
  public void stop_sound()
  {
    if (!noGui && player == null)
    {
      return;
    }
    player = null;
    m_status = STOPPED;
    if(start_button!=null) start_button.setText("start");
  }


  /**  instantaites all the JOgg streams and states. */
  void init_jorbis()
  {
    oy = new SyncState();
    os = new StreamState();
    og = new Page();
    op = new Packet();

    vi = new Info();
    vc = new Comment();
    vd = new DspState();
    vb = new Block(vd);

    buffer = null;
    bytes = 0;

    oy.init();
  }


  /**
   *  Gets the outputLine attribute of the JOrbisPlayer object
   *
   * @param  channels  Description of the Parameter
   * @param  rate      Description of the Parameter
   * @return           The outputLine value
   */
  SourceDataLine getOutputLine(int channels, int rate)
  {
    if (outputLine == null || this.rate != rate || this.channels != channels)
    {
      if (outputLine != null)
      {
        outputLine.drain();
        outputLine.stop();
        outputLine.close();
      }
      init_audio(channels, rate);
      outputLine.start();
    }
    return outputLine;
  }


  /**
   *  Description of the Method
   *
   * @param  channels  Description of the Parameter
   * @param  rate      Description of the Parameter
   */
  void init_audio(int channels, int rate)
  {
    try
    {
      //ClassLoader originalClassLoader=null;
      //try{
      //  originalClassLoader=Thread.currentThread().getContextClassLoader();
      //  Thread.currentThread().setContextClassLoader(ClassLoader.getSystemClassLoader());
      //}
      //catch(Exception ee){
      //  System.out.println(ee);
      //}
      AudioFormat audioFormat =
          new AudioFormat((float) rate,
          16,
          channels,
          true, // PCM_Signed
      false// littleEndian
      );
      DataLine.Info info =
          new DataLine.Info(SourceDataLine.class,
          audioFormat,
          AudioSystem.NOT_SPECIFIED);
      if (!AudioSystem.isLineSupported(info))
      {
        //System.out.println("Line " + info + " not supported.");
        return;
      }

      try
      {
        outputLine = (SourceDataLine) AudioSystem.getLine(info);
        //outputLine.addLineListener(this);
        outputLine.open(audioFormat);
      }
      catch (LineUnavailableException ex)
      {
        System.out.println("Unable to open the sourceDataLine: " + ex);
        return;
      }
      catch (IllegalArgumentException ex)
      {
        System.out.println("Illegal Argument: " + ex);
        return;
      }

      frameSizeInBytes = audioFormat.getFrameSize();
      int bufferLengthInFrames = outputLine.getBufferSize() / frameSizeInBytes / 2;
      bufferLengthInBytes = bufferLengthInFrames * frameSizeInBytes;

      //buffer = new byte[bufferLengthInBytes];
      //if(originalClassLoader!=null)
      //  Thread.currentThread().setContextClassLoader(originalClassLoader);

      this.rate = rate;
      this.channels = channels;
    }
    catch (Exception ee)
    {
      System.out.println(ee);
    }
  }


  /**
   *  Description of the Method
   *
   * @param  item  Description of the Parameter
   * @return       Description of the Return Value
   */
  InputStream selectSource(String item)
  {
    if (item.endsWith(".pls"))
    {
      item = fetch_pls(item);
      if (item == null)
      {
        return null;
      }
      //System.out.println("fetch: "+item);
    }
    else if (item.endsWith(".m3u"))
    {
      item = fetch_m3u(item);
      if (item == null)
      {
        return null;
      }
      //System.out.println("fetch: "+item);
    }

    if (!item.endsWith(".ogg"))
    {
      return null;
    }

    InputStream is = null;
    URLConnection urlc = null;
    try
    {
      URL url = null;
      if (running_as_applet)
      {
        url = new URL(getCodeBase(), item);
      }
      else
      {
        url = new URL(item);
      }
      urlc = url.openConnection();
      is = urlc.getInputStream();
      current_source = url.getProtocol() + "://" + url.getHost() + ":" + url.getPort() + url.getFile();
    }
    catch (Exception ee)
    {
      System.err.println(ee);
    }

    if (is == null && !running_as_applet)
    {
      try
      {
        is = new FileInputStream( //System.getProperty("user.dir") +
                                  //System.getProperty("file.separator") +
                                  item);
        current_source = null;
      }
      catch (Exception ee)
      {
        System.err.println(ee);
      }
    }

    if (is == null)
    {
      return null;
    }

    System.out.println("Select: " + item);
    {
      boolean find = false;
      for (int i = 0; i < playlist.size(); i++)
      {
        String foo = (String) (playlist.get(i));
        if (item.equals(foo))
        {
          find = true;
          break;
        }
      }
      //if (!find)
      // {
      //  cb.addItem(item);
      //}
    }

    int i = 0;
    String s = null;
    String t = null;
    udp_port = -1;
    udp_baddress = null;
    while (urlc != null && true)
    {
      s = urlc.getHeaderField(i);
      t = urlc.getHeaderFieldKey(i);
      if (s == null)
      {
        break;
      }
      i++;
      if (t != null && t.equals("udp-port"))
      {
        try
        {
          udp_port = Integer.parseInt(s);
        }
        catch (Exception ee)
        {
          System.err.println(ee);
        }
      }
      else if (t != null && t.equals("udp-broadcast-address"))
      {
        udp_baddress = s;
      }
    }
    return is;
  }


  /**
   *  Description of the Method
   *
   * @param  pls  Description of the Parameter
   * @return      Description of the Return Value
   */
  String fetch_pls(String pls)
  {
    InputStream pstream = null;
    if (pls.startsWith("http://"))
    {
      try
      {
        URL url = null;
        if (running_as_applet)
        {
          url = new URL(getCodeBase(), pls);
        }
        else
        {
          url = new URL(pls);
        }
        URLConnection urlc = url.openConnection();
        pstream = urlc.getInputStream();
      }
      catch (Exception ee)
      {
        System.err.println(ee);
        return null;
      }
    }
    if (pstream == null && !running_as_applet)
    {
      try
      {
        pstream = new FileInputStream( //System.getProperty("user.dir") +
                                       //System.getProperty("file.separator") +
                                       pls);
      }
      catch (Exception ee)
      {
        System.err.println(ee);
        return null;
      }
    }

    String line = null;
    while (true)
    {
      try
      {
        line = readline(pstream);
      }
      catch (Exception e)
      {}
      if (line == null)
      {
        break;
      }
      if (line.startsWith("File1="))
      {
        byte[] foo = line.getBytes();
        int i = 6;
        for (; i < foo.length; i++)
        {
          if (foo[i] == 0x0d)
          {
            break;
          }
        }
        return line.substring(6, i);
      }
    }
    return null;
  }


  /**
   *  Description of the Method
   *
   * @param  m3u  Description of the Parameter
   * @return      Description of the Return Value
   */
  String fetch_m3u(String m3u)
  {
    InputStream pstream = null;
    if (m3u.startsWith("http://"))
    {
      try
      {
        URL url = null;
        if (running_as_applet)
        {
          url = new URL(getCodeBase(), m3u);
        }
        else
        {
          url = new URL(m3u);
        }
        URLConnection urlc = url.openConnection();
        pstream = urlc.getInputStream();
      }
      catch (Exception ee)
      {
        System.err.println(ee);
        return null;
      }
    }
    if (pstream == null && !running_as_applet)
    {
      try
      {
        pstream = new FileInputStream( //System.getProperty("user.dir") +
                                       //System.getProperty("file.separator") +
                                       m3u);
      }
      catch (Exception ee)
      {
        System.err.println(ee);
        return null;
      }
    }

    String line = null;
    while (true)
    {
      try
      {
        line = readline(pstream);
      }
      catch (Exception e)
      {}
      if (line == null)
      {
        break;
      }
      return line;
    }
    return null;
  }


  /**  Description of the Method */
  public void loadPlaylist()
  {
    if (running_as_applet)
    {
      String s = null;
      for (int i = 0; i < 10; i++)
      {
        s = getParameter("jorbis.player.play." + i);
        if (s == null)
        {
          break;
        }
        playlist.addElement(s);
      }
    }

    if (playlistfile == null)
    {
      return;
    }

    try
    {
      InputStream is = null;
      try
      {
        URL url = null;
        if (running_as_applet)
        {
          url = new URL(getCodeBase(), playlistfile);
        }
        else
        {
          url = new URL(playlistfile);
        }
        URLConnection urlc = url.openConnection();
        is = urlc.getInputStream();
      }
      catch (Exception ee)
      {}
      if (is == null && !running_as_applet)
      {
        try
        {
          is = new FileInputStream(  //System.getProperty("user.dir") +
                                     //System.getProperty("file.separator") +
                                     playlistfile);
        }
        catch (Exception ee)
        {}
      }

      if (is == null)
      {
        return;
      }

      while (true)
      {
        String line = readline(is);
        if (line == null)
        {
          break;
        }
        byte[] foo = line.getBytes();
        for (int i = 0; i < foo.length; i++)
        {
          if (foo[i] == 0x0d)
          {
            line = new String(foo, 0, i);
            break;
          }
        }
        playlist.addElement(line);
      }
    }
    catch (Exception e)
    {
      System.out.println(e);
    }
  }


  /**  Gets all the GUI panel and buttons init. */
  void initUI()
  {
    panel = new JPanel();

    cb = new JComboBox(playlist);
    cb.setEditable(true);
    panel.add(cb);

    start_button = new JButton("start");
    start_button.addActionListener(this);
    panel.add(start_button);

    if (icestats)
    {
      stats_button = new JButton("IceStats");
      stats_button.addActionListener(this);
      panel.add(stats_button);
    }
  }


  /**
   *  Description of the Method
   *
   * @param  me  Description of the Parameter
   */
  private void play_stream(Thread me)
  {
    int last_channels = -1;
    int last_rate = -1;

    boolean chained = false;

    init_jorbis();

    retry = RETRY;

    System.out.println("play_stream>");

    loop :
    while (true)
    {
      int eos = 0;

      int index = oy.buffer(BUFSIZE);
      buffer = oy.data;
      try
      {
        bytes = bitStream.read(buffer, index, BUFSIZE);
      }
      catch (Exception e)
      {
        System.err.println(e);
        return;
      }
      oy.wrote(bytes);

      if (chained)
      {//
        chained = false;//
      }//
      else
      {//
        if (oy.pageout(og) != 1)
        {
          if (bytes < BUFSIZE)
          {
            break;
          }
          System.err.println("Input does not appear to be an Ogg bitstream.");
          return;
        }
      }//
      os.init(og.serialno());
      os.reset();

      vi.init();
      vc.init();

      if (os.pagein(og) < 0)
      {
        // error; stream version mismatch perhaps
        System.err.println("Error reading first page of Ogg bitstream data.");
        return;
      }

      retry = RETRY;

      if (os.packetout(op) != 1)
      {
        // no page? must not be vorbis
        System.err.println("Error reading initial header packet.");
        break;
        //      return;
      }

      if (vi.synthesis_headerin(vc, op) < 0)
      {
        // error case; not a vorbis header
        System.err.println("This Ogg bitstream does not contain Vorbis audio data.");
        return;
      }

      int i = 0;

      while (i < 2)
      {
        while (i < 2)
        {
          int result = oy.pageout(og);
          if (result == 0)
          {
            break;
          }// Need more data
          if (result == 1)
          {
            os.pagein(og);
            while (i < 2)
            {
              result = os.packetout(op);
              if (result == 0)
              {
                break;
              }
              if (result == -1)
              {
                System.err.println("Corrupt secondary header.  Exiting.");
                //return;
                break loop;
              }
              vi.synthesis_headerin(vc, op);
              i++;
            }
          }
        }

        index = oy.buffer(BUFSIZE);
        buffer = oy.data;
        try
        {
          bytes = bitStream.read(buffer, index, BUFSIZE);
        }
        catch (Exception e)
        {
          System.err.println(e);
          return;
        }
        if (bytes == 0 && i < 2)
        {
          System.err.println("End of file before finding all Vorbis headers!");
          return;
        }
        oy.wrote(bytes);
      }
      {
        byte[][] ptr = vc.user_comments;
        StringBuffer sb = null;
        if (acontext != null)
        {
          sb = new StringBuffer();
        }

        String currComment = "";
        String coverImage = "";
        for (int j = 0; j < ptr.length; j++)
        {
          if (ptr[j] == null)
          {
            break;
          }
          currComment = new String(ptr[j], 0, ptr[j].length - 1);
          if(currComment.length()<"METADATA_BLOCK_PICTURE".length() ||
             !"METADATA_BLOCK_PICTURE".equalsIgnoreCase(currComment.substring(0,"METADATA_BLOCK_PICTURE".length()) ))
            System.out.println("Comment: " +currComment );
          else
          {
            coverImage = currComment;
            System.out.println("Comment: " +"METADATA_BLOCK_PICTURE="+"imageData..." );
          }
          if (sb != null)
          {
            sb.append(" " + new String(ptr[j], 0, ptr[j].length - 1));
          }
        }
        System.out.println("Bitstream is " + vi.channels + " channel, " + vi.rate + "Hz");
        if(vc!=null&& vc.vendor!=null)
          System.out.println("Encoded by: " + new String(vc.vendor, 0, vc.vendor.length - 1) + "\n");
        if (sb != null)
        {
          acontext.showStatus(sb.toString());
        }
      }

      convsize = BUFSIZE / vi.channels;

      vd.synthesis_init(vi);
      vb.init(vd);

      double[][][] _pcm = new double[1][][];
      float[][][] _pcmf = new float[1][][];
      int[] _index = new int[vi.channels];

      getOutputLine(vi.channels, vi.rate);

      System.out.print("    Decoding ");

      while (eos == 0)
      {
        while (eos == 0)
        {

          if (false && player != me)
          {
            System.err.println("player!=me bye.");
            try
            {
              //outputLine.drain();
              //outputLine.stop();
              //outputLine.close();
              bitStream.close();
            }
            catch (Exception ee)
            {}
            return;
          }

          int result = oy.pageout(og);
          if (result == 0)
          {
            break;
          }// need more data
          if (result == -1)
          {
            // missing or corrupt data at this page position
                  System.err.println("Corrupt or missing data in bitstream; continuing...");
          }
          else
          {
            os.pagein(og);

            if (og.granulepos() == 0)
            {//
              chained = true;//
              eos = 1;//
              break;//
            }//

            while (true)
            {
              result = os.packetout(op);
              if (result == 0)
              {
                break;
              }// need more data
              if (result == -1)
              {// missing or corrupt data at this page position
                // no reason to complain; already complained above

                System.err.println("no reason to complain; already complained above");
              }
              else
              {
                // we have a packet.  Decode it
                int samples;
                if (vb.synthesis(op) == 0)
                {// test for success!
                  vd.synthesis_blockin(vb);
                }
                while ((samples = vd.synthesis_pcmout(_pcmf, _index)) > 0)
                {
                  //System.out.print(".");
                  double[][] pcm = _pcm[0];
                  float[][] pcmf = _pcmf[0];
                  boolean clipflag = false;
                  int bout = (samples < convsize ? samples : convsize);

                  // convert doubles to 16 bit signed ints (host order) and
                  // interleave
                  for (i = 0; i < vi.channels; i++)
                  {
                    int ptr = i * 2;
                    //int ptr=i;
                    int mono = _index[i];
                    for (int j = 0; j < bout; j++)
                    {
                      int val = (int) (pcmf[i][mono + j] * 32767.);
                      if (val > 32767)
                      {
                        val = 32767;
                        clipflag = true;
                      }
                      if (val < -32768)
                      {
                        val = -32768;
                        clipflag = true;
                      }
                      if (val < 0)
                      {
                        val = val | 0x8000;
                      }
                      convbuffer[ptr] = (byte) (val);
                      convbuffer[ptr + 1] = (byte) (val >>> 8);
                      ptr += 2 * (vi.channels);
                    }
                  }
                  outputLine.write(convbuffer, 0, 2 * vi.channels * bout);
                  vd.synthesis_read(bout);
                }
                // Pause the stream
                while (getLoopPaused())
                {
                  ca.bc.webarts.widgets.Util.sleep(250);
                }
              }
            }
            if (og.eos() != 0)
            {
              eos = 1;
            }
          }
          //System.out.print(">>>");
        }
        //System.out.println("!");

        if (eos == 0)
        {
          index = oy.buffer(BUFSIZE);
          buffer = oy.data;
          try
          {
            bytes = bitStream.read(buffer, index, BUFSIZE);
          }
          catch (Exception e)
          {
            System.err.println(e);
            return;
          }
          if (bytes == -1)
          {
            //System.err.println("bytes==-1");
            break;
          }
          oy.wrote(bytes);
          if (bytes == 0)
          {
            eos = 1;
          }
        }
      }
      System.out.println("DONE Decoding ");

      //if(bytes==-1){
      //  retry--;
      //  if(retry!=0 && current_source!=null){
      //    System.out.println("Connection is dropped. Retry("+retry+")");
      //    init_jorbis();
      //    try { if(bitStream!=null)bitStream.close(); }
      //    catch(Exception e) { System.out.println(e); }
      //    try{Thread.sleep(1000);}
      //    catch(Exception e) { }
      //    try{
      //      URL url=new URL(current_source);
      //      URLConnection urlc=url.openConnection();
      //      bitStream=urlc.getInputStream();
      //      continue;
      //    }
      //    catch(Exception e){
      //      retry=0;
      //    }
      //  }
      //}

      os.clear();
      vb.clear();
      vd.clear();
      vi.clear();
    }

    oy.clear();

    //System.out.println("play_stream<");
    //System.err.println("Done.");

    try
    {
      if (bitStream != null)
      {
        bitStream.close();
      }
    }
    catch (Exception e)
    {}
  }


  /**
   *  Description of the Method
   *
   * @param  me  Description of the Parameter
   */
  private void play_udp_stream(Thread me)
  {
    init_jorbis();

    boolean firstloop = true;

    try
    {
      loop :
      while (true)
      {
        int eos = 0;
        int index = oy.buffer(BUFSIZE);
        buffer = oy.data;
        try
        {
          bytes = bitStream.read(buffer, index, BUFSIZE);
        }
        catch (Exception e)
        {
          System.err.println(e);
          return;
        }

        oy.wrote(bytes);
        if (oy.pageout(og) != 1)
        {
//        if(bytes<BUFSIZE)break;
          System.err.println("Input does not appear to be an Ogg bitstream.");
          return;
        }

        os.init(og.serialno());
        os.reset();

        vi.init();
        vc.init();
        if (os.pagein(og) < 0)
        {
          // error; stream version mismatch perhaps
          System.err.println("Error reading first page of Ogg bitstream data.");
          return;
        }

        if (os.packetout(op) != 1)
        {
          // no page? must not be vorbis
          System.err.println("Error reading initial header packet.");
//        break;
          return;
        }

        if (vi.synthesis_headerin(vc, op) < 0)
        {
          // error case; not a vorbis header
          System.err.println("This Ogg bitstream does not contain Vorbis audio data.");
          return;
        }

        int i = 0;
        while (i < 2)
        {
          while (i < 2)
          {
            int result = oy.pageout(og);
            if (result == 0)
            {
              break;
            }// Need more data
            if (result == 1)
            {
              os.pagein(og);
              while (i < 2)
              {
                result = os.packetout(op);
                if (result == 0)
                {
                  break;
                }
                if (result == -1)
                {
                  System.err.println("Corrupt secondary header.  Exiting.");
                  //return;
                  break loop;
                }
                vi.synthesis_headerin(vc, op);
                i++;
              }
            }
          }

          if (i == 2)
          {
            break;
          }

          index = oy.buffer(BUFSIZE);
          buffer = oy.data;
          try
          {
            bytes = bitStream.read(buffer, index, BUFSIZE);
          }
          catch (Exception e)
          {
            System.err.println(e);
            return;
          }
          if (bytes == 0 && i < 2)
          {
            System.err.println("End of file before finding all Vorbis headers!");
            return;
          }
          oy.wrote(bytes);
        }
        break;
      }
    }
    catch (Exception e)
    {
    }

    try
    {
      bitStream.close();
    }
    catch (Exception e)
    {}

    UDPIO io = null;
    try
    {
      io = new UDPIO(udp_port);
    }
    catch (Exception e)
    {
      return;
    }

    bitStream = io;
    play_stream(me);

    /*
     *  oy.init();
     *  loop:
     *  while(true){
     *  int eos=0;
     *  int index=oy.buffer(BUFSIZE);
     *  buffer=oy.data;
     *  try{ bytes=io.getByte(buffer, index, BUFSIZE); }
     *  catch(Exception e){
     *  System.err.println(e);
     *  return;
     *  }
     *  oy.wrote(bytes);
     *  if(!firstloop){
     *  if(oy.pageout(og)!=1){
     *  if(bytes<BUFSIZE)break;
     *  System.err.println("Input does not appear to be an Ogg bitstream.");
     *  return;
     *  }
     *  os.init(og.serialno());
     *  os.reset();
     *  vi.init();
     *  vc.init();
     *  if(os.pagein(og)<0){
     *  / error; stream version mismatch perhaps
     *  System.err.println("Error reading first page of Ogg bitstream data.");
     *  return;
     *  }
     *  if(os.packetout(op)!=1){
     *  / no page? must not be vorbis
     *  System.err.println("Error reading initial header packet.");
     *  break;
     *  /      return;
     *  }
     *  if(vi.synthesis_headerin(vc, op)<0){
     *  / error case; not a vorbis header
     *  System.err.println("This Ogg bitstream does not contain Vorbis audio data.");
     *  return;
     *  }
     *  int i=0;
     *  while(i<2){
     *  while(i<2){
     *  int result=oy.pageout(og);
     *  if(result==0) break; // Need more data
     *  if(result==1){
     *  os.pagein(og);
     *  while(i<2){
     *  result=os.packetout(op);
     *  if(result==0)break;
     *  if(result==-1){
     *  System.err.println("Corrupt secondary header.  Exiting.");
     *  /return;
     *  break loop;
     *  }
     *  vi.synthesis_headerin(vc, op);
     *  i++;
     *  }
     *  }
     *  }
     *  index=oy.buffer(BUFSIZE);
     *  buffer=oy.data;
     *  try{ bytes=io.getByte(buffer, index, BUFSIZE); }
     *  catch(Exception e){
     *  System.err.println(e);
     *  return;
     *  }
     *  if(bytes==0 && i<2){
     *  System.err.println("End of file before finding all Vorbis headers!");
     *  return;
     *  }
     *  oy.wrote(bytes);
     *  }
     *  }
     *  else{
     *  firstloop=false;
     *  }
     *  {
     *  byte[][] ptr=vc.user_comments;
     *  StringBuffer sb=null;
     *  if(acontext!=null) sb=new StringBuffer();
     *  for(int j=0; j<ptr.length;j++){
     *  if(ptr[j]==null) break;
     *  System.err.println("Comment: "+new String(ptr[j], 0, ptr[j].length-1));
     *  if(sb!=null)sb.append(" "+new String(ptr[j], 0, ptr[j].length-1));
     *  }
     *  System.err.println("Bitstream is "+vi.channels+" channel, "+vi.rate+"Hz");
     *  System.err.println("Encoded by: "+new String(vc.vendor, 0, vc.vendor.length-1)+"\n");
     *  if(sb!=null)acontext.showStatus(sb.toString());
     *  }
     *  convsize=BUFSIZE/vi.channels;
     *  vd.synthesis_init(vi);
     *  vb.init(vd);
     *  double[][][] _pcm=new double[1][][];
     *  float[][][] _pcmf=new float[1][][];
     *  int[] _index=new int[vi.channels];
     *  getOutputLine(vi.channels, vi.rate);
     *  while(eos==0){
     *  while(eos==0){
     *  if(player!=me){
     *  /System.err.println("bye.");
     *  try{
     *  /outputLine.drain();
     *  /outputLine.stop();
     *  /outputLine.close();
     *  io.close();
     *  }
     *  catch(Exception ee){}
     *  return;
     *  }
     *  int result=oy.pageout(og);
     *  if(result==0)break; // need more data
     *  if(result==-1){ // missing or corrupt data at this page position
     *  /           System.err.println("Corrupt or missing data in io; continuing...");
     *  }
     *  else{
     *  os.pagein(og);
     *  while(true){
     *  result=os.packetout(op);
     *  if(result==0)break; // need more data
     *  if(result==-1){ // missing or corrupt data at this page position
     *  / no reason to complain; already complained above
     *  }
     *  else{
     *  / we have a packet.  Decode it
     *  int samples;
     *  if(vb.synthesis(op)==0){ // test for success!
     *  vd.synthesis_blockin(vb);
     *  }
     *  while((samples=vd.synthesis_pcmout(_pcmf, _index))>0){
     *  double[][] pcm=_pcm[0];
     *  float[][] pcmf=_pcmf[0];
     *  boolean clipflag=false;
     *  int bout=(samples<convsize?samples:convsize);
     *  / convert doubles to 16 bit signed ints (host order) and
     *  / interleave
     *  for(int i=0;i<vi.channels;i++){
     *  int ptr=i*2;
     *  /int ptr=i;
     *  int mono=_index[i];
     *  for(int j=0;j<bout;j++){
     *  int val=(int)(pcmf[i][mono+j]*32767.);
     *  if(val>32767){
     *  val=32767;
     *  clipflag=true;
     *  }
     *  if(val<-32768){
     *  val=-32768;
     *  clipflag=true;
     *  }
     *  if(val<0) val=val|0x8000;
     *  convbuffer[ptr]=(byte)(val);
     *  convbuffer[ptr+1]=(byte)(val>>>8);
     *  ptr+=2*(vi.channels);
     *  }
     *  }
     *  outputLine.write(convbuffer, 0, 2*vi.channels*bout);
     *  vd.synthesis_read(bout);
     *  }
     *  }
     *  }
     *  if(og.eos()!=0)eos=1;
     *  }
     *  }
     *  if(eos==0){
     *  index=oy.buffer(BUFSIZE);
     *  buffer=oy.data;
     *  try{  bytes=io.getByte(buffer,index,BUFSIZE); }
     *  catch(Exception e){
     *  System.err.println(e);
     *  return;
     *  }
     *  if(bytes==-1) break;
     *  oy.wrote(bytes);
     *  if(bytes==0)eos=1;
     *  }
     *  }
     *  os.clear();
     *  vb.clear();
     *  vd.clear();
     *  vi.clear();
     *  }
     *  oy.clear();
     *  /System.err.println("Done.");
     *  try {
     *  if(io!=null)io.close();
     *  }
     *  catch(Exception e) { }
     */
  }


  /**
   *  Description of the Method
   *
   * @param  is  Description of the Parameter
   * @return     Description of the Return Value
   */
  private String readline(InputStream is)
  {
    StringBuffer rtn = new StringBuffer();
    int temp;
    do
    {
      try
      {
        temp = is.read();
      }
      catch (Exception e)
      {
        return (null);
      }
      if (temp == -1)
      {
        return (null);
      }
      if (temp != 0 && temp != '\n')
      {
        rtn.append((char) temp);
      }
    } while (temp != '\n');
    return (rtn.toString());
  }


  /**
   *  Description of the Class
   *
   * @author    tgutwin
   */
  class UDPIO extends InputStream
  {
    /**  Description of the Field */
    InetAddress address;
    /**  Description of the Field */
    DatagramSocket socket = null;
    /**  Description of the Field */
    DatagramPacket sndpacket;
    /**  Description of the Field */
    DatagramPacket recpacket;
    /**  Description of the Field */
    byte[] buf = new byte[1024];
    //String host;
    /**  Description of the Field */
    int port;
    /**  Description of the Field */
    byte[] inbuffer = new byte[2048];
    /**  Description of the Field */
    byte[] outbuffer = new byte[1024];
    /**  Description of the Field */
    int instart = 0, inend = 0, outindex = 0;


    /**
     *  Constructor for the UDPIO object
     *
     * @param  port  Description of the Parameter
     */
    UDPIO(int port)
    {
      //this.host="192.168.1.2";
      this.port = port;
      try
      {
        socket = new DatagramSocket(port);
      }
      catch (Exception e)
      {
        System.err.println(e);
      }
      recpacket = new DatagramPacket(buf, 1024);
//    sndpacket=new DatagramPacket(outbuffer, 0, address, port);
    }


    /**
     *  Description of the Method
     *
     * @exception  java.io.IOException  Description of the Exception
     */
    public void close()
      throws java.io.IOException
    {
      socket.close();
    }


    /**
     *  Description of the Method
     *
     * @return                          Description of the Return Value
     * @exception  java.io.IOException  Description of the Exception
     */
    public int read()
      throws java.io.IOException
    {
      return 0;
    }


    /**
     *  Description of the Method
     *
     * @param  array                    Description of the Parameter
     * @param  begin                    Description of the Parameter
     * @param  length                   Description of the Parameter
     * @return                          Description of the Return Value
     * @exception  java.io.IOException  Description of the Exception
     */
    public int read(byte[] array, int begin, int length)
      throws java.io.IOException
    {
      return getByte(array, begin, length);
    }


    /**
     *  Sets the timeout attribute of the UDPIO object
     *
     * @param  i  The new timeout value
     */
    void setTimeout(int i)
    {
      try
      {
        socket.setSoTimeout(i);
      }
      catch (Exception e)
      {
        System.out.println(e);
      }
    }


    /**
     *  Gets the byte attribute of the UDPIO object
     *
     * @return                          The byte value
     * @exception  java.io.IOException  Description of the Exception
     */
    int getByte()
      throws java.io.IOException
    {
      if ((inend - instart) < 1)
      {
        read(1);
      }
      return inbuffer[instart++] & 0xff;
    }


    /**
     *  Gets the byte attribute of the UDPIO object
     *
     * @param  array                    Description of the Parameter
     * @return                          The byte value
     * @exception  java.io.IOException  Description of the Exception
     */
    int getByte(byte[] array)
      throws java.io.IOException
    {
      return getByte(array, 0, array.length);
    }


    /**
     *  Gets the byte attribute of the UDPIO object
     *
     * @param  array                    Description of the Parameter
     * @param  begin                    Description of the Parameter
     * @param  length                   Description of the Parameter
     * @return                          The byte value
     * @exception  java.io.IOException  Description of the Exception
     */
    int getByte(byte[] array, int begin, int length)
      throws java.io.IOException
    {
      int i = 0;
      int foo = begin;
      while (true)
      {
        if ((i = (inend - instart)) < length)
        {
          if (i != 0)
          {
            System.arraycopy(inbuffer, instart, array, begin, i);
            begin += i;
            length -= i;
            instart += i;
          }
          read(length);
          continue;
        }
        System.arraycopy(inbuffer, instart, array, begin, length);
        instart += length;
        break;
      }
      return begin + length - foo;
    }


    /**
     *  Gets the short attribute of the UDPIO object
     *
     * @return                          The short value
     * @exception  java.io.IOException  Description of the Exception
     */
    int getShort()
      throws java.io.IOException
    {
      if ((inend - instart) < 2)
      {
        read(2);
      }
      int s = 0;
      s = inbuffer[instart++] & 0xff;
      s = ((s << 8) & 0xffff) | (inbuffer[instart++] & 0xff);
      return s;
    }


    /**
     *  Gets the int attribute of the UDPIO object
     *
     * @return                          The int value
     * @exception  java.io.IOException  Description of the Exception
     */
    int getInt()
      throws java.io.IOException
    {
      if ((inend - instart) < 4)
      {
        read(4);
      }
      int i = 0;
      i = inbuffer[instart++] & 0xff;
      i = ((i << 8) & 0xffff) | (inbuffer[instart++] & 0xff);
      i = ((i << 8) & 0xffffff) | (inbuffer[instart++] & 0xff);
      i = (i << 8) | (inbuffer[instart++] & 0xff);
      return i;
    }


    /**
     *  Gets the pad attribute of the UDPIO object
     *
     * @param  n                        Description of the Parameter
     * @exception  java.io.IOException  Description of the Exception
     */
    void getPad(int n)
      throws java.io.IOException
    {
      int i;
      while (n > 0)
      {
        if ((i = inend - instart) < n)
        {
          n -= i;
          instart += i;
          read(n);
          continue;
        }
        instart += n;
        break;
      }
    }


    /**
     *  Description of the Method
     *
     * @param  n                        Description of the Parameter
     * @exception  java.io.IOException  Description of the Exception
     */
    void read(int n)
      throws java.io.IOException
    {
      if (n > inbuffer.length)
      {
        n = inbuffer.length;
      }
      instart = inend = 0;
      int i;
      while (true)
      {
        recpacket.setData(buf, 0, 1024);
        socket.receive(recpacket);

        i = recpacket.getLength();
        System.arraycopy(recpacket.getData(), 0, inbuffer, inend, i);
        if (i == -1)
        {
          throw new java.io.IOException();
        }
        inend += i;
        break;
      }
    }
  }
}