Merge pull request #4 from umbraco/feature/semrush-auth

Feature/semrush auth

Author: acoumb

azure-pipeline - Crm.Hubspot.OAuthProxy.yml renamed to azure-pipeline - Cms.OAuthProxy.yml

@@ -5,7 +5,7 @@ pool:
   vmImage: 'windows-latest'
 
 variables:
-  projectName: 'Umbraco.Forms.Integrations.Crm.Hubspot.OAuthProxy'
+  projectName: 'Umbraco.Cms.Integrations.OAuthProxy'
   project: 'src/$(projectName)/$(projectName).csproj'
   buildConfiguration: 'Release'
   azureServiceConnectionDev: 'Umbraco Forms Integrations - Umbraco Cloud Services Dev - Hubspot Auth'
@@ -36,9 +36,14 @@ steps:
     appSettings: |
       [
         {
-          "name": "AppSettings:ClientSecret",
+          "name": "AppSettings:HubspotClientSecret",
           "value": "$(hubSpotAppSecretKey)",
           "slotSetting": false
+        },
+        {
+          "name": "AppSettings:SemrushClientSecret",
+          "value": "$(semrushAppSecretKey)",
+          "slotSetting": false
         }
       ]
 - task: AzureWebApp@1
@@ -55,8 +60,13 @@ steps:
     appSettings: |
       [
         {
-          "name": "AppSettings:ClientSecret",
+          "name": "AppSettings:HubspotClientSecret",
           "value": "$(hubSpotAppSecretKey)",
           "slotSetting": false
+        },
+        {
+          "name": "AppSettings:SemrushClientSecret",
+          "value": "$(semrushAppSecretKey)",
+          "slotSetting": false
         }
       ]

src/Umbraco.Cms.Integrations.OAuthProxy/.config/dotnet-tools.json

@@ -0,0 +1,12 @@
+{
+  "version": 1,
+  "isRoot": true,
+  "tools": {
+    "dotnet-ef": {
+      "version": "6.0.1",
+      "commands": [
+        "dotnet-ef"
+      ]
+    }
+  }
+}

src/Umbraco.Cms.Integrations.OAuthProxy/Configuration/AppSettings.cs

@@ -0,0 +1,11 @@
+namespace Umbraco.Forms.Integrations.Crm.Hubspot.OAuthProxy.Configuration
+{
+    public class AppSettings
+    {
+        public string HubspotClientSecret { get; set; }
+
+        public string SemrushClientSecret { get; set; }
+
+        public string this[string propertyName] => (string) GetType().GetProperty(propertyName)?.GetValue(this, null);
+    }
+}

src/Umbraco.Cms.Integrations.OAuthProxy/Controllers/OAuthProxyController.cs

@@ -0,0 +1,77 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Options;
+
+using Umbraco.Forms.Integrations.Crm.Hubspot.OAuthProxy.Configuration;
+
+namespace Umbraco.Cms.Integrations.OAuthProxy.Controllers
+{
+    [ApiController]
+    public class OAuthProxyController : Controller
+    {
+        private readonly IHttpClientFactory _httpClientFactory;
+        private readonly AppSettings _appSettings;
+
+        public const string ServiceNameHeaderKey = "service_name";
+
+        /// <summary>
+        /// Integrated services with their token URIs
+        /// </summary>
+        private static Dictionary<string, string> ValidServices = new Dictionary<string, string>
+        {
+            { "Hubspot", "oauth/v1/token" }, { "Semrush", "oauth2/access_token" }
+        };
+
+        //private static List<string> ValidServiceNames = new List<string> {"Hubspot", "Semrush"};
+
+        public OAuthProxyController(IHttpClientFactory httpClientFactory, IOptions<AppSettings> appSettings)
+        {
+            _httpClientFactory = httpClientFactory;
+            _appSettings = appSettings.Value;
+        }
+
+        [HttpPost]
+        [Route("/oauth/v1/token")]
+        public async Task ProxyTokenRequest()
+        {
+            if (!Request.Headers.TryGetValue(ServiceNameHeaderKey, out var serviceName))
+            {
+                serviceName = "Hubspot";
+            }
+
+            if (!ValidServices.ContainsKey(serviceName))
+            {
+                throw 
+                    new InvalidOperationException($"Provided {ServiceNameHeaderKey} header value of {serviceName} is not supported");
+            }
+
+            var httpClient = _httpClientFactory.CreateClient($"{serviceName}Token");
+
+            var response =
+                await httpClient.PostAsync(ValidServices[serviceName], GetContent(Request.Form, serviceName));
+            var content = await response.Content.ReadAsStringAsync();
+
+            Response.StatusCode = (int)response.StatusCode;
+
+            Response.ContentType = response.Content.Headers.ContentType?.ToString();
+            Response.ContentLength = response.Content.Headers.ContentLength;
+
+            await Response.WriteAsync(content);
+        }
+
+        private HttpContent GetContent(IFormCollection form, string serviceName)
+        {
+            var dictionary = form.ToDictionary(x => x.Key, x => x.Value.ToString());
+            dictionary.Add("client_secret", GetClientSecret(serviceName));
+            return new FormUrlEncodedContent(dictionary);
+        }
+
+        private string GetClientSecret(string serviceName) => _appSettings[$"{serviceName}ClientSecret"];
+    }
+}