Skip to content
This repository was archived by the owner on Sep 3, 2024. It is now read-only.

Commit dda5160

Browse files
adding metadata to response
1 parent d77462c commit dda5160

2 files changed

Lines changed: 8 additions & 4 deletions

File tree

src/SqlStreamStore.HAL/AllStreamResource.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,8 @@ public async Task<Response> GetPage(
4949
message.StreamId,
5050
message.StreamVersion,
5151
message.Type,
52-
payload
52+
payload,
53+
metadata = message.JsonMetadata
5354
}).AddLinks(
5455
Links.Self(message)))));
5556

@@ -92,7 +93,8 @@ public async Task<Response> GetMessage(
9293
message.StreamId,
9394
message.StreamVersion,
9495
message.Type,
95-
payload
96+
payload,
97+
metadata = message.JsonMetadata
9698
}).AddLinks(
9799
Links.SelfAll(message),
98100
Links.Feed(options)));

src/SqlStreamStore.HAL/StreamResource.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,8 @@ public async Task<Response> GetMessage(
8585
message.StreamId,
8686
message.StreamVersion,
8787
message.Type,
88-
payload
88+
payload,
89+
metadata = message.JsonMetadata
8990
})
9091
.AddLinks(StreamMessageLinks.Self(options))
9192
.AddLinks(StreamMessageLinks.Navigation(options, message))
@@ -124,7 +125,8 @@ public async Task<Response> GetPage(ReadStreamOptions options, CancellationToken
124125
message.StreamId,
125126
message.StreamVersion,
126127
message.Type,
127-
payload
128+
payload,
129+
metadata = message.JsonMetadata
128130
}).AddLinks(StreamMessageLinks.Self(message)))),
129131
page.Status == PageReadStatus.StreamNotFound ? 404 : 200);
130132
}

0 commit comments

Comments
 (0)