Fixed a few bugs

Author: johnsimons

src/ServiceControl.Audit.Persistence.PostgreSQL/PostgresqlMessagesQueryBuilder.cs

@@ -46,7 +46,7 @@ public PostgresqlMessagesQueryBuilder WithSearch(string? q)
     {
         if (!string.IsNullOrWhiteSpace(q))
         {
-            sql.Append(" and query @@ to_tsquery('english', @search)");
+            sql.Append(" and query @@ plainto_tsquery('english', @search)");
             parameters.Add(new NpgsqlParameter("search", q));
         }
         return this;

src/ServiceControl.Audit.Persistence.PostgreSQL/UnitOfWork/PostgreSQLAuditIngestionUnitOfWork.cs

@@ -61,13 +61,14 @@ INSERT INTO processed_messages (
         cmd.Parameters.AddWithValue("message_type", GetMetadata<string>("MessageType"));
         cmd.Parameters.AddWithValue("is_system_message", GetMetadata<bool>("IsSystemMessage"));
         cmd.Parameters.AddWithValue("time_sent", GetMetadata<DateTime>("TimeSent"));
-        cmd.Parameters.AddWithValue("receiving_endpoint_name", GetMetadata<EndpointDetails>("ReceivingEndpoint").Name);
+        cmd.Parameters.AddWithValue("receiving_endpoint_name", GetMetadata<EndpointDetails>("ReceivingEndpoint")?.Name ?? (object)DBNull.Value);
         cmd.Parameters.AddWithValue("critical_time", GetMetadata<TimeSpan>("CriticalTime"));
         cmd.Parameters.AddWithValue("processing_time", GetMetadata<TimeSpan>("ProcessingTime"));
         cmd.Parameters.AddWithValue("delivery_time", GetMetadata<TimeSpan>("DeliveryTime"));
         cmd.Parameters.AddWithValue("conversation_id", GetMetadata<string>("ConversationId"));
         cmd.Parameters.AddWithValue("status", (int)(GetMetadata<bool>("IsRetried") ? MessageStatus.ResolvedSuccessfully : MessageStatus.Successful));
 
+        batch.BatchCommands.Add(cmd);
         return Task.CompletedTask;
     }
 
@@ -94,6 +95,7 @@ INSERT INTO saga_snapshots (
         cmd.Parameters.AddWithValue("outgoing_messages", NpgsqlTypes.NpgsqlDbType.Jsonb, sagaSnapshot.OutgoingMessages);
         cmd.Parameters.AddWithValue("endpoint", sagaSnapshot.Endpoint);
         cmd.Parameters.AddWithValue("processed_at", sagaSnapshot.ProcessedAt);
+        batch.BatchCommands.Add(cmd);
 
         return Task.CompletedTask;
     }
@@ -115,6 +117,7 @@ INSERT INTO known_endpoints (
         cmd.Parameters.AddWithValue("host_id", knownEndpoint.HostId);
         cmd.Parameters.AddWithValue("host", knownEndpoint.Host);
         cmd.Parameters.AddWithValue("last_seen", knownEndpoint.LastSeen);
+        batch.BatchCommands.Add(cmd);
 
         return Task.CompletedTask;
     }