jenkins_job: rename enable to enabled and mutually exclusive with config

Jenkins stores the information about the state (disabled/enabled) in the config, which result in a race condition between `config` and `enabled` and we loose idempotency. It makes sense to define them mutually exclusive.

Renamed `enable` to `enabled`. Ansible uses the name `enabled` in many modules, e.g. service as it indicates a state not an action.
This commit is contained in:
Rene Moser 2016-09-10 16:56:09 +02:00 committed by Matt Clay
parent bd4c935fd7
commit 171b71cfa0

View file

@ -27,11 +27,16 @@ author: "Sergio Millan Rodriguez (@sermilrod)"
options: options:
config: config:
description: description:
- config.xml file to use as job config within your Ansible repo. - config in XML format.
- Required if job does not yet exist.
- Mututally exclusive with C(enabled).
- Considered if C(state=present).
required: false required: false
enable: enabled:
description: description:
- Action to take with the Jenkins job (enable/disable). - Whether the job should be enabled or disabled.
- Mututally exclusive with C(config).
- Considered if C(state=present).
required: false required: false
name: name:
description: description:
@ -68,7 +73,6 @@ EXAMPLES = '''
config: "{{ lookup('file', 'templates/test.xml') }}" config: "{{ lookup('file', 'templates/test.xml') }}"
name: test name: test
password: admin password: admin
enable: True
url: "http://localhost:8080" url: "http://localhost:8080"
user: admin user: admin
@ -77,7 +81,6 @@ EXAMPLES = '''
config: "{{ lookup('template', 'templates/test.xml.j2') }}" config: "{{ lookup('template', 'templates/test.xml.j2') }}"
name: test name: test
token: asdfasfasfasdfasdfadfasfasdfasdfc token: asdfasfasfasdfasdfadfasfasdfasdfc
enable: yes
url: "http://localhost:8080" url: "http://localhost:8080"
user: admin user: admin
@ -101,7 +104,7 @@ EXAMPLES = '''
- jenkins_job: - jenkins_job:
name: test name: test
password: admin password: admin
enable: False enabled: false
url: "http://localhost:8080" url: "http://localhost:8080"
user: admin user: admin
@ -109,7 +112,7 @@ EXAMPLES = '''
- jenkins_job: - jenkins_job:
name: test name: test
token: asdfasfasfasdfasdfadfasfasdfasdfc token: asdfasfasfasdfasdfadfasfasdfasdfc
enable: no enabled: false
url: "http://localhost:8080" url: "http://localhost:8080"
user: admin user: admin
''' '''
@ -146,12 +149,12 @@ except ImportError:
python_lxml_installed = False python_lxml_installed = False
class Jenkins: class Jenkins:
def __init__(self, config, name, password, state, enable, token, url, user): def __init__(self, config, name, password, state, enabled, token, url, user):
self.config = config self.config = config
self.name = name self.name = name
self.password = password self.password = password
self.state = state self.state = state
self.enable = enable self.enabled = enabled
self.token = token self.token = token
self.user = user self.user = user
self.jenkins_url = url self.jenkins_url = url
@ -195,29 +198,39 @@ class Jenkins:
return job_config_to_string(self.config) return job_config_to_string(self.config)
def configuration_changed(self): def configuration_changed(self):
# config is optional, if not provided we keep the current config as is
if self.config is None:
return False
changed = False changed = False
config_file = self.get_config() config_file = self.get_config()
machine_file = job_config_to_string(self.server.get_job_config(self.name).encode('utf-8')) machine_file = job_config_to_string(self.server.get_job_config(self.name).encode('utf-8'))
if not machine_file == config_file: if machine_file != config_file:
changed = True changed = True
return changed return changed
def update_job(self, module): def update_job(self, module):
if self.config is None and self.enabled is None:
module.fail_json(msg='one of the following params is required on state=present: config,enabled')
if not self.job_exists(module): if not self.job_exists(module):
self.create_job(module) self.create_job(module)
else: else:
self.reconfig_job(module) self.reconfig_job(module)
def state_changed(self, status): def state_changed(self, status):
# Keep in current state if enabled arg_spec is not given
if self.enabled is None:
return False
changed = False changed = False
if ( (self.enable == False and status != "disabled") or (self.enable == True and status == "disabled") ): if ( (self.enabled == False and status != "disabled") or (self.enabled == True and status == "disabled") ):
changed = True changed = True
return changed return changed
def change_state(self): def change_state(self):
if self.enable == False: if self.enabled == False:
self.server.disable_job(self.name) self.server.disable_job(self.name)
else: else:
self.server.enable_job(self.name) self.server.enable_job(self.name)
@ -226,14 +239,15 @@ class Jenkins:
changed = False changed = False
try: try:
status = self.get_job_status(module) status = self.get_job_status(module)
if self.enable == True:
if ( self.configuration_changed() or self.state_changed(status) ): # Handle job config
if self.configuration_changed():
changed = True changed = True
if not module.check_mode: if not module.check_mode:
self.server.reconfig_job(self.name, self.get_config()) self.server.reconfig_job(self.name, self.get_config())
self.change_state()
else: # Handle job disable/enable
if self.state_changed(status): elif self.state_changed(status):
changed = True changed = True
if not module.check_mode: if not module.check_mode:
self.change_state() self.change_state()
@ -245,6 +259,10 @@ class Jenkins:
module.exit_json(changed=changed, name=self.name, state=self.state, url=self.jenkins_url) module.exit_json(changed=changed, name=self.name, state=self.state, url=self.jenkins_url)
def create_job(self, module): def create_job(self, module):
if self.config is None:
module.fail_json(msg='missing required param: config')
changed = False changed = False
try: try:
changed = True changed = True
@ -288,7 +306,7 @@ def jenkins_builder(module):
module.params.get('name'), module.params.get('name'),
module.params.get('password'), module.params.get('password'),
module.params.get('state'), module.params.get('state'),
module.params.get('enable'), module.params.get('enabled'),
module.params.get('token'), module.params.get('token'),
module.params.get('url'), module.params.get('url'),
module.params.get('user') module.params.get('user')
@ -301,16 +319,15 @@ def main():
name = dict(required=True), name = dict(required=True),
password = dict(required=False, no_log=True), password = dict(required=False, no_log=True),
state = dict(required=False, choices=['present', 'absent'], default="present"), state = dict(required=False, choices=['present', 'absent'], default="present"),
enable = dict(required=False, type='bool'), enabled = dict(required=False, type='bool'),
token = dict(required=False, no_log=True), token = dict(required=False, no_log=True),
url = dict(required=False, default="http://localhost:8080"), url = dict(required=False, default="http://localhost:8080"),
user = dict(required=False) user = dict(required=False)
), ),
required_if = [ mutually_exclusive = [
('state', 'present', ['enable']), ['password', 'token'],
('enable', True, ['config']) ['config', 'enabled'],
], ],
mutually_exclusive = [['password', 'token']],
supports_check_mode=True, supports_check_mode=True,
) )