http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/4ffaa68a/app/libraries/Airavata/API/Airavata.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/API/Airavata.php b/app/libraries/Airavata/API/Airavata.php index 0c6e126..7d5325a 100644 --- a/app/libraries/Airavata/API/Airavata.php +++ b/app/libraries/Airavata/API/Airavata.php @@ -269,6 +269,35 @@ interface AiravataIf { */ public function generateAndRegisterSSHKeys(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName); /** + * Generate and Register SSH Key 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 description + * The description field for a credential type, all type of credential can have a description. + * + * @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 \Airavata\Model\Security\AuthzToken $authzToken + * @param string $gatewayId + * @param string $userName + * @param string $description + * @return string + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + */ + public function generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description); + /** * Generate and Register Username PWD Pair with Airavata Credential Store. * * @param gatewayId @@ -345,6 +374,54 @@ interface AiravataIf { */ public function getAllGatewaySSHPubKeys(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId); /** + * + * Get all Public Keys of the Gateway + * + * @param CredStoreToken + * Credential Store Token which you want to find the Public Key for. + * + * @param gatewayId + * This is the unique identifier of your gateway where the token and public key was generated from. + * + * @return publicKey + * + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $gatewayId + * @return \Airavata\Model\AppCatalog\CredetialSummary\CredentialSummary[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + */ + public function getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId); + /** + * + * Get all Public Key summaries for user in a Gateway + * + * @param CredStoreToken + * Credential Store Token which you want to find the Public Key for. + * + * @param gatewayId + * This is the unique identifier of your gateway where the token and public key was generated from. + * + * @param userId + * This is the unique identifier of user whose public keys are to be fetched. + * + * @return CredentialSummary + * + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $gatewayId + * @param string $userId + * @return \Airavata\Model\AppCatalog\CredetialSummary\CredentialSummary[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + */ + public function getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId); + /** * @param \Airavata\Model\Security\AuthzToken $authzToken * @param string $gatewayId * @return array @@ -3229,12 +3306,428 @@ interface AiravataIf { */ public function deleteGatewayStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $storageId); /** - * Delete the Storage Resource Preference of a registered gateway profile. + * Register User Resource Profile. + * + * @param UserResourceProfile + * User Resource Profile Object. + * The userId should be obtained from Airavata user profile data model and passed to register a corresponding + * resource profile. + * + * @return status + * Returns a success/failure of the update. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile + * @return string + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile); + /** + * Fetch the given User Resource Profile. + * + * @param userId + * The identifier for the requested user resource profile. * * @param gatewayID - * The identifier of the gateway profile to be deleted. + * The identifier to link a gateway for the requested user resource profile. * - * @param storageId + * @return UserResourceProfile + * User Resource Profile Object. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile User Resource Profile + * + * userId: + * Unique identifier used to link user to corresponding user data model + * + * gatewayID: + * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration. + * + * credentialStoreToken: + * Gateway's defualt credential store token. + * + * computeResourcePreferences: + * List of resource preferences for each of the registered compute resources. + * + * identityServerTenant: + * + * identityServerPwdCredToken: + * + * isNull: + * Indicates that this instance is just a container for a null value. + * + * + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID); + /** + * Update a User Resource Profile. + * + * @param userId + * The identifier for the requested user resource to be updated. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param UserResourceProfile + * User Resource Profile Object. + * + * @return status + * Returns a success/failure of the update. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile); + /** + * Delete the given User Resource Profile. + * + * @param userId + * The identifier for the requested user resource to be deleted. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @return status + * Returns a success/failure of the deletion. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID); + /** + * Add a Compute Resource Preference to a registered User profile. + * + * @param userId + * The identifier for the User resource profile to be added. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param computeResourceId + * Preferences related to a particular compute resource + * + * @param computeResourcePreference + * The ComputeResourcePreference object to be added to the resource profile. + * + * @return status + * Returns a success/failure of the addition. If a profile already exists, this operation will fail. + * Instead an update should be used. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userComputeResourceId + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference); + /** + * Add a Storage Resource Preference to a registered user resource profile. + * + * @param userId + * The identifier of the user resource profile to be added. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param storageResourceId + * Preferences related to a particular compute resource + * + * @param computeResourcePreference + * The ComputeResourcePreference object to be added to the resource profile. + * + * @return status + * Returns a success/failure of the addition. If a profile already exists, this operation will fail. + * Instead an update should be used. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userStorageResourceId + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference); + /** + * + * Fetch a Compute Resource Preference of a registered user resource profile. + * + * @param userId + * The identifier for the user profile to be requested + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userComputeResourceId + * Preferences related to a particular compute resource + * + * @return computeResourcePreference + * Returns the ComputeResourcePreference object. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userComputeResourceId + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference User specific preferences for a Computer Resource + * + * computeResourceId: + * Corelate the preference to a compute resource. + * + * + * loginUserName: + * If turned true, Airavata will override the preferences of better alternatives exist. + * + * + * preferredBatchQueue: + * Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics. + * + * scratchLocation: + * Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution. + * + * allocationProjectNumber: + * Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an + * allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the + * account to be used has to be added to the allocation. + * + * resourceSpecificCredentialStoreToken: + * Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's + * default credential store. + * + * + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId); + /** + * + * Fetch a Storage Resource Preference of a registered user resource profile. + * + * @param userId + * The identifier of the user resource profile to request to fetch the particular storage resource preference. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userStorageResourceId + * Identifier of the Stprage Preference required to be fetched. + * + * @return UserStoragePreference + * Returns the StoragePreference object. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userStorageResourceId + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId); + /** + * + * Fetch all Compute Resource Preferences of a registered gateway profile. + * + * @param userId + * The identifier of the user resource profile to request to fetch the particular storage resource preference. + * + * @param gatewayID + * The identifier for the gateway profile to be requested + * + * @return computeResourcePreference + * Returns the ComputeResourcePreference object. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID); + /** + * Fetch all User Storage Resource Preferences of a registered user profile. + * + * @param userId + * The identifier of the user resource profile to request to fetch the particular storage resource preference. + * + * @param gatewayID + * The identifier for the gateway profile to be requested + * + * @return StoragePreference + * Returns the StoragePreference object. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID); + /** + * + * Fetch all user resources Profiles registered + * + * @return UserResourceProfile + * Returns all the UserResourcePrifle list object. + * + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken); + /** + * Update a Compute Resource Preference to a registered user resource profile. + * + * @param userId + * The identifier for the user profile to be updated. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userComputeResourceId + * Preferences related to a particular compute resource + * + * @param userComputeResourcePreference + * The ComputeResourcePreference object to be updated to the resource profile. + * + * @return status + * Returns a success/failure of the updation. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userComputeResourceId + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference); + /** + * Update a Storage Resource Preference of a registered user resource profile. + * + * @param userId + * The identifier of the user resource profile to be updated. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userStorageId + * The Storage resource identifier of the one that you want to update + * + * @param userStoragePreference + * The storagePreference object to be updated to the resource profile. + * + * @return status + * Returns a success/failure of the updation. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userStorageId + * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference); + /** + * Delete the Compute Resource Preference of a registered user resource profile. + * + * @param userId + * The identifier for the user resource profile to be deleted. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userComputeResourceId + * Preferences related to a particular compute resource + * + * @return status + * Returns a success/failure of the deletion. + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userComputeResourceId + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId); + /** + * Delete the Storage Resource Preference of a registered user resource profile. + * + * @param userId + * The identifier of the user profile to be deleted. + * + * @param gatewayID + * The identifier to link a gateway for the requested user resource profile. + * + * @param userStorageId * ID of the storage preference you want to delete. * * @return status @@ -3242,6 +3735,18 @@ interface AiravataIf { * * * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $userId + * @param string $gatewayID + * @param string $userStorageId + * @return bool + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId); + /** + * @param \Airavata\Model\Security\AuthzToken $authzToken * @param string $gatewayId * @return string[] * @throws \Airavata\API\Error\InvalidRequestException @@ -4432,6 +4937,69 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("generateAndRegisterSSHKeys failed: unknown result"); } + public function generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description) + { + $this->send_generateAndRegisterSSHKeysWithDescription($authzToken, $gatewayId, $userName, $description); + return $this->recv_generateAndRegisterSSHKeysWithDescription(); + } + + public function send_generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description) + { + $args = new \Airavata\API\Airavata_generateAndRegisterSSHKeysWithDescription_args(); + $args->authzToken = $authzToken; + $args->gatewayId = $gatewayId; + $args->userName = $userName; + $args->description = $description; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'generateAndRegisterSSHKeysWithDescription', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('generateAndRegisterSSHKeysWithDescription', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_generateAndRegisterSSHKeysWithDescription() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_generateAndRegisterSSHKeysWithDescription_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new \Airavata\API\Airavata_generateAndRegisterSSHKeysWithDescription_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->success !== null) { + 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 \Exception("generateAndRegisterSSHKeysWithDescription failed: unknown result"); + } + public function registerPwdCredential(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $portalUserName, $loginUserName, $password, $description) { $this->send_registerPwdCredential($authzToken, $gatewayId, $portalUserName, $loginUserName, $password, $description); @@ -4620,6 +5188,129 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("getAllGatewaySSHPubKeys failed: unknown result"); } + public function getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + { + $this->send_getAllGatewaySSHPubKeysSummary($authzToken, $gatewayId); + return $this->recv_getAllGatewaySSHPubKeysSummary(); + } + + public function send_getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + { + $args = new \Airavata\API\Airavata_getAllGatewaySSHPubKeysSummary_args(); + $args->authzToken = $authzToken; + $args->gatewayId = $gatewayId; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'getAllGatewaySSHPubKeysSummary', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('getAllGatewaySSHPubKeysSummary', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_getAllGatewaySSHPubKeysSummary() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllGatewaySSHPubKeysSummary_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new \Airavata\API\Airavata_getAllGatewaySSHPubKeysSummary_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->success !== null) { + 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 \Exception("getAllGatewaySSHPubKeysSummary failed: unknown result"); + } + + public function getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId) + { + $this->send_getAllSSHPubKeysSummaryForUserInGateway($authzToken, $gatewayId, $userId); + return $this->recv_getAllSSHPubKeysSummaryForUserInGateway(); + } + + public function send_getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId) + { + $args = new \Airavata\API\Airavata_getAllSSHPubKeysSummaryForUserInGateway_args(); + $args->authzToken = $authzToken; + $args->gatewayId = $gatewayId; + $args->userId = $userId; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'getAllSSHPubKeysSummaryForUserInGateway', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('getAllSSHPubKeysSummaryForUserInGateway', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_getAllSSHPubKeysSummaryForUserInGateway() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllSSHPubKeysSummaryForUserInGateway_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new \Airavata\API\Airavata_getAllSSHPubKeysSummaryForUserInGateway_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->success !== null) { + 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 \Exception("getAllSSHPubKeysSummaryForUserInGateway failed: unknown result"); + } + public function getAllGatewayPWDCredentials(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) { $this->send_getAllGatewayPWDCredentials($authzToken, $gatewayId); @@ -11813,35 +12504,35 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("deleteGatewayStoragePreference failed: unknown result"); } - public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + public function registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile) { - $this->send_getAllWorkflows($authzToken, $gatewayId); - return $this->recv_getAllWorkflows(); + $this->send_registerUserResourceProfile($authzToken, $userResourceProfile); + return $this->recv_registerUserResourceProfile(); } - public function send_getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + public function send_registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile) { - $args = new \Airavata\API\Airavata_getAllWorkflows_args(); + $args = new \Airavata\API\Airavata_registerUserResourceProfile_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; + $args->userResourceProfile = $userResourceProfile; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getAllWorkflows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'registerUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getAllWorkflows', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('registerUserResourceProfile', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getAllWorkflows() + public function recv_registerUserResourceProfile() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllWorkflows_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerUserResourceProfile_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -11855,7 +12546,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getAllWorkflows_result(); + $result = new \Airavata\API\Airavata_registerUserResourceProfile_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -11874,38 +12565,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getAllWorkflows failed: unknown result"); + throw new \Exception("registerUserResourceProfile failed: unknown result"); } - public function getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) + public function getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $this->send_getWorkflow($authzToken, $workflowTemplateId); - return $this->recv_getWorkflow(); + $this->send_getUserResourceProfile($authzToken, $userId, $gatewayID); + return $this->recv_getUserResourceProfile(); } - public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) + public function send_getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $args = new \Airavata\API\Airavata_getWorkflow_args(); + $args = new \Airavata\API\Airavata_getUserResourceProfile_args(); $args->authzToken = $authzToken; - $args->workflowTemplateId = $workflowTemplateId; + $args->userId = $userId; + $args->gatewayID = $gatewayID; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getWorkflow', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getUserResourceProfile', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getWorkflow() + public function recv_getUserResourceProfile() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflow_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserResourceProfile_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -11919,7 +12611,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getWorkflow_result(); + $result = new \Airavata\API\Airavata_getUserResourceProfile_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -11938,38 +12630,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getWorkflow failed: unknown result"); + throw new \Exception("getUserResourceProfile failed: unknown result"); } - public function deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) + public function updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile) { - $this->send_deleteWorkflow($authzToken, $workflowTemplateId); - $this->recv_deleteWorkflow(); + $this->send_updateUserResourceProfile($authzToken, $userId, $gatewayID, $userResourceProfile); + return $this->recv_updateUserResourceProfile(); } - public function send_deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) + public function send_updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile) { - $args = new \Airavata\API\Airavata_deleteWorkflow_args(); + $args = new \Airavata\API\Airavata_updateUserResourceProfile_args(); $args->authzToken = $authzToken; - $args->workflowTemplateId = $workflowTemplateId; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userResourceProfile = $userResourceProfile; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'deleteWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('deleteWorkflow', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateUserResourceProfile', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_deleteWorkflow() + public function recv_updateUserResourceProfile() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteWorkflow_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserResourceProfile_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -11983,10 +12677,13 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_deleteWorkflow_result(); + $result = new \Airavata\API\Airavata_updateUserResourceProfile_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } + if ($result->success !== null) { + return $result->success; + } if ($result->ire !== null) { throw $result->ire; } @@ -11999,39 +12696,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - return; + throw new \Exception("updateUserResourceProfile failed: unknown result"); } - public function registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow) + public function deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $this->send_registerWorkflow($authzToken, $gatewayId, $workflow); - return $this->recv_registerWorkflow(); + $this->send_deleteUserResourceProfile($authzToken, $userId, $gatewayID); + return $this->recv_deleteUserResourceProfile(); } - public function send_registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow) + public function send_deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $args = new \Airavata\API\Airavata_registerWorkflow_args(); + $args = new \Airavata\API\Airavata_deleteUserResourceProfile_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->workflow = $workflow; + $args->userId = $userId; + $args->gatewayID = $gatewayID; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'registerWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'deleteUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('registerWorkflow', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('deleteUserResourceProfile', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_registerWorkflow() + public function recv_deleteUserResourceProfile() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerWorkflow_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserResourceProfile_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12045,7 +12742,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_registerWorkflow_result(); + $result = new \Airavata\API\Airavata_deleteUserResourceProfile_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12064,39 +12761,41 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("registerWorkflow failed: unknown result"); + throw new \Exception("deleteUserResourceProfile failed: unknown result"); } - public function updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow) + public function addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference) { - $this->send_updateWorkflow($authzToken, $workflowTemplateId, $workflow); - $this->recv_updateWorkflow(); + $this->send_addUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId, $userComputeResourcePreference); + return $this->recv_addUserComputeResourcePreference(); } - public function send_updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow) + public function send_addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference) { - $args = new \Airavata\API\Airavata_updateWorkflow_args(); + $args = new \Airavata\API\Airavata_addUserComputeResourcePreference_args(); $args->authzToken = $authzToken; - $args->workflowTemplateId = $workflowTemplateId; - $args->workflow = $workflow; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userComputeResourceId = $userComputeResourceId; + $args->userComputeResourcePreference = $userComputeResourcePreference; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'updateWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'addUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('updateWorkflow', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('addUserComputeResourcePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_updateWorkflow() + public function recv_addUserComputeResourcePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateWorkflow_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_addUserComputeResourcePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12110,10 +12809,13 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_updateWorkflow_result(); + $result = new \Airavata\API\Airavata_addUserComputeResourcePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } + if ($result->success !== null) { + return $result->success; + } if ($result->ire !== null) { throw $result->ire; } @@ -12126,38 +12828,41 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - return; + throw new \Exception("addUserComputeResourcePreference failed: unknown result"); } - public function getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName) + public function addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference) { - $this->send_getWorkflowTemplateId($authzToken, $workflowName); - return $this->recv_getWorkflowTemplateId(); + $this->send_addUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageResourceId, $userStoragePreference); + return $this->recv_addUserStoragePreference(); } - public function send_getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName) + public function send_addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference) { - $args = new \Airavata\API\Airavata_getWorkflowTemplateId_args(); + $args = new \Airavata\API\Airavata_addUserStoragePreference_args(); $args->authzToken = $authzToken; - $args->workflowName = $workflowName; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userStorageResourceId = $userStorageResourceId; + $args->userStoragePreference = $userStoragePreference; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getWorkflowTemplateId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'addUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getWorkflowTemplateId', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('addUserStoragePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getWorkflowTemplateId() + public function recv_addUserStoragePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflowTemplateId_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_addUserStoragePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12171,7 +12876,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getWorkflowTemplateId_result(); + $result = new \Airavata\API\Airavata_addUserStoragePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12190,38 +12895,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getWorkflowTemplateId failed: unknown result"); + throw new \Exception("addUserStoragePreference failed: unknown result"); } - public function isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName) + public function getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId) { - $this->send_isWorkflowExistWithName($authzToken, $workflowName); - return $this->recv_isWorkflowExistWithName(); + $this->send_getUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId); + return $this->recv_getUserComputeResourcePreference(); } - public function send_isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName) + public function send_getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId) { - $args = new \Airavata\API\Airavata_isWorkflowExistWithName_args(); + $args = new \Airavata\API\Airavata_getUserComputeResourcePreference_args(); $args->authzToken = $authzToken; - $args->workflowName = $workflowName; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userComputeResourceId = $userComputeResourceId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'isWorkflowExistWithName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('isWorkflowExistWithName', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getUserComputeResourcePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_isWorkflowExistWithName() + public function recv_getUserComputeResourcePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_isWorkflowExistWithName_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserComputeResourcePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12235,7 +12942,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_isWorkflowExistWithName_result(); + $result = new \Airavata\API\Airavata_getUserComputeResourcePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12254,38 +12961,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("isWorkflowExistWithName failed: unknown result"); + throw new \Exception("getUserComputeResourcePreference failed: unknown result"); } - public function registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel) + public function getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId) { - $this->send_registerDataProduct($authzToken, $dataProductModel); - return $this->recv_registerDataProduct(); + $this->send_getUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageResourceId); + return $this->recv_getUserStoragePreference(); } - public function send_registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel) + public function send_getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId) { - $args = new \Airavata\API\Airavata_registerDataProduct_args(); + $args = new \Airavata\API\Airavata_getUserStoragePreference_args(); $args->authzToken = $authzToken; - $args->dataProductModel = $dataProductModel; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userStorageResourceId = $userStorageResourceId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'registerDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('registerDataProduct', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getUserStoragePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_registerDataProduct() + public function recv_getUserStoragePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerDataProduct_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserStoragePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12299,7 +13008,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_registerDataProduct_result(); + $result = new \Airavata\API\Airavata_getUserStoragePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12318,38 +13027,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("registerDataProduct failed: unknown result"); + throw new \Exception("getUserStoragePreference failed: unknown result"); } - public function getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri) + public function getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $this->send_getDataProduct($authzToken, $dataProductUri); - return $this->recv_getDataProduct(); + $this->send_getAllUserComputeResourcePreferences($authzToken, $userId, $gatewayID); + return $this->recv_getAllUserComputeResourcePreferences(); } - public function send_getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri) + public function send_getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $args = new \Airavata\API\Airavata_getDataProduct_args(); + $args = new \Airavata\API\Airavata_getAllUserComputeResourcePreferences_args(); $args->authzToken = $authzToken; - $args->dataProductUri = $dataProductUri; + $args->userId = $userId; + $args->gatewayID = $gatewayID; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getAllUserComputeResourcePreferences', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getDataProduct', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getAllUserComputeResourcePreferences', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getDataProduct() + public function recv_getAllUserComputeResourcePreferences() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getDataProduct_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllUserComputeResourcePreferences_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12363,7 +13073,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getDataProduct_result(); + $result = new \Airavata\API\Airavata_getAllUserComputeResourcePreferences_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12382,38 +13092,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getDataProduct failed: unknown result"); + throw new \Exception("getAllUserComputeResourcePreferences failed: unknown result"); } - public function registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel) + public function getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $this->send_registerReplicaLocation($authzToken, $replicaLocationModel); - return $this->recv_registerReplicaLocation(); + $this->send_getAllUserStoragePreferences($authzToken, $userId, $gatewayID); + return $this->recv_getAllUserStoragePreferences(); } - public function send_registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel) + public function send_getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID) { - $args = new \Airavata\API\Airavata_registerReplicaLocation_args(); + $args = new \Airavata\API\Airavata_getAllUserStoragePreferences_args(); $args->authzToken = $authzToken; - $args->replicaLocationModel = $replicaLocationModel; + $args->userId = $userId; + $args->gatewayID = $gatewayID; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'registerReplicaLocation', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getAllUserStoragePreferences', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('registerReplicaLocation', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getAllUserStoragePreferences', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_registerReplicaLocation() + public function recv_getAllUserStoragePreferences() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerReplicaLocation_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllUserStoragePreferences_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12427,7 +13138,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_registerReplicaLocation_result(); + $result = new \Airavata\API\Airavata_getAllUserStoragePreferences_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12446,38 +13157,37 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("registerReplicaLocation failed: unknown result"); + throw new \Exception("getAllUserStoragePreferences failed: unknown result"); } - public function getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri) + public function getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken) { - $this->send_getParentDataProduct($authzToken, $productUri); - return $this->recv_getParentDataProduct(); + $this->send_getAllUserResourceProfiles($authzToken); + return $this->recv_getAllUserResourceProfiles(); } - public function send_getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri) + public function send_getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken) { - $args = new \Airavata\API\Airavata_getParentDataProduct_args(); + $args = new \Airavata\API\Airavata_getAllUserResourceProfiles_args(); $args->authzToken = $authzToken; - $args->productUri = $productUri; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getParentDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getAllUserResourceProfiles', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getParentDataProduct', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getAllUserResourceProfiles', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getParentDataProduct() + public function recv_getAllUserResourceProfiles() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getParentDataProduct_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllUserResourceProfiles_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12491,7 +13201,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getParentDataProduct_result(); + $result = new \Airavata\API\Airavata_getAllUserResourceProfiles_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12510,38 +13220,41 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getParentDataProduct failed: unknown result"); + throw new \Exception("getAllUserResourceProfiles failed: unknown result"); } - public function getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri) + public function updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference) { - $this->send_getChildDataProducts($authzToken, $productUri); - return $this->recv_getChildDataProducts(); + $this->send_updateUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId, $userComputeResourcePreference); + return $this->recv_updateUserComputeResourcePreference(); } - public function send_getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri) + public function send_updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference) { - $args = new \Airavata\API\Airavata_getChildDataProducts_args(); + $args = new \Airavata\API\Airavata_updateUserComputeResourcePreference_args(); $args->authzToken = $authzToken; - $args->productUri = $productUri; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userComputeResourceId = $userComputeResourceId; + $args->userComputeResourcePreference = $userComputeResourcePreference; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getChildDataProducts', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getChildDataProducts', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateUserComputeResourcePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getChildDataProducts() + public function recv_updateUserComputeResourcePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getChildDataProducts_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserComputeResourcePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12555,7 +13268,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getChildDataProducts_result(); + $result = new \Airavata\API\Airavata_updateUserComputeResourcePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12574,40 +13287,41 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getChildDataProducts failed: unknown result"); + throw new \Exception("updateUserComputeResourcePreference failed: unknown result"); } - public function shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList) + public function updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference) { - $this->send_shareResourceWithUsers($authzToken, $resourceId, $resourceType, $userPermissionList); - return $this->recv_shareResourceWithUsers(); + $this->send_updateUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageId, $userStoragePreference); + return $this->recv_updateUserStoragePreference(); } - public function send_shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList) + public function send_updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference) { - $args = new \Airavata\API\Airavata_shareResourceWithUsers_args(); + $args = new \Airavata\API\Airavata_updateUserStoragePreference_args(); $args->authzToken = $authzToken; - $args->resourceId = $resourceId; - $args->resourceType = $resourceType; - $args->userPermissionList = $userPermissionList; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userStorageId = $userStorageId; + $args->userStoragePreference = $userStoragePreference; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'shareResourceWithUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('shareResourceWithUsers', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateUserStoragePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_shareResourceWithUsers() + public function recv_updateUserStoragePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_shareResourceWithUsers_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserStoragePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12621,7 +13335,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_shareResourceWithUsers_result(); + $result = new \Airavata\API\Airavata_updateUserStoragePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12640,40 +13354,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("shareResourceWithUsers failed: unknown result"); + throw new \Exception("updateUserStoragePreference failed: unknown result"); } - public function revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList) + public function deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId) { - $this->send_revokeSharingOfResourceFromUsers($authzToken, $resourceId, $resourceType, $userPermissionList); - return $this->recv_revokeSharingOfResourceFromUsers(); + $this->send_deleteUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId); + return $this->recv_deleteUserComputeResourcePreference(); } - public function send_revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList) + public function send_deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId) { - $args = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_args(); + $args = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_args(); $args->authzToken = $authzToken; - $args->resourceId = $resourceId; - $args->resourceType = $resourceType; - $args->userPermissionList = $userPermissionList; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userComputeResourceId = $userComputeResourceId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'revokeSharingOfResourceFromUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'deleteUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('revokeSharingOfResourceFromUsers', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('deleteUserComputeResourcePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_revokeSharingOfResourceFromUsers() + public function recv_deleteUserComputeResourcePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_revokeSharingOfResourceFromUsers_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserComputeResourcePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12687,7 +13401,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_result(); + $result = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12706,40 +13420,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("revokeSharingOfResourceFromUsers failed: unknown result"); + throw new \Exception("deleteUserComputeResourcePreference failed: unknown result"); } - public function getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType) + public function deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId) { - $this->send_getAllAccessibleUsers($authzToken, $resourceId, $resourceType, $permissionType); - return $this->recv_getAllAccessibleUsers(); + $this->send_deleteUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageId); + return $this->recv_deleteUserStoragePreference(); } - public function send_getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType) + public function send_deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId) { - $args = new \Airavata\API\Airavata_getAllAccessibleUsers_args(); + $args = new \Airavata\API\Airavata_deleteUserStoragePreference_args(); $args->authzToken = $authzToken; - $args->resourceId = $resourceId; - $args->resourceType = $resourceType; - $args->permissionType = $permissionType; + $args->userId = $userId; + $args->gatewayID = $gatewayID; + $args->userStorageId = $userStorageId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getAllAccessibleUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'deleteUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getAllAccessibleUsers', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('deleteUserStoragePreference', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getAllAccessibleUsers() + public function recv_deleteUserStoragePreference() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllAccessibleUsers_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserStoragePreference_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12753,7 +13467,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getAllAccessibleUsers_result(); + $result = new \Airavata\API\Airavata_deleteUserStoragePreference_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12772,38 +13486,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getAllAccessibleUsers failed: unknown result"); + throw new \Exception("deleteUserStoragePreference failed: unknown result"); } - public function createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel) + public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) { - $this->send_createGroup($authzToken, $groupModel); - return $this->recv_createGroup(); + $this->send_getAllWorkflows($authzToken, $gatewayId); + return $this->recv_getAllWorkflows(); } - public function send_createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel) + public function send_getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) { - $args = new \Airavata\API\Airavata_createGroup_args(); + $args = new \Airavata\API\Airavata_getAllWorkflows_args(); $args->authzToken = $authzToken; - $args->groupModel = $groupModel; + $args->gatewayId = $gatewayId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'createGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getAllWorkflows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('createGroup', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getAllWorkflows', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_createGroup() + public function recv_getAllWorkflows() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_createGroup_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllWorkflows_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12817,7 +13531,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_createGroup_result(); + $result = new \Airavata\API\Airavata_getAllWorkflows_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12836,38 +13550,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("createGroup failed: unknown result"); + throw new \Exception("getAllWorkflows failed: unknown result"); } - public function updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel) + public function getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) { - $this->send_updateGroup($authzToken, $groupModel); - return $this->recv_updateGroup(); + $this->send_getWorkflow($authzToken, $workflowTemplateId); + return $this->recv_getWorkflow(); } - public function send_updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel) + public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) { - $args = new \Airavata\API\Airavata_updateGroup_args(); + $args = new \Airavata\API\Airavata_getWorkflow_args(); $args->authzToken = $authzToken; - $args->groupModel = $groupModel; + $args->workflowTemplateId = $workflowTemplateId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'updateGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('updateGroup', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getWorkflow', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_updateGroup() + public function recv_getWorkflow() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateGroup_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflow_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -12881,7 +13595,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_updateGroup_result(); + $result = new \Airavata\API\Airavata_getWorkflow_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -12900,40 +13614,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("updateGroup failed: unknown result"); + throw new \Exception("getWorkflow failed: unknown result"); } - public function deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId) + public function deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) { - $this->send_deleteGroup($authzToken, $groupId, $ownerId, $gatewayId); - return $this->recv_deleteGroup(); + $this->send_deleteWorkflow($authzToken, $workflowTemplateId); + $this->recv_deleteWorkflow(); } - public function send_deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId) + public function send_deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId) { - $args = new \Airavata\API\Airavata_deleteGroup_args(); + $args = new \Airavata\API\Airavata_deleteWorkflow_args(); $args->authzToken = $authzToken; - $args->groupId = $groupId; - $args->ownerId = $ownerId; - $args->gatewayId = $gatewayId; + $args->workflowTemplateId = $workflowTemplateId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protoco
<TRUNCATED>
