Implemented plugins management from client side.
diff --git a/_states/jenkins_plugin.py b/_states/jenkins_plugin.py
new file mode 100644
index 0000000..4956751
--- /dev/null
+++ b/_states/jenkins_plugin.py
@@ -0,0 +1,131 @@
+import logging
+logger = logging.getLogger(__name__)
+
+install_plugin_groovy = """\
+import jenkins.model.*
+import java.util.logging.Logger
+
+def logger = Logger.getLogger("")
+def installed = false
+def exists = false
+def pluginName="{plugin}"
+def instance = Jenkins.getInstance()
+def pm = instance.getPluginManager()
+def uc = instance.getUpdateCenter()
+def needUpdateSites(maxOldInSec = 1800){{
+ long oldestTs = 0
+ for (UpdateSite s : Jenkins.instance.updateCenter.siteList) {{
+ if(oldestTs == 0 || s.getDataTimestamp()<oldestTs){{
+ oldestTs = s.getDataTimestamp()
+ }}
+ }}
+ return (System.currentTimeMillis()-oldestTs)/1000 > maxOldInSec
+}}
+
+if (!pm.getPlugin(pluginName)) {{
+ if(needUpdateSites()) {{
+ uc.updateAllSites()
+ }}
+ def plugin = uc.getPlugin(pluginName)
+ if (plugin) {{
+ plugin.deploy()
+ installed = true
+ }}
+}}else{{
+ exists = true
+ print("EXISTS")
+}}
+if (installed) {{
+ instance.save()
+ if({restart}){{
+ instance.doSafeRestart()
+ }}
+ print("INSTALLED")
+}}else if(!exists){{
+ print("FAILED")
+}}
+""" # noqa
+
+remove_plugin_groovy = """
+import jenkins.model.*
+import java.util.logging.Logger
+
+def logger = Logger.getLogger("")
+def installed = false
+def initialized = false
+
+def pluginName="{plugin}"
+def instance = Jenkins.getInstance()
+def pm = instance.getPluginManager()
+
+def actPlugin = pm.getPlugin(pluginName)
+if (!actPlugin) {{
+ def pluginToInstall = Jenkins.instance.updateCenter.getPlugin(pluginName)
+ if(!pluginToInstall){{
+ print("FAILED")
+ }}else{{
+ print("NOT PRESENT")
+ }}
+}} else {{
+ actPlugin.disable()
+ actPlugin.archive.delete()
+ if({restart}){{
+ instance.doSafeRestart()
+ }}
+ print("REMOVED")
+}}
+""" # noqa
+
+
+def present(name, restart=False):
+ """
+ Jenkins plugin present state method, for installing plugins
+
+ :param name: plugin name
+ :param restart: do you want to restart jenkins after plugin install?
+ :returns: salt-specified state dict
+ """
+ return _plugin_call(name, restart, install_plugin_groovy, ["INSTALLED", "EXISTS"])
+
+
+def absent(name, restart=False):
+ """
+ Jenkins plugin absent state method, for removing plugins
+
+ :param name: plugin name
+ :param restart: do you want to restart jenkins after plugin remove?
+ :returns: salt-specified state dict
+ """
+ return _plugin_call(name, restart, remove_plugin_groovy, ["REMOVED", "NOT PRESENT"])
+
+
+def _plugin_call(name, restart, template, success_msgs):
+ test = __opts__['test'] # noqa
+ ret = {
+ 'name': name,
+ 'changes': {},
+ 'result': False,
+ 'comment': '',
+ }
+ result = False
+ if test:
+ status = success_msgs[0]
+ ret['changes'][name] = status
+ ret['comment'] = 'Jenkins plugin %s %s' % (name, status.lower())
+ else:
+ call_result = __salt__['jenkins_common.call_groovy_script'](
+ template, {"plugin": name, "restart": "true" if restart else "false"})
+ if call_result["code"] == 200 and call_result["msg"] in success_msgs:
+ status = call_result["msg"]
+ if status == success_msgs[0]:
+ ret['changes'][name] = status
+ ret['comment'] = 'Jenkins plugin %s %s%s' % (name, status.lower(), ", jenkins restarted" if status == success_msgs[0] and restart else "")
+ result = True
+ else:
+ status = 'FAILED'
+ logger.error(
+ "Jenkins plugin API call failure: %s", call_result["msg"])
+ ret['comment'] = 'Jenkins plugin API call failure: %s' % (call_result[
+ "msg"])
+ ret['result'] = None if test else result
+ return ret