satisfy new rubocop rules

Author: lostapathy

lib/influxdb/client/http.rb

@@ -58,6 +58,7 @@ def connect_with_retry
         unless (config.retry == -1 || retry_count <= config.retry) && !stopped?
           raise InfluxDB::ConnectionError, "Tried #{retry_count - 1} times to reconnect but failed."
         end
+
         log(:warn) { "Failed to contact host #{host}: #{e.inspect} - retrying in #{delay}s." }
         sleep delay
         delay = [config.max_delay, delay * 2].min
@@ -96,13 +97,14 @@ def handle_successful_response(response, options)
       end
 
       errors = errors_from_response(parsed_response)
-
       raise InfluxDB::QueryError, errors if errors
+
       options.fetch(:parse, false) ? parsed_response : response
     end
 
     def errors_from_response(parsed_resp)
       return unless parsed_resp.is_a?(Hash)
+
       parsed_resp
         .fetch('results', [])
         .fetch(0, {})

lib/influxdb/config.rb

@@ -168,6 +168,7 @@ def opts_from_params(query)
 
       OPTIONS_FROM_PARAMS.each_with_object({}) do |k, opts|
         next unless params[k.to_s].size == 1
+
         opts[k] = coerce(k, params[k.to_s].first)
       end
     end

lib/influxdb/logging.rb

@@ -10,6 +10,7 @@ class << self
 
       def logger
         return false if @logger == false
+
         @logger ||= ::Logger.new(STDERR).tap { |logger| logger.level = Logger::INFO }
       end
 

lib/influxdb/max_queue.rb

@@ -5,6 +5,7 @@ class MaxQueue < Queue
 
     def initialize(max = 10_000)
       raise ArgumentError, "queue size must be positive" if max <= 0
+
       @max = max
       super()
     end

lib/influxdb/point_value.rb

@@ -46,6 +46,7 @@ def escape(str, type)
 
     def escape_values(values)
       return if values.nil?
+
       values.map do |k, v|
         key = escape(k.to_s, :field_key)
         val = escape_value(v)

lib/influxdb/query/measurement.rb

@@ -4,6 +4,7 @@ module Measurement # :nodoc:
       def list_measurements(database = config.database)
         data = execute("SHOW MEASUREMENTS", db: database, parse: true)
         return nil if data.nil? || data["results"][0]["series"].nil?
+
         data["results"][0]["series"][0]["values"].flatten
       end
 

lib/influxdb/query/series.rb

@@ -9,6 +9,7 @@ def list_series
         resp = execute("SHOW SERIES".freeze, parse: true, db: config.database)
         resp = fetch_series(resp)
         return [] if resp.empty?
+
         raw_values(resp[0])
           .fetch('values'.freeze, [])
           .map { |val| val[0].split(',')[0] }

lib/influxdb/writer/async.rb

@@ -19,10 +19,12 @@ def write(data, precision = nil, retention_policy = nil, database = nil)
       WORKER_MUTEX = Mutex.new
       def worker
         return @worker if @worker
+
         WORKER_MUTEX.synchronize do
           # this return is necessary because the previous mutex holder
           # might have already assigned the @worker
           return @worker if @worker
+
           @worker = Worker.new(client, config)
         end
       end

spec/spec_helper.rb

@@ -11,6 +11,7 @@
 def min_influx_version(version)
   v = ENV.fetch("influx_version", "0")
   return true if v == "nightly"
+
   current = Gem::Version.new(v)
   current >= Gem::Version.new(version)
 end