Fix couchrest missing the first change (#5452)

CouchRest::Streamer will ignore the first line from a stream. Normally that's the line opening the results array. But for continuous feeds couch will start streaming the array elements right away. So we miss the first one.

There's a pull request pending for couchrest here:
https://github.com/couchrest/couchrest/pull/104

Until it's merged we'll monkeypatch.

Also stopping tapicero again after travis run.

2 files changed, 30 insertions, 0 deletions

diff --git a/lib/extends/couchrest.rb b/lib/extends/couchrest.rb
new file mode 100644
index 0000000..54db9d8
--- /dev/null
+++ b/lib/extends/couchrest.rb
@@ -0,0 +1,29 @@
+#
+# monkeypatch CouchRest::Streamer to fix
+# https://github.com/couchrest/couchrest/pull/104
+#
+module CouchRest
+  class Streamer
+
+    def open_pipe(cmd, &block)
+      first = nil
+      prev = nil
+      IO.popen(cmd) do |f|
+        while line = f.gets
+          row = parse_line(line)
+          if row.nil?
+            first ||= line # save the header for later if we can't parse it.
+          else
+            block.call row
+          end
+          prev = line
+        end
+      end
+
+      raise RestClient::ServerBrokeConnection if $? && $?.exitstatus != 0
+
+      parse_first(first, prev)
+    end
+
+  end
+end
diff --git a/lib/tapicero_daemon.rb b/lib/tapicero_daemon.rb
index 89566de..b46158a 100644
--- a/lib/tapicero_daemon.rb
+++ b/lib/tapicero_daemon.rb
@@ -5,6 +5,7 @@
 #  Daemons.run('tapicero_daemon.rb')
 #
 require 'tapicero'
+require 'extends/couchrest'
 
 module Tapicero
   module Daemon