class ProxyAPI::Openbolt

# File lib/proxy_api/openbolt.rb, line 11
def initialize(args)
  @url = args[:url]
  super
end

# File lib/proxy_api/openbolt.rb, line 68
def delete_job_artifacts(job_id:)
  with_proxy_error_handling('delete_job_artifacts') do
    parse_response(delete("/openbolt/job/#{job_id}/artifacts"), 'delete_job_artifacts')
  end
end

# File lib/proxy_api/openbolt.rb, line 16
def fetch_tasks
  @tasks = with_proxy_error_handling('fetch_tasks') do
    parse_response(get('/openbolt/tasks'), 'fetch_tasks')
  end
end

# File lib/proxy_api/openbolt.rb, line 62
def job_result(job_id:)
  with_proxy_error_handling('job_result') do
    parse_response(get("/openbolt/job/#{job_id}/result"), 'job_result')
  end
end

# File lib/proxy_api/openbolt.rb, line 56
def job_status(job_id:)
  with_proxy_error_handling('job_status') do
    parse_response(get("/openbolt/job/#{job_id}/status"), 'job_status')
  end
end

# File lib/proxy_api/openbolt.rb, line 44
def launch_task(name:, targets:, parameters: {}, options: {})
  with_transport_errors_wrapped('launch_task') do
    response = post({
      name: name,
      targets: targets,
      parameters: parameters,
      options: options,
    }.to_json, '/openbolt/launch/task')
    parse_response(response, 'launch_task')
  end
end

# File lib/proxy_api/openbolt.rb, line 36
def openbolt_options
  @openbolt_options ||= with_proxy_error_handling('openbolt_options') do
    parse_response(get('/openbolt/tasks/options'), 'openbolt_options')
  end
end

# File lib/proxy_api/openbolt.rb, line 74
def parse_response(response, operation)
  unless response
    raise ProxyException.new(
      @url, RuntimeError.new("No response from Smart Proxy during #{operation}"),
      "No response from Smart Proxy during #{operation}"
    )
  end

  body = response.body
  if body.nil?
    raise ProxyException.new(
      @url, RuntimeError.new("Empty response body from Smart Proxy during #{operation}"),
      "Empty response body from Smart Proxy during #{operation}"
    )
  end

  JSON.parse(body)
rescue JSON::ParserError => e
  raise ProxyException.new(
    @url, e,
    "Invalid JSON from Smart Proxy during #{operation}: #{e.message}. " \
    "Response body (first 500 chars): #{body.to_s[0..500]}"
  )
end

# File lib/proxy_api/openbolt.rb, line 26
def reload_tasks
  @tasks = with_proxy_error_handling('reload_tasks') do
    parse_response(get('/openbolt/tasks/reload'), 'reload_tasks')
  end
end

# File lib/proxy_api/openbolt.rb, line 32
def task_names
  tasks.keys
end

# File lib/proxy_api/openbolt.rb, line 22
def tasks
  @tasks ||= fetch_tasks
end

# File lib/proxy_api/openbolt.rb, line 117
def with_proxy_error_handling(operation, &block)
  result = with_transport_errors_wrapped(operation, &block)
  error = result.is_a?(Hash) ? result['error'] : nil
  if error.is_a?(Hash) && error.key?('message')
    detail = error['message']
    raise ProxyReportedError.new(
      @url, RuntimeError.new(detail.to_s),
      "Smart Proxy reported error during #{operation}: #{detail}"
    )
  end
  result
end

# File lib/proxy_api/openbolt.rb, line 104
def with_transport_errors_wrapped(operation)
  yield
rescue RestClient::Exception, SystemCallError, SocketError, OpenSSL::SSL::SSLError => e
  raise ProxyException.new(
    @url, e,
    "Transport error during #{operation}: #{e.message}"
  )
end