| /** |
| * 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.aries.rsa.itests.felix; |
| |
| import static org.ops4j.pax.exam.CoreOptions.bundle; |
| import static org.ops4j.pax.exam.CoreOptions.composite; |
| import static org.ops4j.pax.exam.CoreOptions.mavenBundle; |
| import static org.ops4j.pax.exam.CoreOptions.systemProperty; |
| import static org.ops4j.pax.exam.CoreOptions.vmOption; |
| import static org.ops4j.pax.exam.CoreOptions.when; |
| import static org.ops4j.pax.exam.cm.ConfigurationAdminOptions.newConfiguration; |
| |
| import java.io.IOException; |
| import java.net.InetSocketAddress; |
| import java.net.ServerSocket; |
| |
| import javax.inject.Inject; |
| |
| import org.ops4j.pax.exam.CoreOptions; |
| import org.ops4j.pax.exam.Option; |
| import org.ops4j.pax.exam.options.MavenArtifactProvisionOption; |
| import org.ops4j.pax.exam.options.OptionalCompositeOption; |
| import org.osgi.framework.Bundle; |
| import org.osgi.framework.BundleContext; |
| import org.osgi.service.cm.ConfigurationAdmin; |
| |
| public class RsaTestBase { |
| protected static final String ZK_PORT = "15201"; |
| |
| @Inject |
| protected BundleContext bundleContext; |
| |
| @Inject |
| ConfigurationAdmin configAdmin; |
| |
| protected static OptionalCompositeOption localRepo() { |
| String localRepo = System.getProperty("maven.repo.local"); |
| if (localRepo == null) { |
| localRepo = System.getProperty("org.ops4j.pax.url.mvn.localRepository"); |
| } |
| return when(localRepo != null) |
| .useOptions(vmOption("-Dorg.ops4j.pax.url.mvn.localRepository=" + localRepo)); |
| } |
| |
| protected static MavenArtifactProvisionOption mvn(String groupId, String artifactId) { |
| return mavenBundle().groupId(groupId).artifactId(artifactId).versionAsInProject(); |
| } |
| |
| public void testInstalled() throws Exception { |
| for (Bundle bundle : bundleContext.getBundles()) { |
| System.out.println(bundle.getBundleId() + " " + bundle.getSymbolicName() + " " + bundle.getState() |
| + " " + bundle.getVersion()); |
| } |
| } |
| |
| protected static int getFreePort() throws IOException { |
| try (ServerSocket socket = new ServerSocket()) { |
| socket.setReuseAddress(true); // enables quickly reopening socket on same port |
| socket.bind(new InetSocketAddress(0)); // zero finds a free port |
| return socket.getLocalPort(); |
| } |
| } |
| |
| protected Bundle getBundle(String symName) { |
| Bundle serviceBundle = null; |
| Bundle[] bundles = bundleContext.getBundles(); |
| for (Bundle bundle : bundles) { |
| if(symName.equals(bundle.getSymbolicName())) { |
| serviceBundle = bundle; |
| break; |
| } |
| } |
| return serviceBundle; |
| } |
| |
| protected static Option echoTcpAPI() { |
| return mvn("org.apache.aries.rsa.examples.echotcp", "org.apache.aries.rsa.examples.echotcp.api"); |
| } |
| |
| protected static Option echoTcpConsumer() { |
| return CoreOptions.composite( |
| echoTcpAPI(), |
| // Consumer bundle is needed to trigger service import. Pax exam inject does not trigger it |
| mvn("org.apache.aries.rsa.examples.echotcp", "org.apache.aries.rsa.examples.echotcp.consumer") |
| ); |
| } |
| |
| protected static Option echoTcpService() { |
| return composite( |
| echoTcpAPI(), |
| mvn("org.apache.aries.rsa.examples.echotcp", "org.apache.aries.rsa.examples.echotcp.service") |
| ); |
| } |
| |
| /** |
| * We create our own junit option to also provide hamcrest and Awaitility support |
| */ |
| protected static Option junit() { |
| return composite(systemProperty("pax.exam.invoker").value("junit"), |
| bundle("link:classpath:META-INF/links/org.ops4j.pax.tipi.junit.link"), |
| bundle("link:classpath:META-INF/links/org.ops4j.pax.exam.invoker.junit.link"), |
| mavenBundle().groupId("org.apache.servicemix.bundles") |
| .artifactId("org.apache.servicemix.bundles.hamcrest").version("1.3_1"), |
| mavenBundle().groupId("org.awaitility").artifactId("awaitility").version("3.1.0")); |
| } |
| |
| protected static Option rsaCore() { |
| return composite(junit(), |
| localRepo(), |
| logback(), |
| systemProperty("pax.exam.osgi.unresolved.fail").value("true"), |
| systemProperty("org.ops4j.pax.logging.DefaultServiceLog.level").value("INFO"), |
| systemProperty("aries.rsa.hostname").value("localhost"), |
| mvn("org.apache.servicemix.bundles", "org.apache.servicemix.bundles.hamcrest"), |
| mvn("org.awaitility", "awaitility"), |
| mvn("org.apache.felix", "org.apache.felix.eventadmin"), |
| mvn("org.apache.felix", "org.apache.felix.configadmin"), |
| mvn("org.apache.felix", "org.apache.felix.scr"), |
| mvn("org.apache.aries.rsa", "org.apache.aries.rsa.core"), |
| mvn("org.apache.aries.rsa", "org.apache.aries.rsa.spi"), |
| mvn("org.apache.aries.rsa", "org.apache.aries.rsa.topology-manager"), |
| mvn("org.apache.aries.rsa.discovery", "org.apache.aries.rsa.discovery.local") |
| ); |
| } |
| |
| public static Option logback() { |
| return composite(systemProperty("logback.configurationFile").value("src/test/resources/logback.xml"), |
| mavenBundle().groupId("org.slf4j").artifactId("slf4j-api").version("1.7.6"), |
| mavenBundle().groupId("ch.qos.logback").artifactId("logback-core").version("1.0.13"), |
| mavenBundle().groupId("ch.qos.logback").artifactId("logback-classic").version("1.0.13")); |
| } |
| |
| protected static Option debug() { |
| return CoreOptions.vmOption("-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=5005"); |
| } |
| |
| protected static Option rsaDiscoveryConfig() { |
| return composite( |
| mvn("org.apache.aries.rsa.discovery", "org.apache.aries.rsa.discovery.config") |
| ); |
| } |
| |
| protected static Option rsaDiscoveryZookeeper() { |
| return composite( |
| mvn("org.apache.zookeeper", "zookeeper"), |
| mvn("org.apache.aries.rsa.discovery", "org.apache.aries.rsa.discovery.zookeeper") |
| ); |
| } |
| |
| protected static Option rsaProviderTcp() { |
| return mvn("org.apache.aries.rsa.provider", "org.apache.aries.rsa.provider.tcp"); |
| } |
| |
| protected static Option rsaProviderFastBin() { |
| return composite(mvn("org.fusesource.hawtbuf", "hawtbuf"), |
| mvn("org.fusesource.hawtdispatch", "hawtdispatch"), |
| mvn("org.apache.aries.rsa.provider", "org.apache.aries.rsa.provider.fastbin")); |
| } |
| |
| protected static Option configZKDiscovery() { |
| return newConfiguration("org.apache.aries.rsa.discovery.zookeeper") // |
| .put("zookeeper.host", "127.0.0.1") // |
| .put("zookeeper.port", ZK_PORT).asOption(); |
| } |
| |
| protected static Option configZKServer() { |
| return newConfiguration("org.apache.aries.rsa.discovery.zookeeper.server") // |
| .put("clientPort", ZK_PORT) // |
| .asOption(); |
| } |
| |
| protected static Option configFastBinPort(int port) { |
| return newConfiguration("org.apache.aries.rsa.provider.fastbin") // |
| .put("uri", "tcp://0.0.0.0:" + port) // |
| .asOption(); |
| } |
| |
| protected static Option configFastBinFreePort() throws IOException { |
| return configFastBinPort(getFreePort()); |
| } |
| |
| } |
