Class: NiceHttp

Inherits:
Object
  • Object
show all
Includes:
NiceHttpHttpMethods, NiceHttpManageRequest, NiceHttpManageResponse
Defined in:
lib/nice_http.rb

Overview

Attributes you can access using NiceHttp.the_attribute: :host, :port, :ssl, :headers, :debug, :log, :proxy_host, :proxy_port, :last_request, :last_response, :request_id, :use_mocks, :connections, :active, :auto_redirect, :values_for, :create_stats, :stats

Constant Summary collapse

Error = 
Class.new StandardError
InfoMissing = 
Class.new Error do
  attr_reader :attribute

  def initialize(attribute, message = "")
    @attribute = attribute
    message += "It was not possible to create the http connection!!!\n"
    message += "Wrong #{attribute}. "
    message += "Remember to supply http:// or https:// in case you specify an url to create the http connection, for example:\n"
    message += "http = NiceHttp.new('http://example.com')"
    super message
  end
end

Class Attribute Summary collapse

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(args = {}) ⇒ NiceHttp

Creates a new http connection.

Examples:

http = NiceHttp.new()

http = NiceHttp.new("https://www.example.com")

http = NiceHttp.new("example.com:8999")

http = NiceHttp.new("localhost:8322")

http2 = NiceHttp.new( host: "reqres.in", port: 443, ssl: true )

my_server = {host: "example.com",
             port: 80,
             headers: {"api-key": "zdDDdjkck"}
            }
http3 = NiceHttp.new my_server

Raises:



236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
 
# File 'lib/nice_http.rb', line 236

