changed routes for BC functions and added an ability to request separate entities

Dmitry Kozlov · Dmitry Kozlov · commit 67f547a458a2 · 2024-11-21T12:42:46.000+01:00
diff --git a/FunctionApp/Dynamics365/BusinessCentral/Authorize.cs b/FunctionApp/Dynamics365/BusinessCentral/Authorize.cs
@@ -26,7 +26,7 @@ public Authorize(IOptions<AppSettings> settings, ILogger<Authorize> logger)
         }
 
         [Function("D365-BC-Authorize")]
-        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequest req)
+        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = "bc/authorize")] HttpRequest req)
         {
             var scopes = new string[] { "https://api.businesscentral.dynamics.com/.default", "offline_access" };
 
diff --git a/FunctionApp/Dynamics365/BusinessCentral/Customers.cs b/FunctionApp/Dynamics365/BusinessCentral/Customers.cs
@@ -1,3 +1,4 @@
+using Grpc.Core;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.Functions.Worker;
@@ -29,20 +30,50 @@ public Customers(IOptions<AppSettings> settings, HttpClientProvider httpClientPr
         }
 
         [Function("D365-BC-Customers")]
-        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get")] HttpRequest req)
+        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", Route = "bc/customers/{id?}")] HttpRequest req, Guid? id)
         {
-            _logger.LogInformation("Dynamics365-BusinessCentral-Customers is requested.");
+            _logger.LogInformation("D365-BC-Customers is requested.");
 
-            var client = _httpClientProvider.Create();
-            var companyId = await client.GetCompanyIdAsync(_settings.Company);
-            if (companyId == null)
+            try
             {
-                return new NotFoundResult();
-            }
+                var client = _httpClientProvider.Create();
+                var companyId = await client.GetCompanyIdAsync(_settings.Company);
+                if (companyId == null)
+                {
+                    return new NotFoundResult();
+                }
+
+                if (!id.HasValue)
+                {
+                    var customersJson = await client.GetStringAsync($"companies({companyId})/customers");
+                    var customers = JsonValue.Parse(customersJson);
+                    return new OkObjectResult(customers?["value"]);
+                }
+
+                var customerResponse = await client.GetAsync($"companies({companyId})/customers({id})");
+                if (!customerResponse.IsSuccessStatusCode)
+                {
+                    if (customerResponse.StatusCode == System.Net.HttpStatusCode.NotFound)
+                    {
+                        return new NotFoundResult();
+                    }
+
+                    // throws Exception
+                    customerResponse.EnsureSuccessStatusCode();
+                }
 
-            var customersJson = await client.GetStringAsync($"companies({companyId})/customers");
-            var customers = JsonValue.Parse(customersJson);
-            return new OkObjectResult(customers?["value"]);
+                var customerJson = await customerResponse.Content.ReadAsStringAsync();
+                return new ContentResult()
+                {
+                    Content = customerJson,
+                    ContentType = "application/json"
+                };
+            }
+            catch (HttpRequestException ex)
+            {
+                _logger.LogError(ex, "An error has occured while processing D365-BC-Customers request.");
+                return new StatusCodeResult(ex.StatusCode.HasValue ? (int)ex.StatusCode.Value : StatusCodes.Status500InternalServerError);
+            }
         }
     }
 }
diff --git a/FunctionApp/Dynamics365/BusinessCentral/Items.cs b/FunctionApp/Dynamics365/BusinessCentral/Items.cs
@@ -1,3 +1,4 @@
+using Grpc.Core;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.Functions.Worker;
@@ -28,20 +29,50 @@ public Items(IOptions<AppSettings> settings, HttpClientProvider httpClientProvid
 
         [Function("D365-BC-Items")]
         public async Task<IActionResult> Run(
-            [HttpTrigger(AuthorizationLevel.Function, "get", Route = null)] HttpRequest req)
+            [HttpTrigger(AuthorizationLevel.Function, "get", Route = "bc/items/{id?}")] HttpRequest req, Guid? id)
         {
-            _logger.LogInformation("Dynamics365-BusinessCentral-Items is requested.");
+            _logger.LogInformation("D365-BC-Items is requested.");
 
-            var client = _httpClientProvider.Create();
-            var companyId = await client.GetCompanyIdAsync(_settings.Company);
-            if (companyId == null)
+            try
             {
-                return new NotFoundResult();
-            }
+                var client = _httpClientProvider.Create();
+                var companyId = await client.GetCompanyIdAsync(_settings.Company);
+                if (companyId == null)
+                {
+                    return new NotFoundResult();
+                }
+
+                if (!id.HasValue)
+                {
+                    var itemsJson = await client.GetStringAsync($"companies({companyId})/items");
+                    var items = JsonValue.Parse(itemsJson);
+                    return new OkObjectResult(items?["value"]);
+                }
+
+                var itemResponse = await client.GetAsync($"companies({companyId})/items({id})");
+                if (!itemResponse.IsSuccessStatusCode)
+                {
+                    if (itemResponse.StatusCode == System.Net.HttpStatusCode.NotFound)
+                    {
+                        return new NotFoundResult();
+                    }
+
+                    // throws Exception
+                    itemResponse.EnsureSuccessStatusCode();
+                }
 
-            var itemsJson = await client.GetStringAsync($"companies({companyId})/items");
-            var items = JsonValue.Parse(itemsJson);
-            return new OkObjectResult(items?["value"]);
+                var itemJson = await itemResponse.Content.ReadAsStringAsync();
+                return new ContentResult()
+                {
+                    Content = itemJson,
+                    ContentType = "application/json"
+                };
+            }
+            catch (HttpRequestException ex)
+            {
+                _logger.LogError(ex, "An error has occured while processing D365-BC-Items request.");
+                return new StatusCodeResult(ex.StatusCode.HasValue ? (int)ex.StatusCode.Value : StatusCodes.Status500InternalServerError);
+            }
         }
     }
 }
