Install ansible-runner-http as local python package

Signed-off-by: chiragkyal <ckyal@redhat.com>

Author: chiragkyal

images/ansible-operator/Dockerfile

@@ -11,12 +11,15 @@ RUN rustc --version
 
 # Copy python dependencies (including ansible) to be installed using Pipenv
 COPY images/ansible-operator/Pipfile* ./
+# Copy our local ansible-runner-http replacement module
+COPY images/ansible-operator/ansible_runner_http ./ansible_runner_http
+COPY images/ansible-operator/setup.py ./setup.py
 # Instruct pip(env) not to keep a cache of installed packages,
 # to install into the global site-packages and
 # to clear the pipenv cache as well
 ENV PIP_NO_CACHE_DIR=1 \
-    PIPENV_SYSTEM=1 \
-    PIPENV_CLEAR=1
+  PIPENV_SYSTEM=1 \
+  PIPENV_CLEAR=1
 # Ensure fresh metadata rather than cached metadata, install system and pip python deps,
 # and remove those not needed at runtime.
 RUN set -e && dnf clean all && rm -rf /var/cache/dnf/* \
@@ -27,6 +30,7 @@ RUN set -e && dnf clean all && rm -rf /var/cache/dnf/* \
   && pip3 install --upgrade pip~=23.3.2 \
   && pip3 install pipenv==2023.11.15 \
   && pipenv install --deploy \
+  && pip3 install . \
   && pipenv check \
   && dnf remove -y gcc libffi-devel openssl-devel python3.12-devel \
   && dnf clean all \
@@ -63,8 +67,8 @@ RUN curl -L -o /tini https://github.com/krallin/tini/releases/download/${TINI_VE
 FROM base AS final
 
 ENV HOME=/opt/ansible \
-    USER_NAME=ansible \
-    USER_UID=1001
+  USER_NAME=ansible \
+  USER_UID=1001
 
 # Ensure directory permissions are properly set
 RUN echo "${USER_NAME}:x:${USER_UID}:0:${USER_NAME} user:${HOME}:/sbin/nologin" >> /etc/passwd \

images/ansible-operator/Pipfile

@@ -5,11 +5,11 @@ name = "pypi"
 
 [packages]
 ansible-runner = "~=2.4.0"
-ansible-runner-http = "~=1.0.0"
+requests = "~=2.32.5"
+requests-unixsocket = "==0.4.1"
 ansible-core = "~=2.18.3"
 urllib3 = "~=2.5.0"
 kubernetes = "==33.1.0"
-requests = "~=2.32.5"
 
 [dev-packages]
 

images/ansible-operator/Pipfile.lock

@@ -0,0 +1 @@
+from .events import status_handler, event_handler # noqa

images/ansible-operator/ansible_runner_http/__init__.py

@@ -0,0 +1,45 @@
+import os
+import requests
+import requests_unixsocket
+import logging
+
+logger = logging.getLogger('ansible-runner')
+
+def send_request(url, data, headers={}, urlpath=None):
+    if os.path.exists(url):
+        url_actual = "http+unix://{}".format(url.replace("/", "%2F"))
+        if urlpath is not None:
+            url_actual += urlpath
+        session = requests_unixsocket.Session()
+    else:
+        url_actual = url
+        session = requests.Session()
+    logger.debug("Sending payload to {}".format(url_actual))
+    return session.post(url_actual, headers=headers, json=(data))
+
+
+def get_configuration(runner_config):
+    runner_url = runner_config.settings.get("runner_http_url", None)
+    runner_url = os.getenv("RUNNER_HTTP_URL", runner_url)
+    runner_path = runner_config.settings.get("runner_http_path", None)
+    runner_path = os.getenv("RUNNER_HTTP_PATH", runner_path)
+    runner_headers = runner_config.settings.get("runner_http_headers", None)
+    return dict(runner_url=runner_url,
+                runner_path=runner_path,
+                runner_headers=runner_headers)
+
+
+def status_handler(runner_config, data):
+    plugin_config = get_configuration(runner_config)
+    if plugin_config['runner_url'] is not None:
+        status = send_request(plugin_config['runner_url'],
+                              data=data,
+                              headers=plugin_config['runner_headers'],
+                              urlpath=plugin_config['runner_path'])
+        logger.debug("POST Response {}".format(status))
+    else:
+        logger.info("HTTP Plugin Skipped")
+
+
+def event_handler(runner_config, data):
+    status_handler(runner_config, data)