projects
/
angular-mojolicious.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
show slots
[angular-mojolicious.git]
/
couchdb-trigger.pl
diff --git
a/couchdb-trigger.pl
b/couchdb-trigger.pl
index
873beee
..
2ec5705
100755
(executable)
--- a/
couchdb-trigger.pl
+++ b/
couchdb-trigger.pl
@@
-15,7
+15,7
@@
use strict;
use lib 'common/mojo/lib';
use lib 'common/mojo/lib';
-use Mojo::
Cli
ent;
+use Mojo::
UserAg
ent;
use Mojo::JSON;
use Time::HiRes qw(time);
use Data::Dump qw(dump);
use Mojo::JSON;
use Time::HiRes qw(time);
use Data::Dump qw(dump);
@@
-25,12
+25,14
@@
my ( $url, $trigger_path ) = @ARGV;
$url ||= 'http://localhost:5984/monitor';
$trigger_path ||= 'trigger/shell.pm' ;
$url ||= 'http://localhost:5984/monitor';
$trigger_path ||= 'trigger/shell.pm' ;
+our $database = $1 if $url =~ m{/(\w+)/?$};
+
sub commit { warn "# commit ignored\n"; }
require $trigger_path if -e $trigger_path;
my $seq = 0;
sub commit { warn "# commit ignored\n"; }
require $trigger_path if -e $trigger_path;
my $seq = 0;
-my $client = Mojo::
Cli
ent->new;
+my $client = Mojo::
UserAg
ent->new;
our $json = Mojo::JSON->new;
sub info { warn $_[0], " ",$json->encode($_[1]),$/ }
sub debug { info "# $_[0]", $_[1] }
our $json = Mojo::JSON->new;
sub info { warn $_[0], " ",$json->encode($_[1]),$/ }
sub debug { info "# $_[0]", $_[1] }
@@
-46,12
+48,9
@@
while( ! $error ) {
$tx->res->body(sub{
my ( $content, $body ) = @_;
$tx->res->body(sub{
my ( $content, $body ) = @_;
- debug 'BODY' => $body;
+ return if length($body) == 0; # empty chunk, heartbeat?
- if ( length($body) == 0 ) {
- warn "# empty chunk, heartbeat?\n";
- return;
- }
+ debug 'BODY' => $body;
foreach ( split(/\r?\n/, $body) ) { # we can get multiple documents in one chunk
foreach ( split(/\r?\n/, $body) ) { # we can get multiple documents in one chunk
@@
-84,7
+83,7
@@
while( ! $error ) {
if ( $tx->res->code == 409 ) {
info "TRIGGER ABORTED started on another worker? ", $tx->error;
} else {
if ( $tx->res->code == 409 ) {
info "TRIGGER ABORTED started on another worker? ", $tx->error;
} else {
- info "ERROR ", $tx->error;
+ info "ERROR
$url/$id
", $tx->error;
}
} else {
my $res = $tx->res->json;
}
} else {
my $res = $tx->res->json;
@@
-98,7
+97,7
@@
while( ! $error ) {
$client->put( "$url/$id" => $json->encode( $change->{doc} ) => sub {
my ($client,$tx) = @_;
if ($tx->error) {
$client->put( "$url/$id" => $json->encode( $change->{doc} ) => sub {
my ($client,$tx) = @_;
if ($tx->error) {
- info "ERROR", $tx->error;
+ info "ERROR
$url/$id
", $tx->error;
} else {
my $res = $tx->res->json;
$change->{doc}->{_rev} = $res->{rev};
} else {
my $res = $tx->res->json;
$change->{doc}->{_rev} = $res->{rev};