CreateRating.cs

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using System.Net.Http;
using System.Text.Json;
using System.Text.Json.Serialization;
using System.Collections.Generic;
using System;
using System.Configuration;
using System.Net;
using Microsoft.Azure.Cosmos;

namespace FunctionAppOH
{
    public static class CreateRating
    {
        // The Azure Cosmos DB endpoint for running this sample.
        private static readonly string EndpointUri = "https://txtteam3-test-cosmo.documents.azure.com:443/";
        // The primary key for the Azure Cosmos account.
        private static readonly string PrimaryKey = "XfhHVjjS8jnmk0GLts174Hp680MXUMwkE8ElbyiUME91bG31lYKKTApRUgVs40EcKZfJmPU8rC1legwusywqeA==";

        // The Cosmos client instance
        private static CosmosClient cosmosClient;

        // The database we will create
        private static Database database;

        // The container we will create.
        private static Container container;

        // The name of the database and container we will create
        private static string databaseId = "taskDatabase";
        private static string containerId = "Container1";

        [FunctionName("CreateRating")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get","post", Route = null)] HttpRequest req,
            ILogger log)
        {
            try {
                cosmosClient = new CosmosClient(EndpointUri, PrimaryKey, new CosmosClientOptions()
                {
                    ConnectionMode = ConnectionMode.Gateway
                });

                //var sqlQueryText = "SELECT * FROM c ";


                //QueryDefinition queryDefinition = new QueryDefinition(sqlQueryText);

                //container = cosmosClient.GetContainer(databaseId, containerId);

                //FeedIterator<test> queryResultSetIterator = cosmosClient.GetContainer(databaseId, containerId).GetItemQueryIterator<test>(queryDefinition);

                //List<test> families = new List<test>();

                //while (queryResultSetIterator.HasMoreResults)
                //{
                //    FeedResponse<test> currentResultSet = await queryResultSetIterator.ReadNextAsync();
                //    foreach (test family in currentResultSet)
                //    {
                //        families.Add(family);
                //    }
                //}


                log.LogInformation("C# HTTP trigger function processed a request.");

                string productId = "";
                string userId = "";
                string location = "";
                string uNotes = "";
                int rating = -1;
                string errorText = "";

                string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
                dynamic data = JsonConvert.DeserializeObject(requestBody);
                
                productId = data?.productId;
                userId = data?.userId;

                string tmpRating = data?.rating;

                bool isRatingValid = int.TryParse(tmpRating, out rating);

                location = data?.locationName;
                uNotes = data?.userNotes;


                try
                {
                    HttpClient client = new HttpClient();
                    HttpResponseMessage responseProduct = await client.GetAsync("https://serverlessohproduct.trafficmanager.net/api/GetProduct?productId="+ productId);
                    responseProduct.EnsureSuccessStatusCode();
                    string responseBody = await responseProduct.Content.ReadAsStringAsync();
                
                    Product getProduct = System.Text.Json.JsonSerializer.Deserialize<Product>(responseBody);
                }
                catch(Exception ex)
                {
                    errorText += "1";
                    log.LogInformation("product error: " + ex.ToString());
                }

                try
                {
                    HttpClient client2 = new HttpClient();
                    HttpResponseMessage responseUSer = await client2.GetAsync("https://serverlessohuser.trafficmanager.net/api/GetUser?userId=" + userId);
                    responseUSer.EnsureSuccessStatusCode();
                    string responseBody2 = await responseUSer.Content.ReadAsStringAsync();
                
                    User getUser = System.Text.Json.JsonSerializer.Deserialize<User>(responseBody2);
                }
                catch (Exception ex)
                {
                    errorText += "2";
                    log.LogInformation("user error: " + ex.ToString());
                }

                if(!isRatingValid || 0 > rating || 5 < rating)
                {
                    errorText += "3";
                    log.LogInformation("invalid rating");
                }

                object tmpResponse  = errorText;

                if (errorText.Length == 0)
                {
                    try
                    {
                        tmpResponse = new ratingModel
                        {
                            id = Guid.NewGuid().ToString(),
                            userId = userId,
                            productId = productId,
                            timestamp = DateTime.UtcNow,
                            locationName = location,
                            rating = rating,
                            userNotes = uNotes
                        };
                        ItemResponse<ratingModel> wakefieldFamilyResponse = await container.CreateItemAsync<ratingModel>(
                            (ratingModel)tmpResponse
                        );
                    }
                    catch (Exception ex)
                    {

                    }
                }

                if(errorText.Length == 0)
                    return new OkObjectResult(tmpResponse);
                else
                    return new NotFoundResult();
            }
            catch (Exception ex)
            {
                return new NotFoundResult();
            }
        }
    }

    //private static async Task<List<Product>> GetProductsAsync()
    //{
    //}
    //private static Product GetProduct(string productid)
    //{

    //}

    //{"productId":"75542e38-563f-436f-adeb-f426f1dabb5c","productName":"Starfruit Explosion","productDescription":"This starfruit ice cream is out of this world!"}
    internal class Product{
        public string productId { get; set; }
        public string productName { get; set; }
        public string productDescription { get; set; }
    }

    //{"userId":"cc20a6fb-a91f-4192-874d-132493685376","userName":"doreen.riddle","fullName":"Doreen Riddle"}
    internal class User
    {
        public string userId { get; set; }
        public string userName { get; set; }
        public string fullName { get; set; }
    }

    internal class test
    {
        public string name { get; set; }
        public string duedate { get; set; }
        public string task { get; set; }
        public string id { get; set; }
    }

//    {
//  "id": "79c2779e-dd2e-43e8-803d-ecbebed8972c",
//  "userId": "cc20a6fb-a91f-4192-874d-132493685376",
//  "productId": "4c25613a-a3c2-4ef3-8e02-9c335eb23204",
//  "timestamp": "2018-05-21 21:27:47Z",
//  "locationName": "Sample ice cream shop",
//  "rating": 5,
//  "userNotes": "I love the subtle notes of orange in this ice cream!"
//}
    internal class ratingModel
    {
        public string id { get; set; }
        public string userId { get; set; }
        public string productId { get; set; }
        public DateTime timestamp { get; set; }
        public string locationName { get; set; }
        public int rating { get; set; }
        public string userNotes { get; set; }
    }
}