Review: applied code
The class contains the logic for processing new orders. It extracts orders and positions from the database, then makes an HTTP request to an external microservice Stock, which reserves products according to the order positions. If all reservations are successful, the microservice confirms the order reservation in Stock and marks the order as processed. The microservice runs in multiple instances, so the Process method can be executed in parallel. To prevent processing the same rows, a pessimistic locking mechanism in PostgreSQL Select for update ... skip locked is used. The IBus implementation sends messages to RabbitMq.
```csharp
public sealed class PendingOrdersProcessor
{
public async Task PendingOrdersProcessor(ILogger logger, IBus bus, HttpStockService st
{
var env = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
var cs = _cs[env];
_db = new OrdersRepository(cs);
_bus = bus;
logger = logger;
```
```csharp
_stockService = stockService;
}
private readonly ILogger _logger;
private readonly IOrdersRepository _db;
private readonly IStockService _stockService;
private readonly IBus _bus;
private static readonly Dictionary<string, string> _cs = new {
{ "Development",
"User ID=root;Password=myPassword;Host=localhost;Port=5432;Database=myDataBase"
},
{ "Production", "User ID=root;Password=myPassword;Host=prod-db;Port=5432;Database="
"Pooling=true;Min Pool Size=0;Max Pool Size=1;" }
};
```
