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;
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);
}
}
}
-die dump($error) if $error;
+die "ERROR ", $json->encode($error) if $error;