diff options
author | jessib <jessib@riseup.net> | 2013-11-29 13:43:32 -0800 |
---|---|---|
committer | jessib <jessib@riseup.net> | 2013-11-29 13:43:32 -0800 |
commit | 8104b882032a851604ba6a2a904c7e267523f158 (patch) | |
tree | cab4ef7775e7c3e61e22be87d5802ca425dc7b61 /lib/tapicero/couch_changes.rb | |
parent | ddda87a96c6c95c1afc163aea3c0d52943ecd41c (diff) | |
parent | c5fea1a1bfaa6690d4d6728feda566e48af452e9 (diff) |
Merge pull request #4 from azul/feature/more_robust_sequence_handling
Feature/more robust sequence handling
Diffstat (limited to 'lib/tapicero/couch_changes.rb')
-rw-r--r-- | lib/tapicero/couch_changes.rb | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/lib/tapicero/couch_changes.rb b/lib/tapicero/couch_changes.rb index aa21676..fddebec 100644 --- a/lib/tapicero/couch_changes.rb +++ b/lib/tapicero/couch_changes.rb @@ -31,10 +31,12 @@ module Tapicero def listen Tapicero.logger.info "listening..." Tapicero.logger.debug "Starting at sequence #{since}" - db.changes :feed => :continuous, :since => since, :heartbeat => 1000 do |hash| + result = db.changes :feed => :continuous, :since => since, :heartbeat => 1000 do |hash| callbacks(hash) store_seq(hash["seq"]) end + Tapicero.logger.info "couch stream ended unexpectedly." + Tapicero.logger.debug result.inspect end protected @@ -59,14 +61,19 @@ module Tapicero unless File.writable?(seq_filename) raise StandardError.new("Can't access sequence file") end - @since = File.read(seq_filename).to_i - Tapicero.logger.debug "Found sequence: #{@since}" + @since = File.read(seq_filename) + if @since == '' + @since = nil + Tapicero.logger.debug "Found no sequence in the file." + else + Tapicero.logger.debug "Found sequence: #{@since}" + end rescue Errno::ENOENT => e Tapicero.logger.warn "No sequence file found. Starting from scratch" end def store_seq(seq) - File.write(@seq_filename, seq) + File.write(@seq_filename, seq.to_json) end # |