applying apis in web project

Author: mehmetozkaya

src/Basket/Basket.API/Entities/BasketCartItem.cs

@@ -5,6 +5,6 @@ public class BasketCartItem
         public int Quantity { get; set; }
         public string Color { get; set; }
         public decimal Price { get; set; }
-        public int ProductId { get; set; }
+        public string ProductId { get; set; }
     }
 }

src/Catalog/Catalog.API/Startup.cs

@@ -35,8 +35,7 @@ public void ConfigureServices(IServiceCollection services)
 
             #region Configuration Dependencies
 
-            services.Configure<CatalogDatabaseSettings>(
-                Configuration.GetSection(nameof(CatalogDatabaseSettings)));
+            services.Configure<CatalogDatabaseSettings>(Configuration.GetSection(nameof(CatalogDatabaseSettings)));
 
             services.AddSingleton<ICatalogDatabaseSettings>(sp =>
                 sp.GetRequiredService<IOptions<CatalogDatabaseSettings>>().Value);

src/WebApp/AspnetRunBasics/ApiCollection/BasketApi.cs

@@ -0,0 +1,61 @@
+using AspnetRunBasics.ApiCollection.Infrastructure;
+using AspnetRunBasics.ApiCollection.Interfaces;
+using AspnetRunBasics.Models;
+using AspnetRunBasics.Settings;
+using Newtonsoft.Json;
+using System;
+using System.Net.Http;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.ApiCollection
+{
+    public class BasketApi : BaseHttpClientWithFactory, IBasketApi
+    {
+        private readonly IApiSettings _settings;
+
+        public BasketApi(IHttpClientFactory factory, IApiSettings settings)
+            : base(factory)
+        {
+            _settings = settings;
+        }
+
+        public async Task<BasketModel> GetBasket(string userName)
+        {
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                               .SetPath(_settings.BasketPath + "//" + userName)
+                               .HttpMethod(HttpMethod.Get)
+                               .GetHttpMessage();
+
+            return await SendRequest<BasketModel>(message);
+        }
+
+        public async Task<BasketModel> AddBasket(BasketModel model)
+        {
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                                .SetPath(_settings.BasketPath)
+                                .HttpMethod(HttpMethod.Post)
+                                .GetHttpMessage();
+
+            var json = JsonConvert.SerializeObject(model);
+            message.Content = new StringContent(json, Encoding.UTF8, "application/json");
+
+            return await SendRequest<BasketModel>(message);
+        }
+
+        public async Task CheckoutBasket(BasketCheckoutModel model)
+        {
+            var postPath = _settings.BasketPath + "/Checkout";
+
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                                .SetPath(postPath)
+                                .HttpMethod(HttpMethod.Post)
+                                .GetHttpMessage();
+
+            var json = JsonConvert.SerializeObject(model);
+            message.Content = new StringContent(json, Encoding.UTF8, "application/json");
+
+            await SendRequest<BasketCheckoutModel>(message);
+        }
+    }
+}

src/WebApp/AspnetRunBasics/ApiCollection/CatalogApi.cs

@@ -0,0 +1,68 @@
+using AspnetRunBasics.ApiCollection.Infrastructure;
+using AspnetRunBasics.ApiCollection.Interfaces;
+using AspnetRunBasics.Models;
+using AspnetRunBasics.Settings;
+using Newtonsoft.Json;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.ApiCollection
+{
+    public class CatalogApi : BaseHttpClientWithFactory, ICatalogApi
+    {
+        private readonly IApiSettings _settings;
+
+        public CatalogApi(IHttpClientFactory factory, IApiSettings settings)
+            : base(factory)
+        {
+            _settings = settings;
+        }
+
+        public async Task<IEnumerable<CatalogModel>> GetCatalog()
+        {
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                               .SetPath(_settings.CatalogPath)
+                               .HttpMethod(HttpMethod.Get)
+                               .GetHttpMessage();
+
+            return await SendRequest<IEnumerable<CatalogModel>>(message);
+        }
+
+        public async Task<CatalogModel> GetCatalog(string id)
+        {
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                               .SetPath(_settings.CatalogPath + "//" + id)
+                               .HttpMethod(HttpMethod.Get)
+                               .GetHttpMessage();
+
+            return await SendRequest<CatalogModel>(message);
+        }
+
+        public async Task<IEnumerable<CatalogModel>> GetCatalogByCategory(string category)
+        {
+            var queryPath = _settings.CatalogPath + "/GetProductByCategory/" + category;
+
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                               .SetPath(queryPath)
+                               .HttpMethod(HttpMethod.Get)
+                               .GetHttpMessage();
+
+            return await SendRequest<IEnumerable<CatalogModel>>(message);
+        }
+
+        public async Task<CatalogModel> CreateCatalog(CatalogModel catalogModel)
+        {
+            var message = new HttpRequestBuilder(_settings.BaseAddress)
+                                .SetPath(_settings.CatalogPath)                                
+                                .HttpMethod(HttpMethod.Post)
+                                .GetHttpMessage();
+
+            var json = JsonConvert.SerializeObject(catalogModel);
+            message.Content = new StringContent(json, Encoding.UTF8, "application/json");
+
+            return await SendRequest<CatalogModel>(message);
+        }
+    }
+}

