lib/fusuma/plugin/parsers/parser.rb in fusuma-2.0.0.pre vs lib/fusuma/plugin/parsers/parser.rb in fusuma-2.0.0.pre2
- old
+ new
@@ -1,8 +1,8 @@
# frozen_string_literal: true
-require_relative '../base.rb'
+require_relative '../base'
module Fusuma
module Plugin
module Parsers
# Parser change record and tag in event
@@ -11,28 +11,27 @@
# Parse Event and convert Record and Tag
# if `#parse_record` return nil, this method will return original event
# @param event [Event]
# @return [Event]
def parse(event)
- event.tap do |e|
- next if e.tag != source
+ return event if event.tag != source
- new_record = parse_record(e.record)
- next unless new_record
+ new_record = parse_record(event.record)
+ return event if new_record.nil?
- e.record = new_record
- e.tag = tag
- end
+ event.record = new_record
+ event.tag = tag
+ event
end
# Set source for tag from config.yml.
# DEFAULT_SOURCE is defined in each Parser plugins.
def source
@source ||= config_params(:source) || self.class.const_get('DEFAULT_SOURCE')
end
def tag
- self.class.name.split('::').last.underscore
+ @tag ||= self.class.name.split('::').last.underscore
end
# parse Record object
# @param _record [Record]
# @return [Record, nil]