http://git-wip-us.apache.org/repos/asf/airavata/blob/3bb7f493/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py index 9f56005..46f4a4b 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py @@ -223,6 +223,33 @@ class Iface: """ pass + def registerPwdCredential(self, authzToken, gatewayId, userName, password): + """ + 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. + + + + Parameters: + - authzToken + - gatewayId + - userName + - password + """ + pass + def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ Get a Public Key by Providing the Token @@ -286,6 +313,14 @@ class Iface: """ pass + def getAllGatewayPWDCredentials(self, authzToken, gatewayId): + """ + Parameters: + - authzToken + - gatewayId + """ + pass + def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ @@ -306,6 +341,15 @@ class Iface: """ pass + def deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId): + """ + Parameters: + - authzToken + - airavataCredStoreToken + - gatewayId + """ + pass + def createProject(self, authzToken, gatewayId, project): """ @@ -3678,6 +3722,66 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result") + def registerPwdCredential(self, authzToken, gatewayId, userName, password): + """ + 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. + + + + Parameters: + - authzToken + - gatewayId + - userName + - password + """ + self.send_registerPwdCredential(authzToken, gatewayId, userName, password) + return self.recv_registerPwdCredential() + + def send_registerPwdCredential(self, authzToken, gatewayId, userName, password): + self._oprot.writeMessageBegin('registerPwdCredential', TMessageType.CALL, self._seqid) + args = registerPwdCredential_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.userName = userName + args.password = password + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_registerPwdCredential(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = registerPwdCredential_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerPwdCredential failed: unknown result") + def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ Get a Public Key by Providing the Token @@ -3835,6 +3939,45 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result") + def getAllGatewayPWDCredentials(self, authzToken, gatewayId): + """ + Parameters: + - authzToken + - gatewayId + """ + self.send_getAllGatewayPWDCredentials(authzToken, gatewayId) + return self.recv_getAllGatewayPWDCredentials() + + def send_getAllGatewayPWDCredentials(self, authzToken, gatewayId): + self._oprot.writeMessageBegin('getAllGatewayPWDCredentials', TMessageType.CALL, self._seqid) + args = getAllGatewayPWDCredentials_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllGatewayPWDCredentials(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllGatewayPWDCredentials_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayPWDCredentials failed: unknown result") + def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ @@ -3887,6 +4030,47 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteSSHPubKey failed: unknown result") + def deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId): + """ + Parameters: + - authzToken + - airavataCredStoreToken + - gatewayId + """ + self.send_deletePWDCredential(authzToken, airavataCredStoreToken, gatewayId) + return self.recv_deletePWDCredential() + + def send_deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId): + self._oprot.writeMessageBegin('deletePWDCredential', TMessageType.CALL, self._seqid) + args = deletePWDCredential_args() + args.authzToken = authzToken + args.airavataCredStoreToken = airavataCredStoreToken + args.gatewayId = gatewayId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deletePWDCredential(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = deletePWDCredential_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "deletePWDCredential failed: unknown result") + def createProject(self, authzToken, gatewayId, project): """ @@ -10878,10 +11062,13 @@ class Processor(Iface, TProcessor): self._processMap["getNotification"] = Processor.process_getNotification self._processMap["getAllNotifications"] = Processor.process_getAllNotifications self._processMap["generateAndRegisterSSHKeys"] = Processor.process_generateAndRegisterSSHKeys + self._processMap["registerPwdCredential"] = Processor.process_registerPwdCredential self._processMap["getSSHPubKey"] = Processor.process_getSSHPubKey self._processMap["getAllUserSSHPubKeys"] = Processor.process_getAllUserSSHPubKeys self._processMap["getAllGatewaySSHPubKeys"] = Processor.process_getAllGatewaySSHPubKeys + self._processMap["getAllGatewayPWDCredentials"] = Processor.process_getAllGatewayPWDCredentials self._processMap["deleteSSHPubKey"] = Processor.process_deleteSSHPubKey + self._processMap["deletePWDCredential"] = Processor.process_deletePWDCredential self._processMap["createProject"] = Processor.process_createProject self._processMap["updateProject"] = Processor.process_updateProject self._processMap["getProject"] = Processor.process_getProject @@ -11455,6 +11642,34 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_registerPwdCredential(self, seqid, iprot, oprot): + args = registerPwdCredential_args() + args.read(iprot) + iprot.readMessageEnd() + result = registerPwdCredential_result() + try: + result.success = self._handler.registerPwdCredential(args.authzToken, args.gatewayId, args.userName, args.password) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("registerPwdCredential", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getSSHPubKey(self, seqid, iprot, oprot): args = getSSHPubKey_args() args.read(iprot) @@ -11539,6 +11754,34 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getAllGatewayPWDCredentials(self, seqid, iprot, oprot): + args = getAllGatewayPWDCredentials_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllGatewayPWDCredentials_result() + try: + result.success = self._handler.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllGatewayPWDCredentials", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_deleteSSHPubKey(self, seqid, iprot, oprot): args = deleteSSHPubKey_args() args.read(iprot) @@ -11567,6 +11810,34 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_deletePWDCredential(self, seqid, iprot, oprot): + args = deletePWDCredential_args() + args.read(iprot) + iprot.readMessageEnd() + result = deletePWDCredential_result() + try: + result.success = self._handler.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("deletePWDCredential", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_createProject(self, seqid, iprot, oprot): args = createProject_args() args.read(iprot) @@ -17975,22 +18246,237 @@ class getNotification_result: def __ne__(self, other): return not (self == other) -class getAllNotifications_args: +class getAllNotifications_args: + """ + Attributes: + - authzToken + - gatewayId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, gatewayId=None,): + self.authzToken = authzToken + self.gatewayId = gatewayId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.gatewayId = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllNotifications_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.gatewayId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getAllNotifications_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Notification, apache.airavata.model.workspace.ttypes.Notification.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.LIST: + self.success = [] + (_etype10, _size7) = iprot.readListBegin() + for _i11 in xrange(_size7): + _elem12 = apache.airavata.model.workspace.ttypes.Notification() + _elem12.read(iprot) + self.success.append(_elem12) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllNotifications_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter13 in self.success: + iter13.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class generateAndRegisterSSHKeys_args: """ Attributes: - authzToken - gatewayId + - userName """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 + (3, TType.STRING, 'userName', None, None, ), # 3 ) - def __init__(self, authzToken=None, gatewayId=None,): + def __init__(self, authzToken=None, gatewayId=None, userName=None,): self.authzToken = authzToken self.gatewayId = gatewayId + self.userName = userName def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -18012,6 +18498,11 @@ class getAllNotifications_args: self.gatewayId = iprot.readString() else: iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.userName = iprot.readString() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -18021,7 +18512,7 @@ class getAllNotifications_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getAllNotifications_args') + oprot.writeStructBegin('generateAndRegisterSSHKeys_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -18030,6 +18521,10 @@ class getAllNotifications_args: oprot.writeFieldBegin('gatewayId', TType.STRING, 2) oprot.writeString(self.gatewayId) oprot.writeFieldEnd() + if self.userName is not None: + oprot.writeFieldBegin('userName', TType.STRING, 3) + oprot.writeString(self.userName) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -18038,6 +18533,8 @@ class getAllNotifications_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.gatewayId is None: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + if self.userName is None: + raise TProtocol.TProtocolException(message='Required field userName is unset!') return @@ -18045,6 +18542,7 @@ class getAllNotifications_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.userName) return value def __repr__(self): @@ -18058,30 +18556,27 @@ class getAllNotifications_args: def __ne__(self, other): return not (self == other) -class getAllNotifications_result: +class generateAndRegisterSSHKeys_result: """ Attributes: - success - ire - ace - ase - - ae """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Notification, apache.airavata.model.workspace.ttypes.Notification.thrift_spec)), None, ), # 0 + (0, TType.STRING, 'success', None, None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 - (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 ) - def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + def __init__(self, success=None, ire=None, ace=None, ase=None,): self.success = success self.ire = ire self.ace = ace self.ase = ase - self.ae = ae def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -18093,14 +18588,8 @@ class getAllNotifications_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype10, _size7) = iprot.readListBegin() - for _i11 in xrange(_size7): - _elem12 = apache.airavata.model.workspace.ttypes.Notification() - _elem12.read(iprot) - self.success.append(_elem12) - iprot.readListEnd() + if ftype == TType.STRING: + self.success = iprot.readString() else: iprot.skip(ftype) elif fid == 1: @@ -18121,12 +18610,6 @@ class getAllNotifications_result: self.ase.read(iprot) else: iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRUCT: - self.ae = apache.airavata.api.error.ttypes.AuthorizationException() - self.ae.read(iprot) - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -18136,13 +18619,10 @@ class getAllNotifications_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getAllNotifications_result') + oprot.writeStructBegin('generateAndRegisterSSHKeys_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter13 in self.success: - iter13.write(oprot) - oprot.writeListEnd() + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -18156,10 +18636,6 @@ class getAllNotifications_result: oprot.writeFieldBegin('ase', TType.STRUCT, 3) self.ase.write(oprot) oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -18173,7 +18649,6 @@ class getAllNotifications_result: value = (value * 31) ^ hash(self.ire) value = (value * 31) ^ hash(self.ace) value = (value * 31) ^ hash(self.ase) - value = (value * 31) ^ hash(self.ae) return value def __repr__(self): @@ -18187,12 +18662,13 @@ class getAllNotifications_result: def __ne__(self, other): return not (self == other) -class generateAndRegisterSSHKeys_args: +class registerPwdCredential_args: """ Attributes: - authzToken - gatewayId - userName + - password """ thrift_spec = ( @@ -18200,12 +18676,14 @@ class generateAndRegisterSSHKeys_args: (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 (3, TType.STRING, 'userName', None, None, ), # 3 + (4, TType.STRING, 'password', None, None, ), # 4 ) - def __init__(self, authzToken=None, gatewayId=None, userName=None,): + def __init__(self, authzToken=None, gatewayId=None, userName=None, password=None,): self.authzToken = authzToken self.gatewayId = gatewayId self.userName = userName + self.password = password def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -18232,6 +18710,11 @@ class generateAndRegisterSSHKeys_args: self.userName = iprot.readString() else: iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.password = iprot.readString() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -18241,7 +18724,7 @@ class generateAndRegisterSSHKeys_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('generateAndRegisterSSHKeys_args') + oprot.writeStructBegin('registerPwdCredential_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -18254,6 +18737,10 @@ class generateAndRegisterSSHKeys_args: oprot.writeFieldBegin('userName', TType.STRING, 3) oprot.writeString(self.userName) oprot.writeFieldEnd() + if self.password is not None: + oprot.writeFieldBegin('password', TType.STRING, 4) + oprot.writeString(self.password) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -18264,6 +18751,8 @@ class generateAndRegisterSSHKeys_args: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') if self.userName is None: raise TProtocol.TProtocolException(message='Required field userName is unset!') + if self.password is None: + raise TProtocol.TProtocolException(message='Required field password is unset!') return @@ -18272,6 +18761,7 @@ class generateAndRegisterSSHKeys_args: value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) value = (value * 31) ^ hash(self.userName) + value = (value * 31) ^ hash(self.password) return value def __repr__(self): @@ -18285,7 +18775,7 @@ class generateAndRegisterSSHKeys_args: def __ne__(self, other): return not (self == other) -class generateAndRegisterSSHKeys_result: +class registerPwdCredential_result: """ Attributes: - success @@ -18348,7 +18838,7 @@ class generateAndRegisterSSHKeys_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('generateAndRegisterSSHKeys_result') + oprot.writeStructBegin('registerPwdCredential_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRING, 0) oprot.writeString(self.success) @@ -18993,6 +19483,205 @@ class getAllGatewaySSHPubKeys_result: def __ne__(self, other): return not (self == other) +class getAllGatewayPWDCredentials_args: + """ + Attributes: + - authzToken + - gatewayId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, gatewayId=None,): + self.authzToken = authzToken + self.gatewayId = gatewayId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.gatewayId = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllGatewayPWDCredentials_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.gatewayId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getAllGatewayPWDCredentials_result: + """ + Attributes: + - success + - ire + - ace + - ase + """ + + thrift_spec = ( + (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.MAP: + self.success = {} + (_ktype33, _vtype34, _size32 ) = iprot.readMapBegin() + for _i36 in xrange(_size32): + _key37 = iprot.readString() + _val38 = iprot.readString() + self.success[_key37] = _val38 + iprot.readMapEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllGatewayPWDCredentials_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.MAP, 0) + oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) + for kiter39,viter40 in self.success.items(): + oprot.writeString(kiter39) + oprot.writeString(viter40) + oprot.writeMapEnd() + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class deleteSSHPubKey_args: """ Attributes: @@ -19197,6 +19886,210 @@ class deleteSSHPubKey_result: def __ne__(self, other): return not (self == other) +class deletePWDCredential_args: + """ + Attributes: + - authzToken + - airavataCredStoreToken + - gatewayId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'airavataCredStoreToken', None, None, ), # 2 + (3, TType.STRING, 'gatewayId', None, None, ), # 3 + ) + + def __init__(self, authzToken=None, airavataCredStoreToken=None, gatewayId=None,): + self.authzToken = authzToken + self.airavataCredStoreToken = airavataCredStoreToken + self.gatewayId = gatewayId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.airavataCredStoreToken = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.gatewayId = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('deletePWDCredential_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.airavataCredStoreToken is not None: + oprot.writeFieldBegin('airavataCredStoreToken', TType.STRING, 2) + oprot.writeString(self.airavataCredStoreToken) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 3) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.airavataCredStoreToken is None: + raise TProtocol.TProtocolException(message='Required field airavataCredStoreToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.airavataCredStoreToken) + value = (value * 31) ^ hash(self.gatewayId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class deletePWDCredential_result: + """ + Attributes: + - success + - ire + - ace + - ase + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('deletePWDCredential_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class createProject_args: """ Attributes: @@ -20237,11 +21130,11 @@ class getUserProjects_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype35, _size32) = iprot.readListBegin() - for _i36 in xrange(_size32): - _elem37 = apache.airavata.model.workspace.ttypes.Project() - _elem37.read(iprot) - self.success.append(_elem37) + (_etype44, _size41) = iprot.readListBegin() + for _i45 in xrange(_size41): + _elem46 = apache.airavata.model.workspace.ttypes.Project() + _elem46.read(iprot) + self.success.append(_elem46) iprot.readListEnd() else: iprot.skip(ftype) @@ -20282,8 +21175,8 @@ class getUserProjects_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter38 in self.success: - iter38.write(oprot) + for iter47 in self.success: + iter47.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -20509,11 +21402,11 @@ class searchProjectsByProjectName_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype42, _size39) = iprot.readListBegin() - for _i43 in xrange(_size39): - _elem44 = apache.airavata.model.workspace.ttypes.Project() - _elem44.read(iprot) - self.success.append(_elem44) + (_etype51, _size48) = iprot.readListBegin() + for _i52 in xrange(_size48): + _elem53 = apache.airavata.model.workspace.ttypes.Project() + _elem53.read(iprot) + self.success.append(_elem53) iprot.readListEnd() else: iprot.skip(ftype) @@ -20554,8 +21447,8 @@ class searchProjectsByProjectName_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter45 in self.success: - iter45.write(oprot) + for iter54 in self.success: + iter54.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -20781,11 +21674,11 @@ class searchProjectsByProjectDesc_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype49, _size46) = iprot.readListBegin() - for _i50 in xrange(_size46): - _elem51 = apache.airavata.model.workspace.ttypes.Project() - _elem51.read(iprot) - self.success.append(_elem51) + (_etype58, _size55) = iprot.readListBegin() + for _i59 in xrange(_size55): + _elem60 = apache.airavata.model.workspace.ttypes.Project() + _elem60.read(iprot) + self.success.append(_elem60) iprot.readListEnd() else: iprot.skip(ftype) @@ -20826,8 +21719,8 @@ class searchProjectsByProjectDesc_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter52 in self.success: - iter52.write(oprot) + for iter61 in self.success: + iter61.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21053,11 +21946,11 @@ class searchExperimentsByName_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype56, _size53) = iprot.readListBegin() - for _i57 in xrange(_size53): - _elem58 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem58.read(iprot) - self.success.append(_elem58) + (_etype65, _size62) = iprot.readListBegin() + for _i66 in xrange(_size62): + _elem67 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem67.read(iprot) + self.success.append(_elem67) iprot.readListEnd() else: iprot.skip(ftype) @@ -21098,8 +21991,8 @@ class searchExperimentsByName_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter59 in self.success: - iter59.write(oprot) + for iter68 in self.success: + iter68.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21325,11 +22218,11 @@ class searchExperimentsByDesc_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype63, _size60) = iprot.readListBegin() - for _i64 in xrange(_size60): - _elem65 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem65.read(iprot) - self.success.append(_elem65) + (_etype72, _size69) = iprot.readListBegin() + for _i73 in xrange(_size69): + _elem74 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem74.read(iprot) + self.success.append(_elem74) iprot.readListEnd() else: iprot.skip(ftype) @@ -21370,8 +22263,8 @@ class searchExperimentsByDesc_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter66 in self.success: - iter66.write(oprot) + for iter75 in self.success: + iter75.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21597,11 +22490,11 @@ class searchExperimentsByApplication_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype70, _size67) = iprot.readListBegin() - for _i71 in xrange(_size67): - _elem72 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem72.read(iprot) - self.success.append(_elem72) + (_etype79, _size76) = iprot.readListBegin() + for _i80 in xrange(_size76): + _elem81 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem81.read(iprot) + self.success.append(_elem81) iprot.readListEnd() else: iprot.skip(ftype) @@ -21642,8 +22535,8 @@ class searchExperimentsByApplication_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter73 in self.success: - iter73.write(oprot) + for iter82 in self.success: + iter82.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21869,11 +22762,11 @@ class searchExperimentsByStatus_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype77, _size74) = iprot.readListBegin() - for _i78 in xrange(_size74): - _elem79 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem79.read(iprot) - self.success.append(_elem79) + (_etype86, _size83) = iprot.readListBegin() + for _i87 in xrange(_size83): + _elem88 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem88.read(iprot) + self.success.append(_elem88) iprot.readListEnd() else: iprot.skip(ftype) @@ -21914,8 +22807,8 @@ class searchExperimentsByStatus_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter80 in self.success: - iter80.write(oprot) + for iter89 in self.success: + iter89.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22156,11 +23049,11 @@ class searchExperimentsByCreationTime_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype84, _size81) = iprot.readListBegin() - for _i85 in xrange(_size81): - _elem86 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem86.read(iprot) - self.success.append(_elem86) + (_etype93, _size90) = iprot.readListBegin() + for _i94 in xrange(_size90): + _elem95 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem95.read(iprot) + self.success.append(_elem95) iprot.readListEnd() else: iprot.skip(ftype) @@ -22201,8 +23094,8 @@ class searchExperimentsByCreationTime_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter87 in self.success: - iter87.write(oprot) + for iter96 in self.success: + iter96.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22305,11 +23198,11 @@ class searchExperiments_args: elif fid == 4: if ftype == TType.MAP: self.filters = {} - (_ktype89, _vtype90, _size88 ) = iprot.readMapBegin() - for _i92 in xrange(_size88): - _key93 = iprot.readI32() - _val94 = iprot.readString() - self.filters[_key93] = _val94 + (_ktype98, _vtype99, _size97 ) = iprot.readMapBegin() + for _i101 in xrange(_size97): + _key102 = iprot.readI32() + _val103 = iprot.readString() + self.filters[_key102] = _val103 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22348,9 +23241,9 @@ class searchExperiments_args: if self.filters is not None: oprot.writeFieldBegin('filters', TType.MAP, 4) oprot.writeMapBegin(TType.I32, TType.STRING, len(self.filters)) - for kiter95,viter96 in self.filters.items(): - oprot.writeI32(kiter95) - oprot.writeString(viter96) + for kiter104,viter105 in self.filters.items(): + oprot.writeI32(kiter104) + oprot.writeString(viter105) oprot.writeMapEnd() oprot.writeFieldEnd() if self.limit is not None: @@ -22436,11 +23329,11 @@ class searchExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype100, _size97) = iprot.readListBegin() - for _i101 in xrange(_size97): - _elem102 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem102.read(iprot) - self.success.append(_elem102) + (_etype109, _size106) = iprot.readListBegin() + for _i110 in xrange(_size106): + _elem111 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem111.read(iprot) + self.success.append(_elem111) iprot.readListEnd() else: iprot.skip(ftype) @@ -22481,8 +23374,8 @@ class searchExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter103 in self.success: - iter103.write(oprot) + for iter112 in self.success: + iter112.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22915,11 +23808,11 @@ class getExperimentsInProject_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype107, _size104) = iprot.readListBegin() - for _i108 in xrange(_size104): - _elem109 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem109.read(iprot) - self.success.append(_elem109) + (_etype116, _size113) = iprot.readListBegin() + for _i117 in xrange(_size113): + _elem118 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem118.read(iprot) + self.success.append(_elem118) iprot.readListEnd() else: iprot.skip(ftype) @@ -22966,8 +23859,8 @@ class getExperimentsInProject_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter110 in self.success: - iter110.write(oprot) + for iter119 in self.success: + iter119.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -23183,11 +24076,11 @@ class getUserExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype114, _size111) = iprot.readListBegin() - for _i115 in xrange(_size111): - _elem116 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem116.read(iprot) - self.success.append(_elem116) + (_etype123, _size120) = iprot.readListBegin() + for _i124 in xrange(_size120): + _elem125 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem125.read(iprot) + self.success.append(_elem125) iprot.readListEnd() else: iprot.skip(ftype) @@ -23228,8 +24121,8 @@ class getUserExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter117 in self.success: - iter117.write(oprot) + for iter126 in self.success: + iter126.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -25462,11 +26355,11 @@ class getExperimentOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype121, _size118) = iprot.readListBegin() - for _i122 in xrange(_size118): - _elem123 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem123.read(iprot) - self.success.append(_elem123) + (_etype130, _size127) = iprot.readListBegin() + for _i131 in xrange(_size127): + _elem132 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem132.read(iprot) + self.success.append(_elem132) iprot.readListEnd() else: iprot.skip(ftype) @@ -25513,8 +26406,8 @@ class getExperimentOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter124 in self.success: - iter124.write(oprot) + for iter133 in self.success: + iter133.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -25688,11 +26581,11 @@ class getIntermediateOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype128, _size125) = iprot.readListBegin() - for _i129 in xrange(_size125): - _elem130 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem130.read(iprot) - self.success.append(_elem130) + (_etype137, _size134) = iprot.readListBegin() + for _i138 in xrange(_size134): + _elem139 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem139.read(iprot) + self.success.append(_elem139) iprot.readListEnd() else: iprot.skip(ftype) @@ -25739,8 +26632,8 @@ class getIntermediateOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter131 in self.success: - iter131.write(oprot) + for iter140 in self.success: + iter140.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -25914,12 +26807,12 @@ class getJobStatuses_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype133, _vtype134, _size132 ) = iprot.readMapBegin() - for _i136 in xrange(_size132): - _key137 = iprot.readString() - _val138 = apache.airavata.model.status.ttypes.JobStatus() - _val138.read(iprot) - self.success[_key137] = _val138 + (_ktype142, _vtype143, _size141 ) = iprot.readMapBegin() + for _i145 in xrange(_size141): + _key146 = iprot.readString() + _val147 = apache.airavata.model.status.ttypes.JobStatus() + _val147.read(iprot) + self.success[_key146] = _val147 iprot.readMapEnd() else: iprot.skip(ftype) @@ -25966,9 +26859,9 @@ class getJobStatuses_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter139,viter140 in self.success.items(): - oprot.writeString(kiter139) - viter140.write(oprot) + for kiter148,viter149 in self.success.items(): + oprot.writeString(kiter148) + viter149.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26142,11 +27035,11 @@ class getJobDetails_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype144, _size141) = iprot.readListBegin() - for _i145 in xrange(_size141): - _elem146 = apache.airavata.model.job.ttypes.JobModel() - _elem146.read(iprot) - self.success.append(_elem146) + (_etype153, _size150) = iprot.readListBegin() + for _i154 in xrange(_size150): + _elem155 = apache.airavata.model.job.ttypes.JobModel() + _elem155.read(iprot) + self.success.append(_elem155) iprot.readListEnd() else: iprot.skip(ftype) @@ -26193,8 +27086,8 @@ class getJobDetails_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter147 in self.success: - iter147.write(oprot) + for iter156 in self.success: + iter156.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -27451,11 +28344,11 @@ class getAllAppModules_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype151, _size148) = iprot.readListBegin() - for _i152 in xrange(_size148): - _elem153 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() - _elem153.read(iprot) - self.success.append(_elem153) + (_etype160, _size157) = iprot.readListBegin() + for _i161 in xrange(_size157): + _elem162 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + _elem162.read(iprot) + self.success.append(_elem162) iprot.readListEnd() else: iprot.skip(ftype) @@ -27496,8 +28389,8 @@ class getAllAppModules_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter154 in self.success: - iter154.write(oprot) + for iter163 in self.success: + iter163.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -28711,11 +29604,11 @@ class getAllApplicationDeployments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype158, _size155) = iprot.readListBegin() - for _i159 in xrange(_size155): - _elem160 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() - _elem160.read(iprot) - self.success.append(_elem160) + (_etype167, _size164) = iprot.readListBegin() + for _i168 in xrange(_size164): + _elem169 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + _elem169.read(iprot) + self.success.append(_elem169) iprot.readListEnd() else: iprot.skip(ftype) @@ -28756,8 +29649,8 @@ class getAllApplicationDeployments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter161 in self.success: - iter161.write(oprot) + for iter170 in self.success: + iter170.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -28923,10 +29816,10 @@ class getAppModuleDeployedResources_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype165, _size162) = iprot.readListBegin() - for _i166 in xrange(_size162): - _elem167 = iprot.readString() - self.success.append(_elem167) + (_etype174, _size171) = iprot.readListBegin() + for _i175 in xrange(_size171): + _elem176 = iprot.readString() + self.success.append(_elem176) iprot.readListEnd() else: iprot.skip(ftype) @@ -28967,8 +29860,8 @@ class getAppModuleDeployedResources_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter168 in self.success: - oprot.writeString(iter168) + for iter177 in self.success: + oprot.writeString(iter177) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -30206,11 +31099,11 @@ class getAllApplicationInterfaceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype170, _vtype171, _size169 ) = iprot.readMapBegin() - for _i173 in xrange(_size169): - _key174 = iprot.readString() - _val175 = iprot.readString() - self.success[_key174] = _val175 + (_ktype179, _vtype180, _size178 ) = iprot.readMapBegin() + for _i182 in xrange(_size178): + _key183 = iprot.readString() + _val184 = iprot.readString() + self.success[_key183] = _val184 iprot.readMapEnd() else: iprot.skip(ftype) @@ -30251,9 +31144,9 @@ class getAllApplicationInterfaceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter176,viter177 in self.success.items(): - oprot.writeString(kiter176) - oprot.writeString(viter177) + for kiter185,viter186 in self.success.items(): + oprot.writeString(kiter185) + oprot.writeString(viter186) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -30419,11 +31312,11 @@ class getAllApplicationInterfaces_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype181, _size178) = iprot.readListBegin() - for _i182 in xrange(_size178): - _elem183 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() - _elem183.read(iprot) - self.success.append(_elem183) + (_etype190, _size187) = iprot.readListBegin() + for _i191 in xrange(_size187): + _elem192 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() + _elem192.read(iprot) + self.success.append(_elem192) iprot.readListEnd() else: iprot.skip(ftype) @@ -30464,8 +31357,8 @@ class getAllApplicationInterfaces_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter184 in self.success: - iter184.write(oprot) + for iter193 in self.success: + iter193.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -30631,11 +31524,11 @@ class getApplicationInputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype188, _size185) = iprot.readListBegin() - for _i189 in xrange(_size185): - _elem190 = apache.airavata.model.application.io.ttypes.InputDataObjectType() - _elem190.read(iprot) - self.success.append(_elem190) + (_etype197, _size194) = iprot.readListBegin() + for _i198 in xrange(_size194): + _elem199 = apache.airavata.model.application.io.ttypes.InputDataObjectType() + _elem199.read(iprot) + self.success.append(_elem199) iprot.readListEnd() else: iprot.skip(ftype) @@ -30676,8 +31569,8 @@ class getApplicationInputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter191 in self.success: - iter191.write(oprot) + for iter200 in self.success: + iter200.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -30843,11 +31736,11 @@ class getApplicationOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype195, _size192) = iprot.readListBegin() - for _i196 in xrange(_size192): - _elem197 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem197.read(iprot) - self.success.append(_elem197) + (_etype204, _size201) = iprot.readListBegin() + for _i205 in xrange(_size201): + _elem206 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem206.read(iprot) + self.success.append(_elem206) iprot.readListEnd() else: iprot.skip(ftype) @@ -30888,8 +31781,8 @@ class getApplicationOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter198 in self.success: - iter198.write(oprot) + for iter207 in self.success: + iter207.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31055,11 +31948,11 @@ class getAvailableAppInterfaceComputeResources_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype200, _vtype201, _size199 ) = iprot.readMapBegin() - for _i203 in xrange(_size199): - _key204 = iprot.readString() - _val205 = iprot.readString() - self.success[_key204] = _val205 + (_ktype209, _vtype210, _size208 ) = iprot.readMapBegin() + for _i212 in xrange(_size208): + _key213 = iprot.readString() + _val214 = iprot.readString() + self.success[_key213] = _val214 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31100,9 +31993,9 @@ class getAvailableAppInterfaceComputeResources_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter206,viter207 in self.success.items(): - oprot.writeString(kiter206) - oprot.writeString(viter207) + for kiter215,viter216 in self.success.items(): + oprot.writeString(kiter215) + oprot.writeString(viter216) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31661,11 +32554,11 @@ class getAllComputeResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype209, _vtype210, _size208 ) = iprot.readMapBegin() - for _i212 in xrange(_size208): - _key213 = iprot.readString() - _val214 = iprot.readString() - self.success[_key213] = _val214 + (_ktype218, _vtype219, _size217 ) = iprot.readMapBegin() + for _i221 in xrange(_size217): + _key222 = iprot.readString() + _val223 = iprot.readString() + self.success[_key222] = _val223 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31706,9 +32599,9 @@ class getAllComputeResourceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter215,viter216 in self.success.items(): - oprot.writeString(kiter215) - oprot.writeString(viter216) + for kiter224,viter225 in self.success.items(): + oprot.writeString(kiter224) + oprot.writeString(viter225) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -32689,11 +33582,11 @@ class getAllStorageResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype218, _vtype219, _size217 ) = iprot.readMapBegin() - for _i221 in xrange(_size217): - _key222 = iprot.readString() - _val223 = iprot.readString() - self.success[_key222] = _val223 + (_ktype227, _vtype228, _size226 ) = iprot.readMapBegin() + for _i230 in xrange(_size226): + _key231 = iprot.readString() + _val232 = iprot.readString() + self.success[_key231] = _val232 iprot.readMapEnd() else: iprot.skip(ftype) @@ -32734,9 +33627,9 @@ class getAllStorageResourceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter224,viter225 in self.success.items(): - oprot.writeString(kiter224) - oprot.writeString(viter225) + for kiter233,viter234 in self.success.items(): + oprot.writeString(kiter233) + oprot.writeString(viter234) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -39225,11 +40118,11 @@ class changeJobSubmissionPriorities_args: elif fid == 2: if ftype == TType.MAP: self.jobSubmissionPriorityMap = {} - (_ktype227, _vtype228, _size226 ) = iprot.readMapBegin() - for _i230 in xrange(_size226): - _key231 = iprot.readString() - _val232 = iprot.readI32() - self.jobSubmissionPriorityMap[_key231] = _val232 + (_ktype236, _vtype237, _size235 ) = iprot.readMapBegin() + for _i239 in xrange(_size235): + _key240 = iprot.readString() + _val241 = iprot.readI32() + self.jobSubmissionPriorityMap[_key240] = _val241 iprot.readMapEnd() else: iprot.skip(ftype) @@ -39250,9 +40143,9 @@ class changeJobSubmissionPriorities_args: if self.jobSubmissionPriorityMap is not None: oprot.writeFieldBegin('jobSubmissionPriorityMap', TType.MAP, 2) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.jobSubmissionPriorityMap)) - for kiter233,viter234 in self.jobSubmissionPriorityMap.items(): - oprot.writeString(kiter233) - oprot.writeI32(viter234) + for kiter242,viter243 in self.jobSubmissionPriorityMap.items(): + oprot.writeString(kiter242) + oprot.writeI32(viter243) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -39438,11 +40331,11 @@ class changeDataMovementPriorities_args: elif fid == 2: if ftype == TType.MAP: self.dataMovementPriorityMap = {} - (_ktype236, _vtype237, _size235 ) = iprot.readMapBegin() - for _i239 in xrange(_size235): - _key240 = iprot.readString() - _val241 = iprot.readI32() - self.dataMovementPriorityMap[_key240] = _val241 + (_ktype245, _vtype246, _size244 ) = iprot.readMapBegin() + for _i248 in xrange(_size244): + _key249 = iprot.readString() + _val250 = iprot.readI32() + self.dataMovementPriorityMap[_key249] = _val250 iprot.readMapEnd() else: iprot.skip(ftype) @@ -39463,9 +40356,9 @@ class changeDataMovementPriorities_args: if self.dataMovementPriorityMap is not None: oprot.writeFieldBegin('dataMovementPriorityMap', TType.MAP, 2) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.dataMovementPriorityMap)) - for kiter242,viter243 in self.dataMovementPriorityMap.items(): - oprot.writeString(kiter242) - oprot.writeI32(viter243) + for kiter251,viter252 in self.dataMovementPriorityMap.items(): + oprot.writeString(kiter251) + oprot.writeI32(viter252) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -42971,11 +43864,11 @@ class getAllGatewayComputeResourcePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype247, _size244) = iprot.readListBegin() - for _i248 in xrange(_size244): - _elem249 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() - _elem249.read(iprot) - self.success.append(_elem249) + (_etype256, _size253) = iprot.readListBegin() + for _i257 in xrange(_size253): + _elem258 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() + _elem258.read(iprot) + self.success.append(_elem258) iprot.readListEnd() else: iprot.skip(ftype) @@ -43016,8 +43909,8 @@ class getAllGatewayComputeResourcePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter250 in self.success: - iter250.write(oprot) + for iter259 in self.success: + iter259.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -43183,11 +44076,11 @@ class getAllGatewayStoragePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype254, _size251) = iprot.readListBegin() - for _i255 in xrange(_size251): - _elem256 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() - _elem256.read(iprot) - self.success.append(_elem256) + (_etype263, _size260) = iprot.readListBegin() + for _i264 in xrange(_size260): + _elem265 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() + _elem265.read(iprot) + self.success.append(_elem265) iprot.readListEnd() else: iprot.skip(ftype) @@ -43228,8 +44121,8 @@ class getAllGatewayStoragePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter257 in self.success: - iter257.write(oprot) + for iter266 in self.success: + iter266.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -43380,11 +44273,11 @@ class getAllGatewayResourceProfiles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype261, _size258) = iprot.readListBegin() - for _i262 in xrange(_size258): - _elem263 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() - _elem263.read(iprot) - self.success.append(_elem263) + (_etype270, _size267) = iprot.readListBegin() + for _i271 in xrange(_size267): + _elem272 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() + _elem272.read(iprot) + self.success.append(_elem272) iprot.readListEnd() else: iprot.skip(ftype) @@ -43425,8 +44318,8 @@ class getAllGatewayResourceProfiles_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter264 in self.success: - iter264.write(oprot) + for iter273 in self.success: + iter273.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -44496,10 +45389,10 @@ class getAllWorkflows_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype268, _size265) = iprot.readListBegin() - for _i269 in xrange(_size265): - _elem270 = iprot.readString() - self.success.append(_elem270) + (_etype277, _size274) = iprot.readListBegin() + for _i278 in xrange(_size274): + _elem279 = iprot.readString() + self.success.append(_elem279) iprot.readListEnd() else: iprot.skip(ftype) @@ -44540,8 +45433,8 @@ class getAllWorkflows_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter271 in self.success: - oprot.writeString(iter271) + for iter280 in self.success: + oprot.writeString(iter280) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -46750,11 +47643,11 @@ class getChildDataProducts_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype275, _size272) = iprot.readListBegin() - for _i276 in xrange(_size272): - _elem277 = apache.airavata.model.data.replica.ttypes.DataProductModel() - _elem277.read(iprot) - self.success.append(_elem277) + (_etype284, _size281) = iprot.readListBegin() + for _i285 in xrange(_size281): + _elem286 = apache.airavata.model.data.replica.ttypes.DataProductModel() + _elem286.read(iprot) + self.success.append(_elem286) iprot.readListEnd() else: iprot.skip(ftype) @@ -46795,8 +47688,8 @@ class getChildDataProducts_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter278 in self.success: - iter278.write(oprot) + for iter287 in self.success: + iter287.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None:
http://git-wip-us.apache.org/repos/asf/airavata/blob/3bb7f493/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java ---------------------------------------------------------------------- diff --git a/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java b/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java index a31c98b..21cc271 100644 --- a/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java +++ b/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java @@ -21,11 +21,8 @@ package org.apache.airavata.credential.store.credential.impl.password; -import org.apache.airavata.credential.store.credential.Credential; import org.apache.airavata.credential.store.credential.impl.ssh.SSHCredential; -import java.util.Date; - /** * User name password credentials. */ @@ -33,6 +30,7 @@ public class PasswordCredential extends SSHCredential { private String userName; private String password; + private String description; public String getUserName() { return userName; @@ -50,4 +48,11 @@ public class PasswordCredential extends SSHCredential { this.password = password; } + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } }
