package wifibroadcast;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.spi.SelectorProvider;

import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;

public class WifiMulticast implements WifiReceiver {
	private MulticastSocket soc;
	private InetAddress mAddr;
	private int port;

	public WifiMulticast(String mCASTADDR, int port, SocketType sender) throws IOException {
		this.port = port;
		try {
			mAddr = InetAddress.getByName(mCASTADDR);
			soc = new MulticastSocket(port);
			soc.joinGroup(mAddr);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	@Override
	public void recieve(ByteBuffer testData, long timeout) throws IOException {
		DatagramPacket packet = new DatagramPacket(testData.array(),testData.capacity());
		soc.receive(packet);
		testData.limit(packet.getLength());
		testData.position(0);
	}

	@Override
	public void send(ByteBuffer testData) throws IOException {
		DatagramPacket sendPacket = new DatagramPacket(testData.array(), testData.limit(),mAddr, port);
		soc.send(sendPacket);		
		testData.position(testData.limit());
	}

}