Remove requires_connection test helper

The aim of this helper is to cause some tests to be skipped if there is no Internet connection. For some reason (which I haven’t investigated) when run on GitHub Actions these tests are always being skipped, causing me to not notice the test failures fixed in 139a59b. I am happy to remove this check; presumably if there’s no Internet connection then the affected tests will just fail, and that’s fine by me. I understand the intent of the author in adding this helper, and understand that being able to run some of the test suite offline may be a desirable thing, but I think not at the cost of it hiding failing tests by default. (There’s also a requires_port helper which is only used in the proxy-related tests; in order to remove that one we’d need to start running proxies locally and in CI, and I don’t want to spend time on that now. We don’t make use of this library’s proxy functionality in ably-ruby.) Enabling these tests on CI caused Ruby 2.2 to segfault; I have no idea of the cause (it exists on the pre-fork version of this library too) and I don’t want to look into it given that we only support Ruby 2.7+ for ably-ruby, so I’ve just removed Ruby 2.2 from CI.
ably-forks · May 14, 2024 · b2f3b4b · b2f3b4b
1 parent 366b91b
commit b2f3b4b
Show file tree

Hide file tree

Showing 6 changed files with 239 additions and 270 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -20,15 +20,3 @@ jobs:
           ruby-version: ${{ matrix.ruby }}
           bundler-cache: true
       - run: bundle exec rake spec
-  spec-legacy:
-    name: "RSpec / Ruby 2.2"
-    runs-on: ubuntu-20.04
-    steps:
-      - run: sudo apt-get install libcurl4-openssl-dev
-      - uses: actions/checkout@v4
-      - uses: ruby/setup-ruby@v1
-        with:
-          ruby-version: 2.2
-          bundler-cache: true
-      - name: rake spec
-        run: bundle exec rake spec
diff --git a/spec/external_spec.rb b/spec/external_spec.rb
@@ -1,149 +1,146 @@
 require 'helper'
 
-requires_connection do
+describe EventMachine::AblyHttpRequest::HttpRequest do
+
+  it "should follow redirects on HEAD method (external)" do
+    EventMachine.run {
+      http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.google.com/').head :redirects => 1
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 200
+        EM.stop
+      }
+    }
+  end
 
-  describe EventMachine::AblyHttpRequest::HttpRequest do
+  it "should follow redirect to https and initiate the handshake" do
+    EventMachine.run {
+      http = EventMachine::AblyHttpRequest::HttpRequest.new('http://github.com/').get :redirects => 5
 
-    it "should follow redirects on HEAD method (external)" do
-      EventMachine.run {
-        http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.google.com/').head :redirects => 1
-        http.errback { failed(http) }
-        http.callback {
-          http.response_header.status.should == 200
-          EM.stop
-        }
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 200
+        EventMachine.stop
       }
-    end
+    }
+  end
 
-    it "should follow redirect to https and initiate the handshake" do
-      EventMachine.run {
-        http = EventMachine::AblyHttpRequest::HttpRequest.new('http://github.com/').get :redirects => 5
+  it "should perform a streaming GET" do
+    EventMachine.run {
 
-        http.errback { failed(http) }
-        http.callback {
-          http.response_header.status.should == 200
-          EventMachine.stop
-        }
+      # digg.com uses chunked encoding
+      http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.httpwatch.com/httpgallery/chunked/').get
+
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 200
+        EventMachine.stop
       }
-    end
+    }
+  end
 
-    it "should perform a streaming GET" do
-      EventMachine.run {
+  it "should handle a 100 continue" do
+    EventMachine.run {
+      # 8.2.3 Use of the 100 (Continue) Status - http://www.ietf.org/rfc/rfc2616.txt
+      #
+      # An origin server SHOULD NOT send a 100 (Continue) response if
+      # the request message does not include an Expect request-header
+      # field with the "100-continue" expectation, and MUST NOT send a
+      # 100 (Continue) response if such a request comes from an HTTP/1.0
+      # (or earlier) client. There is an exception to this rule: for
+      # compatibility with RFC 2068, a server MAY send a 100 (Continue)
+      # status in response to an HTTP/1.1 PUT or POST request that does
+      # not include an Expect request-header field with the "100-
+      # continue" expectation. This exception, the purpose of which is
+      # to minimize any client processing delays associated with an
+      # undeclared wait for 100 (Continue) status, applies only to
+      # HTTP/1.1 requests, and not to requests with any other HTTP-
+      # version value.
+      #
+      # 10.1.1: 100 Continue - http://www.ietf.org/rfc/rfc2068.txt
+      # The client may continue with its request. This interim response is
+      # used to inform the client that the initial part of the request has
+      # been received and has not yet been rejected by the server. The client
+      # SHOULD continue by sending the remainder of the request or, if the
+      # request has already been completed, ignore this response. The server
+      # MUST send a final response after the request has been completed.
+
+      url = 'http://ws.serviceobjects.com/lv/LeadValidation.asmx/ValidateLead_V2'
+      http = EventMachine::AblyHttpRequest::HttpRequest.new(url).post :body => {:name => :test}
+
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 500
+        http.response.should match('Missing')
+        EventMachine.stop
+      }
+    }
+  end
 
