Add url for message body

Author: johnsimons

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

@@ -30,7 +30,8 @@ public async Task<MessageBodyView> GetMessageBody(string messageId, Cancellation
         using var reader = await cmd.ExecuteReaderAsync(cancellationToken);
         if (await reader.ReadAsync(cancellationToken))
         {
-            var stream = await reader.GetStreamAsync(reader.GetOrdinal("body"), cancellationToken);
+            //var stream = await reader.GetStreamAsync(reader.GetOrdinal("body"), cancellationToken);
+            var stream = reader.GetStream(reader.GetOrdinal("body"));
             var contentType = reader.GetFieldValue<Dictionary<string, string>>(reader.GetOrdinal("headers")).GetValueOrDefault(Headers.ContentType, "text/xml");
             return MessageBodyView.FromStream(stream, contentType, (int)stream.Length, string.Empty);
         }
@@ -215,12 +216,13 @@ async Task<QueryResult<IList<MessagesView>>> ReturnResults(NpgsqlCommand cmd, Ca
                 Headers = [.. headers],
                 Status = (MessageStatus)GetValue<int>(reader, "status"),
                 MessageIntent = (MessageIntent)DeserializeOrDefault(messageMetadata, "MessageIntent", 1),
-                BodyUrl = "",
+                BodyUrl = string.Format(BodyUrlFormatString, GetValue<string>(reader, "message_id")),
                 BodySize = DeserializeOrDefault(messageMetadata, "ContentLength", 0),
                 InvokedSagas = DeserializeOrDefault<List<SagaInfo>>(messageMetadata, "InvokedSagas", []),
                 OriginatesFromSaga = DeserializeOrDefault<SagaInfo>(messageMetadata, "OriginatesFromSaga")
             });
         }
         return new QueryResult<IList<MessagesView>>(results, new QueryStatsInfo(string.Empty, results.Count));
     }
+    public const string BodyUrlFormatString = "/messages/{0}/body";
 }

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

@@ -1,7 +1,6 @@
 namespace ServiceControl.Audit.Persistence.PostgreSQL.UnitOfWork;
 
 using System;
-using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
 using Npgsql;