activemq-cpp/src/test/activemq/util/URISupportTest.cpp

/*
 * 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.
 */

#include "URISupportTest.h"

#include <activemq/util/URISupport.h>
#include <decaf/util/Properties.h>
#include <decaf/lang/System.h>
#include <decaf/lang/exceptions/IllegalArgumentException.h>

using namespace std;
using namespace decaf;
using namespace decaf::util;
using namespace activemq;
using namespace activemq::util;

////////////////////////////////////////////////////////////////////////////////
namespace {

    void verifyParams(const Properties& parameters) {
        CPPUNIT_ASSERT(parameters.getProperty("proxyHost", "") == "localhost");
        CPPUNIT_ASSERT(parameters.getProperty("proxyPort", "") == "80");
    }
}

////////////////////////////////////////////////////////////////////////////////
void URISupportTest::test() {

    string test = "?option1=test1&option2=test2";

    Properties map = URISupport::parseQuery( test );

    CPPUNIT_ASSERT( map.hasProperty( "option1" ) == true );
    CPPUNIT_ASSERT( map.hasProperty( "option2" ) == true );

    CPPUNIT_ASSERT( map.getProperty( "option1", "" ) == "test1" );
    CPPUNIT_ASSERT( map.getProperty( "option2", "" ) == "test2" );

    string test2 = "option&option";

    try{
        map = URISupport::parseQuery( test2 );
        CPPUNIT_ASSERT( false );
    } catch(...) {}

    string test3 = "option1=test1&option2=test2";

    map = URISupport::parseQuery( test3 );

    CPPUNIT_ASSERT( map.hasProperty( "option1" ) == true );
    CPPUNIT_ASSERT( map.hasProperty( "option2" ) == true );

    CPPUNIT_ASSERT( map.getProperty( "option1", "" ) == "test1" );
    CPPUNIT_ASSERT( map.getProperty( "option2", "" ) == "test2" );

    string test4 = "http://cause.exception.com?option1=test1&option2=test2";

    try{
        map = URISupport::parseQuery( test4 );
    } catch(...) {
        CPPUNIT_ASSERT( false );
    }

    string test5 = "failover:(tcp://127.0.0.1:61616)?startupMaxReconnectAttempts=10&initialReconnectDelay=10";

    map = URISupport::parseQuery( test5 );

    CPPUNIT_ASSERT( map.hasProperty( "startupMaxReconnectAttempts" ) == true );
    CPPUNIT_ASSERT( map.hasProperty( "initialReconnectDelay" ) == true );

    CPPUNIT_ASSERT( map.getProperty( "startupMaxReconnectAttempts", "" ) == "10" );
    CPPUNIT_ASSERT( map.getProperty( "initialReconnectDelay", "" ) == "10" );

    string test6 = "failover://(tcp://127.0.0.1:61616)?startupMaxReconnectAttempts=10&initialReconnectDelay=10";

    map = URISupport::parseQuery( test6 );

    CPPUNIT_ASSERT( map.hasProperty( "startupMaxReconnectAttempts" ) == true );
    CPPUNIT_ASSERT( map.hasProperty( "initialReconnectDelay" ) == true );

    CPPUNIT_ASSERT( map.getProperty( "startupMaxReconnectAttempts", "" ) == "10" );
    CPPUNIT_ASSERT( map.getProperty( "initialReconnectDelay", "" ) == "10" );
}

////////////////////////////////////////////////////////////////////////////////
void URISupportTest::testURIParseEnv() {

    string test = "tcp://localhost:61616?option1=test1&option2=test2";

    Properties map;

    URISupport::parseURL( test, map );

    CPPUNIT_ASSERT( map.hasProperty( "option1" ) == true );
    CPPUNIT_ASSERT( map.hasProperty( "option2" ) == true );

    CPPUNIT_ASSERT( map.getProperty( "option1", "" ) == "test1" );
    CPPUNIT_ASSERT( map.getProperty( "option2", "" ) == "test2" );

    decaf::lang::System::setenv( "TEST_CPP_AMQ", "test2" );

    test = "tcp://localhost:61616?option1=test1&option2=${TEST_CPP_AMQ}";
    map.clear();
    URISupport::parseURL( test, map );
    CPPUNIT_ASSERT( map.hasProperty( "option2" ) == true );
    CPPUNIT_ASSERT( map.getProperty( "option2", "" ) == "test2" );

    test = "tcp://localhost:61616?option1=test1&option2=${TEST_CPP_AMQ_XXX}";
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should Throw an IllegalArgumentException",
        URISupport::parseURL( test, map ),
        decaf::lang::exceptions::IllegalArgumentException );

    test = "tcp://localhost:61616?option1=test1&option2=${}";
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should Throw an IllegalArgumentException",
        URISupport::parseURL( test, map ),
        decaf::lang::exceptions::IllegalArgumentException );

    test = "tcp://localhost:61616?option1=test1&option2=$X}";
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should Throw an IllegalArgumentException",
        URISupport::parseURL( test, map ),
        decaf::lang::exceptions::IllegalArgumentException );

    test = "tcp://localhost:61616?option1=test1&option2=${X";
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should Throw an IllegalArgumentException",
        URISupport::parseURL( test, map ),
        decaf::lang::exceptions::IllegalArgumentException );

    test = "tcp://localhost:61616?option1=test1&option2=$X";
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should Throw an IllegalArgumentException",
        URISupport::parseURL( test, map ),
        decaf::lang::exceptions::IllegalArgumentException );
}