def initialize(args = {})
  require "net/http"
  require "net/https"
  @host = self.class.host
  @port = self.class.port
  @prepath = ""
  @ssl = self.class.ssl
  @headers = self.class.headers.dup
  @values_for = self.class.values_for.dup
  @debug = self.class.debug
  @log = self.class.log
  @proxy_host = self.class.proxy_host
  @proxy_port = self.class.proxy_port
  @use_mocks = self.class.use_mocks
  @auto_redirect = false #set it up at the end of initialize
  auto_redirect = self.class.auto_redirect
  @num_redirects = 0
  @create_stats = self.class.create_stats

  #todo: set only the cookies for the current domain
  #key: path, value: hash with key is the name of the cookie and value the value
  # we set the default value for non existing keys to empty Hash {} so in case of merge there is no problem
  @cookies = Hash.new { |h, k| h[k] = {} }

  if args.is_a?(String)
    uri = URI.parse(args)
    @host = uri.host unless uri.host.nil?
    @port = uri.port unless uri.port.nil?
    @ssl = true if !uri.scheme.nil? && (uri.scheme == "https")
    @prepath = uri.path unless uri.path == "/"
  elsif args.is_a?(Hash) && !args.keys.empty?
    @host = args[:host] if args.keys.include?(:host)
    @port = args[:port] if args.keys.include?(:port)
    @ssl = args[:ssl] if args.keys.include?(:ssl)
    @headers = args[:headers].dup if args.keys.include?(:headers)
    @values_for = args[:values_for].dup if args.keys.include?(:values_for)
    @debug = args[:debug] if args.keys.include?(:debug)
    @log = args[:log] if args.keys.include?(:log)
    @proxy_host = args[:proxy_host] if args.keys.include?(:proxy_host)
    @proxy_port = args[:proxy_port] if args.keys.include?(:proxy_port)
    @use_mocks = args[:use_mocks] if args.keys.include?(:use_mocks)
    auto_redirect = args[:auto_redirect] if args.keys.include?(:auto_redirect)
  end

  log_filename = ""
  if @log.kind_of?(String) or @log == :fix_file or @log == :file or @log == :file_run
    if @log.kind_of?(String)
      log_filename = @log.dup

      unless log_filename.start_with?(".")
        if caller.first.start_with?(Dir.pwd)
          folder = File.dirname(caller.first[/[^:]+/])
        else
          folder = File.dirname("#{Dir.pwd}/#{caller.first[/[^:]+/]}")
        end
        folder += "/" unless log_filename.start_with?("/")
        log_filename = folder + log_filename
      end
      unless Dir.exist?(File.dirname(log_filename))
        @logger = Logger.new nil
        raise InfoMissing, :log, "Wrong directory specified for logs.\n"
      end
    elsif @log == :fix_file
      log_filename = "nice_http.log"
    elsif @log == :file
      log_filename = "nice_http_#{Time.now.strftime("%Y-%m-%d-%H%M%S")}.log"
    elsif @log == :file_run
      log_filename = "#{caller.first[/[^:]+/]}.log"
    end
    if Thread.current.name.to_s != ""
      log_filename.gsub!(/\.log$/, "_#{Thread.current.name}.log")
    end
    if self.class.log_files.key?(log_filename)
      @logger = self.class.log_files[log_filename]
    else
      begin
        f = File.new(log_filename, "w")
        f.sync = true
        @logger = Logger.new f
      rescue Exception => stack
        @logger = Logger.new nil
        raise InfoMissing, :log
      end
      self.class.log_files[log_filename] = @logger
    end
  elsif @log == :screen
    @logger = Logger.new STDOUT
  elsif @log == :no
    @logger = Logger.new nil
  else
    raise InfoMissing, :log
  end
  @logger.level = Logger::INFO

  if @host.to_s != "" and (@host.start_with?("http:") or @host.start_with?("https:"))
    uri = URI.parse(@host)
    @host = uri.host unless uri.host.nil?
    @port = uri.port unless uri.port.nil?
    @ssl = true if !uri.scheme.nil? && (uri.scheme == "https")
    @prepath = uri.path unless uri.path == "/"
  end

  raise InfoMissing, :port if @port.to_s == ""
  raise InfoMissing, :host if @host.to_s == ""
  raise InfoMissing, :ssl unless @ssl.is_a?(TrueClass) or @ssl.is_a?(FalseClass)
  raise InfoMissing, :debug unless @debug.is_a?(TrueClass) or @debug.is_a?(FalseClass)
  raise InfoMissing, :auto_redirect unless auto_redirect.is_a?(TrueClass) or auto_redirect.is_a?(FalseClass)
  raise InfoMissing, :use_mocks unless @use_mocks.is_a?(TrueClass) or @use_mocks.is_a?(FalseClass)
  raise InfoMissing, :headers unless @headers.is_a?(Hash)
  raise InfoMissing, :values_for unless @values_for.is_a?(Hash)

  begin
    if !@proxy_host.nil? && !@proxy_port.nil?
      @http = Net::HTTP::Proxy(@proxy_host, @proxy_port).new(@host, @port)
      @http.use_ssl = @ssl
      @http.set_debug_output $stderr if @debug
      @http.verify_mode = OpenSSL::SSL::VERIFY_NONE
      @http.start
    else
      @http = Net::HTTP.new(@host, @port)
      @http.use_ssl = @ssl
      @http.set_debug_output $stderr if @debug
      @http.verify_mode = OpenSSL::SSL::VERIFY_NONE
      @http.start
    end

    @message_server = "(#{self.object_id}):"

    log_message = "(#{self.object_id}): Http connection created. host:#{@host},  port:#{@port},  ssl:#{@ssl}, mode:#{@mode}, proxy_host: #{@proxy_host.to_s()}, proxy_port: #{@proxy_port.to_s()} "

    @logger.info(log_message)
    @message_server += " Http connection: "
    if @ssl
      @message_server += "https://"
    else
      @message_server += "http://"
    end
    @message_server += "#{@host}:#{@port}"
    if @proxy_host.to_s != ""
      @message_server += " proxy:#{@proxy_host}:#{@proxy_port}"
    end
    @auto_redirect = auto_redirect
    # for the case we have headers following nice_hash implementation
    @headers = @headers.generate

    self.class.active += 1
    self.class.connections.push(self)
  rescue Exception => stack
    puts stack
    @logger.fatal stack
  end
end

Class Attribute Details

.active ⇒ Object

Returns the value of attribute active.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def active
  @active
end

.auto_redirect ⇒ Object

Returns the value of attribute auto_redirect.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def auto_redirect
  @auto_redirect
end

.connections ⇒ Object

Returns the value of attribute connections.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def connections
  @connections
end

.create_stats ⇒ Object

Returns the value of attribute create_stats.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def create_stats
  @create_stats
end

.debug ⇒ Object

Returns the value of attribute debug.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def debug
  @debug
end

.headers ⇒ Object

Returns the value of attribute headers.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def headers
  @headers
end

.host ⇒ Object

Returns the value of attribute host.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def host
  @host
end

.last_request ⇒ Object

Returns the value of attribute last_request.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def last_request
  @last_request
end

.last_response ⇒ Object

Returns the value of attribute last_response.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def last_response
  @last_response
end

.log ⇒ Object

Returns the value of attribute log.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def log
  @log
end

.log_files ⇒ Object

Returns the value of attribute log_files.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def log_files
  @log_files
end

.port ⇒ Object

Returns the value of attribute port.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def port
  @port
end

.proxy_host ⇒ Object

Returns the value of attribute proxy_host.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def proxy_host
  @proxy_host
end

.proxy_port ⇒ Object

Returns the value of attribute proxy_port.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def proxy_port
  @proxy_port
end

.request_id ⇒ Object

Returns the value of attribute request_id.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def request_id
  @request_id
end

