#!/usr/bin/python # -*- coding: utf-8 -*- # Copyright: (c) 2018, Shuang Wang # GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt) DOCUMENTATION = r""" --- module: codecommit_repository version_added: 1.0.0 short_description: Manage repositories in AWS CodeCommit description: - Supports creation and deletion of CodeCommit repositories. - See U(https://aws.amazon.com/codecommit/) for more information about CodeCommit. - Prior to release 5.0.0 this module was called C(community.aws.aws_codecommit). The usage did not change. author: - Shuang Wang (@ptux) options: name: description: - Name of repository. required: true type: str description: description: - Description or comment of repository. required: false aliases: - comment type: str default: '' state: description: - Specifies the state of repository. required: true choices: [ 'present', 'absent' ] type: str extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.boto3 """ RETURN = r""" repository_metadata: description: "Information about the repository." returned: always type: complex contains: account_id: description: "The ID of the AWS account associated with the repository." returned: when state is present type: str sample: "123456789012" arn: description: "The Amazon Resource Name (ARN) of the repository." returned: when state is present type: str sample: "arn:aws:codecommit:ap-northeast-1:123456789012:username" clone_url_http: description: "The URL to use for cloning the repository over HTTPS." returned: when state is present type: str sample: "https://git-codecommit.ap-northeast-1.amazonaws.com/v1/repos/reponame" clone_url_ssh: description: "The URL to use for cloning the repository over SSH." returned: when state is present type: str sample: "ssh://git-codecommit.ap-northeast-1.amazonaws.com/v1/repos/reponame" creation_date: description: "The date and time the repository was created, in timestamp format." returned: when state is present type: str sample: "2018-10-16T13:21:41.261000+09:00" last_modified_date: description: "The date and time the repository was last modified, in timestamp format." returned: when state is present type: str sample: "2018-10-16T13:21:41.261000+09:00" repository_description: description: "A comment or description about the repository." returned: when state is present type: str sample: "test from ptux" repository_id: description: "The ID of the repository that was created or deleted" returned: always type: str sample: "e62a5c54-i879-497b-b62f-9f99e4ebfk8e" repository_name: description: "The repository's name." returned: when state is present type: str sample: "reponame" response_metadata: description: "Information about the response." returned: always type: complex contains: http_headers: description: "http headers of http response" returned: always type: dict http_status_code: description: "http status code of http response" returned: always type: str sample: "200" request_id: description: "http request id" returned: always type: str sample: "fb49cfca-d0fa-11e8-85cb-b3cc4b5045ef" retry_attempts: description: "numbers of retry attempts" returned: always type: str sample: "0" """ EXAMPLES = r""" # Create a new repository - community.aws.codecommit_repository: name: repo state: present # Delete a repository - community.aws.codecommit_repository: name: repo state: absent """ try: import botocore except ImportError: pass # Handled by AnsibleAWSModule from ansible.module_utils.common.dict_transformations import camel_dict_to_snake_dict from ansible_collections.community.aws.plugins.module_utils.modules import AnsibleCommunityAWSModule as AnsibleAWSModule class CodeCommit(object): def __init__(self, module=None): self._module = module self._client = self._module.client("codecommit") self._check_mode = self._module.check_mode def process(self): result = dict(changed=False) if self._module.params["state"] == "present": if not self._repository_exists(): if not self._check_mode: result = self._create_repository() result["changed"] = True else: metadata = self._get_repository()["repositoryMetadata"] if not metadata.get("repositoryDescription"): metadata["repositoryDescription"] = "" if metadata["repositoryDescription"] != self._module.params["description"]: if not self._check_mode: self._update_repository() result["changed"] = True result.update(self._get_repository()) if self._module.params["state"] == "absent" and self._repository_exists(): if not self._check_mode: result = self._delete_repository() result["changed"] = True return result def _repository_exists(self): try: paginator = self._client.get_paginator("list_repositories") for page in paginator.paginate(): repositories = page["repositories"] for item in repositories: if self._module.params["name"] in item.values(): return True except (botocore.exceptions.ClientError, botocore.exceptions.BotoCoreError) as e: self._module.fail_json_aws(e, msg="couldn't get repository") return False def _get_repository(self): try: result = self._client.get_repository( repositoryName=self._module.params["name"], ) except (botocore.exceptions.ClientError, botocore.exceptions.BotoCoreError) as e: self._module.fail_json_aws(e, msg="couldn't get repository") return result def _update_repository(self): try: result = self._client.update_repository_description( repositoryName=self._module.params["name"], repositoryDescription=self._module.params["description"], ) except (botocore.exceptions.ClientError, botocore.exceptions.BotoCoreError) as e: self._module.fail_json_aws(e, msg="couldn't create repository") return result def _create_repository(self): try: result = self._client.create_repository( repositoryName=self._module.params["name"], repositoryDescription=self._module.params["description"], ) except (botocore.exceptions.ClientError, botocore.exceptions.BotoCoreError) as e: self._module.fail_json_aws(e, msg="couldn't create repository") return result def _delete_repository(self): try: result = self._client.delete_repository( repositoryName=self._module.params["name"], ) except (botocore.exceptions.ClientError, botocore.exceptions.BotoCoreError) as e: self._module.fail_json_aws(e, msg="couldn't delete repository") return result def main(): argument_spec = dict( name=dict(required=True), state=dict(choices=["present", "absent"], required=True), description=dict(default="", aliases=["comment"]), ) ansible_aws_module = AnsibleAWSModule( argument_spec=argument_spec, supports_check_mode=True, ) aws_codecommit = CodeCommit(module=ansible_aws_module) result = aws_codecommit.process() ansible_aws_module.exit_json(**camel_dict_to_snake_dict(result)) if __name__ == "__main__": main()