add php math_server (#26201)

4 years ago · bba425fa11
parent 34ea49a9b1
commit bba425fa11
3 changed files with 265 additions and 1 deletions
--- a/src/php/bin/generate_proto_php.sh
+++ b/src/php/bin/generate_proto_php.sh
@ -23,7 +23,7 @@ PLUGIN=protoc-gen-grpc=bazel-bin/src/compiler/grpc_php_plugin

 $PROTOC --proto_path=src/proto/math \
       --php_out=src/php/tests/generated_code \
-       --grpc_out=src/php/tests/generated_code \
+       --grpc_out=generate_server:src/php/tests/generated_code \
       --plugin=$PLUGIN \
       src/proto/math/math.proto

--- a/src/php/tests/generated_code/Math/MathStub.php
+++ b/src/php/tests/generated_code/Math/MathStub.php
@ -0,0 +1,129 @@
+<?php
+// GENERATED CODE -- DO NOT EDIT!
+
+// Original file comments:
+// 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 Math;
+
+/**
+ */
+class MathStub {
+
+    /**
+     * Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient
+     * and remainder.
+     * @param \Math\DivArgs $request client request
+     * @param \Grpc\ServerContext $context server request context
+     * @return \Math\DivReply for response data, null if if error occured
+     *     initial metadata (if any) and status (if not ok) should be set to $context
+     */
+    public function Div(
+        \Math\DivArgs $request,
+        \Grpc\ServerContext $context
+    ): ?\Math\DivReply {
+        $context->setStatus(\Grpc\Status::unimplemented());
+        return null;
+    }
+
+    /**
+     * DivMany accepts an arbitrary number of division args from the client stream
+     * and sends back the results in the reply stream.  The stream continues until
+     * the client closes its end; the server does the same after sending all the
+     * replies.  The stream ends immediately if either end aborts.
+     * @param \Grpc\ServerCallReader $reader read client request data of \Math\DivArgs
+     * @param \Grpc\ServerCallWriter $writer write response data of \Math\DivReply
+     * @param \Grpc\ServerContext $context server request context
+     * @return void
+     */
+    public function DivMany(
+        \Grpc\ServerCallReader $reader,
+        \Grpc\ServerCallWriter $writer,
+        \Grpc\ServerContext $context
+    ): void {
+        $context->setStatus(\Grpc\Status::unimplemented());
+        $writer->finish();
+    }
+
+    /**
+     * Fib generates numbers in the Fibonacci sequence.  If FibArgs.limit > 0, Fib
+     * generates up to limit numbers; otherwise it continues until the call is
+     * canceled.  Unlike Fib above, Fib has no final FibReply.
+     * @param \Math\FibArgs $request client request
+     * @param \Grpc\ServerCallWriter $writer write response data of \Math\Num
+     * @param \Grpc\ServerContext $context server request context
+     * @return void
+     */
+    public function Fib(
+        \Math\FibArgs $request,
+        \Grpc\ServerCallWriter $writer,
+        \Grpc\ServerContext $context
+    ): void {
+        $context->setStatus(\Grpc\Status::unimplemented());
+        $writer->finish();
+    }
+
+    /**
+     * Sum sums a stream of numbers, returning the final result once the stream
+     * is closed.
+     * @param \Grpc\ServerCallReader $reader read client request data of \Math\Num
+     * @param \Grpc\ServerContext $context server request context
+     * @return \Math\Num for response data, null if if error occured
+     *     initial metadata (if any) and status (if not ok) should be set to $context
+     */
+    public function Sum(
+        \Grpc\ServerCallReader $reader,
+        \Grpc\ServerContext $context
+    ): ?\Math\Num {
+        $context->setStatus(\Grpc\Status::unimplemented());
+        return null;
+    }
+
+    /**
+     * Get the method descriptors of the service for server registration
+     *
+     * @return array of \Grpc\MethodDescriptor for the service methods
+     */
+    public final function getMethodDescriptors(): array
+    {
+        return [
+            '/math.Math/Div' => new \Grpc\MethodDescriptor(
+                $this,
+                'Div',
+                '\Math\DivArgs',
+                \Grpc\MethodDescriptor::UNARY_CALL
+            ),
+            '/math.Math/DivMany' => new \Grpc\MethodDescriptor(
+                $this,
+                'DivMany',
+                '\Math\DivArgs',
+                \Grpc\MethodDescriptor::BIDI_STREAMING_CALL
+            ),
+            '/math.Math/Fib' => new \Grpc\MethodDescriptor(
+                $this,
+                'Fib',
+                '\Math\FibArgs',
+                \Grpc\MethodDescriptor::SERVER_STREAMING_CALL
+            ),
+            '/math.Math/Sum' => new \Grpc\MethodDescriptor(
+                $this,
+                'Sum',
+                '\Math\Num',
+                \Grpc\MethodDescriptor::CLIENT_STREAMING_CALL
+            ),
+        ];
+    }
+
+}
--- a/src/php/tests/generated_code/math_server.php
+++ b/src/php/tests/generated_code/math_server.php
@ -0,0 +1,135 @@
+<?php
+/*
+ *
+ * Copyright 2020 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.
+ *
+ */
+
+require dirname(__FILE__) . '/../../lib/Grpc/MethodDescriptor.php';
+require dirname(__FILE__) . '/../../lib/Grpc/Status.php';
+require dirname(__FILE__) . '/../../lib/Grpc/ServerCallReader.php';
+require dirname(__FILE__) . '/../../lib/Grpc/ServerCallWriter.php';
+require dirname(__FILE__) . '/../../lib/Grpc/ServerContext.php';
+require dirname(__FILE__) . '/../../lib/Grpc/RpcServer.php';
+include 'vendor/autoload.php';
+
+class MathService extends Math\MathStub
+{
+    public function Div(
+        \Math\DivArgs $request,
+        \Grpc\ServerContext $context
+    ): ?\Math\DivReply {
+        $dividend = $request->getDividend();
+        $divisor = $request->getDivisor();
+        if ($divisor == 0) {
+            $context->setStatus(
+                \Grpc\Status::status(
+                    \Grpc\STATUS_INVALID_ARGUMENT,
+                    'Cannot divide by zero'
+                )
+            );
+            return null;
+        }
+        usleep(1000); // for GeneratedCodeTest::testTimeout
+        $quotient = intdiv($dividend, $divisor);
+        $remainder = $dividend % $divisor;
+        $reply = new \Math\DivReply([
+            'quotient' => $quotient,
+            'remainder' => $remainder,
+        ]);
+        return $reply;
+    }
+
+    public function DivMany(
+        \Grpc\ServerCallReader $reader,
+        \Grpc\ServerCallWriter $writter,
+        \Grpc\ServerContext $context
+    ): void {
+        while ($divArgs = $reader->read()) {
+            $dividend = $divArgs->getDividend();
+            $divisor = $divArgs->getDivisor();
+            if ($divisor == 0) {
+                $context->setStatus(\Grpc\Status::status(
+                    \Grpc\STATUS_INVALID_ARGUMENT,
+                    'Cannot divide by zero'
+                ));
+                $writter->finish();
+                return;
+            }
+            $quotient = intdiv($dividend, $divisor);
+            $remainder = $dividend % $divisor;
+            $reply = new \Math\DivReply([
+                'quotient' => $quotient,
+                'remainder' => $remainder,
+            ]);
+            $writter->write($reply);
+        }
+        $writter->finish();
+    }
+
+    public function Fib(
+        \Math\FibArgs $request,
+        \Grpc\ServerCallWriter $writter,
+        \Grpc\ServerContext $context
+    ): void {
+        $previous = 0;
+        $current = 1;
+        $limit = $request->getLimit();
+        for ($i = 0; $i < $limit; $i++) {
+            $num = new \Math\Num();
+            $num->setNum($current);
+            $writter->write($num);
+            $next = $previous + $current;
+            $previous = $current;
+            $current = $next;
+        }
+        $writter->finish();
+    }
+
+    /**
+     * Sum sums a stream of numbers, returning the final result once the stream
+     * is closed.
+     * @param \Grpc\ServerCallReader $reader read client request data of \Math\Num
+     * @param \Grpc\ServerContext $context server request context
+     * @return array with [
+     *     \Math\Num, // response data
+     *     optional array = [], // initial metadata
+     *     optional \Grpc\Status = \Grpc\Status::ok // Grpc status
+     * ]
+     */
+    public function Sum(
+        \Grpc\ServerCallReader $reader,
+        \Grpc\ServerContext $context
+    ): ?\Math\Num {
+        $sum = 0;
+        while ($num = $reader->read()) {
+            $sum += $num->getNum();
+        }
+        $reply = new \Math\Num();
+        $reply->setNum($sum);
+        return $reply;
+    }
+}
+
+$server = new \Grpc\RpcServer();
+$server->addHttp2Port('0.0.0.0:50052');
+$server_credentials = Grpc\ServerCredentials::createSsl(
+    null,
+    file_get_contents(dirname(__FILE__) . '/../data/server1.key'),
+    file_get_contents(dirname(__FILE__) . '/../data/server1.pem')
+);
+$server->addSecureHttp2Port('0.0.0.0:50051', $server_credentials);
+$server->handle(new MathService());
+$server->run();