Add NSB10 version for Entity Framework Core sample (#7565)

* Remove background service

* Copy to new version

* Updates for new version

* Wrong spot

* Fine all preview

* Restore fake password

Author: DavidBoike

samples/entity-framework-core/SqlPersistence_8/Endpoint.SqlPersistence/Program.cs

@@ -3,12 +3,12 @@
 using NServiceBus;
 using NServiceBus.Persistence.Sql;
 using System;
+using System.Linq;
 using Microsoft.Data.SqlClient;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Hosting;
 
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<Sender>();
 
 //for local instance or SqlExpress
 //var connectionString = @"Data Source=(localdb)\mssqllocaldb;Database=NsbSamplesEfCoreUowSql;Trusted_Connection=True;MultipleActiveResultSets=true";
@@ -63,10 +63,35 @@
 
 #endregion
 
-Console.WriteLine("Press any key, the application is starting");
-Console.ReadKey();
-Console.WriteLine("Starting...");
-
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+await host.StartAsync();
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+var random = new Random();
+const string letters = "ABCDEFGHIJKLMNOPQRSTUVXYZ";
+var locations = new[] { "London", "Paris", "Oslo", "Madrid" };
+
+while (true)
+{
+    Console.WriteLine("Press enter to send a message, any other key to exit");
+    var key = Console.ReadKey();
+    Console.WriteLine();
+
+    if (key.Key != ConsoleKey.Enter)
+    {
+        break;
+    }
+    var orderId = new string(Enumerable.Range(0, 4).Select(x => letters[random.Next(letters.Length)]).ToArray());
+    var shipTo = locations[random.Next(locations.Length)];
+    var orderSubmitted = new OrderSubmitted
+    {
+        OrderId = orderId,
+        Value = random.Next(100),
+        ShipTo = shipTo
+    };
+    await messageSession.SendLocal(orderSubmitted);
+}
+
+await host.StopAsync();

samples/entity-framework-core/SqlPersistence_8/Endpoint.SqlPersistence/Sender.cs

@@ -0,0 +1,5 @@
+public class Order
+{
+    public virtual string OrderId { get; set; }
+    public virtual decimal Value { get; set; }
+}

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Data/Order.cs

@@ -0,0 +1,22 @@
+using Microsoft.EntityFrameworkCore;
+
+public class ReceiverDataContext(DbContextOptions options) :
+    DbContext(options)
+{
+    public DbSet<Order> Orders { get; set; }
+    public DbSet<Shipment> Shipments { get; set; }
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        base.OnModelCreating(modelBuilder);
+
+        var orders = modelBuilder.Entity<Order>();
+        orders.ToTable("Orders");
+        orders.HasKey(x => x.OrderId);
+        orders.Property(x => x.Value);
+
+        var shipments = modelBuilder.Entity<Shipment>();
+        shipments.ToTable("Shipments");
+        shipments.HasKey(x => x.Id);
+    }
+}

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Data/ReceiverDataContext.cs

@@ -0,0 +1,11 @@
+using System;
+using System.ComponentModel.DataAnnotations;
+
+public class Shipment
+{
+    public virtual Guid Id { get; set; }
+
+    [Required]
+    public virtual Order Order { get; set; }
+    public virtual string Location { get; set; }
+}

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Data/Shipment.cs

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <OutputType>Exe</OutputType>
+    <LangVersion>preview</LangVersion>
+  </PropertyGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\Messages\Messages.csproj" />
+    <PackageReference Include="Microsoft.Data.SqlClient" Version="6.*" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.*" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.*" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.2" />
+    <PackageReference Include="NServiceBus.Persistence.Sql" Version="9.0.0-alpha.2" />
+    <PackageReference Include="NServiceBus.Transport.SqlServer" Version="9.0.0-alpha.2" />
+  </ItemGroup>
+</Project>

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Endpoint.SqlPersistence.csproj

@@ -0,0 +1,17 @@
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using NServiceBus;
+using Microsoft.Extensions.Logging;
+
+public class CompleteOrderHandler(ReceiverDataContext dataContext, ILogger<CompleteOrderHandler> logger)
+        : IHandleMessages<CompleteOrder>
+{
+    
+    public async Task Handle(CompleteOrder message, IMessageHandlerContext context)
+    {
+        var order = await dataContext.Orders.FindAsync(message.OrderId, context.CancellationToken);
+        var shipment = await dataContext.Shipments.FirstAsync(x => x.Order.OrderId == order.OrderId, context.CancellationToken);
+
+        logger.LogInformation($"Completing order {order.OrderId} worth {order.Value} by shipping to {shipment.Location}.");
+    }
+} 

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Handlers/CompleteOrderHandler.cs

@@ -0,0 +1,25 @@
+using NServiceBus;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+
+public class CreateOrderHandler(ReceiverDataContext dataContext, ILogger<CreateOrderHandler> logger) :
+    IHandleMessages<OrderSubmitted>
+{
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        #region StoreOrder
+
+        var order = new Order
+        {
+            OrderId = message.OrderId,
+            Value = message.Value
+        };
+        dataContext.Orders.Add(order);
+
+        #endregion
+
+        logger.LogInformation($"Order {message.OrderId} worth {message.Value} created.");
+
+        return Task.CompletedTask;
+    }
+}

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Handlers/CreateOrderHandler.cs

@@ -0,0 +1,30 @@
+using System;
+using System.Linq;
+using NServiceBus;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+
+public class CreateShipmentHandler(ReceiverDataContext dataContext, ILogger<CreateShipmentHandler> logger) :
+    IHandleMessages<OrderSubmitted>
+{
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        #region StoreShipment
+
+        var order = dataContext.Orders.Local.Single(x => x.OrderId == message.OrderId);
+
+        var shipment = new Shipment
+        {
+            Id = Guid.NewGuid(),
+            Order = order,
+            Location = message.ShipTo
+        };
+        dataContext.Shipments.Add(shipment);
+
+        #endregion
+
+        logger.LogInformation($"Shipment for {message.OrderId} created.");
+
+        return Task.CompletedTask;
+    }
+}

samples/entity-framework-core/SqlPersistence_9/Endpoint.SqlPersistence/Handlers/CreateShipmentHandler.cs

@@ -0,0 +1,14 @@
+using System.Threading.Tasks;
+using NServiceBus;
+using Microsoft.Extensions.Logging;
+
+public class OrderAcceptedHandler(ILogger<OrderAcceptedHandler> logger) :
+    IHandleMessages<OrderAccepted>
+{
+  
+    public Task Handle(OrderAccepted message, IMessageHandlerContext context)
+    {
+        logger.LogInformation($"Order {message.OrderId} accepted.");
+        return Task.CompletedTask;
+    }
+}