# frozen_string_literal: true

module Meroku
  # Mostly wrappers around aws library functions
  module Aws
    include Meroku::Shared

    def make_instance
      @instance_id = Meroku::Shared.ec2_client.run_instances(
        image_id: 'ami-841f46ff',
        min_count: 1,
        max_count: 1,
        key_name: 'meroku.id_rsa',
        instance_type: 't2.micro',
        tag_specifications: [tag]
      ).instances.first.instance_id
    end

    def associate_address
      retries ||= 0
      sleep 10
      begin
        puts Meroku::Shared.ec2_client.associate_address(
          allocation_id: allocation_id, instance_id: instance_id
        ).class
        sleep 20
      rescue ::Aws::EC2::Errors::InvalidInstanceID
        (retries += 1) < 10 ? retry : raise
      end
    end

    # Private S3 Bucket
    # The only security here is not no one knows the bucket name,
    # which is a uuid
    def bucket
      "http://s3.amazonaws.com/#{Meroku::Shared.secrets.meroku_secret}/"
    end

    def self.terminate_all(tag: nil)
      Meroku::Shared.ec2_client.describe_instances(
        filters: running_filter(tag)
      ).reservations.map do |r|
        id = r.instances.first.instance_id
        puts "Will terminate #{id}"
        Meroku::Shared.ec2_client.terminate_instances(instance_ids: [id])
      end
    end

    # Our elastic ip allocation
    def allocation_id
      'eipalloc-139f7823'
    end

    def ip_address
      '34.239.241.218'
    end

    def tag
      {
        resource_type: 'instance',
        tags: [
          {
            key: 'Name',
            value: 'node'
          }
        ]
      }
    end

    def self.running_filter(tag)
      [
        { name: 'tag:Name', values: [tag] },
        { name: 'instance-state-name', values: %w[running pending] }
      ]
    end
  end
end