.ssl ⇒ Object

Returns the value of attribute ssl.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def ssl
  @ssl
end

.stats ⇒ Object

Returns the value of attribute stats.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def stats
  @stats
end

.use_mocks ⇒ Object

Returns the value of attribute use_mocks.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def use_mocks
  @use_mocks
end

.values_for ⇒ Object

Returns the value of attribute values_for.



68
69
70
 
# File 'lib/nice_http.rb', line 68

def values_for
  @values_for
end

Instance Attribute Details

#active ⇒ Integer

Number of active connections



47
48
49
 
# File 'lib/nice_http.rb', line 47

def active
  @active
end

#auto_redirect ⇒ Boolean

If true, NiceHttp will take care of the auto redirections when required by the responses



47
48
49
 
# File 'lib/nice_http.rb', line 47

def auto_redirect
  @auto_redirect
end

#connections ⇒ Array

It will include all the active connections (NiceHttp instances)



47
48
49
 
# File 'lib/nice_http.rb', line 47

def connections
  @connections
end

#cookies ⇒ Hash

Cookies set. The key is the path (String) where cookies are set and the value a Hash with pairs of cookie keys and values, example: { '/' => { "cfid" => "d95adfas2550255", "amddom.settings" => "doom" } }



47
48
49
 
# File 'lib/nice_http.rb', line 47

def cookies
  @cookies
end

#create_stats ⇒ Boolean

If true, NiceHttp will create stats of the http communication and store them on NiceHttp.stats hash



47
48
49
 
# File 'lib/nice_http.rb', line 47

def create_stats
  @create_stats
end

#debug ⇒ Boolean

In case true shows all the details of the communication with the host



47
48
49
 
# File 'lib/nice_http.rb', line 47

def debug
  @debug
end

#headers ⇒ Hash

Contains the headers you will be using on your connection



47
48
49
 
# File 'lib/nice_http.rb', line 47

def headers
  @headers
end

#host ⇒ String

The host to be accessed



47
48
49
 
# File 'lib/nice_http.rb', line 47

def host
  @host
end

#last_request ⇒ String

The last request with all the content sent



47
48
49
 
# File 'lib/nice_http.rb', line 47

def last_request
  @last_request
end

#last_response ⇒ String

Only in case :debug is true, the last response with all the content



47
48
49
 
# File 'lib/nice_http.rb', line 47

def last_response
  @last_response
end

#log ⇒ String, Symbol

:fix_file, :no, :screen, :file, "path and file name". :fix_file, will log the communication on nice_http.log. (default). :no, will not generate any logs. :screen, will print the logs on the screen. :file, will be generated a log file with name: nice_http_YY-mm-dd-HHMMSS.log. :file_run, will generate a log file with the name where the object was created and extension .log, fex: myfile.rb.log String the path and file name where the logs will be stored.



47
48
49
 
# File 'lib/nice_http.rb', line 47

def log
  @log
end

#logger ⇒ Logger

An instance of the Logger class where logs will be stored. You can access on anytime to store specific data, for example: my_http.logger.info "add this to the log file"

See Also:



47
48
49
 
# File 'lib/nice_http.rb', line 47

def logger
  @logger
end

#num_redirects ⇒ Integer

Number of consecutive redirections managed



47
48
49
 
# File 'lib/nice_http.rb', line 47

def num_redirects
  @num_redirects
end

#port ⇒ Integer

The port number



47
48
49
 
# File 'lib/nice_http.rb', line 47

def port
  @port
end

#proxy_host ⇒ String

the proxy host to be used



47
48
49
 
# File 'lib/nice_http.rb', line 47

def proxy_host
  @proxy_host
end

#proxy_port ⇒ Integer

the proxy port to be used



47
48
49
 
# File 'lib/nice_http.rb', line 47

def proxy_port
  @proxy_port
end

#request_id ⇒ String

If the response includes a requestId, will be stored here



47
48
49
 
# File 'lib/nice_http.rb', line 47

def request_id
  @request_id
end

#response ⇒ Hash

Contains the full response hash



47
48
49
 
# File 'lib/nice_http.rb', line 47

def response
  @response
end

#ssl ⇒ Boolean

If you use ssl or not



47
48
49
 
# File 'lib/nice_http.rb', line 47

def ssl
  @ssl
end

#stats ⇒ Hash

It contains detailed stats of the http communication



47
48
49
 
# File 'lib/nice_http.rb', line 47

def stats
  @stats
end

#use_mocks ⇒ Boolean

If true, in case the request hash includes a :mock_response key, it will be used as the response instead



47
48
49
 
# File 'lib/nice_http.rb', line 47

def use_mocks
  @use_mocks
end

#values_for ⇒ Hash

The default values to set on the data in case not specified others



