# encoding: UTF-8
#
# Copyright (c) 2010-2018 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.

module GoodData
  module LCM2
    class Helpers
      DEFAULT_TABLE_NAME = 'LCM_RELEASE'
      DEFAULT_NFS_DIRECTORY = '/release-tables'

      class << self
        def latest_master_project_from_ads(release_table_name, ads_client, segment_id)
          sorted = get_master_project_list_from_ads(release_table_name, ads_client, segment_id)
          sorted.last
        end

        def latest_master_project_from_nfs(domain_id, data_product_id, segment_id)
          file_path = path_to_release_table_file(domain_id, data_product_id, segment_id)
          sorted = get_master_project_list_from_nfs(domain_id, data_product_id, segment_id)
          latest_master_project = sorted.last

          version_info = latest_master_project ? "master_pid=#{latest_master_project[:master_project_id]} version=#{latest_master_project[:version]}" : ""
          GoodData.gd_logger.info "Getting latest master project: file=#{file_path} domain=#{domain_id} data_product=#{data_product_id} segment=#{segment_id} #{version_info}"
          latest_master_project
        end

        def get_master_project_list_from_ads(release_table_name, ads_client, segment_id)
          replacements = {
            table_name: release_table_name || DEFAULT_TABLE_NAME,
            segment_id: segment_id
          }

          path = File.expand_path('../../data/select_from_lcm_release.sql.erb', __FILE__)
          query = GoodData::Helpers::ErbHelper.template_file(path, replacements)

          res = ads_client.execute_select(query)
          sorted = res.sort_by { |row| row[:version] }
          sorted
        end

        def delete_master_project_from_ads(release_table_name, ads_client, segment_id, removal_master_project_ids)
          replacements = {
            table_name: release_table_name || DEFAULT_TABLE_NAME,
            segment_id: segment_id,
            master_project_ids: removal_master_project_ids.map { |x| "'#{x}'" } * ', '
          }

          path = File.expand_path('../data/delete_from_lcm_release.sql.erb', __dir__)
          query = GoodData::Helpers::ErbHelper.template_file(path, replacements)

          ads_client.execute(query)
        end

        def get_master_project_list_from_nfs(domain_id, data_product_id, segment_id)
          file_path = path_to_release_table_file(domain_id, data_product_id, segment_id)
          data = GoodData::Helpers::Csv.read_as_hash(file_path)
          sorted = data.sort_by { |master| master[:version] }
          sorted
        end

        def update_latest_master_to_nfs(domain_id, data_product_id, segment_id, master_pid, version)
          file_path = path_to_release_table_file(domain_id, data_product_id, segment_id)
          GoodData.gd_logger.info "Updating release table: file=#{file_path} domain=#{domain_id} data_product=#{data_product_id} segment=#{segment_id} master_pid=#{master_pid} version=#{version}" # rubocop:disable Metrics/LineLength
          GoodData::Helpers::Csv.ammend_line(
            file_path,
            master_project_id: master_pid,
            version: version
          )
        end

        def update_master_project_to_nfs(domain_id, data_product_id, segment_id, data)
          file_path = path_to_release_table_file(domain_id, data_product_id, segment_id)
          FileUtils.mkpath(file_path.split('/')[0...-1].join('/'))
          CSV.open(file_path, 'w', write_headers: true, headers: data.first.keys) do |csv|
            data.each do |r|
              csv << r.values
            end
          end
        end

        def path_to_release_table_file(domain_id, data_prod_id, segment_id)
          nsf_directory = ENV['RELEASE_TABLE_NFS_DIRECTORY'] || DEFAULT_NFS_DIRECTORY
          [nsf_directory, domain_id, data_prod_id + '-' + segment_id + '.csv'].join('/')
        end
      end
    end
  end
end