From 010614153f2b109a9a65abf2b9151b7cd9d82627 Mon Sep 17 00:00:00 2001 From: slaws Date: Tue, 15 Mar 2011 13:16:11 +0000 Subject: Take a copy from 2.x trunk as I'm going to remove it from there shortly. git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1081768 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/test/java/sample/HelloworldTestCase.java | 216 +++++++++++++++++++++ 1 file changed, 216 insertions(+) create mode 100644 sandbox/slaws/bundle/src/test/java/sample/HelloworldTestCase.java (limited to 'sandbox/slaws/bundle/src/test/java/sample/HelloworldTestCase.java') diff --git a/sandbox/slaws/bundle/src/test/java/sample/HelloworldTestCase.java b/sandbox/slaws/bundle/src/test/java/sample/HelloworldTestCase.java new file mode 100644 index 0000000000..4c3f0271fa --- /dev/null +++ b/sandbox/slaws/bundle/src/test/java/sample/HelloworldTestCase.java @@ -0,0 +1,216 @@ +/* + * 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 sample; + +import static org.junit.Assert.assertEquals; + +import java.io.BufferedReader; +import java.io.File; +import java.io.FileOutputStream; +import java.io.FileReader; +import java.util.HashSet; +import java.util.Set; + +import static org.ops4j.pax.exam.CoreOptions.equinox; +import static org.ops4j.pax.exam.CoreOptions.options; +import static org.ops4j.pax.exam.CoreOptions.systemProperty; + +import static org.ops4j.pax.exam.container.def.PaxRunnerOptions.workingDirectory; + +import org.apache.aries.application.filesystem.IDirectory; +import org.apache.aries.application.management.spi.repository.RepositoryGenerator; +import org.apache.aries.application.modelling.ModelledResourceManager; +import org.apache.aries.application.modelling.ModelledResource; +import org.apache.aries.application.utils.filesystem.FileSystem; + +import org.apache.felix.bundlerepository.Repository; +import org.apache.felix.bundlerepository.RepositoryAdmin; + +import org.junit.Test; +import org.junit.runner.RunWith; + +import org.ops4j.pax.exam.CoreOptions; +import org.ops4j.pax.exam.Inject; +import org.ops4j.pax.exam.Option; +import org.ops4j.pax.exam.container.def.options.WorkingDirectoryOption; +import org.ops4j.pax.exam.junit.Configuration; +import org.ops4j.pax.exam.junit.JUnit4TestRunner; +import org.ops4j.pax.exam.options.MavenArtifactProvisionOption; + +import org.osgi.framework.BundleContext; +import org.osgi.framework.Constants; +import org.osgi.framework.Filter; +import org.osgi.framework.FrameworkUtil; +import org.osgi.util.tracker.ServiceTracker; + +/* For debugging, uncomment the next two lines and add these imports: + */ +import static org.ops4j.pax.exam.CoreOptions.waitForFrameworkStartup; +import static org.ops4j.pax.exam.container.def.PaxRunnerOptions.vmOption; + + +/** + * Note that much of the technical detail/instruction comes from... + * + * http://svn.apache.org/repos/asf/aries/trunk/application/application-itests/src/test/java/org/apache/aries/application/runtime/itests/OBRResolverTest.java + * + */ + +@RunWith( JUnit4TestRunner.class ) +public class HelloworldTestCase { + + public static final long DEFAULT_TIMEOUT = 30000; + + @Inject + protected BundleContext bundleContext; + + @Configuration + public static Option[] configuration() { + Option[] options = options( + mavenBundle("org.ops4j.pax.logging", "pax-logging-api"), + mavenBundle("org.ops4j.pax.logging", "pax-logging-service"), + systemProperty("org.ops4j.pax.logging.DefaultServiceLog.level").value("INFO"), + +// mavenBundle("org.apache.felix", "org.apache.felix.configadmin"), + mavenBundle("org.ops4j.pax.url", "pax-url-mvn"), + + mavenBundle("org.apache.aries.blueprint", "org.apache.aries.blueprint"), + mavenBundle("asm", "asm-all"), + mavenBundle("org.apache.aries.proxy", "org.apache.aries.proxy"), + mavenBundle("org.apache.aries", "org.apache.aries.util"), + + mavenBundle("org.apache.aries.application", "org.apache.aries.application.api"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.utils"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.modeller"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.default.local.platform"), + mavenBundle("org.apache.felix", "org.apache.felix.bundlerepository"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.resolver.obr"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.deployment.management"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.management"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.runtime"), + mavenBundle("org.apache.aries.application", "org.apache.aries.application.runtime.itest.interfaces"), + mavenBundle("org.osgi", "org.osgi.compendium"), + mavenBundle("org.apache.aries.testsupport", "org.apache.aries.testsupport.unit"), + + mavenBundle("org.apache.tuscany.sca", "tuscany-sca-api"), + + mavenBundle("org.apache.tuscany.sca", "bundle"), + + /* For debugging, uncomment the next two lines + vmOption("-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=7777"), + waitForFrameworkStartup(), + */ + + workingDirectory("D://sca-java-2.x//unreleased//testing//itest//bundle//target"), + + equinox().version("3.5.0")); + + return options; + } + + @Test + public void testSayHello() { + System.out.println("testSayHello - start"); + System.out.println("test dir = " + System.getProperty("user.dir")); + System.out.println("current dir = " + this.getClass().getProtectionDomain().getCodeSource().getLocation()); + + // get the OBR repository admin service + RepositoryAdmin respositoryAdminService = getOsgiService(RepositoryAdmin.class); + + // print currently registered repos + Repository[] repos = respositoryAdminService.listRepositories(); + System.out.println("initial repos"); + for (Repository repo : repos) { + System.out.println("Repo >>> " + repo.getName()); + } + + // get the repository generator service + System.out.println("get RepositoryGenerator service ="); + RepositoryGenerator repositoryGenerator = getOsgiService(RepositoryGenerator.class); + System.out.println(repositoryGenerator); + + System.out.println("get ModelledResourceManager service ="); + ModelledResourceManager modelledResourceManager = getOsgiService(ModelledResourceManager.class); + System.out.println(modelledResourceManager); + + Set mrs = new HashSet(); + + try { + // create mrs based on base runtime + populateMRS(modelledResourceManager, + mrs, + "../../../../../distribution/all/target/features/tuscany-base-runtime-pom/which-jars", + "../../../../../distribution/all/target/modules"); + //File outFile = new File("D://sca-java-2.x//unreleased//testing//itest//bundle//target//myrepository.xml"); + //File outFile = new File(".//target//myrepository.xml"); + //FileOutputStream fout = new FileOutputStream(outFile); + FileOutputStream fout = new FileOutputStream("repository.xml"); + repositoryGenerator.generateRepository("Test repo description", mrs, fout); + fout.close(); + + } catch(Exception ex) { + ex.printStackTrace(); + } + + System.out.println("testSayHello - end"); + } + + private void populateMRS(ModelledResourceManager modelledResourceManager, + Set mrs, + String whichJars, + String modules){ + try { + BufferedReader in = new BufferedReader(new FileReader(whichJars)); + String line; + while ((line = in.readLine()) != null) { + if (line.endsWith(".jar")){ + int dirSeparatorIndex = line.indexOf("/"); + if (dirSeparatorIndex > 0){ + line = line.substring(0, dirSeparatorIndex); + } + System.out.println("Processing - " + line); + File bundleFile = new File(modules + "\\" + line); + IDirectory jarDir = FileSystem.getFSRoot(bundleFile); + mrs.add(modelledResourceManager.getModelledResource(bundleFile.toURI().toString(), jarDir)); + } + } + } catch (Exception ex) { + ex.printStackTrace(); + } + } + + private T getOsgiService(Class type) { + try { + String filterString = "(" + Constants.OBJECTCLASS + "=" + type.getName() + ")"; + Filter osgiFilter = FrameworkUtil.createFilter(filterString); + ServiceTracker tracker = new ServiceTracker(bundleContext, osgiFilter, null); + tracker.open(); + Object tmp = tracker.waitForService(DEFAULT_TIMEOUT); + return type.cast(tmp); + } catch (Exception ex) { + throw new RuntimeException(ex); + } + } + + private static MavenArtifactProvisionOption mavenBundle(String groupId, String artifactId) { + return CoreOptions.mavenBundle().groupId(groupId).artifactId(artifactId).versionAsInProject(); + } +} + + -- cgit v1.2.3