////////////////////////////////////////////////////////////////////////////////
void URISupportTest::testParseComposite() {

    CompositeData data = URISupport::parseComposite(
        URI("broker:()/localhost?persistent=false" ) );
    CPPUNIT_ASSERT( 0 == data.getComponents().size() );

    data = URISupport::parseComposite( URI( "test:(path)/path" ) );
    CPPUNIT_ASSERT( data.getPath() == "path" );

    data = URISupport::parseComposite( URI( "test:path" ) );
    CPPUNIT_ASSERT( data.getPath() == "" );

    data = URISupport::parseComposite( URI( "test:part1" ) );
    CPPUNIT_ASSERT( 1 == data.getComponents().size() );

    data = URISupport::parseComposite(
        URI( "test:(part1://host,part2://(sub1://part,sube2:part))" ) );
    CPPUNIT_ASSERT( 2 == data.getComponents().size() );

    data = URISupport::parseComposite(
        URI( "broker://(tcp://localhost:61616?wireformat=openwire)?name=foo" ) );

    CPPUNIT_ASSERT( data.getScheme() == "broker" );
    CPPUNIT_ASSERT( data.getParameters().hasProperty( "name" ) );
    CPPUNIT_ASSERT( string( data.getParameters().getProperty( "name" ) ) == "foo" );
    CPPUNIT_ASSERT( data.getComponents().size() == 1 );
    CPPUNIT_ASSERT( data.getComponents().get(0).toString() ==
                    "tcp://localhost:61616?wireformat=openwire" );

    data = URISupport::parseComposite(
        URI( "broker:(tcp://localhost:61616?wireformat=openwire)?name=foo" ) );

    CPPUNIT_ASSERT( data.getScheme() == "broker" );
    CPPUNIT_ASSERT( data.getParameters().hasProperty( "name" ) );
    CPPUNIT_ASSERT( !data.getParameters().hasProperty( "wireformat" ) );
    CPPUNIT_ASSERT( string( data.getParameters().getProperty( "name" ) ) == "foo" );
    CPPUNIT_ASSERT( data.getComponents().size() == 1 );
    CPPUNIT_ASSERT( data.getComponents().get(0).toString() ==
                    "tcp://localhost:61616?wireformat=openwire" );

    data = URISupport::parseComposite(
        URI( "broker:(tcp://localhost:61616)?name=foo" ) );

    CPPUNIT_ASSERT( data.getScheme() == "broker" );
    CPPUNIT_ASSERT( data.getParameters().hasProperty( "name" ) );
    CPPUNIT_ASSERT( !data.getParameters().hasProperty( "wireformat" ) );
    CPPUNIT_ASSERT( string( data.getParameters().getProperty( "name" ) ) == "foo" );
    CPPUNIT_ASSERT( data.getComponents().size() == 1 );
    CPPUNIT_ASSERT( data.getComponents().get(0).toString() ==
                    "tcp://localhost:61616" );

    data = URISupport::parseComposite(
        URI( "test:(part1://host,part2://host,part3://host,part4://host)" ) );
    CPPUNIT_ASSERT( 4 == data.getComponents().size() );
    CPPUNIT_ASSERT( data.getComponents().get(0).toString() == "part1://host" );
    CPPUNIT_ASSERT( data.getComponents().get(1).toString() == "part2://host" );
    CPPUNIT_ASSERT( data.getComponents().get(2).toString() == "part3://host" );
    CPPUNIT_ASSERT( data.getComponents().get(3).toString() == "part4://host" );

    data = URISupport::parseComposite(
        URI( "test:(part1://host,part2://host,part3://host,part4://host?option=value)" ) );
    CPPUNIT_ASSERT( 4 == data.getComponents().size() );
    CPPUNIT_ASSERT( data.getComponents().get(0).toString() == "part1://host" );
    CPPUNIT_ASSERT( data.getComponents().get(1).toString() == "part2://host" );
    CPPUNIT_ASSERT( data.getComponents().get(2).toString() == "part3://host" );
    CPPUNIT_ASSERT( data.getComponents().get(3).toString() == "part4://host?option=value" );
}

////////////////////////////////////////////////////////////////////////////////
void URISupportTest::testCreateWithQuery() {

    URI source("vm://localhost");
    URI dest = URISupport::createURIWithQuery(source, "network=true&one=two");

    CPPUNIT_ASSERT_EQUAL_MESSAGE("correct param count", 2, URISupport::parseParameters(dest).size());
    CPPUNIT_ASSERT_EQUAL_MESSAGE("same uri, host", source.getHost(), dest.getHost());
    CPPUNIT_ASSERT_EQUAL_MESSAGE("same uri, scheme", source.getScheme(), dest.getScheme());
    CPPUNIT_ASSERT_MESSAGE("same uri, ssp", dest.getQuery() != source.getQuery());
}

////////////////////////////////////////////////////////////////////////////////
void URISupportTest::testApplyParameters() {

    URI uri("http://0.0.0.0:61616");
    Properties parameters;
    parameters.setProperty("t.proxyHost", "localhost");
    parameters.setProperty("t.proxyPort", "80");

    uri = URISupport::applyParameters(uri, parameters);
    Properties appliedParameters = URISupport::parseParameters(uri);
    CPPUNIT_ASSERT_EQUAL_MESSAGE("all params applied with no prefix", 2, appliedParameters.size());

    // strip off params again
    uri = URISupport::createURIWithQuery(uri, "");

    uri = URISupport::applyParameters(uri, parameters, "joe");
    appliedParameters = URISupport::parseParameters(uri);
    CPPUNIT_ASSERT_MESSAGE("no params applied as none match joe", appliedParameters.isEmpty());

    uri = URISupport::applyParameters(uri, parameters, "t.");
    verifyParams(URISupport::parseParameters(uri));
}