text: #!/usr/bin/python
  
  # GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
  
  from __future__ import (absolute_import, division, print_function)
  __metaclass__ = type
  
  DOCUMENTATION = '''
  ---
  module: routeros_command
  author: "Egor Zaitsev (@heuels)"
  short_description: Run commands on remote devices running MikroTik RouterOS
  description:
    - Sends arbitrary commands to an RouterOS node and returns the results
      read from the device. This module includes an
      argument that will cause the module to wait for a specific condition
      before returning or timing out if the condition is not met.
  options:
    commands:
      description:
        - List of commands to send to the remote RouterOS device over the
          configured provider. The resulting output from the command
          is returned. If the I(wait_for) argument is provided, the
          module is not returned until the condition is satisfied or
          the number of retries has expired.
      required: true
    wait_for:
      description:
        - List of conditions to evaluate against the output of the
          command. The task will wait for each condition to be true
          before moving forward. If the conditional is not true
          within the configured number of retries, the task fails.
          See examples.
    match:
      description:
        - The I(match) argument is used in conjunction with the
          I(wait_for) argument to specify the match policy.  Valid
          values are C(all) or C(any).  If the value is set to C(all)
          then all conditionals in the wait_for must be satisfied.  If
          the value is set to C(any) then only one of the values must be
          satisfied.
      default: all
      choices: ['any', 'all']
    retries:
      description:
        - Specifies the number of retries a command should by tried
          before it is considered failed. The command is run on the
          target device every retry and evaluated against the
          I(wait_for) conditions.
      default: 10
    interval:
      description:
        - Configures the interval in seconds to wait between retries
          of the command. If the command does not pass the specified
          conditions, the interval indicates how long to wait before
          trying the command again.
      default: 1
  '''
  
  EXAMPLES = """
  tasks:
    - name: Run command on remote devices
      community.network.routeros_command:
        commands: /system routerboard print
  
    - name: Run command and check to see if output contains routeros
      community.network.routeros_command:
        commands: /system resource print
        wait_for: result[0] contains MikroTik
  
    - name: Run multiple commands on remote nodes
      community.network.routeros_command:
        commands:
          - /system routerboard print
          - /system identity print
  
    - name: Run multiple commands and evaluate the output
      community.network.routeros_command:
        commands:
          - /system routerboard print
          - /interface ethernet print
        wait_for:
          - result[0] contains x86
          - result[1] contains ether1
  """
  
  RETURN = """
  stdout:
    description: The set of responses from the commands
    returned: always apart from low level errors (such as action plugin)
    type: list
    sample: ['...', '...']
  stdout_lines:
    description: The value of stdout split into a list
    returned: always apart from low level errors (such as action plugin)
    type: list
    sample: [['...', '...'], ['...'], ['...']]
  failed_conditions:
    description: The list of conditionals that have failed
    returned: failed
    type: list
    sample: ['...', '...']
  """
  
  import re
  import time
  
  from ansible_collections.community.network.plugins.module_utils.network.routeros.routeros import run_commands
  from ansible_collections.community.network.plugins.module_utils.network.routeros.routeros import routeros_argument_spec
  from ansible.module_utils.basic import AnsibleModule
  from ansible_collections.ansible.netcommon.plugins.module_utils.network.common.utils import ComplexList
  from ansible_collections.ansible.netcommon.plugins.module_utils.network.common.parsing import Conditional
  from ansible.module_utils.six import string_types
  
  
  def to_lines(stdout):
      for item in stdout:
          if isinstance(item, string_types):
              item = str(item).split('\n')
          yield item
  
  
  def main():
      """main entry point for module execution
      """
      argument_spec = dict(
          commands=dict(type='list', required=True),
  
          wait_for=dict(type='list'),
          match=dict(default='all', choices=['all', 'any']),
  
          retries=dict(default=10, type='int'),
          interval=dict(default=1, type='int')
      )
  
      argument_spec.update(routeros_argument_spec)
  
      module = AnsibleModule(argument_spec=argument_spec,
                             supports_check_mode=True)
  
      result = {'changed': False}
  
      wait_for = module.params['wait_for'] or list()
      conditionals = [Conditional(c) for c in wait_for]
  
      retries = module.params['retries']
      interval = module.params['interval']
      match = module.params['match']
  
      while retries > 0:
          responses = run_commands(module, module.params['commands'])
  
          for item in list(conditionals):
              if item(responses):
                  if match == 'any':
                      conditionals = list()
                      break
                  conditionals.remove(item)
  
          if not conditionals:
              break
  
          time.sleep(interval)
          retries -= 1
  
      if conditionals:
          failed_conditions = [item.raw for item in conditionals]
          msg = 'One or more conditional statements have not been satisfied'
          module.fail_json(msg=msg, failed_conditions=failed_conditions)
  
      result.update({
          'changed': False,
          'stdout': responses,
          'stdout_lines': list(to_lines(responses))
      })
  
      module.exit_json(**result)
  
  
  if __name__ == '__main__':
      main()
  