re-adds CartService definition and reference (open-telemetry#145)

docker-compose.yml

@@ -62,6 +62,7 @@ services:
       - REDIS_ADDR
       - OTEL_EXPORTER_OTLP_ENDPOINT
       - OTEL_RESOURCE_ATTRIBUTES=service.name=cartservice
+      - ASPNETCORE_URLS=http://*:${CART_SERVICE_PORT}
     depends_on:
       - redis-cart
       - otelcol

src/cartservice/src/.dockerignore

@@ -0,0 +1,6 @@
+**/*.sh
+**/*.bat
+**/bin/
+**/obj/
+**/out/
+Dockerfile*

src/cartservice/src/Dockerfile

@@ -31,7 +31,6 @@ FROM mcr.microsoft.com/dotnet/runtime-deps:6.0.5-alpine3.15-amd64
 WORKDIR /usr/src/app/
 COPY --from=builder /cartservice/ ./
 
-ENV ASPNETCORE_URLS http://*:${CART_SERVICE_PORT}
 EXPOSE ${CART_SERVICE_PORT}
 
 ENTRYPOINT [ "./cartservice" ]

src/cartservice/src/Startup.cs

@@ -7,7 +7,7 @@
 using Microsoft.Extensions.Diagnostics.HealthChecks;
 using Microsoft.Extensions.Hosting;
 using cartservice.cartstore;
-using Hipstershop;
+using cartservice.services;
 using OpenTelemetry.Trace;
 
 namespace cartservice;
@@ -66,7 +66,7 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
 
         app.UseEndpoints(endpoints =>
         {
-            endpoints.MapGrpcService<Hipstershop.Cart>();
+            endpoints.MapGrpcService<CartService>();
             endpoints.MapGrpcHealthChecksService();
 
             endpoints.MapGet("/", async context =>

src/cartservice/src/services/CartService.cs

@@ -0,0 +1,49 @@
+// Copyright 2020 Google LLC
+//
+// 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.
+
+using System.Threading.Tasks;
+using Grpc.Core;
+using cartservice.cartstore;
+using Hipstershop;
+
+namespace cartservice.services
+{
+    public class CartService : Hipstershop.CartService.CartServiceBase
+    {
+        private readonly static Empty Empty = new Empty();
+        private readonly ICartStore _cartStore;
+
+        public CartService(ICartStore cartStore)
+        {
+            _cartStore = cartStore;
+        }
+
+        public async override Task<Empty> AddItem(AddItemRequest request, ServerCallContext context)
+        {
+            await _cartStore.AddItemAsync(request.UserId, request.Item.ProductId, request.Item.Quantity);
+            return Empty;
+        }
+
+        public override Task<Cart> GetCart(GetCartRequest request, ServerCallContext context)
+        {
+            return _cartStore.GetCartAsync(request.UserId);
+        }
+
+        public async override Task<Empty> EmptyCart(EmptyCartRequest request, ServerCallContext context)
+        {
+            await _cartStore.EmptyCartAsync(request.UserId);
+            return Empty;
+        }
+    }
+}