Push message urgency

Author: tpeczek

Lib.Net.Http.WebPush/PushMessage.cs

@@ -39,6 +39,11 @@ public int? TimeToLive
                 _timeToLive = value;
             }
         }
+
+        /// <summary>
+        /// Gets or sets the message urgency.
+        /// </summary>
+        public PushMessageUrgency Urgency { get; set; }
         #endregion
 
         #region Constructors
@@ -49,6 +54,7 @@ public int? TimeToLive
         public PushMessage(string content)
         {
             Content = content;
+            Urgency = PushMessageUrgency.Normal;
         }
         #endregion
     }

Lib.Net.Http.WebPush/PushMessageUrgency.cs

@@ -0,0 +1,25 @@
+namespace Lib.Net.Http.WebPush
+{
+    /// <summary>
+    /// The push message urgency.
+    /// </summary>
+    public enum PushMessageUrgency
+    {
+        /// <summary>
+        /// Very low (e.g. advertisements).
+        /// </summary>
+        VeryLow,
+        /// <summary>
+        /// Low (e.g. topic updates).
+        /// </summary>
+        Low,
+        /// <summary>
+        /// Normal (e.g. chat message).
+        /// </summary>
+        Normal,
+        /// <summary>
+        /// High (e.g. time-sensitive alert).
+        /// </summary>
+        High
+    }
+}

Lib.Net.Http.WebPush/PushServiceClient.cs

@@ -6,6 +6,7 @@
 using System.Threading;
 using System.Globalization;
 using System.Threading.Tasks;
+using System.Collections.Generic;
 using System.Security.Cryptography;
 using Org.BouncyCastle.Crypto;
 using Org.BouncyCastle.Crypto.Parameters;
@@ -41,6 +42,12 @@ public class PushServiceClient
         private const int CONTENT_RECORD_SIZE = 4096;
 
         private static readonly byte[] _keyingMaterialInfoParameterPrefix = Encoding.ASCII.GetBytes(KEYING_MATERIAL_INFO_PARAMETER_PREFIX);
+        private static readonly Dictionary<PushMessageUrgency, string> _urgencyHeaderValues = new Dictionary<PushMessageUrgency, string>
+        {
+            { PushMessageUrgency.VeryLow, "very-low" },
+            { PushMessageUrgency.Low, "low" },
+            { PushMessageUrgency.High, "high" }
+        };
 
         private int _defaultTimeToLive = DEFAULT_TIME_TO_LIVE;
 
@@ -199,6 +206,24 @@ private static HttpRequestMessage SetAuthentication(HttpRequestMessage pushMessa
             return pushMessageDeliveryRequest;
         }
 
+        private static HttpRequestMessage SetUrgency(HttpRequestMessage pushMessageDeliveryRequest, PushMessage message)
+        {
+            switch (message.Urgency)
+            {
+                case PushMessageUrgency.Normal:
+                    break;
+                case PushMessageUrgency.VeryLow:
+                case PushMessageUrgency.Low:
+                case PushMessageUrgency.High:
+                    pushMessageDeliveryRequest.Headers.Add(URGENCY_HEADER_NAME, _urgencyHeaderValues[message.Urgency]);
+                    break;
+                default:
+                    throw new NotSupportedException($"Not supported value has been provided for {nameof(PushMessageUrgency)}.");
+            }
+
+            return pushMessageDeliveryRequest;
+        }
+
         private static HttpRequestMessage SetTopic(HttpRequestMessage pushMessageDeliveryRequest, PushMessage message)
         {
             if (!String.IsNullOrWhiteSpace(message.Topic))