enabling additional forms

Author: thefringeninja

src/SqlStreamStore.HAL/Constants.cs

@@ -32,6 +32,7 @@ public static class Relations
             public const string Message = "streamStore:message";
             public const string Metadata = "streamStore:metadata";
             public const string AppendToStream = "streamStore:append";
+            public const string Delete = "streamStore:delete";
         }
 
         public static class Streams

src/SqlStreamStore.HAL/Resources/Schema/AppendToStream.json

@@ -30,17 +30,5 @@
         "rows": 30
       }
     }
-  },
-  "$form": [
-    "messageId",
-    "type",
-    {
-      "key": "jsonData",
-      "type": "textarea"
-    },
-    {
-      "key": "jsonMetadata",
-      "type": "textarea"
-    }
-  ]
+  }
 }

src/SqlStreamStore.HAL/Resources/Schema/DeleteStream.json

@@ -0,0 +1,5 @@
+{
+  "$schema": "http://json-schema.org/draft-07/hyper-schema#",
+  "title": "Delete Stream",
+  "type": "object"
+}

src/SqlStreamStore.HAL/Resources/Schema/DeleteStreamMessage.json

@@ -0,0 +1,5 @@
+{
+  "$schema": "http://json-schema.org/draft-07/hyper-schema#",
+  "title": "Delete Stream Message",
+  "type": "object"
+}

src/SqlStreamStore.HAL/Resources/Schema/SetStreamMetadata.json

@@ -11,7 +11,12 @@
       "minimum": 1
     },
     "metadataJson": {
-      "type": "object"
+      "type": "object",
+      "x-schema-form": {
+        "key": "metadataJson",
+        "type": "textarea",
+        "rows": 30
+      }
     }
   }
 }

src/SqlStreamStore.HAL/Resources/Schemas.cs

@@ -4,20 +4,23 @@
     using System.Collections.Concurrent;
     using System.IO;
     using System.Reflection;
+    using Halcyon.HAL;
     using Newtonsoft.Json;
     using Newtonsoft.Json.Linq;
 
     internal static class Schemas
     {
-        private static readonly ConcurrentDictionary<string, JObject> s_schemas
-            = new ConcurrentDictionary<string, JObject>();
+        private static readonly ConcurrentDictionary<string, HALResponse> s_schemas
+            = new ConcurrentDictionary<string, HALResponse>();
 
-        public static JObject AppendToStream => GetSchema(nameof(AppendToStream));
-        public static JObject SetStreamMetadata => GetSchema(nameof(SetStreamMetadata));
+        public static HALResponse AppendToStream => GetSchema(nameof(AppendToStream));
+        public static HALResponse SetStreamMetadata => GetSchema(nameof(SetStreamMetadata));
+        public static HALResponse DeleteStream => GetSchema(nameof(DeleteStream));
+        public static HALResponse DeleteStreamMessage => GetSchema(nameof(DeleteStreamMessage));
 
-        private static JObject GetSchema(string name) => s_schemas.GetOrAdd(name, ReadSchema);
+        private static HALResponse GetSchema(string name) => s_schemas.GetOrAdd(name, ReadSchema);
 
-        private static JObject ReadSchema(string name)
+        private static HALResponse ReadSchema(string name)
         {
             using(Stream stream = typeof(Schemas)
                 .GetTypeInfo().Assembly
@@ -30,7 +33,7 @@ private static JObject ReadSchema(string name)
 
                 using(var reader = new JsonTextReader(new StreamReader(stream)))
                 {
-                    return JObject.Load(reader);
+                    return new HALResponse(JObject.Load(reader));
                 }
             }
         }

src/SqlStreamStore.HAL/Resources/StreamMessageResource.cs

@@ -72,6 +72,9 @@ public async Task<Response> GetMessage(
                         payload,
                         metadata = message.JsonMetadata
                     })
+                    .AddEmbeddedResource(
+                        Constants.Relations.Delete,
+                        Schemas.DeleteStreamMessage)
                     .AddLinks(Links.Self(operation))
                     .AddLinks(Links.Navigation(operation, message))
                     .AddLinks(Links.Message(operation)));

src/SqlStreamStore.HAL/Resources/StreamMetadataResource.cs

@@ -39,13 +39,17 @@ public async Task<Response> GetStreamMetadata(
             var result = await operation.Invoke(_streamStore, cancellationToken);
 
             var response = new Response(new HALResponse(new
-                {
-                    result.StreamId,
-                    result.MetadataStreamVersion,
-                    result.MaxAge,
-                    result.MaxCount,
-                    result.MetadataJson
-                }).AddLinks(s_links),
+                    {
+                        result.StreamId,
+                        result.MetadataStreamVersion,
+                        result.MaxAge,
+                        result.MaxCount,
+                        result.MetadataJson
+                    })
+                    .AddLinks(s_links)
+                    .AddEmbeddedResource(
+                        Constants.Relations.Metadata,
+                        Schemas.SetStreamMetadata),
                 result.MetadataStreamVersion >= 0 ? 200 : 404);
 
             return response;

src/SqlStreamStore.HAL/Resources/StreamResource.cs

@@ -76,8 +76,11 @@ public async Task<Response> GetPage(ReadStreamOperation operation, CancellationT
                     .AddLinks(Links.Feed(operation))
                     .AddLinks(Links.Metadata(operation))
                     .AddEmbeddedResource(
-                        Constants.Relations.AppendToStream, 
-                        new HALResponse(Schemas.AppendToStream))
+                        Constants.Relations.AppendToStream,
+                        Schemas.AppendToStream)
+                    .AddEmbeddedResource(
+                        Constants.Relations.Delete,
+                        Schemas.DeleteStream)
                     .AddEmbeddedCollection(
                         Constants.Relations.Message,
                         streamMessages.Zip(