| /* |
| * Copyright (c) 2009-2014, JoshuaTree. All Rights Reserved. |
| */ |
| package us.jts.enmasse; |
| |
| import java.io.File; |
| import java.io.InputStream; |
| import java.io.StringReader; |
| import java.io.StringWriter; |
| import java.util.Collection; |
| import java.util.Collections; |
| |
| import us.jts.fortress.rest.HttpIds; |
| import us.jts.fortress.rbac.OrgUnit; |
| import us.jts.fortress.rbac.PermObj; |
| import us.jts.fortress.rbac.Permission; |
| import us.jts.fortress.rbac.Session; |
| import org.apache.commons.httpclient.HttpClient; |
| import org.apache.commons.httpclient.HttpMethod; |
| import org.apache.commons.httpclient.methods.*; |
| import org.apache.cxf.common.util.Base64Utility; |
| import org.apache.cxf.helpers.IOUtils; |
| import org.apache.cxf.io.CachedOutputStream; |
| import org.apache.cxf.jaxrs.client.WebClient; |
| import org.apache.cxf.resource.URIResolver; |
| |
| import javax.ws.rs.WebApplicationException; |
| import javax.ws.rs.core.Response; |
| import javax.xml.bind.JAXBContext; |
| import javax.xml.bind.Marshaller; |
| import javax.xml.bind.Unmarshaller; |
| |
| |
| /** |
| * Test Client to drive EnMasse Service methods. |
| * |
| * @author Shawn McKinney |
| */ |
| public final class Client |
| { |
| private static final String HOST = "localhost"; |
| private static final String PORT = "80"; |
| private static final String SERVICE = "enmasse"; |
| private static final String URI = "http://" + HOST + ":" + PORT + "/" + SERVICE + "/"; |
| |
| private Client() |
| { |
| } |
| |
| public static void main(String args[]) throws Exception |
| { |
| Client client = new Client(); |
| |
| |
| /* |
| client.post("demouser4", "password", "UserSample2.xml", HttpIds.USER_ADD); |
| client.delete("demouser4", "password", "fortressUser1", null, null, Services.userDelete.toString()); |
| client.get("demouser4", "password", "demouser4", null, null, Services.userRead.toString()); |
| client.get("demouser4", "password", "oamuser1", null, null, Services.userRead.toString()); |
| |
| client.get("demouser4", "password", "oamRole1", null, null, Services.roleRead.toString()); |
| client.delete("demouser4", "password", "ROLE_ADMIN", null, null, Services.roleDelete.toString()); |
| client.post("demouser4", "password", "RoleSample2.xml", Services.roleAdd.toString()); |
| client.put("demouser4", "password", "RoleSample2Update.xml", Services.roleUpdate.toString()); |
| client.get("demouser4", "password", "ROLE_ADMIN", null, null, Services.roleRead.toString()); |
| client.get("demouser4", "password", "role1", null, null, Services.roleRead.toString()); |
| client.delete("demouser4", "password", "enMasseTestUser1", null, null, Services.userDelete.toString()); |
| client.post("demouser4", "password", "UserSample2.xml", Services.userAdd.toString()); |
| |
| client.put("demouser4", "password", "UserSample2Update.xml", Services.userUpdate.toString()); |
| |
| client.get("demouser4", "password", "enMasseTestUser1", null, null, Services.userRead.toString()); |
| |
| client.get("demouser4", "password", "USER", "demousrs1", null, Services.orgRead.toString()); |
| |
| client.findUsers("demouser4", "password", "oam"); |
| client.findRoles("demouser4", "password", "oam"); |
| |
| client.delete("demouser4", "password", "USER", "TestEnMasseOrg1", null, Services.orgDelete.toString()); |
| client.post("demouser4", "password", "TestUserOrg.xml", Services.orgAdd.toString()); |
| client.get("demouser4", "password", "USER", "TestEnMasseOrg1", null, Services.orgRead.toString()); |
| client.findOrgs("demouser4", "password", "USER", "o"); |
| |
| client.delete("demouser4", "password", "USER", "TestEMPermObj1", "read", Services.permDelete.toString()); |
| client.delete("demouser4", "password", "USER", "TestEMPermObj1", null, Services.objDelete.toString()); |
| client.delete("demouser4", "password", "PERM", "TestEnMassePermOrg1", null, Services.orgDelete.toString()); |
| client.post("demouser4", "password", "TestPermOrg.xml", Services.orgAdd.toString()); |
| client.get("demouser4", "password", "PERM", "TestEnMassePermOrg1", null, Services.orgRead.toString()); |
| client.post("demouser4", "password", "TestPermObj.xml", Services.objAdd.toString()); |
| client.get("demouser4", "password", "USER", "TestEMPermObj1", null, Services.objRead.toString()); |
| client.findPermObjs("demouser4", "password", "USER", "t"); |
| |
| client.post("demouser4", "password", "TestPermission.xml", Services.permAdd.toString()); |
| client.get("demouser4", "password", "USER", "TestEMPermObj1", "read", Services.permRead.toString()); |
| client.findPermissions("demouser4", "password", "USER", "T", "t"); |
| |
| client.get("demouser4", "password", "demouser4", "password", null, Services.rbacCreate.toString()); |
| |
| client.post("demouser4", "password", "FUser.xml", Services.userAdd.toString()); |
| client.post("demouser4", "password", "TestUserAssign.xml", Services.roleAsgn.toString()); |
| client.get("demouser4", "password", "fortressUser1", null, null, Services.roleAsigned.toString()); |
| client.post("demouser4", "password", "TestUserDeassign.xml", Services.roleDeasgn.toString()); |
| |
| client.post("demouser4", "password", "RoleGrant.xml", Services.roleGrant.toString()); |
| client.post("demouser4", "password", "RoleGrant.xml", Services.roleRevoke.toString()); |
| |
| client.post("demouser4", "password", "UserGrant.xml", Services.userGrant.toString()); |
| client.post("demouser4", "password", "UserGrant.xml", Services.userRevoke.toString()); |
| |
| client.get("demouser4", "password", "oamrole1", null, null, Services.userAsigned.toString()); |
| client.get("demouser4", "password", "oamrole1", null, null, Services.rolePerms.toString()); |
| client.get("demouser4", "password", "oamuser1", null, null, Services.userPerms.toString()); |
| |
| client.put("demouser4", "password", "UserSample2Change.xml", Services.userChange.toString()); |
| client.get("demouser4", "password", "enMasseTestUser1", null, null, Services.userLock.toString()); |
| client.get("demouser4", "password", "enMasseTestUser1", null, null, Services.userUnlock.toString()); |
| client.put("demouser4", "password", "UserSample2Reset.xml", Services.userReset.toString()); |
| |
| client.delete("demouser4", "password", "ROLE_ADMIN_CHILD", null, null, Services.roleDelete.toString()); |
| client.post("demouser4", "password", "TestRoleDescendant.xml", Services.roleDescendant.toString()); |
| client.post("demouser4", "password", "TestRoleDescendant.xml", Services.roleDelinherit.toString()); |
| client.post("demouser4", "password", "TestRoleDescendant.xml", Services.roleAddinherit.toString()); |
| client.post("demouser4", "password", "TestRoleDescendant.xml", Services.roleDelinherit.toString()); |
| |
| client.get("demouser4", "password", "oamT12SSD3", null, null, Services.ssdSets.toString()); |
| client.get("demouser4", "password", "oamT6Ssd1", null, null, Services.ssdRead.toString()); |
| client.get("demouser4", "password", "oamT6Ssd1", null, null, Services.ssdRoles.toString()); |
| client.get("demouser4", "password", "oamT6Ssd1", null, null, Services.ssdCard.toString()); |
| client.get("demouser4", "password", "oamT12DSD3", null, null, Services.dsdSets.toString()); |
| client.get("demouser4", "password", "oamT6Dsd1", null, null, Services.dsdRead.toString()); |
| client.get("demouser4", "password", "oamT6Dsd1", null, null, Services.dsdRoles.toString()); |
| client.get("demouser4", "password", "oamT6Dsd1", null, null, Services.dsdCard.toString()); |
| |
| client.get("demouser4", "password", "oamrole1", null, null, Services.roleAuthzed.toString()); |
| client.get("demouser4", "password", "oamuser1", null, null, Services.userAuthzed.toString()); |
| client.get("demouser4", "password", "TOB3_3", "TOP3_1", null, Services.permRoles.toString()); |
| client.get("demouser4", "password", "TOB1_1", "TOP1_1", "001", Services.permRoles.toString()); |
| client.get("demouser4", "password", "TOB3_3", "TOP3_1", null, Services.permRolesAuthzed.toString()); |
| client.get("demouser4", "password", "TOB1_1", "TOP1_1", "001", Services.permRolesAuthzed.toString()); |
| client.get("demouser4", "password", "TOB1_1", "TOP1_1", "001", Services.permUsers.toString()); |
| client.get("demouser4", "password", "TestEMPermObj1", "read", null, Services.permUsers.toString()); |
| client.get("demouser4", "password", "TOB3_3", "TOP3_1", null, Services.permUsersAuthzed.toString()); |
| client.get("demouser4", "password", "TOB1_1", "TOP1_1", "001", Services.permUsersAuthzed.toString()); |
| |
| client.delete("demouser4", "password", "emSsdT1", null, null, Services.ssdDelete.toString()); |
| client.delete("demouser4", "password", "SSD_ROLE_1", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "SSD_ROLE_2", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "SSD_ROLE_3", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "SSD_ROLE_4", null, null, Services.roleDelete.toString()); |
| client.post("demouser4", "password", "RoleSSD1.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleSSD2.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleSSD3.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleSSD4.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "TestCreateSSD.xml", Services.ssdAdd.toString()); |
| client.get("demouser4", "password", "emSsdT1", "SSD_ROLE_4", null, Services.ssdAddMember.toString()); |
| client.get("demouser4", "password", "emSsdT1", null, null, Services.ssdRead.toString()); |
| client.get("demouser4", "password", "emSsdT1", "SSD_ROLE_3", null, Services.ssdDelMember.toString()); |
| client.get("demouser4", "password", "emSsdT1", "3", null, Services.ssdCardUpdate.toString()); |
| client.get("demouser4", "password", "emSsdT1", null, null, Services.ssdRead.toString()); |
| |
| client.delete("demouser4", "password", "emDsdT1", null, null, Services.dsdDelete.toString()); |
| client.delete("demouser4", "password", "DSD_ROLE_1", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "DSD_ROLE_2", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "DSD_ROLE_3", null, null, Services.roleDelete.toString()); |
| client.delete("demouser4", "password", "DSD_ROLE_4", null, null, Services.roleDelete.toString()); |
| client.post("demouser4", "password", "RoleDSD1.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleDSD2.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleDSD3.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "RoleDSD4.xml", Services.roleAdd.toString()); |
| client.post("demouser4", "password", "TestCreateDSD.xml", Services.dsdAdd.toString()); |
| client.get("demouser4", "password", "emDsdT1", "DSD_ROLE_4", null, Services.dsdAddMember.toString()); |
| client.get("demouser4", "password", "emDsdT1", null, null, Services.dsdRead.toString()); |
| client.get("demouser4", "password", "emDsdT1", "DSD_ROLE_3", null, Services.dsdDelMember.toString()); |
| client.get("demouser4", "password", "emDsdT1", "3", null, Services.dsdCardUpdate.toString()); |
| client.get("demouser4", "password", "emDsdT1", null, null, Services.dsdRead.toString()); |
| |
| client.delete("demouser4", "password", "emPWPolicy1", null, null, Services.pswdDelete.toString()); |
| client.post("demouser4", "password", "TestPswd.xml", Services.pswdAdd.toString()); |
| client.get("demouser4", "password", "emPWPolicy1", null, null, Services.pswdRead.toString()); |
| client.put("demouser4", "password", "TestPswdUpdate.xml", Services.pswdUpdate.toString()); |
| client.get("demouser4", "password", "emPWPolicy1", null, null, Services.pswdRead.toString()); |
| client.get("demouser4", "password", "oam", null, null, Services.pswdSearch.toString()); |
| client.get("demouser4", "password", "enMasseTestUser1", "emPWPolicy1", null, Services.pswdUserAdd.toString()); |
| client.get("demouser4", "password", "enMasseTestUser1", null, null, Services.pswdUserDelete.toString()); |
| |
| client.post("demouser4", "password", "TestAdminRoleDescendant.xml", Services.arleDelinherit.toString()); |
| client.delete("demouser4", "password", "EM_TEST_ADMIN_ROLE_1", null, null, Services.arleDelete.toString()); |
| |
| |
| client.post("demouser4", "password", "TestAdminRole.xml", Services.arleAdd.toString()); |
| client.put("demouser4", "password", "TestAdminRoleUpdate.xml", Services.arleUpdate.toString()); |
| client.get("demouser4", "password", "EM_TEST_ADMIN_ROLE_1", null, null, Services.arleRead.toString()); |
| client.get("demouser4", "password", "EM", null, null, Services.arleSearch.toString()); |
| client.get("demouser4", "password", "demouser4", null, null, Services.arleAsigned.toString()); |
| client.get("demouser4", "password", "oamadmin1", null, null, Services.userAsignedAdmin.toString()); |
| |
| client.post("demouser4", "password", "AuditBind.xml", Services.auditBinds.toString()); |
| |
| |
| String szAuthNSession = client.get("demouser4", "password", "demouser4", "password", null, Services.rbacAuthN.toString()); |
| String szSession = client.get("demouser4", "password", "oamTU3User7", "password7", null, Services.rbacCreate.toString()); |
| Session session = unmarshallSession(szSession); |
| client.checkAccess("demouser4", "password", session, new Permission("TOB3_3", "TOP3_1")); |
| szSession = client.dropActiveRole("demouser4", "password", session, new Role("oamT3ROLE4")); |
| session = unmarshallSession(szSession); |
| szSession = client.addActiveRole("demouser4", "password", session, new Role("oamT3ROLE4")); |
| */ |
| |
| //szSession = marshal(session); |
| /* |
| client.postStr("demouser4", "password", szSession, Services.rbacPerms.toString()); |
| client.postStr("demouser4", "password", szSession, Services.rbacRoles.toString()); |
| client.postStr("demouser4", "password", szSession, Services.rbacUserId.toString()); |
| client.postStr("demouser4", "password", szSession, Services.rbacUser.toString()); |
| */ |
| |
| |
| System.out.println("\n"); |
| System.exit(0); |
| } |
| |
| private static Session unmarshallSession(String szSession) throws Exception |
| { |
| // Create a JAXB context passing in the class of the object we want to marshal/unmarshal |
| final JAXBContext context = JAXBContext.newInstance(Session.class); |
| |
| // Create the unmarshaller, this is the nifty little thing that will actually transform the XML back into an object |
| final Unmarshaller unmarshaller = context.createUnmarshaller(); |
| return (Session) unmarshaller.unmarshal(new StringReader(szSession)); |
| } |
| |
| private static String marshal(Session session) throws Exception |
| { |
| // Create a JAXB context passing in the class of the object we want to marshal/unmarshal |
| final JAXBContext context = JAXBContext.newInstance(Session.class); |
| // ============================================================================================================= |
| // Marshalling OBJECT to XML |
| // ============================================================================================================= |
| // Create the marshaller, this is the nifty little thing that will actually transform the object into XML |
| final Marshaller marshaller = context.createMarshaller(); |
| |
| // Create a stringWriter to hold the XML |
| final StringWriter stringWriter = new StringWriter(); |
| // Marshal the javaObject and write the XML to the stringWriter |
| marshaller.marshal(session, stringWriter); |
| return stringWriter.toString(); |
| } |
| |
| public String postStr(String userId, String password, String szInput, String function) throws Exception |
| { |
| String szResponse = null; |
| Client client = new Client(); |
| // Sent HTTP POST request to add user |
| System.out.println("\n"); |
| System.out.println("Sent HTTP POST request to:" + function); |
| //String inputFile = client.getClass().getResource(xmlFile).getFile(); |
| //URIResolver resolver = new URIResolver(inputFile); |
| //File input = new File(resolver.getURI()); |
| PostMethod post = new PostMethod(URI + function); |
| post.addRequestHeader("Accept", "text/xml"); |
| setMethodHeaders(post, userId, password); |
| //RequestEntity entity = new FileRequestEntity(input, "text/xml; charset=ISO-8859-1"); |
| RequestEntity entity = new StringRequestEntity(szInput, "text/xml; charset=ISO-8859-1", null); |
| post.setRequestEntity(entity); |
| HttpClient httpclient = new HttpClient(); |
| try |
| { |
| int result = httpclient.executeMethod(post); |
| System.out.println("Response status code: " + result); |
| szResponse = post.getResponseBodyAsString(); |
| System.out.println(szResponse); |
| } |
| catch(WebApplicationException we) |
| { |
| System.out.println("WebApplicationException caught=" + we.getMessage()); |
| } |
| finally |
| { |
| // Release current connection to the connection pool once you are |
| // done |
| post.releaseConnection(); |
| } |
| return szResponse; |
| } |
| |
| public void post(String userId, String password, String xmlFile, String function) throws Exception |
| { |
| Client client = new Client(); |
| // Sent HTTP POST request to add user |
| System.out.println("\n"); |
| System.out.println("Sent HTTP POST request to:" + function); |
| String inputFile = client.getClass().getResource(xmlFile).getFile(); |
| URIResolver resolver = new URIResolver(inputFile); |
| File input = new File(resolver.getURI()); |
| PostMethod post = new PostMethod(URI + function); |
| post.addRequestHeader("Accept", "text/xml"); |
| setMethodHeaders(post, userId, password); |
| RequestEntity entity = new FileRequestEntity(input, "text/xml; charset=ISO-8859-1"); |
| post.setRequestEntity(entity); |
| HttpClient httpclient = new HttpClient(); |
| try |
| { |
| int result = httpclient.executeMethod(post); |
| System.out.println("Response status code: " + result); |
| System.out.println(post.getResponseBodyAsString()); |
| } |
| catch(WebApplicationException we) |
| { |
| System.out.println("WebApplicationException caught=" + we.getMessage()); |
| } |
| finally |
| { |
| // Release current connection to the connection pool once you are |
| // done |
| post.releaseConnection(); |
| } |
| } |
| |
| public void put(String userId, String password, String xmlFile, String function) throws Exception |
| { |
| Client client = new Client(); |
| // Sent HTTP POST request to add user |
| System.out.println("\n"); |
| System.out.println("Sent HTTP PUT request to:" + function); |
| String inputFile = client.getClass().getResource(xmlFile).getFile(); |
| URIResolver resolver = new URIResolver(inputFile); |
| File input = new File(resolver.getURI()); |
| PutMethod put = new PutMethod(URI + function); |
| put.addRequestHeader("Accept", "text/xml"); |
| setMethodHeaders(put, userId, password); |
| RequestEntity entity = new FileRequestEntity(input, "text/xml; charset=ISO-8859-1"); |
| put.setRequestEntity(entity); |
| HttpClient httpclient = new HttpClient(); |
| try |
| { |
| int result = httpclient.executeMethod(put); |
| System.out.println("Response status code: " + result); |
| System.out.println(put.getResponseBodyAsString()); |
| } |
| catch(WebApplicationException we) |
| { |
| System.out.println("WebApplicationException caught=" + we.getMessage()); |
| } |
| finally |
| { |
| // Release current connection to the connection pool once you are |
| // done |
| put.releaseConnection(); |
| } |
| } |
| |
| public void delete(String userId, String password, String id, String id2, String id3, String function) throws Exception |
| { |
| String url = URI + function + "/" + id; |
| if(id2 != null) |
| { |
| url += "/" + id2; |
| } |
| if(id3 != null) |
| { |
| url += "/" + id3; |
| } |
| System.out.println("HTTP DELETE to query info, url : " + url); |
| System.out.println("Deleting now..."); |
| DeleteMethod del = new DeleteMethod(url); |
| //DeleteMethod del = new DeleteMethod(URI + function + "/" + id); |
| setMethodHeaders(del, userId, password); |
| handleHttpMethod(del); |
| } |
| |
| public void createSession(String userId, String password, String uid, char[] pw) throws Exception |
| { |
| String url = URI + HttpIds.RBAC_CREATE + "/" + uid + "/" + pw; |
| System.out.println("CREATE SESSION url : " + url); |
| GetMethod get = new GetMethod(url); |
| setMethodHeaders(get, userId, password); |
| handleHttpMethod(get); |
| } |
| |
| public String get(String userId, String password, String id, String id2, String id3, String function) throws Exception |
| { |
| String url = URI + function + "/" + id; |
| if(id2 != null) |
| { |
| url += "/" + id2; |
| } |
| if(id3 != null) |
| { |
| url += "/" + id3; |
| } |
| System.out.println("HTTP GET to query info, url : " + url); |
| GetMethod get = new GetMethod(url); |
| setMethodHeaders(get, userId, password); |
| return handleHttpMethod(get); |
| } |
| |
| private static void setMethodHeaders(HttpMethod httpMethod, String name, String password) |
| { |
| if (httpMethod instanceof PostMethod || httpMethod instanceof PutMethod) |
| { |
| httpMethod.setRequestHeader("Content-Type", "application/xml"); |
| httpMethod.setRequestHeader("Accept", "application/xml"); |
| } |
| //httpMethod.setDoAuthentication(false); |
| httpMethod.setDoAuthentication(true); |
| httpMethod.setRequestHeader("Authorization", |
| "Basic " + base64Encode(name + ":" + password)); |
| } |
| |
| private static String base64Encode(String value) |
| { |
| return Base64Utility.encode(value.getBytes()); |
| } |
| |
| private static String handleHttpMethod(HttpMethod httpMethod) throws Exception |
| { |
| HttpClient client = new HttpClient(); |
| String szResponse = null; |
| |
| try |
| { |
| int statusCode = client.executeMethod(httpMethod); |
| System.out.println("Response status : " + statusCode); |
| |
| Response.Status status = Response.Status.fromStatusCode(statusCode); |
| |
| if (status == Response.Status.OK) |
| { |
| szResponse = httpMethod.getResponseBodyAsString(); |
| System.out.println(szResponse); |
| } |
| else if (status == Response.Status.FORBIDDEN) |
| { |
| System.out.println("Authorization failure"); |
| } |
| else if (status == Response.Status.UNAUTHORIZED) |
| { |
| System.out.println("Authentication failure"); |
| } |
| else |
| { |
| //System.out.println("Unknown error: " + status.toString()); |
| System.out.println("Unknown error"); |
| } |
| |
| System.out.println(); |
| |
| } |
| finally |
| { |
| // release any connection resources used by the method |
| httpMethod.releaseConnection(); |
| } |
| return szResponse; |
| } |
| |
| |
| public void findUsers(String userId, String password, String searchVal) throws Exception |
| { |
| String endpointAddress = URI + HttpIds.USER_SEARCH + "/" + searchVal; |
| System.out.println("now hit:" + endpointAddress); |
| |
| try |
| { |
| WebClient wc = WebClient.create(endpointAddress, |
| Collections.singletonList(new org.codehaus.jackson.jaxrs.JacksonJsonProvider())); |
| |
| String authorizationHeader = "Basic " |
| + org.apache.cxf.common.util.Base64Utility.encode(new String(userId + ":" + password).getBytes()); |
| wc.header("Authorization", authorizationHeader); |
| //wc.accept("application/json"); |
| wc.accept("application/xml"); |
| Collection<? extends us.jts.fortress.rbac.User> collection = wc.getCollection(us.jts.fortress.rbac.User.class); |
| |
| int i = 1; |
| for (us.jts.fortress.rbac.User user : collection) |
| { |
| System.out.println("User[" + i++ + "]"); |
| System.out.println(" userId: " + user.getUserId()); |
| System.out.println(" description: " + user.getDescription()); |
| //System.out.println(" roles: " + user.getRoles()); |
| System.out.println(" cn: " + user.getCn()); |
| System.out.println(" sn: " + user.getSn()); |
| System.out.println(" policy: " + user.getPwPolicy()); |
| System.out.println(" ou: " + user.getOu()); |
| System.out.println(" cn: " + user.getCn()); |
| System.out.println(" beginDate: " + user.getBeginDate()); |
| System.out.println(" endDate: " + user.getEndDate()); |
| System.out.println(" beginTime: " + user.getBeginTime()); |
| System.out.println(" endTime: " + user.getEndTime()); |
| System.out.println(" beginLockDate: " + user.getBeginLockDate()); |
| System.out.println(" endLockDate: " + user.getEndLockDate()); |
| System.out.println(" dayMask: " + user.getDayMask()); |
| System.out.println(" timeout: " + user.getTimeout()); |
| |
| if(user.getRoles() != null) |
| { |
| int j = 1; |
| for(us.jts.fortress.rbac.UserRole userRole : user.getRoles()) |
| { |
| System.out.println("--------------------------------------------------------------------------"); |
| System.out.println("User[" + user.getUserId() + "] UserRole[" + j++ + "]"); |
| System.out.println(" role name: " + userRole.getName()); |
| if(userRole.getParents() != null) |
| { |
| for(String parent : userRole.getParents()) |
| { |
| System.out.println(" parent role: " + parent); |
| } |
| } |
| System.out.println(" beginDate: " + userRole.getBeginDate()); |
| System.out.println(" endDate: " + userRole.getEndDate()); |
| System.out.println(" beginTime: " + userRole.getBeginTime()); |
| System.out.println(" endTime: " + userRole.getEndTime()); |
| System.out.println(" beginLockDate: " + userRole.getBeginLockDate()); |
| System.out.println(" endLockDate: " + userRole.getEndLockDate()); |
| System.out.println(" dayMask: " + userRole.getDayMask()); |
| System.out.println(" timeout: " + userRole.getTimeout()); |
| } |
| } |
| System.out.println("--------------------------------------------------------------------------"); |
| } |
| } |
| catch (Exception e) |
| { |
| System.out.println("Exception caught in findUsers=" + e); |
| e.printStackTrace(); |
| } |
| } |
| |
| |
| /** |
| * @throws Exception |
| */ |
| public void findRoles(String userId, String password, String searchVal) throws Exception |
| { |
| String endpointAddress = URI + HttpIds.ROLE_SEARCH + "/" + searchVal; |
| System.out.println("now hit:" + endpointAddress); |
| |
| try |
| { |
| WebClient wc = WebClient.create(endpointAddress, |
| Collections.singletonList(new org.codehaus.jackson.jaxrs.JacksonJsonProvider())); |
| String authorizationHeader = "Basic " |
| + org.apache.cxf.common.util.Base64Utility.encode(new String(userId + ":" + password).getBytes()); |
| wc.header("Authorization", authorizationHeader); |
| wc.accept("application/xml"); |
| Collection<? extends us.jts.fortress.rbac.Role> collection = wc.getCollection(us.jts.fortress.rbac.Role.class); |
| for (us.jts.fortress.rbac.Role role : collection) |
| { |
| System.out.println("Role: " + role.getName() + " description:" + role.getDescription()); |
| System.out.println(" parents: " + role.getParents()); |
| System.out.println(" children: " + role.getChildren()); |
| System.out.println(" beginDate: " + role.getBeginDate()); |
| System.out.println(" endDate: " + role.getEndDate()); |
| System.out.println(" beginTime: " + role.getBeginTime()); |
| System.out.println(" endTime: " + role.getEndTime()); |
| System.out.println(" beginLockDate: " + role.getBeginLockDate()); |
| System.out.println(" endLockDate: " + role.getEndLockDate()); |
| System.out.println(" dayMask: " + role.getDayMask()); |
| System.out.println(" timeout: " + role.getTimeout()); |
| } |
| } |
| catch (Exception e) |
| { |
| System.out.println("Exception caught in findRoles=" + e); |
| e.printStackTrace(); |
| } |
| } |
| |
| |
| /** |
| * @throws Exception |
| */ |
| public void findOrgs(String userId, String password, String type, String searchVal) throws Exception |
| { |
| String endpointAddress = URI + HttpIds.ORG_SEARCH + "/" + type + "/" + searchVal; |
| System.out.println("now hit:" + endpointAddress); |
| try |
| { |
| WebClient wc = WebClient.create(endpointAddress, |
| Collections.singletonList(new org.codehaus.jackson.jaxrs.JacksonJsonProvider())); |
| String authorizationHeader = "Basic " |
| + org.apache.cxf.common.util.Base64Utility.encode(new String(userId + ":" + password).getBytes()); |
| wc.header("Authorization", authorizationHeader); |
| wc.accept("application/xml"); |
| Collection<? extends OrgUnit> collection = wc.getCollection(OrgUnit.class); |
| for (OrgUnit orgUnit : collection) |
| { |
| System.out.println("OrgUnit: " + orgUnit.getName() + " description:" + orgUnit.getDescription()); |
| } |
| } |
| catch (Exception e) |
| { |
| System.out.println("Exception caught in searchUserOrgs=" + e); |
| e.printStackTrace(); |
| } |
| } |
| |
| |
| /** |
| * @throws Exception |
| */ |
| public void findPermObjs(String userId, String password, String type, String searchVal) throws Exception |
| { |
| String endpointAddress = URI + HttpIds.OBJ_SEARCH + "/" + type + "/" + searchVal; |
| System.out.println("now hit:" + endpointAddress); |
| try |
| { |
| WebClient wc = WebClient.create(endpointAddress, |
| Collections.singletonList(new org.codehaus.jackson.jaxrs.JacksonJsonProvider())); |
| String authorizationHeader = "Basic " |
| + org.apache.cxf.common.util.Base64Utility.encode(new String(userId + ":" + password).getBytes()); |
| wc.header("Authorization", authorizationHeader); |
| wc.accept("application/xml"); |
| Collection<? extends PermObj> collection = wc.getCollection(PermObj.class); |
| for (PermObj permObj : collection) |
| { |
| System.out.println("Object Name: " + permObj.getObjName() + " description:" + permObj.getDescription()); |
| } |
| } |
| catch (Exception e) |
| { |
| System.out.println("Exception caught in findPermObjs=" + e); |
| e.printStackTrace(); |
| } |
| } |
| |
| |
| /** |
| * @throws Exception |
| */ |
| public void findPermissions(String userId, String password, String type, String objName, String opName) throws Exception |
| { |
| String endpointAddress = URI + HttpIds.PERM_SEARCH + "/" + type + "/" + objName + "/" + opName; |
| System.out.println("now hit:" + endpointAddress); |
| try |
| { |
| WebClient wc = WebClient.create(endpointAddress, |
| Collections.singletonList(new org.codehaus.jackson.jaxrs.JacksonJsonProvider())); |
| String authorizationHeader = "Basic " |
| + org.apache.cxf.common.util.Base64Utility.encode(new String(userId + ":" + password).getBytes()); |
| wc.header("Authorization", authorizationHeader); |
| wc.accept("application/xml"); |
| Collection<? extends Permission> collection = wc.getCollection(Permission.class); |
| for (Permission perm : collection) |
| { |
| System.out.println("Permission ObjectName: " + perm.getObjName() + " opName: " + perm.getOpName()); |
| } |
| } |
| catch (Exception e) |
| { |
| System.out.println("Exception caught in findPermissions=" + e); |
| e.printStackTrace(); |
| } |
| } |
| |
| |
| /** |
| * @param in |
| * @return |
| * @throws Exception |
| */ |
| private static String getStringFromInputStream(InputStream in) throws Exception |
| { |
| CachedOutputStream bos = new CachedOutputStream(); |
| IOUtils.copy(in, bos); |
| in.close(); |
| bos.close(); |
| return bos.getOut().toString(); |
| } |
| } |
