CouchDB-changes-listener.rb

require "rubygems"

require "active_support/core_ext"
require "curb"
require "yajl"

class CouchDBChanges
  def self.consume(database_url, opts={}, &block)
    opts = {:feed => :continuous}.merge(opts)

    parser = Yajl::Parser.new()
    parser.on_parse_complete = block

    changes = Curl::Easy.new("#{database_url}/_changes?#{opts.to_param}")
    changes.headers["Accept"] = "application/json"
    changes.on_body { |data_chunk| parser << data_chunk; data_chunk.length }
    changes.perform
  end
end

CouchDBChanges.consume("http://localhost:5984/foo") do |change|
  puts change.inspect
end