-
-
Notifications
You must be signed in to change notification settings - Fork 1.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1828 from PrismLibrary/core3-directorymodulecatalog
Updated .NET Core 3 DirectoryModuleCatalog
- Loading branch information
Showing
2 changed files
with
227 additions
and
20 deletions.
There are no files selected for viewing
212 changes: 212 additions & 0 deletions
212
Source/Wpf/Prism.Wpf/Modularity/DirectoryModuleCatalog.Core.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,212 @@ | ||
| #if NETCOREAPP3_0 | ||
| using Prism.Properties; | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Collections.ObjectModel; | ||
| using System.Globalization; | ||
| using System.IO; | ||
| using System.Linq; | ||
| using System.Reflection; | ||
|
|
||
| namespace Prism.Modularity | ||
| { | ||
| /// <summary> | ||
| /// Represets a catalog created from a directory on disk. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// The directory catalog will scan the contents of a directory, locating classes that implement | ||
| /// <see cref="IModule"/> and add them to the catalog based on contents in their associated <see cref="ModuleAttribute"/>. | ||
| /// Assemblies are loaded into a new application domain with ReflectionOnlyLoad. The application domain is destroyed | ||
| /// once the assemblies have been discovered. | ||
| /// | ||
| /// The diretory catalog does not continue to monitor the directory after it has created the initialze catalog. | ||
| /// </remarks> | ||
| public class DirectoryModuleCatalog : ModuleCatalog | ||
| { | ||
| /// <summary> | ||
| /// Directory containing modules to search for. | ||
| /// </summary> | ||
| public string ModulePath { get; set; } | ||
|
|
||
| /// <summary> | ||
| /// Drives the main logic of building the child domain and searching for the assemblies. | ||
| /// </summary> | ||
| protected override void InnerLoad() | ||
| { | ||
| if (string.IsNullOrEmpty(this.ModulePath)) | ||
| throw new InvalidOperationException(Resources.ModulePathCannotBeNullOrEmpty); | ||
|
|
||
| if (!Directory.Exists(this.ModulePath)) | ||
| throw new InvalidOperationException( | ||
| string.Format(CultureInfo.CurrentCulture, Resources.DirectoryNotFound, this.ModulePath)); | ||
|
|
||
| AppDomain childDomain = AppDomain.CurrentDomain; | ||
|
|
||
| try | ||
| { | ||
| List<string> loadedAssemblies = new List<string>(); | ||
|
|
||
| var assemblies = ( | ||
| from Assembly assembly in AppDomain.CurrentDomain.GetAssemblies() | ||
| where !(assembly is System.Reflection.Emit.AssemblyBuilder) | ||
| && assembly.GetType().FullName != "System.Reflection.Emit.InternalAssemblyBuilder" | ||
| && !String.IsNullOrEmpty(assembly.Location) | ||
| select assembly.Location | ||
| ); | ||
|
|
||
| loadedAssemblies.AddRange(assemblies); | ||
|
|
||
| Type loaderType = typeof(InnerModuleInfoLoader); | ||
|
|
||
| if (loaderType.Assembly != null) | ||
| { | ||
| var loader = | ||
| (InnerModuleInfoLoader) | ||
| childDomain.CreateInstanceFrom(loaderType.Assembly.Location, loaderType.FullName).Unwrap(); | ||
|
|
||
| this.Items.AddRange(loader.GetModuleInfos(this.ModulePath)); | ||
| } | ||
| } | ||
| catch (Exception ex) | ||
| { | ||
| throw new Exception("There was an error loading assemblies.", ex); | ||
| } | ||
| } | ||
|
|
||
| private class InnerModuleInfoLoader : MarshalByRefObject | ||
| { | ||
| [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Performance", "CA1822:MarkMembersAsStatic")] | ||
| internal ModuleInfo[] GetModuleInfos(string path) | ||
| { | ||
| DirectoryInfo directory = new DirectoryInfo(path); | ||
|
|
||
| ResolveEventHandler resolveEventHandler = | ||
| delegate (object sender, ResolveEventArgs args) { return OnReflectionOnlyResolve(args, directory); }; | ||
|
|
||
| AppDomain.CurrentDomain.ReflectionOnlyAssemblyResolve += resolveEventHandler; | ||
|
|
||
| Assembly moduleReflectionOnlyAssembly = AppDomain.CurrentDomain.GetAssemblies().First(asm => asm.FullName == typeof(IModule).Assembly.FullName); | ||
| Type IModuleType = moduleReflectionOnlyAssembly.GetType(typeof(IModule).FullName); | ||
|
|
||
| IEnumerable<ModuleInfo> modules = GetNotAllreadyLoadedModuleInfos(directory, IModuleType); | ||
|
|
||
| var array = modules.ToArray(); | ||
| AppDomain.CurrentDomain.ReflectionOnlyAssemblyResolve -= resolveEventHandler; | ||
| return array; | ||
| } | ||
|
|
||
| private static IEnumerable<ModuleInfo> GetNotAllreadyLoadedModuleInfos(DirectoryInfo directory, Type IModuleType) | ||
| { | ||
| List<Assembly> validAssemblies = new List<Assembly>(); | ||
| Assembly[] alreadyLoadedAssemblies = AppDomain.CurrentDomain.GetAssemblies().Where(p => !p.IsDynamic).ToArray(); | ||
|
|
||
| var fileInfos = directory.GetFiles("*.dll") | ||
| .Where(file => alreadyLoadedAssemblies.FirstOrDefault( | ||
| assembly => String.Compare(Path.GetFileName(assembly.Location), | ||
| file.Name, StringComparison.OrdinalIgnoreCase) == 0) == null).ToList(); | ||
|
|
||
| foreach (FileInfo fileInfo in fileInfos) | ||
| { | ||
| try | ||
| { | ||
| validAssemblies.Add(Assembly.LoadFrom(fileInfo.FullName)); | ||
| } | ||
| catch (BadImageFormatException) | ||
| { | ||
| // skip non-.NET Dlls | ||
| } | ||
| } | ||
|
|
||
| return validAssemblies.SelectMany(assembly => assembly | ||
| .GetExportedTypes() | ||
| .Where(IModuleType.IsAssignableFrom) | ||
| .Where(t => t != IModuleType) | ||
| .Where(t => !t.IsAbstract) | ||
| .Select(type => CreateModuleInfo(type))); | ||
| } | ||
|
|
||
| private static Assembly OnReflectionOnlyResolve(ResolveEventArgs args, DirectoryInfo directory) | ||
| { | ||
| Assembly loadedAssembly = AppDomain.CurrentDomain.ReflectionOnlyGetAssemblies().FirstOrDefault( | ||
| asm => string.Equals(asm.FullName, args.Name, StringComparison.OrdinalIgnoreCase)); | ||
| if (loadedAssembly != null) | ||
| { | ||
| return loadedAssembly; | ||
| } | ||
| AssemblyName assemblyName = new AssemblyName(args.Name); | ||
| string dependentAssemblyFilename = Path.Combine(directory.FullName, assemblyName.Name + ".dll"); | ||
| if (File.Exists(dependentAssemblyFilename)) | ||
| { | ||
| return Assembly.ReflectionOnlyLoadFrom(dependentAssemblyFilename); | ||
| } | ||
| return Assembly.ReflectionOnlyLoad(args.Name); | ||
| } | ||
|
|
||
| [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Performance", "CA1822:MarkMembersAsStatic")] | ||
| internal void LoadAssemblies(IEnumerable<string> assemblies) | ||
| { | ||
| foreach (string assemblyPath in assemblies) | ||
| { | ||
| try | ||
| { | ||
| Assembly.ReflectionOnlyLoadFrom(assemblyPath); | ||
| } | ||
| catch (FileNotFoundException) | ||
| { | ||
| // Continue loading assemblies even if an assembly can not be loaded in the new AppDomain | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private static ModuleInfo CreateModuleInfo(Type type) | ||
| { | ||
| string moduleName = type.Name; | ||
| List<string> dependsOn = new List<string>(); | ||
| bool onDemand = false; | ||
| var moduleAttribute = | ||
| CustomAttributeData.GetCustomAttributes(type).FirstOrDefault( | ||
| cad => cad.Constructor.DeclaringType.FullName == typeof(ModuleAttribute).FullName); | ||
|
|
||
| if (moduleAttribute != null) | ||
| { | ||
| foreach (CustomAttributeNamedArgument argument in moduleAttribute.NamedArguments) | ||
| { | ||
| string argumentName = argument.MemberInfo.Name; | ||
| switch (argumentName) | ||
| { | ||
| case "ModuleName": | ||
| moduleName = (string)argument.TypedValue.Value; | ||
| break; | ||
|
|
||
| case "OnDemand": | ||
| onDemand = (bool)argument.TypedValue.Value; | ||
| break; | ||
|
|
||
| case "StartupLoaded": | ||
| onDemand = !((bool)argument.TypedValue.Value); | ||
| break; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| var moduleDependencyAttributes = | ||
| CustomAttributeData.GetCustomAttributes(type).Where( | ||
| cad => cad.Constructor.DeclaringType.FullName == typeof(ModuleDependencyAttribute).FullName); | ||
|
|
||
| foreach (CustomAttributeData cad in moduleDependencyAttributes) | ||
| { | ||
| dependsOn.Add((string)cad.ConstructorArguments[0].Value); | ||
| } | ||
|
|
||
| ModuleInfo moduleInfo = new ModuleInfo(moduleName, type.AssemblyQualifiedName) | ||
| { | ||
| InitializationMode = onDemand ? InitializationMode.OnDemand : InitializationMode.WhenAvailable, | ||
| Ref = type.Assembly.EscapedCodeBase, | ||
| }; | ||
| moduleInfo.DependsOn.AddRange(dependsOn); | ||
| return moduleInfo; | ||
| } | ||
| } | ||
| } | ||
| } | ||
| #endif |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters