Support for custom properties of date/time type.

microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer.UnitTests/ServiceBusTests/MessagePropertiesTests.cs

@@ -36,13 +36,15 @@ public sealed class MessagePropertiesTests
         public void MessageProperties()
         {
             string queueName = UsesUniqueQueueAttribute.QueueName;
+            DateTimeOffset originalDateTime = new DateTimeOffset(DateTime.UtcNow);
             BrokeredMessageSettings messageSettings = BrokeredMessageSettings.CreateFromText("text/plain", "This is a test.");
 
             messageSettings.Properties.Add("StringProperty", "Test");
             messageSettings.Properties.Add("BoolPropertyTrue", true);
             messageSettings.Properties.Add("BoolPropertyFalse", false);
             messageSettings.Properties.Add("NullProperty", null);
             messageSettings.Properties.Add("NumberProperty", 123);
+            messageSettings.Properties.Add("TimeProperty", originalDateTime);
 
             Configuration.ServiceBus.SendMessageAsync(queueName, messageSettings).AsTask().Wait();
             BrokeredMessageInfo message = Configuration.ServiceBus.GetQueueMessageAsync(queueName, TimeSpan.FromSeconds(10)).AsTask().Result;
@@ -52,13 +54,23 @@ public void MessageProperties()
             Assert.True(message.Properties.ContainsKey("BoolPropertyTrue"));
             Assert.True(message.Properties.ContainsKey("BoolPropertyFalse"));
             Assert.True(message.Properties.ContainsKey("NumberProperty"));
+            Assert.True(message.Properties.ContainsKey("TimeProperty"));
             // The server does not store/return null properties.
             Assert.False(message.Properties.ContainsKey("NullProperty"));
 
             Assert.Equal((string)message.Properties["StringProperty"], "Test", StringComparer.Ordinal);
             Assert.Equal((bool)message.Properties["BoolPropertyTrue"], true);
             Assert.Equal((bool)message.Properties["BoolPropertyFalse"], false);
             Assert.Equal(Convert.ToInt32(message.Properties["NumberProperty"]), 123);
+
+            // Times must be identical to a second.
+            DateTimeOffset readDateTime = (DateTimeOffset)message.Properties["TimeProperty"];
+            Assert.Equal(originalDateTime.Year, readDateTime.Year);
+            Assert.Equal(originalDateTime.Month, readDateTime.Month);
+            Assert.Equal(originalDateTime.Day, readDateTime.Day);
+            Assert.Equal(originalDateTime.Hour, readDateTime.Hour);
+            Assert.Equal(originalDateTime.Minute, readDateTime.Minute);
+            Assert.Equal(originalDateTime.Second, readDateTime.Second);
         }
 
         /// <summary>

microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Microsoft.WindowsAzure.ServiceLayer.csproj

@@ -139,6 +139,9 @@
     <Compile Include="ServiceBus\ServiceBusService.cs" />
     <Compile Include="ServiceBus\ServiceConfiguration.cs" />
   </ItemGroup>
+  <ItemGroup>
+    <Reference Include="System" />
+  </ItemGroup>
   <PropertyGroup Condition=" '$(VisualStudioVersion)' == '' ">
     <VisualStudioVersion>11.0</VisualStudioVersion>
   </PropertyGroup>

microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/CustomPropertiesDictionary.cs

@@ -1,4 +1,19 @@
-using System;
+//
+// Copyright 2012 Microsoft Corporation
+// 
+// Licensed under the Apache License, Version 2.0 (the "License");
+//  you may not use this file except in compliance with the License.
+//  You may obtain a copy of the License at
+//    http://www.apache.org/licenses/LICENSE-2.0
+// 
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+//
+
+using System;
 using System.Collections.Generic;
 using System.Globalization;
 using System.Diagnostics;
@@ -42,7 +57,6 @@ internal CustomPropertiesDictionary(HttpResponseMessage response)
                 }
                 else
                 {
-                    // The string could not be deserialized into Json value; storing raw string data.
                     Add(key, valueString);
                 }
             }
@@ -80,9 +94,20 @@ private static object DecodeValue(JsonValue value)
                     return value.GetNumber();
 
                 default:
-                    Debug.Assert(value.ValueType == JsonValueType.String);
-                    return value.GetString();
+                    break;
             }
+
+            // Extract extra types that are stored as strings.
+            Debug.Assert(value.ValueType == JsonValueType.String);
+            string stringValue = value.GetString();
+            DateTimeOffset dateTime;
+
+            if (DateTimeOffset.TryParse(stringValue, out dateTime))
+            {
+                return dateTime.ToUniversalTime();
+            }
+            return stringValue;
+
         }
 
         /// <summary>
@@ -134,9 +159,13 @@ private static JsonValue EncodeValue(object value)
             {
                 return JsonValue.CreateStringValue((string)value);
             }
+            else if (IsType<System.DateTimeOffset>(type))
+            {
+                return CreateDateTimeValue((DateTimeOffset)value);
+            }
             else
             {
-                //TODO: error message!
+                //TODO: Error message.
                 throw new InvalidCastException();
             }
         }
@@ -151,5 +180,17 @@ private static bool IsType<T>(Type type)
         {
             return object.ReferenceEquals(typeof(T), type);
         }
+
+        /// <summary>
+        /// Creates a Json string for the given date/time.
+        /// </summary>
+        /// <param name="dateTime">Date/time.</param>
+        /// <returns>Json string value with the date/time.</returns>
+        private static JsonValue CreateDateTimeValue(DateTimeOffset dateTime)
+        {
+            dateTime = dateTime.ToUniversalTime();
+            string dateTimeString = dateTime.ToString("r");
+            return JsonValue.CreateStringValue(dateTimeString);
+        }
     }
 }