From a5b66b15b7f68a1da31dd3ff0466c3be16f031c0 Mon Sep 17 00:00:00 2001 From: Azul Date: Thu, 28 Nov 2013 07:44:51 +0100 Subject: make sequence accept all kinds of json bigcouch uses arrays for sequence: http://mail-archives.apache.org/mod_mbox/couchdb-user/201301.mbox/%3CCABvT1DEGDCJyvEuFsNJZbXi_NJwJna8NHDnQvpr2h532s0V18g@mail.gmail.com%3E So we should not expect them to be integers. Still have to catch the empty file situation in a meaningful way though. --- lib/tapicero/couch_changes.rb | 15 +++++++++++---- 1 file 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 # -- cgit v1.2.3 From c5fea1a1bfaa6690d4d6728feda566e48af452e9 Mon Sep 17 00:00:00 2001 From: Azul Date: Thu, 28 Nov 2013 12:11:28 +0100 Subject: rescue from 404 when destroying db Also logging per user db creation and destruction if they happen. --- lib/tapicero/user_database.rb | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/lib/tapicero/user_database.rb b/lib/tapicero/user_database.rb index ec2694a..8f461ef 100644 --- a/lib/tapicero/user_database.rb +++ b/lib/tapicero/user_database.rb @@ -10,10 +10,9 @@ module Tapicero end def create - begin - CouchRest.new(host).create_db(name) - rescue RestClient::PreconditionFailed # database already existed - end + CouchRest.new(host).create_db(name) + Tapicero.logger.debug "database created successfully." + rescue RestClient::PreconditionFailed # database already existed end def secure(security) @@ -27,6 +26,8 @@ module Tapicero def destroy db = CouchRest.new(host).database(name) db.delete! if db + Tapicero.logger.debug "database deleted successfully." + rescue RestClient::ResourceNotFound # no database found end protected -- cgit v1.2.3