NinjectCommandHandler.cs 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. using Ninject;
  2. using Ninject.Parameters;
  3. using System;
  4. using System.CommandLine.Binding;
  5. using System.CommandLine.Invocation;
  6. using System.Linq;
  7. using System.Threading.Tasks;
  8. namespace CustomHostingDemo
  9. {
  10. public interface ICommandHandler<TArg>
  11. {
  12. Task<int> InvokeAsync(InvocationContext context, TArg args);
  13. }
  14. public class NinjectCommandHandler<TArg> : ICommandHandler
  15. {
  16. private readonly IKernel _kernel;
  17. private readonly Type _handlerType;
  18. public NinjectCommandHandler(IKernel kernel, Type handlerType)
  19. {
  20. _kernel = kernel;
  21. _handlerType = handlerType;
  22. if (!typeof(ICommandHandler<TArg>).IsAssignableFrom(_handlerType))
  23. {
  24. throw new ArgumentException($"The handler type must implement ICommandHandler<{typeof(TArg).Name}>", nameof(handlerType));
  25. }
  26. }
  27. public Task<int> InvokeAsync(InvocationContext context)
  28. {
  29. var cmdArgs = _kernel.Get<TArg>();
  30. var binder = new ModelBinder<TArg>();
  31. binder.UpdateInstance(cmdArgs, context.BindingContext);
  32. var handler = (ICommandHandler<TArg>)_kernel.Get(_handlerType, new CommandContextParameter(context, cmdArgs as IDefaultArgs));
  33. return handler.InvokeAsync(context, cmdArgs);
  34. }
  35. }
  36. }