-        # digg.com uses chunked encoding
-        http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.httpwatch.com/httpgallery/chunked/').get
+  it "should detect deflate encoding" do
+    EventMachine.run {
 
-        http.errback { failed(http) }
-        http.callback {
-          http.response_header.status.should == 200
-          EventMachine.stop
-        }
+      options = {:head => {"accept-encoding" => "deflate"}, :redirects => 5}
+      http = EventMachine::AblyHttpRequest::HttpRequest.new('https://www.bing.com/').get options
+
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 200
+        http.response_header["CONTENT_ENCODING"].should == "deflate"
+
+        EventMachine.stop
       }
-    end
+    }
+  end
 
-    it "should handle a 100 continue" do
-      EventMachine.run {
-        # 8.2.3 Use of the 100 (Continue) Status - http://www.ietf.org/rfc/rfc2616.txt
-        #
-        # An origin server SHOULD NOT send a 100 (Continue) response if
-        # the request message does not include an Expect request-header
-        # field with the "100-continue" expectation, and MUST NOT send a
-        # 100 (Continue) response if such a request comes from an HTTP/1.0
-        # (or earlier) client. There is an exception to this rule: for
-        # compatibility with RFC 2068, a server MAY send a 100 (Continue)
-        # status in response to an HTTP/1.1 PUT or POST request that does
-        # not include an Expect request-header field with the "100-
-        # continue" expectation. This exception, the purpose of which is
-        # to minimize any client processing delays associated with an
-        # undeclared wait for 100 (Continue) status, applies only to
-        # HTTP/1.1 requests, and not to requests with any other HTTP-
-        # version value.
-        #
-        # 10.1.1: 100 Continue - http://www.ietf.org/rfc/rfc2068.txt
-        # The client may continue with its request. This interim response is
-        # used to inform the client that the initial part of the request has
-        # been received and has not yet been rejected by the server. The client
-        # SHOULD continue by sending the remainder of the request or, if the
-        # request has already been completed, ignore this response. The server
-        # MUST send a final response after the request has been completed.
-
-        url = 'http://ws.serviceobjects.com/lv/LeadValidation.asmx/ValidateLead_V2'
-        http = EventMachine::AblyHttpRequest::HttpRequest.new(url).post :body => {:name => :test}
+  it "should stream chunked gzipped data" do
+    EventMachine.run {
+      options = {:head => {"accept-encoding" => "gzip"}}
+      # GitHub sends chunked gzip, time for a little Inception ;)
+      http = EventMachine::AblyHttpRequest::HttpRequest.new('https://github.com/igrigorik/em-http-request/commits/master').get options
 
-        http.errback { failed(http) }
-        http.callback {
-          http.response_header.status.should == 500
-          http.response.should match('Missing')
-          EventMachine.stop
-        }
+      http.errback { failed(http) }
+      http.callback {
+        http.response_header.status.should == 200
+        http.response_header["CONTENT_ENCODING"].should == "gzip"
+        http.response.should == ''
+
+        EventMachine.stop
       }
-    end
 
-    it "should detect deflate encoding" do
-      EventMachine.run {
+      body = ''
+      http.stream do |chunk|
+        body << chunk
+      end
+    }
+  end
 
-        options = {:head => {"accept-encoding" => "deflate"}, :redirects => 5}
-        http = EventMachine::AblyHttpRequest::HttpRequest.new('https://www.bing.com/').get options
+  context "keepalive" do
+    it "should default to non-keepalive" do
+      EventMachine.run {
+        headers = {'If-Modified-Since' => 'Thu, 05 Aug 2010 22:54:44 GMT'}
+        http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.google.com/images/logos/ps_logo2.png').get :head => headers
 
-        http.errback { failed(http) }
+        http.errback { fail }
+        start = Time.now.to_i
         http.callback {
-          http.response_header.status.should == 200
-          http.response_header["CONTENT_ENCODING"].should == "deflate"
-
+          (Time.now.to_i - start).should be_within(2).of(0)
           EventMachine.stop
         }
       }
     end
 
-    it "should stream chunked gzipped data" do
+    it "should work with keep-alive servers" do
       EventMachine.run {
-        options = {:head => {"accept-encoding" => "gzip"}}
-        # GitHub sends chunked gzip, time for a little Inception ;)
-        http = EventMachine::AblyHttpRequest::HttpRequest.new('https://github.com/igrigorik/em-http-request/commits/master').get options
+        http = EventMachine::AblyHttpRequest::HttpRequest.new('https://github.com/igrigorik/em-http-request').get :keepalive => true
 
         http.errback { failed(http) }
         http.callback {
           http.response_header.status.should == 200
-          http.response_header["CONTENT_ENCODING"].should == "gzip"
-          http.response.should == ''
-
           EventMachine.stop
         }
-
-        body = ''
-        http.stream do |chunk|
-          body << chunk
-        end
       }
     end
-
-    context "keepalive" do
-      it "should default to non-keepalive" do
-        EventMachine.run {
-          headers = {'If-Modified-Since' => 'Thu, 05 Aug 2010 22:54:44 GMT'}
-          http = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.google.com/images/logos/ps_logo2.png').get :head => headers
-
-          http.errback { fail }
-          start = Time.now.to_i
-          http.callback {
-            (Time.now.to_i - start).should be_within(2).of(0)
-            EventMachine.stop
-          }
-        }
-      end
-
-      it "should work with keep-alive servers" do
-        EventMachine.run {
-          http = EventMachine::AblyHttpRequest::HttpRequest.new('https://github.com/igrigorik/em-http-request').get :keepalive => true
-
-          http.errback { failed(http) }
-          http.callback {
-            http.response_header.status.should == 200
-            EventMachine.stop
-          }
-        }
-      end
-    end
-
   end
+
 end
diff --git a/spec/helper.rb b/spec/helper.rb
@@ -14,10 +14,6 @@ def failed(http = nil)
   http ? fail(http.error) : fail
 end
 
-def requires_connection(&blk)
-  blk.call if system('ping -t1 -c1 google.com 2>&1 > /dev/null')
-end
-
 def requires_port(port, &blk)
   port_open = true
   begin

diff --git a/spec/pipelining_spec.rb b/spec/pipelining_spec.rb
@@ -1,66 +1,62 @@
 require 'helper'
 
-requires_connection do
+describe EventMachine::AblyHttpRequest::HttpRequest do
 
-  describe EventMachine::AblyHttpRequest::HttpRequest do
+  it "should perform successful pipelined GETs" do
+    EventMachine.run do
 
-    it "should perform successful pipelined GETs" do
-      EventMachine.run do
+      # Mongrel doesn't support pipelined requests - bah!
+      conn = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.bing.com/')
 
-        # Mongrel doesn't support pipelined requests - bah!
-        conn = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.bing.com/')
+      pipe1 = conn.get :keepalive => true
+      pipe2 = conn.get :path => '/news', :keepalive => true
 
-        pipe1 = conn.get :keepalive => true
-        pipe2 = conn.get :path => '/news', :keepalive => true
+      processed = 0
+      stop = proc { EM.stop if processed == 2}
 
-        processed = 0
-        stop = proc { EM.stop if processed == 2}
+      pipe1.errback { failed(conn) }
+      pipe1.callback {
+        processed += 1
+        pipe1.response_header.status.should == 200
+        stop.call
+      }
 
-        pipe1.errback { failed(conn) }
-        pipe1.callback {
-          processed += 1
-          pipe1.response_header.status.should == 200
-          stop.call
-        }
+      pipe2.errback { failed(conn) }
+      pipe2.callback {
+        processed += 1
+        pipe2.response_header.status.should == 200
+        pipe2.response.should match(/html/i)
+        stop.call
+      }
 
-        pipe2.errback { failed(conn) }
-        pipe2.callback {
-          processed += 1
-          pipe2.response_header.status.should == 200
-          pipe2.response.should match(/html/i)
-          stop.call
-        }
-
-      end
     end
+  end
 
-    it "should perform successful pipelined HEAD requests" do
-      EventMachine.run do
-        conn = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.bing.com/')
-
-        pipe1 = conn.head :keepalive => true
-        pipe2 = conn.head :path => '/news', :keepalive => true
+  it "should perform successful pipelined HEAD requests" do
+    EventMachine.run do
+      conn = EventMachine::AblyHttpRequest::HttpRequest.new('http://www.bing.com/')
 
-        processed = 0
-        stop = proc { EM.stop if processed == 2}
+      pipe1 = conn.head :keepalive => true
+      pipe2 = conn.head :path => '/news', :keepalive => true
 
-        pipe1.errback { failed(conn) }
-        pipe1.callback {
-          processed += 1
-          pipe1.response_header.status.should == 200
-          stop.call
-        }
+      processed = 0
+      stop = proc { EM.stop if processed == 2}
 
-        pipe2.errback { failed(conn) }
-        pipe2.callback {
-          processed += 1
-          pipe2.response_header.status.should == 200
-          stop.call
-        }
+      pipe1.errback { failed(conn) }
+      pipe1.callback {
+        processed += 1
+        pipe1.response_header.status.should == 200
+        stop.call
+      }
 
-      end
+      pipe2.errback { failed(conn) }
+      pipe2.callback {
+        processed += 1
+        pipe2.response_header.status.should == 200
+        stop.call
+      }
 
     end
-  end
 
+  end
 end