Adapt Locations.api to nosql db

Author: ramon-tomas-c

docker-compose.override.yml

@@ -83,6 +83,10 @@ services:
     ports:
       - "5433:1433"
 
+  nosql.data:
+    ports:
+      - "27017:27017"
+
   webstatus:
     environment:
       - ASPNETCORE_ENVIRONMENT=Development
@@ -100,7 +104,8 @@ services:
     environment:
       - ASPNETCORE_ENVIRONMENT=Development
       - ASPNETCORE_URLS=http://0.0.0.0:80
-      - ConnectionString=Server=sql.data;Database=Microsoft.eShopOnContainers.Services.LocationsDb;User Id=sa;Password=Pass@word
+      - ConnectionString=mongodb://nosql.data
+      - Database=LocationsDb
       - identityUrl=http://identity.api              #Local: You need to open your local dev-machine firewall at range 5100-5105.  at range 5100-5105. 
       - EventBusConnection=rabbitmq
     ports:

docker-compose.yml

@@ -59,6 +59,9 @@ services:
   sql.data:
     image: microsoft/mssql-server-linux
 
+  nosql.data:
+    image: mongo
+
   basket.data:
     image: redis
     ports:
@@ -81,4 +84,4 @@ services:
       context: ./src/Services/Location/Locations.API
       dockerfile: Dockerfile
     depends_on:
-      - sql.data
+      - nosql.data

src/Services/Location/Locations.API/Controllers/LocationsController.cs

@@ -20,6 +20,24 @@ public LocationsController(ILocationsService locationsService, IIdentityService
             _identityService = identityService ?? throw new ArgumentNullException(nameof(identityService));
         }
 
+        //GET api/v1/[controller]/1
+        [Route("{userId:int}")]
+        [HttpGet]
+        public async Task<IActionResult> GetUserLocation(int userId)
+        {
+            var userLocation = await _locationsService.GetUserLocation(userId);
+            return Ok(userLocation);
+        }
+
+        //GET api/v1/[controller]/locations
+        [Route("locations")]
+        [HttpGet]
+        public async Task<IActionResult> GetAllLocations()
+        {
+            var userLocation = await _locationsService.GetAllLocation();
+            return Ok(userLocation);
+        }
+
         //POST api/v1/[controller]/
         [Route("")]
         [HttpPost]

src/Services/Location/Locations.API/Infrastructure/ActionResults/InternalServerErrorObjectResult.cs

@@ -0,0 +1,14 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.ActionResults
+{
+    public class InternalServerErrorObjectResult : ObjectResult
+    {
+        public InternalServerErrorObjectResult(object error)
+            : base(error)
+        {
+            StatusCode = StatusCodes.Status500InternalServerError;
+        }
+    }
+}

src/Services/Location/Locations.API/Infrastructure/Exceptions/LocationDomainException.cs

@@ -0,0 +1,21 @@
+namespace Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.Exceptions
+{
+    using System;
+
+    /// <summary>
+    /// Exception type for app exceptions
+    /// </summary>
+    public class LocationDomainException : Exception
+    {
+        public LocationDomainException()
+        { }
+
+        public LocationDomainException(string message)
+            : base(message)
+        { }
+
+        public LocationDomainException(string message, Exception innerException)
+            : base(message, innerException)
+        { }
+    }
+}

src/Services/Location/Locations.API/Infrastructure/Filters/HttpGlobalExceptionFilter.cs

