jroar.java

java ogg player library. for play back ogg audio

/* -*-mode:java; c-basic-offset:2; -*- */
/* JRoar -- pure Java streaming server for Ogg 
 *
 * Copyright (C) 2001,2002 ymnk, JCraft,Inc.
 *
 * Written by: 2001,2002 ymnk<[e-mail]>
 *
 * 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 com.jcraft.jroar;
import java.util.*;
import java.net.*;
import java.io.*;
import java.awt.*;
import java.awt.event.*;
import java.applet.*;

import com.jcraft.jogg.*;

public class JRoar extends Applet implements Runnable{
  static final String version="0.0.9";

  static boolean running_as_applet=true;
  static java.net.URL codebase=null;
//  static String passwd="passssap";
  static String passwd=null;
//static String icepasswd="changeme";
  static String icepasswd=null;
  static String comment=null;

  static java.util.Vector mplisteners=new java.util.Vector();

  Button mount;

  public JRoar(){
  }

  public void init(){
    String s;

    codebase=getCodeBase();

    s=getParameter("jroar.port");
    if(s!=null){
      try{ HttpServer.port=Integer.parseInt(s); }
      catch(Exception e){}
    }

//  s=getParameter("jroar.ipaddress");
//  HttpServer.myaddress=s;

    s=getParameter("jroar.myaddress");
    HttpServer.myaddress=s;

    s=getParameter("jroar.passwd");
    if(s!=null) JRoar.passwd=s;

    s=getParameter("jroar.icepasswd");
    if(s!=null) JRoar.icepasswd=s;

    s=getParameter("jroar.comment");
    if(s!=null) JRoar.comment=s;

    add(mount = new Button("Control"));

    mount.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {
        try{
          getAppletContext().showStatus("Opening "+HttpServer.myURL+"/ctrl.html");
          URL url=new URL(HttpServer.myURL+"/ctrl.html");
          getAppletContext().showDocument(url, "_blank");
	}
	catch(Exception ee){System.out.println(ee);}
      }
    });
    setBackground(Color.white);
    (new Thread(this)).start();
  }

  static WatchDog wd=null;

  public void run(){
    HttpServer httpServer=new HttpServer();
    httpServer.start();

    wd=new WatchDog();
    wd.start();
  }

  public static void main(String[] arg){
    String[] usage={
	"  acceptable options",
	"  -port     port-number (default: 8000)",
        "  -myaddress my-address", 
	"  -relay    mount-point url-of-source [limit]",
	"  -playlist mount-point filename [limit]", 
	"  -page     page-name class-name", 
	"  -store    page-name URL", 
	"  -passwd   password-for-web-interface",
	"  -icepasswd password-for-ICE",
	"  -mplistener class-name",
	"  -shout    src-mount-point ip-address port-number password  dst-mount-point",
	"  -udp      src-mount-point broadcast-address port-number dst-mount-point",
	"  -peercast-host peercast-lookup-host (default: localhost:7144)"
    };

    running_as_applet=false;

    HttpServer.myaddress=null;
    for(int i=0; i<arg.length; i++){
      if(arg[i].equals("-port") && arg.length>i+1){
        try{ HttpServer.port=Integer.parseInt(arg[i+1]);}
	catch(Exception e){}
	i++;
      }
//    else if(arg[i].equals("-ipaddress") && arg.length>i+1){
//      HttpServer.myaddress=arg[i+1];
//      i++;
//    }
      else if(arg[i].equals("-myaddress") && arg.length>i+1){
        HttpServer.myaddress=arg[i+1];
        i++;
      }
      else if(arg[i].equals("-passwd") && arg.length>i+1){
        JRoar.passwd=arg[i+1];
        i++;
      }
      else if(arg[i].equals("-icepasswd") && arg.length>i+1){
        JRoar.icepasswd=arg[i+1];
        i++;
      }
      else if(arg[i].equals("-comment") && arg.length>i+1){
        JRoar.comment=arg[i+1];
        i++;
      }
      else if((arg[i].equals("-relay") || arg[i].equals("-proxy")) &&
	      arg.length>i+2){
        Proxy proxy=new Proxy(arg[i+1], arg[i+2]);
        i+=2;
        if(arg.length>i+1 && !(arg[i+1].startsWith("-"))){
          try{ proxy.setLimit(Integer.parseInt(arg[i+1])); }
          catch(Exception e){
	  }
          i++;
	}
      }
      else if(arg[i].equals("-playlist") && arg.length>i+2){
        PlayFile p=new PlayFile(arg[i+1], arg[i+2]);
        i+=2;
        if(arg.length>i+1 && !(arg[i+1].startsWith("-"))){
          try{ p.setLimit(Integer.parseInt(arg[i+1])); }
          catch(Exception e){
	  }
          i++;
	}
        p.kick();
      }
      else if(arg[i].equals("-udp") && arg.length>i+4){
        int port=0;
        try{ port=Integer.parseInt(arg[i+3]);}
  	catch(Exception e){System.err.println(e);}
        UDPBroadcast u=new UDPBroadcast(arg[i+1], // src mount point
                                        arg[i+2], // broadcast address
					port,     // port number
					arg[i+4]);// dst mount point
        i+=4;
      }
      else if(arg[i].equals("-shout") && arg.length>i+5){
        int port=0;
        try{ port=Integer.parseInt(arg[i+3]);}
  	catch(Exception e){System.err.println(e);}
        ShoutClient sc=new ShoutClient(arg[i+1], // src mount point
                                       arg[i+2], // dst ip address
                                       port,     // dst port number
				       arg[i+4], // passwd
				       arg[i+5]);// dst mount point
        i+=5;
      }
      else if(arg[i].equals("-page") && arg.length>i+2){
        try{
          Class classObject=Class.forName(arg[i+2]);
          Page.register(arg[i+1], arg[i+2]);
        }
        catch(Exception e){
          System.err.println("Unknown class: "+arg[i+2]);
        }
        i+=2;
      }
      else if(arg[i].equals("-store") && arg.length>i+2){
        try{
          new Store(arg[i+1], arg[i+2]);
        }
        catch(Exception e){
//        System.err.println("Unknown class: "+arg[i+2]);
        }
        i+=2;
      }
      else if(arg[i].equals("-mplistener") && arg.length>i+1){
        try{
          Class c=Class.forName(arg[i+1]);
	  System.out.println("c: "+c);
          addMountPointListener((MountPointListener)(c.newInstance()));
        }
        catch(Exception e){
          System.err.println("Unknown listener class: "+arg[i+1]);
        }
        i++;
      }
      else if(arg[i].equals("-peercast-host") && arg.length>i+1){
        PeerCast.setLookupHost(arg[i+1]);
        i++;
      }
      else {
        System.err.println("invalid option: "+arg[i]);
        for(int ii=0; ii<usage.length; ii++){
          System.err.println(usage[ii]);
	}
        System.exit(-1);
      }
    }


    // Live Ogg stream at 'http://192.168.1.2:8000/example1.ogg' 
    // is mouted at /test1.ogg
    /*
    Proxy proxy=new Proxy("/foo1.ogg", 
    	                    "http://192.168.1.2:8888/example1.ogg");
    */

    /*
    // Ogg Vorbis files included in foo will be streamed at /test2.ogg
    String[] foo={
      "/tmp/foo.ogg",
      "/tmp/bar.ogg"
    };
    PlayFile p=new PlayFile("/foo2.ogg", foo);
    p.kick();
    */  
 
    /*
    // A stream mounted at /foo1.ogg will be broadcasted UDP port 8000
    UDPBroadcast u=new UDPBroadcast("/foo1.ogg", "192.168.0.255", 8000, "/udp.ogg");
    */

    // A stream mounted at /test2.ogg is transfered to IceCast2/JRoar at
    // 192.168.0.3:8000 with mountpoint /example2.ogg.
    /*
    ShoutClient sc=new ShoutClient("/foo2.ogg", "192.168.0.3", 8000, "/example2.ogg", "hackme");
    */

    HttpServer	httpServer=new HttpServer();
    httpServer.start();

    wd=new WatchDog();
    wd.start();
  }

  static Vector fetch_m3u(String m3u){
    InputStream pstream=null;
    if(m3u.startsWith("http://")){
      try{
        URL url=null;
        if(running_as_applet) url=new URL(codebase, 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")+"/"+m3u);
      }
      catch(Exception ee){
        System.err.println(ee); 	    
        return null;
      }
    }

    String line=null;
    Vector foo=new Vector();
    while(true){
      try{line=readline(pstream);}catch(Exception e){}
      if(line==null)break;
System.out.println("playFile ("+line+")");
      if(line.startsWith("#")) continue;
      foo.addElement(line);
    }
    return foo;
  }

  private static 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());
  }

  public static Hashtable getSources(){
    return Source.sources;
  }

  public static int getListeners(String mpoint) throws JRoarException{
    Source source=Source.getSource(mpoint);
    if(source!=null){
      return source.getListeners();
    }
    throw new JRoarException("invalid mountpoint: "+mpoint);
  }
  public static int getConnections(String mpoint) throws JRoarException{
    Source source=Source.getSource(mpoint);
    if(source!=null){
      return source.getConnections();
    }
    throw new JRoarException("invalid mountpoint: "+mpoint);
  }

  public static String getMyURL(){
    return HttpServer.myURL;
  }
  public static void store(String foo, String bar){
    new Store(foo, bar);
  }

  private static final int WATCHDOGSLEEP=3000;
  static class WatchDog extends Thread{
    public void run(){
      Source source;
      Enumeration sources;
      while(true){
        try{
          sources=Source.sources.elements();
          for(; sources.hasMoreElements();){
            source=((Source)sources.nextElement());
            int size=source.listeners.size();
            Client c=null;
            for(int i=0; i<size; i++){
              try{
                c=(Client)(source.listeners.elementAt(i));
                if(c.ready && System.currentTimeMillis()-c.lasttime>1000){
//System.out.println("drop: "+c);
                  ((HttpClient)c).ms.close();
	        }
	      }
              catch(Exception ee){}
	    }
  	  }
	}
        catch(Exception e){
System.out.println("WatchDog: "+e);
	}

        try{Thread.sleep(WATCHDOGSLEEP);}
        catch(Exception e){}
      }
    }
  }

  static void addMountPointListener(MountPointListener foo){
    synchronized(mplisteners){
      mplisteners.addElement(foo);
    }
  }
  static void removeMountPointListener(MountPointListener foo){
    synchronized(mplisteners){
      mplisteners.removeElement(foo);
    }
  }
}