Changeset 83 for LATMOS-Accounts/lib/LATMOS/Accounts/Synchro.pm

Timestamp:

05/10/09 19:03:39 (15 years ago)

Author:

nanardon

Message:

• allow to sync specific object

File:

• LATMOS-Accounts/lib/LATMOS/Accounts/Synchro.pm (modified) (2 diffs)

LATMOS-Accounts/lib/LATMOS/Accounts/Synchro.pm

@@ -140 +140 @@
             foreach my $uid (@lobjfrom) {
                 my $sobj = $self->from->get_object($otype, $uid);
-                if ($exists{$uid}) {
-                    my %fields = map { $_ => $sobj->get_c_field($_, 'r') } @common_fields;
-                    my $dobj = $destbase->get_object($otype, $uid);
-                    $dobj->set_c_fields(%fields) unless($self->{options}{test});
-                    warn "  $otype $uid: synched\n";
-                } elsif (!$self->{options}{nocreate} && !$options{nocreate}) {
-                    my %fields = map { $_ => $sobj->get_c_field($_, 'r') } @common_fields;
-                    $destbase->create_c_object($otype, $uid, %fields) unless($self->{options}{test});
-                    warn "  $otype $uid: created\n";
-                }
+                $destbase->sync_object(
+                    $sobj,
+                    nocreate => ($self->{options}{nocreate} || $options{nocreate}),
+                ) unless($self->{options}{test});
+                warn "  $otype $uid: synched\n";
             }
         }
@@ -172 +167 @@
 }
 
+sub sync_object {
+    my ($self, $otype, $uid) = @_;
+    my $sobj = $self->from->get_object($otype, $uid) or return;
+    foreach ($self->to) {
+        $_->sync_object($sobj)
+    }
+    foreach ($self->to) {
+        $_->commit;
+    }
+    1;
+}
+
 sub process {
     my ($self) = @_;