Merge pull request #9 from bable5/add-connections-redirect-flow

Add connections redirect flow

Author: jconner0623

CSharpApp/Controllers/HomeController.cs

@@ -27,11 +27,12 @@ public IActionResult Index()
             _settings.ClientId = _configuration["JDeere:ClientId"];
             _settings.ClientSecret = _configuration["JDeere:ClientSecret"];
             _settings.WellKnown = _configuration["JDeere:WellKnown"];
-            _settings.CallbackUrl = _configuration["JDeere:CallbackUrl"];
+            _settings.ServerUrl = _configuration["JDeere:ServerUrl"];
+            _settings.CallbackUrl = _settings.ServerUrl + _configuration["JDeere:Callback"];
             _settings.Scopes = _configuration["JDeere:Scopes"];
             _settings.State = _configuration["JDeere:State"];
             _settings.APIURL = _configuration["JDeere:ApiUrl"];
-            
+
             ViewBag.Settings = _settings;
 
             return View();
@@ -87,6 +88,12 @@ public async Task<IActionResult> Callback(string code, string state)
             var responseContent = await response.Content.ReadAsStringAsync();
             _settings.AccessToken = JsonConvert.DeserializeObject<Token>(responseContent);
 
+            string organizationAccessUrl = await NeedsOrganizationAccess();
+            if (organizationAccessUrl != null)
+            {
+                return Redirect(organizationAccessUrl);
+            }
+
             ViewBag.Settings = _settings;
 
             return View("Index");
@@ -165,6 +172,36 @@ private async Task<HttpResponseMessage> SecuredApiGetRequest(string url)
 
             return await client.GetAsync(url);
         }
+
+        /// <summary>Check to see if the 'connections' rel is present for any organization.
+        /// If the rel is present it means the oauth application has not completed it's
+        /// access to an organization and must redirect the user to the uri provided
+        /// in the link.</summary>
+        /// <returns>A redirect uri if the <code>connections</code>
+        /// connections rel is present or <null> if no redirect is
+        /// required to finish the setup.</returns>
+        private async Task<string> NeedsOrganizationAccess()
+        {
+            var response = await SecuredApiGetRequest(_settings.APIURL + "/organizations");
+
+            response.EnsureSuccessStatusCode();
+            var responseContent = await response.Content.ReadAsStringAsync();
+            var dynorg = JsonConvert.DeserializeObject<dynamic>(responseContent);
+
+            foreach (var organization in dynorg.values)
+            {
+                foreach (var link in organization.links)
+                {
+                    string rel = link.rel;
+                    if (rel == "connections")
+                    {
+                        string connectionsLink = link.uri;
+                        return QueryHelpers.AddQueryString(connectionsLink, "redirect_uri", _settings.ServerUrl);
+                    }
+                }
+            }
+            return null;
+        }
     }
 }
 

CSharpApp/Models/JDeere.cs

@@ -1,10 +1,11 @@
-namespace CSharpApp.Models 
+namespace CSharpApp.Models
 {
     public class JDeere
     {
         public string ClientId { get; set; }
         public string ClientSecret { get; set; }
         public string WellKnown { get; set; }
+        public string ServerUrl { get; set; }
         public string CallbackUrl { get; set; }
         public Token AccessToken { get; set; }
         public string Scopes { get; set; }

CSharpApp/appsettings.json

@@ -13,7 +13,8 @@
     "ApiUrl": "https://sandboxapi.deere.com/platform",
     "Scopes": "openid profile offline_access ag1 eq1",
     "State": "test state",
-    "CallbackUrl": "http://localhost:9090/callback"
+    "ServerUrl": "http://localhost:9090",
+    "Callback": "/callback"
   },
   "AllowedHosts": "*"
 }