| /* |
| * Copyright 2015 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 org.apache.juddi.api_v3.Node; |
| 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.BusinessList; |
| import org.uddi.api_v3.DeleteBusiness; |
| import org.uddi.api_v3.DeleteService; |
| import org.uddi.api_v3.DeleteTModel; |
| 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.Name; |
| import org.uddi.api_v3.ServiceList; |
| import org.uddi.api_v3.TModelList; |
| import org.uddi.v3_service.UDDIInquiryPortType; |
| import org.uddi.v3_service.UDDISecurityPortType; |
| |
| /** |
| * |
| * @author alex |
| */ |
| public class EntryPointSingleNode { |
| |
| static void goSingleNode() throws Exception { |
| String currentNode = "default"; |
| UDDIClient clerkManager = new UDDIClient("META-INF/simple-publish-uddi.xml"); |
| |
| List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList(); |
| System.out.println(); |
| |
| System.out.println("Nodes:"); |
| for (int i = 0; i < uddiNodeList.size(); i++) { |
| System.out.println((i + 1) + ") Node name: " + uddiNodeList.get(i).getName()); |
| } |
| System.out.print("Destination Node: "); |
| int index = Integer.parseInt(System.console().readLine()) - 1; |
| |
| currentNode = uddiNodeList.get(index).getName(); |
| Transport transport = clerkManager.getTransport(currentNode); |
| authtoken = login(currentNode, transport); |
| String input = null; |
| do { |
| System.out.println(" 1) Login"); |
| System.out.println(" 2) Print auth token"); |
| System.out.println(" 3) Logout (discard auth token)"); |
| |
| System.out.println("- [ Searching and Browsing ] -"); |
| System.out.println(" 4) List all Businesses (XML)"); |
| System.out.println(" 5) List all Businesses (Human readable)"); |
| System.out.println(" 6) List all Services (XML)"); |
| System.out.println(" 7) List all Services (Human readable)"); |
| System.out.println(" 8) List all tModels (XML)"); |
| System.out.println(" 9) List all tModels (Human readable)"); |
| System.out.println("10) Find a Business"); |
| System.out.println("11) Find a Service"); |
| System.out.println("12) Find a tModel"); |
| |
| System.out.println("13) Find Binding by QOS Parameters (Binding/tModelInstanceInfo)"); |
| System.out.println("14) Find Business by QOS Parameters (Binding/tModelInstanceInfo)"); |
| System.out.println("15) Find Service by QOS Parameters (Binding/tModelInstanceInfo)"); |
| System.out.println("16) Find a Binding, lists all bindings for all services"); |
| System.out.println("17) Find Endpoints of a service (given the key)"); |
| System.out.println("18) Get the details of a service"); |
| System.out.println("19) UDDI Digital Signatures - Search for Signed Items"); |
| |
| System.out.println("- [ Publishing ] -"); |
| System.out.println("20) Make a Key Generator tModel"); |
| System.out.println("22) WSDL2UDDI - Register a service from a WSDL document (business key required)"); |
| System.out.println("23) WADL2UDDI - Register a service from a WADL document (business key required)"); |
| System.out.println("24) UDDI Custody Transfer (within a single node)"); |
| |
| System.out.println("25) UDDI Digital Signatures - Sign a Business"); |
| System.out.println("26) UDDI Digital Signatures - Sign a Service"); |
| System.out.println("27) UDDI Digital Signatures - Sign a tModel"); |
| |
| System.out.println("28) Create a Business Relationship Between two users and two Businesses(Publisher Assertion)"); |
| |
| System.out.println("- [ Subscriptions ] -"); |
| System.out.println("29) Subscriptions - Asynchronous, listens for all changes (req stored credentials)"); |
| System.out.println("30) Subscriptions - Synchronous"); |
| System.out.println("31) Print Subscriptions"); |
| System.out.println("32) Delete a subscription"); |
| System.out.println("33) Delete all subscriptions"); |
| System.out.println("34) Subscriptions - Asynchronous, publisher assertion subscriptions"); |
| |
| System.out.println("- [ Replication ] -"); |
| System.out.println("35) Replication - do_ping"); |
| System.out.println("36) Replication - get high watermarks"); |
| System.out.println("37) Replication - get change records"); |
| System.out.println("38) Replication - get failed change records (jUDDI only)"); |
| |
| //remote config management - juddi only |
| System.out.println("- [ jUDDI Configuration Management ] -"); |
| System.out.println("39) Quick register the jUDDI cloud node to the current node"); |
| System.out.println("40) Register the a locally defined node to another jUDDI server"); |
| System.out.println("41) View all registered remote nodes on a jUDDI server"); |
| System.out.println("42) UnRegister a node on a jUDDI server"); |
| |
| //juddi only |
| System.out.println("43) View the replication config from the current jUDDI server"); |
| System.out.println("44) Set the replication config on a remote jUDDI server"); |
| System.out.println("45) Prints the current replication status of a given node"); |
| |
| //deleters |
| System.out.println("47) Bulk delete business"); |
| System.out.println("48) Bulk delete services"); |
| System.out.println("49) Bulk delete tModels"); |
| |
| System.out.println("q) quit"); |
| System.out.print(username + "@" + currentNode + "# "); |
| input = System.console().readLine(); |
| try { |
| processInput(input, currentNode, transport, clerkManager); |
| } catch (Exception ex) { |
| ex.printStackTrace(); |
| } |
| } while (!input.equalsIgnoreCase("q")); |
| } |
| private static String authtoken = null; |
| static String password; |
| static String username; |
| |
| private static String login(String currentNode, Transport transport) throws Exception { |
| System.out.println("Options:"); |
| System.out.println("1) Enter a username/password for auth token"); |
| System.out.println("2) Enter a username/password for HTTP based logins"); |
| System.out.println("3) Enter a username/password for use stored credentials"); |
| System.out.print("Login Method: "); |
| String input = System.console().readLine(); |
| if ("1".equalsIgnoreCase(input)) { |
| UDDISecurityPortType security = null; |
| security = transport.getUDDISecurityService(); |
| System.out.print(currentNode + "# username: "); |
| username = System.console().readLine(); |
| char passwordArray[] = System.console().readPassword(currentNode + "# password: "); |
| GetAuthToken getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(username); |
| password = new String(passwordArray); |
| getAuthTokenRoot.setCred((password)); |
| String lauthtoken = security.getAuthToken(getAuthTokenRoot).getAuthInfo(); |
| System.out.println("Success!"); |
| return lauthtoken; |
| } else if ("2".equalsIgnoreCase(input)) { |
| System.out.println("not implemented yet!"); |
| |
| } else if ("3".equalsIgnoreCase(input)) { |
| System.out.println("not implemented yet!"); |
| } else { |
| System.out.println("Aborted!"); |
| } |
| return null; |
| |
| } |
| |
| private static void processInput(final String input, final String currentNode, final Transport transport, UDDIClient client) throws Exception { |
| if (input == null) { |
| return; |
| } |
| if (input.equals("1")) { |
| authtoken = login(currentNode, transport); |
| } else if (input.equals("2")) { |
| System.out.println("Token info: " + authtoken); |
| } else if (input.equals("3")) { |
| if (authtoken != null) { |
| UDDISecurityPortType security = null; |
| security = transport.getUDDISecurityService(); |
| DiscardAuthToken getAuthTokenRoot = new DiscardAuthToken(); |
| getAuthTokenRoot.setAuthInfo(authtoken); |
| security.discardAuthToken(getAuthTokenRoot); |
| System.out.println("Success!"); |
| } |
| } else if (input.equals("4")) { |
| new SimpleBrowse(transport).printBusinessList(authtoken, null, true); |
| } else if (input.equals("5")) { |
| new SimpleBrowse(transport).printBusinessList(authtoken, null, false); |
| } else if (input.equals("6")) { |
| new SimpleBrowse(transport).printServiceList(authtoken, null, true); |
| } else if (input.equals("7")) { |
| new SimpleBrowse(transport).printServiceList(authtoken, null, false); |
| } else if (input.equals("8")) { |
| new SimpleBrowse(transport).printTModelList(authtoken, null, true); |
| } else if (input.equals("9")) { |
| new SimpleBrowse(transport).printTModelList(authtoken, null, false); |
| } else if (input.equals("10")) { |
| System.out.print("Tip: (use % for wildcard searches)"); |
| System.out.print("Name to search for: "); |
| String url = (System.console().readLine()); |
| new SimpleBrowse(transport).printBusinessList(authtoken, url, false); |
| } else if (input.equals("11")) { |
| System.out.print("Tip: (use % for wildcard searches)"); |
| System.out.print("Name to search for: "); |
| String url = (System.console().readLine()); |
| new SimpleBrowse(transport).printServiceList(authtoken, url, false); |
| } else if (input.equals("12")) { |
| System.out.print("Tip: (use % for wildcard searches)"); |
| System.out.print("Name to search for: "); |
| String url = (System.console().readLine()); |
| new SimpleBrowse(transport).printTModelList(authtoken, url, false); |
| } else if (input.equals("13")) { |
| new SearchByQos().doFindBinding(authtoken, transport); |
| } else if (input.equals("14")) { |
| new SearchByQos().doFindBusiness(authtoken, transport); |
| } else if (input.equals("15")) { |
| new SearchByQos().doFindService(authtoken, transport); |
| } else if (input.equals("16")) { |
| new UddiFindBinding().fire(authtoken); |
| } else if (input.equals("17")) { |
| System.out.print("Service key to parse the endpoints: "); |
| String key = (System.console().readLine()); |
| new UddiFindEndpoints().fire(authtoken, key); |
| } else if (input.equals("18")) { |
| System.out.print("Service key: "); |
| String key = (System.console().readLine()); |
| new UddiGetServiceDetails().fire(authtoken, key); |
| } else if (input.equals("19")) { |
| new UddiDigitalSignatureSearch().fire(authtoken); |
| } else if (input.equals("20")) { |
| System.out.print("Get FQDN: "); |
| String key = (System.console().readLine()); |
| new UddiKeyGenerator().fire(authtoken, key); |
| } else if (input.equals("22")) { |
| System.out.print("Path or URL to WSDL file: "); |
| String url = (System.console().readLine()); |
| System.out.print("Business key to attach to: "); |
| String key = (System.console().readLine()); |
| new WsdlImport().fire(url, key, authtoken, transport); |
| } else if (input.equals("23")) { |
| System.out.print("Path or URL to WADL file: "); |
| String url = (System.console().readLine()); |
| System.out.print("Business key to attach to: "); |
| String key = (System.console().readLine()); |
| new WadlImport().fire(url, key, authtoken, transport); |
| } else if (input.equals("24")) { |
| UDDISecurityPortType security = null; |
| security = transport.getUDDISecurityService(); |
| |
| System.out.print("Transfer from username: "); |
| String uname = (System.console().readLine()); |
| char passwordArray[] = System.console().readPassword("password: "); |
| GetAuthToken getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(uname); |
| getAuthTokenRoot.setCred(new String(passwordArray)); |
| String authtokenFrom = security.getAuthToken(getAuthTokenRoot).getAuthInfo(); |
| System.out.println("Success!"); |
| |
| System.out.print("Transfer to username: "); |
| String uname2 = (System.console().readLine()); |
| char passwordArray2[] = System.console().readPassword("password: "); |
| getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(uname2); |
| getAuthTokenRoot.setCred(new String(passwordArray2)); |
| String authtokenFrom2 = security.getAuthToken(getAuthTokenRoot).getAuthInfo(); |
| System.out.println("Success!"); |
| System.out.print("business/tModel key to transfer: "); |
| String key = (System.console().readLine()); |
| new UddiCustodyTransfer().transferBusiness(uname, authtokenFrom, uname2, authtokenFrom2, key); |
| } else if (input.equals("25")) { |
| System.out.print("Business key to sign: "); |
| String key = (System.console().readLine()); |
| new UddiDigitalSignatureBusiness().fire(authtoken, key); |
| } else if (input.equals("26")) { |
| System.out.print("Service key to sign: "); |
| String key = (System.console().readLine()); |
| new UddiDigitalSignatureService().fire(authtoken, key); |
| } else if (input.equals("27")) { |
| System.out.print("tModel key to sign: "); |
| String key = (System.console().readLine()); |
| new UddiDigitalSignatureTmodel().fire(authtoken, key); |
| } else if (input.equals("28")) { |
| UDDISecurityPortType security = null; |
| |
| security = transport.getUDDISecurityService(); |
| |
| System.out.print("1st Business username: "); |
| String uname = (System.console().readLine()); |
| char passwordArray[] = System.console().readPassword("password: "); |
| GetAuthToken getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(uname); |
| getAuthTokenRoot.setCred(new String(passwordArray)); |
| String authtokenFrom = security.getAuthToken(getAuthTokenRoot).getAuthInfo(); |
| System.out.println("Success!"); |
| |
| System.out.print(uname + "'s business : "); |
| String key = (System.console().readLine()); |
| |
| System.out.print("2st Business username: "); |
| String uname2 = (System.console().readLine()); |
| char passwordArray2[] = System.console().readPassword("password: "); |
| getAuthTokenRoot = new GetAuthToken(); |
| getAuthTokenRoot.setUserID(uname2); |
| getAuthTokenRoot.setCred(new String(passwordArray2)); |
| String authtokenFrom2 = security.getAuthToken(getAuthTokenRoot).getAuthInfo(); |
| System.out.println("Success!"); |
| |
| System.out.print(uname2 + "'s business : "); |
| String key2 = (System.console().readLine()); |
| |
| System.out.print("relationship (parent-child, peer-peer,or identity) : "); |
| String relationship = (System.console().readLine()); |
| new UddiRelatedBusinesses().fire(key, authtokenFrom, key2, authtokenFrom2, relationship); |
| } else if (input.equals("29")) { |
| new UddiSubscribe(client, currentNode, transport).fire(); |
| |
| } else if (input.equals("30")) { |
| System.out.print("Subscription key: "); |
| String key = (System.console().readLine()); |
| System.out.println("Fetching results for the past 30 days..."); |
| new UddiSubscribeValidate(transport).go(authtoken, input); |
| } else if (input.equals("31")) { |
| new UddiSubscriptionManagement(transport).printSubscriptions(authtoken); |
| } else if (input.equals("32")) { |
| System.out.print("Subscription key: "); |
| String key2 = (System.console().readLine()); |
| new UddiSubscriptionManagement(transport).deleteSubscription(authtoken, key2); |
| } else if (input.equals("33")) { |
| new UddiSubscriptionManagement(transport).deleteAllSubscriptions(authtoken); |
| } else if (input.equals("34")) { |
| new UddiSubscribeAssertionStatus(transport).fire(currentNode); |
| |
| } else if (input.equals("35")) { |
| |
| new UddiReplication(client, currentNode).doPing(); |
| |
| } else if (input.equals("36")) { |
| //System.out.println("28) Replication - get high watermarks"); |
| new UddiReplication(client, currentNode).getHighWatermarks(); |
| |
| } else if (input.equals("37")) { |
| //System.out.println("29) Replication - get change records"); |
| |
| System.out.print("Change ID to fetch: "); |
| String id = (System.console().readLine()); |
| |
| System.out.print("Node id of something in the replication graph: "); |
| String src = (System.console().readLine()); |
| |
| new UddiReplication(client, currentNode).getChangeRecords(Long.parseLong(id), src); |
| |
| } else if ("38".equals(input)) { |
| new JuddiAdminService(client, transport).dumpFailedReplicationRecords(authtoken); |
| } else if (input.equals("39")) { |
| |
| new JuddiAdminService(client, transport).quickRegisterRemoteCloud(authtoken); |
| } else if (input.equals("40")) { |
| |
| //System.out.println("32) Register a *this node to a jUDDI server"); |
| UDDIClient clerkManager = new UDDIClient(); |
| List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList(); |
| System.out.println(); |
| |
| System.out.println("Locally defined nodes:"); |
| for (int i = 0; i < uddiNodeList.size(); i++) { |
| System.out.println("________________________________________________________________________________"); |
| System.out.println((i + 1) + ") Node name: " + uddiNodeList.get(i).getName()); |
| System.out.println((i + 1) + ") Node description: " + uddiNodeList.get(i).getDescription()); |
| System.out.println((i + 1) + ") Transport: " + uddiNodeList.get(i).getProxyTransport()); |
| System.out.println((i + 1) + ") jUDDI URL: " + uddiNodeList.get(i).getJuddiApiUrl()); |
| } |
| System.out.println("Local Source Node: "); |
| int index = Integer.parseInt(System.console().readLine()) - 1; |
| |
| System.out.println("Remote Destination(s):"); |
| for (int i = 0; i < uddiNodeList.size(); i++) { |
| System.out.println("________________________________________________________________________________"); |
| System.out.println((i + 1) + ") Node name: " + uddiNodeList.get(i).getName()); |
| System.out.println((i + 1) + ") Node description: " + uddiNodeList.get(i).getDescription()); |
| System.out.println((i + 1) + ") Transport: " + uddiNodeList.get(i).getProxyTransport()); |
| System.out.println((i + 1) + ") jUDDI URL: " + uddiNodeList.get(i).getJuddiApiUrl()); |
| } |
| System.out.println("Remote Destination Node to publish to: "); |
| int index2 = Integer.parseInt(System.console().readLine()) - 1; |
| |
| new JuddiAdminService(client, transport).registerLocalNodeToRemoteNode(authtoken, uddiNodeList.get(index), uddiNodeList.get(index2)); |
| |
| } else if (input.equals("41")) { |
| |
| new JuddiAdminService(client, transport).viewRemoteNodes(authtoken); |
| } else if (input.equals("42")) { |
| |
| new JuddiAdminService(client, transport).viewRemoveRemoteNode(authtoken); |
| //System.out.println("35) UnRegister a node on a jUDDI server"); |
| } else if (input.equals("43")) { |
| new JuddiAdminService(client, transport).viewReplicationConfig(authtoken, currentNode); |
| } else if (input.equals("44")) { |
| new JuddiAdminService(client, transport).setReplicationConfig(authtoken); |
| } else if (input.equals("45")) { |
| new JuddiAdminService(client, transport).printStatus(transport, authtoken); |
| } else if (input.equals("47")) { |
| System.out.println("We'll run a search first, then the results will be deleted (after confirmation). Use % as a wild card"); |
| System.out.print("Search query: "); |
| String key = (System.console().readLine()); |
| FindBusiness fb = new FindBusiness(); |
| fb.setFindQualifiers(new FindQualifiers()); |
| fb.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| fb.getName().add(new Name(key, null)); |
| BusinessList findBusiness = transport.getUDDIInquiryService().findBusiness(fb); |
| |
| DeleteBusiness db = new DeleteBusiness(); |
| db.setAuthInfo(authtoken); |
| for (int i = 0; i < findBusiness.getBusinessInfos().getBusinessInfo().size(); i++) { |
| db.getBusinessKey().add(findBusiness.getBusinessInfos().getBusinessInfo().get(i).getBusinessKey()); |
| System.out.println(findBusiness.getBusinessInfos().getBusinessInfo().get(i).getBusinessKey() + " " + findBusiness.getBusinessInfos().getBusinessInfo().get(i).getName().get(0).getValue()); |
| } |
| System.out.print("The above businesses will be deleted, are you sure? (y/n) : "); |
| key = (System.console().readLine()); |
| if ("y".equalsIgnoreCase(key.trim().toLowerCase())) { |
| transport.getUDDIPublishService().deleteBusiness(db); |
| System.out.println("done."); |
| }else |
| System.out.println("aborted."); |
| } |
| else if (input.equals("48")) { |
| System.out.println("We'll run a search first, then the results will be deleted (after confirmation). Use % as a wild card"); |
| System.out.print("Search query: "); |
| String key = (System.console().readLine()); |
| |
| FindService fb = new FindService(); |
| fb.setFindQualifiers(new FindQualifiers()); |
| fb.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| fb.getName().add(new Name(key, null)); |
| ServiceList findBusiness = transport.getUDDIInquiryService().findService(fb); |
| |
| DeleteService db = new DeleteService(); |
| db.setAuthInfo(authtoken); |
| for (int i = 0; i < findBusiness.getServiceInfos().getServiceInfo().size(); i++) { |
| db.getServiceKey().add(findBusiness.getServiceInfos().getServiceInfo().get(i).getServiceKey()); |
| System.out.println(findBusiness.getServiceInfos().getServiceInfo().get(i).getServiceKey() + " " + findBusiness.getServiceInfos().getServiceInfo().get(i).getName().get(0).getValue()); |
| } |
| System.out.print("The above services will be deleted, are you sure? (y/n) : "); |
| key = (System.console().readLine()); |
| if ("y".equalsIgnoreCase(key.trim().toLowerCase())) { |
| transport.getUDDIPublishService().deleteService(db); |
| System.out.println("done."); |
| }else |
| System.out.println("aborted."); |
| } |
| else if (input.equals("49")) { |
| System.out.println("We'll run a search first, then the results will be deleted (after confirmation). Use % as a wild card"); |
| System.out.print("Search query: "); |
| String key = (System.console().readLine()); |
| FindTModel fb = new FindTModel(); |
| fb.setFindQualifiers(new FindQualifiers()); |
| fb.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH); |
| fb.setName(new Name(key, null)); |
| TModelList findBusiness = transport.getUDDIInquiryService().findTModel(fb); |
| |
| DeleteTModel db = new DeleteTModel(); |
| db.setAuthInfo(authtoken); |
| for (int i = 0; i < findBusiness.getTModelInfos().getTModelInfo().size(); i++) { |
| db.getTModelKey().add(findBusiness.getTModelInfos().getTModelInfo().get(i).getTModelKey()); |
| System.out.println(findBusiness.getTModelInfos().getTModelInfo().get(i).getTModelKey() + " " + findBusiness.getTModelInfos().getTModelInfo().get(i).getName().getValue()); |
| } |
| System.out.print("The above tModels will be deleted, are you sure? (y/n) : "); |
| key = (System.console().readLine()); |
| if ("y".equalsIgnoreCase(key.trim().toLowerCase())) { |
| transport.getUDDIPublishService().deleteTModel(db); |
| System.out.println("done."); |
| }else |
| System.out.println("aborted."); |
| } |
| |
| } |
| static boolean running = true; |
| static int createdServices = 0; |
| static int createdBusinesses = 0; |
| |
| } |
