passing config to all plugins

This commit is contained in:
dcore94 2021-03-22 16:36:35 +01:00
parent c2420a7b21
commit 3b0e186281
6 changed files with 12 additions and 11 deletions

View File

@ -54,8 +54,8 @@ class Ansible(PyExecPlugin):
"ownerEmail" : "m.lettere@gmail.com"
}
def __init__(self, data=None):
super().__init__(data)
def __init__(self, data=None, config=None):
super().__init__(data, config)
self.playbook = self.data.get("playbook")
self.hosts = self.data.get("hosts", ["localhost"])
self.connection = self.data.get("connection","local")

View File

@ -11,8 +11,8 @@ class Plugin(PyExecPlugin):
"ownerEmail" : "m.lettere@gmail.com"
}
def __init__(self, data=None):
super().__init__(data)
def __init__(self, data=None, config=None):
super().__init__(data, config)
def execute(self):
code = self.data.get("code")

View File

@ -14,8 +14,8 @@ class Plugin(PyExecPlugin):
"ownerEmail" : "m.lettere@gmail.com"
}
def __init__(self, data):
super().__init__(data)
def __init__(self, data, config=None):
super().__init__(data, config)
self.method = data.get("method") or "get"
self.url = data.get("url")
self.headers = data.get("headers") or {}

View File

@ -17,8 +17,8 @@ class Plugin(PyExecPlugin):
"ownerEmail" : "m.lettere@gmail.com"
}
def __init__(self, data=None):
super().__init__(data)
def __init__(self, data=None, config=None):
super().__init__(data, config)
self.template = data["template"]
self.command = data.get("command", "build")
self.extra_vars = data.get("extra_vars", {})

View File

@ -14,8 +14,8 @@ class Plugin(PyExecPlugin):
"ownerEmail" : "m.lettere@gmail.com"
}
def __init__(self, data=None):
super().__init__(data)
def __init__(self, data=None, config=None):
super().__init__(data, config)
def execute(self):
results = []

View File

@ -53,8 +53,9 @@ class PyExecPlugins(type):
logging.getLogger("pyexec").warning("Unable to register task defs %s", e)
class PyExecPlugin(object, metaclass=PyExecPlugins):
def __init__(self, data=None):
def __init__(self, data=None, config=None):
self.data = data
self.config = config
def hasDefinition(self):
return (self.taskdef is not None)