Merge pull request #69 from MarcosCostaDev/fix/add-try-catch

Add try catch
MarcosCostaDev · Aug 22, 2023 · b93bf4a · b93bf4a
2 parents 69fa558 + 6b2bd18
commit b93bf4a
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 22 deletions.
diff --git a/src/RinhaBackEnd/HostedServices/QueueConsumerHostedService.cs b/src/RinhaBackEnd/HostedServices/QueueConsumerHostedService.cs
@@ -27,24 +27,33 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                 continue;
             }
             NpgsqlConnection connection = null!;
-            connection = scope.ServiceProvider.GetRequiredService<NpgsqlConnection>();
-            await connection.OpenAsync(stoppingToken);
-
-            await using var batch = new NpgsqlBatch(connection);
-
-            for (int i = 0; i < peopleInQueue.Length; i++)
+            try
             {
-                var cmd = new NpgsqlBatchCommand("INSERT INTO PESSOAS (ID, APELIDO, NOME, NASCIMENTO, STACK) VALUES ($1, $2, $3, $4, $5)");
-                cmd.Parameters.AddWithValue(peopleInQueue[i].Id);
-                cmd.Parameters.AddWithValue(peopleInQueue[i].Apelido);
-                cmd.Parameters.AddWithValue(peopleInQueue[i].Nome);
-                cmd.Parameters.AddWithValue(peopleInQueue[i].Nascimento);
-                cmd.Parameters.AddWithValue(peopleInQueue[i].Stack);
-                batch.BatchCommands.Add(cmd);
+                connection = scope.ServiceProvider.GetRequiredService<NpgsqlConnection>();
+                await connection.OpenAsync(stoppingToken);
+
+                await using var batch = new NpgsqlBatch(connection);
+
+                for (int i = 0; i < peopleInQueue.Length; i++)
+                {
+                    var cmd = new NpgsqlBatchCommand("INSERT INTO PESSOAS (ID, APELIDO, NOME, NASCIMENTO, STACK) VALUES ($1, $2, $3, $4, $5)");
+                    cmd.Parameters.AddWithValue(peopleInQueue[i].Id);
+                    cmd.Parameters.AddWithValue(peopleInQueue[i].Apelido);
+                    cmd.Parameters.AddWithValue(peopleInQueue[i].Nome);
+                    cmd.Parameters.AddWithValue(peopleInQueue[i].Nascimento);
+                    cmd.Parameters.AddWithValue(peopleInQueue[i].Stack);
+                    batch.BatchCommands.Add(cmd);
+                }
+
+                await batch.ExecuteNonQueryAsync(stoppingToken);
+            }
+            catch
+            {
+            }
+            finally
+            {
+                connection?.Close();
             }
-
-            await batch.ExecuteNonQueryAsync(stoppingToken);
-            connection?.Close();
         }
     }
 }
diff --git a/src/RinhaBackEnd/Program.cs b/src/RinhaBackEnd/Program.cs
@@ -3,8 +3,6 @@
 using RinhaBackEnd.Dtos.Response;
 using RinhaBackEnd.Extensions;
 using RinhaBackEnd.HostedServices;
-using StackExchange.Redis;
-using System.Collections.Concurrent;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -59,8 +57,6 @@
 
     await db.StringSetAsync($"personApelido:{person.Apelido}", ".", TimeSpan.FromMinutes(10));
 
-    //localRecords.TryAdd(result.Id, result);
-
     await sub.PublishAsync("added-record", jsonResult);
 
     return Results.Created(new Uri($"/pessoas/{person.Id}", uriKind: UriKind.Relative), result);

diff --git a/src/docker-compose.yml b/src/docker-compose.yml
@@ -55,13 +55,13 @@ services:
        POSTGRES_DB: rinhadb
     volumes:
       - ./create-script.sql:/docker-entrypoint-initdb.d/create-script.sql
-    command: postgres -c 'max_connections=1000'
+    command: postgres -c 'max_connections=1000' -c work_mem=800MB -c shared_buffers=1GB
   redis:
     image: redis
     container_name: cache
     ports:
       - "6379:6379"
-    command: redis-server --save "" --appendonly no
+    command: redis-server --save "" --appendonly no --maxclients 20000
     deploy:
       resources:
         limits: