aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/php/tests/interop
diff options
context:
space:
mode:
authorGravatar mlumish <mlumish@google.com>2014-12-09 16:28:23 -0800
committerGravatar Michael Lumish <mlumish@google.com>2014-12-09 17:50:41 -0800
commitb892a27e67e534eccf011ab8c68d455c5be77e6c (patch)
tree7d1475a645c6ac60ff0ee28f26425734048480cb /src/php/tests/interop
parent275b3ac04dbe5654a38de47e7f4ee6b9b7ca7b8e (diff)
Added PHP to the global gRPC moe config
Change on 2014/12/09 by mlumish <mlumish@google.com> ------------- Created by MOE: http://code.google.com/p/moe-java MOE_MIGRATED_REVID=81727766
Diffstat (limited to 'src/php/tests/interop')
-rwxr-xr-xsrc/php/tests/interop/empty.php26
-rwxr-xr-xsrc/php/tests/interop/interop_client.php191
-rwxr-xr-xsrc/php/tests/interop/message_set.php26
-rwxr-xr-xsrc/php/tests/interop/messages.php1011
-rwxr-xr-xsrc/php/tests/interop/test.php52
5 files changed, 1306 insertions, 0 deletions
diff --git a/src/php/tests/interop/empty.php b/src/php/tests/interop/empty.php
new file mode 100755
index 0000000000..0107f2530b
--- /dev/null
+++ b/src/php/tests/interop/empty.php
@@ -0,0 +1,26 @@
+<?php
+// DO NOT EDIT! Generated by Protobuf-PHP protoc plugin 1.0
+// Source: net/proto2/proto/empty.proto
+// Date: 2014-12-03 22:02:20
+
+namespace proto2 {
+
+ class EmptyMessage extends \DrSlump\Protobuf\Message {
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'proto2.EmptyMessage');
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+ }
+}
+
diff --git a/src/php/tests/interop/interop_client.php b/src/php/tests/interop/interop_client.php
new file mode 100755
index 0000000000..9810c86272
--- /dev/null
+++ b/src/php/tests/interop/interop_client.php
@@ -0,0 +1,191 @@
+<?php
+require __DIR__ . '/../../lib/Grpc/ActiveCall.php';
+require __DIR__ . '/../../lib/Grpc/SurfaceActiveCall.php';
+require __DIR__ . '/../../lib/Grpc/BaseStub.php';
+require 'DrSlump/Protobuf.php';
+\DrSlump\Protobuf::autoload();
+require 'empty.php';
+require 'message_set.php';
+require 'messages.php';
+require 'test.php';
+/**
+ * Assertion function that always exits with an error code if the assertion is
+ * falsy
+ * @param $value Assertion value. Should be true.
+ * @param $error_message Message to display if the assertion is false
+ */
+function hardAssert($value, $error_message) {
+ if(!$value) {
+ echo $error_message . "\n";
+ exit(1);
+ }
+}
+
+/**
+ * Run the empty_unary test.
+ * Currently not tested against any server as of 2014-12-04
+ * @param $stub Stub object that has service methods
+ */
+function emptyUnary($stub) {
+ list($result, $status) = $stub->EmptyCall(new proto2\EmptyMessage())->wait();
+ hardAssert($status->code == Grpc\STATUS_OK, 'Call did not complete successfully');
+ hardAssert($result != null, 'Call completed with a null response');
+}
+
+/**
+ * Run the large_unary test.
+ * Passes when run against the C++ server as of 2014-12-04
+ * Not tested against any other server as of 2014-12-04
+ * @param $stub Stub object that has service methods
+ */
+function largeUnary($stub) {
+ $request_len = 271828;
+ $response_len = 314159;
+
+ $request = new grpc\testing\SimpleRequest();
+ $request->setResponseType(grpc\testing\PayloadType::COMPRESSABLE);
+ $request->setResponseSize($response_len);
+ $payload = new grpc\testing\Payload();
+ $payload->setType(grpc\testing\PayloadType::COMPRESSABLE);
+ $payload->setBody(str_repeat("\0", $request_len));
+ $request->setPayload($payload);
+
+ list($result, $status) = $stub->UnaryCall($request)->wait();
+ hardAssert($status->code == Grpc\STATUS_OK, 'Call did not complete successfully');
+ hardAssert($result != null, 'Call returned a null response');
+ $payload = $result->getPayload();
+ hardAssert($payload->getType() == grpc\testing\PayloadType::COMPRESSABLE,
+ 'Payload had the wrong type');
+ hardAssert(strlen($payload->getBody()) == $response_len,
+ 'Payload had the wrong length');
+ hardAssert($payload->getBody() == str_repeat("\0", $response_len),
+ 'Payload had the wrong content');
+}
+
+/**
+ * Run the client_streaming test.
+ * Not tested against any server as of 2014-12-04.
+ * @param $stub Stub object that has service methods
+ */
+function clientStreaming($stub) {
+ $request_lengths = array(27182, 8, 1828, 45904);
+
+ $requests = array_map(
+ function($length) {
+ $request = new grpc\testing\StreamingInputCallRequest();
+ $payload = new grpc\testing\Payload();
+ $payload->setBody(str_repeat("\0", $length));
+ $request->setPayload($payload);
+ return $request;
+ }, $request_lengths);
+
+ list($result, $status) = $stub->StreamingInputCall($requests)->wait();
+ hardAssert($status->code == Grpc\STATUS_OK, 'Call did not complete successfully');
+ hardAssert($result->getAggregatedPayloadSize() == 74922,
+ 'aggregated_payload_size was incorrect');
+}
+
+/**
+ * Run the server_streaming test.
+ * Not tested against any server as of 2014-12-04.
+ * @param $stub Stub object that has service methods.
+ */
+function serverStreaming($stub) {
+ $sizes = array(31415, 9, 2653, 58979);
+
+ $request = new grpc\testing\StreamingOutputCallRequest();
+ $request->setResponseType(grpc\testing\PayloadType::COMPRESSABLE);
+ foreach($sizes as $size) {
+ $response_parameters = new grpc\testing\ResponseParameters();
+ $response_parameters->setSize($size);
+ $request->addResponseParameters($response_parameters);
+ }
+
+ $call = $stub->StreamingOutputCall($request);
+ hardAssert($call->getStatus()->code == Grpc\STATUS_OK,
+ 'Call did not complete successfully');
+ $i = 0;
+ foreach($call->responses() as $value) {
+ hardAssert($i < 4, 'Too many responses');
+ $payload = $value->getPayload();
+ hardAssert($payload->getType() == grpc\testing\PayloadType::COMPRESSABLE,
+ 'Payload ' . $i . ' had the wrong type');
+ hardAssert(strlen($payload->getBody()) == $sizes[$i],
+ 'Response ' . $i . ' had the wrong length');
+ }
+}
+
+/**
+ * Run the ping_pong test.
+ * Not tested against any server as of 2014-12-04.
+ * @param $stub Stub object that has service methods.
+ */
+function pingPong($stub) {
+ $request_lengths = array(27182, 8, 1828, 45904);
+ $response_lengths = array(31415, 9, 2653, 58979);
+
+ $call = $stub->FullDuplexCall();
+ for($i = 0; $i < 4; $i++) {
+ $request = new grpc\testing\StreamingOutputCallRequest();
+ $request->setResponseType(grpc\testing\PayloadType::COMPRESSABLE);
+ $response_parameters = new grpc\testing\ResponseParameters();
+ $response_parameters->setSize($response_lengths[$i]);
+ $request->addResponseParameters($response_parameters);
+ $payload = new grpc\testing\Payload();
+ $payload->setBody(str_repeat("\0", $request_lengths[$i]));
+ $request->setPayload($payload);
+
+ $call->write($request);
+ $response = $call->read();
+
+ hardAssert($response != null, 'Server returned too few responses');
+ $payload = $response->getPayload();
+ hardAssert($payload->getType() == grpc\testing\PayloadType::COMPRESSABLE,
+ 'Payload ' . $i . ' had the wrong type');
+ hardAssert(strlen($payload->getBody()) == $response_lengths[$i],
+ 'Payload ' . $i . ' had the wrong length');
+ }
+ $call->writesDone();
+ hardAssert($call->read() == null, 'Server returned too many responses');
+ hardAssert($call->getStatus()->code == Grpc\STATUS_OK,
+ 'Call did not complete successfully');
+}
+
+$args = getopt('', array('server_host:', 'server_port:', 'test_case:'));
+if (!array_key_exists('server_host', $args) ||
+ !array_key_exists('server_port', $args) ||
+ !array_key_exists('test_case', $args)) {
+ throw new Exception('Missing argument');
+}
+
+$server_address = $args['server_host'] . ':' . $args['server_port'];
+
+$credentials = Grpc\Credentials::createSsl(
+ file_get_contents(dirname(__FILE__) . '/../data/ca.pem'));
+$stub = new grpc\testing\TestServiceClient(
+ $server_address,
+ [
+ 'grpc.ssl_target_name_override' => 'foo.test.google.com',
+ 'credentials' => $credentials
+ ]);
+
+echo "Connecting to $server_address\n";
+echo "Running test case $args[test_case]\n";
+
+switch($args['test_case']) {
+ case 'empty_unary':
+ emptyUnary($stub);
+ break;
+ case 'large_unary':
+ largeUnary($stub);
+ break;
+ case 'client_streaming':
+ clientStreaming($stub);
+ break;
+ case 'server_streaming':
+ serverStreaming($stub);
+ break;
+ case 'ping_pong':
+ pingPong($stub);
+ break;
+} \ No newline at end of file
diff --git a/src/php/tests/interop/message_set.php b/src/php/tests/interop/message_set.php
new file mode 100755
index 0000000000..c35c6d74b2
--- /dev/null
+++ b/src/php/tests/interop/message_set.php
@@ -0,0 +1,26 @@
+<?php
+// DO NOT EDIT! Generated by Protobuf-PHP protoc plugin 1.0
+// Source: net/proto2/bridge/proto/message_set.proto
+// Date: 2014-12-03 22:02:20
+
+namespace proto2\bridge {
+
+ class MessageSet extends \DrSlump\Protobuf\Message {
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'proto2.bridge.MessageSet');
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+ }
+}
+
diff --git a/src/php/tests/interop/messages.php b/src/php/tests/interop/messages.php
new file mode 100755
index 0000000000..beaec7c0d8
--- /dev/null
+++ b/src/php/tests/interop/messages.php
@@ -0,0 +1,1011 @@
+<?php
+// DO NOT EDIT! Generated by Protobuf-PHP protoc plugin 1.0
+// Source: third_party/stubby/testing/proto/messages.proto
+// Date: 2014-12-03 22:02:20
+
+namespace grpc\testing {
+
+ class PayloadType extends \DrSlump\Protobuf\Enum {
+ const COMPRESSABLE = 0;
+ const UNCOMPRESSABLE = 1;
+ const RANDOM = 2;
+ }
+}
+namespace grpc\testing {
+
+ class Payload extends \DrSlump\Protobuf\Message {
+
+ /** @var int - \grpc\testing\PayloadType */
+ public $type = null;
+
+ /** @var string */
+ public $body = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.Payload');
+
+ // OPTIONAL ENUM type = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "type";
+ $f->type = \DrSlump\Protobuf::TYPE_ENUM;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\PayloadType';
+ $descriptor->addField($f);
+
+ // OPTIONAL BYTES body = 2
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 2;
+ $f->name = "body";
+ $f->type = \DrSlump\Protobuf::TYPE_BYTES;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <type> has a value
+ *
+ * @return boolean
+ */
+ public function hasType(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <type> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function clearType(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <type> value
+ *
+ * @return int - \grpc\testing\PayloadType
+ */
+ public function getType(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <type> value
+ *
+ * @param int - \grpc\testing\PayloadType $value
+ * @return \grpc\testing\Payload
+ */
+ public function setType( $value){
+ return $this->_set(1, $value);
+ }
+
+ /**
+ * Check if <body> has a value
+ *
+ * @return boolean
+ */
+ public function hasBody(){
+ return $this->_has(2);
+ }
+
+ /**
+ * Clear <body> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function clearBody(){
+ return $this->_clear(2);
+ }
+
+ /**
+ * Get <body> value
+ *
+ * @return string
+ */
+ public function getBody(){
+ return $this->_get(2);
+ }
+
+ /**
+ * Set <body> value
+ *
+ * @param string $value
+ * @return \grpc\testing\Payload
+ */
+ public function setBody( $value){
+ return $this->_set(2, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class SimpleRequest extends \DrSlump\Protobuf\Message {
+
+ /** @var int - \grpc\testing\PayloadType */
+ public $response_type = null;
+
+ /** @var int */
+ public $response_size = null;
+
+ /** @var \grpc\testing\Payload */
+ public $payload = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.SimpleRequest');
+
+ // OPTIONAL ENUM response_type = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "response_type";
+ $f->type = \DrSlump\Protobuf::TYPE_ENUM;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\PayloadType';
+ $descriptor->addField($f);
+
+ // OPTIONAL INT32 response_size = 2
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 2;
+ $f->name = "response_size";
+ $f->type = \DrSlump\Protobuf::TYPE_INT32;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ // OPTIONAL MESSAGE payload = 3
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 3;
+ $f->name = "payload";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\Payload';
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <response_type> has a value
+ *
+ * @return boolean
+ */
+ public function hasResponseType(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <response_type> value
+ *
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function clearResponseType(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <response_type> value
+ *
+ * @return int - \grpc\testing\PayloadType
+ */
+ public function getResponseType(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <response_type> value
+ *
+ * @param int - \grpc\testing\PayloadType $value
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function setResponseType( $value){
+ return $this->_set(1, $value);
+ }
+
+ /**
+ * Check if <response_size> has a value
+ *
+ * @return boolean
+ */
+ public function hasResponseSize(){
+ return $this->_has(2);
+ }
+
+ /**
+ * Clear <response_size> value
+ *
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function clearResponseSize(){
+ return $this->_clear(2);
+ }
+
+ /**
+ * Get <response_size> value
+ *
+ * @return int
+ */
+ public function getResponseSize(){
+ return $this->_get(2);
+ }
+
+ /**
+ * Set <response_size> value
+ *
+ * @param int $value
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function setResponseSize( $value){
+ return $this->_set(2, $value);
+ }
+
+ /**
+ * Check if <payload> has a value
+ *
+ * @return boolean
+ */
+ public function hasPayload(){
+ return $this->_has(3);
+ }
+
+ /**
+ * Clear <payload> value
+ *
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function clearPayload(){
+ return $this->_clear(3);
+ }
+
+ /**
+ * Get <payload> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function getPayload(){
+ return $this->_get(3);
+ }
+
+ /**
+ * Set <payload> value
+ *
+ * @param \grpc\testing\Payload $value
+ * @return \grpc\testing\SimpleRequest
+ */
+ public function setPayload(\grpc\testing\Payload $value){
+ return $this->_set(3, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class SimpleResponse extends \DrSlump\Protobuf\Message {
+
+ /** @var \grpc\testing\Payload */
+ public $payload = null;
+
+ /** @var int */
+ public $effective_gaia_user_id = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.SimpleResponse');
+
+ // OPTIONAL MESSAGE payload = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "payload";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\Payload';
+ $descriptor->addField($f);
+
+ // OPTIONAL INT64 effective_gaia_user_id = 2
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 2;
+ $f->name = "effective_gaia_user_id";
+ $f->type = \DrSlump\Protobuf::TYPE_INT64;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <payload> has a value
+ *
+ * @return boolean
+ */
+ public function hasPayload(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <payload> value
+ *
+ * @return \grpc\testing\SimpleResponse
+ */
+ public function clearPayload(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <payload> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function getPayload(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <payload> value
+ *
+ * @param \grpc\testing\Payload $value
+ * @return \grpc\testing\SimpleResponse
+ */
+ public function setPayload(\grpc\testing\Payload $value){
+ return $this->_set(1, $value);
+ }
+
+ /**
+ * Check if <effective_gaia_user_id> has a value
+ *
+ * @return boolean
+ */
+ public function hasEffectiveGaiaUserId(){
+ return $this->_has(2);
+ }
+
+ /**
+ * Clear <effective_gaia_user_id> value
+ *
+ * @return \grpc\testing\SimpleResponse
+ */
+ public function clearEffectiveGaiaUserId(){
+ return $this->_clear(2);
+ }
+
+ /**
+ * Get <effective_gaia_user_id> value
+ *
+ * @return int
+ */
+ public function getEffectiveGaiaUserId(){
+ return $this->_get(2);
+ }
+
+ /**
+ * Set <effective_gaia_user_id> value
+ *
+ * @param int $value
+ * @return \grpc\testing\SimpleResponse
+ */
+ public function setEffectiveGaiaUserId( $value){
+ return $this->_set(2, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class SimpleContext extends \DrSlump\Protobuf\Message {
+
+ /** @var string */
+ public $value = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.SimpleContext');
+
+ // OPTIONAL STRING value = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "value";
+ $f->type = \DrSlump\Protobuf::TYPE_STRING;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <value> has a value
+ *
+ * @return boolean
+ */
+ public function hasValue(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <value> value
+ *
+ * @return \grpc\testing\SimpleContext
+ */
+ public function clearValue(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <value> value
+ *
+ * @return string
+ */
+ public function getValue(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <value> value
+ *
+ * @param string $value
+ * @return \grpc\testing\SimpleContext
+ */
+ public function setValue( $value){
+ return $this->_set(1, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class StreamingInputCallRequest extends \DrSlump\Protobuf\Message {
+
+ /** @var \grpc\testing\Payload */
+ public $payload = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.StreamingInputCallRequest');
+
+ // OPTIONAL MESSAGE payload = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "payload";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\Payload';
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <payload> has a value
+ *
+ * @return boolean
+ */
+ public function hasPayload(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <payload> value
+ *
+ * @return \grpc\testing\StreamingInputCallRequest
+ */
+ public function clearPayload(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <payload> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function getPayload(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <payload> value
+ *
+ * @param \grpc\testing\Payload $value
+ * @return \grpc\testing\StreamingInputCallRequest
+ */
+ public function setPayload(\grpc\testing\Payload $value){
+ return $this->_set(1, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class StreamingInputCallResponse extends \DrSlump\Protobuf\Message {
+
+ /** @var int */
+ public $aggregated_payload_size = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.StreamingInputCallResponse');
+
+ // OPTIONAL INT32 aggregated_payload_size = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "aggregated_payload_size";
+ $f->type = \DrSlump\Protobuf::TYPE_INT32;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <aggregated_payload_size> has a value
+ *
+ * @return boolean
+ */
+ public function hasAggregatedPayloadSize(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <aggregated_payload_size> value
+ *
+ * @return \grpc\testing\StreamingInputCallResponse
+ */
+ public function clearAggregatedPayloadSize(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <aggregated_payload_size> value
+ *
+ * @return int
+ */
+ public function getAggregatedPayloadSize(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <aggregated_payload_size> value
+ *
+ * @param int $value
+ * @return \grpc\testing\StreamingInputCallResponse
+ */
+ public function setAggregatedPayloadSize( $value){
+ return $this->_set(1, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class ResponseParameters extends \DrSlump\Protobuf\Message {
+
+ /** @var int */
+ public $size = null;
+
+ /** @var int */
+ public $interval_us = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.ResponseParameters');
+
+ // OPTIONAL INT32 size = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "size";
+ $f->type = \DrSlump\Protobuf::TYPE_INT32;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ // OPTIONAL INT32 interval_us = 2
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 2;
+ $f->name = "interval_us";
+ $f->type = \DrSlump\Protobuf::TYPE_INT32;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <size> has a value
+ *
+ * @return boolean
+ */
+ public function hasSize(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <size> value
+ *
+ * @return \grpc\testing\ResponseParameters
+ */
+ public function clearSize(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <size> value
+ *
+ * @return int
+ */
+ public function getSize(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <size> value
+ *
+ * @param int $value
+ * @return \grpc\testing\ResponseParameters
+ */
+ public function setSize( $value){
+ return $this->_set(1, $value);
+ }
+
+ /**
+ * Check if <interval_us> has a value
+ *
+ * @return boolean
+ */
+ public function hasIntervalUs(){
+ return $this->_has(2);
+ }
+
+ /**
+ * Clear <interval_us> value
+ *
+ * @return \grpc\testing\ResponseParameters
+ */
+ public function clearIntervalUs(){
+ return $this->_clear(2);
+ }
+
+ /**
+ * Get <interval_us> value
+ *
+ * @return int
+ */
+ public function getIntervalUs(){
+ return $this->_get(2);
+ }
+
+ /**
+ * Set <interval_us> value
+ *
+ * @param int $value
+ * @return \grpc\testing\ResponseParameters
+ */
+ public function setIntervalUs( $value){
+ return $this->_set(2, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class StreamingOutputCallRequest extends \DrSlump\Protobuf\Message {
+
+ /** @var int - \grpc\testing\PayloadType */
+ public $response_type = null;
+
+ /** @var \grpc\testing\ResponseParameters[] */
+ public $response_parameters = array();
+
+ /** @var \grpc\testing\Payload */
+ public $payload = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.StreamingOutputCallRequest');
+
+ // OPTIONAL ENUM response_type = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "response_type";
+ $f->type = \DrSlump\Protobuf::TYPE_ENUM;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\PayloadType';
+ $descriptor->addField($f);
+
+ // REPEATED MESSAGE response_parameters = 2
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 2;
+ $f->name = "response_parameters";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_REPEATED;
+ $f->reference = '\grpc\testing\ResponseParameters';
+ $descriptor->addField($f);
+
+ // OPTIONAL MESSAGE payload = 3
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 3;
+ $f->name = "payload";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\Payload';
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <response_type> has a value
+ *
+ * @return boolean
+ */
+ public function hasResponseType(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <response_type> value
+ *
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function clearResponseType(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <response_type> value
+ *
+ * @return int - \grpc\testing\PayloadType
+ */
+ public function getResponseType(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <response_type> value
+ *
+ * @param int - \grpc\testing\PayloadType $value
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function setResponseType( $value){
+ return $this->_set(1, $value);
+ }
+
+ /**
+ * Check if <response_parameters> has a value
+ *
+ * @return boolean
+ */
+ public function hasResponseParameters(){
+ return $this->_has(2);
+ }
+
+ /**
+ * Clear <response_parameters> value
+ *
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function clearResponseParameters(){
+ return $this->_clear(2);
+ }
+
+ /**
+ * Get <response_parameters> value
+ *
+ * @param int $idx
+ * @return \grpc\testing\ResponseParameters
+ */
+ public function getResponseParameters($idx = NULL){
+ return $this->_get(2, $idx);
+ }
+
+ /**
+ * Set <response_parameters> value
+ *
+ * @param \grpc\testing\ResponseParameters $value
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function setResponseParameters(\grpc\testing\ResponseParameters $value, $idx = NULL){
+ return $this->_set(2, $value, $idx);
+ }
+
+ /**
+ * Get all elements of <response_parameters>
+ *
+ * @return \grpc\testing\ResponseParameters[]
+ */
+ public function getResponseParametersList(){
+ return $this->_get(2);
+ }
+
+ /**
+ * Add a new element to <response_parameters>
+ *
+ * @param \grpc\testing\ResponseParameters $value
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function addResponseParameters(\grpc\testing\ResponseParameters $value){
+ return $this->_add(2, $value);
+ }
+
+ /**
+ * Check if <payload> has a value
+ *
+ * @return boolean
+ */
+ public function hasPayload(){
+ return $this->_has(3);
+ }
+
+ /**
+ * Clear <payload> value
+ *
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function clearPayload(){
+ return $this->_clear(3);
+ }
+
+ /**
+ * Get <payload> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function getPayload(){
+ return $this->_get(3);
+ }
+
+ /**
+ * Set <payload> value
+ *
+ * @param \grpc\testing\Payload $value
+ * @return \grpc\testing\StreamingOutputCallRequest
+ */
+ public function setPayload(\grpc\testing\Payload $value){
+ return $this->_set(3, $value);
+ }
+ }
+}
+
+namespace grpc\testing {
+
+ class StreamingOutputCallResponse extends \DrSlump\Protobuf\Message {
+
+ /** @var \grpc\testing\Payload */
+ public $payload = null;
+
+
+ /** @var \Closure[] */
+ protected static $__extensions = array();
+
+ public static function descriptor()
+ {
+ $descriptor = new \DrSlump\Protobuf\Descriptor(__CLASS__, 'grpc.testing.StreamingOutputCallResponse');
+
+ // OPTIONAL MESSAGE payload = 1
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 1;
+ $f->name = "payload";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\Payload';
+ $descriptor->addField($f);
+
+ foreach (self::$__extensions as $cb) {
+ $descriptor->addField($cb(), true);
+ }
+
+ return $descriptor;
+ }
+
+ /**
+ * Check if <payload> has a value
+ *
+ * @return boolean
+ */
+ public function hasPayload(){
+ return $this->_has(1);
+ }
+
+ /**
+ * Clear <payload> value
+ *
+ * @return \grpc\testing\StreamingOutputCallResponse
+ */
+ public function clearPayload(){
+ return $this->_clear(1);
+ }
+
+ /**
+ * Get <payload> value
+ *
+ * @return \grpc\testing\Payload
+ */
+ public function getPayload(){
+ return $this->_get(1);
+ }
+
+ /**
+ * Set <payload> value
+ *
+ * @param \grpc\testing\Payload $value
+ * @return \grpc\testing\StreamingOutputCallResponse
+ */
+ public function setPayload(\grpc\testing\Payload $value){
+ return $this->_set(1, $value);
+ }
+ }
+}
+
+namespace {
+ \proto2\bridge\MessageSet::extension(function(){
+ // OPTIONAL MESSAGE grpc\testing\SimpleContext\message_set_extension = 71139615
+ $f = new \DrSlump\Protobuf\Field();
+ $f->number = 71139615;
+ $f->name = "grpc\testing\SimpleContext\message_set_extension";
+ $f->type = \DrSlump\Protobuf::TYPE_MESSAGE;
+ $f->rule = \DrSlump\Protobuf::RULE_OPTIONAL;
+ $f->reference = '\grpc\testing\SimpleContext';
+ return $f;
+ });
+} \ No newline at end of file
diff --git a/src/php/tests/interop/test.php b/src/php/tests/interop/test.php
new file mode 100755
index 0000000000..fe6d0fb6c4
--- /dev/null
+++ b/src/php/tests/interop/test.php
@@ -0,0 +1,52 @@
+<?php
+// DO NOT EDIT! Generated by Protobuf-PHP protoc plugin 1.0
+// Source: third_party/stubby/testing/proto/test.proto
+// Date: 2014-12-03 22:02:20
+
+namespace grpc\testing {
+
+ class TestServiceClient extends \Grpc\BaseStub {
+ /**
+ * @param proto2\EmptyMessage $input
+ * @return proto2\EmptyMessage
+ */
+ public function EmptyCall(\proto2\EmptyMessage $argument, $metadata = array()) {
+ return $this->_simpleRequest('/TestService/EmptyCall', $argument, '\proto2\EmptyMessage::deserialize', $metadata);
+ }
+ /**
+ * @param grpc\testing\SimpleRequest $input
+ * @return grpc\testing\SimpleResponse
+ */
+ public function UnaryCall(\grpc\testing\SimpleRequest $argument, $metadata = array()) {
+ return $this->_simpleRequest('/TestService/UnaryCall', $argument, '\grpc\testing\SimpleResponse::deserialize', $metadata);
+ }
+ /**
+ * @param grpc\testing\StreamingOutputCallRequest $input
+ * @return grpc\testing\StreamingOutputCallResponse
+ */
+ public function StreamingOutputCall($argument, $metadata = array()) {
+ return $this->_serverStreamRequest('/TestService/StreamingOutputCall', $argument, '\grpc\testing\StreamingOutputCallResponse::deserialize', $metadata);
+ }
+ /**
+ * @param grpc\testing\StreamingInputCallRequest $input
+ * @return grpc\testing\StreamingInputCallResponse
+ */
+ public function StreamingInputCall($arguments, $metadata = array()) {
+ return $this->_clientStreamRequest('/TestService/StreamingInputCall', $arguments, '\grpc\testing\StreamingInputCallResponse::deserialize', $metadata);
+ }
+ /**
+ * @param grpc\testing\StreamingOutputCallRequest $input
+ * @return grpc\testing\StreamingOutputCallResponse
+ */
+ public function FullDuplexCall($metadata = array()) {
+ return $this->_bidiRequest('/TestService/FullDuplexCall', '\grpc\testing\StreamingOutputCallResponse::deserialize', $metadata);
+ }
+ /**
+ * @param grpc\testing\StreamingOutputCallRequest $input
+ * @return grpc\testing\StreamingOutputCallResponse
+ */
+ public function HalfDuplexCall($metadata = array()) {
+ return $this->_bidiRequest('/TestService/HalfDuplexCall', '\grpc\testing\StreamingOutputCallResponse::deserialize', $metadata);
+ }
+ }
+}