#   fog:vcair:<vcair host>
class Chef
  module Provisioning
    module FogDriver
      module Providers
        class Vcair < FogDriver::Driver
          Driver.register_provider_class('vcair', FogDriver::Providers::Vcair)

          def creator
            driver_options[:username]
          end

          def initialize(driver_url, config)
            super(driver_url, config)

            @auth_params = {provider: 'vclouddirector'}
            _fog, _vcair, @auth_params[:vcloud_director_host] = driver_url.split(':', 3)
            @auth_params[:vcloud_director_username] = "#{driver_options[:username]}@#{driver_options[:org]}"
            @auth_params[:vcloud_director_password] = driver_options[:password]
            @auth_params[:vcloud_director_show_progress] = driver_options[:show_progress] || false
            Chef::Log.debug('Initialized driver for vcair')
          end

          def compute
            @compute ||= begin
                           Fog::Compute.new(@auth_params)
                         rescue Excon::Errors::Unauthorized => e
                           error_message = "Connection failure, please check your username and password."
                           Chef::Log.error(error_message)
                           raise "#{e.message}. #{error_message}"
                         rescue Excon::Errors::SocketError => e
                           error_message = "Connection failure, please check your authentication URL."
                           Chef::Log.error(error_message)
                           raise "#{e.message}. #{error_message}"
                         end
          end

          # Overrides the parent method and adds some additional vCloud specific metadata
          def create_servers(action_handler, specs_and_options, parallelizer, &block)

            specs_and_options.each do |machine_spec, machine_options|
              machine_spec.reference ||= {}
              # Add some vCloud info to the machine_spec
              bootstrap_options = bootstrap_options_for(machine_spec, machine_options)
              machine_spec.reference['vdc'] = vdc(bootstrap_options).name
              machine_spec.reference['net'] = net(bootstrap_options).name

              # Save the key and whether we're using sudo
              machine_spec.reference['key_name'] = bootstrap_options[:key_name] if bootstrap_options.has_key?(:key_name)
              machine_spec.reference['sudo'] = bootstrap_options[:sudo] if bootstrap_options.has_key?(:sudo)
            end

            super
          end

          def create_many_servers(num_servers, bootstrap_options, parallelizer)
            parallelizer.parallelize(1.upto(num_servers)) do |i|
              clean_bootstrap_options = Marshal.load(Marshal.dump(bootstrap_options)) # Prevent destructive operations on bootstrap_options.
              vm=nil
              begin
                begin
                  Chef::Log.debug('Creating vApp...')
                  instantiate(clean_bootstrap_options)
                  Chef::Log.debug('Created vApp')
                rescue Fog::Errors::Error => e
                  unless e.minor_error_code == "DUPLICATE_NAME"
                    # if it's already there, just use the current one
                    raise e
                  end
                  Chef::Log.warn('Found existing vApp with the same name!')
                end
                vdc = vdc(clean_bootstrap_options)

                Chef::Log.debug("Searching for #{bootstrap_options[:name]}...")
                vapp = vdc.vapps.get_by_name(clean_bootstrap_options[:name])
                raise "Couldn't find vApp #{bootstrap_options[:name]} that was just created!" if vapp.nil?
                vm = vapp.vms.find {|v| v.vapp_name == clean_bootstrap_options[:name]}
                raise "No VMs found in vApp!" if vm.nil?
                Chef::Log.debug("Found #{vm.name}")
                update_customization(clean_bootstrap_options, vm)

                if bootstrap_options[:cpus]
                  vm.cpu = clean_bootstrap_options[:cpus]
                end
                if bootstrap_options[:memory]
                  vm.memory = clean_bootstrap_options[:memory]
                end

                Chef::Log.debug("Updating network for #{vm.name}...")
                update_network(clean_bootstrap_options, vapp, vm)
                Chef::Log.debug("Updated network for #{vm.name}")

              rescue Excon::Errors::BadRequest => e
                response = Chef::JSONCompat.from_json(e.response.body)
                if response['badRequest']['code'] == 400
                  message = "Bad request (400): #{response['badRequest']['message']}"
                  Chef::Log.error(message)
                else
                  message = "Unknown server error (#{response['badRequest']['code']}): #{response['badRequest']['message']}"
                  Chef::Log.error(message)
                end
                raise message
              rescue Fog::Errors::Error => e
                raise e.message
              end

              yield vm if block_given?
              vm

            end.to_a
          end


          def start_server(action_handler, machine_spec, server)

            # If it is stopping, wait for it to get out of "stopping" transition state before starting
            if server.status == 'stopping'
              action_handler.report_progress "wait for #{machine_spec.name} (#{server.id} on #{driver_url}) to finish stopping ..."
              # vCloud Air
              # NOTE: vCloud Air Fog does not get server.status via http every time
              server.wait_for { server.reload ; server.status != 'stopping' }
              action_handler.report_progress "#{machine_spec.name} is now stopped"
            end

            # NOTE: vCloud Air Fog does not get server.status via http every time
            server.reload

            if server.status == 'off' || server.status != 'on'
              action_handler.perform_action "start machine #{machine_spec.name} (#{server.id} on #{driver_url})" do
                server.power_on
                machine_spec.reference['started_at'] = Time.now.to_i
              end
              machine_spec.save(action_handler)
            end
          end


          def server_for(machine_spec)
            if machine_spec.reference
              Chef::Log.debug("Checking for VDC #{machine_spec.reference['vdc']}...")
              vapp = org.vdcs.get_by_name(machine_spec.reference['vdc']).vapps.get_by_name(machine_spec.name)

              server = unless vapp.nil?
                         unless vapp.vms.first.nil?
                           vapp.vms.find{|vm| vm.id == machine_spec.reference['server_id'] }
                         end
                       end
            else
              nil
            end
          end

          def servers_for(specs_and_options)
            result = {}
            specs_and_options.each do |machine_spec, _machine_options|
              result[machine_spec] = server_for(machine_spec)
            end
            result
          end

          # def ssh_options_for(machine_spec, machine_options, server)
          #   ssh_options = {
          #     auth_methods: ['password'],
          #     timeout: (machine_options[:ssh_timeout] || 600),
          #     password: machine_options[:ssh_password]
          #   }.merge(machine_options[:ssh_options] || {})
          # end

          def create_ssh_transport(machine_spec, machine_options, server)
            ssh_options = ssh_options_for(machine_spec, machine_options, server)
            username = machine_spec.reference['ssh_username'] || default_ssh_username
            options = {}
            if machine_spec.reference[:sudo] || (!machine_spec.reference.has_key?(:sudo) && username != 'root')
              options[:prefix] = 'sudo '
            end

            remote_host = nil
            # vCloud Air networking is funky
            #if machine_options[:use_private_ip_for_ssh] # vCloud Air probably needs private ip for now
            if server.ip_address
              remote_host = server.ip_address
            else
              raise "Server #{server.id} has no private or public IP address!"
            end

            #Enable pty by default
            options[:ssh_pty_enable] = true
            options[:ssh_gateway] = machine_spec.reference['ssh_gateway'] if machine_spec.reference.has_key?('ssh_gateway')

            Transport::SSH.new(remote_host, username, ssh_options, options, config)
          end

          def ready_machine(action_handler, machine_spec, machine_options)
            server = server_for(machine_spec)
            if server.nil?
              raise "Machine #{machine_spec.name} does not have a server associated with it, or server does not exist."
            end

            # Start the server if needed, and wait for it to start
            start_server(action_handler, machine_spec, server)
            wait_until_ready(action_handler, machine_spec, machine_options, server)

            # Attach/detach floating IPs if necessary
            # vCloud Air is funky for network.  VM has to be powered off or you get this error:
            #    Primary NIC cannot be changed when the VM is not in Powered-off state
            # See code in update_network()
            #DISABLED: converge_floating_ips(action_handler, machine_spec, machine_options, server)

            begin
              wait_for_transport(action_handler, machine_spec, machine_options, server)
            rescue Fog::Errors::TimeoutError
              # Only ever reboot once, and only if it's been less than 10 minutes since we stopped waiting
              if machine_spec.reference['started_at'] || remaining_wait_time(machine_spec, machine_options) < -(10*60)
                raise
              else
                # Sometimes (on EC2) the machine comes up but gets stuck or has
                # some other problem.  If this is the case, we restart the server
                # to unstick it.  Reboot covers a multitude of sins.
                Chef::Log.warn "Machine #{machine_spec.name} (#{server.id} on #{driver_url}) was started but SSH did not come up.  Rebooting machine in an attempt to unstick it ..."
                restart_server(action_handler, machine_spec, server)
                wait_until_ready(action_handler, machine_spec, machine_options, server)
                wait_for_transport(action_handler, machine_spec, machine_options, server)
              end
            end

            machine_for(machine_spec, machine_options, server)
          end

          def org
            @org ||= compute.organizations.get_by_name(driver_options[:org])
          end

          def vdc(bootstrap_options)
            if bootstrap_options[:vdc]
              @vdc ||= org.vdcs.get_by_name(bootstrap_options[:vdc])
              raise "VDC #{bootstrap_options[:vdc]} not found" unless @vdc
            else
              @vdc ||= org.vdcs.first
              raise 'No VDC found' unless @vdc
            end

            Chef::Log.debug("VDC set to #{@vdc.name}")
            @vdc
          end

          def net(bootstrap_options)
            if bootstrap_options[:net]
              @net ||= org.networks.get_by_name(bootstrap_options[:net])
              raise "Network #{bootstrap_options[:net]} not found" unless @net
            else
              # Grab first non-isolated (bridged, natRouted) network
              @net ||= org.networks.find { |n| n if !n.fence_mode.match("isolated") }
              raise 'No non-isolated network found' unless @net
            end

            Chef::Log.debug("Network set to #{@net.name}")
            @net
          end

          def template(bootstrap_options)
            # If we specify a catalog name, search for the image in it,
            # otherwise return the first image we find in any catalog.
            if bootstrap_options[:catalog_name].nil?
              #TODO: maybe make a hash for caching
              org.catalogs.map do |cat|
                #cat.catalog_items.get_by_name(config_value(:image))
                cat.catalog_items.get_by_name(bootstrap_options[:image_name])
              end.compact.first
            else
              catalog = org.catalogs.get_by_name(bootstrap_options[:catalog_name])
              raise "No catalog named #{bootstrap_options[:catalog_name]} could be found!" if catalog.nil?
              catalog.catalog_items.get_by_name(bootstrap_options[:image_name])
            end
          end

          def instantiate(bootstrap_options)
            #node_name = config_value(:chef_node_name)
            node_name = bootstrap_options[:name]
            vdc = vdc(bootstrap_options)
            net = net(bootstrap_options)

            template(bootstrap_options).instantiate(
              node_name,
              vdc_id: vdc.id,
              network_id: net.id,
              description: "id:#{node_name}")
            #rescue CloudExceptions::ServerCreateError => e
          end

          # Create a WinRM transport for a vCloud Air Vapp VM instance
          # @param [Hash] machine_spec Machine-spec hash
          # @param [Hash] machine_options Machine options (from the recipe)
          # @param [Fog::Compute::Server] server A Fog mapping to the AWS instance
          # @return [ChefMetal::Transport::WinRM] A WinRM Transport object to talk to the server
          def create_winrm_transport(machine_spec, machine_options, server)
            port = machine_spec.reference['winrm_port'] || 5985
            endpoint = "http://#{server.ip_address}:#{port}/wsman"
            type = :plaintext

            # Use basic HTTP auth - this is required for the WinRM setup we
            # are using
            # TODO: Improve that and support different users
            options = {
              :user => 'Administrator',
              :pass => machine_options[:winrm_options][:password],
              :disable_sspi => true,
              :basic_auth_only => true
            }
            Chef::Provisioning::Transport::WinRM.new(endpoint, type, options, {})
          end

          def update_customization(bootstrap_options, server)
            Chef::Log.debug("Customizing vApp: #{server.name}")
            ## Initialization before first power on.
            custom=server.customization

            if bootstrap_options[:customization_script]
              custom.script = open(bootstrap_options[:customization_script]).read
            end

            bootstrap_options[:protocol] ||= case server.operating_system
                                         when /Windows/
                                           'winrm'
                                         else
                                           'ssh'
                                         end
            password = case bootstrap_options[:protocol]
                       when 'ssh'
                         bootstrap_options[:ssh_options][:password] unless bootstrap_options[:ssh_options].nil?
                       when 'winrm'
                         bootstrap_options[:winrm_options][:password] unless bootstrap_options[:winrm_options].nil?
                       end

            if password
              custom.admin_password =  password
              custom.admin_password_auto = false
              custom.reset_password_required = false
            else
              # Password will be autogenerated
              custom.admin_password_auto=true
              # API will force password resets when auto is enabled
              custom.reset_password_required = true
            end

            # TODO: Add support for admin_auto_logon to Fog
            # c.admin_auto_logon_count = 100
            # c.admin_auto_logon_enabled = true

            # DNS and Windows want AlphaNumeric and dashes for hostnames
            # Windows can only handle 15 character hostnames
            custom.computer_name = case server.operating_system
                                   when /Windows/
                                     bootstrap_options[:name].gsub(/\W/,"-").slice(0..14)
                                   else
                                     bootstrap_options[:name]
                                   end

            custom.enabled = true
            custom.save
            Chef::Log.debug("vApp customized: #{server.name}")
          end

          ## vCloud Air
          ## TODO: make work with floating_ip junk currently used
          ## NOTE: current vCloud Air networking changes require VM to be powered off
          def update_network(bootstrap_options, vapp, vm)
            ## TODO: allow user to specify network to connect to (see above net used)
            # Define network connection for vm based on existing routed network

            # vCloud Air inlining vapp() and vm()
            #vapp = vdc.vapps.get_by_name(bootstrap_options[:name])
            #vm = vapp.vms.find {|v| v.vapp_name == bootstrap_options[:name]}
            return if vm.ip_address != "" # return if ip address is set, as this isn't a new VM
            Chef::Log.debug('No IP address found.  Must be a new VM.')
            net = net(bootstrap_options)
            Chef::Log.debug("Searching for network: #{net.name}")
            nc = vapp.network_config.find { |netc| netc if netc[:networkName].match(net.name) }
            Chef::Log.debug("Found network configuration: #{nc}")
            networks_config = [nc]
            section = {PrimaryNetworkConnectionIndex: 0}
            section[:NetworkConnection] = networks_config.compact.each_with_index.map do |network, i|
              connection = {
                network: network[:networkName],
                needsCustomization: true,
                NetworkConnectionIndex: i,
                IsConnected: true
              }
              ip_address      = network[:ip_address]
              ## TODO: support config options for allocation mode
              #allocation_mode = network[:allocation_mode]
              #allocation_mode = 'manual' if ip_address
              #allocation_mode = 'dhcp' unless %w{dhcp manual pool}.include?(allocation_mode)
              #allocation_mode = 'POOL'
              #connection[:Dns1] = dns1 if dns1
              allocation_mode = 'pool'
              connection[:IpAddressAllocationMode] = allocation_mode.upcase
              connection[:IpAddress] = ip_address if ip_address
              connection
            end

            ## attach the network to the vm
            nc_task = compute.put_network_connection_system_section_vapp(
              vm.id,section).body
            compute.process_task(nc_task)
          end

          def self.bootstrap_options_for(machine_spec, machine_options)
            bootstrap_options = machine_options.key?(:bootstrap_options) ? machine_options[:bootstrap_options] : {}
            bootstrap_options[:name] = machine_spec.name unless machine_spec.nil?

            bootstrap_options
          end

          def destroy_machine(action_handler, machine_spec, machine_options)
            server = server_for(machine_spec)
            Chef::Log.info("Destroying machine #{machine_spec.name}...")
            bootstrap_options = bootstrap_options_for(machine_spec, machine_options)
            vdc = vdc(bootstrap_options)
            if server && server.status != 'archive' # TODO: does vCloud Air do archive?
              action_handler.perform_action "destroy machine #{machine_spec.name} (#{machine_spec.reference['server_id']} at #{driver_url})" do
                #NOTE: currently doing 1 vm for 1 vapp
                vapp = vdc.vapps.get_by_name(machine_spec.name)
                if vapp
                  Chef::Log.debug("Found vApp #{machine_spec.name}")
                  vapp.power_off
                  vapp.undeploy
                  vapp.destroy
                else
                  Chef::Log.warn "No VApp named '#{server_name}' was found."
                end
              end
            end
            machine_spec.reference = nil
            strategy = convergence_strategy_for(machine_spec, machine_options)
            strategy.cleanup_convergence(action_handler, machine_spec)
          end

          def self.compute_options_for(provider, id, config)
            new_compute_options = {}
            new_compute_options[:provider] = 'vclouddirector'
            new_config = { :driver_options => { :compute_options => new_compute_options }}
            new_defaults = {
              :driver_options  => { :compute_options => {} },
              :machine_options => { :bootstrap_options => {}, :ssh_options => {} }
            }
            result = Cheffish::MergedConfig.new(new_config, config, new_defaults)

            [result, id]
          end
        end
      end
    end
  end
end