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

Timestamp:

04/25/09 21:18:18 (15 years ago)

Author:

nanardon

Message:

• support database revision, store current revision, allowing to synch only object changed since last sync

File:

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

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

@@ -30 +30 @@
 our $VERSION = (q$Rev$ =~ /^Rev: (\d+) /)[0];
 
-=head2 new($from, $to)
+=head2 new($from, $to, %options)
 
 Create a new synchronisation where $from and $to are LATMOS::Accounts::Base
@@ -38 +38 @@
 
 sub new {
-    my ($class, $from, $to) = @_;
+    my ($class, $from, $to, %options) = @_;
 
-    my $self = {};
+    if ($options{state_file} && ! -w $options{state_file}) {
+        # don't exists, we have to create it
+        open(my $handle, '>', $options{state_file}) or return;
+        close($handle);
+    }
 
+    my $self = Config::IniFiles->new(
+        $options{state_file}
+        ? (-file => $options{state_file})
+        : (),
+    );
+
+    
     $self->{from} = $from;
 
@@ -105 +116 @@
     $self->load_dest and return;
     
+    # tracking current base revision:
+    my $current_rev = $self->from->current_rev;
+
     # listing existing obj one time:
     foreach my $otype ($self->from->list_supported_objects) {
@@ -115 +129 @@
         # loading object list one time for all
         # TODO optimize this, using rev of objects
-        my @lobjfrom = $self->from->list_objects($otype);
 
         warn "Sync objects $otype\n";
         foreach my $destbase (@obj_dest_base) {
+            my @lobjfrom = $self->from->list_objects_from_rev(
+                $otype,
+                $self->val($self->from->label, $destbase->label),
+            );
             warn "objects $otype => " . $destbase->type . "\n";
             my @common_fields = $self->_common_fields($self->from, $destbase, $otype);
@@ -141 +158 @@
 
     foreach ($self->to) {
-        $_->commit;
+        $_->commit or next;
+        $self->newval($self->from->label, $_->label, $current_rev) if($current_rev);
     }
 
+    $self->RewriteConfig if($self->GetFileName);
+    
     1;
 }