Class: RequestLogAnalyzer::Request

Inherits:

Object

• Object
• RequestLogAnalyzer::Request

show all

Includes:

Converters

Defined in:

lib/request_log_analyzer/request.rb

Overview

Defined Under Namespace

Modules: Converters

Instance Attribute Summary (collapse)

• - (Object) attributes readonly

  Returns the value of attribute attributes.

• - (Object) file_format readonly

  Returns the value of attribute file_format.

• - (Object) lines readonly

  Returns the value of attribute lines.

Class Method Summary (collapse)

• + (Object) create(file_format, *hashes)

  Creates a new request that was parsed from the log with the given FileFormat.

Instance Method Summary (collapse)

• - (Object) <<(hash)

  Adds another line to the request.

• - (Object) add_line_hash(value_hash)

  Adds another line to the request using a plain hash.

• - (Object) add_parsed_line(parsed_line)

  Adds another line to the request when it is parsed in the LogParser.

• - (Boolean) completed?

  Checks whether this request is completed.

• - (Boolean) empty?

  Returns true if this request does not yet contain any parsed lines.

• - (Object) every(field)

  Returns an array of all the “field” values that were captured for this request.

• - (Object) first(field) (also: #[])

  Returns the value that was captured for the “field” of this request.

• - (Object) first_lineno
• - (Boolean) has_line_type?(line_type) (also: #=~)

  Checks whether the given line type was parsed from the log file for this request.

• - (Request) initialize(file_format, attributes = {}) constructor

  Initializes a new Request object.

• - (Object) last_lineno
• - (Object) timestamp

  Returns the first timestamp encountered in a request.

• - (Object) validate

  This function is called before a Requests is yielded.

Methods included from Converters

#convert_decimal, #convert_duration, #convert_epoch, #convert_eval, #convert_float, #convert_int, #convert_integer, #convert_nillable_string, #convert_path, #convert_string, #convert_sym, #convert_symbol, #convert_timestamp, #convert_traffic, #convert_value, #sanitize_parameters

96
97
98
99
100

# File 'lib/request_log_analyzer/request.rb', line 96

def initialize(file_format, attributes = {})
  @lines       = []
  @attributes  = attributes
  @file_format = file_format
end

92
93
94

# File 'lib/request_log_analyzer/request.rb', line 92

def attributes
  @attributes
end

92
93
94

# File 'lib/request_log_analyzer/request.rb', line 92

def file_format
  @file_format
end

92
93
94

# File 'lib/request_log_analyzer/request.rb', line 92

def lines
  @lines
end

104
105
106
107
108

# File 'lib/request_log_analyzer/request.rb', line 104

def self.create(file_format, *hashes)
  request = self.new(file_format)
  hashes.flatten.each { |hash| request << hash }
  return request
end

145
146
147

# File 'lib/request_log_analyzer/request.rb', line 145

def <<(hash)
  hash[:line_definition] ? add_parsed_line(hash) : add_line_hash(hash)
end

126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

# File 'lib/request_log_analyzer/request.rb', line 126

def add_line_hash(value_hash)
  @lines << value_hash
  if value_hash[:compound]
    value_hash.each do |key, value|
      if value_hash[:compound].include?(key)
        @attributes[key] = [] if @attributes[key].nil?
        @attributes[key] = [@attributes[key]] unless @attributes[key].is_a?(Array)
        @attributes[key] << value
      else
        @attributes[key] = value unless key == :compound || @attributes[key]
      end
    end
  else
    @attributes = value_hash.merge(@attributes)
  end
end

114
115
116
117
118
119
120
121

# File 'lib/request_log_analyzer/request.rb', line 114

def add_parsed_line (parsed_line)
  value_hash = parsed_line[:line_definition].convert_captured_values(parsed_line[:captures], self)
  value_hash[:line_type] = parsed_line[:line_definition].name
  value_hash[:lineno] = parsed_line[:lineno]
  value_hash[:source] = parsed_line[:source]
  value_hash[:compound] = parsed_line[:line_definition].compound
  add_line_hash(value_hash)
end

180
181
182
183
184
185
186
187
188

# File 'lib/request_log_analyzer/request.rb', line 180

def completed?
  header_found, footer_found = false, false
  @lines.each do |line|
    line_def = file_format.line_definitions[line[:line_type]]
    header_found = true if line_def.header
    footer_found = true if line_def.footer
  end
  header_found && footer_found
end

173
174
175

# File 'lib/request_log_analyzer/request.rb', line 173

def empty?
  @lines.length == 0
end

167
168
169

# File 'lib/request_log_analyzer/request.rb', line 167

def every(field)
  @lines.inject([]) { |result, fields| result << fields[field] if fields.has_key?(field); result }
end

160
161
162

# File 'lib/request_log_analyzer/request.rb', line 160

def first(field)
  @attributes[field]
end

199
200
201

# File 'lib/request_log_analyzer/request.rb', line 199

def first_lineno
  @lines.map { |line| line[:lineno] }.reject { |v| v.nil? }.min
end

150
151
152
153

# File 'lib/request_log_analyzer/request.rb', line 150

def has_line_type?(line_type)
  return true if @lines.length == 1 && @lines[0][:line_type] == line_type.to_sym
  @lines.detect { |l| l[:line_type] == line_type.to_sym }
end

203
204
205

# File 'lib/request_log_analyzer/request.rb', line 203

def last_lineno
  @lines.map { |line| line[:lineno] }.reject { |v| v.nil? }.max
end

195
196
197

# File 'lib/request_log_analyzer/request.rb', line 195

def timestamp
  first(:timestamp)
end

191
192

# File 'lib/request_log_analyzer/request.rb', line 191

def validate
end