require 'fluent/config'

module Fluent
  module Mixin
    module PlainTextFormatter
      attr_accessor :output_include_time, :output_include_tag, :output_data_type
      attr_accessor :add_newline, :field_separator
      attr_accessor :remove_prefix, :default_tag

      attr_accessor :f_separator

      def first_value(*args)
        args.reduce{|a,b| (not a.nil?) ? a : b}
      end

      def configure(conf)
        super

        @output_include_time = first_value( Fluent::Config.bool_value(conf['output_include_time']), @output_include_time, true )
        @output_include_tag = first_value( Fluent::Config.bool_value(conf['output_include_tag']), @output_include_tag, true )

        @output_data_type = first_value( conf['output_data_type'], @output_data_type, 'json' )

        @field_separator = first_value( conf['field_separator'], @field_separator, 'TAB' )
        @f_separator = case @field_separator
                       when /SPACE/i then ' '
                       when /COMMA/i then ','
                       when /SOH/i then "\x01"
                       else "\t"
                       end

        @add_newline = first_value( Fluent::Config.bool_value(conf['add_newline']), @add_newline, true )

        @remove_prefix = conf['remove_prefix']
        if @remove_prefix
          @removed_prefix_string = @remove_prefix + '.'
          @removed_length = @removed_prefix_string.length
        end
        if @output_include_tag and @remove_prefix and @remove_prefix.length > 0
          @default_tag = first_value( conf['default_tag'], @default_tag, nil )
          if @default_tag.nil? or @default_tag.length < 1
            raise Fluent::ConfigError, "Missing 'default_tag' with output_include_tag and remove_prefix."
          end
        end

        # default timezone: utc
        if not conf.has_key?('localtime') and not conf.has_key?('utc')
          @localtime = false
        elsif conf.has_key?('localtime')
          @localtime = true
        elsif conf.has_key?('utc')
          @localtime = false
        end
        # mix-in default time formatter (or you can overwrite @timef on your own configure)
        @time_format = first_value( conf['time_format'], @time_format, nil )
        @timef = @output_include_time ? Fluent::TimeFormatter.new(@time_format, @localtime) : nil

        @custom_attributes = if @output_data_type == 'json'
                               nil
                             elsif @output_data_type =~ /^attr:(.+)$/
                               $1.split(',')
                             else
                               raise Fluent::ConfigError, "invalid output_data_type:'#{@output_data_type}'"
                             end
      end

      def stringify_record(record)
        if @custom_attributes.nil?
          record.to_json
        else
          @custom_attributes.map{|attr|
            (record[attr] || 'NULL').to_s
          }.join(@f_separator)
        end
      end

      def format(tag, time, record)
        if @remove_prefix
          if tag.start_with?(@removed_prefix_string) and tag.length > @removed_length
            tag = tag[@removed_length..-1]
          elsif tag == @remove_prefix
            tag = @default_tag
          end
        end
        time_str = if @output_include_time
                     @timef.format(time) + @f_separator
                   else
                     ''
                   end
        tag_str = if @output_include_tag
                    tag + @f_separator
                  else
                    ''
                  end
        time_str + tag_str + stringify_record(record) + (@add_newline ? "\n" : '')
      end
    end
  end
end