/* $Id$
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements. See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.apache.etch.util.core.io;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNotSame;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;

import org.apache.etch.util.FlexBuffer;
import org.apache.etch.util.core.Who;
import org.junit.After;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;


/** Test UdpConnection. */
public class TestUdpConnection
{
	/** @throws Exception */
	@Before @Ignore
	public void init() throws Exception
	{
		aph = new MyPacketHandler();
		ac = new UdpConnection( "udp://localhost:4011", null );
		ac.setSession( aph );
		ac.start();
		ac.waitUp( 4000 );
		System.out.println( "ac up" );
		
		bph = new MyPacketHandler();
		bc = new UdpConnection( "udp://localhost:4010", null );
		bc.setSession( bph );
		bc.start();
		bc.waitUp( 4000 );
		System.out.println( "bc up" );
	}
	
	/** @throws Exception */
	@After @Ignore
	public void fini() throws Exception
	{
		ac.close( false );
		bc.close( false );
	}
	
	private MyPacketHandler aph;
	
	private UdpConnection ac;
	
	private MyPacketHandler bph;
	
	private UdpConnection bc;
	
	/** @throws Exception */
	@Test @Ignore
	public void blah() throws Exception
	{
		assertEquals( What.UP, aph.what );
		assertEquals( What.UP, bph.what );
		FlexBuffer buf = new FlexBuffer();
		buf.put( 1 );
		buf.put( 2 );
		buf.put( 3 );
		buf.put( 4 );
		buf.put( 5 );
		buf.setIndex( 0 );
		ac.transportPacket( null, buf );
		Thread.sleep( 500 );
		assertEquals( What.PACKET, bph.what );
		assertNotNull( bph.xsender );
		assertNotSame( buf, bph.xbuf );
		assertEquals( 0, bph.xbuf.index() );
		assertEquals( 5, bph.xbuf.length() );
		assertEquals( 1, bph.xbuf.get() );
		assertEquals( 2, bph.xbuf.get() );
		assertEquals( 3, bph.xbuf.get() );
		assertEquals( 4, bph.xbuf.get() );
		assertEquals( 5, bph.xbuf.get() );
	}
	
	/** */
	public enum What
	{
		/** */ UP,
		/** */ PACKET,
		/** */ DOWN
	}
	
	/**
	 * receive packets from the udp connection
	 */
	public static class MyPacketHandler implements SessionPacket
	{
		/** */
		public What what;
		/** */
		public Who xsender;
		/** */
		public FlexBuffer xbuf;

		public void sessionPacket( Who sender, FlexBuffer buf ) throws Exception
		{
			assertEquals( What.UP, what );
			what = What.PACKET;
			xsender = sender;
			xbuf = buf;
		}

		public void sessionControl( Object control, Object value )
		{
			// ignore.
		}

		public void sessionNotify( Object event )
		{
			if (event.equals( Session.UP ))
			{
				assertNull( what );
				what = What.UP;
				return;
			}
			
			if (event.equals( Session.DOWN ))
			{
				assertTrue( what == What.UP || what == What.PACKET );
				what = What.DOWN;
				return;
			}
		}

		public Object sessionQuery( Object query )
		{
			// ignore.
			return null;
		}
	}
}