@@ -18,12 +18,14 @@ package aws
18
18
19
19
import (
20
20
"context"
21
+ "encoding/json"
21
22
"io/ioutil"
22
23
"os"
23
24
24
25
"github.com/pkg/errors"
25
26
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/dynamodb"
26
27
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/ecr"
28
+ "github.com/pulumi/pulumi-aws/sdk/v4/go/aws/resourcegroups"
27
29
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/s3"
28
30
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/sns"
29
31
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/sqs"
@@ -75,6 +77,28 @@ func (a *awsProvider) Deploy(ctx *pulumi.Context) error {
75
77
return err
76
78
}
77
79
80
+ rgQueryJSON , err := json .Marshal (map [string ]interface {}{
81
+ "ResourceTypeFilters" : []string {"AWS::AllSupported" },
82
+ "TagFilters" : []interface {}{
83
+ map [string ]interface {}{
84
+ "Key" : "x-nitric-stack" ,
85
+ "Values" : []string {ctx .Stack ()},
86
+ },
87
+ },
88
+ })
89
+ if err != nil {
90
+ return errors .WithMessage (err , "resource group json marshal" )
91
+ }
92
+
93
+ _ , err = resourcegroups .NewGroup (ctx , ctx .Stack (), & resourcegroups.GroupArgs {
94
+ ResourceQuery : & resourcegroups.GroupResourceQueryArgs {
95
+ Query : pulumi .String (rgQueryJSON ),
96
+ },
97
+ })
98
+ if err != nil {
99
+ return errors .WithMessage (err , "resource group create" )
100
+ }
101
+
78
102
topics := map [string ]* sns.Topic {}
79
103
for k := range a .s .Topics {
80
104
topics [k ], err = sns .NewTopic (ctx , k , & sns.TopicArgs {Tags : commonTags (ctx , k )})
0 commit comments