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

Commit 3133d22

Browse files
thefringeninjathefringeninja
committed
Added a link for finding a stream
1 parent f63097f commit 3133d22

11 files changed

Lines changed: 82 additions & 25 deletions

‎src/SqlStreamStore.HAL.Tests/AllStreamMessageTests.cs‎

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,14 @@ public async Task read_single_message_all_stream()
3333
{
3434
Constants.Relations.Self,
3535
Constants.Relations.Message,
36-
Constants.Relations.Feed
36+
Constants.Relations.Feed,
37+
Constants.Relations.Find
3738
});
3839

3940
resource.ShouldLink(Constants.Relations.Self, "0");
4041
resource.ShouldLink(Constants.Relations.Message, "0");
4142
resource.ShouldLink(Constants.Relations.Feed, HeadOfAll);
43+
resource.ShouldLink(Constants.Relations.Find, "../streams/{streamId}", "Find a Stream");
4244
}
4345
}
4446

@@ -51,9 +53,14 @@ public async Task read_single_message_does_not_exist_all_stream()
5153

5254
var resource = await response.AsHal();
5355

54-
resource.Links.Keys.ShouldBe(new[] { Constants.Relations.Feed });
56+
resource.Links.Keys.ShouldBe(new[]
57+
{
58+
Constants.Relations.Feed,
59+
Constants.Relations.Find
60+
});
5561

5662
resource.ShouldLink(Constants.Relations.Feed, HeadOfAll);
63+
resource.ShouldLink(Constants.Relations.Find, "../streams/{streamId}", "Find a Stream");
5764
}
5865
}
5966
}

‎src/SqlStreamStore.HAL.Tests/StreamMessageTests.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,8 @@ public async Task read_single_message_stream()
3636
Constants.Relations.Next,
3737
Constants.Relations.Last,
3838
Constants.Relations.Feed,
39-
Constants.Relations.Message
39+
Constants.Relations.Message,
40+
Constants.Relations.Find
4041
});
4142

4243
resource.ShouldLink(Constants.Relations.Self, "0");
@@ -45,6 +46,7 @@ public async Task read_single_message_stream()
4546
resource.ShouldLink(Constants.Relations.Last, "-1");
4647
resource.ShouldLink(Constants.Relations.Feed, HeadOfStream);
4748
resource.ShouldLink(Constants.Relations.Message, "0");
49+
resource.ShouldLink(Constants.Relations.Find, "../../streams/{streamId}", "Find a Stream");
4850
}
4951
}
5052

@@ -63,14 +65,16 @@ public async Task read_single_message_does_not_exist_stream()
6365
Constants.Relations.First,
6466
Constants.Relations.Last,
6567
Constants.Relations.Feed,
66-
Constants.Relations.Message
68+
Constants.Relations.Message,
69+
Constants.Relations.Find
6770
});
6871

6972
resource.ShouldLink(Constants.Relations.Self, "0");
7073
resource.ShouldLink(Constants.Relations.First, "0");
7174
resource.ShouldLink(Constants.Relations.Last, "-1");
7275
resource.ShouldLink(Constants.Relations.Feed, HeadOfStream);
7376
resource.ShouldLink(Constants.Relations.Message, "0");
77+
resource.ShouldLink(Constants.Relations.Find, "../../streams/{streamId}", "Find a Stream");
7478
}
7579
}
7680

‎src/SqlStreamStore.HAL/Constants.cs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ public static class Relations
3030
public const string Metadata = "streamStore:metadata";
3131
public const string AppendToStream = "streamStore:append";
3232
public const string Delete = "streamStore:delete";
33+
public const string Find = "streamStore:find";
3334
}
3435

3536
public static class Streams

‎src/SqlStreamStore.HAL/IndexMiddleware.cs‎

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
namespace SqlStreamStore.HAL
2+
{
3+
using Halcyon.HAL;
4+
using Microsoft.AspNetCore.Builder;
5+
using Microsoft.AspNetCore.Http;
6+
using MidFunc = System.Func<
7+
Microsoft.AspNetCore.Http.HttpContext,
8+
System.Func<System.Threading.Tasks.Task>,
9+
System.Threading.Tasks.Task
10+
>;
11+
12+
internal static class IndexMiddleware
13+
{
14+
public static IApplicationBuilder UseIndex(this IApplicationBuilder builder)
15+
=> builder.MapWhen(IsIndex, inner => inner.Use(Index));
16+
17+
private static bool IsIndex(HttpContext context)
18+
=> (context.Request.Path.Value ?? "/") == "/";
19+
20+
private static MidFunc Index => async (context, next) =>
21+
{
22+
var response = new Response(new HALResponse(null)
23+
.AddLinks(new Link(Constants.Relations.Feed, "stream"))
24+
.AddLinks(new Link(Constants.Relations.Self, string.Empty))
25+
.AddLinks(Links.Index(string.Empty))
26+
.AddLinks(Links.Find("streams/{streamId}")));
27+
28+
using(new OptionalHeadRequestWrapper(context))
29+
{
30+
await context.WriteHalResponse(response);
31+
}
32+
};
33+
}
34+
}

