Changeset 1200 for trunk/LATMOS-Accounts/lib/LATMOS/Accounts/SyncManager.pm

Timestamp:

12/27/12 18:26:31 (11 years ago)

Author:

nanardon

Message:

store module freshness state in inifile

File:

• trunk/LATMOS-Accounts/lib/LATMOS/Accounts/SyncManager.pm (modified) (7 diffs)

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/SyncManager.pm

@@ -5 +5 @@
 use LATMOS::Accounts::Log;
 use LATMOS::Accounts;
+use Config::IniFiles;
 
 =head1 NAME
@@ -66 +67 @@
 =cut
 
-sub dbrev { $_[0]->{lastrev} }
-
-=head2 updrev
-
-Update status file with with current base revision as restart point
-
-=cut
-
-sub updrev {
+sub dbrev {
     my ($self) = @_;
     my $LA = LATMOS::Accounts->new($self->{config}, noacl => 1);
     my $base = $LA->base;
-    my $newrev = $base->current_rev;
-    $self->{lastrev} = $newrev;
-    return $newrev;
+    return $base->current_rev;
+}
+
+sub _load_state_ini {
+    my ($self) = @_;
+    my $la = LATMOS::Accounts->new($self->{config}, noacl => 1);
+
+    my $state_file =  $la->val('_default_', 'state_dir', '/');
+    $state_file .= '/la-sync-manager.ini';
+    la_log(LA_DEBUG, "Status file is %s", $state_file);
+    if ($state_file && ! -w $state_file) {
+        # don't exists, we have to create it
+        open(my $handle, '>', $state_file) or do {
+            la_log(LA_ERR, "Cannot open build net status file %s",
+                $state_file);
+            return;
+        };
+        print $handle "[_default_]\n";
+        close($handle);
+    }
+    return Config::IniFiles->new(
+        -file => $state_file
+    );
+}
+
+=head2 get_last_rev($module)
+
+Return the last revision the module succeed
+
+=cut
+
+sub get_last_rev {
+    my ($self, $module) = @_;
+
+    my $ini = $self->_load_state_ini or return;
+
+    return ($ini->val($module, 'rev', 0), $ini->val($module, 'time', 0));
 }
 
@@ -94 +121 @@
 }
 
-=head2 process_module($module, $dbrev)
+=head2 process_module($module)
 
 Process C<$module>.
@@ -103 +130 @@
 
 sub process_module {
-    my ($self, $module, $dbrev) = @_;
+    my ($self, $module) = @_;
 
     eval {
@@ -115 +142 @@
             $modtype,
             config => $self->{config},
+            name   => $module,
+            syncm  => $self,
         )
             or do {
@@ -126 +155 @@
         }
 
-        if (!$task->needupd($dbrev, $self)) {
+        my ($lastrev) = $self->get_last_rev($module);
+        my $currentrev = $self->dbrev;
+        if (!$task->needupd($lastrev, $currentrev, $self)) {
             la_log LA_DEBUG, "No change on main base, aborting";
             return 1;
         }
-
 
         my $res = $task->run;
@@ -137 +167 @@
         }
         $task->post if ($res);
+        my $ini = $self->_load_state_ini or return;
+
+        $ini->newval($module, 'rev', $currentrev);
+        my $time = time;
+        $ini->newval($module, 'time', $time);
+        $ini->SetParameterComment(
+            $module, 'time',
+            scalar(localtime(time)),
+        );
+        $ini->RewriteConfig;
+
         la_log LA_DEBUG, "end process $module";
         return $res;