Hooks

src/Examples/JsonApiDotNetCoreExample/Logic/LogicCache.cs

@@ -0,0 +1,24 @@
+using JsonApiDotNetCore.Logic;
+using JsonApiDotNetCore.Models;
+using JsonApiDotNetCoreExample.Models;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace JsonApiDotNetCoreExample.Logic
+{
+    public class LogicCache : BaseLogicCache
+    {
+
+        /// <summary>
+        /// Hacky, but fast to show how it could work
+        /// </summary>
+        /// <param name="tagDefinition"></param>
+        public LogicCache(ResourceDefinition<Tag> tagDefinition)
+        {
+            _cache.Add(typeof(Tag), tagDefinition);
+        }
+
+    }
+}

src/Examples/JsonApiDotNetCoreExample/Startup.cs

@@ -7,6 +7,8 @@
 using Microsoft.EntityFrameworkCore;
 using JsonApiDotNetCore.Extensions;
 using System;
+using JsonApiDotNetCore.Logic;
+using JsonApiDotNetCoreExample.Logic;
 
 namespace JsonApiDotNetCoreExample
 {
@@ -43,6 +45,7 @@ public virtual IServiceProvider ConfigureServices(IServiceCollection services)
                 mvcBuilder,
                 discovery => discovery.AddCurrentAssembly());
 
+            services.AddSingleton<ILogicCache, LogicCache>();
             return services.BuildServiceProvider();
         }
 

src/JsonApiDotNetCore/Data/DefaultEntityRepository.cs

@@ -7,9 +7,11 @@
 using JsonApiDotNetCore.Internal;
 using JsonApiDotNetCore.Internal.Generics;
 using JsonApiDotNetCore.Internal.Query;
+using JsonApiDotNetCore.Logic;
 using JsonApiDotNetCore.Models;
 using JsonApiDotNetCore.Services;
 using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Query.Internal;
 using Microsoft.Extensions.Logging;
 
 namespace JsonApiDotNetCore.Data
@@ -23,16 +25,17 @@ public class DefaultEntityRepository<TEntity>
         public DefaultEntityRepository(
             IJsonApiContext jsonApiContext,
             IDbContextResolver contextResolver,
-            ResourceDefinition<TEntity> resourceDefinition = null)
-        : base(jsonApiContext, contextResolver, resourceDefinition)
+            ILogicCache logicCache = null)
+        : base(jsonApiContext, contextResolver, logicCache)
         { }
 
         public DefaultEntityRepository(
             ILoggerFactory loggerFactory,
             IJsonApiContext jsonApiContext,
             IDbContextResolver contextResolver,
-            ResourceDefinition<TEntity> resourceDefinition = null)
-        : base(loggerFactory, jsonApiContext, contextResolver, resourceDefinition)
+            ILogicCache logicCache = null
+            )
+        : base(loggerFactory, jsonApiContext, contextResolver, logicCache)
         { }
     }
 
@@ -50,32 +53,42 @@ public class DefaultEntityRepository<TEntity, TId>
         private readonly ILogger _logger;
         private readonly IJsonApiContext _jsonApiContext;
         private readonly IGenericProcessorFactory _genericProcessorFactory;
