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]