Regenerated thrift stubs
diff --git a/app/libraries/Airavata/API/Sharing/Types.php b/app/libraries/Airavata/API/Sharing/Types.php
index 050b73e..054d28e 100644
--- a/app/libraries/Airavata/API/Sharing/Types.php
+++ b/app/libraries/Airavata/API/Sharing/Types.php
@@ -17,4 +17,12 @@
use Thrift\Exception\TApplicationException;
+final class Constant extends \Thrift\Type\TConstant {
+ static protected $SHARING_CPI_VERSION;
+
+ static protected function init_SHARING_CPI_VERSION() {
+ return "0.18.0";
+ }
+}
+
diff --git a/app/libraries/Airavata/API/Types.php b/app/libraries/Airavata/API/Types.php
index f1235c6..71ca620 100644
--- a/app/libraries/Airavata/API/Types.php
+++ b/app/libraries/Airavata/API/Types.php
@@ -35,7 +35,7 @@
* in a change to major/minor version numbers.
*
*/
-"0.17.0";
+"0.18.0";
}
}
diff --git a/app/libraries/Airavata/Base/API/BaseAPI.php b/app/libraries/Airavata/Base/API/BaseAPI.php
new file mode 100644
index 0000000..c720897
--- /dev/null
+++ b/app/libraries/Airavata/Base/API/BaseAPI.php
@@ -0,0 +1,218 @@
+<?php
+namespace Airavata\Base\API;
+/**
+ * Autogenerated by Thrift Compiler (0.10.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
+use Thrift\Exception\TApplicationException;
+
+
+interface BaseAPIIf {
+ /**
+ * @return string
+ */
+ public function getAPIVersion();
+}
+
+
+class BaseAPIClient implements \Airavata\Base\API\BaseAPIIf {
+ protected $input_ = null;
+ protected $output_ = null;
+
+ protected $seqid_ = 0;
+
+ public function __construct($input, $output=null) {
+ $this->input_ = $input;
+ $this->output_ = $output ? $output : $input;
+ }
+
+ public function getAPIVersion()
+ {
+ $this->send_getAPIVersion();
+ return $this->recv_getAPIVersion();
+ }
+
+ public function send_getAPIVersion()
+ {
+ $args = new \Airavata\Base\API\BaseAPI_getAPIVersion_args();
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAPIVersion', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAPIVersion', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAPIVersion()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Base\API\BaseAPI_getAPIVersion_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\Base\API\BaseAPI_getAPIVersion_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ throw new \Exception("getAPIVersion failed: unknown result");
+ }
+
+}
+
+
+// HELPER FUNCTIONS AND STRUCTURES
+
+class BaseAPI_getAPIVersion_args {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'BaseAPI_getAPIVersion_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('BaseAPI_getAPIVersion_args');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class BaseAPI_getAPIVersion_result {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $success = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'BaseAPI_getAPIVersion_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('BaseAPI_getAPIVersion_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+
diff --git a/app/libraries/Airavata/Base/API/Types.php b/app/libraries/Airavata/Base/API/Types.php
new file mode 100644
index 0000000..86d6757
--- /dev/null
+++ b/app/libraries/Airavata/Base/API/Types.php
@@ -0,0 +1,20 @@
+<?php
+namespace Airavata\Base\API;
+
+/**
+ * Autogenerated by Thrift Compiler (0.10.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
+use Thrift\Exception\TApplicationException;
+
+
+
diff --git a/app/libraries/Airavata/Model/AppCatalog/GroupResourceProfile/Types.php b/app/libraries/Airavata/Model/AppCatalog/GroupResourceProfile/Types.php
index 072d787..50364a5 100644
--- a/app/libraries/Airavata/Model/AppCatalog/GroupResourceProfile/Types.php
+++ b/app/libraries/Airavata/Model/AppCatalog/GroupResourceProfile/Types.php
@@ -1055,6 +1055,8 @@
* batchQueueResourcePolicies:
* List of enforced policies on registered batch queues
*
+ * defaultCredentialStoreToken:
+ * The default credential store token to use for compute resources that don't specify a resource specific credential store token.
*
*/
class GroupResourceProfile {
@@ -1092,6 +1094,10 @@
* @var int
*/
public $updatedTime = null;
+ /**
+ * @var string
+ */
+ public $defaultCredentialStoreToken = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -1143,6 +1149,10 @@
'var' => 'updatedTime',
'type' => TType::I64,
),
+ 9 => array(
+ 'var' => 'defaultCredentialStoreToken',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -1170,6 +1180,9 @@
if (isset($vals['updatedTime'])) {
$this->updatedTime = $vals['updatedTime'];
}
+ if (isset($vals['defaultCredentialStoreToken'])) {
+ $this->defaultCredentialStoreToken = $vals['defaultCredentialStoreToken'];
+ }
}
}
@@ -1281,6 +1294,13 @@
$xfer += $input->skip($ftype);
}
break;
+ case 9:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->defaultCredentialStoreToken);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -1370,6 +1390,11 @@
$xfer += $output->writeI64($this->updatedTime);
$xfer += $output->writeFieldEnd();
}
+ if ($this->defaultCredentialStoreToken !== null) {
+ $xfer += $output->writeFieldBegin('defaultCredentialStoreToken', TType::STRING, 9);
+ $xfer += $output->writeString($this->defaultCredentialStoreToken);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
diff --git a/app/libraries/Airavata/Model/AppCatalog/Parser/Types.php b/app/libraries/Airavata/Model/AppCatalog/Parser/Types.php
new file mode 100644
index 0000000..33ff6fe
--- /dev/null
+++ b/app/libraries/Airavata/Model/AppCatalog/Parser/Types.php
@@ -0,0 +1,1407 @@
+<?php
+namespace Airavata\Model\AppCatalog\Parser;
+
+/**
+ * Autogenerated by Thrift Compiler (0.10.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
+use Thrift\Exception\TApplicationException;
+
+
+final class IOType {
+ const FILE = 0;
+ const PROPERTY = 1;
+ static public $__names = array(
+ 0 => 'FILE',
+ 1 => 'PROPERTY',
+ );
+}
+
+class ParserInput {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $name = null;
+ /**
+ * @var bool
+ */
+ public $requiredInput = null;
+ /**
+ * @var string
+ */
+ public $parserId = null;
+ /**
+ * @var int
+ */
+ public $type = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'name',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'requiredInput',
+ 'type' => TType::BOOL,
+ ),
+ 4 => array(
+ 'var' => 'parserId',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'type',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['name'])) {
+ $this->name = $vals['name'];
+ }
+ if (isset($vals['requiredInput'])) {
+ $this->requiredInput = $vals['requiredInput'];
+ }
+ if (isset($vals['parserId'])) {
+ $this->parserId = $vals['parserId'];
+ }
+ if (isset($vals['type'])) {
+ $this->type = $vals['type'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParserInput';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->name);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->requiredInput);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parserId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->type);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParserInput');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->name !== null) {
+ $xfer += $output->writeFieldBegin('name', TType::STRING, 2);
+ $xfer += $output->writeString($this->name);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->requiredInput !== null) {
+ $xfer += $output->writeFieldBegin('requiredInput', TType::BOOL, 3);
+ $xfer += $output->writeBool($this->requiredInput);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parserId !== null) {
+ $xfer += $output->writeFieldBegin('parserId', TType::STRING, 4);
+ $xfer += $output->writeString($this->parserId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->type !== null) {
+ $xfer += $output->writeFieldBegin('type', TType::I32, 5);
+ $xfer += $output->writeI32($this->type);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ParserOutput {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $name = null;
+ /**
+ * @var bool
+ */
+ public $requiredOutput = null;
+ /**
+ * @var string
+ */
+ public $parserId = null;
+ /**
+ * @var int
+ */
+ public $type = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'name',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'requiredOutput',
+ 'type' => TType::BOOL,
+ ),
+ 4 => array(
+ 'var' => 'parserId',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'type',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['name'])) {
+ $this->name = $vals['name'];
+ }
+ if (isset($vals['requiredOutput'])) {
+ $this->requiredOutput = $vals['requiredOutput'];
+ }
+ if (isset($vals['parserId'])) {
+ $this->parserId = $vals['parserId'];
+ }
+ if (isset($vals['type'])) {
+ $this->type = $vals['type'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParserOutput';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->name);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->requiredOutput);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parserId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->type);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParserOutput');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->name !== null) {
+ $xfer += $output->writeFieldBegin('name', TType::STRING, 2);
+ $xfer += $output->writeString($this->name);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->requiredOutput !== null) {
+ $xfer += $output->writeFieldBegin('requiredOutput', TType::BOOL, 3);
+ $xfer += $output->writeBool($this->requiredOutput);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parserId !== null) {
+ $xfer += $output->writeFieldBegin('parserId', TType::STRING, 4);
+ $xfer += $output->writeString($this->parserId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->type !== null) {
+ $xfer += $output->writeFieldBegin('type', TType::I32, 5);
+ $xfer += $output->writeI32($this->type);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Parser {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $imageName = null;
+ /**
+ * @var string
+ */
+ public $outputDirPath = null;
+ /**
+ * @var string
+ */
+ public $inputDirPath = null;
+ /**
+ * @var string
+ */
+ public $executionCommand = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\Parser\ParserInput[]
+ */
+ public $inputFiles = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\Parser\ParserOutput[]
+ */
+ public $outputFiles = null;
+ /**
+ * @var string
+ */
+ public $gatewayId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'imageName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'outputDirPath',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'inputDirPath',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'executionCommand',
+ 'type' => TType::STRING,
+ ),
+ 6 => array(
+ 'var' => 'inputFiles',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\Parser\ParserInput',
+ ),
+ ),
+ 7 => array(
+ 'var' => 'outputFiles',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\Parser\ParserOutput',
+ ),
+ ),
+ 8 => array(
+ 'var' => 'gatewayId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['imageName'])) {
+ $this->imageName = $vals['imageName'];
+ }
+ if (isset($vals['outputDirPath'])) {
+ $this->outputDirPath = $vals['outputDirPath'];
+ }
+ if (isset($vals['inputDirPath'])) {
+ $this->inputDirPath = $vals['inputDirPath'];
+ }
+ if (isset($vals['executionCommand'])) {
+ $this->executionCommand = $vals['executionCommand'];
+ }
+ if (isset($vals['inputFiles'])) {
+ $this->inputFiles = $vals['inputFiles'];
+ }
+ if (isset($vals['outputFiles'])) {
+ $this->outputFiles = $vals['outputFiles'];
+ }
+ if (isset($vals['gatewayId'])) {
+ $this->gatewayId = $vals['gatewayId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Parser';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->imageName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->outputDirPath);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->inputDirPath);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->executionCommand);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->inputFiles = array();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $elem5 = new \Airavata\Model\AppCatalog\Parser\ParserInput();
+ $xfer += $elem5->read($input);
+ $this->inputFiles []= $elem5;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::LST) {
+ $this->outputFiles = array();
+ $_size6 = 0;
+ $_etype9 = 0;
+ $xfer += $input->readListBegin($_etype9, $_size6);
+ for ($_i10 = 0; $_i10 < $_size6; ++$_i10)
+ {
+ $elem11 = null;
+ $elem11 = new \Airavata\Model\AppCatalog\Parser\ParserOutput();
+ $xfer += $elem11->read($input);
+ $this->outputFiles []= $elem11;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Parser');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->imageName !== null) {
+ $xfer += $output->writeFieldBegin('imageName', TType::STRING, 2);
+ $xfer += $output->writeString($this->imageName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->outputDirPath !== null) {
+ $xfer += $output->writeFieldBegin('outputDirPath', TType::STRING, 3);
+ $xfer += $output->writeString($this->outputDirPath);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->inputDirPath !== null) {
+ $xfer += $output->writeFieldBegin('inputDirPath', TType::STRING, 4);
+ $xfer += $output->writeString($this->inputDirPath);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->executionCommand !== null) {
+ $xfer += $output->writeFieldBegin('executionCommand', TType::STRING, 5);
+ $xfer += $output->writeString($this->executionCommand);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->inputFiles !== null) {
+ if (!is_array($this->inputFiles)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('inputFiles', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->inputFiles));
+ {
+ foreach ($this->inputFiles as $iter12)
+ {
+ $xfer += $iter12->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->outputFiles !== null) {
+ if (!is_array($this->outputFiles)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('outputFiles', TType::LST, 7);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->outputFiles));
+ {
+ foreach ($this->outputFiles as $iter13)
+ {
+ $xfer += $iter13->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayId !== null) {
+ $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 8);
+ $xfer += $output->writeString($this->gatewayId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ParserConnectorInput {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $inputId = null;
+ /**
+ * @var string
+ */
+ public $parentOutputId = null;
+ /**
+ * @var string
+ */
+ public $value = null;
+ /**
+ * @var string
+ */
+ public $parserConnectorId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'inputId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'parentOutputId',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'value',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'parserConnectorId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['inputId'])) {
+ $this->inputId = $vals['inputId'];
+ }
+ if (isset($vals['parentOutputId'])) {
+ $this->parentOutputId = $vals['parentOutputId'];
+ }
+ if (isset($vals['value'])) {
+ $this->value = $vals['value'];
+ }
+ if (isset($vals['parserConnectorId'])) {
+ $this->parserConnectorId = $vals['parserConnectorId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParserConnectorInput';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->inputId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parentOutputId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->value);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parserConnectorId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParserConnectorInput');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->inputId !== null) {
+ $xfer += $output->writeFieldBegin('inputId', TType::STRING, 2);
+ $xfer += $output->writeString($this->inputId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parentOutputId !== null) {
+ $xfer += $output->writeFieldBegin('parentOutputId', TType::STRING, 3);
+ $xfer += $output->writeString($this->parentOutputId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->value !== null) {
+ $xfer += $output->writeFieldBegin('value', TType::STRING, 4);
+ $xfer += $output->writeString($this->value);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parserConnectorId !== null) {
+ $xfer += $output->writeFieldBegin('parserConnectorId', TType::STRING, 5);
+ $xfer += $output->writeString($this->parserConnectorId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ParserConnector {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $parentParserId = null;
+ /**
+ * @var string
+ */
+ public $childParserId = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\Parser\ParserConnectorInput[]
+ */
+ public $connectorInputs = null;
+ /**
+ * @var string
+ */
+ public $parsingTemplateId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'parentParserId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'childParserId',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'connectorInputs',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\Parser\ParserConnectorInput',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'parsingTemplateId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['parentParserId'])) {
+ $this->parentParserId = $vals['parentParserId'];
+ }
+ if (isset($vals['childParserId'])) {
+ $this->childParserId = $vals['childParserId'];
+ }
+ if (isset($vals['connectorInputs'])) {
+ $this->connectorInputs = $vals['connectorInputs'];
+ }
+ if (isset($vals['parsingTemplateId'])) {
+ $this->parsingTemplateId = $vals['parsingTemplateId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParserConnector';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parentParserId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->childParserId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->connectorInputs = array();
+ $_size14 = 0;
+ $_etype17 = 0;
+ $xfer += $input->readListBegin($_etype17, $_size14);
+ for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
+ {
+ $elem19 = null;
+ $elem19 = new \Airavata\Model\AppCatalog\Parser\ParserConnectorInput();
+ $xfer += $elem19->read($input);
+ $this->connectorInputs []= $elem19;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parsingTemplateId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParserConnector');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parentParserId !== null) {
+ $xfer += $output->writeFieldBegin('parentParserId', TType::STRING, 2);
+ $xfer += $output->writeString($this->parentParserId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->childParserId !== null) {
+ $xfer += $output->writeFieldBegin('childParserId', TType::STRING, 3);
+ $xfer += $output->writeString($this->childParserId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->connectorInputs !== null) {
+ if (!is_array($this->connectorInputs)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('connectorInputs', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->connectorInputs));
+ {
+ foreach ($this->connectorInputs as $iter20)
+ {
+ $xfer += $iter20->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parsingTemplateId !== null) {
+ $xfer += $output->writeFieldBegin('parsingTemplateId', TType::STRING, 5);
+ $xfer += $output->writeString($this->parsingTemplateId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ParsingTemplateInput {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $targetInputId = null;
+ /**
+ * @var string
+ */
+ public $applicationOutputName = null;
+ /**
+ * @var string
+ */
+ public $value = null;
+ /**
+ * @var string
+ */
+ public $parsingTemplateId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'targetInputId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'applicationOutputName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'value',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'parsingTemplateId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['targetInputId'])) {
+ $this->targetInputId = $vals['targetInputId'];
+ }
+ if (isset($vals['applicationOutputName'])) {
+ $this->applicationOutputName = $vals['applicationOutputName'];
+ }
+ if (isset($vals['value'])) {
+ $this->value = $vals['value'];
+ }
+ if (isset($vals['parsingTemplateId'])) {
+ $this->parsingTemplateId = $vals['parsingTemplateId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParsingTemplateInput';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->targetInputId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->applicationOutputName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->value);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->parsingTemplateId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParsingTemplateInput');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->targetInputId !== null) {
+ $xfer += $output->writeFieldBegin('targetInputId', TType::STRING, 2);
+ $xfer += $output->writeString($this->targetInputId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationOutputName !== null) {
+ $xfer += $output->writeFieldBegin('applicationOutputName', TType::STRING, 3);
+ $xfer += $output->writeString($this->applicationOutputName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->value !== null) {
+ $xfer += $output->writeFieldBegin('value', TType::STRING, 4);
+ $xfer += $output->writeString($this->value);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parsingTemplateId !== null) {
+ $xfer += $output->writeFieldBegin('parsingTemplateId', TType::STRING, 5);
+ $xfer += $output->writeString($this->parsingTemplateId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ParsingTemplate {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $applicationInterface = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\Parser\ParsingTemplateInput[]
+ */
+ public $initialInputs = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\Parser\ParserConnector[]
+ */
+ public $parserConnections = null;
+ /**
+ * @var string
+ */
+ public $gatewayId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'applicationInterface',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'initialInputs',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\Parser\ParsingTemplateInput',
+ ),
+ ),
+ 4 => array(
+ 'var' => 'parserConnections',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\Parser\ParserConnector',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'gatewayId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['applicationInterface'])) {
+ $this->applicationInterface = $vals['applicationInterface'];
+ }
+ if (isset($vals['initialInputs'])) {
+ $this->initialInputs = $vals['initialInputs'];
+ }
+ if (isset($vals['parserConnections'])) {
+ $this->parserConnections = $vals['parserConnections'];
+ }
+ if (isset($vals['gatewayId'])) {
+ $this->gatewayId = $vals['gatewayId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ParsingTemplate';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->applicationInterface);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->initialInputs = array();
+ $_size21 = 0;
+ $_etype24 = 0;
+ $xfer += $input->readListBegin($_etype24, $_size21);
+ for ($_i25 = 0; $_i25 < $_size21; ++$_i25)
+ {
+ $elem26 = null;
+ $elem26 = new \Airavata\Model\AppCatalog\Parser\ParsingTemplateInput();
+ $xfer += $elem26->read($input);
+ $this->initialInputs []= $elem26;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->parserConnections = array();
+ $_size27 = 0;
+ $_etype30 = 0;
+ $xfer += $input->readListBegin($_etype30, $_size27);
+ for ($_i31 = 0; $_i31 < $_size27; ++$_i31)
+ {
+ $elem32 = null;
+ $elem32 = new \Airavata\Model\AppCatalog\Parser\ParserConnector();
+ $xfer += $elem32->read($input);
+ $this->parserConnections []= $elem32;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ParsingTemplate');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationInterface !== null) {
+ $xfer += $output->writeFieldBegin('applicationInterface', TType::STRING, 2);
+ $xfer += $output->writeString($this->applicationInterface);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->initialInputs !== null) {
+ if (!is_array($this->initialInputs)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('initialInputs', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->initialInputs));
+ {
+ foreach ($this->initialInputs as $iter33)
+ {
+ $xfer += $iter33->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parserConnections !== null) {
+ if (!is_array($this->parserConnections)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('parserConnections', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->parserConnections));
+ {
+ foreach ($this->parserConnections as $iter34)
+ {
+ $xfer += $iter34->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayId !== null) {
+ $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 5);
+ $xfer += $output->writeString($this->gatewayId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+
diff --git a/app/libraries/Airavata/Model/Application/Io/Types.php b/app/libraries/Airavata/Model/Application/Io/Types.php
index c417a5b..fb4977e 100644
--- a/app/libraries/Airavata/Model/Application/Io/Types.php
+++ b/app/libraries/Airavata/Model/Application/Io/Types.php
@@ -490,6 +490,10 @@
* @var string
*/
public $storageResourceId = null;
+ /**
+ * @var string
+ */
+ public $metaData = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -538,6 +542,10 @@
'var' => 'storageResourceId',
'type' => TType::STRING,
),
+ 12 => array(
+ 'var' => 'metaData',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -574,6 +582,9 @@
if (isset($vals['storageResourceId'])) {
$this->storageResourceId = $vals['storageResourceId'];
}
+ if (isset($vals['metaData'])) {
+ $this->metaData = $vals['metaData'];
+ }
}
}
@@ -673,6 +684,13 @@
$xfer += $input->skip($ftype);
}
break;
+ case 12:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->metaData);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -741,6 +759,11 @@
$xfer += $output->writeString($this->storageResourceId);
$xfer += $output->writeFieldEnd();
}
+ if ($this->metaData !== null) {
+ $xfer += $output->writeFieldBegin('metaData', TType::STRING, 12);
+ $xfer += $output->writeString($this->metaData);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
diff --git a/app/libraries/Airavata/Model/Experiment/Types.php b/app/libraries/Airavata/Model/Experiment/Types.php
index 26f9695..56f77cd 100644
--- a/app/libraries/Airavata/Model/Experiment/Types.php
+++ b/app/libraries/Airavata/Model/Experiment/Types.php
@@ -34,6 +34,8 @@
const TO_DATE = 4;
const STATUS = 5;
const PROJECT_ID = 6;
+ const USER_NAME = 7;
+ const JOB_ID = 8;
static public $__names = array(
0 => 'EXPERIMENT_NAME',
1 => 'EXPERIMENT_DESC',
@@ -42,6 +44,8 @@
4 => 'TO_DATE',
5 => 'STATUS',
6 => 'PROJECT_ID',
+ 7 => 'USER_NAME',
+ 8 => 'JOB_ID',
);
}
@@ -464,6 +468,10 @@
* @var \Airavata\Model\Process\ProcessModel[]
*/
public $processes = null;
+ /**
+ * @var \Airavata\Model\Workflow\AiravataWorkflow
+ */
+ public $workflow = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -574,6 +582,11 @@
'class' => '\Airavata\Model\Process\ProcessModel',
),
),
+ 20 => array(
+ 'var' => 'workflow',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\AiravataWorkflow',
+ ),
);
}
if (is_array($vals)) {
@@ -634,6 +647,9 @@
if (isset($vals['processes'])) {
$this->processes = $vals['processes'];
}
+ if (isset($vals['workflow'])) {
+ $this->workflow = $vals['workflow'];
+ }
}
}
@@ -855,6 +871,14 @@
$xfer += $input->skip($ftype);
}
break;
+ case 20:
+ if ($ftype == TType::STRUCT) {
+ $this->workflow = new \Airavata\Model\Workflow\AiravataWorkflow();
+ $xfer += $this->workflow->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -1038,6 +1062,14 @@
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->workflow !== null) {
+ if (!is_object($this->workflow)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('workflow', TType::STRUCT, 20);
+ $xfer += $this->workflow->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
diff --git a/app/libraries/Airavata/Model/Group/Types.php b/app/libraries/Airavata/Model/Group/Types.php
index 0ccb16b..9e17f8a 100644
--- a/app/libraries/Airavata/Model/Group/Types.php
+++ b/app/libraries/Airavata/Model/Group/Types.php
@@ -70,6 +70,12 @@
* @var string[]
*/
public $members = null;
+ /**
+ * Note: each admin must also be a member of the group.
+ *
+ * @var string[]
+ */
+ public $admins = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -98,6 +104,14 @@
'type' => TType::STRING,
),
),
+ 6 => array(
+ 'var' => 'admins',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
);
}
if (is_array($vals)) {
@@ -116,6 +130,9 @@
if (isset($vals['members'])) {
$this->members = $vals['members'];
}
+ if (isset($vals['admins'])) {
+ $this->admins = $vals['admins'];
+ }
}
}
@@ -183,6 +200,23 @@
$xfer += $input->skip($ftype);
}
break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->admins = array();
+ $_size6 = 0;
+ $_etype9 = 0;
+ $xfer += $input->readListBegin($_etype9, $_size6);
+ for ($_i10 = 0; $_i10 < $_size6; ++$_i10)
+ {
+ $elem11 = null;
+ $xfer += $input->readString($elem11);
+ $this->admins []= $elem11;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -224,9 +258,26 @@
{
$output->writeListBegin(TType::STRING, count($this->members));
{
- foreach ($this->members as $iter6)
+ foreach ($this->members as $iter12)
{
- $xfer += $output->writeString($iter6);
+ $xfer += $output->writeString($iter12);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->admins !== null) {
+ if (!is_array($this->admins)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('admins', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRING, count($this->admins));
+ {
+ foreach ($this->admins as $iter13)
+ {
+ $xfer += $output->writeString($iter13);
}
}
$output->writeListEnd();
diff --git a/app/libraries/Airavata/Model/Process/Types.php b/app/libraries/Airavata/Model/Process/Types.php
index c64ed03..555ff92 100644
--- a/app/libraries/Airavata/Model/Process/Types.php
+++ b/app/libraries/Airavata/Model/Process/Types.php
@@ -17,6 +17,150 @@
use Thrift\Exception\TApplicationException;
+class ProcessWorkflow {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $processId = null;
+ /**
+ * @var string
+ */
+ public $workflowId = null;
+ /**
+ * @var int
+ */
+ public $creationTime = null;
+ /**
+ * @var string
+ */
+ public $type = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'processId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'workflowId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'creationTime',
+ 'type' => TType::I64,
+ ),
+ 4 => array(
+ 'var' => 'type',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['processId'])) {
+ $this->processId = $vals['processId'];
+ }
+ if (isset($vals['workflowId'])) {
+ $this->workflowId = $vals['workflowId'];
+ }
+ if (isset($vals['creationTime'])) {
+ $this->creationTime = $vals['creationTime'];
+ }
+ if (isset($vals['type'])) {
+ $this->type = $vals['type'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ProcessWorkflow';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->processId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->workflowId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->creationTime);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->type);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ProcessWorkflow');
+ if ($this->processId !== null) {
+ $xfer += $output->writeFieldBegin('processId', TType::STRING, 1);
+ $xfer += $output->writeString($this->processId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->workflowId !== null) {
+ $xfer += $output->writeFieldBegin('workflowId', TType::STRING, 2);
+ $xfer += $output->writeString($this->workflowId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->creationTime !== null) {
+ $xfer += $output->writeFieldBegin('creationTime', TType::I64, 3);
+ $xfer += $output->writeI64($this->creationTime);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->type !== null) {
+ $xfer += $output->writeFieldBegin('type', TType::STRING, 4);
+ $xfer += $output->writeString($this->type);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
/**
* ProcessModel: A structure holding the process details. The infromation is derived based on user provided
* configuration data or system inferred information from scheduling and QoS parameters.
@@ -129,6 +273,10 @@
* @var string
*/
public $groupResourceProfileId = null;
+ /**
+ * @var \Airavata\Model\Process\ProcessWorkflow[]
+ */
+ public $processWorkflows = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -263,6 +411,15 @@
'var' => 'groupResourceProfileId',
'type' => TType::STRING,
),
+ 26 => array(
+ 'var' => 'processWorkflows',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Process\ProcessWorkflow',
+ ),
+ ),
);
}
if (is_array($vals)) {
@@ -341,6 +498,9 @@
if (isset($vals['groupResourceProfileId'])) {
$this->groupResourceProfileId = $vals['groupResourceProfileId'];
}
+ if (isset($vals['processWorkflows'])) {
+ $this->processWorkflows = $vals['processWorkflows'];
+ }
}
}
@@ -604,6 +764,24 @@
$xfer += $input->skip($ftype);
}
break;
+ case 26:
+ if ($ftype == TType::LST) {
+ $this->processWorkflows = array();
+ $_size36 = 0;
+ $_etype39 = 0;
+ $xfer += $input->readListBegin($_etype39, $_size36);
+ for ($_i40 = 0; $_i40 < $_size36; ++$_i40)
+ {
+ $elem41 = null;
+ $elem41 = new \Airavata\Model\Process\ProcessWorkflow();
+ $xfer += $elem41->read($input);
+ $this->processWorkflows []= $elem41;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -645,9 +823,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->processStatuses));
{
- foreach ($this->processStatuses as $iter36)
+ foreach ($this->processStatuses as $iter42)
{
- $xfer += $iter36->write($output);
+ $xfer += $iter42->write($output);
}
}
$output->writeListEnd();
@@ -682,9 +860,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->processInputs));
{
- foreach ($this->processInputs as $iter37)
+ foreach ($this->processInputs as $iter43)
{
- $xfer += $iter37->write($output);
+ $xfer += $iter43->write($output);
}
}
$output->writeListEnd();
@@ -699,9 +877,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->processOutputs));
{
- foreach ($this->processOutputs as $iter38)
+ foreach ($this->processOutputs as $iter44)
{
- $xfer += $iter38->write($output);
+ $xfer += $iter44->write($output);
}
}
$output->writeListEnd();
@@ -724,9 +902,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->tasks));
{
- foreach ($this->tasks as $iter39)
+ foreach ($this->tasks as $iter45)
{
- $xfer += $iter39->write($output);
+ $xfer += $iter45->write($output);
}
}
$output->writeListEnd();
@@ -746,9 +924,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->processErrors));
{
- foreach ($this->processErrors as $iter40)
+ foreach ($this->processErrors as $iter46)
{
- $xfer += $iter40->write($output);
+ $xfer += $iter46->write($output);
}
}
$output->writeListEnd();
@@ -773,9 +951,9 @@
{
$output->writeListBegin(TType::STRING, count($this->emailAddresses));
{
- foreach ($this->emailAddresses as $iter41)
+ foreach ($this->emailAddresses as $iter47)
{
- $xfer += $output->writeString($iter41);
+ $xfer += $output->writeString($iter47);
}
}
$output->writeListEnd();
@@ -817,6 +995,23 @@
$xfer += $output->writeString($this->groupResourceProfileId);
$xfer += $output->writeFieldEnd();
}
+ if ($this->processWorkflows !== null) {
+ if (!is_array($this->processWorkflows)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('processWorkflows', TType::LST, 26);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->processWorkflows));
+ {
+ foreach ($this->processWorkflows as $iter48)
+ {
+ $xfer += $iter48->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
diff --git a/app/libraries/Airavata/Model/Task/Types.php b/app/libraries/Airavata/Model/Task/Types.php
index 5691abf..a204c2a 100644
--- a/app/libraries/Airavata/Model/Task/Types.php
+++ b/app/libraries/Airavata/Model/Task/Types.php
@@ -108,6 +108,14 @@
* @var \Airavata\Model\Job\JobModel[]
*/
public $jobs = null;
+ /**
+ * @var int
+ */
+ public $maxRetry = null;
+ /**
+ * @var int
+ */
+ public $currentRetry = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -167,6 +175,14 @@
'class' => '\Airavata\Model\Job\JobModel',
),
),
+ 11 => array(
+ 'var' => 'maxRetry',
+ 'type' => TType::I32,
+ ),
+ 12 => array(
+ 'var' => 'currentRetry',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -200,6 +216,12 @@
if (isset($vals['jobs'])) {
$this->jobs = $vals['jobs'];
}
+ if (isset($vals['maxRetry'])) {
+ $this->maxRetry = $vals['maxRetry'];
+ }
+ if (isset($vals['currentRetry'])) {
+ $this->currentRetry = $vals['currentRetry'];
+ }
}
}
@@ -325,6 +347,20 @@
$xfer += $input->skip($ftype);
}
break;
+ case 11:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxRetry);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 12:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->currentRetry);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -424,6 +460,16 @@
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->maxRetry !== null) {
+ $xfer += $output->writeFieldBegin('maxRetry', TType::I32, 11);
+ $xfer += $output->writeI32($this->maxRetry);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->currentRetry !== null) {
+ $xfer += $output->writeFieldBegin('currentRetry', TType::I32, 12);
+ $xfer += $output->writeI32($this->currentRetry);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
diff --git a/app/libraries/Airavata/Model/Workflow/Types.php b/app/libraries/Airavata/Model/Workflow/Types.php
new file mode 100644
index 0000000..30801da
--- /dev/null
+++ b/app/libraries/Airavata/Model/Workflow/Types.php
@@ -0,0 +1,2176 @@
+<?php
+namespace Airavata\Model\Workflow;
+
+/**
+ * Autogenerated by Thrift Compiler (0.10.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
+use Thrift\Exception\TApplicationException;
+
+
+final class ApplicationState {
+ const CREATED = 0;
+ const VALIDATED = 1;
+ const SCHEDULED = 2;
+ const LAUNCHED = 3;
+ const EXECUTING = 4;
+ const CANCELING = 5;
+ const CANCELED = 6;
+ const COMPLETED = 7;
+ const FAILED = 8;
+ static public $__names = array(
+ 0 => 'CREATED',
+ 1 => 'VALIDATED',
+ 2 => 'SCHEDULED',
+ 3 => 'LAUNCHED',
+ 4 => 'EXECUTING',
+ 5 => 'CANCELING',
+ 6 => 'CANCELED',
+ 7 => 'COMPLETED',
+ 8 => 'FAILED',
+ );
+}
+
+final class ComponentType {
+ const APPLICATION = 0;
+ const HANDLER = 1;
+ static public $__names = array(
+ 0 => 'APPLICATION',
+ 1 => 'HANDLER',
+ );
+}
+
+final class HandlerType {
+ const FLOW_STARTER = 0;
+ const FLOW_TERMINATOR = 1;
+ static public $__names = array(
+ 0 => 'FLOW_STARTER',
+ 1 => 'FLOW_TERMINATOR',
+ );
+}
+
+final class HandlerState {
+ const CREATED = 0;
+ const VALIDATED = 1;
+ const SCHEDULED = 2;
+ const LAUNCHED = 3;
+ const EXECUTING = 4;
+ const CANCELING = 5;
+ const CANCELED = 6;
+ const COMPLETED = 7;
+ const FAILED = 8;
+ static public $__names = array(
+ 0 => 'CREATED',
+ 1 => 'VALIDATED',
+ 2 => 'SCHEDULED',
+ 3 => 'LAUNCHED',
+ 4 => 'EXECUTING',
+ 5 => 'CANCELING',
+ 6 => 'CANCELED',
+ 7 => 'COMPLETED',
+ 8 => 'FAILED',
+ );
+}
+
+final class WorkflowState {
+ const CREATED = 0;
+ const VALIDATED = 1;
+ const SCHEDULED = 2;
+ const LAUNCHED = 3;
+ const EXECUTING = 4;
+ const PAUSING = 5;
+ const PAUSED = 6;
+ const RESTARTING = 7;
+ const CANCELING = 8;
+ const CANCELED = 9;
+ const COMPLETED = 10;
+ const FAILED = 11;
+ static public $__names = array(
+ 0 => 'CREATED',
+ 1 => 'VALIDATED',
+ 2 => 'SCHEDULED',
+ 3 => 'LAUNCHED',
+ 4 => 'EXECUTING',
+ 5 => 'PAUSING',
+ 6 => 'PAUSED',
+ 7 => 'RESTARTING',
+ 8 => 'CANCELING',
+ 9 => 'CANCELED',
+ 10 => 'COMPLETED',
+ 11 => 'FAILED',
+ );
+}
+
+class ApplicationStatus {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var int
+ */
+ public $state = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'state',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['state'])) {
+ $this->state = $vals['state'];
+ }
+ if (isset($vals['description'])) {
+ $this->description = $vals['description'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationStatus';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->state);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->description);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ApplicationStatus');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->state !== null) {
+ $xfer += $output->writeFieldBegin('state', TType::I32, 2);
+ $xfer += $output->writeI32($this->state);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 3);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 4);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WorkflowApplication {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $processId = null;
+ /**
+ * @var string
+ */
+ public $applicationInterfaceId = null;
+ /**
+ * @var string
+ */
+ public $computeResourceId = null;
+ /**
+ * @var string
+ */
+ public $queueName = null;
+ /**
+ * @var int
+ */
+ public $nodeCount = null;
+ /**
+ * @var int
+ */
+ public $coreCount = null;
+ /**
+ * @var int
+ */
+ public $wallTimeLimit = null;
+ /**
+ * @var int
+ */
+ public $physicalMemory = null;
+ /**
+ * @var \Airavata\Model\Workflow\ApplicationStatus[]
+ */
+ public $statuses = null;
+ /**
+ * @var \Airavata\Model\Commons\ErrorModel[]
+ */
+ public $errors = null;
+ /**
+ * @var int
+ */
+ public $createdAt = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'processId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'applicationInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'computeResourceId',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'queueName',
+ 'type' => TType::STRING,
+ ),
+ 6 => array(
+ 'var' => 'nodeCount',
+ 'type' => TType::I32,
+ ),
+ 7 => array(
+ 'var' => 'coreCount',
+ 'type' => TType::I32,
+ ),
+ 8 => array(
+ 'var' => 'wallTimeLimit',
+ 'type' => TType::I32,
+ ),
+ 9 => array(
+ 'var' => 'physicalMemory',
+ 'type' => TType::I32,
+ ),
+ 10 => array(
+ 'var' => 'statuses',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\ApplicationStatus',
+ ),
+ ),
+ 11 => array(
+ 'var' => 'errors',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Commons\ErrorModel',
+ ),
+ ),
+ 12 => array(
+ 'var' => 'createdAt',
+ 'type' => TType::I64,
+ ),
+ 13 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['processId'])) {
+ $this->processId = $vals['processId'];
+ }
+ if (isset($vals['applicationInterfaceId'])) {
+ $this->applicationInterfaceId = $vals['applicationInterfaceId'];
+ }
+ if (isset($vals['computeResourceId'])) {
+ $this->computeResourceId = $vals['computeResourceId'];
+ }
+ if (isset($vals['queueName'])) {
+ $this->queueName = $vals['queueName'];
+ }
+ if (isset($vals['nodeCount'])) {
+ $this->nodeCount = $vals['nodeCount'];
+ }
+ if (isset($vals['coreCount'])) {
+ $this->coreCount = $vals['coreCount'];
+ }
+ if (isset($vals['wallTimeLimit'])) {
+ $this->wallTimeLimit = $vals['wallTimeLimit'];
+ }
+ if (isset($vals['physicalMemory'])) {
+ $this->physicalMemory = $vals['physicalMemory'];
+ }
+ if (isset($vals['statuses'])) {
+ $this->statuses = $vals['statuses'];
+ }
+ if (isset($vals['errors'])) {
+ $this->errors = $vals['errors'];
+ }
+ if (isset($vals['createdAt'])) {
+ $this->createdAt = $vals['createdAt'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WorkflowApplication';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->processId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->applicationInterfaceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->computeResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->queueName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->nodeCount);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->coreCount);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->wallTimeLimit);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->physicalMemory);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 10:
+ if ($ftype == TType::LST) {
+ $this->statuses = array();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $elem5 = new \Airavata\Model\Workflow\ApplicationStatus();
+ $xfer += $elem5->read($input);
+ $this->statuses []= $elem5;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 11:
+ if ($ftype == TType::LST) {
+ $this->errors = array();
+ $_size6 = 0;
+ $_etype9 = 0;
+ $xfer += $input->readListBegin($_etype9, $_size6);
+ for ($_i10 = 0; $_i10 < $_size6; ++$_i10)
+ {
+ $elem11 = null;
+ $elem11 = new \Airavata\Model\Commons\ErrorModel();
+ $xfer += $elem11->read($input);
+ $this->errors []= $elem11;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 12:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->createdAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 13:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WorkflowApplication');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->processId !== null) {
+ $xfer += $output->writeFieldBegin('processId', TType::STRING, 2);
+ $xfer += $output->writeString($this->processId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('applicationInterfaceId', TType::STRING, 3);
+ $xfer += $output->writeString($this->applicationInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->computeResourceId !== null) {
+ $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 4);
+ $xfer += $output->writeString($this->computeResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->queueName !== null) {
+ $xfer += $output->writeFieldBegin('queueName', TType::STRING, 5);
+ $xfer += $output->writeString($this->queueName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->nodeCount !== null) {
+ $xfer += $output->writeFieldBegin('nodeCount', TType::I32, 6);
+ $xfer += $output->writeI32($this->nodeCount);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->coreCount !== null) {
+ $xfer += $output->writeFieldBegin('coreCount', TType::I32, 7);
+ $xfer += $output->writeI32($this->coreCount);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->wallTimeLimit !== null) {
+ $xfer += $output->writeFieldBegin('wallTimeLimit', TType::I32, 8);
+ $xfer += $output->writeI32($this->wallTimeLimit);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->physicalMemory !== null) {
+ $xfer += $output->writeFieldBegin('physicalMemory', TType::I32, 9);
+ $xfer += $output->writeI32($this->physicalMemory);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->statuses !== null) {
+ if (!is_array($this->statuses)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('statuses', TType::LST, 10);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->statuses));
+ {
+ foreach ($this->statuses as $iter12)
+ {
+ $xfer += $iter12->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->errors !== null) {
+ if (!is_array($this->errors)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('errors', TType::LST, 11);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->errors));
+ {
+ foreach ($this->errors as $iter13)
+ {
+ $xfer += $iter13->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createdAt !== null) {
+ $xfer += $output->writeFieldBegin('createdAt', TType::I64, 12);
+ $xfer += $output->writeI64($this->createdAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 13);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class DataBlock {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var string
+ */
+ public $value = null;
+ /**
+ * @var int
+ */
+ public $type = null;
+ /**
+ * @var int
+ */
+ public $createdAt = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'value',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'type',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'createdAt',
+ 'type' => TType::I64,
+ ),
+ 5 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['value'])) {
+ $this->value = $vals['value'];
+ }
+ if (isset($vals['type'])) {
+ $this->type = $vals['type'];
+ }
+ if (isset($vals['createdAt'])) {
+ $this->createdAt = $vals['createdAt'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DataBlock';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->value);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->type);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->createdAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('DataBlock');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->value !== null) {
+ $xfer += $output->writeFieldBegin('value', TType::STRING, 2);
+ $xfer += $output->writeString($this->value);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->type !== null) {
+ $xfer += $output->writeFieldBegin('type', TType::I32, 3);
+ $xfer += $output->writeI32($this->type);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createdAt !== null) {
+ $xfer += $output->writeFieldBegin('createdAt', TType::I64, 4);
+ $xfer += $output->writeI64($this->createdAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 5);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WorkflowConnection {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = "DO_NOT_SET_AT_CLIENTS";
+ /**
+ * @var \Airavata\Model\Workflow\DataBlock
+ */
+ public $dataBlock = null;
+ /**
+ * @var int
+ */
+ public $fromType = null;
+ /**
+ * @var string
+ */
+ public $fromId = null;
+ /**
+ * @var string
+ */
+ public $fromOutputName = null;
+ /**
+ * @var int
+ */
+ public $toType = null;
+ /**
+ * @var string
+ */
+ public $toId = null;
+ /**
+ * @var string
+ */
+ public $toInputName = null;
+ /**
+ * @var int
+ */
+ public $createdAt = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dataBlock',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\DataBlock',
+ ),
+ 3 => array(
+ 'var' => 'fromType',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'fromId',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'fromOutputName',
+ 'type' => TType::STRING,
+ ),
+ 6 => array(
+ 'var' => 'toType',
+ 'type' => TType::I32,
+ ),
+ 7 => array(
+ 'var' => 'toId',
+ 'type' => TType::STRING,
+ ),
+ 8 => array(
+ 'var' => 'toInputName',
+ 'type' => TType::STRING,
+ ),
+ 9 => array(
+ 'var' => 'createdAt',
+ 'type' => TType::I64,
+ ),
+ 10 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['dataBlock'])) {
+ $this->dataBlock = $vals['dataBlock'];
+ }
+ if (isset($vals['fromType'])) {
+ $this->fromType = $vals['fromType'];
+ }
+ if (isset($vals['fromId'])) {
+ $this->fromId = $vals['fromId'];
+ }
+ if (isset($vals['fromOutputName'])) {
+ $this->fromOutputName = $vals['fromOutputName'];
+ }
+ if (isset($vals['toType'])) {
+ $this->toType = $vals['toType'];
+ }
+ if (isset($vals['toId'])) {
+ $this->toId = $vals['toId'];
+ }
+ if (isset($vals['toInputName'])) {
+ $this->toInputName = $vals['toInputName'];
+ }
+ if (isset($vals['createdAt'])) {
+ $this->createdAt = $vals['createdAt'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WorkflowConnection';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->dataBlock = new \Airavata\Model\Workflow\DataBlock();
+ $xfer += $this->dataBlock->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->fromType);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->fromId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->fromOutputName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->toType);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->toId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->toInputName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->createdAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 10:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WorkflowConnection');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataBlock !== null) {
+ if (!is_object($this->dataBlock)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataBlock', TType::STRUCT, 2);
+ $xfer += $this->dataBlock->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fromType !== null) {
+ $xfer += $output->writeFieldBegin('fromType', TType::I32, 3);
+ $xfer += $output->writeI32($this->fromType);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fromId !== null) {
+ $xfer += $output->writeFieldBegin('fromId', TType::STRING, 4);
+ $xfer += $output->writeString($this->fromId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fromOutputName !== null) {
+ $xfer += $output->writeFieldBegin('fromOutputName', TType::STRING, 5);
+ $xfer += $output->writeString($this->fromOutputName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->toType !== null) {
+ $xfer += $output->writeFieldBegin('toType', TType::I32, 6);
+ $xfer += $output->writeI32($this->toType);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->toId !== null) {
+ $xfer += $output->writeFieldBegin('toId', TType::STRING, 7);
+ $xfer += $output->writeString($this->toId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->toInputName !== null) {
+ $xfer += $output->writeFieldBegin('toInputName', TType::STRING, 8);
+ $xfer += $output->writeString($this->toInputName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createdAt !== null) {
+ $xfer += $output->writeFieldBegin('createdAt', TType::I64, 9);
+ $xfer += $output->writeI64($this->createdAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 10);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class HandlerStatus {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var int
+ */
+ public $state = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'state',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['state'])) {
+ $this->state = $vals['state'];
+ }
+ if (isset($vals['description'])) {
+ $this->description = $vals['description'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'HandlerStatus';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->state);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->description);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('HandlerStatus');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->state !== null) {
+ $xfer += $output->writeFieldBegin('state', TType::I32, 2);
+ $xfer += $output->writeI32($this->state);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 3);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 4);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WorkflowHandler {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var int
+ */
+ public $type = null;
+ /**
+ * @var \Airavata\Model\Application\Io\InputDataObjectType[]
+ */
+ public $inputs = null;
+ /**
+ * @var \Airavata\Model\Application\Io\OutputDataObjectType[]
+ */
+ public $outputs = null;
+ /**
+ * @var \Airavata\Model\Workflow\HandlerStatus[]
+ */
+ public $statuses = null;
+ /**
+ * @var \Airavata\Model\Commons\ErrorModel[]
+ */
+ public $errors = null;
+ /**
+ * @var int
+ */
+ public $createdAt = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'type',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'inputs',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Application\Io\InputDataObjectType',
+ ),
+ ),
+ 4 => array(
+ 'var' => 'outputs',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Application\Io\OutputDataObjectType',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'statuses',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\HandlerStatus',
+ ),
+ ),
+ 6 => array(
+ 'var' => 'errors',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Commons\ErrorModel',
+ ),
+ ),
+ 7 => array(
+ 'var' => 'createdAt',
+ 'type' => TType::I64,
+ ),
+ 8 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['type'])) {
+ $this->type = $vals['type'];
+ }
+ if (isset($vals['inputs'])) {
+ $this->inputs = $vals['inputs'];
+ }
+ if (isset($vals['outputs'])) {
+ $this->outputs = $vals['outputs'];
+ }
+ if (isset($vals['statuses'])) {
+ $this->statuses = $vals['statuses'];
+ }
+ if (isset($vals['errors'])) {
+ $this->errors = $vals['errors'];
+ }
+ if (isset($vals['createdAt'])) {
+ $this->createdAt = $vals['createdAt'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WorkflowHandler';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->type);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->inputs = array();
+ $_size14 = 0;
+ $_etype17 = 0;
+ $xfer += $input->readListBegin($_etype17, $_size14);
+ for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
+ {
+ $elem19 = null;
+ $elem19 = new \Airavata\Model\Application\Io\InputDataObjectType();
+ $xfer += $elem19->read($input);
+ $this->inputs []= $elem19;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->outputs = array();
+ $_size20 = 0;
+ $_etype23 = 0;
+ $xfer += $input->readListBegin($_etype23, $_size20);
+ for ($_i24 = 0; $_i24 < $_size20; ++$_i24)
+ {
+ $elem25 = null;
+ $elem25 = new \Airavata\Model\Application\Io\OutputDataObjectType();
+ $xfer += $elem25->read($input);
+ $this->outputs []= $elem25;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::LST) {
+ $this->statuses = array();
+ $_size26 = 0;
+ $_etype29 = 0;
+ $xfer += $input->readListBegin($_etype29, $_size26);
+ for ($_i30 = 0; $_i30 < $_size26; ++$_i30)
+ {
+ $elem31 = null;
+ $elem31 = new \Airavata\Model\Workflow\HandlerStatus();
+ $xfer += $elem31->read($input);
+ $this->statuses []= $elem31;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->errors = array();
+ $_size32 = 0;
+ $_etype35 = 0;
+ $xfer += $input->readListBegin($_etype35, $_size32);
+ for ($_i36 = 0; $_i36 < $_size32; ++$_i36)
+ {
+ $elem37 = null;
+ $elem37 = new \Airavata\Model\Commons\ErrorModel();
+ $xfer += $elem37->read($input);
+ $this->errors []= $elem37;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->createdAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WorkflowHandler');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->type !== null) {
+ $xfer += $output->writeFieldBegin('type', TType::I32, 2);
+ $xfer += $output->writeI32($this->type);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->inputs !== null) {
+ if (!is_array($this->inputs)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('inputs', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->inputs));
+ {
+ foreach ($this->inputs as $iter38)
+ {
+ $xfer += $iter38->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->outputs !== null) {
+ if (!is_array($this->outputs)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('outputs', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->outputs));
+ {
+ foreach ($this->outputs as $iter39)
+ {
+ $xfer += $iter39->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->statuses !== null) {
+ if (!is_array($this->statuses)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('statuses', TType::LST, 5);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->statuses));
+ {
+ foreach ($this->statuses as $iter40)
+ {
+ $xfer += $iter40->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->errors !== null) {
+ if (!is_array($this->errors)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('errors', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->errors));
+ {
+ foreach ($this->errors as $iter41)
+ {
+ $xfer += $iter41->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createdAt !== null) {
+ $xfer += $output->writeFieldBegin('createdAt', TType::I64, 7);
+ $xfer += $output->writeI64($this->createdAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 8);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WorkflowStatus {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = null;
+ /**
+ * @var int
+ */
+ public $state = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'state',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['state'])) {
+ $this->state = $vals['state'];
+ }
+ if (isset($vals['description'])) {
+ $this->description = $vals['description'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WorkflowStatus';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->state);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->description);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WorkflowStatus');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->state !== null) {
+ $xfer += $output->writeFieldBegin('state', TType::I32, 2);
+ $xfer += $output->writeI32($this->state);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 3);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 4);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class AiravataWorkflow {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $id = "DO_NOT_SET_AT_CLIENTS";
+ /**
+ * @var string
+ */
+ public $experimentId = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var \Airavata\Model\Workflow\WorkflowApplication[]
+ */
+ public $applications = null;
+ /**
+ * @var \Airavata\Model\Workflow\WorkflowHandler[]
+ */
+ public $handlers = null;
+ /**
+ * @var \Airavata\Model\Workflow\WorkflowConnection[]
+ */
+ public $connections = null;
+ /**
+ * @var \Airavata\Model\Workflow\WorkflowStatus[]
+ */
+ public $statuses = null;
+ /**
+ * @var \Airavata\Model\Commons\ErrorModel[]
+ */
+ public $errors = null;
+ /**
+ * @var int
+ */
+ public $createdAt = null;
+ /**
+ * @var int
+ */
+ public $updatedAt = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'id',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'experimentId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'applications',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\WorkflowApplication',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'handlers',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\WorkflowHandler',
+ ),
+ ),
+ 6 => array(
+ 'var' => 'connections',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\WorkflowConnection',
+ ),
+ ),
+ 7 => array(
+ 'var' => 'statuses',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workflow\WorkflowStatus',
+ ),
+ ),
+ 8 => array(
+ 'var' => 'errors',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Commons\ErrorModel',
+ ),
+ ),
+ 9 => array(
+ 'var' => 'createdAt',
+ 'type' => TType::I64,
+ ),
+ 10 => array(
+ 'var' => 'updatedAt',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['id'])) {
+ $this->id = $vals['id'];
+ }
+ if (isset($vals['experimentId'])) {
+ $this->experimentId = $vals['experimentId'];
+ }
+ if (isset($vals['description'])) {
+ $this->description = $vals['description'];
+ }
+ if (isset($vals['applications'])) {
+ $this->applications = $vals['applications'];
+ }
+ if (isset($vals['handlers'])) {
+ $this->handlers = $vals['handlers'];
+ }
+ if (isset($vals['connections'])) {
+ $this->connections = $vals['connections'];
+ }
+ if (isset($vals['statuses'])) {
+ $this->statuses = $vals['statuses'];
+ }
+ if (isset($vals['errors'])) {
+ $this->errors = $vals['errors'];
+ }
+ if (isset($vals['createdAt'])) {
+ $this->createdAt = $vals['createdAt'];
+ }
+ if (isset($vals['updatedAt'])) {
+ $this->updatedAt = $vals['updatedAt'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'AiravataWorkflow';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->id);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->experimentId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->description);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->applications = array();
+ $_size42 = 0;
+ $_etype45 = 0;
+ $xfer += $input->readListBegin($_etype45, $_size42);
+ for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
+ {
+ $elem47 = null;
+ $elem47 = new \Airavata\Model\Workflow\WorkflowApplication();
+ $xfer += $elem47->read($input);
+ $this->applications []= $elem47;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::LST) {
+ $this->handlers = array();
+ $_size48 = 0;
+ $_etype51 = 0;
+ $xfer += $input->readListBegin($_etype51, $_size48);
+ for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
+ {
+ $elem53 = null;
+ $elem53 = new \Airavata\Model\Workflow\WorkflowHandler();
+ $xfer += $elem53->read($input);
+ $this->handlers []= $elem53;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->connections = array();
+ $_size54 = 0;
+ $_etype57 = 0;
+ $xfer += $input->readListBegin($_etype57, $_size54);
+ for ($_i58 = 0; $_i58 < $_size54; ++$_i58)
+ {
+ $elem59 = null;
+ $elem59 = new \Airavata\Model\Workflow\WorkflowConnection();
+ $xfer += $elem59->read($input);
+ $this->connections []= $elem59;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::LST) {
+ $this->statuses = array();
+ $_size60 = 0;
+ $_etype63 = 0;
+ $xfer += $input->readListBegin($_etype63, $_size60);
+ for ($_i64 = 0; $_i64 < $_size60; ++$_i64)
+ {
+ $elem65 = null;
+ $elem65 = new \Airavata\Model\Workflow\WorkflowStatus();
+ $xfer += $elem65->read($input);
+ $this->statuses []= $elem65;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::LST) {
+ $this->errors = array();
+ $_size66 = 0;
+ $_etype69 = 0;
+ $xfer += $input->readListBegin($_etype69, $_size66);
+ for ($_i70 = 0; $_i70 < $_size66; ++$_i70)
+ {
+ $elem71 = null;
+ $elem71 = new \Airavata\Model\Commons\ErrorModel();
+ $xfer += $elem71->read($input);
+ $this->errors []= $elem71;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->createdAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 10:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->updatedAt);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('AiravataWorkflow');
+ if ($this->id !== null) {
+ $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+ $xfer += $output->writeString($this->id);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->experimentId !== null) {
+ $xfer += $output->writeFieldBegin('experimentId', TType::STRING, 2);
+ $xfer += $output->writeString($this->experimentId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 3);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applications !== null) {
+ if (!is_array($this->applications)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('applications', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->applications));
+ {
+ foreach ($this->applications as $iter72)
+ {
+ $xfer += $iter72->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->handlers !== null) {
+ if (!is_array($this->handlers)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('handlers', TType::LST, 5);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->handlers));
+ {
+ foreach ($this->handlers as $iter73)
+ {
+ $xfer += $iter73->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->connections !== null) {
+ if (!is_array($this->connections)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('connections', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->connections));
+ {
+ foreach ($this->connections as $iter74)
+ {
+ $xfer += $iter74->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->statuses !== null) {
+ if (!is_array($this->statuses)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('statuses', TType::LST, 7);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->statuses));
+ {
+ foreach ($this->statuses as $iter75)
+ {
+ $xfer += $iter75->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->errors !== null) {
+ if (!is_array($this->errors)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('errors', TType::LST, 8);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->errors));
+ {
+ foreach ($this->errors as $iter76)
+ {
+ $xfer += $iter76->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createdAt !== null) {
+ $xfer += $output->writeFieldBegin('createdAt', TType::I64, 9);
+ $xfer += $output->writeI64($this->createdAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->updatedAt !== null) {
+ $xfer += $output->writeFieldBegin('updatedAt', TType::I64, 10);
+ $xfer += $output->writeI64($this->updatedAt);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+
diff --git a/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/IamAdminServices.php b/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/IamAdminServices.php
index 1ba47d3..281b2df 100644
--- a/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/IamAdminServices.php
+++ b/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/IamAdminServices.php
@@ -16,14 +16,7 @@
use Thrift\Exception\TApplicationException;
-interface IamAdminServicesIf {
- /**
- * @param \Airavata\Model\Security\AuthzToken $authzToken
- * @return string
- * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
- * @throws \Airavata\API\Error\AuthorizationException
- */
- public function getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken);
+interface IamAdminServicesIf extends \Airavata\Base\API\BaseAPIIf {
/**
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param \Airavata\Model\Workspace\Gateway $gateway
@@ -35,6 +28,14 @@
/**
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $username
+ * @return bool
+ * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function isUsernameAvailable(\Airavata\Model\Security\AuthzToken $authzToken, $username);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $username
* @param string $emailAddress
* @param string $firstName
* @param string $lastName
@@ -63,6 +64,88 @@
/**
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $username
+ * @return bool
+ * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function isUserExist(\Airavata\Model\Security\AuthzToken $authzToken, $username);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $username
+ * @return \Airavata\Model\User\UserProfile * A structure holding the user profile and its child models.
+ * *
+ * * Notes:
+ * * The model does not include passwords as it is assumed an external identity provider is used to authenticate user.
+ * * References:
+ * * NSF Demographic Information - http://www.nsf.gov/pubs/2000/00form1225/00form1225.doc
+ * * LDAP Schema - https://tools.ietf.org/html/rfc4519
+ * * SCIM 2.0 - https://tools.ietf.org/html/rfc7643
+ * *
+ * * userModelVersion:
+ * * Version number of profile
+ * *
+ * * airavataInternalUserId:
+ * * internal to Airavata, not intended to be used outside of the Airavata platform or possibly by gateways
+ * * (that is, never shown to users), never reassigned, REQUIRED
+ * *
+ * * userId:
+ * * Externally assertable unique identifier. SAML (primarly in higher education, academic) tends to keep
+ * * user name less opaque. OpenID Connect maintains them to be opaque.
+ * *
+ * * firstName, middleName, lastName:
+ * * First and Last names as assertede by the user
+ * *
+ * * namePrefix, nameSuffix:
+ * * prefix and suffix to the users name as asserted by the user
+ * *
+ * * emails:
+ * * Email identifier are Verified, REQUIRED and MULTIVALUED
+ * *
+ * * userName:
+ * * Name-based identifiers can be multivalues. To keep it simple, Airavata will make it a string.
+ * * In the future these can be enumerated as:
+ * * Official name (as asserted possibly by some external identity provider)
+ * * Prefered name (as asserted or suggested by user directly)
+ * * Components:
+ * * givenName
+ * * surname (familyName)
+ * * displayName (often asserted by user to handle things like middle names, suffix, prefix, and the like)
+ * *
+ * * orcidId: ORCID ID - http://orcid.org/about/what-is-orcid)
+ * *
+ * * phones: Telephone MULTIVALUED
+ * *
+ * * country: Country of Residance
+ * *
+ * * nationality Countries of citizenship
+ * *
+ * * comments:
+ * * Free-form information (treated as opaque by Airavata and simply passed to resource).
+ * *
+ * * labeledURI:
+ * * Google Scholar, Web of Science, ACS, e.t.c
+ * *
+ * * timeZone:
+ * * User’s preferred timezone - IANA Timezone Databases - http://www.iana.org/time-zones.
+ * *
+ *
+ * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getUser(\Airavata\Model\Security\AuthzToken $authzToken, $username);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param int $offset
+ * @param int $limit
+ * @param string $search
+ * @return \Airavata\Model\User\UserProfile[]
+ * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getUsers(\Airavata\Model\Security\AuthzToken $authzToken, $offset, $limit, $search);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $username
* @param string $newPassword
* @return bool
* @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
@@ -88,6 +171,14 @@
/**
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $username
+ * @return bool
+ * @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function deleteUser(\Airavata\Model\Security\AuthzToken $authzToken, $username);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $username
* @param string $roleName
* @return bool
* @throws \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
@@ -114,72 +205,9 @@
}
-class IamAdminServicesClient implements \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServicesIf {
- protected $input_ = null;
- protected $output_ = null;
-
- protected $seqid_ = 0;
-
+class IamAdminServicesClient extends \Airavata\Base\API\BaseAPIClient implements \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServicesIf {
public function __construct($input, $output=null) {
- $this->input_ = $input;
- $this->output_ = $output ? $output : $input;
- }
-
- public function getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken)
- {
- $this->send_getAPIVersion($authzToken);
- return $this->recv_getAPIVersion();
- }
-
- public function send_getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken)
- {
- $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getAPIVersion_args();
- $args->authzToken = $authzToken;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getAPIVersion', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getAPIVersion', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getAPIVersion()
- {
- $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getAPIVersion_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\Service\Iam\Admin\Services\CPI\IamAdminServices_getAPIVersion_result();
- $result->read($this->input_);
- $this->input_->readMessageEnd();
- }
- if ($result->success !== null) {
- return $result->success;
- }
- if ($result->Idse !== null) {
- throw $result->Idse;
- }
- if ($result->ae !== null) {
- throw $result->ae;
- }
- throw new \Exception("getAPIVersion failed: unknown result");
+ parent::__construct($input, $output);
}
public function setUpGateway(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Workspace\Gateway $gateway)
@@ -240,6 +268,64 @@
throw new \Exception("setUpGateway failed: unknown result");
}
+ public function isUsernameAvailable(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $this->send_isUsernameAvailable($authzToken, $username);
+ return $this->recv_isUsernameAvailable();
+ }
+
+ public function send_isUsernameAvailable(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_isUsernameAvailable_args();
+ $args->authzToken = $authzToken;
+ $args->username = $username;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'isUsernameAvailable', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('isUsernameAvailable', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_isUsernameAvailable()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_isUsernameAvailable_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\Service\Iam\Admin\Services\CPI\IamAdminServices_isUsernameAvailable_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->Idse !== null) {
+ throw $result->Idse;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("isUsernameAvailable failed: unknown result");
+ }
+
public function registerUser(\Airavata\Model\Security\AuthzToken $authzToken, $username, $emailAddress, $firstName, $lastName, $newPassword)
{
$this->send_registerUser($authzToken, $username, $emailAddress, $firstName, $lastName, $newPassword);
@@ -418,6 +504,182 @@
throw new \Exception("isUserEnabled failed: unknown result");
}
+ public function isUserExist(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $this->send_isUserExist($authzToken, $username);
+ return $this->recv_isUserExist();
+ }
+
+ public function send_isUserExist(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_isUserExist_args();
+ $args->authzToken = $authzToken;
+ $args->username = $username;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'isUserExist', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('isUserExist', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_isUserExist()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_isUserExist_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\Service\Iam\Admin\Services\CPI\IamAdminServices_isUserExist_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->Idse !== null) {
+ throw $result->Idse;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("isUserExist failed: unknown result");
+ }
+
+ public function getUser(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $this->send_getUser($authzToken, $username);
+ return $this->recv_getUser();
+ }
+
+ public function send_getUser(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getUser_args();
+ $args->authzToken = $authzToken;
+ $args->username = $username;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getUser', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getUser', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getUser()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getUser_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\Service\Iam\Admin\Services\CPI\IamAdminServices_getUser_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->Idse !== null) {
+ throw $result->Idse;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("getUser failed: unknown result");
+ }
+
+ public function getUsers(\Airavata\Model\Security\AuthzToken $authzToken, $offset, $limit, $search)
+ {
+ $this->send_getUsers($authzToken, $offset, $limit, $search);
+ return $this->recv_getUsers();
+ }
+
+ public function send_getUsers(\Airavata\Model\Security\AuthzToken $authzToken, $offset, $limit, $search)
+ {
+ $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getUsers_args();
+ $args->authzToken = $authzToken;
+ $args->offset = $offset;
+ $args->limit = $limit;
+ $args->search = $search;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getUsers', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getUsers()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_getUsers_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\Service\Iam\Admin\Services\CPI\IamAdminServices_getUsers_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->Idse !== null) {
+ throw $result->Idse;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("getUsers failed: unknown result");
+ }
+
public function resetUserPassword(\Airavata\Model\Security\AuthzToken $authzToken, $username, $newPassword)
{
$this->send_resetUserPassword($authzToken, $username, $newPassword);
@@ -591,6 +853,64 @@
return;
}
+ public function deleteUser(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $this->send_deleteUser($authzToken, $username);
+ return $this->recv_deleteUser();
+ }
+
+ public function send_deleteUser(\Airavata\Model\Security\AuthzToken $authzToken, $username)
+ {
+ $args = new \Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_deleteUser_args();
+ $args->authzToken = $authzToken;
+ $args->username = $username;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteUser', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteUser', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteUser()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Iam\Admin\Services\CPI\IamAdminServices_deleteUser_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\Service\Iam\Admin\Services\CPI\IamAdminServices_deleteUser_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->Idse !== null) {
+ throw $result->Idse;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("deleteUser failed: unknown result");
+ }
+
public function addRoleToUser(\Airavata\Model\Security\AuthzToken $authzToken, $username, $roleName)
{
$this->send_addRoleToUser($authzToken, $username, $roleName);
@@ -772,211 +1092,6 @@
// HELPER FUNCTIONS AND STRUCTURES
-class IamAdminServices_getAPIVersion_args {
- static $_TSPEC;
-
- /**
- * @var \Airavata\Model\Security\AuthzToken
- */
- public $authzToken = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'authzToken',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\Security\AuthzToken',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['authzToken'])) {
- $this->authzToken = $vals['authzToken'];
- }
- }
- }
-
- public function getName() {
- return 'IamAdminServices_getAPIVersion_args';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRUCT) {
- $this->authzToken = new \Airavata\Model\Security\AuthzToken();
- $xfer += $this->authzToken->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('IamAdminServices_getAPIVersion_args');
- if ($this->authzToken !== null) {
- if (!is_object($this->authzToken)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
- $xfer += $this->authzToken->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class IamAdminServices_getAPIVersion_result {
- static $_TSPEC;
-
- /**
- * @var string
- */
- public $success = null;
- /**
- * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
- */
- public $Idse = null;
- /**
- * @var \Airavata\API\Error\AuthorizationException
- */
- public $ae = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 0 => array(
- 'var' => 'success',
- 'type' => TType::STRING,
- ),
- 1 => array(
- 'var' => 'Idse',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
- ),
- 2 => array(
- 'var' => 'ae',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\API\Error\AuthorizationException',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['success'])) {
- $this->success = $vals['success'];
- }
- if (isset($vals['Idse'])) {
- $this->Idse = $vals['Idse'];
- }
- if (isset($vals['ae'])) {
- $this->ae = $vals['ae'];
- }
- }
- }
-
- public function getName() {
- return 'IamAdminServices_getAPIVersion_result';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 0:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->success);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 1:
- if ($ftype == TType::STRUCT) {
- $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
- $xfer += $this->Idse->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::STRUCT) {
- $this->ae = new \Airavata\API\Error\AuthorizationException();
- $xfer += $this->ae->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('IamAdminServices_getAPIVersion_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->Idse !== null) {
- $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
- $xfer += $this->Idse->write($output);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->ae !== null) {
- $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
- $xfer += $this->ae->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
class IamAdminServices_setUpGateway_args {
static $_TSPEC;
@@ -1215,6 +1330,234 @@
}
+class IamAdminServices_isUsernameAvailable_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $username = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'username',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['username'])) {
+ $this->username = $vals['username'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_isUsernameAvailable_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->username);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_isUsernameAvailable_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->username !== null) {
+ $xfer += $output->writeFieldBegin('username', TType::STRING, 2);
+ $xfer += $output->writeString($this->username);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_isUsernameAvailable_result {
+ static $_TSPEC;
+
+ /**
+ * @var bool
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ */
+ public $Idse = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
+ 1 => array(
+ 'var' => 'Idse',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['Idse'])) {
+ $this->Idse = $vals['Idse'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_isUsernameAvailable_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
+ $xfer += $this->Idse->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_isUsernameAvailable_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->Idse !== null) {
+ $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
+ $xfer += $this->Idse->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class IamAdminServices_registerUser_args {
static $_TSPEC;
@@ -1991,6 +2334,769 @@
}
+class IamAdminServices_isUserExist_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $username = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'username',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['username'])) {
+ $this->username = $vals['username'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_isUserExist_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->username);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_isUserExist_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->username !== null) {
+ $xfer += $output->writeFieldBegin('username', TType::STRING, 2);
+ $xfer += $output->writeString($this->username);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_isUserExist_result {
+ static $_TSPEC;
+
+ /**
+ * @var bool
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ */
+ public $Idse = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
+ 1 => array(
+ 'var' => 'Idse',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['Idse'])) {
+ $this->Idse = $vals['Idse'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_isUserExist_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
+ $xfer += $this->Idse->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_isUserExist_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->Idse !== null) {
+ $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
+ $xfer += $this->Idse->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_getUser_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $username = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'username',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['username'])) {
+ $this->username = $vals['username'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_getUser_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->username);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_getUser_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->username !== null) {
+ $xfer += $output->writeFieldBegin('username', TType::STRING, 2);
+ $xfer += $output->writeString($this->username);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_getUser_result {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\User\UserProfile
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ */
+ public $Idse = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\User\UserProfile',
+ ),
+ 1 => array(
+ 'var' => 'Idse',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['Idse'])) {
+ $this->Idse = $vals['Idse'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_getUser_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \Airavata\Model\User\UserProfile();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
+ $xfer += $this->Idse->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_getUser_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->Idse !== null) {
+ $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
+ $xfer += $this->Idse->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_getUsers_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var int
+ */
+ public $offset = null;
+ /**
+ * @var int
+ */
+ public $limit = null;
+ /**
+ * @var string
+ */
+ public $search = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'offset',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'limit',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'search',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['offset'])) {
+ $this->offset = $vals['offset'];
+ }
+ if (isset($vals['limit'])) {
+ $this->limit = $vals['limit'];
+ }
+ if (isset($vals['search'])) {
+ $this->search = $vals['search'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_getUsers_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->offset);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->limit);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->search);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_getUsers_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->offset !== null) {
+ $xfer += $output->writeFieldBegin('offset', TType::I32, 2);
+ $xfer += $output->writeI32($this->offset);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->limit !== null) {
+ $xfer += $output->writeFieldBegin('limit', TType::I32, 3);
+ $xfer += $output->writeI32($this->limit);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->search !== null) {
+ $xfer += $output->writeFieldBegin('search', TType::STRING, 4);
+ $xfer += $output->writeString($this->search);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_getUsers_result {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\User\UserProfile[]
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ */
+ public $Idse = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\User\UserProfile',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'Idse',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['Idse'])) {
+ $this->Idse = $vals['Idse'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_getUsers_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $elem5 = new \Airavata\Model\User\UserProfile();
+ $xfer += $elem5->read($input);
+ $this->success []= $elem5;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
+ $xfer += $this->Idse->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_getUsers_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->success));
+ {
+ foreach ($this->success as $iter6)
+ {
+ $xfer += $iter6->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->Idse !== null) {
+ $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
+ $xfer += $this->Idse->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class IamAdminServices_resetUserPassword_args {
static $_TSPEC;
@@ -2443,15 +3549,15 @@
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size0 = 0;
- $_etype3 = 0;
- $xfer += $input->readListBegin($_etype3, $_size0);
- for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ $_size7 = 0;
+ $_etype10 = 0;
+ $xfer += $input->readListBegin($_etype10, $_size7);
+ for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
{
- $elem5 = null;
- $elem5 = new \Airavata\Model\User\UserProfile();
- $xfer += $elem5->read($input);
- $this->success []= $elem5;
+ $elem12 = null;
+ $elem12 = new \Airavata\Model\User\UserProfile();
+ $xfer += $elem12->read($input);
+ $this->success []= $elem12;
}
$xfer += $input->readListEnd();
} else {
@@ -2495,9 +3601,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter6)
+ foreach ($this->success as $iter13)
{
- $xfer += $iter6->write($output);
+ $xfer += $iter13->write($output);
}
}
$output->writeListEnd();
@@ -2731,6 +3837,234 @@
}
+class IamAdminServices_deleteUser_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $username = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'username',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['username'])) {
+ $this->username = $vals['username'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_deleteUser_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->username);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_deleteUser_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->username !== null) {
+ $xfer += $output->writeFieldBegin('username', TType::STRING, 2);
+ $xfer += $output->writeString($this->username);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class IamAdminServices_deleteUser_result {
+ static $_TSPEC;
+
+ /**
+ * @var bool
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException
+ */
+ public $Idse = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
+ 1 => array(
+ 'var' => 'Idse',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['Idse'])) {
+ $this->Idse = $vals['Idse'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'IamAdminServices_deleteUser_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->Idse = new \Airavata\Service\Iam\Admin\Services\CPI\Error\IamAdminServicesException();
+ $xfer += $this->Idse->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('IamAdminServices_deleteUser_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->Idse !== null) {
+ $xfer += $output->writeFieldBegin('Idse', TType::STRUCT, 1);
+ $xfer += $this->Idse->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class IamAdminServices_addRoleToUser_args {
static $_TSPEC;
@@ -3411,15 +4745,15 @@
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size7 = 0;
- $_etype10 = 0;
- $xfer += $input->readListBegin($_etype10, $_size7);
- for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
+ $_size14 = 0;
+ $_etype17 = 0;
+ $xfer += $input->readListBegin($_etype17, $_size14);
+ for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
{
- $elem12 = null;
- $elem12 = new \Airavata\Model\User\UserProfile();
- $xfer += $elem12->read($input);
- $this->success []= $elem12;
+ $elem19 = null;
+ $elem19 = new \Airavata\Model\User\UserProfile();
+ $xfer += $elem19->read($input);
+ $this->success []= $elem19;
}
$xfer += $input->readListEnd();
} else {
@@ -3463,9 +4797,9 @@
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter13)
+ foreach ($this->success as $iter20)
{
- $xfer += $iter13->write($output);
+ $xfer += $iter20->write($output);
}
}
$output->writeListEnd();
diff --git a/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/Types.php b/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/Types.php
index 54391ec..6290b8c 100644
--- a/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/Types.php
+++ b/app/libraries/Airavata/Service/Iam/Admin/Services/CPI/Types.php
@@ -22,7 +22,7 @@
static protected $IAM_ADMIN_SERVICES_CPI_NAME;
static protected function init_IAM_ADMIN_SERVICES_CPI_VERSION() {
- return "0.17";
+ return "0.18.0";
}
static protected function init_IAM_ADMIN_SERVICES_CPI_NAME() {
diff --git a/app/libraries/Airavata/Service/Profile/Groupmanager/CPI/Types.php b/app/libraries/Airavata/Service/Profile/Groupmanager/CPI/Types.php
index b49f4a3..68ee023 100644
--- a/app/libraries/Airavata/Service/Profile/Groupmanager/CPI/Types.php
+++ b/app/libraries/Airavata/Service/Profile/Groupmanager/CPI/Types.php
@@ -22,7 +22,7 @@
static protected $GROUP_MANAGER_CPI_NAME;
static protected function init_GROUP_MANAGER_CPI_VERSION() {
- return "0.17";
+ return "0.18.0";
}
static protected function init_GROUP_MANAGER_CPI_NAME() {
diff --git a/app/libraries/Airavata/Service/Profile/Tenant/CPI/TenantProfileService.php b/app/libraries/Airavata/Service/Profile/Tenant/CPI/TenantProfileService.php
index 633771e..da935f8 100644
--- a/app/libraries/Airavata/Service/Profile/Tenant/CPI/TenantProfileService.php
+++ b/app/libraries/Airavata/Service/Profile/Tenant/CPI/TenantProfileService.php
@@ -16,14 +16,7 @@
use Thrift\Exception\TApplicationException;
-interface TenantProfileServiceIf {
- /**
- * @param \Airavata\Model\Security\AuthzToken $authzToken
- * @return string
- * @throws \Airavata\Service\Profile\Tenant\CPI\Error\TenantProfileServiceException
- * @throws \Airavata\API\Error\AuthorizationException
- */
- public function getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken);
+interface TenantProfileServiceIf extends \Airavata\Base\API\BaseAPIIf {
/**
* Return the airavataInternalGatewayId assigned to given gateway.
*
@@ -85,72 +78,9 @@
}
-class TenantProfileServiceClient implements \Airavata\Service\Profile\Tenant\CPI\TenantProfileServiceIf {
- protected $input_ = null;
- protected $output_ = null;
-
- protected $seqid_ = 0;
-
+class TenantProfileServiceClient extends \Airavata\Base\API\BaseAPIClient implements \Airavata\Service\Profile\Tenant\CPI\TenantProfileServiceIf {
public function __construct($input, $output=null) {
- $this->input_ = $input;
- $this->output_ = $output ? $output : $input;
- }
-
- public function getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken)
- {
- $this->send_getAPIVersion($authzToken);
- return $this->recv_getAPIVersion();
- }
-
- public function send_getAPIVersion(\Airavata\Model\Security\AuthzToken $authzToken)
- {
- $args = new \Airavata\Service\Profile\Tenant\CPI\TenantProfileService_getAPIVersion_args();
- $args->authzToken = $authzToken;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getAPIVersion', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getAPIVersion', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getAPIVersion()
- {
- $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Profile\Tenant\CPI\TenantProfileService_getAPIVersion_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\Service\Profile\Tenant\CPI\TenantProfileService_getAPIVersion_result();
- $result->read($this->input_);
- $this->input_->readMessageEnd();
- }
- if ($result->success !== null) {
- return $result->success;
- }
- if ($result->tpe !== null) {
- throw $result->tpe;
- }
- if ($result->ae !== null) {
- throw $result->ae;
- }
- throw new \Exception("getAPIVersion failed: unknown result");
+ parent::__construct($input, $output);
}
public function addGateway(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Workspace\Gateway $gateway)
@@ -564,211 +494,6 @@
// HELPER FUNCTIONS AND STRUCTURES
-class TenantProfileService_getAPIVersion_args {
- static $_TSPEC;
-
- /**
- * @var \Airavata\Model\Security\AuthzToken
- */
- public $authzToken = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'authzToken',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\Security\AuthzToken',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['authzToken'])) {
- $this->authzToken = $vals['authzToken'];
- }
- }
- }
-
- public function getName() {
- return 'TenantProfileService_getAPIVersion_args';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRUCT) {
- $this->authzToken = new \Airavata\Model\Security\AuthzToken();
- $xfer += $this->authzToken->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('TenantProfileService_getAPIVersion_args');
- if ($this->authzToken !== null) {
- if (!is_object($this->authzToken)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
- $xfer += $this->authzToken->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class TenantProfileService_getAPIVersion_result {
- static $_TSPEC;
-
- /**
- * @var string
- */
- public $success = null;
- /**
- * @var \Airavata\Service\Profile\Tenant\CPI\Error\TenantProfileServiceException
- */
- public $tpe = null;
- /**
- * @var \Airavata\API\Error\AuthorizationException
- */
- public $ae = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 0 => array(
- 'var' => 'success',
- 'type' => TType::STRING,
- ),
- 1 => array(
- 'var' => 'tpe',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Service\Profile\Tenant\CPI\Error\TenantProfileServiceException',
- ),
- 2 => array(
- 'var' => 'ae',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\API\Error\AuthorizationException',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['success'])) {
- $this->success = $vals['success'];
- }
- if (isset($vals['tpe'])) {
- $this->tpe = $vals['tpe'];
- }
- if (isset($vals['ae'])) {
- $this->ae = $vals['ae'];
- }
- }
- }
-
- public function getName() {
- return 'TenantProfileService_getAPIVersion_result';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 0:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->success);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 1:
- if ($ftype == TType::STRUCT) {
- $this->tpe = new \Airavata\Service\Profile\Tenant\CPI\Error\TenantProfileServiceException();
- $xfer += $this->tpe->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::STRUCT) {
- $this->ae = new \Airavata\API\Error\AuthorizationException();
- $xfer += $this->ae->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('TenantProfileService_getAPIVersion_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->tpe !== null) {
- $xfer += $output->writeFieldBegin('tpe', TType::STRUCT, 1);
- $xfer += $this->tpe->write($output);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->ae !== null) {
- $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
- $xfer += $this->ae->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
class TenantProfileService_addGateway_args {
static $_TSPEC;
diff --git a/app/libraries/Airavata/Service/Profile/Tenant/CPI/Types.php b/app/libraries/Airavata/Service/Profile/Tenant/CPI/Types.php
index 41891f4..ab67b5d 100644
--- a/app/libraries/Airavata/Service/Profile/Tenant/CPI/Types.php
+++ b/app/libraries/Airavata/Service/Profile/Tenant/CPI/Types.php
@@ -22,7 +22,7 @@
static protected $TENANT_PROFILE_CPI_NAME;
static protected function init_TENANT_PROFILE_CPI_VERSION() {
- return "0.17";
+ return "0.18.0";
}
static protected function init_TENANT_PROFILE_CPI_NAME() {
diff --git a/app/libraries/Airavata/Service/Profile/User/CPI/Types.php b/app/libraries/Airavata/Service/Profile/User/CPI/Types.php
index bceeb65..6ff1b16 100644
--- a/app/libraries/Airavata/Service/Profile/User/CPI/Types.php
+++ b/app/libraries/Airavata/Service/Profile/User/CPI/Types.php
@@ -22,7 +22,7 @@
static protected $USER_PROFILE_CPI_NAME;
static protected function init_USER_PROFILE_CPI_VERSION() {
- return "0.17";
+ return "0.18.0";
}
static protected function init_USER_PROFILE_CPI_NAME() {
diff --git a/app/libraries/Airavata/Service/Profile/User/CPI/UserProfileService.php b/app/libraries/Airavata/Service/Profile/User/CPI/UserProfileService.php
index 0efa67e..ca995b9 100644
--- a/app/libraries/Airavata/Service/Profile/User/CPI/UserProfileService.php
+++ b/app/libraries/Airavata/Service/Profile/User/CPI/UserProfileService.php
@@ -16,8 +16,26 @@
use Thrift\Exception\TApplicationException;
-interface UserProfileServiceIf {
+interface UserProfileServiceIf extends \Airavata\Base\API\BaseAPIIf {
/**
+ * @return string
+ * @throws \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException
+ */
+ public function getAPIVersion();
+ /**
+ * Create an initial UserProfile based on information in the IAM service for this user.
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @return string
+ * @throws \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function initializeUserProfile(\Airavata\Model\Security\AuthzToken $authzToken);
+ /**
+ * This method is deprecated and will be removed in future versions of Airavata. Please use
+ * the initializeUserProfile method which fetches the information about the user profile from
+ * IAM service - @Deprecated
+ *
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param \Airavata\Model\User\UserProfile $userProfile
* @return string
@@ -129,15 +147,119 @@
}
-class UserProfileServiceClient implements \Airavata\Service\Profile\User\CPI\UserProfileServiceIf {
- protected $input_ = null;
- protected $output_ = null;
-
- protected $seqid_ = 0;
-
+class UserProfileServiceClient extends \Airavata\Base\API\BaseAPIClient implements \Airavata\Service\Profile\User\CPI\UserProfileServiceIf {
public function __construct($input, $output=null) {
- $this->input_ = $input;
- $this->output_ = $output ? $output : $input;
+ parent::__construct($input, $output);
+ }
+
+ public function getAPIVersion()
+ {
+ $this->send_getAPIVersion();
+ return $this->recv_getAPIVersion();
+ }
+
+ public function send_getAPIVersion()
+ {
+ $args = new \Airavata\Service\Profile\User\CPI\UserProfileService_getAPIVersion_args();
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAPIVersion', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAPIVersion', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAPIVersion()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Profile\User\CPI\UserProfileService_getAPIVersion_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\Service\Profile\User\CPI\UserProfileService_getAPIVersion_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->upe !== null) {
+ throw $result->upe;
+ }
+ throw new \Exception("getAPIVersion failed: unknown result");
+ }
+
+ public function initializeUserProfile(\Airavata\Model\Security\AuthzToken $authzToken)
+ {
+ $this->send_initializeUserProfile($authzToken);
+ return $this->recv_initializeUserProfile();
+ }
+
+ public function send_initializeUserProfile(\Airavata\Model\Security\AuthzToken $authzToken)
+ {
+ $args = new \Airavata\Service\Profile\User\CPI\UserProfileService_initializeUserProfile_args();
+ $args->authzToken = $authzToken;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'initializeUserProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('initializeUserProfile', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_initializeUserProfile()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\Service\Profile\User\CPI\UserProfileService_initializeUserProfile_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\Service\Profile\User\CPI\UserProfileService_initializeUserProfile_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->upe !== null) {
+ throw $result->upe;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("initializeUserProfile failed: unknown result");
}
public function addUserProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\User\UserProfile $userProfile)
@@ -498,6 +620,361 @@
// HELPER FUNCTIONS AND STRUCTURES
+class UserProfileService_getAPIVersion_args {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'UserProfileService_getAPIVersion_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('UserProfileService_getAPIVersion_args');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class UserProfileService_getAPIVersion_result {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException
+ */
+ public $upe = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRING,
+ ),
+ 1 => array(
+ 'var' => 'upe',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['upe'])) {
+ $this->upe = $vals['upe'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'UserProfileService_getAPIVersion_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->upe = new \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException();
+ $xfer += $this->upe->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('UserProfileService_getAPIVersion_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->upe !== null) {
+ $xfer += $output->writeFieldBegin('upe', TType::STRUCT, 1);
+ $xfer += $this->upe->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class UserProfileService_initializeUserProfile_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'UserProfileService_initializeUserProfile_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('UserProfileService_initializeUserProfile_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class UserProfileService_initializeUserProfile_result {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException
+ */
+ public $upe = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRING,
+ ),
+ 1 => array(
+ 'var' => 'upe',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException',
+ ),
+ 2 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['upe'])) {
+ $this->upe = $vals['upe'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'UserProfileService_initializeUserProfile_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->upe = new \Airavata\Service\Profile\User\CPI\Error\UserProfileServiceException();
+ $xfer += $this->upe->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('UserProfileService_initializeUserProfile_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->upe !== null) {
+ $xfer += $output->writeFieldBegin('upe', TType::STRUCT, 1);
+ $xfer += $this->upe->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 2);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class UserProfileService_addUserProfile_args {
static $_TSPEC;
