You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2014/04/14 20:30:42 UTC
[40/90] [abbrv] [partial] AIRAVATA-1124
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProjectResourceClient.java
----------------------------------------------------------------------
diff --git a/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProjectResourceClient.java b/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProjectResourceClient.java
deleted file mode 100644
index 653f664..0000000
--- a/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProjectResourceClient.java
+++ /dev/null
@@ -1,391 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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.airavata.rest.client;
-
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-import com.sun.jersey.api.client.WebResource;
-import com.sun.jersey.api.client.config.ClientConfig;
-import com.sun.jersey.api.client.config.DefaultClientConfig;
-import com.sun.jersey.api.json.JSONConfiguration;
-import com.sun.jersey.core.util.MultivaluedMapImpl;
-import org.apache.airavata.registry.api.PasswordCallback;
-import org.apache.airavata.registry.api.WorkspaceProject;
-import org.apache.airavata.rest.mappings.resourcemappings.WorkspaceProjectList;
-import org.apache.airavata.rest.mappings.utils.ResourcePathConstants;
-import org.apache.airavata.rest.utils.BasicAuthHeaderUtil;
-import org.apache.airavata.rest.utils.ClientConstant;
-import org.apache.airavata.rest.utils.CookieManager;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import javax.ws.rs.core.Cookie;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.MultivaluedMap;
-import javax.ws.rs.core.UriBuilder;
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.List;
-
-public class ProjectResourceClient {
- private WebResource webResource;
- private final static Logger logger = LoggerFactory.getLogger(ProjectResourceClient.class);
- private String userName;
- private PasswordCallback callback;
- private String baseURI;
- private Cookie cookie;
- private WebResource.Builder builder;
- private String gateway;
-// private CookieManager cookieManager = new CookieManager();
-
- public ProjectResourceClient(String userName,
- String gateway,
- String serviceURI,
- PasswordCallback callback,
- Cookie cookie) {
- this.callback = callback;
- this.userName = userName;
- this.baseURI = serviceURI;
- this.gateway = gateway;
- this.cookie = cookie;
- }
-
- private URI getBaseURI() {
- logger.debug("Creating Base URI");
- return UriBuilder.fromUri(baseURI).build();
- }
-
- private WebResource getProjectRegistryBaseResource() {
- ClientConfig config = new DefaultClientConfig();
- config.getFeatures().put(JSONConfiguration.FEATURE_POJO_MAPPING,
- Boolean.TRUE);
- Client client = Client.create(config);
- WebResource baseWebResource = client.resource(getBaseURI());
- webResource = baseWebResource.path(
- ResourcePathConstants.ProjectResourcePathConstants.REGISTRY_API_PROJECTREGISTRY);
- return webResource;
- }
-
- public boolean isWorkspaceProjectExists(String projectName) {
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.PROJECT_EXIST);
- MultivaluedMap queryParams = new MultivaluedMapImpl();
- queryParams.add("projectName", projectName);
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, null, cookie, gateway);
- ClientResponse response = builder.get(ClientResponse.class);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- }
- String exists = response.getEntity(String.class);
- if (exists.equals("True")) {
- return true;
- } else {
- return false;
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, callback.getPassword(userName), null, gateway);
- response = webResource.queryParams(queryParams).get(ClientResponse.class);
- status = response.getStatus();
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- }
- }
- String exists = response.getEntity(String.class);
- if (exists.equals("True")) {
- return true;
- } else {
- return false;
- }
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
- }
-
- public boolean isWorkspaceProjectExists(String projectName, boolean createIfNotExists) {
- String createStatus = "false";
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.PROJECT_EXIST);
- if (createIfNotExists) {
- createStatus = "true";
- }
- MultivaluedMap formParams = new MultivaluedMapImpl();
- formParams.add("projectName", projectName);
- formParams.add("createIfNotExists", createStatus);
-
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, null, cookie, gateway);
- ClientResponse response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- String exists = response.getEntity(String.class);
- if (exists.equals("True")) {
- return true;
- } else {
- return false;
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, callback.getPassword(userName), null, gateway);
- response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- status = response.getStatus();
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- String exists = response.getEntity(String.class);
- if (exists.equals("True")) {
- return true;
- } else {
- return false;
- }
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
- }
-
- public void addWorkspaceProject(WorkspaceProject project) {
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.ADD_PROJECT);
- MultivaluedMap formParams = new MultivaluedMapImpl();
- formParams.add("projectName", project.getProjectName());
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, null, cookie, gateway);
- ClientResponse response = builder.accept(
- MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, callback.getPassword(userName), null, gateway);
- response = builder.accept(
- MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- status = response.getStatus();
- if (status != ClientConstant.HTTP_OK) {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- } else {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
- }
-
- public void updateWorkspaceProject(WorkspaceProject project) {
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.UPDATE_PROJECT);
- MultivaluedMap formParams = new MultivaluedMapImpl();
- formParams.add("projectName", project.getProjectName());
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, null, cookie, gateway);
- ClientResponse response = builder.accept(
- MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, callback.getPassword(userName), null, gateway);
- response = builder.accept(
- MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams);
- status = response.getStatus();
- if (status != ClientConstant.HTTP_OK) {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- } else {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
- }
-
- public void deleteWorkspaceProject(String projectName) {
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.DELETE_PROJECT);
- MultivaluedMap queryParams = new MultivaluedMapImpl();
- queryParams.add("projectName", projectName);
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, null, cookie, gateway);
- ClientResponse response = builder.delete(ClientResponse.class);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, callback.getPassword(userName), null, gateway);
- response = builder.delete(ClientResponse.class);
- status = response.getStatus();
- if (status != ClientConstant.HTTP_OK) {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- } else {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
- }
-
- public WorkspaceProject getWorkspaceProject(String projectName) {
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.GET_PROJECT);
- MultivaluedMap queryParams = new MultivaluedMapImpl();
- queryParams.add("projectName", projectName);
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, null, cookie, gateway);
- ClientResponse response = builder.get(ClientResponse.class);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, queryParams, userName, callback.getPassword(userName), null, gateway);
- response = builder.get(ClientResponse.class);
- status = response.getStatus();
- if (status == ClientConstant.HTTP_NO_CONTENT) {
- return null;
- }
- if (status != ClientConstant.HTTP_OK) {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- } else {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- } else if (status == ClientConstant.HTTP_NO_CONTENT) {
- return null;
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
-
- WorkspaceProject workspaceProject = response.getEntity(WorkspaceProject.class);
- return workspaceProject;
- }
-
- public List<WorkspaceProject> getWorkspaceProjects() {
- List<WorkspaceProject> workspaceProjectsList = new ArrayList<WorkspaceProject>();
- webResource = getProjectRegistryBaseResource().path(
- ResourcePathConstants.ProjectResourcePathConstants.GET_PROJECTS);
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, null, cookie, gateway);
- ClientResponse response = builder.get(ClientResponse.class);
- int status = response.getStatus();
-
- if (status == ClientConstant.HTTP_OK) {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- } else if (status == ClientConstant.HTTP_UNAUTHORIZED) {
- builder = BasicAuthHeaderUtil.getBuilder(
- webResource, null, userName, callback.getPassword(userName), null, gateway);
- response = builder.get(ClientResponse.class);
- status = response.getStatus();
- if (status == ClientConstant.HTTP_NO_CONTENT) {
- return workspaceProjectsList;
- }
- if (status != ClientConstant.HTTP_OK) {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- } else {
- if (response.getCookies().size() > 0) {
- cookie = response.getCookies().get(0).toCookie();
- CookieManager.setCookie(cookie);
- }
- }
- } else if (status == ClientConstant.HTTP_NO_CONTENT) {
- return workspaceProjectsList;
- } else {
- logger.error(response.getEntity(String.class));
- throw new RuntimeException("Failed : HTTP error code : "
- + status);
- }
-
- WorkspaceProjectList workspaceProjectList = response.getEntity(WorkspaceProjectList.class);
- WorkspaceProject[] workspaceProjects = workspaceProjectList.getWorkspaceProjects();
-
- for (WorkspaceProject workspaceProject : workspaceProjects) {
- workspaceProjectsList.add(workspaceProject);
- }
- return workspaceProjectsList;
- }
-
-}