fog--fog/lib/fog/aws/models/ec2/instance.rb

module Fog
  module AWS
    class EC2

      class Instance < Fog::Model

        attribute :ami_launch_index,  'amiLaunchIndex'
        attribute :availability_zone, 'availabilityZone'
        attribute :dns_name,          'dnsName'
        attribute :group_id,          'groupId'
        attribute :image_id,          'imageId'
        attribute :instance_id,       'instanceId'
        attribute :instance_state,    'instanceState'
        attribute :instance_type,     'instanceType'
        attribute :kernel_id,         'kernelId'
        attribute :key_name,          'keyName'
        attribute :launch_time,       'launchTime'
        attribute :monitoring
        attribute :placement
        attribute :product_codes,     'productCodes'
        attribute :private_dns_name,  'privateDnsName'
        attribute :ramdisk_id,        'ramdiskId'
        attribute :reason
        attribute :user_data

        def address
          connection.addresses.select {|address| address.instance_id == @instance_id}.first
        end

        def address=(new_address)
          connection.associate_address(@instance_id, new_address.public_ip)
        end

        def delete
          connection.terminate_instances(@instance_id)
          true
        end

        def monitoring=(new_monitoring)
          if new_monitoring.is_a?(Hash)
            @monitoring = new_monitoring['state']
          else
            @monitoring = new_monitoring
          end
        end

        def placement=(new_placement)
          if placement.is_a?(Hash)
            @availability_zone = new_placement['availabilityZone']
          else
            @availability_zone = new_placement
          end
        end

        def volumes
          connection.volumes.all.select {|volume| volume.instance_id == @instance_id}
        end

        def volume=(new_volume)
          connection.attach_volume(@instance_id, new_volume.volume_id, new_volume.device)
        end

        def save
          options = {}
          if @availability_zone
            options['Placement.AvailabilityZone'] = @availability_zone
          end
          if @group_id
            options['groupId'] = @group_id
          end
          if @instance_type
            options['instanceType'] = @instance_type
          end
          if @kernel_id
            options['KernelId'] = @kernel_id
          end
          if @key_name
            options['KeyName'] = @key_name
          end
          if @monitoring
            options['Monitoring.Enabled'] = @monitoring
          end
          if @ramdisk_id
            options['RamdiskId'] = @ramdisk_id
          end
          if @user_data
            options['UserData'] = @user_data
          end
          data = connection.run_instances(@image_id, 1, 1, options)
          merge_attributes(data.body['instancesSet'].first)
          true
        end

        private

        def instance_state=(new_instance_state)
          @instance_state = new_instance_state['name']
        end

      end

    end
  end
end