test(CreateOpProcessor): test and implement the create op processor

Author: jaredcnance

src/JsonApiDotNetCore/Builders/ContextGraphBuilder.cs

@@ -28,10 +28,10 @@ public IContextGraph Build()
             return graph;
         }
 
-        public void AddResource<TResource>(string pluralizedTypeName) where TResource : class, IIdentifiable<int>
+        public IContextGraphBuilder AddResource<TResource>(string pluralizedTypeName) where TResource : class, IIdentifiable<int>
             => AddResource<TResource, int>(pluralizedTypeName);
 
-        public void AddResource<TResource, TId>(string pluralizedTypeName) where TResource : class, IIdentifiable<TId>
+        public IContextGraphBuilder AddResource<TResource, TId>(string pluralizedTypeName) where TResource : class, IIdentifiable<TId>
         {
             var entityType = typeof(TResource);
 
@@ -45,6 +45,8 @@ public void AddResource<TResource, TId>(string pluralizedTypeName) where TResour
                 Attributes = GetAttributes(entityType),
                 Relationships = GetRelationships(entityType)
             });
+
+            return this;
         }
 
         private Link GetLinkFlags(Type entityType)
@@ -97,7 +99,7 @@ protected virtual Type GetRelationshipType(RelationshipAttribute relation, Prope
                 return prop.PropertyType;
         }
 
-        public void AddDbContext<T>() where T : DbContext
+        public IContextGraphBuilder AddDbContext<T>() where T : DbContext
         {
             _usesDbContext = true;
 
@@ -125,6 +127,8 @@ public void AddDbContext<T>() where T : DbContext
                     });
                 }
             }
+
+            return this;
         }
 
         private string GetResourceName(PropertyInfo property)

src/JsonApiDotNetCore/Builders/DocumentBuilder.cs

@@ -104,7 +104,7 @@ private List<DocumentData> AppendIncludedObject(List<DocumentData> includedObjec
             return includedObject;
         }
 
-        private DocumentData GetData(ContextEntity contextEntity, IIdentifiable entity)
+        public DocumentData GetData(ContextEntity contextEntity, IIdentifiable entity)
         {
             var data = new DocumentData
             {

src/JsonApiDotNetCore/Builders/IContextGraphBuilder.cs

@@ -8,8 +8,8 @@ public interface IContextGraphBuilder
     {
         Link DocumentLinks  { get; set; }
         IContextGraph Build();
-        void AddResource<TResource>(string pluralizedTypeName) where TResource : class, IIdentifiable<int>;
-        void AddResource<TResource, TId>(string pluralizedTypeName) where TResource : class, IIdentifiable<TId>;
-        void AddDbContext<T>() where T : DbContext;
+        IContextGraphBuilder AddResource<TResource>(string pluralizedTypeName) where TResource : class, IIdentifiable<int>;
+        IContextGraphBuilder AddResource<TResource, TId>(string pluralizedTypeName) where TResource : class, IIdentifiable<TId>;
+        IContextGraphBuilder AddDbContext<T>() where T : DbContext;
     }
 }

src/JsonApiDotNetCore/Builders/IDocumentBuilder.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using JsonApiDotNetCore.Internal;
 using JsonApiDotNetCore.Models;
 
 namespace JsonApiDotNetCore.Builders
@@ -7,5 +8,6 @@ public interface IDocumentBuilder
     {
         Document Build(IIdentifiable entity);
         Documents Build(IEnumerable<IIdentifiable> entities);
+        DocumentData GetData(ContextEntity contextEntity, IIdentifiable entity);
     }
 }

src/JsonApiDotNetCore/Models/DocumentData.cs

@@ -1,6 +1,4 @@
-using System;
 using System.Collections.Generic;
-using JsonApiDotNetCore.Models.Pointers;
 using Newtonsoft.Json;
 
 namespace JsonApiDotNetCore.Models

src/JsonApiDotNetCore/Services/Operations/Processors/CreateOpProcessor.cs

@@ -1,26 +1,42 @@
 using System.Threading.Tasks;
 using JsonApiDotNetCore.Builders;
