Author: tcunning
Date: Thu Apr 16 05:52:25 2009
New Revision: 765475

URL: http://svn.apache.org/viewvc?rev=765475&view=rev
Log:
SCOUT-55
Use GetRegisteredInfo to grab the organizations owned.

Modified:
    
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/BusinessQueryManagerImpl.java
    
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/IRegistry.java
    
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/RegistryImpl.java
    
webservices/scout/trunk/scout/src/test/java/org/apache/ws/scout/registry/BusinessQueryManager2Test.java

Modified: 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/BusinessQueryManagerImpl.java
URL: 
http://svn.apache.org/viewvc/webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/BusinessQueryManagerImpl.java?rev=765475&r1=765474&r2=765475&view=diff
==============================================================================
--- 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/BusinessQueryManagerImpl.java
 (original)
+++ 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/BusinessQueryManagerImpl.java
 Thu Apr 16 05:52:25 2009
@@ -57,6 +57,7 @@
 import org.apache.ws.scout.uddi.BusinessDetail;
 import org.apache.ws.scout.uddi.BusinessEntity;
 import org.apache.ws.scout.uddi.BusinessInfo;
+import org.apache.ws.scout.uddi.BusinessInfos;
 import org.apache.ws.scout.uddi.BusinessList;
 import org.apache.ws.scout.uddi.BusinessService;
 import org.apache.ws.scout.uddi.FindQualifiers;
@@ -64,6 +65,7 @@
 import org.apache.ws.scout.uddi.Name;
 import org.apache.ws.scout.uddi.PublisherAssertion;
 import org.apache.ws.scout.uddi.PublisherAssertions;
+import org.apache.ws.scout.uddi.RegisteredInfo;
 import org.apache.ws.scout.uddi.ServiceDetail;
 import org.apache.ws.scout.uddi.ServiceInfo;
 import org.apache.ws.scout.uddi.ServiceInfos;
@@ -718,8 +720,7 @@
                 throw new JAXRException(e.getLocalizedMessage());
             }
         }
