package org.eclipse.osee.ote.endpoint;

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;

import org.eclipse.osee.framework.jdk.core.util.network.PortUtil;
import org.eclipse.osee.ote.message.event.FileAvailableRequest;
import org.junit.Assert;
import org.junit.Test;

public class OteUdpEndpointTest {

   @Test
   public void testCreation() throws IOException {
      int port = PortUtil.getInstance().getValidPort();
      OteUdpEndpointSender sender = new OteUdpEndpointSender(new InetSocketAddress(port));
      Assert.assertNotNull(sender);
      port = PortUtil.getInstance().getValidPort();
      OteUdpEndpointReceiverImpl receiver = new OteUdpEndpointReceiverImpl(new InetSocketAddress(port));
      Assert.assertNotNull(receiver);
   }
   
   @Test
   public void testSendReceive() throws IOException, InterruptedException {
      int port = PortUtil.getInstance().getValidPort();
      OteUdpEndpointReceiverImpl receiver = new OteUdpEndpointReceiverImpl(new InetSocketAddress(InetAddress.getLocalHost(), port));
      receiver.setDebugOutput(true);
      receiver.start();
      Thread.sleep(20);
      InetSocketAddress address = receiver.getEndpoint();
      OteUdpEndpointSender sender = new OteUdpEndpointSender(address);
      sender.start();
      FileAvailableRequest request = new FileAvailableRequest();
      sender.send(request);
      
      Thread.sleep(20);
      
      sender.stop();
      receiver.stop();
   }

}