src/test/java/org/apache/ws/scout/registry/qa/JAXR050ServiceBindingTest.java - juddi-scout - Git at Google

 /**
  *
  * Copyright 2004 The Apache Software Foundation
  *
  *  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.
  */
 package org.apache.ws.scout.registry.qa;

 import static org.junit.Assert.fail;

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

 import javax.xml.registry.BulkResponse;
 import javax.xml.registry.BusinessLifeCycleManager;
 import javax.xml.registry.JAXRException;
 import javax.xml.registry.JAXRResponse;
 import javax.xml.registry.RegistryService;
 import javax.xml.registry.infomodel.Concept;
 import javax.xml.registry.infomodel.ExternalLink;
 import javax.xml.registry.infomodel.InternationalString;
 import javax.xml.registry.infomodel.Key;
 import javax.xml.registry.infomodel.Organization;
 import javax.xml.registry.infomodel.Service;
 import javax.xml.registry.infomodel.ServiceBinding;
 import javax.xml.registry.infomodel.SpecificationLink;

 import junit.framework.JUnit4TestAdapter;

 import org.apache.ws.scout.BaseTestCase;
 import org.apache.ws.scout.Finder;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;

 /**
 Tests Publish, Delete (and indirectly, find) for service bindings.
  *
  * You can comment out the deletion portion and use
  * Open source UDDI Browser  <http://www.uddibrowser.org>
  * to check your intermediate results
  *
  * Based on query/publish tests written by
  * <a href="mailto:anil@apache.org">Anil Saldhana</a>.
  *
  * @author <a href="mailto:dbhole@redhat.com">Deepak Bhole</a>
  * @author <a href="mailto:anil@apache.org">Anil Saldhana</a>
  *
  * @since Sep 27, 2005
  */
 public class JAXR050ServiceBindingTest extends BaseTestCase
 {

     String serviceBindingName = "Apache JAXR Service Binding -- APACHE SCOUT TEST";
     String serviceName = "Apache JAXR Service -- APACHE SCOUT TEST";
 	String tempOrgName = "Apache JAXR Service Org -- APACHE SCOUT TEST";

     @Before
     public void setUp()
     {
        super.setUp();
     }
     @After
     public void tearDown()
     {
         super.tearDown();
     }

 	/**
 	 * Tests publishing and deleting of service bindings.
 	 *
 	 * Do not break this into testPublish(), testDelete(), etc. Order is
 	 * important, and not all jvms can guarantee order since the JUnit framework
 	 * uses getMethods() to gather test methods, and getMethods() does not
 	 * guarantee order.
 	 */
     @Test
     public void testPublishFindAndDeleteServiceBinding()
     {
         login();
         try
         {
             RegistryService rs = connection.getRegistryService();
             blm = rs.getBusinessLifeCycleManager();
             bqm = rs.getBusinessQueryManager();
             Finder finder = new Finder(bqm);

             System.out.println("\nCreating temporary organization...\n");
             Organization tmpOrg = createTempOrg();
             Key tmpOrgKey = tmpOrg.getKey();

             System.out.println("\nCreating service...\n");
             Service tmpSvc = createTempService(tmpOrg);
             Key tmpSvcKey = tmpSvc.getKey();

             System.out.println("\nCreating service binding...\n");
             Key sbKey = createServiceBinding(tmpSvc);

             //find serviceBinding
             Collection<ServiceBinding> serviceBindings2 = finder.findServiceBindings(tmpSvcKey );
             @SuppressWarnings("unused")
 			ServiceBinding serviceBinding2 = serviceBindings2.iterator().next();

             // All created ... now try to delete.
             deleteServiceBinding(sbKey);
             deleteTempService(tmpSvcKey);
             deleteTempOrg(tmpOrgKey);
             // No find service binding.. search by name is not currently supported.

         } catch (JAXRException e)
         {
             e.printStackTrace();
             fail(e.getMessage());
         }
     }


     private Key createServiceBinding(Service tmpSvc) throws JAXRException {
     	Key key = null;
         ServiceBinding serviceBinding = blm.createServiceBinding();
         serviceBinding.setName(getIString(serviceBindingName));
         serviceBinding.setDescription(getIString("UDDI service binding"));
         tmpSvc.addServiceBinding(serviceBinding);

         SpecificationLink specLink = blm.createSpecificationLink();
         ExternalLink externalLink = blm.createExternalLink("http://localhost:8080/jmx-console", "Scout test");
         Collection<ExternalLink> externalLinks = new ArrayList<ExternalLink>();
         externalLinks.add(externalLink);
         specLink.setExternalLinks(externalLinks);

         RegistryService rs = connection.getRegistryService();
         bqm = rs.getBusinessQueryManager();
         Concept concept = (Concept)bqm.getRegistryObject("uuid:AD61DE98-4DB8-31B2-A299-A2373DC97212",BusinessLifeCycleManager.CONCEPT);
         specLink.setSpecificationObject(concept);

         serviceBinding.addSpecificationLink(specLink);

         ArrayList<ServiceBinding> serviceBindings = new ArrayList<ServiceBinding>();
         serviceBindings.add(serviceBinding);

         BulkResponse br = blm.saveServiceBindings(serviceBindings);
         if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
         {
             System.out.println("Service Binding Saved");
             key = (Key) br.getCollection().iterator().next();
             System.out.println("Saved Key=" + key.getId());
         } else
         {
             System.err.println("JAXRExceptions " +
                     "occurred during save:");
             Collection exceptions = br.getExceptions();
             Iterator iter = exceptions.iterator();
             while (iter.hasNext())
             {
                 Exception e = (Exception) iter.next();
                 System.err.println(e.toString());
                 fail(e.toString());
             }
         }

         return key;
     }

     private void deleteServiceBinding(Key key) throws JAXRException {

     	String id = key.getId();

     	System.out.println("\nDeleting service binding with id " + id + "\n");

     	Collection<Key> keys = new ArrayList<Key>();
     	keys.add(key);
     	BulkResponse response = blm.deleteServiceBindings(keys);

     	Collection exceptions = response.getExceptions();
     	if (exceptions == null) {
     		Collection retKeys = response.getCollection();
     		Iterator keyIter = retKeys.iterator();
     		javax.xml.registry.infomodel.Key orgKey = null;
     		if (keyIter.hasNext()) {
     			orgKey =
     				(javax.xml.registry.infomodel.Key) keyIter.next();
     			id = orgKey.getId();
     			System.out.println("Service binding with ID=" + id + " was deleted");
     		}
     	}
     }

     private Service createTempService(Organization tmpOrg) throws JAXRException {

         Service service = blm.createService(getIString(serviceName));
         service.setDescription(getIString("Services in UDDI Registry"));
         service.setProvidingOrganization(tmpOrg);

         ArrayList<Service> services = new ArrayList<Service>();
         services.add(service);

         BulkResponse br = blm.saveServices(services);
         if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
         {
             System.out.println("Service Saved");
             Key key = (Key) br.getCollection().iterator().next();
             System.out.println("Saved Key=" + key.getId());
             service.setKey(key);
         } else
         {
             System.err.println("JAXRExceptions " +
                     "occurred during save:");
             Collection exceptions = br.getExceptions();
             Iterator iter = exceptions.iterator();
             while (iter.hasNext())
             {
                 Exception e = (Exception) iter.next();
                 System.err.println(e.toString());
             }
         }

         return service;
     }

     private void deleteTempService(Key key) throws JAXRException {

     	String id = key.getId();

     	System.out.println("\nDeleting service with id " + id + "\n");

     	Collection<Key> keys = new ArrayList<Key>();
     	keys.add(key);
     	BulkResponse response = blm.deleteServices(keys);

     	Collection exceptions = response.getExceptions();
     	if (exceptions == null) {
     		Collection retKeys = response.getCollection();
     		Iterator keyIter = retKeys.iterator();
     		javax.xml.registry.infomodel.Key orgKey = null;
     		if (keyIter.hasNext()) {
     			orgKey =
     				(javax.xml.registry.infomodel.Key) keyIter.next();
     			id = orgKey.getId();
     			System.out.println("Service with ID=" + id + " was deleted");
     		}
     	}
     }

     private Organization createTempOrg() throws JAXRException {

         Key orgKey = null;
         Organization org = blm.createOrganization(getIString(tempOrgName));
         org.setDescription(getIString("Temporary organization to test saveService()"));

         Collection<Organization> orgs = new ArrayList<Organization>();
         orgs.add(org);
         BulkResponse br = blm.saveOrganizations(orgs);

         if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
         {
         	orgKey = (Key) br.getCollection().iterator().next();
             System.out.println("Temporary Organization Created with id=" + orgKey.getId());
             org.setKey(orgKey);
         }  else
         {
             System.err.println("JAXRExceptions " +
                     "occurred during creation of temporary organization:");

             Iterator iter = br.getCollection().iterator();

             while (iter.hasNext()) {
             	Exception e = (Exception) iter.next();
             	System.err.println(e.toString());
             }

             fail();
         }

         return org;
     }

     private void deleteTempOrg(Key key) throws JAXRException {

     	if (key == null) {
     		return;
     	}

     	String id = key.getId();

     	System.out.println("\nDeleting temporary organization with id " + id + "\n");

     	Collection<Key> keys = new ArrayList<Key>();
     	keys.add(key);
     	BulkResponse response = blm.deleteOrganizations(keys);

     	Collection exceptions = response.getExceptions();
     	if (exceptions == null) {
     		Collection retKeys = response.getCollection();
     		Iterator keyIter = retKeys.iterator();
     		Key orgKey = null;
     		if (keyIter.hasNext()) {
     			orgKey =
     				(javax.xml.registry.infomodel.Key) keyIter.next();
     			id = orgKey.getId();
     			System.out.println("Organization with ID=" + id + " was deleted");
     		}
     	}
     }

     private InternationalString getIString(String str)
     throws JAXRException
     {
         return blm.createInternationalString(str);
     }

     public static junit.framework.Test suite() {
         return new JUnit4TestAdapter(JAXR050ServiceBindingTest.class);
     }
 }
	/**
	*
	* Copyright 2004 The Apache Software Foundation
	*
	* 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.
	*/
	package org.apache.ws.scout.registry.qa;

	import static org.junit.Assert.fail;

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

	import javax.xml.registry.BulkResponse;
	import javax.xml.registry.BusinessLifeCycleManager;
	import javax.xml.registry.JAXRException;
	import javax.xml.registry.JAXRResponse;
	import javax.xml.registry.RegistryService;
	import javax.xml.registry.infomodel.Concept;
	import javax.xml.registry.infomodel.ExternalLink;
	import javax.xml.registry.infomodel.InternationalString;
	import javax.xml.registry.infomodel.Key;
	import javax.xml.registry.infomodel.Organization;
	import javax.xml.registry.infomodel.Service;
	import javax.xml.registry.infomodel.ServiceBinding;
	import javax.xml.registry.infomodel.SpecificationLink;

	import junit.framework.JUnit4TestAdapter;

	import org.apache.ws.scout.BaseTestCase;
	import org.apache.ws.scout.Finder;
	import org.junit.After;
	import org.junit.Before;
	import org.junit.Test;

	/**
	Tests Publish, Delete (and indirectly, find) for service bindings.
	*
	* You can comment out the deletion portion and use
	* Open source UDDI Browser <http://www.uddibrowser.org>
	* to check your intermediate results
	*
	* Based on query/publish tests written by
	* <a href="mailto:anil@apache.org">Anil Saldhana</a>.
	*
	* @author <a href="mailto:dbhole@redhat.com">Deepak Bhole</a>
	* @author <a href="mailto:anil@apache.org">Anil Saldhana</a>
	*
	* @since Sep 27, 2005
	*/
	public class JAXR050ServiceBindingTest extends BaseTestCase
	{

	String serviceBindingName = "Apache JAXR Service Binding -- APACHE SCOUT TEST";
	String serviceName = "Apache JAXR Service -- APACHE SCOUT TEST";
	String tempOrgName = "Apache JAXR Service Org -- APACHE SCOUT TEST";

	@Before
	public void setUp()
	{
	super.setUp();
	}
	@After
	public void tearDown()
	{
	super.tearDown();
	}

	/**
	* Tests publishing and deleting of service bindings.
	*
	* Do not break this into testPublish(), testDelete(), etc. Order is
	* important, and not all jvms can guarantee order since the JUnit framework
	* uses getMethods() to gather test methods, and getMethods() does not
	* guarantee order.
	*/
	@Test
	public void testPublishFindAndDeleteServiceBinding()
	{
	login();
	try
	{
	RegistryService rs = connection.getRegistryService();
	blm = rs.getBusinessLifeCycleManager();
	bqm = rs.getBusinessQueryManager();
	Finder finder = new Finder(bqm);

	System.out.println("\nCreating temporary organization...\n");
	Organization tmpOrg = createTempOrg();
	Key tmpOrgKey = tmpOrg.getKey();

	System.out.println("\nCreating service...\n");
	Service tmpSvc = createTempService(tmpOrg);
	Key tmpSvcKey = tmpSvc.getKey();

	System.out.println("\nCreating service binding...\n");
	Key sbKey = createServiceBinding(tmpSvc);

	//find serviceBinding
	Collection<ServiceBinding> serviceBindings2 = finder.findServiceBindings(tmpSvcKey );
	@SuppressWarnings("unused")
	ServiceBinding serviceBinding2 = serviceBindings2.iterator().next();

	// All created ... now try to delete.
	deleteServiceBinding(sbKey);
	deleteTempService(tmpSvcKey);
	deleteTempOrg(tmpOrgKey);
	// No find service binding.. search by name is not currently supported.

	} catch (JAXRException e)
	{
	e.printStackTrace();
	fail(e.getMessage());
	}
	}


	private Key createServiceBinding(Service tmpSvc) throws JAXRException {
	Key key = null;
	ServiceBinding serviceBinding = blm.createServiceBinding();
	serviceBinding.setName(getIString(serviceBindingName));
	serviceBinding.setDescription(getIString("UDDI service binding"));
	tmpSvc.addServiceBinding(serviceBinding);

	SpecificationLink specLink = blm.createSpecificationLink();
	ExternalLink externalLink = blm.createExternalLink("http://localhost:8080/jmx-console", "Scout test");
	Collection<ExternalLink> externalLinks = new ArrayList<ExternalLink>();
	externalLinks.add(externalLink);
	specLink.setExternalLinks(externalLinks);

	RegistryService rs = connection.getRegistryService();
	bqm = rs.getBusinessQueryManager();
	Concept concept = (Concept)bqm.getRegistryObject("uuid:AD61DE98-4DB8-31B2-A299-A2373DC97212",BusinessLifeCycleManager.CONCEPT);
	specLink.setSpecificationObject(concept);

	serviceBinding.addSpecificationLink(specLink);

	ArrayList<ServiceBinding> serviceBindings = new ArrayList<ServiceBinding>();
	serviceBindings.add(serviceBinding);

	BulkResponse br = blm.saveServiceBindings(serviceBindings);
	if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
	{
	System.out.println("Service Binding Saved");
	key = (Key) br.getCollection().iterator().next();
	System.out.println("Saved Key=" + key.getId());
	} else
	{
	System.err.println("JAXRExceptions " +
	"occurred during save:");
	Collection exceptions = br.getExceptions();
	Iterator iter = exceptions.iterator();
	while (iter.hasNext())
	{
	Exception e = (Exception) iter.next();
	System.err.println(e.toString());
	fail(e.toString());
	}
	}

	return key;
	}

	private void deleteServiceBinding(Key key) throws JAXRException {

	String id = key.getId();

	System.out.println("\nDeleting service binding with id " + id + "\n");

	Collection<Key> keys = new ArrayList<Key>();
	keys.add(key);
	BulkResponse response = blm.deleteServiceBindings(keys);

	Collection exceptions = response.getExceptions();
	if (exceptions == null) {
	Collection retKeys = response.getCollection();
	Iterator keyIter = retKeys.iterator();
	javax.xml.registry.infomodel.Key orgKey = null;
	if (keyIter.hasNext()) {
	orgKey =
	(javax.xml.registry.infomodel.Key) keyIter.next();
	id = orgKey.getId();
	System.out.println("Service binding with ID=" + id + " was deleted");
	}
	}
	}

	private Service createTempService(Organization tmpOrg) throws JAXRException {

	Service service = blm.createService(getIString(serviceName));
	service.setDescription(getIString("Services in UDDI Registry"));
	service.setProvidingOrganization(tmpOrg);

	ArrayList<Service> services = new ArrayList<Service>();
	services.add(service);

	BulkResponse br = blm.saveServices(services);
	if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
	{
	System.out.println("Service Saved");
	Key key = (Key) br.getCollection().iterator().next();
	System.out.println("Saved Key=" + key.getId());
	service.setKey(key);
	} else
	{
	System.err.println("JAXRExceptions " +
	"occurred during save:");
	Collection exceptions = br.getExceptions();
	Iterator iter = exceptions.iterator();
	while (iter.hasNext())
	{
	Exception e = (Exception) iter.next();
	System.err.println(e.toString());
	}
	}

	return service;
	}

	private void deleteTempService(Key key) throws JAXRException {

	String id = key.getId();

	System.out.println("\nDeleting service with id " + id + "\n");

	Collection<Key> keys = new ArrayList<Key>();
	keys.add(key);
	BulkResponse response = blm.deleteServices(keys);

	Collection exceptions = response.getExceptions();
	if (exceptions == null) {
	Collection retKeys = response.getCollection();
	Iterator keyIter = retKeys.iterator();
	javax.xml.registry.infomodel.Key orgKey = null;
	if (keyIter.hasNext()) {
	orgKey =
	(javax.xml.registry.infomodel.Key) keyIter.next();
	id = orgKey.getId();
	System.out.println("Service with ID=" + id + " was deleted");
	}
	}
	}

	private Organization createTempOrg() throws JAXRException {

	Key orgKey = null;
	Organization org = blm.createOrganization(getIString(tempOrgName));
	org.setDescription(getIString("Temporary organization to test saveService()"));

	Collection<Organization> orgs = new ArrayList<Organization>();
	orgs.add(org);
	BulkResponse br = blm.saveOrganizations(orgs);

	if (br.getStatus() == JAXRResponse.STATUS_SUCCESS)
	{
	orgKey = (Key) br.getCollection().iterator().next();
	System.out.println("Temporary Organization Created with id=" + orgKey.getId());
	org.setKey(orgKey);
	} else
	{
	System.err.println("JAXRExceptions " +
	"occurred during creation of temporary organization:");

	Iterator iter = br.getCollection().iterator();

	while (iter.hasNext()) {
	Exception e = (Exception) iter.next();
	System.err.println(e.toString());
	}

	fail();
	}

	return org;
	}

	private void deleteTempOrg(Key key) throws JAXRException {

	if (key == null) {
	return;
	}

	String id = key.getId();

	System.out.println("\nDeleting temporary organization with id " + id + "\n");

	Collection<Key> keys = new ArrayList<Key>();
	keys.add(key);
	BulkResponse response = blm.deleteOrganizations(keys);

	Collection exceptions = response.getExceptions();
	if (exceptions == null) {
	Collection retKeys = response.getCollection();
	Iterator keyIter = retKeys.iterator();
	Key orgKey = null;
	if (keyIter.hasNext()) {
	orgKey =
	(javax.xml.registry.infomodel.Key) keyIter.next();
	id = orgKey.getId();
	System.out.println("Organization with ID=" + id + " was deleted");
	}
	}
	}

	private InternationalString getIString(String str)
	throws JAXRException
	{
	return blm.createInternationalString(str);
	}

	public static junit.framework.Test suite() {
	return new JUnit4TestAdapter(JAXR050ServiceBindingTest.class);
	}
	}