X-Git-Url: http://git.rot13.org/?p=angular-mojolicious.git;a=blobdiff_plain;f=couchdb-changes.pl;h=3cb1637b936e056ca0b43ce376114f7bbe7eb2bc;hp=ebdac86a3914e2b58ebd57afa8424606a3252611;hb=a9035c2e30dec2e21ec6558b7ff5fe24efec5aeb;hpb=ccad06ffade5c7658b81dc2dba28c683472c2d21 diff --git a/couchdb-changes.pl b/couchdb-changes.pl index ebdac86..3cb1637 100755 --- a/couchdb-changes.pl +++ b/couchdb-changes.pl @@ -7,16 +7,13 @@ use strict; use lib 'common/mojo/lib'; -use Mojo::Client; +use Mojo::UserAgent; use Mojo::JSON; -use Data::Dump qw(dump); -use JSON::XS; my $url = 'http://localhost:5984/monitor/_changes?feed=continuous;include_docs=true;since='; my $seq = 0; -our $last_id_rev = ''; -my $client = Mojo::Client->new; +my $client = Mojo::UserAgent->new; my $json = Mojo::JSON->new; my $error; @@ -52,15 +49,10 @@ while( ! $error ) { my $rev = $data->{changes}->[0]->{rev} || warn "no rev?"; $seq = $data->{seq} || warn "no seq?"; - if ( $last_id_rev eq "$id $rev" ) { - warn "# duplicate $last_id_rev\n"; - } else { - $last_id_rev = "$id $rev"; - warn "# ",dump( $data ); - } + warn "# doc ", $json->encode( $data->{doc} ); # FIXME custom code here } else { - warn "UNKNOWN", dump($data); + warn "UNKNOWN", $json->encode($data); } } @@ -70,4 +62,4 @@ while( ! $error ) { } -die dump($error) if $error; +die "ERROR ", $json->encode($error) if $error;