| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 | # Copyright 2017 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."""The Python implementation of the GRPC helloworld.Greeter server."""from concurrent import futuresimport timeimport loggingimport grpcimport helloworld_pb2import helloworld_pb2_grpcfrom request_header_validator_interceptor import RequestHeaderValidatorInterceptor_ONE_DAY_IN_SECONDS = 60 * 60 * 24class Greeter(helloworld_pb2_grpc.GreeterServicer):    def SayHello(self, request, context):        return helloworld_pb2.HelloReply(message='Hello, %s!' % request.name)def serve():    header_validator = RequestHeaderValidatorInterceptor(        'one-time-password', '42', grpc.StatusCode.UNAUTHENTICATED,        'Access denied!')    server = grpc.server(        futures.ThreadPoolExecutor(max_workers=10),        interceptors=(header_validator,))    helloworld_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server)    server.add_insecure_port('[::]:50051')    server.start()    try:        while True:            time.sleep(_ONE_DAY_IN_SECONDS)    except KeyboardInterrupt:        server.stop(0)if __name__ == '__main__':    logging.basicConfig()    serve()
 |