Changeset 2283 for trunk

Timestamp:

09/03/19 19:40:51 (5 years ago)

Author:

nanardon

Message:

Allow to callback to SynchAccess? to follow process

File:

• trunk/LATMOS-Accounts/lib/LATMOS/Accounts/SynchAccess/base.pm (modified) (5 diffs)

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/SynchAccess/base.pm

@@ -36 +36 @@
 }
 
-=head2 new( \@bases )
+=head2 new( \@bases, %config )
 
 Create a new SynchAccess instance over given bases
+
+C<%config>:
+
+=over 4
+
+=item cb
+
+Callback, see L<SetCB>
+
+=back
 
 =cut
 
 sub new {
-    my ($class, $bases) = @_;
+    my ($class, $bases, %config) = @_;
     bless {
         bases => [ @{ $bases } ],
+        %config
     }, $class;
 }
@@ -60 +71 @@
 }
 
+=head2 SetCB ( $callback )
+
+Set a callback to receive the object being call, return the previous one.
+
+=cut
+
+sub SetCB {
+    my ( $self, $cb ) = @_;
+
+    my $oldCB = $self->{cb};
+    $self->{cb} = $cb;
+    return $oldCB;
+}
+
 sub _return_all {
     my ($self, $sub, @args) = @_;
-    map { $_->$sub(@args) } $self->bases
+    my @allres;
+    foreach my $ba ($self->bases) {
+        my @res = $_->$sub(@args);
+        $self->{cb}->($ba, @res) if($self->{cb});
+        push(@allres, @res);
+    }
+    @allres;
 }
 
@@ -82 +113 @@
     my $failure = 0;
     foreach ($self->bases) {
-        $_->$sub(@args) or do {
+        my $res = $_->$sub(@args);
+        $self->{cb}->($_, $res) if($self->{cb});
+        $res or do {
                     la_log(LA_ERR, "SyncA: Erreur call $sub() for %s", $_);
                 $failure = 1;
@@ -94 +127 @@
     my $failure = 0;
     foreach ($self->bases) {
-        $_->$sub(@args) and $failure = 1;
+        my $res = $_->$sub(@args) and $failure = 1;
+        $self->{cb}->($_, $res) if($self->{cb});
     }
     $failure ? 0 : 1;
@@ -107 +141 @@
     foreach ($self->bases) {
         if ($_->is_supported_object($otype)) {
-            $_->rename_object($otype, $uid, $newuid) or do {
+            my $res = $_->rename_object($otype, $uid, $newuid);
+            $self->{cb}->($_, $res) if($self->{cb});
+            $res or do {
                 la_log(LA_ERR,
                     "Cannot get object $otype/$uid in %s/%s",