diff --git a/FunctionApp/Dynamics365/BusinessCentral/Vendors.cs b/FunctionApp/Dynamics365/BusinessCentral/Vendors.cs
@@ -1,16 +1,10 @@
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.Functions.Worker;
-using Microsoft.Azure.WebJobs;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Microsoft.Graph;
-using Microsoft.Graph.Beta.Models;
 using Plumsail.DataSource.Dynamics365.BusinessCentral.Settings;
-using Plumsail.DataSource.Dynamics365.CRM;
-using System.Collections.Generic;
 using System.Text.Json.Nodes;
-using System.Threading.Tasks;
 
 namespace Plumsail.DataSource.Dynamics365.BusinessCentral
 {
@@ -28,20 +22,50 @@ public Vendors(IOptions<AppSettings> settings, HttpClientProvider httpClientProv
         }
 
         [Function("D365-BC-Vendors")]
-        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get")] HttpRequest req)
+        public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", Route = "bc/vendors/{id?}")] HttpRequest req, Guid? id)
         {
-            _logger.LogInformation("Dynamics365-BusinessCentral-Vendors is requested.");
+            _logger.LogInformation("D365-BC-Vendors is requested.");
 
-            var client = _httpClientProvider.Create();
-            var companyId = await client.GetCompanyIdAsync(_settings.Company);
-            if (companyId == null)
+            try
             {
-                return new NotFoundResult();
-            }
+                var client = _httpClientProvider.Create();
+                var companyId = await client.GetCompanyIdAsync(_settings.Company);
+                if (companyId == null)
+                {
+                    return new NotFoundResult();
+                }
+
+                if (!id.HasValue)
+                {
+                    var vendorsJson = await client.GetStringAsync($"companies({companyId})/vendors");
+                    var vendors = JsonValue.Parse(vendorsJson);
+                    return new OkObjectResult(vendors?["value"]);
+                }
+
+                var vendorResponse = await client.GetAsync($"companies({companyId})/vendors({id})");
+                if (!vendorResponse.IsSuccessStatusCode)
+                {
+                    if (vendorResponse.StatusCode == System.Net.HttpStatusCode.NotFound)
+                    {
+                        return new NotFoundResult();
+                    }
+
+                    // throws Exception
+                    vendorResponse.EnsureSuccessStatusCode();
+                }
 
-            var vendorsJson = await client.GetStringAsync($"companies({companyId})/vendors");
-            var vendors = JsonValue.Parse(vendorsJson);
-            return new OkObjectResult(vendors?["value"]);
+                var vendorJson = await vendorResponse.Content.ReadAsStringAsync();
+                return new ContentResult()
+                {
+                    Content = vendorJson,
+                    ContentType = "application/json"
+                };
+            }
+            catch (HttpRequestException ex)
+            {
+                _logger.LogError(ex, "An error has occured while processing D365-BC-Vendors request.");
+                return new StatusCodeResult(ex.StatusCode.HasValue ? (int)ex.StatusCode.Value : StatusCodes.Status500InternalServerError);
+            }
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@ public Authorize(IOptions<AppSettings> settings, ILogger<Authorize> logger)`
`26`	`26`	`}`
`27`	`27`
`28`	`28`	`[Function("D365-BC-Authorize")]`
`29`		`- public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequest req)`
	`29`	`+ public async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = "bc/authorize")] HttpRequest req)`
`30`	`30`	`{`
`31`	`31`	`var scopes = new string[] { "https://api.businesscentral.dynamics.com/.default", "offline_access" };`
`32`	`32`