Skip to content

Commit

Permalink
Handle multiple default providers for different packages.
Browse files Browse the repository at this point in the history
Also added a test to test topological sort works correctly.

       Bug: #643
Remote-Ref: brandonpollack23/e8219876
  • Loading branch information
brandonpollack23 committed Sep 25, 2024
1 parent 9bc5360 commit 6f23208
Show file tree
Hide file tree
Showing 4 changed files with 55 additions and 10 deletions.
28 changes: 19 additions & 9 deletions pkg/pulumiyaml/sort.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,14 +139,16 @@ func topologicallySortedResources(t *ast.TemplateDecl, externalConfig []configNo
}
}

var defaultProvider *ast.StringExpr
// Map of package name to default provider resource and it's key.
defaultProviders := map[string]*ast.StringExpr{}
for _, kvp := range t.Resources.Entries {
rname, r := kvp.Key.Value, kvp.Value
node := resourceNode(kvp)

// Check if the resource is a default provider
if resourceIsDefaultProvider(node) {
defaultProvider = node.key()
pkg := strings.Split(node.Value.Type.Value, ":")[2]
defaultProviders[pkg] = node.key()
}

cdiags := checkUniqueNode(intermediates, node)
Expand Down Expand Up @@ -215,14 +217,22 @@ func topologicallySortedResources(t *ast.TemplateDecl, externalConfig []configNo
}
}

if resourceNodeHasNoExplicitProvider(e) && defaultProvider != name {
// If the resource has no explicit provider and the default provider is not set, then the
// (implicit) dependency is not yet met.
if defaultProvider != nil && !visit(defaultProvider) {
return false
if resNode, ok := e.(resourceNode); ok {
pkg := ""
if resNode.Value.Type != nil {
pkg = strings.Split(resNode.Value.Type.Value, ":")[0]
}
defaultProviderForPackage := defaultProviders[pkg]
isDefaultProvider := resNode.Value.DefaultProvider != nil && resNode.Value.DefaultProvider.Value
if resourceNodeHasNoExplicitProvider(e) && !isDefaultProvider {
// If the resource has no explicit provider and the default provider is not set, then the
// (implicit) dependency is not yet met.
if defaultProviderForPackage != nil && !visit(defaultProviderForPackage) {
return false
}

// if the defaultProviderForPackage is not set, then it may not be needed.
}

// if the defaultProviderForPackage is not set, then it may not be needed.
}

visited[name.Value] = true
Expand Down
18 changes: 18 additions & 0 deletions pkg/pulumiyaml/sort_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,24 @@ func TestSortUnordered(t *testing.T) {
assert.Equal(t, "my-object", names[1])
}

func TestSortMultipleDefaultProviders(t *testing.T) {
t.Parallel()

tmpl, diags, err := LoadFile("../tests/testdata/resource-ordering/Pulumi.yaml")
requireNoErrors(t, tmpl, diags)
assert.NoError(t, err)

confNodes := []configNode{}
resources, diags := topologicallySortedResources(tmpl, confNodes)
requireNoErrors(t, tmpl, diags)
names := sortedNames(resources)
assert.Len(t, names, 4)
assert.Equal(t, "provider", names[0])
assert.Equal(t, "alb", names[1])
assert.Equal(t, "testProvider", names[2])
assert.Equal(t, "echo", names[3])
}

func TestSortErrorCycle(t *testing.T) {
t.Parallel()

Expand Down
12 changes: 12 additions & 0 deletions pkg/tests/testdata/resource-ordering/Pulumi.yaml
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
name: aws-yaml
runtime: yaml
plugins:
providers:
- name: testprovider
path: ../../testprovider
resources:
alb:
type: aws:alb:LoadBalancer
Expand All @@ -10,8 +14,16 @@ resources:
subnets:
- subnet-eacf3697
- subnet-939b18f8
echo:
type: testprovider:index:Echo
provider:
defaultProvider: true
type: pulumi:providers:aws
properties:
region: us-west-2
testProvider:
defaultProvider: true
type: pulumi:providers:testprovider
properties:
testInput: ${alb.urn}

7 changes: 6 additions & 1 deletion pkg/tests/testprovider/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,12 @@ var providerSchema = pschema.PackageSpec{
Description: "The provider type for the testprovider package.",
Type: "object",
},
InputProperties: map[string]pschema.PropertySpec{},
InputProperties: map[string]pschema.PropertySpec{
"testInput": {
TypeSpec: pschema.TypeSpec{Type: "string"},
Description: "A test input property.",
},
},
},

Types: map[string]pschema.ComplexTypeSpec{},
Expand Down

0 comments on commit 6f23208

Please sign in to comment.