# 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 UpdateReleaseTable < BaseAction
      DESCRIPTION = 'Update Release Table'

      PARAMS = define_params(self) do
        description 'ADS Client'
        param :ads_client, instance_of(Type::AdsClientType), required: true

        description 'Client Used for Connecting to GD'
        param :gdc_gd_client, instance_of(Type::GdClientType), required: true

        description 'Organization Name'
        param :organization, instance_of(Type::StringType), required: false

        description 'Domain'
        param :domain, instance_of(Type::StringType), required: false

        description 'Segments to manage'
        param :segments, array_of(instance_of(Type::SegmentType)), required: true

        description 'Table Name'
        param :release_table_name, instance_of(Type::StringType), required: false

        description 'Query'
        param :query, instance_of(Type::GdSmartHashType), required: false
      end

      DEFAULT_TABLE_NAME = 'LCM_RELEASE'

      class << self
        def call(params)
          client = params.gdc_gd_client

          domain_name = params.organization || params.domain
          fail "Either organisation or domain has to be specified in params" unless domain_name
          client.domain(domain_name) || fail("Invalid domain name specified - #{domain_name}")

          params.segments.map do |segment_in|
            segment_id = segment_in.segment_id

            placeholders = {
              segment_id: segment_in[:segment_id],
              master_project_id: segment_in[:master_pid],
              version: segment_in[:version],
              timestamp: segment_in[:timestamp],
              table_name: params.release_table_name || DEFAULT_TABLE_NAME
            }

            update_release_table(params, placeholders)

            {
              segment: segment_id,
              master_pid: segment_in[:master_pid],
              version: segment_in[:version],
              timestamp: segment_in[:timestamp]
            }
          end
        end

        def replace_placeholders(text, placeholders)
          result = text.dup
          placeholders.each do |k, v|
            result.gsub!("\#{#{k}}", v.to_s)
          end
          result
        end

        def update_release_table(params, placeholders)
          query = if placeholders[:version] > 1
                    path = File.expand_path('../../data/update_lcm_release.sql.erb', __FILE__)
                    default_query = GoodData::Helpers::ErbHelper.template_file(path, placeholders)

                    temp_query = (params.query && params.query[:update]) || default_query
                    replace_placeholders(temp_query, placeholders)
                  else
                    path = File.expand_path('../../data/insert_into_lcm_release.sql.erb', __FILE__)
                    default_query = GoodData::Helpers::ErbHelper.template_file(path, placeholders)
                    temp_query = (params.query && params.query.insert) || default_query
                    replace_placeholders(temp_query, placeholders)
                  end

          params.ads_client.execute(query)
        end
      end
    end
  end
end