‎src/SqlStreamStore.HAL/Links.cs‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
namespace SqlStreamStore.HAL
2+
{
3+
using Halcyon.HAL;
4+
5+
internal static class Links
6+
{
7+
public static Link Find(string href) => new Link(Constants.Relations.Find, href, "Find a Stream", replaceParameters: false);
8+
public static Link Index(string href) => new Link(Constants.Relations.Index, href, "Index", replaceParameters: false);
9+
}
10+
}

‎src/SqlStreamStore.HAL/Resources/AllStreamMessageResource.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,8 @@ public async Task<Response> Get(
3535
{
3636
return new Response(
3737
new HALResponse(new HALModelConfig())
38-
.AddLinks(Links.Feed()),
38+
.AddLinks(Links.Feed())
39+
.AddLinks(Links.Find()),
3940
404);
4041
}
4142

@@ -55,11 +56,14 @@ public async Task<Response> Get(
5556
}).AddLinks(
5657
Links.Self(message),
5758
Links.Message(message),
58-
Links.Feed()));
59+
Links.Feed(),
60+
Links.Find()));
5961
}
6062

6163
private static class Links
6264
{
65+
public static Link Find() => SqlStreamStore.HAL.Links.Find("../streams/{streamId}");
66+
6367
public static Link Last()
6468
=> new Link(
6569
Constants.Relations.Last,

‎src/SqlStreamStore.HAL/Resources/AllStreamResource.cs‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ public async Task<Response> Get(
6060
.AddLinks(Links.Self(operation))
6161
.AddLinks(Links.Navigation(page, operation))
6262
.AddLinks(Links.Feed(operation))
63+
.AddLinks(Links.Find())
6364
.AddEmbeddedCollection(
6465
Constants.Relations.Message,
6566
streamMessages.Zip(
@@ -93,6 +94,8 @@ public async Task<Response> Get(
9394

9495
private static class Links
9596
{
97+
public static Link Find() => SqlStreamStore.HAL.Links.Find("../streams/{streamId}");
98+
9699
public static Link Self(ReadAllStreamOperation operation)
97100
=> new Link(Constants.Relations.Self, operation.Self);
98101

‎src/SqlStreamStore.HAL/Resources/StreamMessageResource.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ public async Task<Response> Get(
4343
})
4444
.AddLinks(Links.Self(operation))
4545
.AddLinks(Links.Navigation(operation))
46-
.AddLinks(Links.Message(operation)),
46+
.AddLinks(Links.Message(operation))
47+
.AddLinks(Links.Find()),
4748
404);
4849
}
4950

@@ -77,7 +78,8 @@ public async Task<Response> Get(
7778
Schemas.DeleteStreamMessage)
7879
.AddLinks(Links.Self(operation))
7980
.AddLinks(Links.Navigation(operation, message))
80-
.AddLinks(Links.Message(operation)));
81+
.AddLinks(Links.Message(operation))
82+
.AddLinks(Links.Find()));
8183
}
8284

8385
public async Task<Response> DeleteMessage(
@@ -92,6 +94,8 @@ public async Task<Response> DeleteMessage(
9294

9395
private static class Links
9496
{
97+
public static Link Find() => SqlStreamStore.HAL.Links.Find("../../streams/{streamId}");
98+
9599
public static Link Self(ReadStreamMessageByStreamVersionOperation operation) => new Link(
96100
Constants.Relations.Self,
97101
$"{operation.StreamVersion}");

‎src/SqlStreamStore.HAL/Resources/StreamMetadataResource.cs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ public async Task<Response> Post(
7474

7575
private static class Links
7676
{
77+
public static Link Find() => SqlStreamStore.HAL.Links.Find("../{streamId}");
7778
public static Link Self() => new Link(Constants.Relations.Self, Constants.Streams.Metadata);
7879
public static Link Metadata() => new Link(Constants.Relations.Metadata, Constants.Streams.Metadata);
7980
public static Link Feed(GetStreamMetadataOperation operation) => Link(operation.StreamId);

‎src/SqlStreamStore.HAL/Resources/StreamResource.cs‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,8 @@ public async Task<Response> Post(
3838
var response = new Response(
3939
new HALResponse(result)
4040
.AddLinks(Links.Self(operation))
41-
.AddLinks(Links.Feed(operation)),
41+
.AddLinks(Links.Feed(operation))
42+
.AddLinks(Links.Find()),
4243
result.CurrentVersion == 0
4344
? 201
4445
: 200);
@@ -85,6 +86,7 @@ public async Task<Response> Get(ReadStreamOperation operation, CancellationToken
8586
.AddLinks(Links.Feed(operation))
8687
.AddLinks(Links.Metadata(operation))
8788
.AddLinks(Links.Index())
89+
.AddLinks(Links.Find())
8890
.AddEmbeddedResource(
8991
Constants.Relations.AppendToStream,
9092
Schemas.AppendToStream)
@@ -121,6 +123,8 @@ public async Task<Response> Delete(DeleteStreamOperation operation, Cancellation
121123

122124
private static class Links
123125
{
126+
public static Link Find() => SqlStreamStore.HAL.Links.Find("../streams/{streamId}");
127+
124128
public static Link First(ReadStreamPage page, ReadStreamOperation operation)
125129
=> new Link(
126130
Constants.Relations.First,

0 commit comments

Comments
 (0)