package org.neo.swarm.util.network.jxta;
   
   import java.io.IOException;
   import java.net.DatagramPacket;
   
   import net.jxta.document.AdvertisementFactory;
   import net.jxta.exception.PeerGroupException;
   import net.jxta.peergroup.PeerGroup;
  import net.jxta.peergroup.PeerGroupFactory;
  import net.jxta.protocol.PipeAdvertisement;
  import net.jxta.socket.JxtaMulticastSocket;
  
  import org.neo.swarm.util.network.multicast.Receiver;
  
  /***
   * 
   * @author navery
   */
  public class JXReciever implements Receiver {
  
  	private static PeerGroup netPeerGroup;
  	private static PipeAdvertisement pipeAdv;
  	protected static JxtaMulticastSocket mcastSocket;
  	DatagramPacket packet;
  	int bufferSize;
  
  	public JXReciever() {
  		try {
  			  
  //		     PlatformConfigurator.c
  //		     args[0], // peername
  //		     "A dwPeer - " + args[0], // description
  //		     tcpAddress, // ip
  //		     myPort,  // ports
  //		     rdvList    , // rdvs
  //		     USER_NAME,
  //		     USER_PASS
  //		     );
  
  		     // disable multicast
  		      // pass in to preserve settings
  //		     TcpConfigurat tc = new TcpConfigurator(pa);
  //		     tc.setMulticastState(false);
  //		     // enable incoming connection
  //		     tc.setServer(tcpAddress);
  //		     tc.setServerEnabled(true);
  //		     tc.save(pa);   // save to pa only, not file
  			
  			PeerGroupFactory.setNetPGDesc("swarm jxta multicast");
  			PeerGroupFactory.setNetPGName("swamcast");
  			netPeerGroup = PeerGroupFactory.newPeerGroup();	
  			pipeAdv = (PipeAdvertisement) AdvertisementFactory.newAdvertisement("SWARM_MCAST");
  			mcastSocket = new JxtaMulticastSocket(netPeerGroup, pipeAdv);
  			
  			// recommended max for jxta packets before chunking
  			bufferSize = 16 * 1024;
  			byte[] buffer = new byte[bufferSize];
  			packet = new DatagramPacket(buffer, buffer.length);
  	//	} catch (PeerGroupException ex){
  		//	ex.printStackTrace();
  		} catch (IOException ex) {
  			ex.printStackTrace();
  		}
  	}
  
  	public byte[] read() {
  		try {
  			mcastSocket.receive(packet);
          return packet.getData();
  		} catch (IOException ex){
  			ex.printStackTrace();
  			return null;
  		}
  	}
  
  	public void close() {
  	}
  
  }