<gh_stars>0
from spotty.commands.writers.abstract_output_writrer import AbstractOutputWriter
from spotty.providers.aws.aws_resources.image import Image
from spotty.providers.aws.deployment.abstract_aws_deployment import AbstractAwsDeployment
from spotty.providers.aws.aws_resources.instance import Instance
from spotty.providers.aws.deployment.cf_templates.ami_template import prepare_ami_template
from spotty.providers.aws.deployment.checks import check_az_and_subnet, check_max_price
from spotty.providers.aws.deployment.project_resources.ami_stack import AmiStackResource
from spotty.providers.aws.config.validation import is_gpu_instance


class AmiDeployment(AbstractAwsDeployment):

    # version of the AMI stack
    VERSION = '1.0.4'

    @property
    def ec2_instance_name(self) -> str:
        return 'spotty-ami-%s' % self.instance_config.ami_name.lower()

    @property
    def stack(self):
        return AmiStackResource(self.instance_config.ami_name, self.instance_config.region)

    def deploy(self, debug_mode: bool, output: AbstractOutputWriter):
        # check that the "amiId" parameter is not set
        if self.instance_config.ami_id:
            raise ValueError('The "amiId" parameter cannot be used for creating an AMI.')

        # check that it's a GPU instance type
        instance_type = self.instance_config.instance_type
        if not is_gpu_instance(instance_type):
            raise ValueError('"%s" is not a GPU instance' % instance_type)

        # check that an image with this name doesn't exist yet
        ami = Image.get_by_name(self._ec2, self.instance_config.ami_name)
        if ami:
            raise ValueError('AMI with the name "%s" already exists.' % self.instance_config.ami_name)

        # check availability zone and subnet
        check_az_and_subnet(self._ec2, self.instance_config.region, self.instance_config.availability_zone,
                            self.instance_config.subnet_id)

        # check the maximum price for a spot instance
        availability_zone = self.instance_config.availability_zone
        check_max_price(self._ec2, self.instance_config.instance_type, self.instance_config.on_demand,
                        self.instance_config.max_price, availability_zone)

        # prepare CF template
        subnet_id = self.instance_config.subnet_id
        on_demand = self.instance_config.on_demand
        template = prepare_ami_template(availability_zone, subnet_id, debug_mode, on_demand)

        # create stack
        parameters = self._get_template_parameters(debug_mode)
        self.stack.create_stack(template, parameters, debug_mode, output)

    def _get_template_parameters(self, debug_mode: bool = False):
        parameters = {
            'ImageVersion': self.VERSION,
            'VpcId': self.get_vpc_id(),
            'InstanceType': self.instance_config.instance_type,
            'ImageName': self.instance_config.ami_name,
            'InstanceNameTag': self.ec2_instance_name,
        }

        if debug_mode:
            parameters['DebugMode'] = 'true'
            parameters['KeyName'] = self.key_pair.get_or_create_key()  # get or create a key pair

        return parameters

    def delete(self, output: AbstractOutputWriter):
        # check that the "amiId" parameter is not set
        if self.instance_config.ami_id:
            raise ValueError('The "amiId" parameter cannot be used for deleting an AMI.')

        # check if the AMI stack exists
        stack_id = None
        if not self.stack.get_stack():
            # try to get the stack ID from the AMI tags (for older versions of Spotty)
            ami = Image.get_by_name(self._ec2, self.instance_config.ami_name)
            if not ami:
                raise ValueError('AMI with the name "%s" not found.' % self.instance_config.ami_name)

            stack_id = ami.get_tag_value('spotty:stack-id')
            if not stack_id:
                raise ValueError('AMI "%s" wasn\'t created by Spotty.' % self.instance_config.ami_name)

        # ask user to confirm the deletion
        confirm = input('AMI "%s" will be deleted.\n'
                        'Type "y" to confirm: ' % self.instance_config.ami_name)
        if confirm != 'y':
            output.write('You didn\'t confirm the operation.')
            return

        self.stack.delete_stack(output, stack_id=stack_id)

    def get_ip_address(self):
        instance = Instance.get_by_stack_name(self._ec2, self.stack.name)
        if not instance:
            return None

        if self._instance_config.local_ssh_port:
            return '127.0.0.1'

        return instance.public_ip_address