-        else if (LifeCycleManager.ORGANIZATION.equalsIgnoreCase(objectType)) {
-
+        else if (LifeCycleManager.ORGANIZATION.equalsIgnoreCase(objectType)) { 
        
             try
             {
                 BusinessDetail orgdetail = registry.getBusinessDetail(id);
@@ -729,6 +730,7 @@
                 e.printStackTrace();
                 throw new JAXRException(e.getLocalizedMessage());
             }
+
         }
         else if (LifeCycleManager.CONCEPT.equalsIgnoreCase(objectType)) {
 
@@ -861,18 +863,27 @@
         }
         else if (LifeCycleManager.ORGANIZATION.equalsIgnoreCase(objectType))
         {
-            //Get the Organization from the uddi registry
+               ConnectionImpl con = 
((RegistryServiceImpl)getRegistryService()).getConnection();
+            AuthToken auth = this.getAuthToken(con,registry);
+               
             try
             {
-                BusinessDetail orgdetail = registry.getBusinessDetail(keys);
-                BusinessEntity[] bizarr = orgdetail.getBusinessEntityArray();
-                for (int i = 0; bizarr != null && i < bizarr.length; i++)
-                {
-                    col.add(ScoutUddiJaxrHelper.getOrganization(bizarr[i], 
lcm));
-                }
-            } catch (RegistryException e)
-            {
-                throw new JAXRException(e.getLocalizedMessage());
+               RegisteredInfo ri = 
registry.getRegisteredInfo(auth.getAuthInfo());
+               BusinessInfos infos = null;
+               BusinessInfo[] biarr = null;
+               
+               if (ri != null) infos = ri.getBusinessInfos();
+               if (infos != null) biarr = infos.getBusinessInfoArray();
+                               
+               for (int i = 0; i < biarr.length; i++) {
+                       BusinessInfo info = biarr[i];
+                       BusinessDetail detail = 
registry.getBusinessDetail(info.getBusinessKey());
+
+                    
col.add(registryService.getLifeCycleManagerImpl().createOrganization(detail));
+               }
+            } catch (RegistryException e) {
+                    e.printStackTrace();
+                    throw new JAXRException(e.getLocalizedMessage());
             }
         }
         else if (LifeCycleManager.CONCEPT.equalsIgnoreCase(objectType))
@@ -925,12 +936,37 @@
     public BulkResponse getRegistryObjects(String id) throws JAXRException
     {
         if (LifeCycleManager.ORGANIZATION.equalsIgnoreCase(id)) {
-            List<String> a = new ArrayList<String>();
-            a.add("%");
+            IRegistry registry = registryService.getRegistry();
 
-            BulkResponse br = findOrganizations(null, a, null, null, null, 
null);
+               ConnectionImpl con = 
((RegistryServiceImpl)getRegistryService()).getConnection();
+            AuthToken auth = this.getAuthToken(con,registry);
 
-            return br;
+            BulkResponse br = null;
+               LinkedHashSet<Organization> orgs = null;
+            
+            try
+            {
+               RegisteredInfo ri = 
registry.getRegisteredInfo(auth.getAuthInfo());
+               BusinessInfos infos = null;
+               BusinessInfo[] biarr = null;
+               
+               if (ri != null) infos = ri.getBusinessInfos();
+               if (infos != null) biarr = infos.getBusinessInfoArray();
+               
+               if (biarr != null) {
+                    orgs = new LinkedHashSet<Organization>();
+               }
+               
+               for (int i = 0; i < biarr.length; i++) {
+                       BusinessInfo info = biarr[i];
+                       BusinessDetail detail = 
registry.getBusinessDetail(info.getBusinessKey());
+
+                    
orgs.add(registryService.getLifeCycleManagerImpl().createOrganization(detail));
+               }
+            } catch (RegistryException re) {
+               throw new JAXRException(re);
+            }
+            return new BulkResponseImpl(orgs);
         }
         else if (LifeCycleManager.SERVICE.equalsIgnoreCase(id)) {
             List<String> a = new ArrayList<String>();

Modified: 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/IRegistry.java
URL: 
http://svn.apache.org/viewvc/webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/IRegistry.java?rev=765475&r1=765474&r2=765475&view=diff
==============================================================================
--- 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/IRegistry.java
 (original)
+++ 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/IRegistry.java
 Thu Apr 16 05:52:25 2009
@@ -34,6 +34,7 @@
 import org.apache.ws.scout.uddi.Name;
 import org.apache.ws.scout.uddi.PublisherAssertion;
 import org.apache.ws.scout.uddi.PublisherAssertions;
+import org.apache.ws.scout.uddi.RegisteredInfo;
 import org.apache.ws.scout.uddi.ServiceDetail;
 import org.apache.ws.scout.uddi.ServiceList;
 import org.apache.ws.scout.uddi.TModel;
@@ -68,7 +69,7 @@
        /**
         * @return Returns the publishURL.
         */
-       URI getPublishURI();
+       URI getPublishURI();    
        
        /**
         * @param publishURL The publishURL to set.
@@ -223,6 +224,12 @@
            throws RegistryException;
          
          /**
+          * @exception RegistryException;
+          */
+         RegisteredInfo getRegisteredInfo(String authInfo)
+               throws RegistryException;
+         
+         /**
           * "Used to locate one or more tModel information structures. Returns 
a
           *  tModelList structure."
           *

Modified: 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/RegistryImpl.java
URL: 
http://svn.apache.org/viewvc/webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/RegistryImpl.java?rev=765475&r1=765474&r2=765475&view=diff
==============================================================================
--- 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/RegistryImpl.java
 (original)
+++ 
webservices/scout/trunk/scout/src/main/java/org/apache/ws/scout/registry/RegistryImpl.java
 Thu Apr 16 05:52:25 2009
@@ -70,6 +70,8 @@
 import org.apache.ws.scout.uddi.GetBusinessDetailDocument;
 import org.apache.ws.scout.uddi.GetPublisherAssertions;
 import org.apache.ws.scout.uddi.GetPublisherAssertionsDocument;
+import org.apache.ws.scout.uddi.GetRegisteredInfo;
+import org.apache.ws.scout.uddi.GetRegisteredInfoDocument;
 import org.apache.ws.scout.uddi.GetServiceDetail;
 import org.apache.ws.scout.uddi.GetServiceDetailDocument;
 import org.apache.ws.scout.uddi.GetTModelDetail;
@@ -79,6 +81,8 @@
 import org.apache.ws.scout.uddi.PublisherAssertion;
 import org.apache.ws.scout.uddi.PublisherAssertions;
 import org.apache.ws.scout.uddi.PublisherAssertionsDocument;
+import org.apache.ws.scout.uddi.RegisteredInfo;
+import org.apache.ws.scout.uddi.RegisteredInfoDocument;
 import org.apache.ws.scout.uddi.SaveBinding;
 import org.apache.ws.scout.uddi.SaveBindingDocument;
 import org.apache.ws.scout.uddi.SaveBusiness;
@@ -920,6 +924,27 @@
        }
 
        /**
+        * @exception RegistryException;
+        */
+       public RegisteredInfo getRegisteredInfo(String authInfo)
+                       throws RegistryException {
+               GetRegisteredInfoDocument doc = 
GetRegisteredInfoDocument.Factory
+                               .newInstance();
+               GetRegisteredInfo request = doc.addNewGetRegisteredInfo();
+
+               if (authInfo != null) {
+                       request.setAuthInfo(authInfo);
+               }
+
+        RegisteredInfo ri;
+        XmlObject o = execute(doc, this.getPublishURI()).changeType(
+                RegisteredInfoDocument.type);
+        ri = ((RegisteredInfoDocument) o).getRegisteredInfo();
+
+        return ri;
+       }
+       
+       /**
         * "Used to get full details for a particular registered 
businessService.
         * Returns a serviceDetail message."
         * 

Modified: 
webservices/scout/trunk/scout/src/test/java/org/apache/ws/scout/registry/BusinessQueryManager2Test.java
URL: 
http://svn.apache.org/viewvc/webservices/scout/trunk/scout/src/test/java/org/apache/ws/scout/registry/BusinessQueryManager2Test.java?rev=765475&r1=765474&r2=765475&view=diff
==============================================================================
--- 
webservices/scout/trunk/scout/src/test/java/org/apache/ws/scout/registry/BusinessQueryManager2Test.java
 (original)
+++ 
webservices/scout/trunk/scout/src/test/java/org/apache/ws/scout/registry/BusinessQueryManager2Test.java
 Thu Apr 16 05:52:25 2009
@@ -63,6 +63,7 @@
         super.tearDown();
     }
        
+    @Test
        public void testGetRegistryObjects() {
         login();
         try {



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to