dub-mirrors/poodinis
1
0
Fork 0
mirror of https://github.com/mbierlee/poodinis.git synced 2024-11-15 04:04:01 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Register with an initializer.

Browse source
This commit is contained in:
heromyth 2020-02-09 23:46:06 +08:00
parent 4ebeeb9c9f
commit b9d4bd1b83
2 changed files with 70 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
example/constructorinjection/app.d
View file

@ -36,9 +36,17 @@ class Calendar {
} }
} }
import std.stdio;
class HardwareClock { class HardwareClock {
// Parameterless constructors will halt any further selection of constructors. // Parameterless constructors will halt any further selection of constructors.
this() {} this() {
writeln("default constructor");
}
this(string name) {
writeln(name);
}
// As a result, this constructor will not be used when HardwareClock is created. // As a result, this constructor will not be used when HardwareClock is created.
this(Calendar calendar) { this(Calendar calendar) {
@ -46,7 +54,6 @@ class HardwareClock {
} }
public void doThings() { public void doThings() {
import std.stdio;
writeln("Things are being done!"); writeln("Things are being done!");
} }
} }
@ -57,7 +64,10 @@ void main() {
auto dependencies = new shared DependencyContainer(); auto dependencies = new shared DependencyContainer();
dependencies.register!Scheduler; dependencies.register!Scheduler;
dependencies.register!Calendar; dependencies.register!Calendar;
dependencies.register!HardwareClock; dependencies.register!HardwareClock( {
writeln("Running the creator");
return new HardwareClock("clock name");
});
auto scheduler = dependencies.resolve!Scheduler; auto scheduler = dependencies.resolve!Scheduler;
scheduler.scheduleJob(); scheduler.scheduleJob();

67
source/poodinis/container.d
View file

@ -30,6 +30,8 @@ debug {
import std.stdio; import std.stdio;
} }
alias InjectionInitializer(T) = T delegate();
/** /**
* Exception thrown when errors occur while resolving a type in a dependency container. * Exception thrown when errors occur while resolving a type in a dependency container.
*/ */
@ -147,6 +149,11 @@ synchronized class DependencyContainer {
return register!(ConcreteType, ConcreteType)(options); return register!(ConcreteType, ConcreteType)(options);
} }
Registration register(ConcreteType)(InjectionInitializer!ConcreteType creator,
RegistrationOption options = RegistrationOption.none) {
return register!(ConcreteType, ConcreteType)(creator, options);
}
/** /**
* Register a dependency by super type. * Register a dependency by super type.
* *
@ -164,7 +171,9 @@ synchronized class DependencyContainer {
* *
* See_Also: singleInstance, newInstance, existingInstance, RegistrationOption * See_Also: singleInstance, newInstance, existingInstance, RegistrationOption
*/ */
public Registration register(SuperType, ConcreteType : SuperType)(RegistrationOption options = RegistrationOption.none) if (!is(ConcreteType == struct)) { public Registration register(SuperType, ConcreteType : SuperType)(
RegistrationOption options = RegistrationOption.none) if (!is(ConcreteType == struct)) {
TypeInfo registeredType = typeid(SuperType); TypeInfo registeredType = typeid(SuperType);
TypeInfo_Class concreteType = typeid(ConcreteType); TypeInfo_Class concreteType = typeid(ConcreteType);
@ -192,6 +201,44 @@ synchronized class DependencyContainer {
return newRegistration; return newRegistration;
} }
/**
*
*/
Registration register(SuperType, ConcreteType : SuperType)(InjectionInitializer!ConcreteType creator,
RegistrationOption options = RegistrationOption.none) if (!is(ConcreteType == struct)) {
TypeInfo registeredType = typeid(SuperType);
TypeInfo_Class concreteType = typeid(ConcreteType);
debug(poodinisVerbose) {
writeln(format("DEBUG: Register type %s (as %s)", concreteType.toString(), registeredType.toString()));
}
auto existingRegistration = getExistingRegistration(registeredType, concreteType);
if (existingRegistration) {
return existingRegistration;
}
InstanceFactory instanceFactory = new class InstanceFactory {
protected override Object createInstance() {
return creator();
}
};
auto newRegistration = new AutowiredRegistration!ConcreteType(registeredType, instanceFactory, this);
newRegistration.singleInstance();
static if (!is(SuperType == ConcreteType)) {
if (!hasOption(options, persistentRegistrationOptions, RegistrationOption.doNotAddConcreteTypeRegistration)) {
auto concreteTypeRegistration = register!ConcreteType;
concreteTypeRegistration.linkTo(newRegistration);
}
}
registrations[registeredType] ~= cast(shared(Registration)) newRegistration;
return newRegistration;
}
private bool hasOption(OptionType)(OptionType options, OptionType persistentOptions, OptionType option) { private bool hasOption(OptionType)(OptionType options, OptionType persistentOptions, OptionType option) {
return ((options | persistentOptions) & option) != 0; return ((options | persistentOptions) & option) != 0;
} }
@ -391,16 +438,16 @@ synchronized class DependencyContainer {
} }
private void callPostConstructors(Type)(Type instance) { private void callPostConstructors(Type)(Type instance) {
foreach (memberName; __traits(allMembers, Type)) { // foreach (memberName; __traits(allMembers, Type)) {
mixin(createImportsString!Type); // mixin(createImportsString!Type);
static if (__traits(compiles, __traits(getProtection, __traits(getMember, instance, memberName))) // static if (__traits(compiles, __traits(getProtection, __traits(getMember, instance, memberName)))
&& __traits(getProtection, __traits(getMember, instance, memberName)) == "public" // && __traits(getProtection, __traits(getMember, instance, memberName)) == "public"
&& isFunction!(mixin(fullyQualifiedName!Type ~ `.` ~ memberName)) // && isFunction!(mixin(fullyQualifiedName!Type ~ `.` ~ memberName))
&& hasUDA!(__traits(getMember, instance, memberName), PostConstruct)) { // && hasUDA!(__traits(getMember, instance, memberName), PostConstruct)) {
__traits(getMember, instance, memberName)(); // __traits(getMember, instance, memberName)();
} // }
} // }
} }
/** /**