Initial mirror probe realworld integration spec

2 files changed, 82 insertions, 0 deletions

diff --git a/spec/realworld/mirror_probe_spec.rb b/spec/realworld/mirror_probe_spec.rb
new file mode 100644
index 0000000000..48bd6c3c72
--- /dev/null
+++ b/spec/realworld/mirror_probe_spec.rb
@@ -0,0 +1,57 @@
+require "spec_helper"
+require "thread"
+
+describe "fetching dependencies with a not available mirror" do
+  let(:mirror) { @mirror_uri }
+  let(:original) { @server_uri }
+
+  before do
+    require_rack
+    setup_mirror
+    setup_server
+    global_config("BUNDLE_MIRROR__HTTP://127__0__0__1:#{@server_port}/__FALLBACK_TIMEOUT/" => "true",
+                  "BUNDLE_MIRROR__HTTP://127__0__0__1:#{@server_port}/" => @mirror_uri)
+  end
+
+  after do
+    @server_thread.kill
+  end
+
+
+  it "install a gem using the original uri when the mirror is not responding" do
+    gemfile <<-G
+      source "#{original}"
+      gem 'weakling'
+    G
+
+    bundle :install
+
+    expect(out).to include("Installing weakling")
+    expect(out).to include("Bundle complete")
+    should_be_installed "weakling 0.0.3"
+  end
+
+  def setup_server
+    @server_port = find_unused_port
+    @server_host = "127.0.0.1"
+    @server_uri = "http://#{@server_host}:#{@server_port}"
+
+    require File.expand_path("../../support/artifice/endpoint", __FILE__)
+
+    @server_thread = Thread.new do
+      Rack::Server.start(:app       => Endpoint,
+                         :Host      => @server_host,
+                         :Port      => @server_port,
+                         :server    => "webrick",
+                         :AccessLog => [])
+    end.run
+
+    wait_for_server(@server_host, @server_port)
+  end
+
+  def setup_mirror
+    @mirror_port = find_unused_port
+    @mirror_host = "127.0.0.1"
+    @mirror_uri = "http://#{@mirror_host}:#{@mirror_port}"
+  end
+end
diff --git a/spec/support/helpers.rb b/spec/support/helpers.rb
index bec6bb8758..324e52d2d0 100644
--- a/spec/support/helpers.rb
+++ b/spec/support/helpers.rb
@@ -410,5 +410,30 @@ module Spec
         ENV[k] = current_values[k]
       end
     end
+
+    def require_rack
+      # need to hack, so we can require rack
+      old_gem_home = ENV["GEM_HOME"]
+      ENV["GEM_HOME"] = Spec::Path.base_system_gems.to_s
+      require "rack"
+      ENV["GEM_HOME"] = old_gem_home
+    end
+
+    def wait_for_server(host, port, seconds = 15)
+      tries = 0
+      sleep 0.5
+      TCPSocket.new(host, port)
+    rescue => e
+      raise(e) if tries > (seconds * 2)
+      tries += 1
+      retry
+    end
+
+    def find_unused_port
+      tcp_server = TCPServer.new("127.0.0.1", 0) # Use any available ephemeral port
+      port = tcp_server.addr[1]
+      tcp_server.close
+      port
+    end
   end
 end