Standardizing the module

library/service

@@ -17,29 +17,10 @@
 # You should have received a copy of the GNU General Public License
 # along with Ansible.  If not, see <http://www.gnu.org/licenses/>.
 
-try:
-    import json
-except ImportError:
-    import simplejson as json
-import sys
-import shlex
-import subprocess
-import os.path
-import syslog
-
-# TODO: switch to fail_json and other helper functions
-# like other modules are using
-
-# ===========================================
-
 SERVICE = None
 CHKCONFIG = None
 
-def fail_json(d):
+def _find_binaries(m):
-    print json.dumps(d)
-    sys.exit(1)
-
-def _find_binaries():
     # list of possible paths for service/chkconfig binaries
     # with the most probable first
     global CHKCONFIG
@@ -63,11 +44,11 @@ def _find_binaries():
     elif location.get('update-rc.d', None):
         CHKCONFIG = location['update-rc.d']
     else:
-        fail_json(dict(failed=True, msg='unable to find chkconfig or update-rc.d binary'))
+        m.fail_json(msg='unable to find chkconfig or update-rc.d binary')
     if location.get('service', None):
         SERVICE = location['service']
     else:
-        fail_json(dict(failed=True, msg='unable to find service binary'))
+        m.fail_json(msg='unable to find service binary')
     if location.get('initctl', None):
         INITCTL = location['initctl']
     else:
@@ -145,56 +126,36 @@ def _do_enable(name, enable):
     
     return rc, stdout, stderr
     
-argfile = sys.argv[1]
+def main():
-args = open(argfile, 'r').read()
+    module = AnsibleModule(
-items = shlex.split(args)
+        argument_spec = dict(
-syslog.openlog('ansible-%s' % os.path.basename(__file__))
+            name = dict(required=True),
-syslog.syslog(syslog.LOG_NOTICE, 'Invoked with %s' % args)
+            state = dict(choices=['running', 'started', 'stopped', 'restarted', 'reloaded']),
-
+            list_items = dict(choices=['status']),
-if not len(items):
+            enable = dict(choices=['on', 'off', 'true', 'false', 'yes', 'no', 'enable', 'disable', 'none'])
-    fail_json(dict(failed=True, msg='this module requires arguments (-a)'))
+        )
-
+    )
-params = {}
+
-for arg in items:
+    p = module.params
-    if "=" not in arg:
+    name = p['name']
-        fail_json(dict(failed=True, msg='expected key=value format arguments'))
+    state = p.get('state', None)
-
+    list_items = p.get('list_items', None)
-    (name, value) = arg.split("=")
+    enable = p.get('enable', None)
-    params[name] = value
-
-name = params.get('name', None)
-
-if name is None:
-    fail_json(dict(failed=True, msg='missing name'))
-
-state = params.get('state', None)
-list_items = params.get('list', None)
-enable = params.get('enabled', params.get('enable', None))
-
-# running and started are the same
-if state and state.lower() not in [ 'running', 'started', 'stopped', 'restarted','reloaded' ]:
-    fail_json(dict(failed=True, msg='invalid value for state'))
-if list_items and list_items.lower() not in [ 'status' ]:
-    fail_json(dict(failed=True, msg='invalid value for list'))
-if enable and enable.lower() not in [ 'on', 'off', 'true', 'false', 'yes', 'no', 'enable', 'disable' ]:
-    fail_json(dict(failed=True, msg='invalid value for enable'))
-    
 
     # ===========================================
     # find binaries locations on minion
-_find_binaries()
+    _find_binaries(module)
-
     
     # ===========================================
     # get service status
     running = _get_service_status(name)
 
-
+    # ===========================================
-if state or enable:
+    # Some common variables
+    changed = False
     rc = 0
-    out = ''
     err = ''
-    changed = False
+    out = ''
     
     if enable:
         rc_enable, out_enable, err_enable = _do_enable(name, enable)
@@ -203,30 +164,24 @@ if state or enable:
         err += err_enable
 
     if state and running == None:
-        print json.dumps({
+        module.fail_json(msg="failed determining the current service state => state stays unchanged", changed=False)
-            "failed" : True,
+
-            "msg"    : "failed determining the current service state => state stays unchanged",
-            "changed": False
-        })
-        sys.exit(1)
     elif state:
         # a state change command has been requested
 
         # ===========================================
         # determine if we are going to change anything
-
+        if not running and state in ["started", "running"]:
-        if not running and state in ("started", "running"):
             changed = True
-        elif running and state in ("stopped","reloaded"):
+        elif running and state in ["stopped","reloaded"]:
             changed = True
         elif state == "restarted":
             changed = True
 
         # ===========================================
         # run change commands if we need to
-
         if changed:
-            if state in ('started', 'running'):
+            if state in ['started', 'running']:
                 rc_state, stdout, stderr = _run("%s %s start" % (SERVICE, name))
             elif state == 'stopped':
                 rc_state, stdout, stderr = _run("%s %s stop" % (SERVICE, name))
@@ -244,27 +199,17 @@ if state or enable:
             rc = rc + rc_state
 
     if rc != 0:
-
+        module.fail_json(msg=err)
-        print json.dumps({
-            "failed" : True,
-            "rc"     : rc,
-        })
-        sys.exit(1)
-
-
-    # ===============================================
-    # success
 
     result = {"changed": changed}
-
     rc, stdout, stderr = _run("%s %s status" % (SERVICE, name))
-    if list_items and list_items in [ 'status' ]:
+    if list_items == 'status':
         result['status'] = stdout
-    print json.dumps(result)
+    module.exit_json(**result);
     
-else:
-    print json.dumps(dict(failed=True, msg="expected state or list parameters"))
 
+# this is magic, see lib/ansible/module_common.py 
+#<<INCLUDE_ANSIBLE_MODULE_COMMON>> 
 
-sys.exit(0)
+main()