Make EC2 Adapter and use it with command files

lib/opsicle/commands/add_tags.rb

@@ -1,6 +1,7 @@
 require 'gli'
 require "opsicle/user_profile"
 require "opsicle/opsworks_adapter"
+require "opsicle/ec2_adapter"
 require "opsicle/manageable_layer"
 require "opsicle/manageable_instance"
 require "opsicle/manageable_stack"
@@ -10,6 +11,7 @@ class AddTags
 
     def initialize(environment)
       @client = Client.new(environment)
+      @ec2_adapter = Ec2Adapter.new(@client)
       @opsworks_adapter = OpsworksAdapter.new(@client)
       stack_id = @client.config.opsworks_config[:stack_id]
       @stack = ManageableStack.new(stack_id, @opsworks_adapter.client)
@@ -34,7 +36,7 @@ def select_layer
 
       layers = []
       ops_layers.each do |layer|
-        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @client.ec2, @cli)
+        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli)
       end
 
       layers.each_with_index { |layer, index| puts "#{index.to_i + 1}) #{layer.name}" }

lib/opsicle/commands/clone_instance.rb

@@ -1,6 +1,7 @@
 require 'gli'
 require "opsicle/user_profile"
 require "opsicle/opsworks_adapter"
+require "opsicle/ec2_adapter"
 require "opsicle/manageable_layer"
 require "opsicle/manageable_instance"
 require "opsicle/manageable_stack"
@@ -10,6 +11,7 @@ class CloneInstance
 
     def initialize(environment)
       @client = Client.new(environment)
+      @ec2_adapter = Ec2Adapter.new(@client)
       @opsworks_adapter = OpsworksAdapter.new(@client)
       stack_id = @client.config.opsworks_config[:stack_id]
       @stack = ManageableStack.new(stack_id, @opsworks_adapter.client)
@@ -40,7 +42,7 @@ def select_layer
 
       layers = []
       ops_layers.each do |layer|
-        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @client.ec2, @cli)
+        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli)
       end
 
       layers.each_with_index { |layer, index| puts "#{index.to_i + 1}) #{layer.name}" }

lib/opsicle/commands/create_instance.rb

@@ -1,6 +1,7 @@
 require 'gli'
 require "opsicle/user_profile"
 require "opsicle/opsworks_adapter"
+require "opsicle/ec2_adapter"
 require "opsicle/manageable_layer"
 require "opsicle/manageable_stack"
 require "opsicle/creatable_instance"
@@ -10,6 +11,7 @@ class CreateInstance
 
     def initialize(environment)
       @client = Client.new(environment)
+      @ec2_adapter = Ec2Adapter.new(@client)
       @opsworks_adapter = OpsworksAdapter.new(@client)
       stack_id = @client.config.opsworks_config[:stack_id]
       @stack = ManageableStack.new(stack_id, @opsworks_adapter.client)
@@ -26,7 +28,7 @@ def execute(options={})
     end
 
     def create_instance(layer, options)
-      CreatableInstance.new(layer, @stack, @opsworks_adapter.client, @client.ec2, @cli).create(options)
+      CreatableInstance.new(layer, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli).create(options)
     end
 
     def select_layer
@@ -35,7 +37,7 @@ def select_layer
 
       layers = []
       ops_layers.each do |layer|
-        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @client.ec2, @cli)
+        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli)
       end
 
       layers.each_with_index { |layer, index| puts "#{index.to_i + 1}) #{layer.name}" }

lib/opsicle/commands/delete_instance.rb

@@ -1,6 +1,7 @@
 require 'gli'
 require "opsicle/user_profile"
 require "opsicle/opsworks_adapter"
+require "opsicle/ec2_adapter"
 require "opsicle/manageable_layer"
 require "opsicle/manageable_instance"
 require "opsicle/manageable_stack"
@@ -10,6 +11,7 @@ class DeleteInstance
 
     def initialize(environment)
       @client = Client.new(environment)
+      @ec2_adapter = Ec2Adapter.new(@client)
       @opsworks_adapter = OpsworksAdapter.new(@client)
       stack_id = @client.config.opsworks_config[:stack_id]
       @stack = ManageableStack.new(stack_id, @opsworks_adapter.client)
@@ -40,7 +42,7 @@ def select_layer
 
       layers = []
       ops_layers.each do |layer|
-        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @client.ec2, @cli)
+        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli)
       end
 
       layers.each_with_index { |layer, index| puts "#{index.to_i + 1}) #{layer.name}" }

lib/opsicle/commands/stop_instance.rb

@@ -1,6 +1,7 @@
 require 'gli'
 require "opsicle/user_profile"
 require "opsicle/opsworks_adapter"
+require "opsicle/ec2_adapter"
 require "opsicle/manageable_layer"
 require "opsicle/manageable_instance"
 require "opsicle/manageable_stack"
@@ -10,6 +11,7 @@ class StopInstance
 
     def initialize(environment)
       @client = Client.new(environment)
+      @ec2_adapter = Ec2Adapter.new(@client)
       @opsworks_adapter = OpsworksAdapter.new(@client)
       stack_id = @client.config.opsworks_config[:stack_id]
       @stack = ManageableStack.new(stack_id, @opsworks_adapter.client)
@@ -40,7 +42,7 @@ def select_layer
 
       layers = []
       ops_layers.each do |layer|
-        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @client.ec2, @cli)
+        layers << ManageableLayer.new(layer.name, layer.layer_id, @stack, @opsworks_adapter.client, @ec2_adapter.client, @cli)
       end
 
       layers.each_with_index { |layer, index| puts "#{index.to_i + 1}) #{layer.name}" }

lib/opsicle/ec2_adapter.rb

@@ -0,0 +1,15 @@
+class Opsicle::Ec2Adapter
+  attr_reader :client
+
+  def initialize(client)
+    @client = client.ec2
+  end
+
+  def get_subnets
+    client.describe_subnets.subnets
+  end
+
+  def tag_instance(ec2_instance_id, tags)
+    client.create_tags(resources: [ ec2_instance_id ], tags: tags)
+  end
+end

spec/opsicle/ec2_adapter_spec.rb

@@ -0,0 +1,23 @@
+describe Opsicle::Ec2Adapter do
+  let(:aws_ec2_client) do
+    double(:aws_ec2_client,
+     describe_subnets: double(:subnets, subnets: []),
+     create_tags: :tags_created
+    )
+  end
+  let(:client) { double(:client, ec2: aws_ec2_client) }
+
+  subject { described_class.new(client) }
+
+  describe "#get_subnets" do
+    it "should gather an array of subnets for this ec2 client" do
+      expect(subject.get_subnets).to be_empty
+    end
+  end
+
+  describe "#tag_instance" do
+    it "should call to create a tag on an instance" do
+      expect(subject.tag_instance(:instance_id, [1, 2, 3])).to eq(:tags_created)
+    end
+  end
+end