Merge pull request #9 from palkalaiselvand/additional-changes-from-review

completed changes

Author: palkalaiselvand

.vs/SampleFunctionApp/DesignTimeBuild/.dtbcache

@@ -97,7 +97,9 @@ private async Task SendMessageToTopic<T>(T message, AzureMessageContext context)
         }
         private Message FormatMessage<T>(T queueMessage)
         {
-            Message message = new Message(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(queueMessage)))
+            var type = queueMessage.GetType();
+            string data = type.Name == "String" ? queueMessage.ToString() : JsonConvert.SerializeObject(queueMessage);
+            Message message = new Message(Encoding.UTF8.GetBytes(data))
             {
                 MessageId = Guid.NewGuid().ToString(),
                 SessionId = Guid.NewGuid().ToString()

.vs/SampleFunctionApp/v16/.suo

@@ -49,8 +49,10 @@ public async Task SendMessages<T>(List<T> messages, AzureMessageContext context)
             }
         }
 
-        private async Task<bool> AddMessageAsync<T>(string queue, T message)
+        private async Task<bool> AddMessageAsync<T>(string queue, T queueMessage)
         {
+            var type = queueMessage.GetType();
+            string data = type.Name == "String" ? queueMessage.ToString() : JsonConvert.SerializeObject(queueMessage);
             var cloudQueue = _cloudQueueClient.GetQueueReference(queue.ToLower());
             await Policy
                 .Handle<StorageException>()
@@ -60,7 +62,7 @@ await Policy
                 })
                 .ExecuteAsync(async () =>
                 {
-                    await cloudQueue.AddMessageAsync(new CloudQueueMessage(JsonConvert.SerializeObject(message)));
+                    await cloudQueue.AddMessageAsync(new CloudQueueMessage(data));
                 });
             return true;
         }

.vs/SampleFunctionApp/v16/Server/sqlite3/storage.ide

@@ -61,15 +61,15 @@ public async Task<IActionResult> Work(HttpRequest req, ILogger logger)
 
                 //Audit the request for suppoert purpose
 
-                await _audit.Create(new RequestAudit { RequestId = requestId, Data = requestBody });
+                //await _audit.Create(new RequestAudit { RequestId = requestId, Data = requestBody });
 
-                var data = JsonConvert.DeserializeObject<UserDetails>(requestBody);
+                //var data = JsonConvert.DeserializeObject<UserDetails>(requestBody);
 
-                data.Id = requestId;
-                await _engine.Process(data);
+                //data.Id = requestId;
+                //await _engine.Process(data);
 
                 var azureContext = AzureAssets.GetAzureAssets(Environment.GetEnvironmentVariable(AppSettingsKey.AzureQueueAssets));
-                
+                var data = requestBody;
 
                 if (azureContext.AssetsType == AssetsType.ServiceBus)
                 {

.vs/SampleFunctionApp/v16/Server/sqlite3/storage.ide-shm

@@ -4,10 +4,10 @@
 		"AzureWebJobsStorage": "UseDevelopmentStorage=true",
 		"FUNCTIONS_WORKER_RUNTIME": "dotnet",
 		"SampleApp_ConnectionString": "Data Source=(localdb)\\ProjectsV13;Initial Catalog=SampleApp;Integrated Security=True;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
-		"SampleApp_ServiceBus_ConnectionString": "Endpoint=sb://developmentaccount.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=2m+dy8rXboZmHrDdqkDod46Hg/DThH9aYEM1ZYFWUpoE=",
+		"SampleApp_ServiceBus_ConnectionString": "Endpoint=sb://developmentaccount.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=2m+dy8rXboZmHrDdqkDod46Hg/DThH9aYEM1ZYFWUpo=",
 		"SampleApp_ServiceBus_QueueName": "sbuserdetailsqueue",
 		"SampleApp_ServiceBus_TopicName": "sbuserdetailstopic",
-		"SampleApp_StorageAccount_ConnectionString": "DefaultEndpointsProtocol=https;AccountName=storaccpocctr;AccountKey=SzlfpjbTy+VpR0DqJHt6Wb4/TP1MEPV0eIsjHepxSxXQ5e3RitFTwwz5clAxWxXAloNO2Hc2yZvePHks65I/qgJ==;EndpointSuffix=core.windows.net",
+		"SampleApp_StorageAccount_ConnectionString": "DefaultEndpointsProtocol=https;AccountName=storaccpocctr;AccountKey=SzlfpjbTy+VpR0DqJHt6Wb4/TP1MEPV0eIsjHepxSxXQ5e3RitFTwwz5clAxWxXAloNO2Hc2yZvePHks65I/qg==;EndpointSuffix=core.windows.net",
 		"SampleApp_StorageQueueName": "squserdetailsqueue",
 		"AzureQueueAssets": "ServiceBus|Queue"
 	}