| /* |
| * Copyright 2001-2010 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.juddi.v3.client.cli; |
| |
| import java.util.List; |
| import javax.xml.bind.JAXB; |
| import org.apache.juddi.api_v3.AccessPointType; |
| import org.apache.juddi.v3.client.UDDIConstants; |
| import org.apache.juddi.v3.client.config.UDDIClient; |
| import org.apache.juddi.v3.client.transport.Transport; |
| import org.uddi.api_v3.AuthToken; |
| import org.uddi.api_v3.BindingTemplates; |
| import org.uddi.api_v3.BusinessDetail; |
| import org.uddi.api_v3.BusinessInfos; |
| import org.uddi.api_v3.BusinessList; |
| import org.uddi.api_v3.BusinessService; |
| import org.uddi.api_v3.CategoryBag; |
| import org.uddi.api_v3.Contacts; |
| import org.uddi.api_v3.Description; |
| import org.uddi.api_v3.DiscardAuthToken; |
| import org.uddi.api_v3.FindBusiness; |
| import org.uddi.api_v3.FindQualifiers; |
| import org.uddi.api_v3.FindService; |
| import org.uddi.api_v3.FindTModel; |
| import org.uddi.api_v3.GetAuthToken; |
| import org.uddi.api_v3.GetBusinessDetail; |
| import org.uddi.api_v3.GetServiceDetail; |
| import org.uddi.api_v3.KeyedReference; |
| import org.uddi.api_v3.Name; |
| import org.uddi.api_v3.ServiceDetail; |
| import org.uddi.api_v3.ServiceInfos; |
| import org.uddi.api_v3.ServiceList; |
| import org.uddi.api_v3.TModelInfo; |
| import org.uddi.api_v3.TModelInfos; |
| import org.uddi.api_v3.TModelList; |
| import org.uddi.v3_service.UDDIInquiryPortType; |
| import org.uddi.v3_service.UDDISecurityPortType; |
| |
| /** |
| * A Simple UDDI Browser that dumps basic information to console |
| * |
| * @author <a href="mailto:alexoree@apache.org">Alex O'Ree</a> |
| */ |
| public class SimpleBrowse { |
| |
| private UDDISecurityPortType security = null; |
| private UDDIInquiryPortType inquiry = null; |
| |
| /** |
| * This sets up the ws proxies using uddi.xml in META-INF |
| */ |
| public SimpleBrowse() { |
| try { |
| // create a manager and read the config in the archive; |
| // you can use your config file name |
| UDDIClient client = new UDDIClient("META-INF/simple-browse-uddi.xml"); |
| // a UDDIClient can be a client to multiple UDDI nodes, so |
| // supply the nodeName (defined in your uddi.xml. |
| // The transport can be WS, inVM, RMI etc which is defined in the uddi.xml |
| Transport transport = client.getTransport("default"); |
| // Now you create a reference to the UDDI API |
| security = transport.getUDDISecurityService(); |
| inquiry = transport.getUDDIInquiryService(); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| /** |
| * Main entry point |
| * |
| * @param args |
| */ |
| public static void main(String args[]) { |
| |
| SimpleBrowse sp = new SimpleBrowse(); |
| sp.browse(args); |
| } |
| |
| public SimpleBrowse(Transport transport) { |
| try { |
| |
| // Now you create a reference to the UDDI API |
| security = transport.getUDDISecurityService(); |
| inquiry = transport.getUDDIInquiryService(); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| public void browse(String[] args) { |
| try { |
| |
| String token = getAuthKey("uddi", "uddi"); |
| BusinessList findBusiness = getBusinessList(token, null, 0, 100); |
| printBusinessInfo(findBusiness.getBusinessInfos()); |
| printBusinessDetails(findBusiness.getBusinessInfos(), token); |
| printServiceDetailsByBusiness(findBusiness.getBusinessInfos(), token); |
| |
| security.discardAuthToken(new DiscardAuthToken(token)); |
| |
| } catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| /** |
| * Find all of the registered businesses. This list may be filtered |
| * based on access control rules |
| * |
| * @param token |
| * @return |
| * @throws Exception |
| */ |
| private BusinessList getBusinessList(String token, String query, int offset, int maxrecords) throws Exception { |
| FindBusiness fb = new FindBusiness(); |
| fb.setAuthInfo(token); |
| org.uddi.api_v3.FindQualifiers fq = new org.uddi.api_v3.FindQualifiers(); |
| fq.getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| |
| fb.setFindQualifiers(fq); |
| Name searchname = new Name(); |
| if (query == null || query.equalsIgnoreCase("")) { |
| searchname.setValue(UDDIConstants.WILDCARD); |
| } else { |
| searchname.setValue(query); |
| } |
| fb.getName().add(searchname); |
| fb.setListHead(offset); |
| fb.setMaxRows(maxrecords); |
| BusinessList findBusiness = inquiry.findBusiness(fb); |
| return findBusiness; |
| |
| } |
| |
| /** |
| * Converts category bags of tmodels to a readable string |
| * |
| * @param categoryBag |
| * @return |
| */ |
| private String catBagToString(CategoryBag categoryBag) { |
| StringBuilder sb = new StringBuilder(); |
| if (categoryBag == null) { |
| return "no data"; |
| } |
| for (int i = 0; i < categoryBag.getKeyedReference().size(); i++) { |
| sb.append(keyedReferenceToString(categoryBag.getKeyedReference().get(i))); |
| } |
| for (int i = 0; i < categoryBag.getKeyedReferenceGroup().size(); i++) { |
| sb.append("Key Ref Grp: TModelKey="); |
| for (int k = 0; k < categoryBag.getKeyedReferenceGroup().get(i).getKeyedReference().size(); k++) { |
| sb.append(keyedReferenceToString(categoryBag.getKeyedReferenceGroup().get(i).getKeyedReference().get(k))); |
| } |
| } |
| return sb.toString(); |
| } |
| |
| private String keyedReferenceToString(KeyedReference item) { |
| StringBuilder sb = new StringBuilder(); |
| sb.append("Key Ref: Name="). |
| append(item.getKeyName()). |
| append(" Value="). |
| append(item.getKeyValue()). |
| append(" tModel="). |
| append(item.getTModelKey()). |
| append(System.getProperty("line.separator")); |
| return sb.toString(); |
| } |
| |
| private void printContacts(Contacts contacts) { |
| if (contacts == null) { |
| return; |
| } |
| for (int i = 0; i < contacts.getContact().size(); i++) { |
| System.out.println("Contact " + i + " type:" + contacts.getContact().get(i).getUseType()); |
| for (int k = 0; k < contacts.getContact().get(i).getPersonName().size(); k++) { |
| System.out.println("Name: " + contacts.getContact().get(i).getPersonName().get(k).getValue()); |
| } |
| for (int k = 0; k < contacts.getContact().get(i).getEmail().size(); k++) { |
| System.out.println("Email: " + contacts.getContact().get(i).getEmail().get(k).getValue()); |
| } |
| for (int k = 0; k < contacts.getContact().get(i).getAddress().size(); k++) { |
| System.out.println("Address sort code " + contacts.getContact().get(i).getAddress().get(k).getSortCode()); |
| System.out.println("Address use type " + contacts.getContact().get(i).getAddress().get(k).getUseType()); |
| System.out.println("Address tmodel key " + contacts.getContact().get(i).getAddress().get(k).getTModelKey()); |
| for (int x = 0; x < contacts.getContact().get(i).getAddress().get(k).getAddressLine().size(); x++) { |
| System.out.println("Address line value " + contacts.getContact().get(i).getAddress().get(k).getAddressLine().get(x).getValue()); |
| System.out.println("Address line key name " + contacts.getContact().get(i).getAddress().get(k).getAddressLine().get(x).getKeyName()); |
| System.out.println("Address line key value " + contacts.getContact().get(i).getAddress().get(k).getAddressLine().get(x).getKeyValue()); |
| } |
| } |
| for (int k = 0; k < contacts.getContact().get(i).getDescription().size(); k++) { |
| System.out.println("Desc: " + contacts.getContact().get(i).getDescription().get(k).getValue()); |
| } |
| for (int k = 0; k < contacts.getContact().get(i).getPhone().size(); k++) { |
| System.out.println("Phone: " + contacts.getContact().get(i).getPhone().get(k).getValue()); |
| } |
| } |
| |
| } |
| |
| private void printServiceDetail(BusinessService get) { |
| if (get == null) { |
| return; |
| } |
| System.out.println("Name " + listToString(get.getName())); |
| System.out.println("Desc " + listToDescString(get.getDescription())); |
| System.out.println("Key " + (get.getServiceKey())); |
| System.out.println("Cat bag " + catBagToString(get.getCategoryBag())); |
| if (!get.getSignature().isEmpty()) { |
| System.out.println("Item is digitally signed"); |
| } else { |
| System.out.println("Item is not digitally signed"); |
| } |
| printBindingTemplates(get.getBindingTemplates()); |
| } |
| |
| /** |
| * This function is useful for translating UDDI's somewhat complex data |
| * format to something that is more useful. |
| * |
| * @param bindingTemplates |
| */ |
| private void printBindingTemplates(BindingTemplates bindingTemplates) { |
| if (bindingTemplates == null) { |
| return; |
| } |
| for (int i = 0; i < bindingTemplates.getBindingTemplate().size(); i++) { |
| System.out.println("Binding Key: " + bindingTemplates.getBindingTemplate().get(i).getBindingKey()); |
| //TODO The UDDI spec is kind of strange at this point. |
| //An access point could be a URL, a reference to another UDDI binding key, a hosting redirector (which is |
| //esscentially a pointer to another UDDI registry) or a WSDL Deployment |
| //From an end client's perspective, all you really want is the endpoint. |
| //http://uddi.org/pubs/uddi_v3.htm#_Ref8977716 |
| //So if you have a wsdlDeployment useType, fetch the wsdl and parse for the invocation URL |
| //If its hosting director, you'll have to fetch that data from uddi recursively until the leaf node is found |
| //Consult the UDDI specification for more information |
| |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint() != null) { |
| System.out.println("Access Point: " + bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getValue() + " type " + bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType()); |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType() != null) { |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType().equalsIgnoreCase(AccessPointType.END_POINT.toString())) { |
| System.out.println("Use this access point value as an invocation endpoint."); |
| } |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType().equalsIgnoreCase(AccessPointType.BINDING_TEMPLATE.toString())) { |
| System.out.println("Use this access point value as a reference to another binding template."); |
| } |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType().equalsIgnoreCase(AccessPointType.WSDL_DEPLOYMENT.toString())) { |
| System.out.println("Use this access point value as a URL to a WSDL document, which presumably will have a real access point defined."); |
| } |
| if (bindingTemplates.getBindingTemplate().get(i).getAccessPoint().getUseType().equalsIgnoreCase(AccessPointType.HOSTING_REDIRECTOR.toString())) { |
| System.out.println("Use this access point value as an Inquiry URL of another UDDI registry, look up the same binding template there (usage varies)."); |
| } |
| } |
| } |
| |
| } |
| } |
| |
| public void printBusinessList(String authtoken, String searchString, boolean rawXml) throws Exception { |
| |
| int offset = 0; |
| int maxrecords = 100; |
| BusinessList findBusiness = getBusinessList(authtoken, searchString, offset, maxrecords); |
| while (findBusiness != null && findBusiness.getBusinessInfos() != null |
| && !findBusiness.getBusinessInfos().getBusinessInfo().isEmpty()) { |
| if (rawXml) { |
| JAXB.marshal(findBusiness, System.out); |
| } else { |
| printBusinessInfo(findBusiness.getBusinessInfos()); |
| printBusinessDetails(findBusiness.getBusinessInfos(), authtoken); |
| printServiceDetailsByBusiness(findBusiness.getBusinessInfos(), authtoken); |
| } |
| offset = offset + maxrecords; |
| |
| findBusiness = getBusinessList(authtoken, searchString, offset, maxrecords); |
| } |
| } |
| |
| public void printServiceList(String authtoken, String searchString, boolean rawXml) throws Exception { |
| |
| int offset = 0; |
| int maxrecords = 100; |
| ServiceList findBusiness = getServiceList(authtoken, searchString, offset, maxrecords); |
| while (findBusiness != null && findBusiness.getServiceInfos() != null |
| && !findBusiness.getServiceInfos().getServiceInfo().isEmpty()) { |
| if (rawXml) { |
| JAXB.marshal(findBusiness, System.out); |
| } else { |
| printServiceInfo(findBusiness.getServiceInfos()); |
| //PrintBusinessDetails(findBusiness.getBusinessInfos(), authtoken); |
| //PrintServiceDetailsByBusiness(findBusiness.getBusinessInfos(), authtoken); |
| } |
| offset = offset + maxrecords; |
| |
| findBusiness = getServiceList(authtoken, searchString, offset, maxrecords); |
| } |
| } |
| |
| private ServiceList getServiceList(String authtoken, String searchString, int offset, int maxrecords) throws Exception { |
| FindService fs = new FindService(); |
| fs.setAuthInfo(authtoken); |
| fs.setListHead(offset); |
| fs.setMaxRows(maxrecords); |
| if (searchString != null) { |
| fs.getName().add(new Name("%" + searchString + " %", null)); |
| |
| } else { |
| fs.getName().add(new Name(UDDIConstants.WILDCARD, null)); |
| } |
| fs.setFindQualifiers(new FindQualifiers()); |
| fs.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| return inquiry.findService(fs); |
| } |
| |
| void printTModelList(String authtoken, String searchString, boolean rawXml) throws Exception { |
| int offset = 0; |
| int maxrecords = 100; |
| TModelList findBusiness = getTmodelList(authtoken, searchString, offset, maxrecords); |
| while (findBusiness != null && findBusiness.getTModelInfos() != null |
| && !findBusiness.getTModelInfos().getTModelInfo().isEmpty()) { |
| if (rawXml) { |
| JAXB.marshal(findBusiness, System.out); |
| } else { |
| printTModelInfo(findBusiness.getTModelInfos()); |
| //PrintBusinessDetails(findBusiness.getBusinessInfos(), authtoken); |
| //PrintServiceDetailsByBusiness(findBusiness.getBusinessInfos(), authtoken); |
| } |
| offset = offset + maxrecords; |
| |
| findBusiness = getTmodelList(authtoken, searchString, offset, maxrecords); |
| } |
| } |
| |
| private void printTModelInfo(TModelInfos tModelInfos) { |
| if (tModelInfos == null) { |
| System.out.println("No data returned"); |
| return; |
| } |
| for (TModelInfo tModelInfo : tModelInfos.getTModelInfo()) { |
| System.out.println("tModel key: " + tModelInfo.getTModelKey()); |
| System.out.println("tModel name: " + tModelInfo.getName().getLang() + " " + tModelInfo.getName().getValue()); |
| // PrintServiceInfo(null); |
| for (int k = 0; k < tModelInfo.getDescription().size(); k++) { |
| System.out.println("Desc: " + tModelInfo.getDescription().get(k).getValue()); |
| } |
| } |
| } |
| |
| private TModelList getTmodelList(String authtoken, String searchString, int offset, int maxrecords) throws Exception { |
| FindTModel fs = new FindTModel(); |
| fs.setAuthInfo(authtoken); |
| fs.setListHead(offset); |
| fs.setMaxRows(maxrecords); |
| if (searchString != null) { |
| fs.setName(new Name("%" + searchString + " %", null)); |
| |
| } else { |
| fs.setName(new Name(UDDIConstants.WILDCARD, null)); |
| } |
| fs.setFindQualifiers(new FindQualifiers()); |
| fs.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| return inquiry.findTModel(fs); |
| } |
| |
| private enum AuthStyle { |
| |
| HTTP_BASIC, |
| HTTP_DIGEST, |
| HTTP_NTLM, |
| UDDI_AUTH, |
| HTTP_CLIENT_CERT |
| } |
| |
| /** |
| * Gets a UDDI style auth token, otherwise, appends credentials to the |
| * ws proxies (not yet implemented) |
| * |
| * @param username |
| * @param password |
| * @param style |
| * @return |
| */ |
| private String getAuthKey(String username, String password) { |
| try { |
| |
| GetAuthToken getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(username); |
| getAuthTokenRoot.setCred(password); |
| |
| // Making API call that retrieves the authentication token for the user. |
| AuthToken rootAuthToken = security.getAuthToken(getAuthTokenRoot); |
| System.out.println(username + " AUTHTOKEN = (don't log auth tokens!"); |
| return rootAuthToken.getAuthInfo(); |
| } catch (Exception ex) { |
| System.out.println("Could not authenticate with the provided credentials " + ex.getMessage()); |
| } |
| return null; |
| } |
| |
| private void printBusinessInfo(BusinessInfos businessInfos) { |
| if (businessInfos == null) { |
| System.out.println("No data returned"); |
| } else { |
| for (int i = 0; i < businessInfos.getBusinessInfo().size(); i++) { |
| System.out.println("==============================================="); |
| System.out.println("Business Key: " + businessInfos.getBusinessInfo().get(i).getBusinessKey()); |
| System.out.println("Name: " + listToString(businessInfos.getBusinessInfo().get(i).getName())); |
| |
| System.out.println("Description: " + listToDescString(businessInfos.getBusinessInfo().get(i).getDescription())); |
| System.out.println("Services:"); |
| printServiceInfo(businessInfos.getBusinessInfo().get(i).getServiceInfos()); |
| } |
| } |
| } |
| |
| private String listToString(List<Name> name) { |
| StringBuilder sb = new StringBuilder(); |
| for (int i = 0; i < name.size(); i++) { |
| sb.append(name.get(i).getValue()).append(" "); |
| } |
| return sb.toString(); |
| } |
| |
| private String listToDescString(List<Description> name) { |
| StringBuilder sb = new StringBuilder(); |
| for (int i = 0; i < name.size(); i++) { |
| sb.append(name.get(i).getValue()).append(" "); |
| } |
| return sb.toString(); |
| } |
| |
| private void printServiceInfo(ServiceInfos serviceInfos) { |
| for (int i = 0; i < serviceInfos.getServiceInfo().size(); i++) { |
| System.out.println("-------------------------------------------"); |
| System.out.println("Service Key: " + serviceInfos.getServiceInfo().get(i).getServiceKey()); |
| System.out.println("Owning Business Key: " + serviceInfos.getServiceInfo().get(i).getBusinessKey()); |
| System.out.println("Name: " + listToString(serviceInfos.getServiceInfo().get(i).getName())); |
| } |
| } |
| |
| private void printBusinessDetails(BusinessInfos businessInfos, String token) throws Exception { |
| GetBusinessDetail gbd = new GetBusinessDetail(); |
| gbd.setAuthInfo(token); |
| for (int i = 0; i < businessInfos.getBusinessInfo().size(); i++) { |
| gbd.getBusinessKey().add(businessInfos.getBusinessInfo().get(i).getBusinessKey()); |
| } |
| BusinessDetail businessDetail = inquiry.getBusinessDetail(gbd); |
| for (int i = 0; i < businessDetail.getBusinessEntity().size(); i++) { |
| System.out.println("Business Detail - key: " + businessDetail.getBusinessEntity().get(i).getBusinessKey()); |
| System.out.println("Name: " + listToString(businessDetail.getBusinessEntity().get(i).getName())); |
| System.out.println("CategoryBag: " + catBagToString(businessDetail.getBusinessEntity().get(i).getCategoryBag())); |
| printContacts(businessDetail.getBusinessEntity().get(i).getContacts()); |
| } |
| } |
| |
| private void printServiceDetailsByBusiness(BusinessInfos businessInfos, String token) throws Exception { |
| for (int i = 0; i < businessInfos.getBusinessInfo().size(); i++) { |
| GetServiceDetail gsd = new GetServiceDetail(); |
| for (int k = 0; k < businessInfos.getBusinessInfo().get(i).getServiceInfos().getServiceInfo().size(); k++) { |
| gsd.getServiceKey().add(businessInfos.getBusinessInfo().get(i).getServiceInfos().getServiceInfo().get(k).getServiceKey()); |
| } |
| gsd.setAuthInfo(token); |
| System.out.println("Fetching data for business " + businessInfos.getBusinessInfo().get(i).getBusinessKey()); |
| ServiceDetail serviceDetail = inquiry.getServiceDetail(gsd); |
| for (int k = 0; k < serviceDetail.getBusinessService().size(); k++) { |
| printServiceDetail(serviceDetail.getBusinessService().get(k)); |
| } |
| System.out.println("................"); |
| |
| } |
| } |
| } |
