---
# tasks/rabbit.yml: Deploy RabbitMQ and set-up vhost for Sensu messaging

  - include_vars: "{{ ansible_distribution }}.yml"

  - include: "{{ ansible_distribution }}/rabbit.yml"

  - name: Ensure RabbitMQ SSL directory exists
    file: dest={{ rabbitmq_config_path }}/ssl state=directory

  - name: Ensure RabbitMQ SSL certs/keys are in place
    copy: src={{ item }} dest={{ rabbitmq_config_path }}/ssl
    with_items:
      - "{{ sensu_ssl_server_cacert }}"
      - "{{ sensu_ssl_server_cert }}"
      - "{{ sensu_ssl_server_key }}"
    notify:
      - restart rabbitmq service
      - restart sensu-api service
      - restart sensu-server service
      - restart sensu-enterprise service
    when: sensu_ssl_manage_certs

  - name: Deploy RabbitMQ config
    template:
      dest: "{{ rabbitmq_config_path }}/rabbitmq.config"
      src: "{{ rabbitmq_config_template }}"
      owner: root
      group: "{{ __root_group }}"
      mode: 0644
    notify: restart rabbitmq service

  - name: Ensure RabbitMQ is running
    service:
      name: "{{ rabbitmq_service_name }}"
      state: started
      enabled: true
    register: rabbitmq_state

  - name: Wait for RabbitMQ to be up and running before asking to create a vhost
    pause: seconds=3
    when: rabbitmq_state|changed

  - block:
    - name: Ensure Sensu RabbitMQ vhost exists
      rabbitmq_vhost: name={{ rabbitmq_sensu_vhost }} state=present

    - name: Ensure Sensu RabbitMQ user has access to the Sensu vhost
      rabbitmq_user:
        user: "{{ rabbitmq_sensu_user_name }}"
        password: "{{ rabbitmq_sensu_password }}"
        vhost: "{{ rabbitmq_sensu_vhost }}"
        configure_priv: .*
        read_priv: .*
        write_priv: .*
        state: present
    become: true
    become_user: rabbitmq