POST data to HubSpot API

Author: Warren Buckley

src/Umbraco.Forms.Extensions.Crm.Hubspot/HubspotWorkflow.cs

@@ -1,8 +1,9 @@
 using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
 using System;
 using System.Collections.Generic;
 using System.Net.Http;
-using System.Net.Http.Json;
+using System.Text;
 using Umbraco.Core.Composing;
 using Umbraco.Core.Logging;
 using Umbraco.Forms.Core;
@@ -38,8 +39,69 @@ private Uri HubspotContactApiUrl
         }
 
         static readonly HttpClient client = new HttpClient();
+
         public override WorkflowExecutionStatus Execute(Record record, RecordEventArgs e)
         {
+            // Check Hubspot key is not empty
+            if (string.IsNullOrWhiteSpace(HubspotApiKey))
+            {
+                // Missing an API Key
+                // TODO: Can I bubble up a specific message as to why
+                Current.Logger.Warn<HubspotWorkflow>("Workflow {WorkflowName}: No API key has been set for the Hubspot workflow for the form {FormName} ({FormId})", Workflow.Name, e.Form.Name, e.Form.Id);
+                return WorkflowExecutionStatus.NotConfigured;
+            }
+
+            var fieldMappingsRawJson = FieldMappings;
+            var fieldMappings = JsonConvert.DeserializeObject<List<MappedProperty>>(fieldMappingsRawJson);
+            if(fieldMappings.Count == 0)
+            {
+                Current.Logger.Warn<HubspotWorkflow>("Workflow {WorkflowName}: Missing Hubspot field mappings for workflow for the form {FormName} ({FormId})", Workflow.Name, e.Form.Name, e.Form.Id);
+                return WorkflowExecutionStatus.NotConfigured;
+            }                
+
+            // Map data from the workflow setting Hubspot fields
+            // From the form field values submitted for this form submission
+            var postData = new PropertiesPost();
+
+            foreach (var mapping in fieldMappings)
+            {
+                var fieldId = mapping.FormField;
+                var recordField = record.GetRecordField(new Guid(fieldId));
+                if (recordField != null)
+                {
+                    // TODO:
+                    // What about different field types in forms & Hubspot that are not simple text ones ?
+                    postData.Properties.Add(mapping.HubspotField, recordField.ValuesAsString(false));
+                }
+                else
+                {
+                    // There field mapping value could not be found.
+                    // Write a warning in the log
+                    Current.Logger.Warn<HubspotWorkflow>("Workflow {WorkflowName}: The field mapping with Id, {FieldMappingId}, did not match any record fields. This is probably caused by the record field being marked as sensitive and the workflow has been set not to include sensitive data", Workflow.Name, mapping.FormField);
+                }
+            }
+
+            // Serialise dynamic JObject to a string for StringContent to POST to URL
+            var objAsJson = JsonConvert.SerializeObject(postData);
+            var content = new StringContent(objAsJson, Encoding.UTF8, "application/json");
+
+            // POST data to hubspot
+            // https://api.hubapi.com/crm/v3/objects/contacts?hapikey=YOUR_HUBSPOT_API_KEY
+            var postResponse = client.PostAsync(HubspotContactApiUrl, content).Result;
+
+            // Depending on POST status fail or mark workflow as completed
+            if(postResponse.IsSuccessStatusCode == false)
+            {
+                // LOG THE ERROR
+                Current.Logger.Warn<HubspotWorkflow>("Workflow {WorkflowName}: Error submitting data to Hubspot for the form {FormName} ({FormId})", Workflow.Name, e.Form.Name, e.Form.Id);
+                return WorkflowExecutionStatus.Failed;
+            }
+
+            // TODO:
+            // Is it worth logging the success that it got created in HubSpot with its ID etc in response
+            var rawResult = postResponse.Content.ReadAsStringAsync().Result;
+
+
             return WorkflowExecutionStatus.Completed;
         }
 
@@ -57,7 +119,7 @@ public override List<Exception> ValidateSettings()
             // Make a super simple GET request to fetch contacts in HubSpot
             // This way with we can verify that the API key is valid
             // https://developers.hubspot.com/docs/api/crm/contacts
-            var testResponse = client.GetAsync(HubspotApiUrl).Result;
+            var testResponse = client.GetAsync(HubspotContactApiUrl).Result;
 
             if (testResponse.IsSuccessStatusCode == false)
             {
@@ -78,6 +140,27 @@ public override List<Exception> ValidateSettings()
         }
     }
 
+    public class PropertiesPost
+    {
+        public PropertiesPost()
+        {
+            // Ensure we an init an empty object to add straight away
+            Properties = new JObject();
+        }
+
+        [JsonProperty(PropertyName = "properties")]
+        public JObject Properties { get; set; }
+    }
+
+    public class MappedProperty
+    {
+        [JsonProperty(PropertyName = "formField")]
+        public string FormField { get; set; }
+
+        [JsonProperty(PropertyName = "hubspotField")]
+        public string HubspotField { get; set; }
+    }
+
     public class ErrorResponse
     {
         public string message { get; set; }