+        private readonly ILogicCache _logicCache;
         private readonly ResourceDefinition<TEntity> _resourceDefinition;
 
         public DefaultEntityRepository(
             IJsonApiContext jsonApiContext,
             IDbContextResolver contextResolver,
-            ResourceDefinition<TEntity> resourceDefinition = null)
+            ILogicCache logicCache)
         {
             _context = contextResolver.GetContext();
             _dbSet = contextResolver.GetDbSet<TEntity>();
             _jsonApiContext = jsonApiContext;
             _genericProcessorFactory = _jsonApiContext.GenericProcessorFactory;
-            _resourceDefinition = resourceDefinition;
+            if (logicCache != null)
+            {
+                _logicCache = logicCache;
+                _resourceDefinition = (ResourceDefinition<TEntity>)logicCache.GetLogic(typeof(TEntity));
+            }
+
         }
 
         public DefaultEntityRepository(
             ILoggerFactory loggerFactory,
             IJsonApiContext jsonApiContext,
             IDbContextResolver contextResolver,
-            ResourceDefinition<TEntity> resourceDefinition = null)
+            ILogicCache logicCache)
         {
             _context = contextResolver.GetContext();
             _dbSet = contextResolver.GetDbSet<TEntity>();
             _jsonApiContext = jsonApiContext;
             _logger = loggerFactory.CreateLogger<DefaultEntityRepository<TEntity, TId>>();
             _genericProcessorFactory = _jsonApiContext.GenericProcessorFactory;
-            _resourceDefinition = resourceDefinition;
+            if (logicCache != null)
+            {
+                _logicCache = logicCache;
+                _resourceDefinition = (ResourceDefinition<TEntity>)logicCache.GetLogic(typeof(TEntity));
+            }
         }
 
         /// <inheritdoc />
@@ -354,15 +367,19 @@ public virtual IQueryable<TEntity> Include(IQueryable<TEntity> entities, string
             string internalRelationshipPath = null;
             var entity = _jsonApiContext.RequestEntity;
 
-            var typeTree = new Dictionary<Type, IResourceDefinition>() { };
+            var logicTree = new Dictionary<Type, IResourceDefinition>() { };
 
             for (var i = 0; i < relationshipChain.Length; i++)
             {
                 var requestedRelationship = relationshipChain[i];
                 var relationship = entity.Relationships.FirstOrDefault(r => r.PublicRelationshipName == requestedRelationship);
 
                 // need to add this to the typetree so we know what we're dealing with
-                typeTree.Add(relationship.Type);
+                var logic = _logicCache.GetLogic(relationship.Type);
+                if (logic != null)
+                {
+                    logicTree.Add(relationship.Type, logic);
+                }
                 if (relationship == null)
                 {
                     throw new JsonApiException(400, $"Invalid relationship {requestedRelationship} on {entity.EntityName}",
@@ -382,13 +399,22 @@ public virtual IQueryable<TEntity> Include(IQueryable<TEntity> entities, string
                     entity = _jsonApiContext.ResourceGraph.GetContextEntity(relationship.Type);
             }
 
-            entities =  entities.Include(internalRelationshipPath);
-            // here we also need to check for any filters
 
 
+            // here we also need to check for any filters
+            // we have access to the logicTree which should have the 
+            // Required logic to handle nested changes to the entities
+            // we need to 
+            entities = entities.Include(internalRelationshipPath);
+            // I mean, the including is fine, but we still need to apply a `Where` somehow
+            // we could dynamically build
+            // entities.Where(e = > logic.Apply(e)) or something, but I cant really figure out how atm
             return entities;
         }
 
+
+
+
         /// <inheritdoc />
         public virtual async Task<IEnumerable<TEntity>> PageAsync(IQueryable<TEntity> entities, int pageSize, int pageNumber)
         {

src/JsonApiDotNetCore/Logic/ILogicCache.cs

@@ -0,0 +1,29 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using JsonApiDotNetCore.Models;
+
+namespace JsonApiDotNetCore.Logic
+{
+    public interface ILogicCache
+    {
+        IResourceDefinition GetLogic(Type type);
+    }
+    public class BaseLogicCache : ILogicCache
+    {
+        protected Dictionary<Type, IResourceDefinition> _cache = new Dictionary<Type, IResourceDefinition>();
+
+
+        public IResourceDefinition GetLogic(Type type) 
+        {
+            var toReturn = _cache.FirstOrDefault(c => c.Key == type); 
+            if(toReturn.Equals(default(KeyValuePair<Type,IResourceDefinition>)))
+            {
+                return null;
+            }
+            return  toReturn.Value;
+        }
+    }
+
+}