+using JsonApiDotNetCore.Internal;
 using JsonApiDotNetCore.Models;
 using JsonApiDotNetCore.Models.Operations;
 using JsonApiDotNetCore.Serialization;
 
 namespace JsonApiDotNetCore.Services.Operations.Processors
 {
+    public class CreateOpProcessor<T> : CreateOpProcessor<T, int>
+        where T : class, IIdentifiable<int>
+    {
+        public CreateOpProcessor(
+            ICreateService<T, int> service,
+            IJsonApiDeSerializer deSerializer,
+            IDocumentBuilder documentBuilder,
+            IContextGraph contextGraph
+        ) : base(service, deSerializer, documentBuilder, contextGraph)
+        { }
+    }
+
     public class CreateOpProcessor<T, TId> : IOpProcessor<T, TId>
          where T : class, IIdentifiable<TId>
     {
         private readonly ICreateService<T, TId> _service;
         private readonly IJsonApiDeSerializer _deSerializer;
         private readonly IDocumentBuilder _documentBuilder;
+        private readonly IContextGraph _contextGraph;
 
         public CreateOpProcessor(
             ICreateService<T, TId> service,
             IJsonApiDeSerializer deSerializer,
-            IDocumentBuilder documentBuilder)
+            IDocumentBuilder documentBuilder,
+            IContextGraph contextGraph)
         {
             _service = service;
             _deSerializer = deSerializer;
             _documentBuilder = documentBuilder;
+            _contextGraph = contextGraph;
         }
 
         public async Task<Operation> ProcessAsync(Operation operation)
@@ -32,7 +48,9 @@ public async Task<Operation> ProcessAsync(Operation operation)
                 Op = OperationCode.add
             };
 
-            operationResult.Data = _documentBuilder.Build(result);
+            operationResult.Data = _documentBuilder.GetData(
+                _contextGraph.GetContextEntity(operation.GetResourceTypeName()), 
+                result);
 
             return operationResult;
         }

test/UnitTests/Services/Operations/Processors/CreateOpProcessorTests.cs

@@ -0,0 +1,80 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using JsonApiDotNetCore.Builders;
+using JsonApiDotNetCore.Internal;
+using JsonApiDotNetCore.Models;
+using JsonApiDotNetCore.Models.Operations;
+using JsonApiDotNetCore.Serialization;
+using JsonApiDotNetCore.Services;
+using JsonApiDotNetCore.Services.Operations.Processors;
+using Moq;
+using Xunit;
+
+namespace UnitTests.Services
+{
+    public class CreateOpProcessorTests
+    {
+        private readonly Mock<ICreateService<TestResource>> _createServiceMock;
+        private readonly Mock<IJsonApiDeSerializer> _deserializerMock;
+        private readonly Mock<IDocumentBuilder> _documentBuilderMock;
+
+        public CreateOpProcessorTests()
+        {
+            _createServiceMock = new Mock<ICreateService<TestResource>>();
+            _deserializerMock = new Mock<IJsonApiDeSerializer>();
+            _documentBuilderMock = new Mock<IDocumentBuilder>();
+        }
+
+        [Fact]
+        public async Task ProcessAsync_Deserializes_And_Creates()
+        {
+            // arrange
+            var testResource = new TestResource {
+                Name = "some-name"
+            };
+
+            var data = new DocumentData {
+                Type = "test-resources",
+                Attributes = new Dictionary<string, object> {
+                    { "name", testResource.Name }
+                }
+            };
+
+            var operation = new Operation {
+                Data = data,                
+            };
+
+            var contextGraph = new ContextGraphBuilder()
+                .AddResource<TestResource>("test-resources")
+                .Build();
+
+            _deserializerMock.Setup(m => m.DocumentToObject(It.IsAny<DocumentData>()))
+                .Returns(testResource);
+
+            var opProcessor = new CreateOpProcessor<TestResource>(
+                _createServiceMock.Object,
+                _deserializerMock.Object,
+                _documentBuilderMock.Object,
+                contextGraph
+            );
+
+            _documentBuilderMock.Setup(m => m.GetData(It.IsAny<ContextEntity>(), It.IsAny<TestResource>()))
+                .Returns(data);
+
+            // act
+            var result = await opProcessor.ProcessAsync(operation);
+
+            // assert
+            Assert.Equal(OperationCode.add, result.Op);
+            Assert.NotNull(result.Data);
+            Assert.Equal(testResource.Name, result.DataObject.Attributes["name"]);
+            _createServiceMock.Verify(m => m.CreateAsync(It.IsAny<TestResource>()));
+        }
+
+        public class TestResource : Identifiable
+        {
+            [Attr("name")]
+            public string Name { get; set; }
+        }
+    }
+}