using OpsManagerUiDrivers::BackportRefinements

module OpsManagerUiDrivers
  module Version17
    class OpsManagerDirector
      def initialize(browser:, iaas_configuration: Version17::BoshProductSections::IaasConfiguration.new(browser: browser))
        @browser            = browser
        @iaas_configuration = iaas_configuration
      end

      def configure_bosh_product(test_settings)
        configure_iaas(test_settings)

        config_director(test_settings.dig('ops_manager'))

        add_availability_zones(test_settings.dig('iaas_type'), test_settings.dig('ops_manager', 'availability_zones'))

        add_networks(test_settings)

        assign_azs_and_networks(test_settings.dig('iaas_type'), test_settings.dig('ops_manager', 'availability_zones'), test_settings.dig('ops_manager'))

        configure_experimental_features(test_settings.dig('ops_manager', 'experimental_features'))
      end

      def configure_iaas(test_settings)
        iaas_settings                         = Settings.for(test_settings)
        iaas_specific_fields                  = iaas_settings.iaas_configuration_fields
        advanced_infrastructure_config_fields = iaas_settings.advanced_infrastructure_config_fields
        iaas_configuration.fill_iaas_settings(iaas_specific_fields)
        advanced_infrastructure_config.fill_advanced_infrastructure_config_settings(advanced_infrastructure_config_fields)
      end

      def add_availability_zones(iaas_type, iaas_availability_zones)
        case iaas_type
          when OpsManagerUiDrivers::AWS_IAAS_TYPE, OpsManagerUiDrivers::OPENSTACK_IAAS_TYPE
            return unless iaas_availability_zones
            availability_zones.add_single_az(iaas_availability_zones.first['iaas_identifier'])
          when OpsManagerUiDrivers::VSPHERE_IAAS_TYPE
            iaas_availability_zones && iaas_availability_zones.each do |az|
              availability_zones.add_az('name' => az['name'], 'cluster' => az['cluster'], 'resource_pool' => az['resource_pool'])
            end
        end
      end

      def add_networks(test_settings)
        iaas_networks = test_settings.dig('ops_manager', 'networks')

        iaas_networks && iaas_networks.each do |network|
          networks.add_network(
            name:                    network['name'],
            iaas_network_identifier: network['identifier'],
            subnet:                  network['subnet'],
            reserved_ip_ranges:      network['reserved_ips'],
            dns:                     network['dns'],
            gateway:                 network['gateway'],
          )
        end
      end

      def delete_network(network_name)
        networks.delete_network(network_name)
      end

      def config_director(ops_manager)
        browser.click_on 'Director Config'
        browser.fill_in('director_configuration[ntp_servers_string]', with: ops_manager.dig('ntp_servers'))
        browser.check('Enable VM Resurrector Plugin') if ops_manager.dig('resurrector_enabled')

        s3_blobstore = ops_manager.dig('s3_blobstore')
        if s3_blobstore
          browser.choose('S3 Compatible Blobstore')
          browser.fill_in('director_configuration[s3_blobstore_options][endpoint]', with: s3_blobstore.dig('endpoint'))
          browser.fill_in('director_configuration[s3_blobstore_options][bucket_name]', with: s3_blobstore.dig('bucket_name'))
          browser.fill_in('director_configuration[s3_blobstore_options][access_key]', with: s3_blobstore.dig('access_key_id'))
          browser.fill_in('director_configuration[s3_blobstore_options][secret_key]', with: s3_blobstore.dig('secret_access_key'))
        end

        mysql = ops_manager.dig('mysql')
        if mysql
          browser.choose('External MySQL Database')
          browser.fill_in('director_configuration[external_database_options][host]', with: mysql.dig('host'))
          browser.fill_in('director_configuration[external_database_options][port]', with: mysql.dig('port'))
          browser.fill_in('director_configuration[external_database_options][user]', with: mysql.dig('user'))
          browser.fill_in('director_configuration[external_database_options][password]', with: mysql.dig('password'))
          browser.fill_in('director_configuration[external_database_options][database]', with: mysql.dig('dbname'))
        end

        browser.click_on 'Save'
      end

      def assign_azs_and_networks(iaas_type, iaas_availability_zones, ops_manager)
        case iaas_type
          when OpsManagerUiDrivers::AWS_IAAS_TYPE, OpsManagerUiDrivers::OPENSTACK_IAAS_TYPE
            browser.click_on 'Assign AZs and Networks'
            browser.select(ops_manager.dig('networks', 0, 'name'), from: 'Network')
            browser.select(iaas_availability_zones.first['iaas_identifier'])
          when OpsManagerUiDrivers::VSPHERE_IAAS_TYPE
            browser.click_on 'Assign AZs and Networks'
            browser.select(ops_manager.dig('networks', 0, 'name'), from: 'Network')
            browser.select(iaas_availability_zones.first['name'])
          when OpsManagerUiDrivers::VCLOUD_IAAS_TYPE
            browser.click_on 'Assign Networks'
            browser.select(ops_manager.dig('networks', 0, 'name'), from: 'Network')
        end
        browser.click_on 'Save'
      end

      def configure_vm_passwords(use_generated_passwords: true)
        browser.click_on 'Security'
        if use_generated_passwords
          browser.choose('Generate passwords')
        else
          browser.choose('Use default BOSH password')
        end
        browser.click_on 'Save'
        browser.poll_up_to_times(20) { browser.assert_text('Settings updated') }
      end

      # WARNING: these features are experimental and may change or disappear in later versions of opsman
      def configure_experimental_features(experimental_features)
        browser.click_on 'Experimental Features'

        trusted_certificates = experimental_features ? experimental_features.dig('trusted_certificates') : ''

        browser.fill_in('experimental_features[trusted_certificates]', with: trusted_certificates)
      end

      def selected_network_name(iaas_type)
        case iaas_type
          when OpsManagerUiDrivers::VCLOUD_IAAS_TYPE
            browser.click_on 'Assign Networks'
          else
            browser.click_on 'Assign AZs and Networks'
        end
        selected_options = browser.find_field('Network').all('option[selected]')
        selected_options.first.text unless selected_options.empty?
      end

      def selected_singleton_az_name(iaas_type)
        case iaas_type
          when OpsManagerUiDrivers::VCLOUD_IAAS_TYPE
            browser.click_on 'Assign Networks'
          else
            browser.click_on 'Assign AZs and Networks'
        end
        selected_options = browser.find_field('bosh_product[singleton_availability_zone_reference]').all('option[selected]')
        selected_options.first.text unless selected_options.empty?
      end

      private

      attr_reader :browser, :iaas_configuration


      def availability_zones
        @availability_zones ||= Version17::BoshProductSections::AvailabilityZones.new(browser: browser)
      end

      def networks
        @networks ||= Version17::BoshProductSections::Networks.new(browser: browser)
      end

      def advanced_infrastructure_config
        @advanced_infrastructure_config ||= Version17::BoshProductSections::AdvancedInfrastructureConfig.new(browser: browser)
      end
    end
  end
end