| /* |
| * 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.unomi.itests; |
| |
| import com.fasterxml.jackson.databind.ObjectMapper; |
| import org.apache.commons.io.IOUtils; |
| import org.apache.unomi.api.Item; |
| import org.apache.unomi.api.conditions.Condition; |
| import org.apache.unomi.api.services.DefinitionsService; |
| import org.apache.unomi.lifecycle.BundleWatcher; |
| import org.apache.unomi.persistence.spi.CustomObjectMapper; |
| import org.apache.unomi.persistence.spi.PersistenceService; |
| import org.junit.Assert; |
| import org.junit.Before; |
| import org.junit.runner.RunWith; |
| import org.ops4j.pax.exam.Configuration; |
| import org.ops4j.pax.exam.CoreOptions; |
| import org.ops4j.pax.exam.Option; |
| import org.ops4j.pax.exam.junit.PaxExam; |
| import org.ops4j.pax.exam.karaf.container.internal.JavaVersionUtil; |
| import org.ops4j.pax.exam.karaf.options.LogLevelOption.LogLevel; |
| import org.ops4j.pax.exam.options.MavenArtifactUrlReference; |
| import org.ops4j.pax.exam.options.extra.VMOption; |
| import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy; |
| import org.ops4j.pax.exam.spi.reactors.PerSuite; |
| import org.ops4j.pax.exam.util.Filter; |
| import org.osgi.framework.BundleContext; |
| import org.slf4j.Logger; |
| import org.slf4j.LoggerFactory; |
| |
| import javax.inject.Inject; |
| import java.io.File; |
| import java.io.IOException; |
| import java.util.ArrayList; |
| import java.util.Arrays; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.function.Predicate; |
| import java.util.function.Supplier; |
| |
| import static org.ops4j.pax.exam.CoreOptions.maven; |
| import static org.ops4j.pax.exam.CoreOptions.systemProperty; |
| import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.*; |
| |
| /** |
| * Base class for integration tests. |
| * |
| * @author kevan |
| */ |
| @RunWith(PaxExam.class) |
| @ExamReactorStrategy(PerSuite.class) |
| public abstract class BaseIT { |
| |
| private final static Logger LOGGER = LoggerFactory.getLogger(BaseIT.class); |
| |
| protected static final String HTTP_PORT = "8181"; |
| protected static final String URL = "http://localhost:" + HTTP_PORT; |
| protected static final String KARAF_DIR = "target/exam"; |
| protected static final String UNOMI_KEY = "670c26d1cc413346c3b2fd9ce65dab41"; |
| |
| @Inject |
| @Filter(timeout = 600000) |
| protected PersistenceService persistenceService; |
| |
| @Inject |
| @Filter(timeout = 600000) |
| protected DefinitionsService definitionsService; |
| |
| @Inject |
| protected BundleContext bundleContext; |
| |
| @Inject @Filter(timeout = 600000) |
| protected BundleWatcher bundleWatcher; |
| |
| @Before |
| public void waitForStartup() throws InterruptedException { |
| while (!bundleWatcher.isStartupComplete()) { |
| LOGGER.info("Waiting for startup to complete..."); |
| Thread.sleep(1000); |
| } |
| } |
| |
| protected void removeItems(final Class<? extends Item> ...classes) throws InterruptedException { |
| Condition condition = new Condition(definitionsService.getConditionType("matchAllCondition")); |
| for (Class<? extends Item> aClass : classes) { |
| persistenceService.removeByQuery(condition, aClass); |
| } |
| refreshPersistence(); |
| } |
| |
| protected void recreateIndex(final String itemType) { |
| if (persistenceService.removeIndex(itemType)) { |
| persistenceService.createIndex(itemType); |
| } |
| } |
| |
| protected void refreshPersistence() throws InterruptedException { |
| persistenceService.refresh(); |
| Thread.sleep(1000); |
| } |
| |
| @Configuration |
| public Option[] config() throws InterruptedException { |
| |
| MavenArtifactUrlReference karafUrl = maven() |
| .groupId("org.apache.unomi") |
| .artifactId("unomi") |
| .type("tar.gz") |
| .versionAsInProject(); |
| |
| List<Option> options = new ArrayList<>(); |
| |
| Option[] commonOptions = new Option[]{ |
| karafDistributionConfiguration() |
| .frameworkUrl(karafUrl) |
| .unpackDirectory(new File(KARAF_DIR)) |
| .useDeployFolder(true), |
| replaceConfigurationFile("etc/org.apache.unomi.router.cfg", new File( |
| "src/test/resources/org.apache.unomi.router.cfg")), |
| replaceConfigurationFile("data/tmp/1-basic-test.csv", new File( |
| "src/test/resources/1-basic-test.csv")), |
| replaceConfigurationFile("data/tmp/recurrent_import/2-surfers-test.csv", new File( |
| "src/test/resources/2-surfers-test.csv")), |
| replaceConfigurationFile("data/tmp/recurrent_import/3-surfers-overwrite-test.csv", new File( |
| "src/test/resources/3-surfers-overwrite-test.csv")), |
| replaceConfigurationFile("data/tmp/recurrent_import/4-surfers-delete-test.csv", new File( |
| "src/test/resources/4-surfers-delete-test.csv")), |
| replaceConfigurationFile("data/tmp/recurrent_import/5-ranking-test.csv", new File( |
| "src/test/resources/5-ranking-test.csv")), |
| replaceConfigurationFile("data/tmp/recurrent_import/6-actors-test.csv", new File( |
| "src/test/resources/6-actors-test.csv")), |
| replaceConfigurationFile("data/tmp/testLogin.json", new File( |
| "src/test/resources/testLogin.json")), |
| replaceConfigurationFile("data/tmp/testCopyProperties.json", new File( |
| "src/test/resources/testCopyProperties.json")), |
| replaceConfigurationFile("data/tmp/testCopyPropertiesWithoutSystemTags.json", new File( |
| "src/test/resources/testCopyPropertiesWithoutSystemTags.json")), |
| replaceConfigurationFile("data/tmp/testLoginEventCondition.json", new File( |
| "src/test/resources/testLoginEventCondition.json")), |
| keepRuntimeFolder(), |
| // configureConsole().ignoreLocalConsole(), |
| logLevel(LogLevel.INFO), |
| editConfigurationFilePut("etc/org.ops4j.pax.logging.cfg", "log4j2.rootLogger.level", "INFO"), |
| editConfigurationFilePut("etc/org.apache.karaf.features.cfg", "serviceRequirements", "disable"), |
| // editConfigurationFilePut("etc/org.ops4j.pax.web.cfg", "org.osgi.service.http.port", HTTP_PORT), |
| // systemProperty("org.osgi.service.http.port").value(HTTP_PORT), |
| systemProperty("org.ops4j.pax.exam.rbc.rmi.port").value("1199"), |
| systemProperty("org.apache.unomi.itests.elasticsearch.transport.port").value("9500"), |
| systemProperty("org.apache.unomi.itests.elasticsearch.cluster.name").value("contextElasticSearchITests"), |
| systemProperty("org.apache.unomi.itests.elasticsearch.http.port").value("9400"), |
| systemProperty("org.apache.unomi.itests.elasticsearch.bootstrap.seccomp").value("false"), |
| systemProperty("org.apache.unomi.hazelcast.group.name").value("cellar"), |
| systemProperty("org.apache.unomi.hazelcast.group.password").value("pass"), |
| systemProperty("org.apache.unomi.hazelcast.network.port").value("5701"), |
| systemProperty("org.apache.unomi.hazelcast.tcp-ip.members").value("127.0.0.1"), |
| systemProperty("org.apache.unomi.hazelcast.tcp-ip.interface").value("127.0.0.1"), |
| systemProperty("unomi.autoStart").value("true"), |
| CoreOptions.bundleStartLevel(100), |
| CoreOptions.frameworkStartLevel(100) |
| }; |
| |
| options.addAll(Arrays.asList(commonOptions)); |
| |
| String karafDebug = System.getProperty("it.karaf.debug"); |
| if (karafDebug != null) { |
| System.out.println("Found system Karaf Debug system property, activating configuration: " + karafDebug); |
| String port = "5006"; |
| boolean hold = true; |
| if (karafDebug.trim().length() > 0) { |
| String[] debugOptions = karafDebug.split(","); |
| for (String debugOption : debugOptions) { |
| String[] debugOptionParts = debugOption.split(":"); |
| if ("hold".equals(debugOptionParts[0])) { |
| hold = Boolean.parseBoolean(debugOptionParts[1].trim()); |
| } |
| if ("port".equals(debugOptionParts[0])) { |
| port = debugOptionParts[1].trim(); |
| } |
| } |
| } |
| options.add(0, debugConfiguration(port, hold)); |
| } |
| |
| if (JavaVersionUtil.getMajorVersion() >= 9) { |
| Option[] jdk9PlusOptions = new Option[]{ |
| new VMOption("--add-reads=java.xml=java.logging"), |
| new VMOption("--add-exports=java.base/org.apache.karaf.specs.locator=java.xml,ALL-UNNAMED"), |
| new VMOption("--patch-module"), |
| new VMOption("java.base=lib/endorsed/org.apache.karaf.specs.locator-" |
| + System.getProperty("karaf.version") + ".jar"), |
| new VMOption("--patch-module"), new VMOption("java.xml=lib/endorsed/org.apache.karaf.specs.java.xml-" |
| + System.getProperty("karaf.version") + ".jar"), |
| new VMOption("--add-opens"), |
| new VMOption("java.base/java.security=ALL-UNNAMED"), |
| new VMOption("--add-opens"), |
| new VMOption("java.base/java.net=ALL-UNNAMED"), |
| new VMOption("--add-opens"), |
| new VMOption("java.base/java.lang=ALL-UNNAMED"), |
| new VMOption("--add-opens"), |
| new VMOption("java.base/java.util=ALL-UNNAMED"), |
| new VMOption("--add-opens"), |
| new VMOption("java.naming/javax.naming.spi=ALL-UNNAMED"), |
| new VMOption("--add-opens"), |
| new VMOption("java.rmi/sun.rmi.transport.tcp=ALL-UNNAMED"), |
| new VMOption("--add-exports=java.base/sun.net.www.protocol.http=ALL-UNNAMED"), |
| new VMOption("--add-exports=java.base/sun.net.www.protocol.https=ALL-UNNAMED"), |
| new VMOption("--add-exports=java.base/sun.net.www.protocol.jar=ALL-UNNAMED"), |
| new VMOption("--add-exports=jdk.naming.rmi/com.sun.jndi.url.rmi=ALL-UNNAMED"), |
| new VMOption("-classpath"), |
| new VMOption("lib/jdk9plus/*" + File.pathSeparator + "lib/boot/*") |
| |
| }; |
| options.addAll(Arrays.asList(jdk9PlusOptions)); |
| } |
| |
| return options.toArray(new Option[0]); |
| } |
| |
| protected <T> T keepTrying(String failMessage, Supplier<T> call, Predicate<T> predicate, int timeout, int retries) throws InterruptedException { |
| int count = 0; |
| T value = null; |
| while (value == null || !predicate.test(value)) { |
| if (count++ > retries) { |
| Assert.fail(failMessage); |
| } |
| Thread.sleep(timeout); |
| value = call.get(); |
| } |
| return value; |
| } |
| |
| protected String bundleResourceAsString(final String resourcePath) throws IOException { |
| final java.net.URL url = bundleContext.getBundle().getResource(resourcePath); |
| if (url != null) { |
| return IOUtils.toString(url); |
| } else { |
| return null; |
| } |
| } |
| |
| protected String getValidatedBundleJSON(final String resourcePath, Map<String,String> parameters) throws IOException { |
| String jsonString = bundleResourceAsString(resourcePath); |
| if (parameters != null && parameters.size() > 0) { |
| for (Map.Entry<String,String> parameterEntry : parameters.entrySet()) { |
| jsonString = jsonString.replace("###" + parameterEntry.getKey() + "###", parameterEntry.getValue()); |
| } |
| } |
| ObjectMapper objectMapper = CustomObjectMapper.getObjectMapper(); |
| return objectMapper.writeValueAsString(objectMapper.readTree(jsonString)); |
| } |
| |
| } |
