NiFi Check

module.exports = header: 'NiFi Check', handler: (options) ->
  protocol = if options.properties['nifi.cluster.protocol.is.secure'] is 'true' then 'https' else 'http'
  webui = options.properties["nifi.web.#{protocol}.port"]

Wait

  @call once: true, 'ryba/nifi/wait', options.wait

Check TCP

  @connection.assert
    header: 'Check WebUI port'
    host: "#{options.fqdn}"
    port: "#{webui}"
    retry: 3
    interval: 5000
  @system.execute
    header: 'Check Node port'
    if: options.properties['nifi.cluster.is.node'] is 'true'
    cmd: "echo > /dev/tcp/#{options.fqdn}/#{options.properties['nifi.cluster.node.protocol.port']}"
  @system.execute
    header: 'Check Manager port'
    if: options.properties['nifi.cluster.is.manager'] is 'true'
    cmd: "echo > /dev/tcp/#{options.fqdn}/#{options.properties['nifi.cluster.manager.protocol.port']}"
  @system.execute
    header: 'Check Multicast port'
    if: options.properties['nifi.cluster.protocol.use.multicast'] is 'true'
    cmd: "echo > /dev/tcp/#{options.fqdn}/#{options.properties['nifi.cluster.protocol.multicast.port']}"
  @system.execute
    header: 'Check Input Socket port'
    if: options.properties['nifi.remote.input.socket.port'] and options.properties['nifi.remote.input.socket.port'] isnt ''
    cmd: "echo > /dev/tcp/#{options.fqdn}/#{options.properties['nifi.remote.input.socket.port']}"

Check Rest Api

Executes a series of job to test NiFi functionning curl -H "Content-Type: application/json" --negotiate -k -X POST -d '[#{JSON.stringify pic}]' -u: https:// #