updates to output bindings

Author: paladique

event-sourcing/README.md

@@ -23,7 +23,7 @@ While event sourcing can be implemented with various types of databases, this pa
 
 1. Flexible schema: NoSQL databases generally allow for schema flexibility. Easy support for unstructured event data formats that are often in JSON formats align perfectly with the needs of event sourcing architectures.
 
-1. Scalability: NoSQL databases are typically designed for high scale. Data volumes in event sourcing patterns can range from the thousands to millions of messages per second. An underlying database needs to scale and do so seemlessly. Azure Cosmos DB's scale-out architecture is well-suited here with highly elastic throughput and storage.
+1. Scalability: NoSQL databases are typically designed for high scale. Data volumes in event sourcing patterns can range from the thousands to millions of messages per second. An underlying database needs to scale and do so seamlessly. Azure Cosmos DB's scale-out architecture is well-suited here with highly elastic throughput and storage.
 
 This sample demonstrates:
 

event-sourcing/source/CartEvent.cs

@@ -11,7 +11,7 @@ public class CartEvent
         public int UserId { get; set; }
         public string EventType { get; set; } = "";
         public string? Product { get; set; }
-        public int? QuantityChange { get; set; }
+        public int? QuantityChange { get; set; } = 0;
         public List<CartItem>? ProductsInCart { get; set; }
         public string EventTimestamp { get; set; } = DateTime.UtcNow.ToString();
     }

event-sourcing/source/EventSourceFunction.cs

@@ -11,11 +11,11 @@ namespace EventSourcing
 {
     public class EventSourceFunction
     {
-        private readonly ILogger _logger;
+        private readonly ILogger<EventSourceFunction> _logger;
 
-        public EventSourceFunction(ILoggerFactory loggerFactory)
+        public EventSourceFunction(ILogger<EventSourceFunction> logger)
         {
-            _logger = loggerFactory.CreateLogger<EventSourceFunction>();
+            _logger = logger;
         }
 
         [Function("EventSourcing")]
@@ -25,22 +25,22 @@ public EventSourceFunction(ILoggerFactory loggerFactory)
                 Connection = "CosmosDBConnection",
                 CreateIfNotExists = true,
                 PartitionKey = "/CartId")]
-        public static async Task<IActionResult> Run(
-            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
-                IAsyncCollector<CartEvent> cartEventOut,
-                ILogger log)
+        public async Task<IActionResult> Run(
+            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req, 
+                FunctionContext context)
         {
-            log.LogInformation("C# HTTP trigger function processed a request.");
+            _logger.LogInformation("C# HTTP trigger function processed a request.");
 
             string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
             string responseMessage;
 
             if (requestBody != null)
             {
                 CartEvent cartEvent = JsonConvert.DeserializeObject<CartEvent>(requestBody) ?? throw new ArgumentException("Request body is empty");
-                await cartEventOut.AddAsync(cartEvent);
+                _logger.LogInformation(JsonConvert.SerializeObject(cartEvent, Formatting.Indented));
 
-                responseMessage = $"HTTP function successful for event {cartEvent.EventType} for cart {cartEvent.CartId}.";
+                //responseMessage = $"HTTP function successful for event {cartEvent.EventType} for cart {cartEvent.CartId}.";
+                return new OkObjectResult(cartEvent);
             }
             else
             {

event-sourcing/source/EventSourcing.csproj

@@ -6,13 +6,19 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
+  <ItemGroup>
+    <None Update="local.settings.json">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+      <CopyToPublishDirectory>Never</CopyToPublishDirectory>
+    </None>
+  </ItemGroup>
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="1.21.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.CosmosDB" Version="4.6.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http" Version="3.1.0" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" Version="1.2.0" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" Version="1.17.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" Version="1.2.1" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" Version="1.17.4" />
     <PackageReference Include="Microsoft.ApplicationInsights.WorkerService" Version="2.22.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.ApplicationInsights" Version="1.2.0" />
     <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.CosmosDB" Version="4.7.0" />

event-sourcing/source/Program.cs

@@ -3,16 +3,6 @@
 using Microsoft.Extensions.Hosting;
 using Newtonsoft.Json;
 
-var host = new HostBuilder()
-    .ConfigureFunctionsWebApplication()
-    .ConfigureServices(services =>
-    {
-        services.AddApplicationInsightsTelemetryWorkerService();
-        services.ConfigureFunctionsApplicationInsights();
-    })
-    .Build();
-
-host.Run();
 
 namespace EventSourcing
 {
@@ -23,10 +13,11 @@ internal class Program
 
         public static async Task<string> CreateCartEvent(HttpClient client, CartEvent cartEvent)
         {
-            var url = $"{urlBase}/api/EventSourceFunction";
+            var url = $"{urlBase}/api/EventSourcing";
 
             string jsonBody = JsonConvert.SerializeObject(cartEvent);
             var body = new StringContent(jsonBody, System.Text.Encoding.UTF8, "application/json");
+            Console.WriteLine(jsonBody);
 
             var response = await client.PostAsync(url, body);
             string result = await response.Content.ReadAsStringAsync();
@@ -108,7 +99,7 @@ public static List<CartEvent> GenerateCartEvents()
                     cartEvent.SessionId = sessionId;
                     cartEvent.UserId = userId;
                     cartEvent.EventType = action;
-                    cartEvent.ProductsInCart = null;
+                    cartEvent.ProductsInCart =  new List<CartItem>();
                     cartEvents.Add(cartEvent);
                 }
             }
@@ -118,15 +109,25 @@ public static List<CartEvent> GenerateCartEvents()
         static async Task Main(string[] args)
         {
 
-            HttpClient httpClient = new HttpClient();
+            if (args.Length > 0 && args[0] != "console")
+            {
+                var host = new HostBuilder()
+                .ConfigureFunctionsWebApplication()
+                .ConfigureServices(services =>
+                {
+                    services.AddApplicationInsightsTelemetryWorkerService();
+                    services.ConfigureFunctionsApplicationInsights();
+                })
+                .Build();
+
+                await host.RunAsync();
+            }
+
+            else
+            {
+                HttpClient httpClient = new HttpClient();
 
-            //var services = new ServiceCollection();
-            //services.AddHttpClient(); // Add the HttpClientFactory service
-            //services.AddLogging(); // Add the logging service
-            //var serviceProvider = services.BuildServiceProvider();
 
-            //// Resolve the HttpClient from the service provider
-            //var httpClient = serviceProvider.GetRequiredService<HttpClient>();
             httpClient.Timeout = TimeSpan.FromMinutes(10);
 
             Console.WriteLine("This code will demonstrate the Event Sourcing pattern by saving shopping cart events to Azure Cosmos DB for NoSQL account.");
@@ -151,6 +152,7 @@ static async Task Main(string[] args)
 
             System.Console.WriteLine($"Function completed generation of shopping cart events");
             Console.WriteLine($"Check CartEventContainer for new shopping cart events");
+            }
         }
     }
 }