WorkflowInstaller.cs 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. using Castle.MicroKernel;
  2. using Castle.MicroKernel.Registration;
  3. using Castle.MicroKernel.SubSystems.Configuration;
  4. using Castle.Windsor;
  5. using System.Reflection;
  6. namespace VberZero.Workflow;
  7. internal class WorkflowInstaller : IWindsorInstaller
  8. {
  9. //private readonly IIocResolver _iocResolver;
  10. private IVberWorkflowRegistry _workflowRegistry;
  11. // public WorkflowInstaller(IIocResolver iocResolver)
  12. // {
  13. // _iocResolver = iocResolver;
  14. // }
  15. public void Install(IWindsorContainer container, IConfigurationStore store)
  16. {
  17. _workflowRegistry = container.Resolve<IVberWorkflowRegistry>();
  18. container.Kernel.ComponentRegistered += Kernel_ComponentRegistered;
  19. }
  20. private void Kernel_ComponentRegistered(string key, IHandler handler)
  21. {
  22. /* This code checks if registering component implements any IEventHandler<TEventData> interface, if yes,
  23. * gets all event handler interfaces and registers type to Event Bus for each handling event.
  24. * 此代码检查注册组件是否实现了任何 IEventHandler<TEventData> 接口,如果是,则获取所有事件处理程序接口并将每个处理事件的类型注册到事件总线。
  25. */
  26. if (!typeof(IVberWorkflow).GetTypeInfo().IsAssignableFrom(handler.ComponentModel.Implementation))
  27. {
  28. return;
  29. }
  30. var interfaces = handler.ComponentModel.Implementation.GetTypeInfo().GetInterfaces();
  31. foreach (var @interface in interfaces)
  32. {
  33. if (!typeof(IVberWorkflow).GetTypeInfo().IsAssignableFrom(@interface))
  34. {
  35. continue;
  36. }
  37. _workflowRegistry.RegisterWorkflow(handler.ComponentModel.Implementation);
  38. }
  39. }
  40. }