module Fog
  module AWS
    class Compute
      class Address < Fog::Model
        identity  :public_ip,                  :aliases => 'publicIp'

        attribute :private_ip_address,         :aliases => 'privateIpAddress'
        attribute :allocation_id,              :aliases => 'allocationId'
        attribute :association_id,             :aliases => 'associationId'
        attribute :server_id,                  :aliases => 'instanceId'
        attribute :network_interface_id,       :aliases => 'networkInterfaceId'
        attribute :network_interface_owner_id, :aliases => 'networkInterfaceOwnerId'
        attribute :tags,                       :aliases => 'tagSet'
        attribute :domain

        def initialize(attributes = {})
          # assign server first to prevent race condition with persisted?
          self.server = attributes.delete(:server)
          super
        end

        def destroy
          requires :public_ip

          service.release_address(allocation_id || public_ip)
          true
        end

        def change_scope
          if self.domain == 'standard'
            service.move_address_to_vpc(self.identity)
            wait_for { self.domain == 'vpc' }
          else
            service.restore_address_to_classic(self.identity)
            wait_for { self.domain == 'standard' }
          end
        end

        def server=(new_server)
          if new_server
            associate(new_server)
          else
            disassociate
          end
        end

        def server
          service.servers.get(server_id)
        end

        def save
          raise Fog::Errors::Error.new('Resaving an existing object may create a duplicate') if persisted?
          data = service.allocate_address(domain).body
          new_attributes = data.reject {|key,value| key == 'requestId'}
          merge_attributes(new_attributes)
          if @server
            self.server = @server
          end
          true
        end

        private

        def associate(new_server)
          unless persisted?
            @server = new_server
          else
            @server = nil
            self.server_id = new_server.id
            service.associate_address(server_id, public_ip, network_interface_id, allocation_id)
          end
        end

        def disassociate
          @server = nil
          self.server_id = nil
          if persisted?
            if association_id
              service.disassociate_address(nil, association_id)
            else
              service.disassociate_address(public_ip)
            end
          end
        end
      end
    end
  end
end