http://git-wip-us.apache.org/repos/asf/airavata/blob/3bb7f493/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java index f35fc59..3f31655 100644 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java @@ -215,6 +215,31 @@ public class Airavata { public String generateAndRegisterSSHKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; /** + * Generate and Register Username PWD Pair with Airavata Credential Store. + * + * @param gatewayId + * The identifier for the requested Gateway. + * + * @param userName + * The User for which the credential should be registered. For community accounts, this user is the name of the + * community user name. For computational resources, this user name need not be the same user name on resoruces. + * + * @param password + * + * @return airavataCredStoreToken + * An SSH Key pair is generated and stored in the credential store and associated with users or community account + * belonging to a Gateway. + * + * + * + * @param authzToken + * @param gatewayId + * @param userName + * @param password + */ + public String registerPwdCredential(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + /** * Get a Public Key by Providing the Token * * @param CredStoreToken @@ -271,6 +296,8 @@ public class Airavata { */ public Map<String,String> getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + public Map<String,String> getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + /** * * Delete a Gateway @@ -289,6 +316,8 @@ public class Airavata { */ public boolean deleteSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + public boolean deletePWDCredential(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + /** * * Creates a Project with basic metadata. @@ -2703,14 +2732,20 @@ public class Airavata { public void generateAndRegisterSSHKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void registerPwdCredential(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deletePWDCredential(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void createProject(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.workspace.Project project, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void updateProject(org.apache.airavata.model.security.AuthzToken authzToken, String projectId, org.apache.airavata.model.workspace.Project updatedProject, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -3486,6 +3521,41 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result"); } + public String registerPwdCredential(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_registerPwdCredential(authzToken, gatewayId, userName, password); + return recv_registerPwdCredential(); + } + + public void send_registerPwdCredential(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password) throws org.apache.thrift.TException + { + registerPwdCredential_args args = new registerPwdCredential_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + args.setUserName(userName); + args.setPassword(password); + sendBase("registerPwdCredential", args); + } + + public String recv_registerPwdCredential() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + registerPwdCredential_result result = new registerPwdCredential_result(); + receiveBase(result, "registerPwdCredential"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ire != null) { + throw result.ire; + } + if (result.ace != null) { + throw result.ace; + } + if (result.ase != null) { + throw result.ase; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "registerPwdCredential failed: unknown result"); + } + public String getSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { send_getSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); @@ -3586,6 +3656,39 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result"); } + public Map<String,String> getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_getAllGatewayPWDCredentials(authzToken, gatewayId); + return recv_getAllGatewayPWDCredentials(); + } + + public void send_getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.thrift.TException + { + getAllGatewayPWDCredentials_args args = new getAllGatewayPWDCredentials_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + sendBase("getAllGatewayPWDCredentials", args); + } + + public Map<String,String> recv_getAllGatewayPWDCredentials() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); + receiveBase(result, "getAllGatewayPWDCredentials"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ire != null) { + throw result.ire; + } + if (result.ace != null) { + throw result.ace; + } + if (result.ase != null) { + throw result.ase; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllGatewayPWDCredentials failed: unknown result"); + } + public boolean deleteSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { send_deleteSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); @@ -3620,6 +3723,40 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteSSHPubKey failed: unknown result"); } + public boolean deletePWDCredential(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_deletePWDCredential(authzToken, airavataCredStoreToken, gatewayId); + return recv_deletePWDCredential(); + } + + public void send_deletePWDCredential(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId) throws org.apache.thrift.TException + { + deletePWDCredential_args args = new deletePWDCredential_args(); + args.setAuthzToken(authzToken); + args.setAiravataCredStoreToken(airavataCredStoreToken); + args.setGatewayId(gatewayId); + sendBase("deletePWDCredential", args); + } + + public boolean recv_deletePWDCredential() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + deletePWDCredential_result result = new deletePWDCredential_result(); + receiveBase(result, "deletePWDCredential"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ire != null) { + throw result.ire; + } + if (result.ace != null) { + throw result.ace; + } + if (result.ase != null) { + throw result.ase; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deletePWDCredential failed: unknown result"); + } + public String createProject(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.workspace.Project project) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException { send_createProject(authzToken, gatewayId, project); @@ -8790,6 +8927,47 @@ public class Airavata { } } + public void registerPwdCredential(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + registerPwdCredential_call method_call = new registerPwdCredential_call(authzToken, gatewayId, userName, password, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class registerPwdCredential_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String gatewayId; + private String userName; + private String password; + public registerPwdCredential_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, String userName, String password, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.authzToken = authzToken; + this.gatewayId = gatewayId; + this.userName = userName; + this.password = password; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("registerPwdCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); + registerPwdCredential_args args = new registerPwdCredential_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + args.setUserName(userName); + args.setPassword(password); + args.write(prot); + prot.writeMessageEnd(); + } + + public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_registerPwdCredential(); + } + } + public void getSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getSSHPubKey_call method_call = new getSSHPubKey_call(authzToken, airavataCredStoreToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); @@ -8898,6 +9076,41 @@ public class Airavata { } } + public void getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getAllGatewayPWDCredentials_call method_call = new getAllGatewayPWDCredentials_call(authzToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getAllGatewayPWDCredentials_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String gatewayId; + public getAllGatewayPWDCredentials_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.authzToken = authzToken; + this.gatewayId = gatewayId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllGatewayPWDCredentials", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getAllGatewayPWDCredentials_args args = new getAllGatewayPWDCredentials_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public Map<String,String> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_getAllGatewayPWDCredentials(); + } + } + public void deleteSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteSSHPubKey_call method_call = new deleteSSHPubKey_call(authzToken, airavataCredStoreToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); @@ -8936,6 +9149,44 @@ public class Airavata { } } + public void deletePWDCredential(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + deletePWDCredential_call method_call = new deletePWDCredential_call(authzToken, airavataCredStoreToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class deletePWDCredential_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String airavataCredStoreToken; + private String gatewayId; + public deletePWDCredential_call(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.authzToken = authzToken; + this.airavataCredStoreToken = airavataCredStoreToken; + this.gatewayId = gatewayId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deletePWDCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); + deletePWDCredential_args args = new deletePWDCredential_args(); + args.setAuthzToken(authzToken); + args.setAiravataCredStoreToken(airavataCredStoreToken); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_deletePWDCredential(); + } + } + public void createProject(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.workspace.Project project, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); createProject_call method_call = new createProject_call(authzToken, gatewayId, project, resultHandler, this, ___protocolFactory, ___transport); @@ -13706,10 +13957,13 @@ public class Airavata { processMap.put("getNotification", new getNotification()); processMap.put("getAllNotifications", new getAllNotifications()); processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys()); + processMap.put("registerPwdCredential", new registerPwdCredential()); processMap.put("getSSHPubKey", new getSSHPubKey()); processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys()); processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys()); + processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials()); processMap.put("deleteSSHPubKey", new deleteSSHPubKey()); + processMap.put("deletePWDCredential", new deletePWDCredential()); processMap.put("createProject", new createProject()); processMap.put("updateProject", new updateProject()); processMap.put("getProject", new getProject()); @@ -14262,6 +14516,34 @@ public class Airavata { } } + public static class registerPwdCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerPwdCredential_args> { + public registerPwdCredential() { + super("registerPwdCredential"); + } + + public registerPwdCredential_args getEmptyArgsInstance() { + return new registerPwdCredential_args(); + } + + protected boolean isOneway() { + return false; + } + + public registerPwdCredential_result getResult(I iface, registerPwdCredential_args args) throws org.apache.thrift.TException { + registerPwdCredential_result result = new registerPwdCredential_result(); + try { + result.success = iface.registerPwdCredential(args.authzToken, args.gatewayId, args.userName, args.password); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } + return result; + } + } + public static class getSSHPubKey<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHPubKey_args> { public getSSHPubKey() { super("getSSHPubKey"); @@ -14346,6 +14628,34 @@ public class Airavata { } } + public static class getAllGatewayPWDCredentials<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewayPWDCredentials_args> { + public getAllGatewayPWDCredentials() { + super("getAllGatewayPWDCredentials"); + } + + public getAllGatewayPWDCredentials_args getEmptyArgsInstance() { + return new getAllGatewayPWDCredentials_args(); + } + + protected boolean isOneway() { + return false; + } + + public getAllGatewayPWDCredentials_result getResult(I iface, getAllGatewayPWDCredentials_args args) throws org.apache.thrift.TException { + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); + try { + result.success = iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } + return result; + } + } + public static class deleteSSHPubKey<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteSSHPubKey_args> { public deleteSSHPubKey() { super("deleteSSHPubKey"); @@ -14375,6 +14685,35 @@ public class Airavata { } } + public static class deletePWDCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deletePWDCredential_args> { + public deletePWDCredential() { + super("deletePWDCredential"); + } + + public deletePWDCredential_args getEmptyArgsInstance() { + return new deletePWDCredential_args(); + } + + protected boolean isOneway() { + return false; + } + + public deletePWDCredential_result getResult(I iface, deletePWDCredential_args args) throws org.apache.thrift.TException { + deletePWDCredential_result result = new deletePWDCredential_result(); + try { + result.success = iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } + return result; + } + } + public static class createProject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createProject_args> { public createProject() { super("createProject"); @@ -18241,10 +18580,13 @@ public class Airavata { processMap.put("getNotification", new getNotification()); processMap.put("getAllNotifications", new getAllNotifications()); processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys()); + processMap.put("registerPwdCredential", new registerPwdCredential()); processMap.put("getSSHPubKey", new getSSHPubKey()); processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys()); processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys()); + processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials()); processMap.put("deleteSSHPubKey", new deleteSSHPubKey()); + processMap.put("deletePWDCredential", new deletePWDCredential()); processMap.put("createProject", new createProject()); processMap.put("updateProject", new updateProject()); processMap.put("getProject", new getProject()); @@ -19381,20 +19723,20 @@ public class Airavata { } } - public static class getSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHPubKey_args, String> { - public getSSHPubKey() { - super("getSSHPubKey"); + public static class registerPwdCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerPwdCredential_args, String> { + public registerPwdCredential() { + super("registerPwdCredential"); } - public getSSHPubKey_args getEmptyArgsInstance() { - return new getSSHPubKey_args(); + public registerPwdCredential_args getEmptyArgsInstance() { + return new registerPwdCredential_args(); } public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<String>() { public void onComplete(String o) { - getSSHPubKey_result result = new getSSHPubKey_result(); + registerPwdCredential_result result = new registerPwdCredential_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19407,7 +19749,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getSSHPubKey_result result = new getSSHPubKey_result(); + registerPwdCredential_result result = new registerPwdCredential_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19443,25 +19785,25 @@ public class Airavata { return false; } - public void start(I iface, getSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.getSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); + public void start(I iface, registerPwdCredential_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerPwdCredential(args.authzToken, args.gatewayId, args.userName, args.password,resultHandler); } } - public static class getAllUserSSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserSSHPubKeys_args, Map<String,String>> { - public getAllUserSSHPubKeys() { - super("getAllUserSSHPubKeys"); + public static class getSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHPubKey_args, String> { + public getSSHPubKey() { + super("getSSHPubKey"); } - public getAllUserSSHPubKeys_args getEmptyArgsInstance() { - return new getAllUserSSHPubKeys_args(); + public getSSHPubKey_args getEmptyArgsInstance() { + return new getSSHPubKey_args(); } - public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Map<String,String>>() { - public void onComplete(Map<String,String> o) { - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + getSSHPubKey_result result = new getSSHPubKey_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19474,7 +19816,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); + getSSHPubKey_result result = new getSSHPubKey_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19510,25 +19852,25 @@ public class Airavata { return false; } - public void start(I iface, getAllUserSSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllUserSSHPubKeys(args.authzToken, args.userName,resultHandler); + public void start(I iface, getSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.getSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); } } - public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> { - public getAllGatewaySSHPubKeys() { - super("getAllGatewaySSHPubKeys"); + public static class getAllUserSSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserSSHPubKeys_args, Map<String,String>> { + public getAllUserSSHPubKeys() { + super("getAllUserSSHPubKeys"); } - public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() { - return new getAllGatewaySSHPubKeys_args(); + public getAllUserSSHPubKeys_args getEmptyArgsInstance() { + return new getAllUserSSHPubKeys_args(); } public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Map<String,String>>() { public void onComplete(Map<String,String> o) { - getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); + getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19541,7 +19883,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); + getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19577,27 +19919,26 @@ public class Airavata { return false; } - public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, getAllUserSSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { + iface.getAllUserSSHPubKeys(args.authzToken, args.userName,resultHandler); } } - public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> { - public deleteSSHPubKey() { - super("deleteSSHPubKey"); + public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> { + public getAllGatewaySSHPubKeys() { + super("getAllGatewaySSHPubKeys"); } - public deleteSSHPubKey_args getEmptyArgsInstance() { - return new deleteSSHPubKey_args(); + public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() { + return new getAllGatewaySSHPubKeys_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteSSHPubKey_result result = new deleteSSHPubKey_result(); + return new AsyncMethodCallback<Map<String,String>>() { + public void onComplete(Map<String,String> o) { + getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19609,7 +19950,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteSSHPubKey_result result = new deleteSSHPubKey_result(); + getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19645,25 +19986,25 @@ public class Airavata { return false; } - public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); + public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { + iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler); } } - public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { - public createProject() { - super("createProject"); + public static class getAllGatewayPWDCredentials<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayPWDCredentials_args, Map<String,String>> { + public getAllGatewayPWDCredentials() { + super("getAllGatewayPWDCredentials"); } - public createProject_args getEmptyArgsInstance() { - return new createProject_args(); + public getAllGatewayPWDCredentials_args getEmptyArgsInstance() { + return new getAllGatewayPWDCredentials_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - createProject_result result = new createProject_result(); + return new AsyncMethodCallback<Map<String,String>>() { + public void onComplete(Map<String,String> o) { + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19676,7 +20017,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createProject_result result = new createProject_result(); + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19692,11 +20033,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -19717,25 +20053,27 @@ public class Airavata { return false; } - public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler); + public void start(I iface, getAllGatewayPWDCredentials_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { + iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId,resultHandler); } } - public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { - public updateProject() { - super("updateProject"); + public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> { + public deleteSSHPubKey() { + super("deleteSSHPubKey"); } - public updateProject_args getEmptyArgsInstance() { - return new updateProject_args(); + public deleteSSHPubKey_args getEmptyArgsInstance() { + return new deleteSSHPubKey_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - updateProject_result result = new updateProject_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteSSHPubKey_result result = new deleteSSHPubKey_result(); + result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19747,7 +20085,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateProject_result result = new updateProject_result(); + deleteSSHPubKey_result result = new deleteSSHPubKey_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19763,16 +20101,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } - else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -19793,26 +20121,27 @@ public class Airavata { return false; } - public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler); + public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); } } - public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { - public getProject() { - super("getProject"); + public static class deletePWDCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePWDCredential_args, Boolean> { + public deletePWDCredential() { + super("deletePWDCredential"); } - public getProject_args getEmptyArgsInstance() { - return new getProject_args(); + public deletePWDCredential_args getEmptyArgsInstance() { + return new deletePWDCredential_args(); } - public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { - public void onComplete(org.apache.airavata.model.workspace.Project o) { - getProject_result result = new getProject_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deletePWDCredential_result result = new deletePWDCredential_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19824,7 +20153,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getProject_result result = new getProject_result(); + deletePWDCredential_result result = new deletePWDCredential_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19840,16 +20169,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } - else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -19870,27 +20189,26 @@ public class Airavata { return false; } - public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { - iface.getProject(args.authzToken, args.projectId,resultHandler); + public void start(I iface, deletePWDCredential_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); } } - public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> { - public deleteProject() { - super("deleteProject"); + public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { + public createProject() { + super("createProject"); } - public deleteProject_args getEmptyArgsInstance() { - return new deleteProject_args(); + public createProject_args getEmptyArgsInstance() { + return new createProject_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteProject_result result = new deleteProject_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createProject_result result = new createProject_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19902,7 +20220,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteProject_result result = new deleteProject_result(); + createProject_result result = new createProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19918,11 +20236,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -19948,26 +20261,25 @@ public class Airavata { return false; } - public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteProject(args.authzToken, args.projectId,resultHandler); + public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler); } } - public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { - public getUserProjects() { - super("getUserProjects"); + public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { + public updateProject() { + super("updateProject"); } - public getUserProjects_args getEmptyArgsInstance() { - return new getUserProjects_args(); + public updateProject_args getEmptyArgsInstance() { + return new updateProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - getUserProjects_result result = new getUserProjects_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateProject_result result = new updateProject_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19979,7 +20291,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserProjects_result result = new getUserProjects_result(); + updateProject_result result = new updateProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19995,6 +20307,11 @@ public class Airavata { result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20020,25 +20337,25 @@ public class Airavata { return false; } - public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); + public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler); } } - public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectName() { - super("searchProjectsByProjectName"); + public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { + public getProject() { + super("getProject"); } - public searchProjectsByProjectName_args getEmptyArgsInstance() { - return new searchProjectsByProjectName_args(); + public getProject_args getEmptyArgsInstance() { + return new getProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { + public void onComplete(org.apache.airavata.model.workspace.Project o) { + getProject_result result = new getProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20051,7 +20368,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + getProject_result result = new getProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20067,6 +20384,11 @@ public class Airavata { result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20092,26 +20414,27 @@ public class Airavata { return false; } - public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler); + public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { + iface.getProject(args.authzToken, args.projectId,resultHandler); } } - public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectDesc() { - super("searchProjectsByProjectDesc"); + public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> { + public deleteProject() { + super("deleteProject"); } - public searchProjectsByProjectDesc_args getEmptyArgsInstance() { - return new searchProjectsByProjectDesc_args(); + public deleteProject_args getEmptyArgsInstance() { + return new deleteProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteProject_result result = new deleteProject_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20123,7 +20446,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + deleteProject_result result = new deleteProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20139,6 +20462,11 @@ public class Airavata { result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20164,25 +20492,25 @@ public class Airavata { return false; } - public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); + public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteProject(args.authzToken, args.projectId,resultHandler); } } - public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByName() { - super("searchExperimentsByName"); + public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { + public getUserProjects() { + super("getUserProjects"); } - public searchExperimentsByName_args getEmptyArgsInstance() { - return new searchExperimentsByName_args(); + public getUserProjects_args getEmptyArgsInstance() { + return new getUserProjects_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByName_result result = new searchExperimentsByName_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + getUserProjects_result result = new getUserProjects_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20195,7 +20523,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByName_result result = new searchExperimentsByName_result(); + getUserProjects_result result = new getUserProjects_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20236,25 +20564,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler); + public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByDesc() { - super("searchExperimentsByDesc"); + public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectName() { + super("searchProjectsByProjectName"); } - public searchExperimentsByDesc_args getEmptyArgsInstance() { - return new searchExperimentsByDesc_args(); + public searchProjectsByProjectName_args getEmptyArgsInstance() { + return new searchProjectsByProjectName_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20267,7 +20595,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20308,25 +20636,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); + public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByApplication() { - super("searchExperimentsByApplication"); + public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectDesc() { + super("searchProjectsByProjectDesc"); } - public searchExperimentsByApplication_args getEmptyArgsInstance() { - return new searchExperimentsByApplication_args(); + public searchProjectsByProjectDesc_args getEmptyArgsInstance() { + return new searchProjectsByProjectDesc_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20339,7 +20667,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20380,25 +20708,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler); + public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByStatus() { - super("searchExperimentsByStatus"); + public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByName() { + super("searchExperimentsByName"); } - public searchExperimentsByStatus_args getEmptyArgsInstance() { - return new searchExperimentsByStatus_args(); + public searchExperimentsByName_args getEmptyArgsInstance() { + return new searchExperimentsByName_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + searchExperimentsByName_result result = new searchExperimentsByName_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20411,7 +20739,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + searchExperimentsByName_result result = new searchExperimentsByName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20452,25 +20780,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByCreationTime() { - super("searchExperimentsByCreationTime"); + public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByDesc() { + super("searchExperimentsByDesc"); } - public searchExperimentsByCreationTime_args getEmptyArgsInstance() { - return new searchExperimentsByCreationTime_args(); + public searchExperimentsByDesc_args getEmptyArgsInstance() { + return new searchExperimentsByDesc_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20483,7 +20811,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20524,25 +20852,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); } } - public static class searchExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperiments_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperiments() { - super("searchExperiments"); + public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByApplication() { + super("searchExperimentsByApplication"); } - public searchExperiments_args getEmptyArgsInstance() { - return new searchExperiments_args(); + public searchExperimentsByApplication_args getEmptyArgsInstance() { + return new searchExperimentsByApplication_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperiments_result result = new searchExperiments_result(); + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20555,7 +20883,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperiments_result result = new searchExperiments_result(); + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20596,25 +20924,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperiments(args.authzToken, args.gatewayId, args.userName, args.filters, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler); } } - public static class getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.experiment.ExperimentStatistics> { - public getExperimentStatistics() { - super("getExperimentStatistics"); + public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByStatus() { + super("searchExperimentsByStatus"); } - public getExperimentStatistics_args getEmptyArgsInstance() { - return new getExperimentStatistics_args(); + public searchExperimentsByStatus_args getEmptyArgsInstance() { + return new searchExperimentsByStatus_args(); } - public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics>() { - public void onComplete(org.apache.airavata.model.experiment.ExperimentStatistics o) { - getExperimentStatistics_result result = new getExperimentStatistics_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { + public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { + searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20627,7 +20955,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperimentStatistics_result result = new getExperimentStatistics_result(); + searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20668,25 +20996,25 @@ public class Airavata { return false; } - public void start(I iface, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> resultHandler) throws TException { - iface.getExperimentStatistics(args.authzToken, args.gatewayId, args.fromTime, args.toTime,resultHandler); + public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler); } } - public static class getExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentsInProject_args, List<org.apache.airavata.model.experiment.ExperimentModel>> { - public getExperimentsInProject() { - super("getExperimentsInProject"); + public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByCreationTime() { + super("searchExperimentsByCreationTime"); } - public getExperimentsInProject_args getEmptyArgsInstance() { - return new getExperimentsInProject_args(); + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return ne
<TRUNCATED>
