Review: application code
The class contains logic for processing new orders. It retrieves orders and items from the database, then makes an HTTP call to an external Stock microservice, which reserves goods for the order items. If all reservations are successful, the microservice confirms the reservation in Stock and marks the order as processed. The microservice runs in multiple instances, so the Process method can execute in parallel. To prevent processing the same rows, a pessimistic locking mechanism 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;" }
};
```
