Merge branch 'dev' into prod

README.md

@@ -1 +1,36 @@
-# resqueue
+# ResQueue
+
+**ResQueue** is a web-based UI management tool designed for SQL-based message transports. Currently, it offers seamless integration with MassTransit, and we're open to adding support for additional frameworks based on user feedback and demand.
+
+Join our community on [Discord](https://discord.gg/322AAB4xKx) for updates, support, and discussions.
+
+## Configuration
+
+To set up **ResQueue**, follow these simple steps:
+
+1. Install the latest version of `ResQueue.MassTransit` from NuGet to ensure compatibility with the official MassTransit updates:
+    ```bash
+    dotnet add package ResQueue.MassTransit
+    ```
+
+2. In your .NET application, configure **ResQueue** in the `WebApplication` builder by calling `builder.Services.AddResQueue()` with your database connection details. This can be done as follows:
+    ```csharp
+    var builder = WebApplication.CreateBuilder(args);
+
+    // Add ResQueue with the necessary database configuration
+    builder.Services.AddResQueue(options =>
+    {
+        // Configure database
+    });
+
+    var app = builder.Build();
+
+    app.UseResQueue();
+
+    // Run the app
+    app.Run();
+    ```
+
+3. Once this is set up, your application should work right out of the box.
+
+**ResQueue** will handle all the configuration and integration with MassTransit for you, making it simple to manage your SQL transports.

backend/ResQueue/ResQueue.sln.DotSettings

@@ -0,0 +1,3 @@
+<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:Boolean x:Key="/Default/UserDictionary/Words/=dtos/@EntryIndexedValue">True</s:Boolean>
+	<s:Boolean x:Key="/Default/UserDictionary/Words/=postgre/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>

backend/ResQueue/ResQueue/Dtos/Messages/RequeueMessagesDto.cs

@@ -1,4 +1,4 @@
-namespace ResQueue.Dtos;
+namespace ResQueue.Dtos.Messages;
 
 public record RequeueMessagesDto(
     string QueueName,

backend/ResQueue/ResQueue/Dtos/Messages/MoveMessagesDto.cs → backend/ResQueue/ResQueue/Dtos/Messages/RequeueSpecificMessagesDto.cs

@@ -1,4 +1,4 @@
-namespace ResQueue.Dtos;
+namespace ResQueue.Dtos.Messages;
 
 public record RequeueSpecificMessagesDto(
     long[] MessageDeliveryIds,

backend/ResQueue/ResQueue/Dtos/Queue/QueueDto.cs

@@ -1,4 +1,4 @@
-namespace ResQueue.Dtos;
+namespace ResQueue.Dtos.Queue;
 
 public record QueueDto(
     long Id,

backend/ResQueue/ResQueue/Dtos/Queue/QueueViewDto.cs

@@ -1,4 +1,4 @@
-namespace ResQueue.Dtos;
+namespace ResQueue.Dtos.Queue;
 
 public class QueueViewDto
 {

backend/ResQueue/ResQueue/Endpoints/MessagesEndpoints.cs

@@ -3,8 +3,9 @@
 using Microsoft.Extensions.Options;
 using Npgsql;
 using ResQueue.Dtos;
-using ResQueue.Features.Messages.MoveMessage;
+using ResQueue.Dtos.Messages;
 using ResQueue.Features.Messages.RequeueMessages;
+using ResQueue.Features.Messages.RequeueSpecificMessages;
 using ResQueue.Models.Postgres;
 using Message = ResQueue.Models.Postgres.Message;
 
@@ -20,7 +21,7 @@ public static void MapMessageEndpoints(this IEndpointRouteBuilder routes)
             async (IOptions<Settings> settings, [FromQuery] long queueId, [FromQuery] int pageIndex = 0,
                 int pageSize = 4) =>
             {
-                pageSize = 50; 
+                pageSize = 50;
                 pageIndex = pageIndex >= 0 ? pageIndex : 0;
 
                 await using var db = new NpgsqlConnection(settings.Value.PostgreSQLConnectionString);

backend/ResQueue/ResQueue/Endpoints/QueuesEndpoints.cs

@@ -3,6 +3,7 @@
 using Microsoft.Extensions.Options;
 using Npgsql;
 using ResQueue.Dtos;
+using ResQueue.Dtos.Queue;
 using ResQueue.Models.Postgres;
 
 namespace ResQueue.Endpoints;

backend/ResQueue/ResQueue/Features/Messages/RequeueMessages/RequeueMessagesFeature.cs

@@ -3,6 +3,7 @@
 using Microsoft.Extensions.Options;
 using Npgsql;
 using ResQueue.Dtos;
+using ResQueue.Dtos.Messages;
 
 namespace ResQueue.Features.Messages.RequeueMessages;
 

backend/ResQueue/ResQueue/Features/Messages/RequeueSpecificMessages/IRequeueSpecificMessagesFeature.cs

@@ -1,4 +1,4 @@
-namespace ResQueue.Features.Messages.MoveMessage;
+namespace ResQueue.Features.Messages.RequeueSpecificMessages;
 
 public interface IRequeueSpecificMessagesFeature
 {

backend/ResQueue/ResQueue/Features/Messages/RequeueSpecificMessages/RequeueSpecificMessagesFeature.cs

@@ -1,9 +1,9 @@
 using Dapper;
 using Microsoft.Extensions.Options;
 using Npgsql;
-using ResQueue.Dtos;
+using ResQueue.Dtos.Messages;
 
-namespace ResQueue.Features.Messages.MoveMessage;
+namespace ResQueue.Features.Messages.RequeueSpecificMessages;
 
 public record RequeueSpecificMessagesRequest(
     RequeueSpecificMessagesDto Dto

backend/ResQueue/ResQueue/ResQueue.csproj

@@ -42,12 +42,12 @@
 
     <ItemGroup>
         <PackageReference Include="Dapper" Version="2.1.35"/>
-        <PackageReference Include="Dapper.Contrib" Version="2.0.78"/>
         <PackageReference Include="Npgsql" Version="8.0.5"/>
-        <PackageReference Include="MailKit" Version="4.8.0"/>
         <PackageReference Include="Marten" Version="7.30.1"/>
-        <PackageReference Include="Stripe.net" Version="46.2.0"/>
-        <PackageReference Include="RabbitMQ.Client" Version="6.8.1"/>
         <PackageReference Include="NewId" Version="4.0.1"/>
     </ItemGroup>
+
+    <ItemGroup>
+        <None Remove="Properties\launchSettings.json"/>
+    </ItemGroup>
 </Project>

backend/ResQueue/ResQueue/ResQueueExtensions.cs

@@ -1,8 +1,8 @@
 using Microsoft.AspNetCore.Rewrite;
 using Microsoft.Extensions.Options;
 using ResQueue.Endpoints;
-using ResQueue.Features.Messages.MoveMessage;
 using ResQueue.Features.Messages.RequeueMessages;
+using ResQueue.Features.Messages.RequeueSpecificMessages;
 
 namespace ResQueue;