- $client->put( "$url/$id" => $json->encode( $change->{doc} ) => sub {
- my ($client,$tx) = @_;
- if ($tx->error) {
- if ( $tx->res->code == 409 ) {
- info "TRIGGER ABORTED started on another worker? ", $tx->error;
+ my $client = Mojo::UserAgent->new;
+ my $res = $client->put( "$url/$id" => $json->encode( $change->{doc} ) )->res;
+warn "code ", $res->code, dump( $res->json );
+ if ( $res->code == 409 ) {
+ info "TRIGGER ABORTED started on another worker? ", $res->error;
+ next;
+ } elsif ( $res->code != 201 ) {
+ info "ERROR $url/$id ", $res->code;
+ }
+
+
+ } elsif ( $change->{doc}->{trigger}->{active}->[0] eq $uid ) {
+ if ( exists $change->{doc}->{trigger}->{active}->[2] ) {
+ warn "allready executed";
+ next;
+ } else {
+
+ debug "TRIGGER execute ", $change->{doc};
+ trigger( $change );
+
+ push @{ $change->{doc}->{trigger}->{active} }, time(), 0; # last timestamp
+warn "change ",dump $change;
+
+ my $client = Mojo::UserAgent->new;
+ my $res = $client->put( "$url/$id" => $json->encode( $change->{doc} ) )->res;
+warn "code ", $res->code;
+ if ( my $json = $res->json ) {
+warn dump($json);
+ $change->{doc}->{_rev} = $json->{rev};
+ info "TRIGGER finish ", $change->{doc};