ansible_rulebook.exception.ConditionParsingException: Error parsing: event.friend_list.names is select("search",  events.m_0.request.friend_name). Expected end of text, found '('  (at char 33), (line:1, col:34)

$ ansible-rulebook --version
__version__ = '0.11.0'

ansible_rulebook.exception.ConditionParsingException: Error parsing: event.friend_list.names is select("search",  events.m_0.request.friend_name). Expected end of text, found '('  (at char 33), (line:1, col:34)

$ ansible-playbook
usage: ansible-playbook [-h] [--version] [-v] [--private-key PRIVATE_KEY_FILE] [-u REMOTE_USER] [-c CONNECTION] [-T TIMEOUT]
                        [--ssh-common-args SSH_COMMON_ARGS] [--sftp-extra-args SFTP_EXTRA_ARGS] [--scp-extra-args SCP_EXTRA_ARGS]
                        [--ssh-extra-args SSH_EXTRA_ARGS] [-k | --connection-password-file CONNECTION_PASSWORD_FILE] [--force-handlers] [--flush-cache]
                        [-b] [--become-method BECOME_METHOD] [--become-user BECOME_USER] [-K | --become-password-file BECOME_PASSWORD_FILE] [-t TAGS]
                        [--skip-tags SKIP_TAGS] [-C] [--syntax-check] [-D] [-i INVENTORY] [--list-hosts] [-l SUBSET] [-e EXTRA_VARS]
                        [--vault-id VAULT_IDS] [--ask-vault-password | --vault-password-file VAULT_PASSWORD_FILES] [-f FORKS] [-M MODULE_PATH]
                        [--list-tasks] [--list-tags] [--step] [--start-at-task START_AT_TASK]
                        playbook [playbook ...]
ansible-playbook: error: the following arguments are required: playbook
.......
$

$ ansible-rulebook
$

condition: events.third << event.i == 2

Modified tests/test_simple.yml
changed
condition: event.i == 2
to
condition: events.second << event.i == 2

Ran pytest
pytest tests/test_engine.py::test_run_rules_simple

__version__ = '0.12.0'
  Executable location = /root/eda-venv/bin/ansible-rulebook
  Drools_jpy version = 0.3.0
  Java home = /etc/alternatives/jre
  Java version = 17.0.7
  Python version = 3.9.14 (main, Jan  9 2023, 00:00:00) [GCC 11.3.1 20220421 (Red Hat 11.3.1-2)]

# cat rulebook.yml 
---
- name: Listen for events on a webhook
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
  rules:
    - name: Check performance events
      condition: event.payload.vendor-product.rule == "Test"
      action:
        run_playbook:
          name: action.yml
# ansible-rulebook --inventory inventory.yml --rulebook rulebook.yml
2023-04-24 09:27:28,539 - ansible_rulebook.cli - ERROR - Unexpected exception
Traceback (most recent call last):
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/condition_parser.py", line 320, in parse_condition
    return condition.parseString(condition_string, parse_all=True)[0]
  File "/root/eda-venv/lib64/python3.9/site-packages/pyparsing/core.py", line 1141, in parse_string
    raise exc.with_traceback(None)