@@ -0,0 +1,67 @@
+namespace Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.Filters
+{
+    using AspNetCore.Mvc;
+    using Microsoft.AspNetCore.Hosting;
+    using Microsoft.AspNetCore.Mvc.Filters;
+    using Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.ActionResults;
+    using Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.Exceptions;
+    using Microsoft.Extensions.Logging;
+    using System.Net;
+
+    public class HttpGlobalExceptionFilter : IExceptionFilter
+    {
+        private readonly IHostingEnvironment env;
+        private readonly ILogger<HttpGlobalExceptionFilter> logger;
+
+        public HttpGlobalExceptionFilter(IHostingEnvironment env, ILogger<HttpGlobalExceptionFilter> logger)
+        {
+            this.env = env;
+            this.logger = logger;
+        }
+
+        public void OnException(ExceptionContext context)
+        {
+            logger.LogError(new EventId(context.Exception.HResult),
+                context.Exception,
+                context.Exception.Message);
+
+            if (context.Exception.GetType() == typeof(LocationDomainException))
+            {
+                var json = new JsonErrorResponse
+                {
+                    Messages = new[] { context.Exception.Message }
+                };
+
+                // Result asigned to a result object but in destiny the response is empty. This is a known bug of .net core 1.1
+                //It will be fixed in .net core 1.1.2. See https://github.com/aspnet/Mvc/issues/5594 for more information
+                context.Result = new BadRequestObjectResult(json);
+                context.HttpContext.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+            }
+            else
+            {
+                var json = new JsonErrorResponse
+                {
+                    Messages = new[] { "An error occur.Try it again." }
+                };
+
+                if (env.IsDevelopment())
+                {
+                    json.DeveloperMessage = context.Exception;
+                }
+
+                // Result asigned to a result object but in destiny the response is empty. This is a known bug of .net core 1.1
+                // It will be fixed in .net core 1.1.2. See https://github.com/aspnet/Mvc/issues/5594 for more information
+                context.Result = new InternalServerErrorObjectResult(json);
+                context.HttpContext.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+            }
+            context.ExceptionHandled = true;
+        }
+
+        private class JsonErrorResponse
+        {
+            public string[] Messages { get; set; }
+
+            public object DeveloperMessage { get; set; }
+        }
+    }
+}

src/Services/Location/Locations.API/Infrastructure/LocationsContext.cs

@@ -1,72 +1,34 @@
 namespace Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure
 {
-    using Microsoft.EntityFrameworkCore;
-    using Microsoft.EntityFrameworkCore.Metadata.Builders;
-    using Microsoft.eShopOnContainers.Services.Locations.API.Infrastructure.Repositories;
     using Microsoft.eShopOnContainers.Services.Locations.API.Model;
-    using System.Threading;
-    using System.Threading.Tasks;
+    using Microsoft.Extensions.Options;
+    using MongoDB.Driver;
 
-    public class LocationsContext : DbContext, IUnitOfWork
+    public class LocationsContext
     {
-        public LocationsContext(DbContextOptions options) : base(options)
-        {
-        }
+        private readonly IMongoDatabase _database = null;
 
-        public DbSet<Locations> Locations { get; set; }
-        public DbSet<FrontierPoints> FrontierPoints { get; set; }
-        public DbSet<UserLocation> UserLocation { get; set; }
-
-        protected override void OnModelCreating(ModelBuilder builder)
+        public LocationsContext(IOptions<LocationSettings> settings)
         {
-            builder.Entity<Locations>(ConfigureLocations);
-            builder.Entity<FrontierPoints>(ConfigureFrontierPoints);
-            builder.Entity<UserLocation>(ConfigureUserLocation);
+            var client = new MongoClient(settings.Value.ConnectionString);
+            if (client != null)
+                _database = client.GetDatabase(settings.Value.Database);
         }
 
-        void ConfigureLocations(EntityTypeBuilder<Locations> builder)
+        public IMongoCollection<UserLocation> UserLocation
         {
-            builder.ToTable("Locations");
-
-            builder.HasKey(cl => cl.Id);
-
-            builder.Property(cl => cl.Id)
-               .ForSqlServerUseSequenceHiLo("locations_seq")
-               .IsRequired();
-
-            builder.Property(cb => cb.Code)
-                .IsRequired()
-                .HasColumnName("LocationCode")
-                .HasMaxLength(15);
-
-            builder.HasMany(f => f.Polygon)
-                .WithOne(l => l.Location)
-                .IsRequired();          
-
-            builder.Property(cb => cb.Description)
-                .HasMaxLength(100);
+            get
+            {
+                return _database.GetCollection<UserLocation>("UserLocation");
+            }
         }
 
-        void ConfigureFrontierPoints(EntityTypeBuilder<FrontierPoints> builder)
+        public IMongoCollection<Locations> Locations
         {
-            builder.ToTable("FrontierPoints");
-
-            builder.HasKey(fp => fp.Id);
-
-            builder.Property(fp => fp.Id)
-               .ForSqlServerUseSequenceHiLo("frontier_seq")
-               .IsRequired();           
-        }
-
-        void ConfigureUserLocation(EntityTypeBuilder<UserLocation> builder)
-        {
-            builder.ToTable("UserLocation");
-
-            builder.Property(ul => ul.Id)
-               .ForSqlServerUseSequenceHiLo("UserLocation_seq")
-               .IsRequired();
-
-            builder.HasIndex(ul => ul.UserId).IsUnique();
-        }        
+            get
+            {
+                return _database.GetCollection<Locations>("Locations");
+            }
+        }       
     }
 }