src/WebApp/AspnetRunBasics/ApiCollection/Infrastructure/ApiBuilder.cs

@@ -0,0 +1,119 @@
+using System;
+using System.Web;
+
+namespace AspnetRunBasics.ApiCollection.Infrastructure
+{
+    public class ApiBuilder
+    {
+        private readonly string _fullUrl;
+        private UriBuilder _builder;
+
+        public ApiBuilder(string url)
+        {
+            _fullUrl = url;
+            _builder = new UriBuilder(url);
+        }
+
+        public Uri GetUri() => _builder.Uri;
+
+        public ApiBuilder Scheme(string scheme)
+        {
+            _builder.Scheme = scheme;
+            return this;
+        }
+
+        public ApiBuilder Host(string host)
+        {
+            _builder.Host = host;
+            return this;
+        }
+
+        public ApiBuilder Port(int port)
+        {
+            _builder.Port = port;
+            return this;
+        }
+
+        public ApiBuilder AddToPath(string path)
+        {
+            IncludePath(path);
+            return this;
+        }
+
+        public ApiBuilder SetPath(string path)
+        {
+            _builder.Path = path;
+            return this;
+        }
+
+        public void IncludePath(string path)
+        {
+            if (string.IsNullOrEmpty(_builder.Path)
+                || _builder.Path == "/")
+            {
+                _builder.Path = path;
+            }
+            else
+            {
+                var newPath = $"{_builder.Path}/{path}";
+                _builder.Path = newPath.Replace("//", "/");
+            }
+        }
+
+        public ApiBuilder Fragment(string fragment)
+        {
+            _builder.Fragment = fragment;
+            return this;
+        }
+
+        public ApiBuilder SetSubdomain(string subdomain)
+        {
+            _builder.Host = string.Concat(subdomain, ".", new Uri(_fullUrl).Host);
+            return this;
+        }
+
+        public bool HasSubdomain()
+        {
+            return _builder.Uri.HostNameType == UriHostNameType.Dns
+                   && _builder.Uri.Host.Split('.').Length > 2;
+        }
+
+        public ApiBuilder AddQueryString(string name, string value)
+        {
+            var qsNv = HttpUtility.ParseQueryString(_builder.Query);
+            qsNv[name] = string.IsNullOrEmpty(qsNv[name])
+                ? value
+                : string.Concat(qsNv[name], ",", value);
+
+            _builder.Query = qsNv.ToString();
+
+            return this;
+        }
+
+        public ApiBuilder QueryString(string queryString)
+        {
+            if (!string.IsNullOrEmpty(queryString))
+            {
+                _builder.Query = queryString;
+            }
+            return this;
+        }
+
+        public ApiBuilder UserName(string username)
+        {
+            _builder.UserName = username;
+            return this;
+        }
+
+        public ApiBuilder Password(string password)
+        {
+            _builder.Password = password;
+            return this;
+        }
+
+        public string GetLeftPart()
+        {
+            return _builder.Uri.GetLeftPart(UriPartial.Path);
+        }
+    }
+}

src/WebApp/AspnetRunBasics/ApiCollection/Infrastructure/BaseHttpClientWithFactory.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Net.Http.Formatting;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.ApiCollection.Infrastructure
+{
+    public abstract class BaseHttpClientWithFactory
+    {
+        private readonly IHttpClientFactory _factory;
+
+        public Uri BaseAddress { get; set; }
+        public string BasePath { get; set; }
+
+        public BaseHttpClientWithFactory(IHttpClientFactory factory) => _factory = factory;
+
+        private HttpClient GetHttpClient()
+        {
+            return _factory.CreateClient();
+        }
+
+        public virtual async Task<T> SendRequest<T>(HttpRequestMessage request) where T : class
+        {
+            var client = GetHttpClient();
+
+            var response = await client.SendAsync(request);
+
+            T result = null;
+
+            response.EnsureSuccessStatusCode();
+
+            if (response.IsSuccessStatusCode)
+            {
+                result = await response.Content.ReadAsAsync<T>(GetFormatters());
+            }
+
+            return result;
+        }
+
+        protected virtual IEnumerable<MediaTypeFormatter> GetFormatters()
+        {
+            // Make default the JSON
+            return new List<MediaTypeFormatter> { new JsonMediaTypeFormatter() };
+        }        
+    }
+}