/*******************************************************************************
 *  ============LICENSE_START=======================================================
 *  org.onap.dmaap
 *  ================================================================================
 *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
 *  ================================================================================
 *  Licensed 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.
 *  ============LICENSE_END=========================================================
 *
 *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
 *  
 *******************************************************************************/
package org.onap.dmaap.mr.client.impl;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;

import junit.framework.TestCase;

import org.apache.http.HttpHost;
import org.junit.Test;

import org.onap.dmaap.mr.client.impl.MRConstants;

public class MRConstantsTest extends TestCase
{
	@Test
	public void testPlainHost () throws IOException
	{
		final String rawTopic = "bar";
		final String result = MRConstants.makeUrl ( rawTopic );
		assertEquals ( "/events/"  + "bar", result );
	}

	@Test
	public void testHostWithProtocol () throws IOException
	{
		final String rawTopic = "bar";
		final String result = MRConstants.makeUrl (  rawTopic );
		assertEquals ( "/events/"  + "bar", result );
	}

	@Test
	public void testHostWithProtocolAndPort () throws IOException
	{
		final String rawTopic = "bar";
		final String result = MRConstants.makeUrl ( rawTopic );
		assertEquals ( "/events/" + "bar", result );
	}

	@Test
	public void testHostWithPort () throws IOException
	{
		final String rawTopic = "bar";
		final String result = MRConstants.makeUrl ( rawTopic );
		assertEquals ( "/events/" + "bar", result );
	}

	@Test
	public void testHostWithPortAndEscapedTopic () throws IOException
	{
		final String rawTopic = "bar?bell";
		final String result = MRConstants.makeUrl ( rawTopic );
		assertEquals ( "/events/" + "bar%3Fbell", result );
	}

	@Test
	public void testConsumerPlainHost () throws IOException
	{
		final String rawTopic = "bar";
		final String rawGroup = "group";
		final String rawId = "id";
		final String result = MRConstants.makeConsumerUrl ( rawTopic, rawGroup, rawId );
		assertEquals ( "/events/" + "bar/group/id", result );
	}

	@Test
	public void testCreateHostList ()
	{
		final ArrayList<String> in = new ArrayList<String> ();
		in.add ( "foo" );
		in.add ( "bar" );
		in.add ( "baz:80" );

		final Collection<HttpHost> hosts = MRConstants.createHostsList ( in );
		assertEquals ( 3, hosts.size () );

		final Iterator<HttpHost> it = hosts.iterator ();
		final HttpHost first = it.next ();
		assertEquals ( MRConstants.kStdMRServicePort, first.getPort () );
		assertEquals ( "foo", first.getHostName () );

		final HttpHost second = it.next ();
		assertEquals ( MRConstants.kStdMRServicePort, second.getPort () );
		assertEquals ( "bar", second.getHostName () );

		final HttpHost third = it.next ();
		assertEquals ( 80, third.getPort () );
		assertEquals ( "baz", third.getHostName () );
	}

	private static final String[][] hostTests =
	{
		{ "host", "host", "" + MRConstants.kStdMRServicePort },
		{ ":oops", null, "-1" },
		{ "host:1.3", null, "-1" },
		{ "host:13", "host", "13" },
		{ "host:", "host", "" + MRConstants.kStdMRServicePort },
	};

	@Test
	public void testHostParse ()
	{
		for ( String[] test : hostTests )
		{
			final String hostIn = test[0];
			final String hostOut = test[1];
			final int portOut = Integer.parseInt ( test[2] );

			try
			{
				final HttpHost hh = MRConstants.hostForString ( hostIn );
				assertEquals ( hostOut, hh.getHostName () );
				assertEquals ( portOut, hh.getPort () );
			}
			catch ( IllegalArgumentException x )
			{
				assertEquals ( -1, portOut );
			}
		}
	}
}