require 'nokogiri'
require 'fog/core/parser'

module Fog
  module AWS

    extend Fog::Provider

    service_path 'fog/aws'
    service 'cdn'
    service 'compute'
    service 'ec2'
    service 'elb'
    service 'iam'
    service 's3'
    service 'simpledb'
    service 'storage'

    def self.indexed_param(key, values)
      params = {}
      unless key.include?('%d')
        key << '.%d'
      end
      [*values].each_with_index do |value, index|
        params[format(key, index + 1)] = value
      end
      params
    end

    def self.indexed_filters(filters)
      params = {}
      filters.keys.each_with_index do |key, key_index|
        key_index += 1
        params[format('Filter.%d.Name', key_index)] = key
        [*filters[key]].each_with_index do |value, value_index|
          value_index += 1
          params[format('Filter.%d.Value.%d', key_index, value_index)] = value
        end
      end
      params
    end

    def self.signed_params(params, options = {})
      params.merge!({
        'AWSAccessKeyId'    => options[:aws_access_key_id],
        'SignatureMethod'   => 'HmacSHA256',
        'SignatureVersion'  => '2',
        'Timestamp'         => Time.now.utc.strftime("%Y-%m-%dT%H:%M:%SZ"),
        'Version'           => options[:version]
      })

      body = ''
      for key in params.keys.sort
        unless (value = params[key]).nil?
          body << "#{key}=#{CGI.escape(value.to_s).gsub(/\+/, '%20')}&"
        end
      end
      string_to_sign = "POST\n#{options[:host]}\n#{options[:path]}\n" << body.chop
      signed_string = options[:hmac].sign(string_to_sign)
      body << "Signature=#{CGI.escape(Base64.encode64(signed_string).chomp!).gsub(/\+/, '%20')}"

      body
    end

    class Mock

      def self.availability_zone
        "us-east-1" << random_selection('abcd', 1)
      end

      def self.box_usage
        sprintf("%0.10f", rand / 100).to_f
      end

      def self.dns_name_for(ip_address)
        "ec2-#{ip_address.gsub('.','-')}.compute-1.amazonaws.com"
      end

      def self.private_dns_name_for(ip_address)
        "ip-#{ip_address.gsub('.','-')}.ec2.internal"
      end

      def self.etag
        hex(32)
      end

      def self.image
        path = []
        (rand(3) + 2).times do
          path << letters(rand(9) + 8)
        end
        {
          "imageOwnerId"   => letters(rand(5) + 4),
          "blockDeviceMapping" => [],
          "productCodes"   => [],
          "kernelId"       => kernel_id,
          "ramdiskId"      => ramdisk_id,
          "imageState"     => "available",
          "imageId"        => image_id,
          "architecture"   => "i386",
          "isPublic"       => true,
          "imageLocation"  => path.join('/'),
          "imageType"      => "machine",
          "rootDeviceType" => ["ebs","instance-store"][rand(2)],
          "rootDeviceName" => "/dev/sda1"
        }
      end

      def self.image_id
        "ami-#{hex(8)}"
      end

      def self.key_fingerprint
        fingerprint = []
        20.times do
          fingerprint << hex(2)
        end
        fingerprint.join(':')
      end

      def self.instance_id
        "i-#{hex(8)}"
      end

      def self.ip_address
        ip = []
        4.times do
          ip << numbers(rand(3) + 1).to_i.to_s # remove leading 0
        end
        ip.join('.')
      end

      def self.kernel_id
        "aki-#{hex(8)}"
      end

      def self.key_material
        key_material = ['-----BEGIN RSA PRIVATE KEY-----']
        20.times do
          key_material << base64(76)
        end
        key_material << base64(67) + '='
        key_material << '-----END RSA PRIVATE KEY-----'
        key_material.join("\n")
      end

      def self.owner_id
        numbers(12)
      end

      def self.ramdisk_id
        "ari-#{hex(8)}"
      end

      def self.request_id
        request_id = []
        request_id << hex(8)
        3.times do
          request_id << hex(4)
        end
        request_id << hex(12)
        request_id.join('-')
      end

      def self.reservation_id
        "r-#{hex(8)}"
      end

      def self.snapshot_id
        "snap-#{hex(8)}"
      end

      def self.volume_id
        "vol-#{hex(8)}"
      end

      private
      
      def self.random_selection(characters, length)
        selection = ''
        length.times do
          position = rand(characters.length)
          selection << characters[position..position]
        end
        selection
      end

      def self.letters(length)
        random_selection(
          'abcdefghijklmnopqrstuvwxyz',
          length
        )
      end

      def self.numbers(length)
        max = ('9' * length).to_i
        rand(max).to_s
      end

      def self.hex(length)
        max = ('f' * length).to_i(16)
        rand(max).to_s(16).rjust(length, '0')
      end

      def self.base64(length)
        random_selection(
          "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",
          length
        )
      end

    end
  end
end