47
48
49
 
# File 'lib/nice_http.rb', line 47

def values_for
  @values_for
end

Class Method Details

.add_stats(name, state, started, finished) ⇒ Object

To add specific stats The stats will be added to NiceHttp.stats[:specific]

Examples:

started = Time.now
@http.send_request Requests::Customer.add_customer
30.times do
   resp = @http.get(Requests::Customer.get_customer)
   break if resp.code == 200
   sleep 0.5
end
NiceHttp.add_stats(:customer, :create, started, Time.now)



170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
 
# File 'lib/nice_http.rb', line 170

def self.add_stats(name, state, started, finished)
  self.stats[:specific] ||= {}
  self.stats[:specific][name] ||= { num: 0, time_elapsed: { total: 0, maximum: 0, minimum: 1000, average: 0 } }
  self.stats[:specific][name][:num] += 1
  time_elapsed = self.stats[:specific][name][:time_elapsed]
  time_elapsed[:total] += finished - started
  time_elapsed[:maximum] = (finished - started) if time_elapsed[:maximum] < (finished - started)
  time_elapsed[:minimum] = (finished - started) if time_elapsed[:minimum] > (finished - started)
  time_elapsed[:average] = time_elapsed[:total] / self.stats[:specific][name][:num]

  self.stats[:specific][name][state] ||= { num: 0, time_elapsed: { total: 0, maximum: 0, minimum: 1000, average: 0 } }
  self.stats[:specific][name][state][:num] += 1
  time_elapsed = self.stats[:specific][name][state][:time_elapsed]
  time_elapsed[:total] += finished - started
  time_elapsed[:maximum] = (finished - started) if time_elapsed[:maximum] < (finished - started)
  time_elapsed[:minimum] = (finished - started) if time_elapsed[:minimum] > (finished - started)
  time_elapsed[:average] = time_elapsed[:total] / self.stats[:specific][name][state][:num]
end

.defaults=(par = {}) ⇒ Object

Change the default values for NiceHttp supplying a Hash



136
137
138
139
140
141
142
143
144
145
146
147
148
149
 
# File 'lib/nice_http.rb', line 136

def self.defaults=(par = {})
  @host = par[:host] if par.key?(:host)
  @port = par[:port] if par.key?(:port)
  @ssl = par[:ssl] if par.key?(:ssl)
  @headers = par[:headers].dup if par.key?(:headers)
  @values_for = par[:values_for].dup if par.key?(:values_for)
  @debug = par[:debug] if par.key?(:debug)
  @log = par[:log] if par.key?(:log)
  @proxy_host = par[:proxy_host] if par.key?(:proxy_host)
  @proxy_port = par[:proxy_port] if par.key?(:proxy_port)
  @use_mocks = par[:use_mocks] if par.key?(:use_mocks)
  @auto_redirect = par[:auto_redirect] if par.key?(:auto_redirect)
  @create_stats = par[:create_stats] if par.key?(:create_stats)
end

.inherited(subclass) ⇒ Object

If inheriting from NiceHttp class



124
125
126
 
# File 'lib/nice_http.rb', line 124

def self.inherited(subclass)
  subclass.reset!
end

.reset! ⇒ Object

to reset to the original defaults



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/nice_http.rb', line 85

def self.reset!
  @host = nil
  @port = 80
  @ssl = false
  @headers = {}
  @values_for = {}
  @debug = false
  @log = :fix_file
  @proxy_host = nil
  @proxy_port = nil
  @last_request = nil
  @last_response = nil
  @request_id = ""
  @use_mocks = false
  @connections = []
  @active = 0
  @auto_redirect = true
  @log_files = {}
  @create_stats = false
  @stats = {
    all: {
      num_requests: 0,
      time_elapsed: {
        total: 0,
        maximum: 0,
        minimum: 100000,
        average: 0,
      },
      method: {},
    },
    path: {},
    name: {},
  }
end

Instance Method Details

#close ⇒ Object

Close HTTP connection



392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
 
# File 'lib/nice_http.rb', line 392

def close
  begin
    pos = 0
    found = false
    self.class.connections.each { |conn|
      if conn.object_id == self.object_id
        found = true
        break
      else
        pos += 1
      end
    }
    if found
      self.class.connections.delete_at(pos)
    end

    unless @closed
      if !@http.nil?
        @http.finish()
        @http = nil
        @logger.info "the HTTP connection was closed: #{@message_server}"
      else
        @http = nil
        @logger.fatal "It was not possible to close the HTTP connection: #{@message_server}"
      end
      @closed = true
    else
      @logger.warn "It was not possible to close the HTTP connection, already closed: #{@message_server}"
    end
  rescue Exception => stack
    @logger.fatal stack
  end
  self.class.active -= 1
end