---
- name: Geth | Create sync check script
  copy:
    dest: '{{ geth_sync_check_script }}'
    mode: 0755
    content: |
      #!/usr/bin/env bash
      set -e
      echo -n "Geth synced: "
      RESP=$(curl -s -X POST \
                 --connect-timeout 5 \
                 -H 'Content-type:application/json' \
                 --data '{"jsonrpc":"2.0","method":"eth_syncing","id":1}' \
                 http://localhost:{{ geth_rpc_port }}/)
      echo "${RESP}" | jq -e ".result == false" \
          || ( echo "${RESP}" | jq . ; exit 1 )

- name: Geth | Create Consul service definition
  include_role: name=consul-service
  vars:
    consul_config_name: '{{ geth_cont_name | replace("-", "_") }}'
    consul_services:
      - name: '{{ geth_cont_name }}'
        tags: '{{ geth_consul_tags }}'
        port: '{{ geth_port }}'
        address: '{{ geth_consul_address }}'
        meta:
          env: '{{ env }}'
          stage: '{{ stage }}'
          node_addr: '{{ node_info.json.result.id }}'
          node_enode: '{{ node_info.json.result.enode }}'
        checks:
          - id: '{{ geth_cont_name }}-status'
            type: tcp
            tcp: '127.0.0.1:{{ geth_port }}'
      - name: '{{ geth_cont_name }}-rpc'
        tags: '{{ geth_consul_tags + ["rpc"] }}'
        port: '{{ geth_rpc_port }}'
        address: '{{ geth_consul_rpc_address }}'
        meta:
          env: '{{ env }}'
          stage: '{{ stage }}'
        checks:
          - id: '{{ geth_cont_name }}-rpc-status'
            type: script
            script: '{{ geth_sync_check_script }}'
            timeout: '5s'
      - name: '{{ geth_cont_name }}-ws'
        tags: '{{ geth_consul_tags + ["websocket"] }}'
        port: '{{ geth_websocket_port }}'
        address: '{{ geth_consul_rpc_address }}'
        meta:
          env: '{{ env }}'
          stage: '{{ stage }}'
        checks:
          - id: '{{ geth_cont_name }}-ws-status'
            name: 'Geth WebSocket API'
            type: 'tcp'
            tcp: 'localhost:{{ geth_websocket_port }}'