#392 Host.Outbox.PostgreSql

Signed-off-by: Richard Pringle <richardpringle@gmail.com>

Author: EtherZa

docs/plugin_outbox.md

@@ -5,11 +5,16 @@ Please read the [Introduction](intro.md) before reading this provider documentat
 - [Introduction](#introduction)
 - [Configuration](#configuration)
   - [Entity Framework](#entity-framework)
-  - [SQL Connection](#sql-connection)
+    - [PostgreSQL](#postgresql)
+    - [SQL Server](#sql-server)
+  - [Direct Connection](#direct-connection)
+    - [PostgreSQL](#postgresql-1)
+    - [SQL Server](#sql-server-1)
 - [Options](#options)
   - [UseOutbox for Producers](#useoutbox-for-producers)
   - [Transactions for Consumers](#transactions-for-consumers)
     - [UseTransactionScope](#usetransactionscope)
+    - [UsePostgreSqlTransaction](#usepostgresqltransaction)
     - [UseSqlTransaction](#usesqltransaction)
 - [How it works](#how-it-works)
 - [Clean up](#clean-up)
@@ -18,16 +23,29 @@ Please read the [Introduction](intro.md) before reading this provider documentat
 ## Introduction
 
 The [`Host.Outbox`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox) introduces [Transactional Outbox](https://microservices.io/patterns/data/transactional-outbox.html) pattern to the SlimMessageBus.
-It comes in two flavors:
 
+PostgreSQL
+- [`Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql) as integration with the [Npgsql](https://www.npgsql.org/) client
+- [`Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext) as integration with Entity Framework Core using Npgsql
+
+SQL server
 - [`Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) as integration with the System.Data.Sql client (MSSQL)
-- [`Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) as integration with Entity Framework Core
+- [`Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) as integration with Entity Framework Core using System.Data.Sql
 
 Outbox plugin can work in combination with any transport provider.
 
 ## Configuration
 
 ### Entity Framework
+#### PostgreSQL
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql.DbContext;
+```
+
+#### SQL Server
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext)
 
@@ -40,7 +58,7 @@ Consider the following example (from [Samples](../src/Samples/Sample.OutboxWebAp
 - `services.AddOutboxUsingDbContext<CustomerContext>(...)` is used to add the [Outbox.DbContext](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) plugin to the container.
 - `CustomerContext` is the application specific Entity Framework `DbContext`.
 - `CustomerCreatedEvent` is produced on the `AzureSB` child bus, the bus will deliver these events via outbox - see `.UseOutbox()`
-- `CreateCustomerCommand` is consumed on the `Memory` child bus, each command is wrapped in an SQL transaction - see `UseSqlTransaction()`
+- `CreateCustomerCommand` is consumed on the `Memory` child bus, each command is wrapped in an SQL transaction - see `UsePostgreSqlTransaction()` / `UseSqlTransaction()`
 
 Startup setup:
 
@@ -52,9 +70,20 @@ builder.Services.AddSlimMessageBus(mbb =>
         .AddChildBus("Memory", mbb =>
         {
             mbb.WithProviderMemory()
-                .AutoDeclareFrom(Assembly.GetExecutingAssembly(), consumerTypeFilter: t => t.Name.EndsWith("CommandHandler"))
-                //.UseTransactionScope(messageTypeFilter: t => t.Name.EndsWith("Command")) // Consumers/Handlers will be wrapped in a TransactionScope
-                .UseSqlTransaction(messageTypeFilter: t => t.Name.EndsWith("Command")); // Consumers/Handlers will be wrapped in a SqlTransaction ending with Command
+                .AutoDeclareFrom(Assembly.GetExecutingAssembly(), consumerTypeFilter: t => t.Name.EndsWith("CommandHandler"));
+            //.UseTransactionScope(messageTypeFilter: t => t.Name.EndsWith("Command")) // Consumers/Handlers will be wrapped in a TransactionScope
+            //.UseSqlTransaction(messageTypeFilter: t => t.Name.EndsWith("Command")); // Consumers/Handlers will be wrapped in a SqlTransaction ending with Command
+
+            switch (dbProvider)
+            {
+                case DbProvider.SqlServer:
+                    mbb.UseSqlTransaction(messageTypeFilter: t => t.Name.EndsWith("Command")); // Consumers/Handlers will be wrapped in a SqlTransaction ending with Command
+                    break;
+
+                case DbProvider.PostgreSql:
+                    mbb.UsePostgreSqlTransaction(messageTypeFilter: t => t.Name.EndsWith("Command")); // Consumers/Handlers will be wrapped in a SqlTransaction ending with Command
+                    break;
+            }
         })
         .AddChildBus("AzureSB", mbb =>
         {
@@ -81,20 +110,40 @@ builder.Services.AddSlimMessageBus(mbb =>
                     // x.UseOutbox();
                 })
                 // All outgoing messages from this bus will go out via an outbox
-                .UseOutbox(/* messageTypeFilter: t => t.Name.EndsWith("Command") */); // Additionaly, can apply filter do determine messages that should go out via outbox                
+                .UseOutbox(/* messageTypeFilter: t => t.Name.EndsWith("Command") */); // Additionally, can apply filter do determine messages that should go out via outbox                
         })
         .AddServicesFromAssembly(Assembly.GetExecutingAssembly())
         .AddJsonSerializer()
-        .AddAspNet()
-        .AddOutboxUsingDbContext<CustomerContext>(opts =>
-        {
-            opts.PollBatchSize = 100;
-            opts.PollIdleSleep = TimeSpan.FromSeconds(10);
-            opts.MessageCleanup.Interval = TimeSpan.FromSeconds(10);
-            opts.MessageCleanup.Age = TimeSpan.FromMinutes(1);
-            //opts.SqlSettings.TransactionIsolationLevel = System.Data.IsolationLevel.RepeatableRead;
-            //opts.SqlSettings.Dialect = SqlDialect.SqlServer;
-        });
+        .AddAspNet();
+
+    switch (dbProvider)
+    {
+        case DbProvider.SqlServer:
+            SlimMessageBus.Host.Outbox.Sql.DbContext.MessageBusBuilderExtensions.AddOutboxUsingDbContext<CustomerContext>(mbb, opts =>
+            {
+                opts.PollBatchSize = 500;
+                opts.PollIdleSleep = TimeSpan.FromSeconds(10);
+                opts.MessageCleanup.Interval = TimeSpan.FromSeconds(10);
+                opts.MessageCleanup.Age = TimeSpan.FromMinutes(1);
+                //opts.SqlSettings.TransactionIsolationLevel = System.Data.IsolationLevel.RepeatableRead;
+                //opts.SqlSettings.Dialect = SqlDialect.SqlServer;
+            });
+
+            break;
+
+        case DbProvider.PostgreSql:
+            SlimMessageBus.Host.Outbox.PostgreSql.DbContext.MessageBusBuilderExtensions.AddOutboxUsingDbContext<CustomerContext>(mbb, opts =>
+            {
+                opts.PollBatchSize = 500;
+                opts.PollIdleSleep = TimeSpan.FromSeconds(10);
+                opts.MessageCleanup.Interval = TimeSpan.FromSeconds(10);
+                opts.MessageCleanup.Age = TimeSpan.FromMinutes(1);
+                //opts.SqlSettings.TransactionIsolationLevel = System.Data.IsolationLevel.RepeatableRead;
+                //opts.SqlSettings.Dialect = SqlDialect.SqlServer;
+            });
+
+            break;
+    }
 });
 ```
 
@@ -119,7 +168,16 @@ public record CreateCustomerCommandHandler(IMessageBus Bus, CustomerContext Cust
 }
 ```
 
-### SQL Connection
+### Direct Connection
+#### PostgreSQL
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql;
+```
+
+#### SQL Server
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql)
 
@@ -129,7 +187,7 @@ using SlimMessageBus.Host.Outbox.Sql;
 
 Consider the following example:
 
-- `services.AddMessageBusOutboxUsingSql(...)` is used to add the [Outbox.Sql](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) plugin to the container.
+- `services.AddOutboxUsingSql(...)` is used to add the [Outbox.Sql](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) plugin to the container.
 - `SqlConnection` is registered in the container
 
 ```cs
@@ -181,6 +239,20 @@ using SlimMessageBus.Host.Outbox;
 
 When applied on the (child) bus level then all consumers (or handlers) will inherit that option.
 
+#### UsePostgreSqlTransaction
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql) or [`SlimMessageBus.Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql;
+```
+
+`.UsePostgreSqlTransaction()` can be used on consumers (or handlers) declaration to force the consumer to start a `PostgreSqlTransaction` prior the message `OnHandle` and to complete that transaction after it. Any exception raised by the consumer would cause the transaction to be rolled back.
+
+When applied on the (child) bus level then all consumers (or handlers) will inherit that option.
+
+`PostgreSqlTransaction`-s are created off the associated `NpgsqlConnection`.
+
 #### UseSqlTransaction
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) or [`SlimMessageBus.Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext)
@@ -204,7 +276,7 @@ When applied on the (child) bus level then all consumers (or handlers) will inhe
 - When a message is sent via a bus or producer marked with `.UseOutbox()` then such message will be inserted into the `Outbox` table.
   It is important that message publish happens in the context of an transaction to ensure consistency.
 
-- When the message publication happens in the context of a consumer (or handler) of another message, the `.UseTransactionScope()`, `.UseSqlTransaction()` can be used to start a transaction.
+- When the message publication happens in the context of a consumer (or handler) of another message, the `.UseTransactionScope()`, `.UseSqlTransaction()` or `.UseSqlTransaction()` can be used to start a transaction.
 
 - The transaction can be managed by the application, starting it either explicitly using `DbContext.Database.BeginTransactionAsync()` or creating a `TransactionScope()`.
 

docs/plugin_outbox.t.md

@@ -5,11 +5,16 @@ Please read the [Introduction](intro.md) before reading this provider documentat
 - [Introduction](#introduction)
 - [Configuration](#configuration)
   - [Entity Framework](#entity-framework)
-  - [SQL Connection](#sql-connection)
+    - [PostgreSQL](#postgresql)
+    - [SQL Server](#sql-server)
+  - [Direct Connection](#direct-connection)
+    - [PostgreSQL](#postgresql-1)
+    - [SQL Server](#sql-server-1)
 - [Options](#options)
   - [UseOutbox for Producers](#useoutbox-for-producers)
   - [Transactions for Consumers](#transactions-for-consumers)
     - [UseTransactionScope](#usetransactionscope)
+    - [UsePostgreSqlTransaction](#usepostgresqltransaction)
     - [UseSqlTransaction](#usesqltransaction)
 - [How it works](#how-it-works)
 - [Clean up](#clean-up)
@@ -18,16 +23,29 @@ Please read the [Introduction](intro.md) before reading this provider documentat
 ## Introduction
 
 The [`Host.Outbox`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox) introduces [Transactional Outbox](https://microservices.io/patterns/data/transactional-outbox.html) pattern to the SlimMessageBus.
-It comes in two flavors:
 
+PostgreSQL
+- [`Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql) as integration with the [Npgsql](https://www.npgsql.org/) client
+- [`Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext) as integration with Entity Framework Core using Npgsql
+
+SQL server
 - [`Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) as integration with the System.Data.Sql client (MSSQL)
-- [`Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) as integration with Entity Framework Core
+- [`Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) as integration with Entity Framework Core using System.Data.Sql
 
 Outbox plugin can work in combination with any transport provider.
 
 ## Configuration
 
 ### Entity Framework
+#### PostgreSQL
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql.DbContext;
+```
+
+#### SQL Server
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext)
 
@@ -40,7 +58,7 @@ Consider the following example (from [Samples](../src/Samples/Sample.OutboxWebAp
 - `services.AddOutboxUsingDbContext<CustomerContext>(...)` is used to add the [Outbox.DbContext](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext) plugin to the container.
 - `CustomerContext` is the application specific Entity Framework `DbContext`.
 - `CustomerCreatedEvent` is produced on the `AzureSB` child bus, the bus will deliver these events via outbox - see `.UseOutbox()`
-- `CreateCustomerCommand` is consumed on the `Memory` child bus, each command is wrapped in an SQL transaction - see `UseSqlTransaction()`
+- `CreateCustomerCommand` is consumed on the `Memory` child bus, each command is wrapped in an SQL transaction - see `UsePostgreSqlTransaction()` / `UseSqlTransaction()`
 
 Startup setup:
 
@@ -50,7 +68,16 @@ Command handler:
 
 @[:cs](../src/Samples/Sample.OutboxWebApi/Application/CreateCustomerCommandHandler.cs,Handler)
 
-### SQL Connection
+### Direct Connection
+#### PostgreSQL
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql;
+```
+
+#### SQL Server
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql)
 
@@ -60,7 +87,7 @@ using SlimMessageBus.Host.Outbox.Sql;
 
 Consider the following example:
 
-- `services.AddMessageBusOutboxUsingSql(...)` is used to add the [Outbox.Sql](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) plugin to the container.
+- `services.AddOutboxUsingSql(...)` is used to add the [Outbox.Sql](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) plugin to the container.
 - `SqlConnection` is registered in the container
 
 ```cs
@@ -112,6 +139,20 @@ using SlimMessageBus.Host.Outbox;
 
 When applied on the (child) bus level then all consumers (or handlers) will inherit that option.
 
+#### UsePostgreSqlTransaction
+
+> Required: [`SlimMessageBus.Host.Outbox.PostgreSql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql) or [`SlimMessageBus.Host.Outbox.PostgreSql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.PostgreSql.DbContext)
+
+```cs
+using SlimMessageBus.Host.Outbox.PostgreSql;
+```
+
+`.UsePostgreSqlTransaction()` can be used on consumers (or handlers) declaration to force the consumer to start a `PostgreSqlTransaction` prior the message `OnHandle` and to complete that transaction after it. Any exception raised by the consumer would cause the transaction to be rolled back.
+
+When applied on the (child) bus level then all consumers (or handlers) will inherit that option.
+
+`PostgreSqlTransaction`-s are created off the associated `NpgsqlConnection`.
+
 #### UseSqlTransaction
 
 > Required: [`SlimMessageBus.Host.Outbox.Sql`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql) or [`SlimMessageBus.Host.Outbox.Sql.DbContext`](https://www.nuget.org/packages/SlimMessageBus.Host.Outbox.Sql.DbContext)
@@ -135,7 +176,7 @@ When applied on the (child) bus level then all consumers (or handlers) will inhe
 - When a message is sent via a bus or producer marked with `.UseOutbox()` then such message will be inserted into the `Outbox` table.
   It is important that message publish happens in the context of an transaction to ensure consistency.
 
-- When the message publication happens in the context of a consumer (or handler) of another message, the `.UseTransactionScope()`, `.UseSqlTransaction()` can be used to start a transaction.
+- When the message publication happens in the context of a consumer (or handler) of another message, the `.UseTransactionScope()`, `.UseSqlTransaction()` or `.UseSqlTransaction()` can be used to start a transaction.
 
 - The transaction can be managed by the application, starting it either explicitly using `DbContext.Database.BeginTransactionAsync()` or creating a `TransactionScope()`.
 

src/Infrastructure/docker-compose.yml

@@ -34,6 +34,17 @@ services:
     networks:
       - slim
 
+  psqldb:
+    container_name: slim.psql
+    image: postgres:17.4
+    environment:
+      - POSTGRES_USER=postgres
+      - POSTGRES_PASSWORD=SecretP@55word
+    ports:
+      - 5432:5432
+    networks:
+      - slim      
+
   rabbitmq:
     container_name: slim.rabbitmq
     image: rabbitmq:3.12.14-management-alpine

src/Samples/Sample.OutboxWebApi/DbProvider.cs

@@ -0,0 +1,7 @@
+namespace Sample.OutboxWebApi;
+
+public enum DbProvider
+{
+    PostgreSql,
+    SqlServer
+}