Skip to content

Commit

Permalink
update module using module_utils/cloudfront_facts.py (ansible-collect…
Browse files Browse the repository at this point in the history
…ions#1596)

update module using module_utils/cloudfront_facts.py

Depends-On: ansible-collections#1265
SUMMARY

update cloudfront_* modules, fix some bugs and add integration tests

ISSUE TYPE


Feature Pull Request

Reviewed-by: Alina Buzachis <None>
Reviewed-by: Bikouo Aubin <None>
  • Loading branch information
abikouo committed Sep 18, 2023
1 parent 648d4fe commit b751593
Show file tree
Hide file tree
Showing 4 changed files with 88 additions and 336 deletions.
12 changes: 6 additions & 6 deletions cloudfront_distribution.py
Original file line number Diff line number Diff line change
Expand Up @@ -2105,12 +2105,12 @@ def validate_attribute_with_allowed_values(self, attribute, attribute_name, allo

def validate_distribution_from_caller_reference(self, caller_reference):
try:
distributions = self.__cloudfront_facts_mgr.list_distributions(False)
distributions = self.__cloudfront_facts_mgr.list_distributions(keyed=False)
distribution_name = 'Distribution'
distribution_config_name = 'DistributionConfig'
distribution_ids = [dist.get('Id') for dist in distributions]
for distribution_id in distribution_ids:
distribution = self.__cloudfront_facts_mgr.get_distribution(distribution_id)
distribution = self.__cloudfront_facts_mgr.get_distribution(id=distribution_id)
if distribution is not None:
distribution_config = distribution[distribution_name].get(distribution_config_name)
if distribution_config is not None and distribution_config.get('CallerReference') == caller_reference:
Expand All @@ -2128,13 +2128,13 @@ def validate_distribution_from_aliases_caller_reference(self, distribution_id, a
if aliases and distribution_id is None:
distribution_id = self.validate_distribution_id_from_alias(aliases)
if distribution_id:
return self.__cloudfront_facts_mgr.get_distribution(distribution_id)
return self.__cloudfront_facts_mgr.get_distribution(id=distribution_id)
return None
except Exception as e:
self.module.fail_json_aws(e, msg="Error validating distribution_id from alias, aliases and caller reference")

def validate_distribution_id_from_alias(self, aliases):
distributions = self.__cloudfront_facts_mgr.list_distributions(False)
distributions = self.__cloudfront_facts_mgr.list_distributions(keyed=False)
if distributions:
for distribution in distributions:
distribution_aliases = distribution.get('Aliases', {}).get('Items', [])
Expand Down Expand Up @@ -2253,12 +2253,12 @@ def main():
if not (update or create or delete):
module.exit_json(changed=False)

config = {}
if update or delete:
config = distribution['Distribution']['DistributionConfig']
e_tag = distribution['ETag']
distribution_id = distribution['Distribution']['Id']
else:
config = dict()

if update:
config = camel_dict_to_snake_dict(config, reversible=True)

Expand Down
Loading

0 comments on commit b751593

Please sign in to comment.