-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathcontainer_resolve.go
50 lines (43 loc) · 1.29 KB
/
container_resolve.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package autowire
import (
"fmt"
"reflect"
)
// DependencyGraph dependency graph info of a type.
type DependencyGraph struct {
TargetType reflect.Type
Dependencies []DependencyGraph
}
// Resolve implementation of Container interface
func (c *container) Resolve(targetType reflect.Type) (value DependencyGraph, err error) {
ctx := &Context{
sharedMode: c.sharedMode,
providerSet: c.providerSet,
objectMap: c.objectMap,
resolvingTypes: make(map[reflect.Type]struct{}, 10), //nolint:gomnd
}
return c.resolve(ctx, targetType)
}
func (c *container) resolve(ctx *Context, targetType reflect.Type) (DependencyGraph, error) {
if _, exist := ctx.resolvingTypes[targetType]; exist {
return DependencyGraph{}, fmt.Errorf("%w: circular dependency detected at type '%v'",
ErrCircularDependency, targetType)
}
ctx.resolvingTypes[targetType] = struct{}{}
provider, err := ctx.providerSet.GetFor(targetType)
if err != nil {
return DependencyGraph{}, err
}
depGraph := DependencyGraph{
TargetType: targetType,
}
for _, dType := range provider.DependentTypes() {
dGraph, err := c.resolve(ctx, dType)
if err != nil {
return DependencyGraph{}, err
}
depGraph.Dependencies = append(depGraph.Dependencies, dGraph)
}
delete(ctx.resolvingTypes, targetType)
return depGraph, nil
}