from spotty.commands.writers.abstract_output_writrer import AbstractOutputWriter
from spotty.providers.aws.aws_resources.image import Image
from spotty.providers.aws.deployment.abstract_aws_deployment import AbstractAwsDeployment
from spotty.providers.aws.aws_resources.instance import Instance
from spotty.providers.aws.deployment.cf_templates.ami_template import prepare_ami_template
from spotty.providers.aws.deployment.checks import check_az_and_subnet, check_max_price
from spotty.providers.aws.deployment.project_resources.ami_stack import AmiStackResource
from spotty.providers.aws.config.validation import is_gpu_instance


class AmiDeployment(AbstractAwsDeployment):

    # version of the AMI stack
    VERSION = '1.0.4'

    @property
    def ec2_instance_name(self) -> str:
        return 'spotty-ami-%s' % self.instance_config.ami_name.lower()

    @property
    def stack(self):
        return AmiStackResource(self.instance_config.ami_name, self.instance_config.region)

    def deploy(self, debug_mode: bool, output: AbstractOutputWriter):
        # check that the "amiId" parameter is not set
        if self.instance_config.ami_id:
            raise ValueError('The "amiId" parameter cannot be used for creating an AMI.')

        # check that it's a GPU instance type
        instance_type = self.instance_config.instance_type
        if not is_gpu_instance(instance_type):
            raise ValueError('"%s" is not a GPU instance' % instance_type)

        # check that an image with this name doesn't exist yet
        ami = Image.get_by_name(self._ec2, self.instance_config.ami_name)
        if ami:
            raise ValueError('AMI with the name "%s" already exists.' % self.instance_config.ami_name)

        # check availability zone and subnet
        check_az_and_subnet(self._ec2, self.instance_config.region, self.instance_config.availability_zone,
                            self.instance_config.subnet_id)

        # check the maximum price for a spot instance
        availability_zone = self.instance_config.availability_zone
        check_max_price(self._ec2, self.instance_config.instance_type, self.instance_config.on_demand,
                        self.instance_config.max_price, availability_zone)

        # prepare CF template
        subnet_id = self.instance_config.subnet_id
        on_demand = self.instance_config.on_demand
        template = prepare_ami_template(availability_zone, subnet_id, debug_mode, on_demand)

        # create stack
        parameters = self._get_template_parameters(debug_mode)
        self.stack.create_stack(template, parameters, debug_mode, output)

    def _get_template_parameters(self, debug_mode: bool = False):
        parameters = {
            'ImageVersion': self.VERSION,
            'VpcId': self.get_vpc_id(),
            'InstanceType': self.instance_config.instance_type,
            'ImageName': self.instance_config.ami_name,
            'InstanceNameTag': self.ec2_instance_name,
        }

        if debug_mode:
            parameters['DebugMode'] = 'true'
            parameters['KeyName'] = self.key_pair.get_or_create_key()  # get or create a key pair

        return parameters

    def delete(self, output: AbstractOutputWriter):
        # check that the "amiId" parameter is not set
        if self.instance_config.ami_id:
            raise ValueError('The "amiId" parameter cannot be used for deleting an AMI.')

        # check if the AMI stack exists
        stack_id = None
        if not self.stack.get_stack():
            # try to get the stack ID from the AMI tags (for older versions of Spotty)
            ami = Image.get_by_name(self._ec2, self.instance_config.ami_name)
            if not ami:
                raise ValueError('AMI with the name "%s" not found.' % self.instance_config.ami_name)

            stack_id = ami.get_tag_value('spotty:stack-id')
            if not stack_id:
                raise ValueError('AMI "%s" wasn\'t created by Spotty.' % self.instance_config.ami_name)

        # ask user to confirm the deletion
        confirm = input('AMI "%s" will be deleted.\n'
                        'Type "y" to confirm: ' % self.instance_config.ami_name)
        if confirm != 'y':
            output.write('You didn\'t confirm the operation.')
            return

        self.stack.delete_stack(output, stack_id=stack_id)

    def get_ip_address(self):
        instance = Instance.get_by_stack_name(self._ec2, self.stack.name)
        if not instance:
            return None

        if self._instance_config.local_ssh_port:
            return '127.0.0.1'

        return instance.public_ip_address
# version of the AMI stack # check that the "amiId" parameter is not set # check that it's a GPU instance type # check that an image with this name doesn't exist yet # check availability zone and subnet # check the maximum price for a spot instance # prepare CF template # create stack # get or create a key pair # check that the "amiId" parameter is not set # check if the AMI stack exists # try to get the stack ID from the AMI tags (for older versions of Spotty) # ask user to confirm the deletion