httpapi connection support #1086

ansible_mitogen/connection.py

@@ -41,6 +41,7 @@
 import ansible.constants as C
 import ansible.errors
 import ansible.plugins.connection
+from ansible.plugins.action.normal import ActionModule
 
 import mitogen.core
 
@@ -585,7 +586,7 @@ def _get_task_vars(self):
  if f.f_code.co_name == 'run':
  f_locals = f.f_locals
  f_self = f_locals.get('self')
- if isinstance(f_self, ansible_mitogen.mixins.ActionModuleMixin):
+ if isinstance(f_self, ansible_mitogen.mixins.ActionModuleMixin) or (self._play_context.connection == 'httpapi' and isinstance(f_self, ActionModule)):
  # backref for python interpreter discovery, should be safe because _get_task_vars
  # is always called before running interpreter discovery
  self._action = f_self

ansible_mitogen/plugins/connection/mitogen_ssh.py

@@ -75,7 +75,7 @@
 
 class Connection(ansible_mitogen.connection.Connection):
  transport = 'ssh'
- vanilla_class = ansible_mitogen.loaders.connection_loader__get(
+ (vanilla_class, _) = ansible_mitogen.loaders.connection_loader__get(
  'ssh',
  class_only=True,
  )