#!/usr/bin/python # -*- coding: utf-8 -*- # # (c) 2015, René Moser # # This file is part of Ansible # # Ansible is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # # Ansible is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with Ansible. If not, see . DOCUMENTATION = ''' --- module: cs_project short_description: Manages projects on Apache CloudStack based clouds. description: - Create, update, suspend, activate and remove projects. version_added: '2.0' author: "René Moser (@resmo)" options: name: description: - Name of the project. required: true display_text: description: - Display text of the project. - If not specified, C(name) will be used as C(display_text). required: false default: null state: description: - State of the project. required: false default: 'present' choices: [ 'present', 'absent', 'active', 'suspended' ] domain: description: - Domain the project is related to. required: false default: null account: description: - Account the project is related to. required: false default: null tags: description: - List of tags. Tags are a list of dictionaries having keys C(key) and C(value). - "If you want to delete all tags, set a empty list e.g. C(tags: [])." required: false default: null version_added: "2.2" poll_async: description: - Poll async jobs until job has finished. required: false default: true extends_documentation_fragment: cloudstack ''' EXAMPLES = ''' # Create a project - local_action: module: cs_project name: web tags: - { key: admin, value: john } - { key: foo, value: bar } # Rename a project - local_action: module: cs_project name: web display_text: my web project # Suspend an existing project - local_action: module: cs_project name: web state: suspended # Activate an existing project - local_action: module: cs_project name: web state: active # Remove a project - local_action: module: cs_project name: web state: absent ''' RETURN = ''' --- id: description: UUID of the project. returned: success type: string sample: 04589590-ac63-4ffc-93f5-b698b8ac38b6 name: description: Name of the project. returned: success type: string sample: web project display_text: description: Display text of the project. returned: success type: string sample: web project state: description: State of the project. returned: success type: string sample: Active domain: description: Domain the project is related to. returned: success type: string sample: example domain account: description: Account the project is related to. returned: success type: string sample: example account tags: description: List of resource tags associated with the project. returned: success type: dict sample: '[ { "key": "foo", "value": "bar" } ]' ''' # import cloudstack common from ansible.module_utils.cloudstack import * class AnsibleCloudStackProject(AnsibleCloudStack): def get_project(self): if not self.project: project = self.module.params.get('name') args = {} args['account'] = self.get_account(key='name') args['domainid'] = self.get_domain(key='id') projects = self.cs.listProjects(**args) if projects: for p in projects['project']: if project.lower() in [ p['name'].lower(), p['id']]: self.project = p break return self.project def present_project(self): project = self.get_project() if not project: project = self.create_project(project) else: project = self.update_project(project) if project: project = self.ensure_tags(resource=project, resource_type='project') # refresh resource self.project = project return project def update_project(self, project): args = {} args['id'] = project['id'] args['displaytext'] = self.get_or_fallback('display_text', 'name') if self._has_changed(args, project): self.result['changed'] = True if not self.module.check_mode: project = self.cs.updateProject(**args) if 'errortext' in project: self.module.fail_json(msg="Failed: '%s'" % project['errortext']) poll_async = self.module.params.get('poll_async') if project and poll_async: project = self._poll_job(project, 'project') return project def create_project(self, project): self.result['changed'] = True args = {} args['name'] = self.module.params.get('name') args['displaytext'] = self.get_or_fallback('display_text', 'name') args['account'] = self.get_account('name') args['domainid'] = self.get_domain('id') if not self.module.check_mode: project = self.cs.createProject(**args) if 'errortext' in project: self.module.fail_json(msg="Failed: '%s'" % project['errortext']) poll_async = self.module.params.get('poll_async') if project and poll_async: project = self._poll_job(project, 'project') return project def state_project(self, state='active'): project = self.present_project() if project['state'].lower() != state: self.result['changed'] = True args = {} args['id'] = project['id'] if not self.module.check_mode: if state == 'suspended': project = self.cs.suspendProject(**args) else: project = self.cs.activateProject(**args) if 'errortext' in project: self.module.fail_json(msg="Failed: '%s'" % project['errortext']) poll_async = self.module.params.get('poll_async') if project and poll_async: project = self._poll_job(project, 'project') return project def absent_project(self): project = self.get_project() if project: self.result['changed'] = True args = {} args['id'] = project['id'] if not self.module.check_mode: res = self.cs.deleteProject(**args) if 'errortext' in res: self.module.fail_json(msg="Failed: '%s'" % res['errortext']) poll_async = self.module.params.get('poll_async') if res and poll_async: res = self._poll_job(res, 'project') return project def main(): argument_spec = cs_argument_spec() argument_spec.update(dict( name = dict(required=True), display_text = dict(default=None), state = dict(choices=['present', 'absent', 'active', 'suspended' ], default='present'), domain = dict(default=None), account = dict(default=None), poll_async = dict(type='bool', default=True), tags=dict(type='list', aliases=['tag'], default=None), )) module = AnsibleModule( argument_spec=argument_spec, required_together=cs_required_together(), supports_check_mode=True ) try: acs_project = AnsibleCloudStackProject(module) state = module.params.get('state') if state in ['absent']: project = acs_project.absent_project() elif state in ['active', 'suspended']: project = acs_project.state_project(state=state) else: project = acs_project.present_project() result = acs_project.get_result(project) except CloudStackException as e: module.fail_json(msg='CloudStackException: %s' % str(e)) module.exit_json(**result) # import module snippets from ansible.module_utils.basic import * if __name__ == '__main__': main()