← All changes | includes/sdk/google/grpc/grpc/src/lib/RpcServer.php +10 -10 1.2.2 → 1.4.2 View file →

		@@ -16,9 +16,9 @@
16	16	* See the License for the specific language governing permissions and
17	17	* limitations under the License.
18	18	*
19	19	*/
20		-namespace Dudlewebs\WPMCS\Grpc;
	20	+namespace Dudlewebs\WPMCS\GCP\Grpc;
21	21
22	22	/**
23	23	* This is an experimental and incomplete implementation of gRPC server
24	24	* for PHP. APIs are _definitely_ going to be changed.
		@@ -44,13 +44,13 @@
44	44	*/
45	45	public function handle($service)
46	46	{
47	47	$methodDescriptors = $service->getMethodDescriptors();
48		- $exist_methods = array_intersect_key($this->paths_map, $methodDescriptors);
	48	+ $exist_methods = \array_intersect_key($this->paths_map, $methodDescriptors);
49	49	if (!empty($exist_methods)) {
50		- fwrite(\STDERR, "WARNING: " . 'override already registered methods: ' . implode(', ', array_keys($exist_methods)) . \PHP_EOL);
	50	+ \fwrite(\STDERR, "WARNING: " . 'override already registered methods: ' . \implode(', ', \array_keys($exist_methods)) . \PHP_EOL);
51	51	}
52		- $this->paths_map = array_merge($this->paths_map, $methodDescriptors);
	52	+ $this->paths_map = \array_merge($this->paths_map, $methodDescriptors);
53	53	return $this->paths_map;
54	54	}
55	55	public function run()
56	56	{
		@@ -61,9 +61,9 @@
61	61	$event = $this->waitForNextEvent();
62	62	$full_path = $event->method;
63	63	$context = new ServerContext($event);
64	64	$server_writer = new ServerCallWriter($event->call, $context);
65		- if (!array_key_exists($full_path, $this->paths_map)) {
	65	+ if (!\array_key_exists($full_path, $this->paths_map)) {
66	66	$context->setStatus(Status::unimplemented());
67	67	$server_writer->finish();
68	68	continue;
69	69	}
		@@ -75,9 +75,9 @@
75	75	$context->setStatus(Status::status(STATUS_INTERNAL, $e->getMessage()));
76	76	$server_writer->finish();
77	77	}
78	78	} catch (\Exception $e) {
79		- fwrite(\STDERR, "ERROR: " . $e->getMessage() . \PHP_EOL);
	79	+ \fwrite(\STDERR, "ERROR: " . $e->getMessage() . \PHP_EOL);
80	80	exit(1);
81	81	}
82	82	}
83	83	}
		@@ -86,21 +86,21 @@
86	86	// Dispatch to actual server logic
87	87	switch ($method_desc->call_type) {
88	88	case MethodDescriptor::UNARY_CALL:
89	89	$request = $server_reader->read();
90		- $response = call_user_func(array($method_desc->service, $method_desc->method_name), $request ?? new $method_desc->request_type(), $context);
	90	+ $response = \call_user_func(array($method_desc->service, $method_desc->method_name), $request ?? new $method_desc->request_type(), $context);
91	91	$server_writer->finish($response);
92	92	break;
93	93	case MethodDescriptor::SERVER_STREAMING_CALL:
94	94	$request = $server_reader->read();
95		- call_user_func(array($method_desc->service, $method_desc->method_name), $request ?? new $method_desc->request_type(), $server_writer, $context);
	95	+ \call_user_func(array($method_desc->service, $method_desc->method_name), $request ?? new $method_desc->request_type(), $server_writer, $context);
96	96	break;
97	97	case MethodDescriptor::CLIENT_STREAMING_CALL:
98		- $response = call_user_func(array($method_desc->service, $method_desc->method_name), $server_reader, $context);
	98	+ $response = \call_user_func(array($method_desc->service, $method_desc->method_name), $server_reader, $context);
99	99	$server_writer->finish($response);
100	100	break;
101	101	case MethodDescriptor::BIDI_STREAMING_CALL:
102		- call_user_func(array($method_desc->service, $method_desc->method_name), $server_reader, $server_writer, $context);
	102	+ \call_user_func(array($method_desc->service, $method_desc->method_name), $server_reader, $server_writer, $context);
103	103	break;
104	104	default:
105	105	throw new \Exception();
106	106	}