Skip to content

Commit a132841

Browse files
authored
[aws][feat] Edge: s3 account settings --> s3 bucket (#2112)
1 parent 221960f commit a132841

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

plugins/aws/fix_plugin_aws/resource/s3.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -457,7 +457,8 @@ class AwsS3AccountSettings(AwsResource, PhantomBaseResource):
457457
" available for an Amazon S3 (Simple Storage Service) account."
458458
)
459459
reference_kinds: ClassVar[ModelReference] = {
460-
"successors": {"default": ["aws_account"]},
460+
"predecessors": {"default": ["aws_account"]},
461+
"successors": {"default": ["aws_s3_bucket"]},
461462
}
462463
api_spec: ClassVar[AwsApiSpec] = AwsApiSpec(
463464
"s3control",
@@ -489,5 +490,9 @@ def collect_resources(cls: Type[AwsResource], builder: GraphBuilder) -> None:
489490
builder.add_node(node)
490491
builder.add_edge(builder.account, node=node)
491492

493+
def connect_in_graph(self, builder: GraphBuilder, source: Json) -> None:
494+
for bucket in builder.nodes(AwsS3Bucket):
495+
builder.add_edge(self, node=bucket)
496+
492497

493498
resources: List[Type[AwsResource]] = [AwsS3AccountSettings, AwsS3Bucket]

plugins/aws/test/collector_test.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ def count_kind(clazz: Type[AwsResource]) -> int:
3434
assert len(threading.enumerate()) == 1
3535
# ensure the correct number of nodes and edges
3636
assert count_kind(AwsResource) == 225
37-
assert len(account_collector.graph.edges) == 515
37+
assert len(account_collector.graph.edges) == 519
3838
assert len(account_collector.graph.deferred_edges) == 2
3939
for node in account_collector.graph.nodes:
4040
if isinstance(node, AwsRegion):

0 commit comments

Comments
 (0)