# encoding: UTF-8
#
# Copyright (c) 2010-2017 GoodData Corporation. All rights reserved.
# This source code is licensed under the BSD-style license found in the
# LICENSE file in the root directory of this source tree.

require_relative 'base_action'

module GoodData
  module LCM2
    class CollectUsersBrickUsers < BaseAction
      DESCRIPTION = 'Enriches parameters with users from the Users Brick input.'

      PARAMS = define_params(self) do
        description 'Input source of the Users Brick. Needed to prevent ' \
                    'deletion of filters for a user that is to be removed.'
        param :users_brick_config, instance_of(Type::UsersBrickConfig), required: true

        description 'Column That Contains Target Project IDs'
        param :multiple_projects_column, instance_of(Type::StringType), required: true

        description 'Input Source'
        param :input_source, instance_of(Type::HashType), required: false

        description 'Synchronization Mode (e.g. sync_one_project_based_on_pid)'
        param :sync_mode, instance_of(Type::StringType), required: false, default: 'sync_project'
      end

      MULTIPLE_COLUMN_MODES = %w(
        sync_domain_client_workspaces
        sync_multiple_projects_based_on_custom_id
        sync_multiple_projects_based_on_pid
      )

      class << self
        def call(params)
          users_brick_users = []
          login_column = params.users_brick_config.login_column&.downcase || 'login'
          users_brick_data_source = GoodData::Helpers::DataSource.new(params.users_brick_config.input_source)

          users_brick_data_source_file = without_check(PARAMS, params) do
            File.open(
              users_brick_data_source.realize(params),
              'r:UTF-8'
            )
          end
          CSV.foreach(users_brick_data_source_file,
                      :headers => true,
                      :return_headers => false,
                      :header_converters => :downcase,
                      :encoding => 'utf-8') do |row|
            pid = row[params.multiple_projects_column&.downcase]
            fail "The set multiple_projects_column '#{params.multiple_projects_column}' of the users input is empty" if !pid && MULTIPLE_COLUMN_MODES.include?(params.sync_mode)

            users_brick_users << {
              login: row[login_column].nil? ? nil : row[login_column].strip.downcase,
              pid: pid
            }
          end
          {
            # TODO; TMA-989 return the real results when print of results is fixed for large sets
            results: [{ status: 'ok' }],
            params: {
              users_brick_users: users_brick_users
            }
          }
        end
      end
    end
  end
end