diff --git a/src/recommendationservice/client.py b/src/recommendationservice/client.py new file mode 100644 index 0000000..b59198c --- /dev/null +++ b/src/recommendationservice/client.py @@ -0,0 +1,12 @@ +import grpc +import demo_pb2 +import demo_pb2_grpc + +channel = grpc.insecure_channel('localhost:8081') +stub = demo_pb2_grpc.RecommendationServiceStub(channel) + +request = demo_pb2.ListRecommendationsRequest(user_id="test", product_ids=["test"]) + +response = stub.ListRecommendations(request) + +print(response) diff --git a/src/recommendationservice/demo_pb2.pyc b/src/recommendationservice/demo_pb2.pyc new file mode 100644 index 0000000..f0afb0e Binary files /dev/null and b/src/recommendationservice/demo_pb2.pyc differ diff --git a/src/recommendationservice/demo_pb2_grpc.pyc b/src/recommendationservice/demo_pb2_grpc.pyc new file mode 100644 index 0000000..a713fd9 Binary files /dev/null and b/src/recommendationservice/demo_pb2_grpc.pyc differ diff --git a/src/recommendationservice/recommendation_server.py b/src/recommendationservice/recommendation_server.py index 7007604..b96bd28 100644 --- a/src/recommendationservice/recommendation_server.py +++ b/src/recommendationservice/recommendation_server.py @@ -6,7 +6,19 @@ import time class RecommendationService(demo_pb2_grpc.RecommendationServiceServicer): def ListRecommendations(self, request, context): + print("handling request") response = demo_pb2.ListRecommendationsResponse() + prod_list = [] + for i in range(3): + this_price = demo_pb2.MoneyAmount(decimal=i, + fractional=i) + this_prod = demo_pb2.Product(id=i, + name="test-"+str(i), + description="test product", + picture="test image", + price_usd=this_price) + prod_list.append(this_prod) + response.products.extend(prod_list) return response if __name__ == "__main__": @@ -17,13 +29,13 @@ if __name__ == "__main__": demo_pb2_grpc.add_RecommendationServiceServicer_to_server(RecommendationService(), server) # start server - print("Listening on port 8080") - server.add_insecure_port('[::]:8080') + print("Listening on port 8081") + server.add_insecure_port('[::]:8081') server.start() # keep alive try: while True: - time.sleep(86400) + time.sleep(10000) except KeyboardInterrupt: server.stop(0)