The C based gRPC (C++, Python, Ruby, Objective-C, PHP, C#)
https://grpc.io/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
166 lines
4.5 KiB
166 lines
4.5 KiB
<?php |
|
/* |
|
* |
|
* Copyright 2015 gRPC authors. |
|
* |
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
* you may not use this file except in compliance with the License. |
|
* You may obtain a copy of the License at |
|
* |
|
* http://www.apache.org/licenses/LICENSE-2.0 |
|
* |
|
* Unless required by applicable law or agreed to in writing, software |
|
* distributed under the License is distributed on an "AS IS" BASIS, |
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
* See the License for the specific language governing permissions and |
|
* limitations under the License. |
|
* |
|
*/ |
|
|
|
namespace Grpc; |
|
|
|
/** |
|
* Class AbstractCall. |
|
* @package Grpc |
|
*/ |
|
abstract class AbstractCall |
|
{ |
|
/** |
|
* @var Call |
|
*/ |
|
protected $call; |
|
protected $deserialize; |
|
protected $metadata; |
|
protected $trailing_metadata; |
|
|
|
/** |
|
* Create a new Call wrapper object. |
|
* |
|
* @param Channel $channel The channel to communicate on |
|
* @param string $method The method to call on the |
|
* remote server |
|
* @param callback $deserialize A callback function to deserialize |
|
* the response |
|
* @param array $options Call options (optional) |
|
*/ |
|
public function __construct(Channel $channel, |
|
$method, |
|
$deserialize, |
|
array $options = []) |
|
{ |
|
if (array_key_exists('timeout', $options) && |
|
is_numeric($timeout = $options['timeout']) |
|
) { |
|
$now = Timeval::now(); |
|
$delta = new Timeval($timeout); |
|
$deadline = $now->add($delta); |
|
} else { |
|
$deadline = Timeval::infFuture(); |
|
} |
|
$this->call = new Call($channel, $method, $deadline); |
|
$this->deserialize = $deserialize; |
|
$this->metadata = null; |
|
$this->trailing_metadata = null; |
|
if (array_key_exists('call_credentials_callback', $options) && |
|
is_callable($call_credentials_callback = |
|
$options['call_credentials_callback']) |
|
) { |
|
$call_credentials = CallCredentials::createFromPlugin( |
|
$call_credentials_callback |
|
); |
|
$this->call->setCredentials($call_credentials); |
|
} |
|
} |
|
|
|
/** |
|
* @return mixed The metadata sent by the server |
|
*/ |
|
public function getMetadata() |
|
{ |
|
return $this->metadata; |
|
} |
|
|
|
/** |
|
* @return mixed The trailing metadata sent by the server |
|
*/ |
|
public function getTrailingMetadata() |
|
{ |
|
return $this->trailing_metadata; |
|
} |
|
|
|
/** |
|
* @return string The URI of the endpoint |
|
*/ |
|
public function getPeer() |
|
{ |
|
return $this->call->getPeer(); |
|
} |
|
|
|
/** |
|
* Cancels the call. |
|
*/ |
|
public function cancel() |
|
{ |
|
$this->call->cancel(); |
|
} |
|
|
|
/** |
|
* Serialize a message to the protobuf binary format. |
|
* |
|
* @param mixed $data The Protobuf message |
|
* |
|
* @return string The protobuf binary format |
|
*/ |
|
protected function _serializeMessage($data) |
|
{ |
|
// Proto3 implementation |
|
if (method_exists($data, 'encode')) { |
|
return $data->encode(); |
|
} elseif (method_exists($data, 'serializeToString')) { |
|
return $data->serializeToString(); |
|
} |
|
|
|
// Protobuf-PHP implementation |
|
return $data->serialize(); |
|
} |
|
|
|
/** |
|
* Deserialize a response value to an object. |
|
* |
|
* @param string $value The binary value to deserialize |
|
* |
|
* @return mixed The deserialized value |
|
*/ |
|
protected function _deserializeResponse($value) |
|
{ |
|
if ($value === null) { |
|
return; |
|
} |
|
|
|
// Proto3 implementation |
|
if (is_array($this->deserialize)) { |
|
list($className, $deserializeFunc) = $this->deserialize; |
|
$obj = new $className(); |
|
if (method_exists($obj, $deserializeFunc)) { |
|
$obj->$deserializeFunc($value); |
|
} else { |
|
$obj->mergeFromString($value); |
|
} |
|
|
|
return $obj; |
|
} |
|
|
|
// Protobuf-PHP implementation |
|
return call_user_func($this->deserialize, $value); |
|
} |
|
|
|
/** |
|
* Set the CallCredentials for the underlying Call. |
|
* |
|
* @param CallCredentials $call_credentials The CallCredentials object |
|
*/ |
|
public function setCallCredentials($call_credentials) |
|
{ |
|
$this->call->setCredentials($call_credentials); |
|
} |
|
}
|
|
|