pyparsing.exceptions.ParseException: Expected end of text, found '.'  (at char 28), (line:1, col:29)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/cli.py", line 223, in main
    asyncio.run(app.run(args))
  File "/usr/lib64/python3.9/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/usr/lib64/python3.9/asyncio/base_events.py", line 647, in run_until_complete
    return future.result()
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/app.py", line 71, in run
    startup_args.rulesets = load_rulebook(
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/app.py", line 171, in load_rulebook
    rulesets = rules_parser.parse_rule_sets(data, variables)
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/rules_parser.py", line 72, in parse_rule_sets
    rules=parse_rules(rule_set.get("rules", {}), variables),
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/rules_parser.py", line 143, in parse_rules
    condition=parse_condition(rule["condition"]),
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/rules_parser.py", line 177, in parse_condition
    return rt.Condition("all", [parse_condition_value(condition)])
  File "/root/eda-venv/lib64/python3.9/site-packages/ansible_rulebook/condition_parser.py", line 324, in parse_condition
    raise ConditionParsingException(msg)
ansible_rulebook.exception.ConditionParsingException: Error parsing: event.payload.vendor-product.rule == "Test". Expected end of text, found '.'  (at char 28), (line:1, col:29)

ansible-events --rules ./performance_test/1k_event_rules.yml --inventory ./performance_test/inventory1.yml -S ./performance_test/sources/

ansible-events --rules ./performance_test/1k_event_rules.yml --inventory ./performance_test/inventory1.yml -S ./performance_test/sources/

---
- name: Run playbook
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: 127.0.0.1
        port: 6000
  rules:
    - name: Webhook called
      condition: event.payload.cmd == 'start'
      action:
        run_playbook:
          name: /home/charlespick/playbook.yml

2023-10-29 18:46:29,916 - ansible_rulebook.rule_set_runner - ERROR - Error calling action run_playbook, err [('/home/charlespick/.ansible/cp/47aa5da64f', '/tmp/edach48wb7s/project/.ansible/cp/47aa5da64f', "[Errno 6] No such device or address: '/home/charlespick/.ansible/cp/47aa5da64f'")]

hosts: localhost
sources:
  - ansible.eda.webhook:
      host: 0.0.0.0
      port: 5000
      token: MySecretToken

hosts: localhost
sources:
  - ansible.eda.webhook:
      host: 0.0.0.0
      port: 5000
      token: {{ token }} 

ansible-rulebook -r somerulebook.yml --controller-url https://some-awx:443 --controller-token some-valid-token --controller-ssl-verify no

2023-07-18 19:23:22,870 - ansible_rulebook.job_template_runner - ERROR - Error connecting to controller 401, message='Unauthorized', url=URL('https://some-awx:443/api/v2/config/')
2023-07-18 19:23:22,872 - ansible_rulebook.cli - ERROR - Terminating 401, message='Unauthorized', url=URL('https://some-awx:443/api/v2/config/')

DISTRIB_ID=Ubuntu
DISTRIB_RELEASE=22.04
DISTRIB_CODENAME=jammy
DISTRIB_DESCRIPTION="Ubuntu 22.04.4 LTS"

ansible-rulebook --version
Traceback (most recent call last):
  File "/home/meyers/.local/bin/ansible-rulebook", line 5, in <module>
    from ansible_rulebook.cli import main
  File "/home/meyers/.local/lib/python3.10/site-packages/ansible_rulebook/cli.py", line 36, in <module>
    from ansible_rulebook import app  # noqa: E402
  File "/home/meyers/.local/lib/python3.10/site-packages/ansible_rulebook/app.py", line 32, in <module>
    from ansible_rulebook.engine import run_rulesets, start_source
  File "/home/meyers/.local/lib/python3.10/site-packages/ansible_rulebook/engine.py", line 37, in <module>
    from ansible_rulebook.rule_set_runner import RuleSetRunner
  File "/home/meyers/.local/lib/python3.10/site-packages/ansible_rulebook/rule_set_runner.py", line 36, in <module>
    from ansible_rulebook.action.pg_notify import PGNotify
  File "/home/meyers/.local/lib/python3.10/site-packages/ansible_rulebook/action/pg_notify.py", line 20, in <module>
    from psycopg import AsyncClientCursor, AsyncConnection, OperationalError
ModuleNotFoundError: No module named 'psycopg'

      action:
        run_playbook:
          name: ansible.containerized_installer.install

May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]: 2023-05-24 12:43:24,546 - ansible_rulebook.rule_set_runner - ERROR - Error calling run_playbook
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]: Traceback (most recent call last):
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:   File "/usr/local/lib/python3.11/site-packages/ansible_rulebook/rule_set_runner.py", line 375, in _call_action
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:     await builtin_actions[action](
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:   File "/usr/local/lib/python3.11/site-packages/ansible_rulebook/builtin.py", line 303, in run_playbook
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:     temp_dir, playbook_name = await pre_process_runner(
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:                               ^^^^^^^^^^^^^^^^^^^^^^^^^
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:   File "/usr/local/lib/python3.11/site-packages/ansible_rulebook/builtin.py", line 647, in pre_process_runner
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]:     raise PlaybookNotFoundException(msg)
May 24 12:43:24 ip-172-31-17-143.ec2.internal ansible-rulebook[1164134]: ansible_rulebook.exception.PlaybookNotFoundException: Could not find a playbook for ansible.containerized_installer.install from /home/ec2-user/aap/servicediscovery/etc

[ec2-user@ip-172-31-17-143 aap-containerized-installer]$ ansible-playbook ansible.containerized_installer.install
[WARNING]: provided hosts list is empty, only localhost is available. Note that the implicit localhost does not match 'all'
[WARNING]: running playbook inside collection ansible.containerized_installer

>           event = event_log.get_nowait()

/Users/madhukanoor/devsrc/ansible-rulebook/tests/test_examples.py:1398: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <Queue at 0x105b4f4f0 maxsize=0>

    def get_nowait(self):
        """Remove and return an item from the queue.
    
        Return an item if one is immediately available, else raise QueueEmpty.
        """
        if self.empty():
>           raise QueueEmpty
E           asyncio.queues.QueueEmpty

/opt/homebrew/Cellar/[email protected]/3.9.16/Frameworks/Python.framework/Versions/3.9/lib/python3.9/asyncio/queues.py:189: QueueEmpty

ansible [core 2.16.0]
  config file = None
  configured module search path = ['/home/evonlanthen/.ansible/plugins/modules', '/usr/share/ansible/plugins/modules']
  ansible python module location = /home/evonlanthen/.local/lib/python3.10/site-packages/ansible
  ansible collection location = /home/evonlanthen/.ansible/collections:/usr/share/ansible/collections
  executable location = /home/evonlanthen/.local/bin/ansible
  python version = 3.10.12 (main, Nov 20 2023, 15:14:05) [GCC 11.4.0] (/usr/bin/python3)
  jinja version = 3.0.3
  libyaml = True

1.0.6
  Executable location = /home/evonlanthen/.local/bin/ansible-rulebook
  Drools_jpy version = 0.3.9
  Java home = /usr/lib/jvm/java-17-openjdk-amd64
  Java version = 17.0.10
  Python version = 3.10.12 (main, Nov 20 2023, 15:14:05) [GCC 11.4.0]

.
├── inventories
│   └── production
│       ├── group_vars
│       │   └── mygroup.yml
│       ├── host_vars
│       │   └── localhost.yml
│       └── hosts.yml
├── playbook.yml
└── rulebook.yml

---
- hosts: mygroup
  gather_facts: false
  tasks:
    - name: Show vars
      ansible.builtin.debug:
        msg:
          - "groupvar: {{ mygroupvar }}"
          - "hostvar: {{ myhostvar }}"
      connection: local

---
- name: Listen for selfservice events on a webhook
  hosts: all

  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
      filters:
        - ansible.eda.insert_hosts_to_meta:
            host_path: payload.host
  rules:
    - name: Test rule
      condition: 1 == 1
      actions:
        - print_event:
            pretty: true
        - run_playbook:
            name: playbook.yml
            copy_files: true

---
mygroup:
  hosts:
    localhost

---
mygroupvar: 'hello from group var'

evonlanthen@SWP-HM60793 ~/ansible/rulebook $ ansible-playbook -i inventories/production/hosts.yml playbook.yml

PLAY [mygroup] *********************************************************************************************************************************************************************************************************************************************

TASK [Show vars] *******************************************************************************************************************************************************************************************************************************************
ok: [localhost] => {
    "msg": [
        "groupvar: hello from group var",
        "hostvar: hello from host var"
    ]
}

PLAY RECAP *************************************************************************************************************************************************************************************************************************************************
localhost                  : ok=1    changed=0    unreachable=0    failed=0    skipped=0    rescued=0    ignored=0

evonlanthen@SWP-HM60793 ~/ansible/rulebook $ ansible-rulebook -i inventories/production/hosts.yml -r rulebook.yml -v
2024-05-15 15:39:28,769 - ansible_rulebook.app - INFO - Starting sources
2024-05-15 15:39:28,769 - ansible_rulebook.app - INFO - Starting rules
2024-05-15 15:39:28,769 - drools.ruleset - INFO - Using jar: /home/evonlanthen/.local/lib/python3.10/site-packages/drools/jars/drools-ansible-rulebook-integration-runtime-1.0.6-SNAPSHOT.jar
2024-05-15 15:39:29 201 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.AbstractRulesEvaluator - Start automatic pseudo clock with a tick every 100 milliseconds
2024-05-15 15:39:29,212 - ansible_rulebook.engine - INFO - load source ansible.eda.webhook
2024-05-15 15:39:29,505 - ansible_rulebook.engine - INFO - loading source filter ansible.eda.insert_hosts_to_meta
2024-05-15 15:39:29,505 - ansible_rulebook.engine - INFO - loading source filter eda.builtin.insert_meta_info
2024-05-15 15:39:29,786 - ansible_rulebook.engine - INFO - Waiting for all ruleset tasks to end
2024-05-15 15:39:29,786 - ansible_rulebook.rule_set_runner - INFO - Waiting for actions on events from Listen for selfservice events on a webhook
2024-05-15 15:39:29,786 - ansible_rulebook.rule_set_runner - INFO - Waiting for events, ruleset: Listen for selfservice events on a webhook
2024-05-15 15:39:29 786 [drools-async-evaluator-thread] INFO org.drools.ansible.rulebook.integration.api.io.RuleExecutorChannel - Async channel connected

evonlanthen@SWP-HM60793 ~ $ curl -H 'Content-Type: application/json' -d '{"host":"localhost"}' 127.0.0.1:5000/endpoint

2024-05-15 15:41:27,647 - aiohttp.access - INFO - 127.0.0.1 [15/May/2024:14:41:27 +0100] "POST /endpoint HTTP/1.1" 200 159 "-" "curl/7.81.0"

** 2024-05-15 15:41:27.649608 [event] **********************************************************************************************************************************************************************************************************************
{'meta': {'endpoint': 'endpoint',
          'headers': {'Accept': '*/*',
                      'Content-Length': '20',
                      'Content-Type': 'application/json',
                      'Host': '127.0.0.1:5000',
                      'User-Agent': 'curl/7.81.0'},
          'hosts': ['localhost'],
          'received_at': '2024-05-15T13:41:27.647399Z',
          'source': {'name': 'ansible.eda.webhook',
                     'type': 'ansible.eda.webhook'},
          'uuid': '943699e9-eb36-4537-82f3-3df1e033c282'},
 'payload': {'host': 'localhost'}}
************************************************************************************************************************************************************************************************************************************************************

PLAY [mygroup] *****************************************************************

TASK [Show vars] ***************************************************************
fatal: [localhost]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: 'mygroupvar' is undefined. 'mygroupvar' is undefined\n\nThe error appears to be in '/tmp/eda131fp7ui/project/playbook.yml': line 5, column 7, but may\nbe elsewhere in the file depending on the exact syntax problem.\n\nThe offending line appears to be:\n\n  tasks:\n    - name: Show vars\n      ^ here\n"}

PLAY RECAP *********************************************************************
localhost                  : ok=0    changed=0    unreachable=0    failed=1    skipped=0    rescued=0    ignored=0
2024-05-15 15:41:28,185 - ansible_rulebook.action.runner - INFO - Ansible runner Queue task cancelled
2024-05-15 15:41:28,185 - ansible_rulebook.action.run_playbook - INFO - Ansible runner rc: 2, status: failed
2024-05-15 15:41:28,185 - ansible_rulebook.action.run_playbook - ERROR -
PLAY [mygroup] *****************************************************************

TASK [Show vars] ***************************************************************
fatal: [localhost]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: 'mygroupvar' is undefined. 'mygroupvar' is undefined\n\nThe error appears to be in '/tmp/eda131fp7ui/project/playbook.yml': line 5, column 7, but may\nbe elsewhere in the file depending on the exact syntax problem.\n\nThe offending line appears to be:\n\n  tasks:\n    - name: Show vars\n      ^ here\n"}

PLAY RECAP *********************************************************************
localhost                  : ok=0    changed=0    unreachable=0    failed=1    skipped=0    rescued=0    ignored=0

Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]: 2023-11-16 03:31:40,839 ERROR    Exception inside application: ['“” value has an invalid format. It must be in YYYY-MM-DD HH:MM[:ss[.uuuuuu]][TZ] format.']
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]: Traceback (most recent call last):
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/routing.py", line 62, in __call__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return await application(scope, receive, send)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/routing.py", line 116, in __call__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return await application(
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/routing.py", line 116, in __call__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return await application(
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/consumer.py", line 94, in app
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return await consumer(scope, receive, send)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/consumer.py", line 62, in __call__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await await_many_dispatch([receive], self.dispatch)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/utils.py", line 50, in await_many_dispatch
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await dispatch(result)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/consumer.py", line 73, in dispatch
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await handler(message)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/generic/websocket.py", line 194, in websocket_receive
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await self.receive(text_data=message["text"])
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/aap_eda/wsapi/consumers.py", line 92, in receive
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await self.handle_actions(ActionMessage.parse_obj(data))
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/aap_eda/wsapi/consumers.py", line 135, in handle_actions
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    await self.insert_audit_rule_data(message)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/asgiref/sync.py", line 448, in __call__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    ret = await asyncio.wait_for(future, timeout=None)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib64/python3.9/asyncio/tasks.py", line 442, in wait_for
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return await fut
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib64/python3.9/concurrent/futures/thread.py", line 58, in run
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    result = self.fn(*self.args, **self.kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/channels/db.py", line 13, in thread_handler
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return super().thread_handler(loop, *args, **kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/asgiref/sync.py", line 490, in thread_handler
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return func(*args, **kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/aap_eda/wsapi/consumers.py", line 204, in insert_audit_rule_data
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    audit_rule = models.AuditRule.objects.filter(
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/manager.py", line 85, in manager_method
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return getattr(self.get_queryset(), name)(*args, **kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/query.py", line 941, in filter
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return self._filter_or_exclude(False, args, kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/query.py", line 961, in _filter_or_exclude
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    clone._filter_or_exclude_inplace(negate, args, kwargs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/query.py", line 968, in _filter_or_exclude_inplace
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    self._query.add_q(Q(*args, **kwargs))
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/sql/query.py", line 1416, in add_q
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    clause, _ = self._add_q(q_object, self.used_aliases)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/sql/query.py", line 1435, in _add_q
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    child_clause, needed_inner = self.build_filter(
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/sql/query.py", line 1370, in build_filter
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    condition = self.build_lookup(lookups, col, value)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/sql/query.py", line 1216, in build_lookup
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    lookup = lookup_class(lhs, rhs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/lookups.py", line 25, in __init__
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    self.rhs = self.get_prep_lookup()
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/lookups.py", line 77, in get_prep_lookup
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return self.lhs.output_field.get_prep_value(self.rhs)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/fields/__init__.py", line 1406, in get_prep_value
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    value = super().get_prep_value(value)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/fields/__init__.py", line 1266, in get_prep_value
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    return self.to_python(value)
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:  File "/usr/lib/python3.9/site-packages/django/db/models/fields/__init__.py", line 1388, in to_python
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]:    raise exceptions.ValidationError(
Nov 15 22:31:40 eda01 automation-eda-controller-daphne[821839]: django.core.exceptions.ValidationError: ['“” value has an invalid format. It must be in YYYY-MM-DD HH:MM[:ss[.uuuuuu]][TZ] format.']

    - name: Fiber Adapters
      condition: event.payload.event_tags.playbook is select("==", "Tune Fiber Adapters")
      action:
        run_workflow_template: 
          name: Tune Fiber Adapters
          organization: Default
          job_args:
            extra_vars:
              key: "{{ event.payload.event_tags.key[0] }}"
              run: "{{ event.payload.host_host }}"
              context: "fiber"
              device: "{{ event.payload.event_tags.device[0] }}"
        ```





### Environment

[root@eda01 log]# ansible-rulebook --version
__version__ = '1.0.0'
  Executable location = /usr/bin/ansible-rulebook
  Drools_jpy version = 0.3.4
  Java home = /usr/lib/jvm/java-17-openjdk-17.0.9.0.9-2.el8.x86_64
  Java version = 17.0.9
  Python version = 3.9.16 (main, Sep 22 2023, 17:57:55) [GCC 8.5.0 20210514 (Red Hat 8.5.0-18)]

### Steps to reproduce

Create a workflow template with a few steps

Try and run it using EDA.

### Actual results

Error in daphne log.

### Expected results

It to run the workflow template job on AAP.

### Additional information

_No response_

ansible.eda       1.3.4

$ ansible-rulebook --version
__version__ = '0.11.0'

$ cat eda.yaml 
# eda.yaml
apiVersion: eda.ansible.com/v1alpha1
kind: EDA
metadata:
  name: my-eda
spec:
  automation_server_url: http://awx-demo-service.awx/awx/
  service_type: ClusterIP
  ingress_type: ingress

2024-01-19 23:32:13,505 - ansible_rulebook.websocket - INFO - websocket ws://my-eda-daphne:8001/api/eda/ws/ansible-rulebook connected
2024-01-19 23:32:13,552 - ansible_rulebook.job_template_runner - INFO - Attempting to connect to Controller http://awx-demo-service.awx/awx
2024-01-19 23:32:13,553 - ansible_rulebook.job_template_runner - ERROR - Error connecting to controller 404, message='Not Found', url=URL('http://awx-demo-service.awx/api/v2/config/')
2024-01-19 23:32:13,554 - ansible_rulebook.cli - ERROR - Terminating 404, message='Not Found', url=URL('http://awx-demo-service.awx/api/v2/config/') 

export EDA_CONTROLLER_URL="http://localhost:8081/awx/"
export EDA_CONTROLLER_TOKEN="ZesMMFepb2WYfHNEfvv1pMz0PMbUkE"

$ ansible-rulebook -r rulebooks/hello.yaml -vv 
2024-01-19 20:02:55,303 - asyncio - DEBUG - Using selector: KqueueSelector
2024-01-19 20:02:55,304 - ansible_rulebook.app - DEBUG - Loading rules from the file system rulebooks/hello.yaml
2024-01-19 20:02:55,309 - ansible_rulebook.condition_parser - DEBUG - [Identifier(value='event.i'), '==', Integer(value=1)]
2024-01-19 20:02:55,309 - ansible_rulebook.job_template_runner - INFO - Attempting to connect to Controller http://localhost:8081/awx/
2024-01-19 20:02:55,317 - ansible_rulebook.cli - ERROR - Terminating Expecting value: line 1 column 1 (char 0)

$ ansible-rulebook -r rulebooks/hello.yaml -vv 
2024-01-19 20:16:46,145 - asyncio - DEBUG - Using selector: KqueueSelector
2024-01-19 20:16:46,145 - ansible_rulebook.app - DEBUG - Loading rules from the file system rulebooks/hello.yaml
2024-01-19 20:16:46,150 - ansible_rulebook.condition_parser - DEBUG - [Identifier(value='event.i'), '==', Integer(value=1)]
2024-01-19 20:16:46,151 - ansible_rulebook.job_template_runner - INFO - Attempting to connect to Controller http://localhost:8081/awx/
2024-01-19 20:16:46,259 - ansible_rulebook.app - INFO - AAP Version 23.6.0
2024-01-19 20:16:46,259 - ansible_rulebook.app - INFO - Starting sources
2024-01-19 20:16:46,259 - ansible_rulebook.app - INFO - Starting rules
2024-01-19 20:16:46,259 - ansible_rulebook.engine - INFO - run_ruleset
2024-01-19 20:16:46,260 - drools.ruleset - INFO - Using jar: /opt/homebrew/lib/python3.9/site-packages/drools/jars/drools-ansible-rulebook-integration-runtime-1.0.5-SNAPSHOT.jar
2024-01-19 20:16:46,508 - drools.ruleset - DEBUG - Creating Drools Ruleset
2024-01-19 20:16:46 801 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.AbstractRulesEvaluator - Start automatic pseudo clock with a tick every 100 milliseconds
2024-01-19 20:16:46,805 - drools.ruleset - DEBUG - Ruleset Session ID : 1
2024-01-19 20:16:46,805 - ansible_rulebook.engine - INFO - ruleset define: {"name": "Hello Events", "hosts": ["localhost"], "sources": [{"EventSource": {"name": "ansible.eda.range", "source_name": "ansible.eda.range", "source_args": {"limit": 5}, "source_filters": []}}], "rules": [{"Rule": {"name": "Say Hello", "condition": {"AllCondition": [{"EqualsExpression": {"lhs": {"Event": "i"}, "rhs": {"Integer": 1}}}]}, "actions": [{"Action": {"action": "run_job_template", "action_args": {"name": "Hello World", "organization": "Default"}}}], "enabled": true}}]}
2024-01-19 20:16:46,805 - drools.dispatch - DEBUG - Establishing async channel
2024-01-19 20:16:46,817 - ansible_rulebook.engine - INFO - load source
2024-01-19 20:16:47,077 - ansible_rulebook.engine - ERROR - Source error Could not find source plugin for ansible.eda.range
2024-01-19 20:16:47,077 - ansible_rulebook.engine - ERROR - Shutting down source: ansible.eda.range error : Could not find source plugin for ansible.eda.range

$ cat awx-demo.yml 
---
apiVersion: awx.ansible.com/v1beta1
kind: AWX
metadata:
  name: awx-demo
spec:
  service_type: nodeport
  ingress_type: ingress
  ingress_path: /awx

>>> from urllib.parse import urljoin
>>> UNIFIED_TEMPLATE_SLUG = "/api/v2/unified_job_templates/"
>>> CONFIG_SLUG = "/api/v2/config/"
>>> host="http://awx-demo-service/awx"
>>> url = urljoin(host, href_slug)
>>> url = urljoin(host, CONFIG_SLUG)
>>> print(url)
http://awx-demo-service/api/v2/config/

>>> CONFIG_SLUG = "api/v2/config/"
>>> print(urljoin(host, CONFIG_SLUG))
http://awx-demo-service/awx/api/v2/config/

__version__ = '0.9.4'
b1098dab-ac28-4b68-b604-d4b7bcebc07c

TASK [Gathering Facts] *********************************************************
fatal: [...]: UNREACHABLE! => {"changed": false, "msg": "Failed to connect to the host via ssh: ssh: Could not resolve hostname ...: Name or service not known", "unreachable": true}
ok: [127.0.0.1]

~$ ansible-rulebook --verbose --inventory inventory --rulebook otx.yml
INFO:ansible_rulebook.app:Starting sources
INFO:ansible_rulebook.app:Starting rules
INFO:ansible_rulebook.engine:run_ruleset
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
INFO:ansible_rulebook.engine:ruleset define: {"name": "otx events", "hosts": ["all"], "sources": [{"EventSource": {"name": "Match all messages", "source_name": "ansible.eda.otx", "source_args": {"count": "1"}, "source_filters": []}}], "rules": [{"Rule": {"name": "Send to playboox", "condition": {"AllCondition": [{"IsDefinedExpression": {"Event": "otx"}}]}, "action": {"Action": {"action": "run_playbook", "action_args": {"name": "otx_ufw.yml"}}}, "enabled": true}}]}
INFO:ansible_rulebook.engine:load source
INFO:ansible_rulebook.engine:load source filters
INFO:ansible_rulebook.engine:Calling main in ansible.eda.otx
INFO:ansible_rulebook.engine:Waiting for event from otx events
INFO:ansible_rulebook.rule_generator:calling Send to playboox
INFO:ansible_rulebook.engine:call_action run_playbook
INFO:ansible_rulebook.engine:substitute_variables [{'name': 'otx_ufw.yml'}] [{'event': {'otx': {'ip': '193.105.210.113'}}, 'fact': {'otx': {'ip': '193.105.210.113'}}}]
INFO:ansible_rulebook.engine:action args: {'name': 'otx_ufw.yml'}
INFO:ansible_rulebook.builtin:running Ansible playbook: otx_ufw.yml
INFO:ansible_rulebook.builtin:ruleset: otx events, rule: Send to playboox
INFO:ansible_rulebook.builtin:Calling Ansible runner

PLAY [otx events] **************************************************************

TASK [Gathering Facts] *********************************************************
fatal: [...]: UNREACHABLE! => {"changed": false, "msg": "Failed to connect to the host via ssh: ssh: Could not resolve hostname ...: Name or service not known", "unreachable": true}
ok: [127.0.0.1]

TASK [debug msg] ***************************************************************
ok: [127.0.0.1] => {
    "msg": "debug task: 193.105.210.113"
}

PLAY RECAP *********************************************************************
...                        : ok=0    changed=0    unreachable=1    failed=0    skipped=0    rescued=0    ignored=0   
127.0.0.1                  : ok=2    changed=0    unreachable=0    failed=0    skipped=0    rescued=0    ignored=0   
^C

~$ ansible-inventory -i inventory --list
{
    "_meta": {
        "hostvars": {
            "127.0.0.1": {
                "ansible_connection": "local"
            }
        }
    },
    "all": {
        "children": [
            "ungrouped"
        ]
    },
    "ungrouped": {
        "hosts": [
            "127.0.0.1"
        ]
    }
}

~$ cat otx*.yml
---
- name: otx events
  hosts: all
  sources:
    - name: Match all messages
      ansible.eda.otx:
        count: "1"
  rules:
    - name: Send to playboox
      condition: event.otx is defined
      action:
        run_playbook:
          name: otx_ufw.yml
...
---
- name: otx events
  hosts: all
  tasks:
    - name: debug msg
      ansible.builtin.debug:
        msg: "debug task: {{ event.otx.ip }}"
...

$ ansible-rulebook --version

__version__ = '0.9.4'
fca63ab1-f243-4459-97ef-bb546e3cc60d

$ ansible --version

ansible [core 2.12.2]
  config file = None
  configured module search path = ['/home/vscode/.ansible/plugins/modules', '/usr/share/ansible/plugins/modules']
  ansible python module location = /usr/local/lib/python3.8/dist-packages/ansible
  ansible collection location = /home/vscode/.ansible/collections:/usr/share/ansible/collections
  executable location = /usr/local/bin/ansible
  python version = 3.8.10 (default, Mar 15 2022, 12:22:08) [GCC 9.4.0]
  jinja version = 3.1.2
  libyaml = True
  
$ cat /etc/os-release 

NAME="Ubuntu"
VERSION="20.04.4 LTS (Focal Fossa)"
ID=ubuntu
ID_LIKE=debian
PRETTY_NAME="Ubuntu 20.04.4 LTS"
VERSION_ID="20.04"
HOME_URL="https://www.ubuntu.com/"
SUPPORT_URL="https://help.ubuntu.com/"
BUG_REPORT_URL="https://bugs.launchpad.net/ubuntu/"
PRIVACY_POLICY_URL="https://www.ubuntu.com/legal/terms-and-policies/privacy-policy"
VERSION_CODENAME=focal
UBUNTU_CODENAME=focal

---
- name: Simple Event Stream Usage Example
  hosts: all
  sources:
    - crowdstrike.falcon.eventstream:
        falcon_client_id: "{{ lookup('env', 'FALCON_CLIENT_ID') }}"
        falcon_client_secret: "{{ lookup('env', 'FALCON_CLIENT_SECRET') }}"
        falcon_cloud: "us-2"
        stream_name: "{{stream_name | default('eda')}}"

  rules:
    - name: print output
      condition: event.falcon is defined 
      action:
        debug:

ERROR:ansible_rulebook.engine:Source error
Traceback (most recent call last):
 File "/usr/local/lib/python3.8/dist-packages/ansible_rulebook/engine.py", line 130, in start_source
   args = {
 File "/usr/local/lib/python3.8/dist-packages/ansible_rulebook/engine.py", line 131, in <dictcomp>
   k: substitute_variables(v, variables)
 File "/usr/local/lib/python3.8/dist-packages/ansible_rulebook/util.py", line 36, in substitute_variables
   return render_string_or_return_value(value, context)
 File "/usr/local/lib/python3.8/dist-packages/ansible_rulebook/util.py", line 28, in render_string_or_return_value
   return render_string(value, context)
 File "/usr/local/lib/python3.8/dist-packages/ansible_rulebook/util.py", line 21, in render_string
   return jinja2.Template(value, undefined=jinja2.StrictUndefined).render(
 File "/usr/local/lib/python3.8/dist-packages/jinja2/environment.py", line 1301, in render
   self.environment.handle_exception()
 File "/usr/local/lib/python3.8/dist-packages/jinja2/environment.py", line 936, in handle_exception
   raise rewrite_traceback_stack(source=source)
 File "<template>", line 1, in top-level template code
 File "/usr/local/lib/python3.8/dist-packages/jinja2/utils.py", line 83, in from_obj
   if hasattr(obj, "jinja_pass_arg"):
jinja2.exceptions.UndefinedError: 'lookup' is undefined

ansible-doc -t lookup -l | grep env
[WARNING]: Collection ibm.qradar does not support Ansible version 2.12.2
[WARNING]: Collection splunk.es does not support Ansible version 2.12.2
[WARNING]: Collection frr.frr does not support Ansible version 2.12.2
env                                               Read the value of environ...

 `ansible-rulebook -i inventory.yml --rulebook rulebooks/event_stream_example.yml --env-vars FALCON_CLIENT_ID,FALCON_CLIENT_SECRET`

PIP_NO_BINARY=jpy pip install jpy 
DEPRECATION: --no-binary currently disables reading from the cache of locally built wheels. In the future --no-binary will not influence the wheel cache. pip 23.1 will enforce this behaviour change. A possible replacement is to use the --no-cache-dir option. You can use the flag --use-feature=no-binary-enable-wheel-cache to test the upcoming behaviour. Discussion can be found at https://github.com/pypa/pip/issues/11453
Collecting jpy
  Using cached jpy-0.12.0.tar.gz (171 kB)
  Preparing metadata (setup.py) ... done
Installing collected packages: jpy
  DEPRECATION: jpy is being installed using the legacy 'setup.py install' method, because the '--no-binary' option was enabled for it and this currently disables local wheel building for projects that don't have a 'pyproject.toml' file. pip 23.1 will enforce this behaviour change. A possible replacement is to enable the '--use-pep517' option. Discussion can be found at https://github.com/pypa/pip/issues/11451
  Running setup.py install for jpy ... error
  error: subprocess-exited-with-error
  
  × Running setup.py install for jpy did not run successfully.
  │ exit code: 1
  ╰─> [198 lines of output]
      /usr/local/lib/python3.11/site-packages/setuptools/dist.py:771: UserWarning: Usage of dash-separated 'description-file' will not be supported in future versions. Please use the underscore name 'description_file' instead
        warnings.warn(
      running install
      /usr/local/lib/python3.11/site-packages/setuptools/command/install.py:34: SetuptoolsDeprecationWarning: setup.py install is deprecated. Use build and pip and other standards-based tools.
        warnings.warn(
      running build
      running build_py
      creating build
      creating build/lib.linux-x86_64-cpython-311
      copying jpyutil.py -> build/lib.linux-x86_64-cpython-311
      running build_ext
      building 'jpy' extension
      creating build/temp.linux-x86_64-cpython-311
      creating build/temp.linux-x86_64-cpython-311/src
      creating build/temp.linux-x86_64-cpython-311/src/main
      creating build/temp.linux-x86_64-cpython-311/src/main/c
      creating build/temp.linux-x86_64-cpython-311/src/main/c/jni
      gcc -pthread -Wsign-compare -DNDEBUG -g -fwrapv -O3 -Wall -fPIC -Isrc/main/c -I/usr/lib/jvm/java-17-openjdk-amd64/include -I/usr/lib/jvm/java-17-openjdk-amd64/include/linux -I/usr/local/include/python3.11 -c src/main/c/jni/org_jpy_PyLib.c -o build/temp.linux-x86_64-cpython-311/src/main/c/jni/org_jpy_PyLib.o
      src/main/c/jni/org_jpy_PyLib.c: In function ‘Java_org_jpy_PyLib_setPythonHome’:
      src/main/c/jni/org_jpy_PyLib.c:170:31: warning: passing argument 1 of ‘PyMem_RawFree’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
        170 |                 PyMem_RawFree(pythonHome);
            |                               ^~~~~~~~~~
      In file included from /usr/local/include/python3.11/pymem.h:96,
                       from /usr/local/include/python3.11/Python.h:41,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/cpython/pymem.h:8:38: note: expected ‘void *’ but argument is of type ‘const wchar_t *’ {aka ‘const int *’}
          8 | PyAPI_FUNC(void) PyMem_RawFree(void *ptr);
            |                                ~~~~~~^~~
      src/main/c/jni/org_jpy_PyLib.c:184:13: warning: ‘Py_SetPythonHome’ is deprecated [-Wdeprecated-declarations]
        184 |             Py_SetPythonHome(staticPythonHome);
            |             ^~~~~~~~~~~~~~~~
      In file included from /usr/local/include/python3.11/Python.h:94,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/pylifecycle.h:40:38: note: declared here
         40 | Py_DEPRECATED(3.11) PyAPI_FUNC(void) Py_SetPythonHome(const wchar_t *);
            |                                      ^~~~~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:187:27: warning: passing argument 1 of ‘PyMem_RawFree’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
        187 |             PyMem_RawFree(pythonHome);
            |                           ^~~~~~~~~~
      In file included from /usr/local/include/python3.11/pymem.h:96,
                       from /usr/local/include/python3.11/Python.h:41,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/cpython/pymem.h:8:38: note: expected ‘void *’ but argument is of type ‘const wchar_t *’ {aka ‘const int *’}
          8 | PyAPI_FUNC(void) PyMem_RawFree(void *ptr);
            |                                ~~~~~~^~~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘Java_org_jpy_PyLib_setProgramName’:
      src/main/c/jni/org_jpy_PyLib.c:237:31: warning: passing argument 1 of ‘PyMem_RawFree’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
        237 |                 PyMem_RawFree(programName);
            |                               ^~~~~~~~~~~
      In file included from /usr/local/include/python3.11/pymem.h:96,
                       from /usr/local/include/python3.11/Python.h:41,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/cpython/pymem.h:8:38: note: expected ‘void *’ but argument is of type ‘const wchar_t *’ {aka ‘const int *’}
          8 | PyAPI_FUNC(void) PyMem_RawFree(void *ptr);
            |                                ~~~~~~^~~
      src/main/c/jni/org_jpy_PyLib.c:251:13: warning: ‘Py_SetProgramName’ is deprecated [-Wdeprecated-declarations]
        251 |             Py_SetProgramName(staticProgramName);
            |             ^~~~~~~~~~~~~~~~~
      In file included from /usr/local/include/python3.11/Python.h:94,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/pylifecycle.h:37:38: note: declared here
         37 | Py_DEPRECATED(3.11) PyAPI_FUNC(void) Py_SetProgramName(const wchar_t *);
            |                                      ^~~~~~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:254:27: warning: passing argument 1 of ‘PyMem_RawFree’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
        254 |             PyMem_RawFree(programName);
            |                           ^~~~~~~~~~~
      In file included from /usr/local/include/python3.11/pymem.h:96,
                       from /usr/local/include/python3.11/Python.h:41,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/cpython/pymem.h:8:38: note: expected ‘void *’ but argument is of type ‘const wchar_t *’ {aka ‘const int *’}
          8 | PyAPI_FUNC(void) PyMem_RawFree(void *ptr);
            |                                ~~~~~~^~~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘Java_org_jpy_PyLib_startPython0’:
      src/main/c/jni/org_jpy_PyLib.c:280:9: warning: ‘PySys_SetArgvEx’ is deprecated [-Wdeprecated-declarations]
        280 |         PySys_SetArgvEx(0, NULL, 0);
            |         ^~~~~~~~~~~~~~~
      In file included from /usr/local/include/python3.11/Python.h:96,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/sysmodule.h:14:38: note: declared here
         14 | Py_DEPRECATED(3.11) PyAPI_FUNC(void) PySys_SetArgvEx(int, wchar_t **, int);
            |                                      ^~~~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:284:9: warning: ‘PyEval_InitThreads’ is deprecated [-Wdeprecated-declarations]
        284 |         PyEval_InitThreads();
            |         ^~~~~~~~~~~~~~~~~~
      In file included from /usr/local/include/python3.11/Python.h:95,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/ceval.h:132:37: note: declared here
        132 | Py_DEPRECATED(3.9) PyAPI_FUNC(void) PyEval_InitThreads(void);
            |                                     ^~~~~~~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘Java_org_jpy_PyLib_executeCode’:
      src/main/c/jni/org_jpy_PyLib.c:1024:16: warning: returning ‘void *’ from a function with return type ‘jlong’ {aka ‘long int’} makes integer from pointer without a cast [-Wint-conversion]
       1024 |         return NULL;
            |                ^~~~
      src/main/c/jni/org_jpy_PyLib.c:1029:101: warning: passing argument 7 of ‘executeInternal’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
       1029 |     result = executeInternal(jenv, jLibClass, jStart, jGlobals, jLocals, (DoRun)pyRunStringWrapper, codeChars);
            |                                                                                                     ^~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:890:128: note: expected ‘void *’ but argument is of type ‘const char *’
        890 | jlong executeInternal(JNIEnv* jenv, jclass jLibClass, jint jStart, jobject jGlobals, jobject jLocals, DoRun runFunction, void *runArg) {
            |                                                                                                                          ~~~~~~^~~~~~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘Java_org_jpy_PyLib_getType’:
      src/main/c/jni/org_jpy_PyLib.c:1364:14: warning: assignment to ‘PyObject *’ {aka ‘struct _object *’} from incompatible pointer type ‘PyTypeObject *’ {aka ‘struct _typeobject *’} [-Wincompatible-pointer-types]
       1364 |     pyObject = ((PyObject*) objId)->ob_type;
            |              ^
      src/main/c/jni/org_jpy_PyLib.c: In function ‘PyLib_CallAndReturnObject’:
      src/main/c/jni/org_jpy_PyLib.c:2350:68: warning: passing argument 4 of ‘PyLib_FromJObjectForTuple’ discards ‘const’ qualifier from pointer target type [-Wdiscarded-qualifiers]
       2350 |         pyArg = PyLib_FromJObjectForTuple(jenv, jArg, jParamClass, nameChars, i);
            |                                                                    ^~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2270:91: note: expected ‘char *’ but argument is of type ‘const char *’
       2270 | PyObject* PyLib_FromJObjectForTuple(JNIEnv *jenv, jobject jArg, jclass jParamClass, char* nameChars, jint index) {
            |                                                                                     ~~~~~~^~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2319:16: warning: unused variable ‘jArgParamType’ [-Wunused-variable]
       2319 |     JPy_JType* jArgParamType;
            |                ^~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2318:16: warning: unused variable ‘explicitParamType’ [-Wunused-variable]
       2318 |     JPy_JType* explicitParamType = NULL;
            |                ^~~~~~~~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘PyLib_HandlePythonException’:
      src/main/c/jni/org_jpy_PyLib.c:2466:36: warning: passing argument 3 of ‘PyErr_Fetch’ from incompatible pointer type [-Wincompatible-pointer-types]
       2466 |     PyErr_Fetch(&pyType, &pyValue, &pyTraceback);
            |                                    ^~~~~~~~~~~~
            |                                    |
            |                                    PyTracebackObject ** {aka struct _traceback **}
      In file included from /usr/local/include/python3.11/Python.h:88,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/pyerrors.h:19:56: note: expected ‘PyObject **’ {aka ‘struct _object **’} but argument is of type ‘PyTracebackObject **’ {aka ‘struct _traceback **’}
         19 | PyAPI_FUNC(void) PyErr_Fetch(PyObject **, PyObject **, PyObject **);
            |                                                        ^~~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2469:49: warning: passing argument 3 of ‘PyErr_NormalizeException’ from incompatible pointer type [-Wincompatible-pointer-types]
       2469 |     PyErr_NormalizeException(&pyType, &pyValue, &pyTraceback);
            |                                                 ^~~~~~~~~~~~
            |                                                 |
            |                                                 PyTracebackObject ** {aka struct _traceback **}
      In file included from /usr/local/include/python3.11/Python.h:88,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/pyerrors.h:40:67: note: expected ‘PyObject **’ {aka ‘struct _object **’} but argument is of type ‘PyTracebackObject **’ {aka ‘struct _traceback **’}
         40 | PyAPI_FUNC(void) PyErr_NormalizeException(PyObject**, PyObject**, PyObject**);
            |                                                                   ^~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2490:63: warning: passing argument 1 of ‘PyObject_GetAttrString’ from incompatible pointer type [-Wincompatible-pointer-types]
       2490 |         linenoChars = PyLib_ObjToChars(PyObject_GetAttrString(pyTraceback, "tb_lineno"), &pyLinenoUtf8);
            |                                                               ^~~~~~~~~~~
            |                                                               |
            |                                                               PyTracebackObject * {aka struct _traceback *}
      In file included from /usr/local/include/python3.11/Python.h:44,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/object.h:289:47: note: expected ‘PyObject *’ {aka ‘struct _object *’} but argument is of type ‘PyTracebackObject *’ {aka ‘struct _traceback *’}
        289 | PyAPI_FUNC(PyObject *) PyObject_GetAttrString(PyObject *, const char *);
            |                                               ^~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2491:42: warning: passing argument 1 of ‘PyObject_GetAttrString’ from incompatible pointer type [-Wincompatible-pointer-types]
       2491 |         pyFrame = PyObject_GetAttrString(pyTraceback, "tb_frame");
            |                                          ^~~~~~~~~~~
            |                                          |
            |                                          PyTracebackObject * {aka struct _traceback *}
      In file included from /usr/local/include/python3.11/Python.h:44,
                       from src/main/c/jni/org_jpy_PyLib.c:21:
      /usr/local/include/python3.11/object.h:289:47: note: expected ‘PyObject *’ {aka ‘struct _object *’} but argument is of type ‘PyTracebackObject *’ {aka ‘struct _traceback *’}
        289 | PyAPI_FUNC(PyObject *) PyObject_GetAttrString(PyObject *, const char *);
            |                                               ^~~~~~~~~~
      src/main/c/jni/org_jpy_PyLib.c:2530:47: warning: passing argument 1 of ‘python_traceback_report’ from incompatible pointer type [-Wincompatible-pointer-types]
       2530 |             int err = python_traceback_report(pyTraceback, &javaMessage, &bufLen);
            |                                               ^~~~~~~~~~~
            |                                               |
            |                                               PyTracebackObject * {aka struct _traceback *}
      src/main/c/jni/org_jpy_PyLib.c:48:46: note: expected ‘PyObject *’ {aka ‘struct _object *’} but argument is of type ‘PyTracebackObject *’ {aka ‘struct _traceback *’}
         48 | static int python_traceback_report(PyObject *tb, char **buf, int* bufLen);
            |                                    ~~~~~~~~~~^~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘append_to_java_message’:
      src/main/c/jni/org_jpy_PyLib.c:2702:35: warning: comparison of integer expressions of different signedness: ‘size_t’ {aka ‘long unsigned int’} and ‘int’ [-Wsign-compare]
       2702 |     if (strlen(*buf) + msgLen + 1 >= *bufLen) {
            |                                   ^~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘format_python_traceback’:
      src/main/c/jni/org_jpy_PyLib.c:2743:25: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2743 |             tb->tb_frame->f_code->co_filename != last_file ||
            |                         ^~
      src/main/c/jni/org_jpy_PyLib.c:2745:46: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2745 |             last_name == NULL || tb->tb_frame->f_code->co_name != last_name) {
            |                                              ^~
      src/main/c/jni/org_jpy_PyLib.c:2752:37: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2752 |             last_file = tb->tb_frame->f_code->co_filename;
            |                                     ^~
      src/main/c/jni/org_jpy_PyLib.c:2754:37: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2754 |             last_name = tb->tb_frame->f_code->co_name;
            |                                     ^~
      src/main/c/jni/org_jpy_PyLib.c:2760:46: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2760 |                                  tb->tb_frame->f_code->co_filename,
            |                                              ^~
      src/main/c/jni/org_jpy_PyLib.c:2762:46: error: invalid use of incomplete typedef ‘PyFrameObject’ {aka ‘struct _frame’}
       2762 |                                  tb->tb_frame->f_code->co_name);
            |                                              ^~
      src/main/c/jni/org_jpy_PyLib.c: In function ‘python_traceback_report’:
      src/main/c/jni/org_jpy_PyLib.c:2781:36: warning: passing argument 1 of ‘format_python_traceback’ from incompatible pointer type [-Wincompatible-pointer-types]
       2781 |     return format_python_traceback(tb, buf, bufLen);
            |                                    ^~
            |                                    |
            |                                    PyObject * {aka struct _object *}
      src/main/c/jni/org_jpy_PyLib.c:2721:55: note: expected ‘PyTracebackObject *’ {aka ‘struct _traceback *’} but argument is of type ‘PyObject *’ {aka ‘struct _object *’}
       2721 | static int format_python_traceback(PyTracebackObject *tb, char **buf, int *bufLen)
            |                                    ~~~~~~~~~~~~~~~~~~~^~
      error: command '/usr/bin/gcc' failed with exit code 1
      [end of output]
  
  note: This error originates from a subprocess, and is likely not a problem with pip.
error: legacy-install-failure

× Encountered error while trying to install package.
╰─> jpy

# Plaintext YAML file
$ cat secrets_file.enc
webhook_token: SuperSecretToken

# Encrypt the file with ansible-vault
$ ansible-vault encrypt secrets_file.enc
New Vault password:
Confirm New Vault password:
Encryption successful

# Rulebook
$ cat secrets-rulebook.yaml
- name: secrets example
  hosts: all
  sources:
    - ansible.eda.webhook:
        token: "{{ webhook_token }}"

$ ansible-rulebook --rulebook secrets-example.yml -i inventory.yml -e @secrets_file.enc

ansible-rulebook --rulebook rulebook.yml -i inventory/aws_ec2.yml --verbose

---
- name: Listen for events on a webhook
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
  rules:
    - name: Prepare build server
      condition: event.payload.message == "Prep Build Server"
      action:
        run_playbook:
          name: tasks/build_server.yml

- hosts: build_server
  vars:
    ansible_connection: aws_ssm
    ansible_aws_ssm_bucket_name: ansible-eda-demo
    ansible_aws_ssm_region: us-east-1
  tasks:
  - name: Install all packages for bender
    dnf:
      name:
      - python3-pip
      - buildah
      - podman
      - ansible
      - docker
  - name: Start dockerd
    systemd:
      name: docker
      state: started
  - name: install bender
    pip:
      name:
      - ansible-bender

plugin: aws_ec2
regions:
  - us-east-1
filters:
  instance-state-name: running
compose:
  ansible_host: instance_id
keyed_groups:
  - key: tags.Name
    separator: ''

__version__ = '0.9.4'
ad5944ee-3782-48d6-8dae-1e924d00197f

- name: example webhook
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: localhost
        port: 5000

  rules:
    - name: trigger when meta is defined
      condition: event.meta is defined
      action:
        debug:

ansible-rulebook --rulebook example.yml -i hosts.yml --verbose

> curl -d "{\"data\": \"example\"}" http://localhost:5000/someurl 
webhook

INFO:aiohttp.access:127.0.0.1 [21/Nov/2022:17:39:41 +0000] "POST /someurl HTTP/1.1" 200 158 "-" "curl/7.79.1"
INFO:ansible_rulebook.rule_generator:calling trigger when meta is defined
INFO:ansible_rulebook.engine:call_action debug
INFO:ansible_rulebook.engine:substitute_variables [{}] [{'event': {'payload': {'data': 'example'}, 'meta': {'headers': {'Content_Type': 'application/x-www-form-urlencoded', 'Content_Length': '19', 'Accept': '*/*', 'Host': 'localhost:43005', 'User_Agent': 'curl/7.79.1'}, 'endpoint': 'someurl'}}, 'fact': {'payload': {'data': 'example'}, 'meta': {'headers': {'Content_Type': 'application/x-www-form-urlencoded', 'Content_Length': '19', 'Accept': '*/*', 'Host': 'localhost:5000', 'User_Agent': 'curl/7.79.1'}, 'endpoint': 'someurl'}}}]
INFO:ansible_rulebook.engine:action args: {}
============================================================================================================================================================================================================

> curl -d "{\"data\": \"example\"}" http://localhost:5000/       
404: Not Found

INFO:aiohttp.access:127.0.0.1 [21/Nov/2022:17:41:03 +0000] "POST / HTTP/1.1" 404 173 "-" "curl/7.79.1"

apt-get --assume-yes install openjdk-17-jdk python3-pip
export JAVA_HOME=/usr/lib/jvm/java-17-openjdk-amd64
export PATH=$PATH:~/.local/bin
pip3 install ansible ansible-rulebook ansible-runner

Traceback (most recent call last):
  File "/home/charlespick/.local/bin/ansible-rulebook", line 5, in <module>
    from ansible_rulebook.cli import main
  File "/home/charlespick/.local/lib/python3.10/site-packages/ansible_rulebook/cli.py", line 35, in <module>
    from ansible_rulebook import app  # noqa: E402
  File "/home/charlespick/.local/lib/python3.10/site-packages/ansible_rulebook/app.py", line 32, in <module>
    from ansible_rulebook.engine import run_rulesets, start_source
  File "/home/charlespick/.local/lib/python3.10/site-packages/ansible_rulebook/engine.py", line 25, in <module>
    from watchdog.events import FileSystemEventHandler
ModuleNotFoundError: No module named 'watchdog'

ERROR:root:Error calling run_playbook: ansible_events.builtin.run_playbook() got multiple values for keyword argument 'facts'

Create a playbook with the following contents
---
- name: Demo rules multiple conditions reference assignment
  hosts: localhost
  sources:
    - benthomasson.eda.range:
        limit: 5
  rules:
    - name: multiple conditions
      condition:
        all:
          - event.i == 0
          - event.i == 1
      action:
        run_playbook:
          name: hello_playbook.yml
          post_events: true
          events: 12345
          facts: 789
          hello: "world"

2023-05-18 17:03:06,051 - ansible_rulebook.engine - INFO - ruleset define: {"name": "Example", "hosts": ["all"], "sources": [{"EventSource": {"name": "ansible.eda.webhook", "source_name": "ansible.eda.webhook", "source_args": {"host": "0.0.0.0", "port": 5000}, "source_filters": []}}], "rules": [{"Rule": {"name": "Get device info if BGP neighbor down", "condition": {"AllCondition": [{"EqualsExpression": {"lhs": {"Event": "payload.message"}, "rhs": {"String": "BGP neighbor down"}}}]}, "actions": [{"Action": {"action": "run_job_template", "action_args": {"name": "Parsers", "job_args": {"limit": "{{ event.payload.meta.hosts }}"}, "organization": "MackNet"}}}], "enabled": true}}]}

2023-05-18 17:03:06,070 - ansible_rulebook.engine - INFO - load source

2023-05-18 17:03:07,047 - ansible_rulebook.engine - INFO - load source filters

2023-05-18 17:03:07,047 - ansible_rulebook.engine - INFO - loading eda.builtin.insert_meta_info

2023-05-18 17:03:08,189 - ansible_rulebook.engine - INFO - Calling main in ansible.eda.webhook

2023-05-18 17:03:08,194 - ansible_rulebook.websocket - INFO - websocket wss://host.containers.internal/api/eda/ws/ansible-rulebook connecting

2023-05-18 17:03:08,202 - ansible_rulebook.engine - INFO - Waiting for all ruleset tasks to end

2023-05-18 17:03:08 204 [drools-async-evaluator-thread] INFO org.drools.ansible.rulebook.integration.api.io.RuleExecutorChannel - Async channel connected

2023-05-18 17:03:08,249 - ansible_rulebook.rule_set_runner - INFO - Waiting for actions on events from Example

2023-05-18 17:03:08,249 - ansible_rulebook.rule_set_runner - INFO - Waiting for events, ruleset: Example

2023-05-18 17:03:08,285 - ansible_rulebook.websocket - INFO - websocket wss://host.containers.internal/api/eda/ws/ansible-rulebook connected

2023-05-18 17:03:42,874 - aiohttp.access - INFO - 10.0.2.100 [18/May/2023:17:03:42 +0000] "POST /endpoint HTTP/1.1" 200 158 "-" "curl/7.87.0"

2023-05-18 17:03:43 011 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.RegisterOnlyAgendaFilter - Activation of effective rule "Get device info if BGP neighbor down" with facts: {m={payload={meta={hosts=leaf3}, message=BGP neighbor down}, meta={headers={Accept=*/*, User-Agent=curl/7.87.0, Host=192.168.6.109:5000, Content-Length=59, Content-Type=application/json}, endpoint=endpoint, received_at=2023-05-18T17:03:42.870982Z, source={name=ansible.eda.webhook, type=ansible.eda.webhook}, uuid=a1cf2a8c-2af9-45e6-99c6-eb5e4560b059}}}

2023-05-18 17:03:43,034 - ansible_rulebook.rule_generator - INFO - calling Get device info if BGP neighbor down

2023-05-18 17:03:43,036 - ansible_rulebook.rule_set_runner - INFO - call_action run_job_template

2023-05-18 17:03:43,038 - ansible_rulebook.rule_set_runner - INFO - substitute_variables [{'name': 'Parsers', 'job_args': {'limit': '{{ event.payload.meta.hosts }}'}, 'organization': 'MackNet'}] [{'event': {'payload': {'meta': {'hosts': 'leaf3'}, 'message': 'BGP neighbor down'}, 'meta': {'headers': {'Accept': '*/*', 'User-Agent': 'curl/7.87.0', 'Host': '192.168.6.109:5000', 'Content-Length': '59', 'Content-Type': 'application/json'}, 'endpoint': 'endpoint', 'received_at': '2023-05-18T17:03:42.870982Z', 'source': {'name': 'ansible.eda.webhook', 'type': 'ansible.eda.webhook'}, 'uuid': 'a1cf2a8c-2af9-45e6-99c6-eb5e4560b059'}}}]

2023-05-18 17:03:43,054 - ansible_rulebook.rule_set_runner - INFO - action args: {'name': 'Parsers', 'job_args': {'limit': 'leaf3'}, 'organization': 'MackNet'}

2023-05-18 17:03:43,054 - ansible_rulebook.builtin - INFO - running job template: Parsers, organization: MackNet

2023-05-18 17:03:43,055 - ansible_rulebook.builtin - INFO - ruleset: Example, rule Get device info if BGP neighbor down

[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# ansible-rulebook --version
__version__ = '0.13.0'
  Executable location = /usr/local/bin/ansible-rulebook
  Drools_jpy version = 0.3.1
  Java home = /usr/lib/jvm/java-17-openjdk-17.0.7.0.7-1.el8_7.x86_64
  Java version = 17.0.7
  Python version = 3.9.13 (main, Nov  9 2022, 13:16:24) [GCC 8.5.0 20210514 (Red Hat 8.5.0-15)]

[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# cat /etc/redhat-release 
Red Hat Enterprise Linux release 8.7 (Ootpa)
[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# 

[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# ansible-rulebook --rulebook rulebooks/webhook-block-ips.yaml --inventory ../inventory/inventory_2.yml --print-events --verbose 

[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# cat ../inventory/inventory_2.yml 
[all:vars]
lab_version="udf"
#ansible_python_interpreter=/usr/bin/python3

[lb]
f5 ansible_host=10.1.1.4 ansible_user=admin ansible_password=supersecretpassword server_port=443

[local_system]
ansible-local ansible_host=10.1.1.11 ansible_user=root  

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "meta": {
            "endpoint": "endpoint",
            "headers": {
                "Accept-Charset": "UTF-8",
                "Accept-Encoding": "gzip,deflate",
                "Connection": "Keep-Alive",
                "Content-Length": "376",
                "Content-Type": "application/json; charset=UTF-8",
                "Host": "10.1.1.11:5000",
                "User-Agent": "Apache-HttpClient/4.5.10 (Java/16.0.2)"
            },
            "received_at": "2023-05-17T19:45:02.128666Z",
            "source": {
                "name": "ansible.eda.webhook",
                "type": "ansible.eda.webhook"
            },
            "uuid": "ddf1b125-1e9b-45d0-bd71-c5a3f338bd57"
        },
        "payload": {
            "message": "Ansible Please Block Some IPs",
            "payload": "61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, "
        }
    }
}

[root@8cb336c8-8dc8-4fee-b9f1-fdaa7ec4cc61 f5-bd-ansible-security-labs]# ansible-rulebook --rulebook rulebooks/webhook-block-ips.yaml --inventory ../inventory/inventory_2.yml --print-events --verbose
2023-05-17 15:39:40,415 - ansible_rulebook.app - INFO - Starting sources
2023-05-17 15:39:40,415 - ansible_rulebook.app - INFO - Starting rules
2023-05-17 15:39:40,415 - ansible_rulebook.engine - INFO - run_ruleset
2023-05-17 15:39:40,415 - drools.ruleset - INFO - Using jar: /usr/local/lib/python3.9/site-packages/drools/jars/drools-ansible-rulebook-integration-runtime-1.0.1-SNAPSHOT.jar
2023-05-17 15:39:41 137 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.AbstractRulesEvaluator - Start automatic pseudo clock with a tick every 100 milliseconds
2023-05-17 15:39:41,141 - ansible_rulebook.engine - INFO - ruleset define: {"name": "Listen for events on a webhook", "hosts": ["all"], "sources": [{"EventSource": {"name": "ansible.eda.webhook", "source_name": "ansible.eda.webhook", "source_args": {"host": "0.0.0.0", "port": 5000}, "source_filters": []}}], "rules": [{"Rule": {"name": "Say Hello", "condition": {"AllCondition": [{"EqualsExpression": {"lhs": {"Event": "payload.message"}, "rhs": {"String": "Ansible Please Block Some IPs"}}}]}, "actions": [{"Action": {"action": "run_playbook", "action_args": {"name": "f5-playbooks/block-ips-playbook/block-ips.yaml", "var_root": "payload", "post_events": true}}}], "enabled": true}}]}
2023-05-17 15:39:41,161 - ansible_rulebook.engine - INFO - load source
2023-05-17 15:39:41,741 - ansible_rulebook.engine - INFO - load source filters
2023-05-17 15:39:41,741 - ansible_rulebook.engine - INFO - loading eda.builtin.insert_meta_info
2023-05-17 15:39:42,304 - ansible_rulebook.engine - INFO - Calling main in ansible.eda.webhook
2023-05-17 15:39:42,307 - ansible_rulebook.engine - INFO - Waiting for all ruleset tasks to end
2023-05-17 15:39:42,307 - ansible_rulebook.rule_set_runner - INFO - Waiting for actions on events from Listen for events on a webhook
2023-05-17 15:39:42,307 - ansible_rulebook.rule_set_runner - INFO - Waiting for events, ruleset: Listen for events on a webhook
2023-05-17 15:39:42 307 [drools-async-evaluator-thread] INFO org.drools.ansible.rulebook.integration.api.io.RuleExecutorChannel - Async channel connected



2023-05-17 15:42:02,324 - aiohttp.access - INFO - 10.1.1.5 [17/May/2023:19:42:02 +0000] "POST /endpoint HTTP/1.1" 200 158 "-" "Apache-HttpClient/4.5.10 (Java/16.0.2)"
{   'meta': {   'endpoint': 'endpoint',
                'headers': {   'Accept-Charset': 'UTF-8',
                               'Accept-Encoding': 'gzip,deflate',
                               'Connection': 'Keep-Alive',
                               'Content-Length': '373',
                               'Content-Type': 'application/json; '
                                               'charset=UTF-8',
                               'Host': '10.1.1.11:5000',
                               'User-Agent': 'Apache-HttpClient/4.5.10 '
                                             '(Java/16.0.2)'},
                'received_at': '2023-05-17T19:42:02.323578Z',
                'source': {   'name': 'ansible.eda.webhook',
                              'type': 'ansible.eda.webhook'},
                'uuid': 'f7fba787-1b15-42c6-a64e-97b1f5673c45'},
    'payload': {   'message': 'Ansible Please Block Some IPs',
                   'payload': '114.225.248.7, 122.159.243.78, 49.66.141.203, '
                              '47.98.58.62, 139.203.90.78, 43.251.247.220, '
                              '113.97.123.155, 115.170.100.80, 106.27.28.238, '
                              '49.69.74.215, 125.86.131.83, 123.160.232.22, '
                              '120.76.45.146, 112.194.39.209, 122.236.26.112, '
                              '42.187.79.104, 60.2.184.96, 60.191.138.128, '
                              '124.65.127.96, 91.191.249.134, '}}
2023-05-17 15:42:02 360 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.RegisterOnlyAgendaFilter - Activation of effective rule "Say Hello" with facts: {m={payload={payload=114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, , message=Ansible Please Block Some IPs}, meta={headers={Accept-Charset=UTF-8, Connection=Keep-Alive, User-Agent=Apache-HttpClient/4.5.10 (Java/16.0.2), Host=10.1.1.11:5000, Accept-Encoding=gzip,deflate, Content-Length=373, Content-Type=application/json; charset=UTF-8}, endpoint=endpoint, received_at=2023-05-17T19:42:02.323578Z, source={name=ansible.eda.webhook, type=ansible.eda.webhook}, uuid=f7fba787-1b15-42c6-a64e-97b1f5673c45}}}
2023-05-17 15:42:02,368 - ansible_rulebook.rule_generator - INFO - calling Say Hello
2023-05-17 15:42:02,369 - ansible_rulebook.rule_set_runner - INFO - call_action run_playbook
2023-05-17 15:42:02,369 - ansible_rulebook.rule_set_runner - INFO - Update variables [{'event': {'payload': {'payload': '114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, ', 'message': 'Ansible Please Block Some IPs'}, 'meta': {'headers': {'Accept-Charset': 'UTF-8', 'Connection': 'Keep-Alive', 'User-Agent': 'Apache-HttpClient/4.5.10 (Java/16.0.2)', 'Host': '10.1.1.11:5000', 'Accept-Encoding': 'gzip,deflate', 'Content-Length': '373', 'Content-Type': 'application/json; charset=UTF-8'}, 'endpoint': 'endpoint', 'received_at': '2023-05-17T19:42:02.323578Z', 'source': {'name': 'ansible.eda.webhook', 'type': 'ansible.eda.webhook'}, 'uuid': 'f7fba787-1b15-42c6-a64e-97b1f5673c45'}}}] with new root [payload]
2023-05-17 15:42:02,369 - ansible_rulebook.rule_set_runner - INFO - substitute_variables [{'name': 'f5-playbooks/block-ips-playbook/block-ips.yaml', 'post_events': True}] [{'event': {'payload': '114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, ', 'message': 'Ansible Please Block Some IPs'}}]
2023-05-17 15:42:02,369 - ansible_rulebook.rule_set_runner - INFO - action args: {'name': 'f5-playbooks/block-ips-playbook/block-ips.yaml', 'post_events': True}
2023-05-17 15:42:02,370 - ansible_rulebook.builtin - INFO - running Ansible playbook: f5-playbooks/block-ips-playbook/block-ips.yaml
2023-05-17 15:42:02,372 - ansible_rulebook.builtin - INFO - ruleset: Listen for events on a webhook, rule: Say Hello
2023-05-17 15:42:02,372 - ansible_rulebook.builtin - INFO - Calling Ansible runner

PLAY [ASM Policy Update with Blocked URLS, IPs or Both] ************************

TASK [Setup provider] **********************************************************
ok: [f5]

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "message": "Ansible Please Block Some IPs",
        "payload": "114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, "
    }
}

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": "114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, "
}

TASK [Create Array from BlockedIPs] ********************************************
ok: [f5]

TASK [Create Array from BlockedIPs] ********************************************
ok: [f5]

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": [
        "114.225.248.7",
        "122.159.243.78",
        "49.66.141.203",
        "47.98.58.62",
        "139.203.90.78",
        "43.251.247.220",
        "113.97.123.155",
        "115.170.100.80",
        "106.27.28.238",
        "49.69.74.215",
        "125.86.131.83",
        "123.160.232.22",
        "120.76.45.146",
        "112.194.39.209",
        "122.236.26.112",
        "42.187.79.104",
        "60.2.184.96",
        "60.191.138.128",
        "124.65.127.96",
        "91.191.249.134"
    ]
}

TASK [Fetching ASM Policy] *****************************************************
changed: [f5]

TASK [Create tmp directory if it does not exist] *******************************
ok: [f5 -> localhost]

TASK [ansible.builtin.copy] ****************************************************
changed: [f5 -> localhost]

TASK [Validate Existing IP Addresses] ******************************************
failed: [f5 -> localhost] (item=114.225.248.7) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>114.225.248.7\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006000", "end": "2023-05-17 15:42:15.423592", "item": "114.225.248.7", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:15.417592", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=122.159.243.78) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>122.159.243.78\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006376", "end": "2023-05-17 15:42:15.675942", "item": "122.159.243.78", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:15.669566", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=49.66.141.203) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>49.66.141.203\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006154", "end": "2023-05-17 15:42:15.903503", "item": "49.66.141.203", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:15.897349", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=47.98.58.62) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>47.98.58.62\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005651", "end": "2023-05-17 15:42:16.133725", "item": "47.98.58.62", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:16.128074", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=139.203.90.78) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>139.203.90.78\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005888", "end": "2023-05-17 15:42:16.361906", "item": "139.203.90.78", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:16.356018", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=43.251.247.220) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>43.251.247.220\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005859", "end": "2023-05-17 15:42:16.616423", "item": "43.251.247.220", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:16.610564", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=113.97.123.155) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>113.97.123.155\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005949", "end": "2023-05-17 15:42:16.846424", "item": "113.97.123.155", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:16.840475", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=115.170.100.80) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>115.170.100.80\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005615", "end": "2023-05-17 15:42:17.074025", "item": "115.170.100.80", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:17.068410", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=106.27.28.238) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>106.27.28.238\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006197", "end": "2023-05-17 15:42:17.308347", "item": "106.27.28.238", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:17.302150", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=49.69.74.215) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>49.69.74.215\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005887", "end": "2023-05-17 15:42:17.540660", "item": "49.69.74.215", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:17.534773", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=125.86.131.83) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>125.86.131.83\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005887", "end": "2023-05-17 15:42:17.772369", "item": "125.86.131.83", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:17.766482", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=123.160.232.22) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>123.160.232.22\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005604", "end": "2023-05-17 15:42:18.002185", "item": "123.160.232.22", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:17.996581", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=120.76.45.146) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>120.76.45.146\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006546", "end": "2023-05-17 15:42:18.235037", "item": "120.76.45.146", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:18.228491", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=112.194.39.209) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>112.194.39.209\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006281", "end": "2023-05-17 15:42:18.468348", "item": "112.194.39.209", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:18.462067", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=122.236.26.112) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>122.236.26.112\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006514", "end": "2023-05-17 15:42:18.712462", "item": "122.236.26.112", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:18.705948", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=42.187.79.104) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>42.187.79.104\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005660", "end": "2023-05-17 15:42:18.952829", "item": "42.187.79.104", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:18.947169", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=60.2.184.96) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>60.2.184.96\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006056", "end": "2023-05-17 15:42:19.182045", "item": "60.2.184.96", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:19.175989", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=60.191.138.128) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>60.191.138.128\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.006157", "end": "2023-05-17 15:42:19.410286", "item": "60.191.138.128", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:19.404129", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=124.65.127.96) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>124.65.127.96\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005954", "end": "2023-05-17 15:42:19.649318", "item": "124.65.127.96", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:19.643364", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
failed: [f5 -> localhost] (item=91.191.249.134) => {"ansible_loop_var": "item", "changed": true, "cmd": "grep \"<ip_address>91.191.249.134\" /tmp/f5/WAF-POLICY.xml", "delta": "0:00:00.005733", "end": "2023-05-17 15:42:19.875205", "item": "91.191.249.134", "msg": "non-zero return code", "rc": 1, "start": "2023-05-17 15:42:19.869472", "stderr": "", "stderr_lines": [], "stdout": "", "stdout_lines": []}
...ignoring

TASK [Add Disallowed IPs] ******************************************************
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>114.225.248.7" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:15.417592', 'end': '2023-05-17 15:42:15.423592', 'delta': '0:00:00.006000', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>114.225.248.7" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '114.225.248.7', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>122.159.243.78" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:15.669566', 'end': '2023-05-17 15:42:15.675942', 'delta': '0:00:00.006376', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>122.159.243.78" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '122.159.243.78', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>49.66.141.203" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:15.897349', 'end': '2023-05-17 15:42:15.903503', 'delta': '0:00:00.006154', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>49.66.141.203" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '49.66.141.203', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>47.98.58.62" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:16.128074', 'end': '2023-05-17 15:42:16.133725', 'delta': '0:00:00.005651', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>47.98.58.62" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '47.98.58.62', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>139.203.90.78" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:16.356018', 'end': '2023-05-17 15:42:16.361906', 'delta': '0:00:00.005888', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>139.203.90.78" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '139.203.90.78', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>43.251.247.220" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:16.610564', 'end': '2023-05-17 15:42:16.616423', 'delta': '0:00:00.005859', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>43.251.247.220" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '43.251.247.220', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>113.97.123.155" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:16.840475', 'end': '2023-05-17 15:42:16.846424', 'delta': '0:00:00.005949', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>113.97.123.155" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '113.97.123.155', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>115.170.100.80" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:17.068410', 'end': '2023-05-17 15:42:17.074025', 'delta': '0:00:00.005615', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>115.170.100.80" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '115.170.100.80', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>106.27.28.238" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:17.302150', 'end': '2023-05-17 15:42:17.308347', 'delta': '0:00:00.006197', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>106.27.28.238" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '106.27.28.238', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>49.69.74.215" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:17.534773', 'end': '2023-05-17 15:42:17.540660', 'delta': '0:00:00.005887', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>49.69.74.215" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '49.69.74.215', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>125.86.131.83" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:17.766482', 'end': '2023-05-17 15:42:17.772369', 'delta': '0:00:00.005887', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>125.86.131.83" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '125.86.131.83', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>123.160.232.22" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:17.996581', 'end': '2023-05-17 15:42:18.002185', 'delta': '0:00:00.005604', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>123.160.232.22" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '123.160.232.22', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>120.76.45.146" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:18.228491', 'end': '2023-05-17 15:42:18.235037', 'delta': '0:00:00.006546', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>120.76.45.146" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '120.76.45.146', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>112.194.39.209" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:18.462067', 'end': '2023-05-17 15:42:18.468348', 'delta': '0:00:00.006281', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>112.194.39.209" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '112.194.39.209', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>122.236.26.112" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:18.705948', 'end': '2023-05-17 15:42:18.712462', 'delta': '0:00:00.006514', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>122.236.26.112" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '122.236.26.112', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>42.187.79.104" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:18.947169', 'end': '2023-05-17 15:42:18.952829', 'delta': '0:00:00.005660', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>42.187.79.104" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '42.187.79.104', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>60.2.184.96" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:19.175989', 'end': '2023-05-17 15:42:19.182045', 'delta': '0:00:00.006056', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>60.2.184.96" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '60.2.184.96', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>60.191.138.128" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:19.404129', 'end': '2023-05-17 15:42:19.410286', 'delta': '0:00:00.006157', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>60.191.138.128" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '60.191.138.128', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>124.65.127.96" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:19.643364', 'end': '2023-05-17 15:42:19.649318', 'delta': '0:00:00.005954', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>124.65.127.96" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '124.65.127.96', 'ansible_loop_var': 'item'})
changed: [f5 -> localhost] => (item={'changed': True, 'stdout': '', 'stderr': '', 'rc': 1, 'cmd': 'grep "<ip_address>91.191.249.134" /tmp/f5/WAF-POLICY.xml', 'start': '2023-05-17 15:42:19.869472', 'end': '2023-05-17 15:42:19.875205', 'delta': '0:00:00.005733', 'failed': True, 'msg': 'non-zero return code', 'invocation': {'module_args': {'_raw_params': 'grep "<ip_address>91.191.249.134" /tmp/f5/WAF-POLICY.xml', '_uses_shell': True, 'stdin_add_newline': True, 'strip_empty_ends': True, 'argv': None, 'chdir': None, 'executable': None, 'creates': None, 'removes': None, 'stdin': None}}, 'stdout_lines': [], 'stderr_lines': [], 'item': '91.191.249.134', 'ansible_loop_var': 'item'})

TASK [Create an LTM policy] ****************************************************
ok: [f5 -> localhost]

TASK [Import ASM policy] *******************************************************
changed: [f5 -> localhost]

TASK [Replace a forward action with an ASM action] *****************************
ok: [f5 -> localhost]

TASK [Deploy Draft ASM policy] *************************************************
ok: [f5 -> localhost]

TASK [Activate ASM Policy] *****************************************************
ok: [f5 -> localhost]

TASK [Publish ASM Policy via TMSH] *********************************************
[WARNING]: Using "write" commands is not idempotent. You should use a module
that is specifically made for that. If such a module does not exist, then
please file a bug. The command in question is "publish asm policy WAF-
POLICY..."
ok: [f5 -> localhost]

TASK [Change ASM Policy to Blocking] *******************************************
[WARNING]: Using "write" commands is not idempotent. You should use a module
that is specifically made for that. If such a module does not exist, then
please file a bug. The command in question is "modify asm policy WAF-POLICY
blocking-mo..."
changed: [f5]

PLAY RECAP *********************************************************************
f5                         : ok=18   changed=6    unreachable=0    failed=0    skipped=0    rescued=0    ignored=1   

  
2023-05-17 15:43:14,316 - ansible_rulebook.builtin - INFO - Ansible Runner Queue task cancelled
2023-05-17 15:43:14,317 - ansible_rulebook.builtin - INFO - Playbook rc: 0, status: successful
2023-05-17 15:43:14,320 - ansible_rulebook.rule_set_runner - INFO - Task action::run_playbook::Listen for events on a webhook::Say Hello finished, active actions 0
2023-05-17 15:45:02,129 - aiohttp.access - INFO - 10.1.1.5 [17/May/2023:19:45:02 +0000] "POST /endpoint HTTP/1.1" 200 158 "-" "Apache-HttpClient/4.5.10 (Java/16.0.2)"
{   'meta': {   'endpoint': 'endpoint',
                'headers': {   'Accept-Charset': 'UTF-8',
                               'Accept-Encoding': 'gzip,deflate',
                               'Connection': 'Keep-Alive',
                               'Content-Length': '376',
                               'Content-Type': 'application/json; '
                                               'charset=UTF-8',
                               'Host': '10.1.1.11:5000',
                               'User-Agent': 'Apache-HttpClient/4.5.10 '
                                             '(Java/16.0.2)'},
                'received_at': '2023-05-17T19:45:02.128666Z',
                'source': {   'name': 'ansible.eda.webhook',
                              'type': 'ansible.eda.webhook'},
                'uuid': 'ddf1b125-1e9b-45d0-bd71-c5a3f338bd57'},
    'payload': {   'message': 'Ansible Please Block Some IPs',
                   'payload': '61.159.83.27, 106.31.225.181, 124.113.69.146, '
                              '110.193.169.10, 36.105.233.171, 36.117.197.225, '
                              '113.91.81.178, 115.207.239.18, 110.252.60.154, '
                              '117.42.208.29, 121.227.208.31, 121.227.153.3, '
                              '46.250.37.60, 118.224.199.107, 118.89.240.8, '
                              '36.101.190.239, 80.250.71.98, 58.38.47.241, '
                              '122.76.41.113, 59.108.107.170, '}}
2023-05-17 15:45:02 132 [main] INFO org.drools.ansible.rulebook.integration.api.rulesengine.RegisterOnlyAgendaFilter - Activation of effective rule "Say Hello" with facts: {m={payload={payload=61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, , message=Ansible Please Block Some IPs}, meta={headers={Accept-Charset=UTF-8, Connection=Keep-Alive, User-Agent=Apache-HttpClient/4.5.10 (Java/16.0.2), Host=10.1.1.11:5000, Accept-Encoding=gzip,deflate, Content-Length=376, Content-Type=application/json; charset=UTF-8}, endpoint=endpoint, received_at=2023-05-17T19:45:02.128666Z, source={name=ansible.eda.webhook, type=ansible.eda.webhook}, uuid=ddf1b125-1e9b-45d0-bd71-c5a3f338bd57}}}
2023-05-17 15:45:02,133 - ansible_rulebook.rule_generator - INFO - calling Say Hello
2023-05-17 15:45:02,133 - ansible_rulebook.rule_set_runner - INFO - call_action run_playbook
2023-05-17 15:45:02,134 - ansible_rulebook.rule_set_runner - INFO - substitute_variables [{'name': 'f5-playbooks/block-ips-playbook/block-ips.yaml', 'post_events': True}] [{'event': {'payload': {'payload': '61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, ', 'message': 'Ansible Please Block Some IPs'}, 'meta': {'headers': {'Accept-Charset': 'UTF-8', 'Connection': 'Keep-Alive', 'User-Agent': 'Apache-HttpClient/4.5.10 (Java/16.0.2)', 'Host': '10.1.1.11:5000', 'Accept-Encoding': 'gzip,deflate', 'Content-Length': '376', 'Content-Type': 'application/json; charset=UTF-8'}, 'endpoint': 'endpoint', 'received_at': '2023-05-17T19:45:02.128666Z', 'source': {'name': 'ansible.eda.webhook', 'type': 'ansible.eda.webhook'}, 'uuid': 'ddf1b125-1e9b-45d0-bd71-c5a3f338bd57'}}}]
2023-05-17 15:45:02,134 - ansible_rulebook.rule_set_runner - INFO - action args: {'name': 'f5-playbooks/block-ips-playbook/block-ips.yaml', 'post_events': True}
2023-05-17 15:45:02,134 - ansible_rulebook.builtin - INFO - running Ansible playbook: f5-playbooks/block-ips-playbook/block-ips.yaml
2023-05-17 15:45:02,137 - ansible_rulebook.builtin - INFO - ruleset: Listen for events on a webhook, rule: Say Hello
2023-05-17 15:45:02,138 - ansible_rulebook.builtin - INFO - Calling Ansible runner

PLAY [ASM Policy Update with Blocked URLS, IPs or Both] ************************

TASK [Setup provider] **********************************************************
ok: [f5]

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "meta": {
            "endpoint": "endpoint",
            "headers": {
                "Accept-Charset": "UTF-8",
                "Accept-Encoding": "gzip,deflate",
                "Connection": "Keep-Alive",
                "Content-Length": "376",
                "Content-Type": "application/json; charset=UTF-8",
                "Host": "10.1.1.11:5000",
                "User-Agent": "Apache-HttpClient/4.5.10 (Java/16.0.2)"
            },
            "received_at": "2023-05-17T19:45:02.128666Z",
            "source": {
                "name": "ansible.eda.webhook",
                "type": "ansible.eda.webhook"
            },
            "uuid": "ddf1b125-1e9b-45d0-bd71-c5a3f338bd57"
        },
        "payload": {
            "message": "Ansible Please Block Some IPs",
            "payload": "61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, "
        }
    }
}

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "message": "Ansible Please Block Some IPs",
        "payload": "61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, "
    }
}

TASK [Create Array from BlockedIPs] ********************************************
fatal: [f5]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: 'dict object' has no attribute 'split'. 'dict object' has no attribute 'split'\n\nThe error appears to be in '/tmp/run_playbookcbp6leub/project/block-ips.yaml': line 32, column 5, but may\nbe elsewhere in the file depending on the exact syntax problem.\n\nThe offending line appears to be:\n\n\n  - name: Create Array from BlockedIPs\n    ^ here\n"}

PLAY RECAP *********************************************************************
f5                         : ok=3    changed=0    unreachable=0    failed=1    skipped=0    rescued=0    ignored=0   
2023-05-17 15:45:03,245 - ansible_rulebook.builtin - INFO - Ansible Runner Queue task cancelled
2023-05-17 15:45:03,246 - ansible_rulebook.builtin - INFO - Playbook rc: 2, status: failed
2023-05-17 15:45:03,247 - ansible_rulebook.builtin - ERROR - 
PLAY [ASM Policy Update with Blocked URLS, IPs or Both] ************************

TASK [Setup provider] **********************************************************
ok: [f5]

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "meta": {
            "endpoint": "endpoint",
            "headers": {
                "Accept-Charset": "UTF-8",
                "Accept-Encoding": "gzip,deflate",
                "Connection": "Keep-Alive",
                "Content-Length": "376",
                "Content-Type": "application/json; charset=UTF-8",
                "Host": "10.1.1.11:5000",
                "User-Agent": "Apache-HttpClient/4.5.10 (Java/16.0.2)"
            },
            "received_at": "2023-05-17T19:45:02.128666Z",
            "source": {
                "name": "ansible.eda.webhook",
                "type": "ansible.eda.webhook"
            },
            "uuid": "ddf1b125-1e9b-45d0-bd71-c5a3f338bd57"
        },
        "payload": {
            "message": "Ansible Please Block Some IPs",
            "payload": "61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, "
        }
    }
}

TASK [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "message": "Ansible Please Block Some IPs",
        "payload": "61.159.83.27, 106.31.225.181, 124.113.69.146, 110.193.169.10, 36.105.233.171, 36.117.197.225, 113.91.81.178, 115.207.239.18, 110.252.60.154, 117.42.208.29, 121.227.208.31, 121.227.153.3, 46.250.37.60, 118.224.199.107, 118.89.240.8, 36.101.190.239, 80.250.71.98, 58.38.47.241, 122.76.41.113, 59.108.107.170, "
    }
}

TASK [Create Array from BlockedIPs] ********************************************
fatal: [f5]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: 'dict object' has no attribute 'split'. 'dict object' has no attribute 'split'\n\nThe error appears to be in '/tmp/run_playbookcbp6leub/project/block-ips.yaml': line 32, column 5, but may\nbe elsewhere in the file depending on the exact syntax problem.\n\nThe offending line appears to be:\n\n\n  - name: Create Array from BlockedIPs\n    ^ here\n"}

PLAY RECAP *********************************************************************
f5                         : ok=3    changed=0    unreachable=0    failed=1    skipped=0    rescued=0    ignored=0   

2023-05-17 15:45:03,248 - ansible_rulebook.rule_set_runner - INFO - Task action::run_playbook::Listen for events on a webhook::Say Hello finished, active actions 0

`TASK` [debug] *******************************************************************
ok: [f5] => {
    "msg": {
        "message": "Ansible Please Block Some IPs",
        "payload": "114.225.248.7, 122.159.243.78, 49.66.141.203, 47.98.58.62, 139.203.90.78, 43.251.247.220, 113.97.123.155, 115.170.100.80, 106.27.28.238, 49.69.74.215, 125.86.131.83, 123.160.232.22, 120.76.45.146, 112.194.39.209, 122.236.26.112, 42.187.79.104, 60.2.184.96, 60.191.138.128, 124.65.127.96, 91.191.249.134, "
    }
}

.
├── hosts.yml
├── local_copy.yml
├── playbook-create.yml
├── playbook-delete.yml
└── webhooks.yml

all:
  children:
    local:
      hosts:
        localhost:
          ansible_connection: local

resource_list: []

---
- hosts: local
  gather_facts: false
  vars:
    local_copy_file: "/tmp/local_copy.yml"
  tasks:
    - ansible.builtin.stat:
        path: "{{ local_copy_file }}"
      register: local_copy_stat

    - ansible.builtin.copy:
        dest: "{{ local_copy_file }}"
        content: "resource_list: []"
      when: local_copy_stat.stat.exists == false

    - ansible.builtin.include_vars:
        file: "{{ local_copy_file }}"
        name: observed

    - set_fact:
        cacheable: true
        active:
          resource_list: "{{ observed.resource_list + [ansible_eda.event.payload.resource_name] }}"

    - copy:
        dest: "{{ local_copy_file }}"
        content: "resource_list: {{ active.resource_list }}"

---
- hosts: local
  gather_facts: false
  vars:
    local_copy_file: "/tmp/local_copy.yml"
  tasks:
    - ansible.builtin.include_vars:
        file: "{{ local_copy_file }}"
        name: observed
    - set_fact:
        cacheable: true
        active:
          resource_list: "{{ observed.resource_list | difference([ansible_eda.events.m_0.payload.resource_name]) }}"
    - copy:
        dest: "{{ local_copy_file }}"
        content: "resource_list: {{ active.resource_list }}"

---
- name: Ruleset 1
  hosts: all
  sources:   
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
  rules:
    - name: Inspect Create request
      condition: >
        event.payload.event_name == "Create"
      action:
        run_playbook:
          name: playbook-create.yml
          post_events: true
          set_facts: true
    - name: Post Create request
      condition:
        all:
          - events.scoped << event.active.resource_list is defined
      action:
        post_event:
          ruleset: Ruleset 2
          event:
            payload:
              resource_list: "{{ events.scoped.active.resource_list }}"

- name: Ruleset 2
  hosts: all
  sources:   
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5001
  rules:
    - name: Process Delete
      condition:
        all:
          - event.payload.event_name == "Delete"
          - event.payload.resource_list is select("search", "r1")
#          - event.payload.resource_list is select("search", events.m_0.payload.resource_name)
      action:
        run_playbook:
          name: playbook-delete.yml

__version__ = '0.11.0'
  Executable location = /home/alialkhalidi/work/ansible-04062023/bin/ansible-rulebook
  Drools_jpy version = 0.2.8
  Java home = /usr/lib/jvm/java-17-openjdk-17.0.6.0.10-1.fc36.x86_64/
  Java version = 17.0.6
  Python version = 3.10.10 (main, Feb  8 2023, 00:00:00) [GCC 12.2.1 20221121 (Red Hat 12.2.1-4)]

[root@dd6d2c871e07 cloin.eda]# ansible-rulebook --version
__version__ = '1.0.1'
  Executable location = /usr/local/bin/ansible-rulebook
  Drools_jpy version = 0.3.4
  Java home = /usr/lib/jvm/jre-17-openjdk
  Java version = 17.0.8
  Python version = 3.11.4 (main, Jun  7 2023, 00:00:00) [GCC 13.1.1 20230511 (Red Hat 13.1.1-2)]

---
- name: Respond to webhook POST
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
      filters:
        - endpoint_as_namespace:

2023-08-11 15:17:06,126 - ansible_rulebook.engine - INFO - Cancelling all ruleset tasks
2023-08-11 15:17:06,127 - ansible_rulebook.engine - INFO - Waiting on gather
2023-08-11 15:17:06,127 - ansible_rulebook.engine - INFO - Returning from run_rulesets
2023-08-11 15:17:06,127 - ansible_rulebook.app - INFO - Cancelling event source tasks
2023-08-11 15:17:06,128 - ansible_rulebook.app - ERROR - Could not find source filter plugin for endpoint_as_namespace
2023-08-11 15:17:06,129 - ansible_rulebook.app - INFO - Main complete
2023-08-11 15:17:06,129 - ansible_rulebook.cli - ERROR - Terminating One of the source plugins failed

- name: Example
  hosts: all
  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 5000
  rules:
    - name: Get device info if BGP neighbor down
      condition: event.payload.message == "BGP neighbor down"
      throttle:
        once_within: 5 minutes
      action:
        run_job_template:
          name: Parsers
          job_args:
            limit: "{{ event.payload.meta.hosts }}"
          organization: MackNet

[amack@ansible-eda ansible-event-driven-automation]$ ansible-rulebook --rulebook rulebook.yml  -i inventory.yml --verbose
2023-02-10 17:52:42,045 - ansible_rulebook.validators - ERROR - Rulebook failed validation.
Traceback (most recent call last):
  File "/home/amack/.local/lib/python3.8/site-packages/ansible_rulebook/validators.py", line 36, in rulebook
    validate(instance=instance, schema=cls._get_schema())
  File "/usr/local/lib/python3.8/site-packages/jsonschema/validators.py", line 1121, in validate
    raise error
jsonschema.exceptions.ValidationError: Additional properties are not allowed ('throttle' was unexpected)

Failed validating 'additionalProperties' in schema['items']['properties']['rules']['items']:
    {'additionalProperties': False,
     'properties': {'action': {'oneOf': [{'$ref': '#/$defs/run-playbook-action'},
                                         {'$ref': '#/$defs/run-module-action'},
                                         {'$ref': '#/$defs/run-job-template-action'},
                                         {'$ref': '#/$defs/post-event-action'},
                                         {'$ref': '#/$defs/set-fact-action'},
                                         {'$ref': '#/$defs/retract-fact-action'},
                                         {'$ref': '#/$defs/print-event-action'},
                                         {'$ref': '#/$defs/debug-action'},
                                         {'$ref': '#/$defs/none-action'},
                                         {'$ref': '#/$defs/shutdown-action'},
                                         {'$ref': '#/$defs/echo-action'}]},
                    'condition': {'anyOf': [{'type': 'string'},
                                            {'$ref': '#/$defs/all-condition'},
                                            {'$ref': '#/$defs/any-condition'}]},
                    'name': {'minLength': 1,
                             'pattern': '\\S',
                             'type': 'string'}},
     'required': ['name', 'condition', 'action'],
     'type': 'object'}

On instance[0]['rules'][0]:
    {'action': {'run_job_template': {'name': 'Parsers',
                                     'organization': 'MackNet'}},
     'condition': 'event.payload.message == "BGP neighbor down"',
     'name': 'Get device info if BGP neighbor down',
     'throttle': {'once_within': '5 minutes'}}
2023-02-10 17:52:42,074 - ansible_rulebook.cli - ERROR - Unexpected exception
Traceback (most recent call last):
  File "/home/amack/.local/lib/python3.8/site-packages/ansible_rulebook/cli.py", line 203, in main
    asyncio.run(app.run(args))
  File "/usr/lib64/python3.8/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/usr/lib64/python3.8/asyncio/base_events.py", line 616, in run_until_complete
    return future.result()
  File "/home/amack/.local/lib/python3.8/site-packages/ansible_rulebook/app.py", line 65, in run
    rulesets = load_rulebook(parsed_args)
  File "/home/amack/.local/lib/python3.8/site-packages/ansible_rulebook/app.py", line 149, in load_rulebook
    Validate.rulebook(data)
  File "/home/amack/.local/lib/python3.8/site-packages/ansible_rulebook/validators.py", line 36, in rulebook
    validate(instance=instance, schema=cls._get_schema())
  File "/usr/local/lib/python3.8/site-packages/jsonschema/validators.py", line 1121, in validate
    raise error
jsonschema.exceptions.ValidationError: Additional properties are not allowed ('throttle' was unexpected)

Failed validating 'additionalProperties' in schema['items']['properties']['rules']['items']:
    {'additionalProperties': False,
     'properties': {'action': {'oneOf': [{'$ref': '#/$defs/run-playbook-action'},
                                         {'$ref': '#/$defs/run-module-action'},
                                         {'$ref': '#/$defs/run-job-template-action'},
                                         {'$ref': '#/$defs/post-event-action'},
                                         {'$ref': '#/$defs/set-fact-action'},
                                         {'$ref': '#/$defs/retract-fact-action'},
                                         {'$ref': '#/$defs/print-event-action'},
                                         {'$ref': '#/$defs/debug-action'},
                                         {'$ref': '#/$defs/none-action'},
                                         {'$ref': '#/$defs/shutdown-action'},
                                         {'$ref': '#/$defs/echo-action'}]},
                    'condition': {'anyOf': [{'type': 'string'},
                                            {'$ref': '#/$defs/all-condition'},
                                            {'$ref': '#/$defs/any-condition'}]},
                    'name': {'minLength': 1,
                             'pattern': '\\S',
                             'type': 'string'}},
     'required': ['name', 'condition', 'action'],
     'type': 'object'}

On instance[0]['rules'][0]:
    {'action': {'run_job_template': {'name': 'Parsers',
                                     'organization': 'MackNet'}},
     'condition': 'event.payload.message == "BGP neighbor down"',
     'name': 'Get device info if BGP neighbor down',
     'throttle': {'once_within': '5 minutes'}}

DISTRIB_ID=Ubuntu
DISTRIB_RELEASE=22.04
DISTRIB_CODENAME=jammy
DISTRIB_DESCRIPTION="Ubuntu 22.04.4 LTS"

ansible-rulebook --rulebook chaos.yml --inventory inventory.yml
2024-06-07 13:08:39,153 - ansible_rulebook.engine - ERROR - Source error Could not find source plugin for ansible.eda.range
2024-06-07 13:08:39,153 - ansible_rulebook.engine - ERROR - Shutting down source: ansible.eda.range error : Could not find source plugin for ansible.eda.range
2024-06-07 13:08:39,169 - ansible_rulebook.app - ERROR - Could not find source plugin for ansible.eda.range
2024-06-07 13:08:39,170 - ansible_rulebook.cli - ERROR - Terminating One of the source plugins failed

- name: print event always
  condition: true
  action:
    print_event:
      pretty: true

raceback (most recent call last):
  File "/usr/local/bin/ansible-rulebook", line 5, in <module>
    from ansible_rulebook.cli import main
  File "/usr/local/lib/python3.8/site-packages/ansible_rulebook/cli.py", line 29, in <module>
    util.check_jvm()
  File "/usr/local/lib/python3.8/site-packages/ansible_rulebook/util.py", line 190, in check_jvm
    if version.parse(java_version) < version.parse("17"):
  File "/usr/local/lib/python3.8/site-packages/packaging/version.py", line 52, in parse
    return Version(version)
  File "/usr/local/lib/python3.8/site-packages/packaging/version.py", line 197, in __init__
    raise InvalidVersion(f"Invalid version: '{version}'")
packaging.version.InvalidVersion: Invalid version: '1.8.0_312'

$ ansible-rulebook --version
1.1.0
  Executable location = /home/bzjr2686/ansible-rulebook/venv/bin/ansible-rulebook
  Drools_jpy version = 0.3.9
  Java home = /usr/lib/jvm/java-17-openjdk-17.0.6.0.10-3.el9.x86_64
  Java version = 17.0.6
  Python version = 3.9.18 (main, Jan 24 2024, 00:00:00) [GCC 11.4.1 20231218 (Red Hat 11.4.1-3)]

$ cat rule-test.yml
---
- name: Test webhook
  hosts: localhost

  sources:
    - ansible.eda.webhook:
        host: 0.0.0.0
        port: 8081

  rules:
    - name: Run playbook
      condition: True
      action:
        run_playbook:
          name: play-test.yml
          extra_vars:
            testkey1: testval1
            testfilter1: "{{ event.payload.hostname | ansible.builtin.regex_replace('\\w+_(\\w+)', '\\1') }}"

Summury of commands:

1. yum install java-17-openjdk-devel openssl-devel git wget tar python39-devel.ppc64le gcc rust cargo
2. wget https://dlcdn.apache.org/maven/maven-3/3.8.7/binaries/apache-maven-3.8.7-bin.tar.gz
3. tar -xzvf apache-maven-3.8.7-bin.tar.gz -C /opt/
4. ln -s /opt/apache-maven-3.8.7/bin/mvn /usr/local/bin/mvn
5. rm -f apache-maven-3.8.7-bin.tar.gz
6. git clone https://github.com/ansible/ansible-rulebook.git
7. cd ansible-rulebook
8. export JDK_HOME=/usr/lib/jvm/java-17-openjdk
9. export JAVA_HOME=/usr/lib/jvm/java-17-openjdk
10. pip3 install -e .
11. pip3 install -r requirements_test.txt
12. ansible-galaxy collection install git+https://github.com/ansible/event-driven-ansible
13. pip3 install pyparsing jsonschema websockets drools-jpy 
14. pytest -v -n auto

output:

INFO     tests.e2e.test_operators:test_operators.py:387 Running command: ansible-rulebook -i /root/ansible-rulebook/tests/e2e/files/inventories/default_inventory.yml -S /root/ansible-rulebook/tests/e2e/../sources --rulebook /root/ansible-rulebook/tests/e2e/files/rulebooks/operators/test_not_operator.yml

=========================== short test summary info ============================
FAILED tests/e2e/test_actions.py::test_actions_sanity - subprocess.TimeoutExp...
FAILED tests/e2e/test_operators.py::test_less_operators[lt] - AssertionError:...
FAILED tests/e2e/test_operators.py::test_less_operators[le] - AssertionError:...
FAILED tests/e2e/test_operators.py::test_greater_operators[ge_operator] - Ass...
FAILED tests/e2e/test_operators.py::test_greater_operators[gt_operator] - Ass...
FAILED tests/e2e/test_operators.py::test_ne_operator[str] - AssertionError: a...
FAILED tests/e2e/test_operators.py::test_ne_operator[int] - AssertionError: a...
FAILED tests/e2e/test_operators.py::test_defined_operator[str] - AssertionErr...
FAILED tests/e2e/test_operators.py::test_defined_operator[int] - AssertionErr...
FAILED tests/e2e/test_operators.py::test_defined_operator[nested] - Assertion...
FAILED tests/e2e/test_operators.py::test_contains_operator[contains_str_single]
FAILED tests/e2e/test_operators.py::test_contains_operator[contains_int_single]
FAILED tests/e2e/test_operators.py::test_contains_operator[not_contains_str_combined]
FAILED tests/e2e/test_operators.py::test_in_operator[int_combined_multiple_extravars]
FAILED tests/e2e/test_operators.py::test_in_operator[not_in_int_extravars] - ...
FAILED tests/e2e/test_operators.py::test_in_operator[not_in_str_extravars] - ...
FAILED tests/e2e/test_operators.py::test_in_operator[str_single] - AssertionE...
FAILED tests/e2e/test_operators.py::test_in_operator[not_in_str_single] - Ass...
FAILED tests/e2e/test_operators.py::test_not_operator - AssertionError: asser...
============ 19 failed, 120 passed, 2 xfailed in 506.72s (0:08:26) =============

~$ ansible-rulebook --debug -i inventory --rulebook hello_events.yml --env-vars EVENT_INTEGER 
[...]
INFO:ansible_rulebook.engine:ruleset define: {"name": "Hello Events", "hosts": ["all"], "sources": [{"EventSource": {"name": "ansible.eda.range", "source_name": "ansible.eda.range", "source_args": {"limit": 5}, "source_filters": []}}], "rules": [{"Rule": {"name": "First -- Say Hello when 1", "condition": {"AllCondition": [{"EqualsExpression": {"lhs": {"Event": "i"}, "rhs": {"Integer": 1}}}]}, "action": {"Action": {"action": "print_event", "action_args": {}}}, "enabled": true}}]}
INFO:ansible_rulebook.rule_generator:calling First -- Say Hello when 1
INFO:ansible_rulebook.engine:substitute_variables [{}] [{'EVENT_INTEGER': '1', 'event': {'i': 1}, 'fact': {'i': 1}}]
INFO:ansible_rulebook.engine:action args: {}
{'i': 1}

openjdk 19 2022-09-20
OpenJDK Runtime Environment Homebrew (build 19)
OpenJDK 64-Bit Server VM Homebrew (build 19, mixed mode, sharing)

pip install wheel ansible-rulebook ansible ansible-runner                          ✔  08:30:07 AM  
Requirement already satisfied: wheel in /opt/homebrew/lib/python3.10/site-packages (0.37.1)
Requirement already satisfied: ansible-rulebook in /opt/homebrew/lib/python3.10/site-packages (0.9.4)
Requirement already satisfied: ansible in /opt/homebrew/lib/python3.10/site-packages (6.5.0)
Requirement already satisfied: ansible-runner in /opt/homebrew/lib/python3.10/site-packages (2.2.1)
Requirement already satisfied: drools-jpy in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (0.0.8)
Requirement already satisfied: jinja2 in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (3.1.2)
Requirement already satisfied: janus in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (1.0.0)
Requirement already satisfied: pyparsing>=3.0 in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (3.0.9)
Requirement already satisfied: redis in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (4.3.4)
Requirement already satisfied: dpath in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (2.0.6)
Requirement already satisfied: websockets in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (10.3)
Requirement already satisfied: jsonschema in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (4.16.0)
Requirement already satisfied: durable-rules in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (2.0.28)
Requirement already satisfied: asyncio in /opt/homebrew/lib/python3.10/site-packages (from ansible-rulebook) (3.4.3)
Requirement already satisfied: ansible-core~=2.13.5 in /opt/homebrew/lib/python3.10/site-packages (from ansible) (2.13.5)
Requirement already satisfied: python-daemon in /opt/homebrew/lib/python3.10/site-packages (from ansible-runner) (2.3.1)
Requirement already satisfied: pexpect>=4.5 in /opt/homebrew/lib/python3.10/site-packages (from ansible-runner) (4.8.0)
Requirement already satisfied: pyyaml in /opt/homebrew/lib/python3.10/site-packages (from ansible-runner) (6.0)
Requirement already satisfied: packaging in /opt/homebrew/lib/python3.10/site-packages (from ansible-runner) (21.3)
Requirement already satisfied: six in /opt/homebrew/lib/python3.10/site-packages (from ansible-runner) (1.16.0)
Requirement already satisfied: cryptography in /opt/homebrew/lib/python3.10/site-packages (from ansible-core~=2.13.5->ansible) (38.0.1)
Requirement already satisfied: resolvelib<0.9.0,>=0.5.3 in /opt/homebrew/lib/python3.10/site-packages (from ansible-core~=2.13.5->ansible) (0.8.1)
Requirement already satisfied: MarkupSafe>=2.0 in /opt/homebrew/lib/python3.10/site-packages (from jinja2->ansible-rulebook) (2.1.1)
Requirement already satisfied: ptyprocess>=0.5 in /opt/homebrew/lib/python3.10/site-packages (from pexpect>=4.5->ansible-runner) (0.7.0)
Requirement already satisfied: jpy in /opt/homebrew/lib/python3.10/site-packages (from drools-jpy->ansible-rulebook) (0.12.0)
Requirement already satisfied: typing-extensions>=3.7.4.3 in /opt/homebrew/lib/python3.10/site-packages (from janus->ansible-rulebook) (4.4.0)
Requirement already satisfied: attrs>=17.4.0 in /opt/homebrew/lib/python3.10/site-packages (from jsonschema->ansible-rulebook) (22.1.0)
Requirement already satisfied: pyrsistent!=0.17.0,!=0.17.1,!=0.17.2,>=0.14.0 in /opt/homebrew/lib/python3.10/site-packages (from jsonschema->ansible-rulebook) (0.18.1)
Requirement already satisfied: lockfile>=0.10 in /opt/homebrew/lib/python3.10/site-packages (from python-daemon->ansible-runner) (0.12.2)
Requirement already satisfied: setuptools in /opt/homebrew/lib/python3.10/site-packages (from python-daemon->ansible-runner) (65.4.1)
Requirement already satisfied: docutils in /opt/homebrew/lib/python3.10/site-packages (from python-daemon->ansible-runner) (0.19)
Requirement already satisfied: deprecated>=1.2.3 in /opt/homebrew/lib/python3.10/site-packages (from redis->ansible-rulebook) (1.2.13)
Requirement already satisfied: async-timeout>=4.0.2 in /opt/homebrew/lib/python3.10/site-packages (from redis->ansible-rulebook) (4.0.2)
Requirement already satisfied: wrapt<2,>=1.10 in /opt/homebrew/lib/python3.10/site-packages (from deprecated>=1.2.3->redis->ansible-rulebook) (1.14.1)
Requirement already satisfied: cffi>=1.12 in /opt/homebrew/lib/python3.10/site-packages (from cryptography->ansible-core~=2.13.5->ansible) (1.15.1)
Requirement already satisfied: pycparser in /opt/homebrew/lib/python3.10/site-packages (from cffi>=1.12->cryptography->ansible-core~=2.13.5->ansible) (2.21)