Changeset 44 for LATMOS-Accounts

Timestamp:

04/25/09 09:23:55 (15 years ago)

Author:

nanardon

Message:

• LA_NO_COMMIT envirronement variable disable commit/rollback

Location:

LATMOS-Accounts/lib/LATMOS/Accounts

Files:

• Bases/Sql.pm (modified) (2 diffs)
• Synchro.pm (modified) (2 diffs)

LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql.pm

@@ -112 +112 @@
 sub commit {
     my ($self) = @_;
+    if ($ENV{LA_NO_COMMIT}) { return 1 }
     $self->db->commit;
 }
@@ -117 +118 @@
 sub rollback {
     my ($self) = @_;
+    if ($ENV{LA_NO_COMMIT}) { return 1 }
     $self->db->rollback;
 }

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

@@ -84 +84 @@
 }
 
+# sync obj $from to $to
+# obj must be L::A::Base::Object based
+
+sub _sync_object {
+    my ($self, $from, $to) = @_;
+    my @common_fields = $self->_common_fields($from, $to);
+
+}
+
+sub _common_fields {
+    my ($self, $from, $to, $otype) = @_;
+    my %fields = ();
+    foreach my $base ($from, $to) {
+        foreach ($base->list_canonicals_fields($otype)) {
+            $fields{$_} ||= 0; # avoid 
+            $fields{$_}++;
+        }
+    }
+    # field having value are in both
+    grep { $fields{$_} == 2 } keys %fields;
+}
+
 sub process {
     my ($self, %options) = @_;
@@ -108 +130 @@
             warn "objects $otype => " . $destbase->type . "\n";
             my %exists = map { $_ => 1 } $destbase->list_objects($otype);
-            foreach (@lobjfrom) {
-                if (!$exists{$_}) {
-                    warn "  $otype $_: created\n";
+            foreach my $uid (@lobjfrom) {
+                if (!$exists{$uid}) {
+                    # TODO cache this:
+                    my @common_fields = $self->_common_fields($self->from, $destbase, $otype);
+
+                    my $sobj = $self->from->get_object($otype, $uid);
+                    my %fields = map { $_ => $sobj->get_c_field($_) } @common_fields;
+                    $destbase->create_c_object($otype, $uid, %fields);
+                    warn "  $otype $uid: created\n";
                 }
             }