require "prepare_embulk"
require "embulk/guess/query_string"
require "embulk/data_source"

module Embulk
  module Guess
    class QueryStringTest < Test::Unit::TestCase
      class TestGuessLines < self
        data do
          {
            same_keys: [sample_lines_with_same_keys, schema_with_same_keys],
            different_keys: [sample_lines_with_different_keys, schema_with_different_keys],
            invalid: [sample_lines_with_invalid, schema_with_invalid],

          }
        end

        def test_schema(data)
          sample_lines, schema = data
          actual = QueryString.new.guess_lines(config, sample_lines)
          expected = {
            "parser" => {
              type: "query_string",
              schema: schema
            }
          }
          assert_equal(expected, actual)
        end

        data do
          valid_schema = {
            "parser" => {
              type: "query_string",
              schema: schema_with_same_keys,
            }
          }

          {
            "query_string" => ["query_string", valid_schema],
            "other" => ["other", {}],
          }
        end

        def test_type(data)
          type, expected = data
          sample_lines = self.class.sample_lines_with_same_keys
          config = DataSource[{"parser" => {"type" => type}}]

          actual = QueryString.new.guess_lines(config, sample_lines)
          assert_equal(expected, actual)
        end
      end

      private

      class << self
        def sample_lines_with_same_keys
          [
            %Q(foo=1&bar=vv&baz=3),
            %Q(foo=2&bar=ss&baz=a),
          ]
        end

        def schema_with_same_keys
          [
            {name: "foo", type: :long},
            {name: "bar", type: :string},
            {name: "baz", type: :string},
          ]
        end

        def sample_lines_with_different_keys
          [
            %Q(foo=1&bar=vv&baz=3&hoge=999),
            %Q(foo=2&bar=ss&baz=a&xxx=ABC),
          ]
        end

        def schema_with_different_keys
          [
            {name: "foo", type: :long},
            {name: "bar", type: :string},
            {name: "baz", type: :string},
            {name: "hoge", type: :long},
            {name: "xxx", type: :string},
          ]
        end

        def sample_lines_with_invalid
          [
            %Q(foo=1&bar=vv&baz=3),
            %Q(this=line=is=invalid),
            %Q(foo=2&bar=ss&baz=a),
          ]
        end

        def schema_with_invalid
          schema_with_same_keys
        end
      end

      def task
        {
          strip_quote: true,
          strip_whitespace: true,
          schema: columns,
        }
      end

      def columns
        [
          {"name" => "foo", "type" => "string"},
          {"name" => "bar", "type" => "string"},
        ]
      end

      def config
        DataSource[task.to_a]
      end
    end
  end
end