Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id B8468D283 for ; Wed, 19 Dec 2012 22:35:43 +0000 (UTC) Received: (qmail 33412 invoked by uid 500); 19 Dec 2012 22:35:43 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 33379 invoked by uid 500); 19 Dec 2012 22:35:43 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 33369 invoked by uid 99); 19 Dec 2012 22:35:43 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Dec 2012 22:35:43 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Dec 2012 22:35:40 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id C549C23889ED; Wed, 19 Dec 2012 22:35:19 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1424180 [4/5] - in /airavata/trunk/modules/rest: client/src/main/java/org/apache/airavata/rest/ client/src/main/java/org/apache/airavata/rest/client/ client/src/main/java/org/apache/airavata/rest/utils/ webapp/src/main/webapp/WEB-INF/ Date: Wed, 19 Dec 2012 22:35:19 -0000 To: commits@airavata.apache.org From: chathuri@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20121219223519.C549C23889ED@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Modified: airavata/trunk/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProvenanceResourceClient.java URL: http://svn.apache.org/viewvc/airavata/trunk/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProvenanceResourceClient.java?rev=1424180&r1=1424179&r2=1424180&view=diff ============================================================================== --- airavata/trunk/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProvenanceResourceClient.java (original) +++ airavata/trunk/modules/rest/client/src/main/java/org/apache/airavata/rest/client/ProvenanceResourceClient.java Wed Dec 19 22:35:18 2012 @@ -57,13 +57,16 @@ public class ProvenanceResourceClient { private String baseURI; private Cookie cookie; private WebResource.Builder builder; + private String gateway; public ProvenanceResourceClient(String userName, + String gateway, String serviceURL, PasswordCallback callback) { this.userName = userName; this.callback = callback; this.baseURI = serviceURL; + this.gateway = gateway; } private URI getBaseURI() { @@ -88,7 +91,9 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("experimentId", experimentId); formParams.add("user", user); - ClientResponse response = webResource.accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); @@ -97,24 +102,24 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -124,33 +129,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT_EXECUTIONUSER); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -163,7 +175,9 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.EXPERIMENTNAME_EXISTS); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentName", experimentName); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -171,29 +185,33 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).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 { + if(response.getCookies().size() > 0){ cookie = response.getCookies().get(0).toCookie(); } - status = response.getStatus(); String exists = response.getEntity(String.class); - if (exists.equals("True")){ + 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 String getExperimentName(String experimentId) { @@ -201,32 +219,39 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT_NAME); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -240,29 +265,31 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("experimentId", experimentId); formParams.add("experimentName", experimentName); - - ClientResponse response = webResource.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); + 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 && status != ClientConstant.HTTP_UNAUTHORIZED) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -273,32 +300,39 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENTMETADATA); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } String experimentMetadata = response.getEntity(String.class); @@ -311,29 +345,32 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("experimentId", experimentId); formParams.add("metadata", metadata); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); + ClientResponse response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -343,32 +380,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_WORKFLOWTEMPLATENAME); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowInstanceId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -382,30 +427,34 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("workflowInstanceId", workflowInstanceId); formParams.add("templateName", templateName); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, callback.getPassword(userName), null, gateway); + response = builder.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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -416,32 +465,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENTWORKFLOWINSTANCES); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + if (status == ClientConstant.HTTP_NO_CONTENT) { return workflowInstanceList; } 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return workflowInstanceList; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -461,7 +518,10 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.WORKFLOWINSTANCE_EXIST_CHECK); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("instanceId", instanceId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); @@ -470,29 +530,28 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); + status = response.getStatus(); + if (status == ClientConstant.HTTP_OK) { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); + } } - status = response.getStatus(); String exists = response.getEntity(String.class); - if (exists.equals("True")){ + if (exists.equals("True")) { return true; } else { return false; } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); + } + return true; } - else { - logger.error(response.getEntity(String.class)); - throw new RuntimeException("Failed : HTTP error code : " - + status); - } + } public boolean isWorkflowInstanceExists(String instanceId, boolean createIfNotPresent) { @@ -501,8 +560,10 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("instanceId", instanceId); formParams.add("createIfNotPresent", String.valueOf(createIfNotPresent)); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -510,29 +571,28 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); + 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(); + } } - status = response.getStatus(); String exists = response.getEntity(String.class); - if (exists.equals("True")){ + if (exists.equals("True")) { return true; } else { return false; } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); + } + return true; } - else { - logger.error(response.getEntity(String.class)); - throw new RuntimeException("Failed : HTTP error code : " - + status); - } + } public void updateWorkflowInstanceStatus(String instanceId, WorkflowExecutionStatus.State executionStatus) { @@ -541,8 +601,10 @@ public class ProvenanceResourceClient { MultivaluedMap formParams = new MultivaluedMapImpl(); formParams.add("instanceId", instanceId); formParams.add("executionStatus", executionStatus.name()); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -550,23 +612,25 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } + } public void updateWorkflowInstanceStatus(WorkflowExecutionStatus workflowInstanceStatus) { @@ -581,8 +645,10 @@ public class ProvenanceResourceClient { workflowInstanceStatus.getExecutionStatus().name()); formParams.add("statusUpdateTime", statusUpdateDate); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -590,24 +656,26 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } + } public WorkflowExecutionStatus getWorkflowInstanceStatus(String instanceId) { @@ -615,32 +683,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_WORKFLOWINSTANCESTATUS); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("instanceId", instanceId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -655,8 +731,10 @@ public class ProvenanceResourceClient { formParams.add("nodeID", node.getNodeId()); formParams.add("workflowInstanceId", node.getWorkflowInstance().getWorkflowExecutionId()); formParams.add("data", data); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -664,23 +742,23 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -692,8 +770,10 @@ public class ProvenanceResourceClient { formParams.add("nodeID", node.getNodeId()); formParams.add("workflowInstanceId", node.getWorkflowInstance().getWorkflowExecutionId()); formParams.add("data", data); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -701,21 +781,22 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -725,32 +806,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + }else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } ExperimentData experimentData = response.getEntity(ExperimentData.class); @@ -762,32 +851,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT_METAINFORMATION); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("experimentId", experimentId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -801,32 +898,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_ALL_EXPERIMENT_METAINFORMATION); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("user", user); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + if (status == ClientConstant.HTTP_NO_CONTENT) { return experimentDatas; } 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return experimentDatas; + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -846,32 +951,40 @@ public class ProvenanceResourceClient { MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("user", user); queryParams.add("experimentNameRegex", experimentNameRegex); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + if (status == ClientConstant.HTTP_NO_CONTENT) { return experimentDatas; } 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return experimentDatas; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -889,32 +1002,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT_ID_USER); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("username", user); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + if (status == ClientConstant.HTTP_NO_CONTENT) { return new ArrayList(); } 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return new ArrayList(); + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -929,32 +1050,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_EXPERIMENT_USER); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("username", user); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + if (status == ClientConstant.HTTP_NO_CONTENT) { return experimentDatas; } 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return experimentDatas; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } ExperimentDataList experimentDataList = response.getEntity(ExperimentDataList.class); @@ -976,8 +1105,10 @@ public class ProvenanceResourceClient { workflowStatusNode.getWorkflowInstanceNode().getNodeId()); formParams.add("executionStatus", workflowStatusNode.getExecutionStatus().name()); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -985,23 +1116,23 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -1015,8 +1146,10 @@ public class ProvenanceResourceClient { formParams.add("workflowInstanceId", workflowInstanceId); formParams.add("nodeId", nodeId); formParams.add("executionStatus", executionStatus.name()); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -1024,23 +1157,23 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -1054,8 +1187,10 @@ public class ProvenanceResourceClient { workflowNode.getWorkflowInstance().getWorkflowExecutionId()); formParams.add("nodeId", workflowNode.getNodeId()); formParams.add("executionStatus", executionStatus.name()); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); - ClientResponse response = webResource.accept( + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -1063,23 +1198,23 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept( - MediaType.TEXT_PLAIN).post(ClientResponse.class, formParams); - cookie = response.getCookies().get(0).toCookie(); - } + 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -1090,32 +1225,40 @@ public class ProvenanceResourceClient { MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowNode.getWorkflowInstance().getWorkflowExecutionId()); queryParams.add("nodeId", workflowNode.getNodeId()); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -1130,32 +1273,40 @@ public class ProvenanceResourceClient { MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowNode.getWorkflowInstance().getWorkflowExecutionId()); queryParams.add("nodeId", workflowNode.getNodeId()); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -1175,32 +1326,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_WORKFLOW_STARTTIME); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowInstance.getWorkflowExecutionId()); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -1218,7 +1377,10 @@ public class ProvenanceResourceClient { public void updateWorkflowNodeGramData(WorkflowNodeGramData workflowNodeGramData) { webResource = getProvenanceRegistryBaseResource().path( ResourcePathConstants.ProvenanceResourcePathConstants.UPDATE_WORKFLOWNODE_GRAMDATA); - ClientResponse response = webResource.accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).type( MediaType.APPLICATION_JSON).post(ClientResponse.class, workflowNodeGramData); int status = response.getStatus(); @@ -1227,23 +1389,23 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).type( - MediaType.APPLICATION_JSON).post(ClientResponse.class, workflowNodeGramData); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, null, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).type( - MediaType.APPLICATION_JSON).post(ClientResponse.class, workflowNodeGramData); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, null, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).type( + MediaType.APPLICATION_JSON).post(ClientResponse.class, workflowNodeGramData); 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(); + } + } + } else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } } @@ -1253,32 +1415,40 @@ public class ProvenanceResourceClient { ResourcePathConstants.ProvenanceResourcePathConstants.GET_WORKFLOWINSTANCEDATA); MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowInstanceId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.APPLICATION_JSON).get(ClientResponse.class); int status = response.getStatus(); - if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { + if (status != ClientConstant.HTTP_OK && + status != ClientConstant.HTTP_UNAUTHORIZED && + status != ClientConstant.HTTP_NO_CONTENT) { logger.error(response.getEntity(String.class)); throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); - } + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); status = response.getStatus(); - if(status == ClientConstant.HTTP_NO_CONTENT){ + 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(); + } + } + } else if (status == ClientConstant.HTTP_NO_CONTENT) { + return null; + }else { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); } } @@ -1292,7 +1462,10 @@ public class ProvenanceResourceClient { MultivaluedMap queryParams = new MultivaluedMapImpl(); queryParams.add("workflowInstanceId", workflowInstanceId); queryParams.add("nodeId", nodeId); - ClientResponse response = webResource.queryParams(queryParams).accept( + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, null, cookie, gateway); + + ClientResponse response = builder.accept( MediaType.TEXT_PLAIN).get(ClientResponse.class); int status = response.getStatus(); if (status != ClientConstant.HTTP_OK && status != ClientConstant.HTTP_UNAUTHORIZED) { @@ -1300,28 +1473,26 @@ public class ProvenanceResourceClient { throw new RuntimeException("Failed : HTTP error code : " + status); } else if (status == ClientConstant.HTTP_UNAUTHORIZED) { - if (cookie != null){ - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), cookie); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - } else { - builder = BasicAuthHeaderUtil.getBuilder( - webResource, queryParams, userName, callback.getPassword(userName), null); - response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); - cookie = response.getCookies().get(0).toCookie(); + builder = BasicAuthHeaderUtil.getBuilder( + webResource, queryParams, userName, callback.getPassword(userName), null, gateway); + response = builder.accept(MediaType.TEXT_PLAIN).get(ClientResponse.class); + status = response.getStatus(); + if (status == ClientConstant.HTTP_OK) { + if(response.getCookies().size() > 0){ + cookie = response.getCookies().get(0).toCookie(); + } } - status = response.getStatus(); String exists = response.getEntity(String.class); - if (exists.equals("True")){ + if (exists.equals("True")) { return true; } else { return false; } - } - else { - 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(); [... 266 lines stripped ...]