ansible/library/rhn_channel

150 lines
4.3 KiB
Text
Raw Normal View History

2013-03-23 16:30:02 +01:00
#!/usr/bin/python
DOCUMENTATION = '''
---
module: rhn_channel
2013-03-25 16:03:38 +01:00
short_description: Adds or removes Red Hat software channels
2013-03-23 16:30:02 +01:00
description:
2013-03-25 16:03:38 +01:00
- Adds or removes Red Hat software channels
version_added: "1.1"
2013-03-23 16:30:02 +01:00
author: Vincent Van der Kussen
notes:
2013-03-25 16:03:38 +01:00
- this module fetches the system id from RHN.
2013-03-23 16:30:02 +01:00
requirements:
- none
options:
name:
2013-03-25 16:03:38 +01:00
description:
2013-03-23 16:30:02 +01:00
- name of the software channel
required: true
default: null
sysname:
description:
2013-03-25 16:03:38 +01:00
- name of the system as it is known in RHN/Satellite
2013-03-23 16:30:02 +01:00
required: true
default: null
2013-03-26 03:24:30 +01:00
state:
description:
- whether the channel should be present or not
required: false
default: present
2013-03-23 16:30:02 +01:00
url:
description:
2013-03-25 16:03:38 +01:00
- The full url to the RHN/Satellite api
2013-03-23 16:30:02 +01:00
required: true
user:
description:
2013-03-25 16:03:38 +01:00
- RHN/Satellite user
required: true
password:
description:
2013-03-25 16:03:38 +01:00
- "the user's password"
required: true
2013-03-25 16:03:38 +01:00
'''
EXAMPLES = '''
rhn_channel: name=rhel-x86_64-server-v2vwin-6 sysname=server01 url=https://rhn.redhat.com/rpc/api user=rhnuser password=guessme
2013-03-23 16:30:02 +01:00
'''
import xmlrpclib
from operator import itemgetter
import re
# ------------------------------------------------------- #
def get_systemid(client, session, sysname):
systems = client.system.listUserSystems(session)
for system in systems:
if system.get('name') == sysname:
idres = system.get('id')
idd = int(idres)
return idd
# ------------------------------------------------------- #
2013-03-25 16:03:38 +01:00
# unused:
#
#def get_localsystemid():
# f = open("/etc/sysconfig/rhn/systemid", "r")
# content = f.read()
# loc_id = re.search(r'\b(ID-)(\d{10})' ,content)
# return loc_id.group(2)
2013-03-23 16:30:02 +01:00
# ------------------------------------------------------- #
def subscribe_channels(channels, client, session, sysname, sys_id):
c = base_channels(client, session, sys_id)
c.append(channels)
return client.channel.software.setSystemChannels(session, sys_id, c)
# ------------------------------------------------------- #
def unsubscribe_channels(channels, client, session, sysname, sys_id):
c = base_channels(client, session, sys_id)
c.remove(channels)
return client.channel.software.setSystemChannels(session, sys_id, c)
# ------------------------------------------------------- #
def base_channels(client, session, sys_id):
basechan = client.channel.software.listSystemChannels(session, sys_id)
chans = [item['channel_label'] for item in basechan]
return chans
# ------------------------------------------------------- #
def main():
module = AnsibleModule(
argument_spec = dict(
state = dict(default='present', choices=['present', 'absent']),
name = dict(required=True),
sysname = dict(required=True),
url = dict(required=True),
user = dict(required=True),
password = dict(required=True, aliases=['pwd']),
2013-03-23 16:30:02 +01:00
)
# supports_check_mode=True
)
state = module.params['state']
channelname = module.params['name']
systname = module.params['sysname']
saturl = module.params['url']
user = module.params['user']
password = module.params['password']
2013-03-23 16:30:02 +01:00
#initialize connection
client = xmlrpclib.Server(saturl, verbose=0)
session = client.auth.login(user, password)
2013-03-23 16:30:02 +01:00
# get systemid
sys_id = get_systemid(client, session, systname)
# get channels for system
chans = base_channels(client, session, sys_id)
if state == 'present':
if channelname in chans:
module.exit_json(changed=False, msg="Channel %s already exists" % channelname)
else:
subscribe_channels(channelname, client, session, systname, sys_id)
module.exit_json(changed=True, msg="Channel %s added" % channelname)
if state == 'absent':
if not channelname in chans:
module.exit_json(changed=False, msg="Not subscribed to channel %s." % channelname)
2013-03-23 16:30:02 +01:00
else:
unsubscribe_channels(channelname, client, session, systname, sys_id)
module.exit_json(changed=True, msg="Channel %s removed" % channelname)
client.auth.logout(session)
# include magic from lib/ansible/module_common.py
#<<INCLUDE_ANSIBLE_MODULE_COMMON>>
main()