Changeset 2220 for trunk/LATMOS-Accounts/lib/LATMOS

Timestamp:

02/25/19 16:40:07 (5 years ago)

Author:

nanardon

Message:

Add module to recompute object value in background

Location:

trunk/LATMOS-Accounts/lib/LATMOS/Accounts

Files:

• Bases/Sql/upgrade.pm (modified) (4 diffs)
• SyncManager.pm (modified) (1 diff)
• Task/Update.pm (copied) (copied from trunk/LATMOS-Accounts/lib/LATMOS/Accounts/Task/Updatedyndata.pm) (3 diffs)
• Task/Updatedyndata.pm (modified) (1 diff)

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

@@ -1184 +1184 @@
             ],
         },
+        {
+            ver => 30,
+            recompute => 1,
+        },
     );
 
     my $dbi = $self->{_db};
+
+    my $NeedRecompute = 0;
 
     foreach my $maj (@updates) {
@@ -1193 +1199 @@
         }
         $self->log(LA_NOTICE, 'Switching to schema revision: ' . $maj->{ver} . "\n");
-        foreach my $sql (@{ $maj->{sql} }) {
+        foreach my $sql (@{ $maj->{sql} || []}) {
             {
                 my $sqlv = $sql;
@@ -1203 +1209 @@
                 return;
             };
+
+        }
+        if ($maj->{recompute}) {
+            $NeedRecompute = 1;
         }
 
@@ -1212 +1222 @@
             $maj->{ver}, 'schema_version'
         );
+    }
+
+    if ( $NeedRecompute ) {
+        $self->set_global_value('NeedRecomputeObject', 'Yes');
     }
 

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

@@ -38 +38 @@
     };
 
-    foreach my $section (qw(basessynchro refreshexpired updatedyndata)) {
+    foreach my $section (qw(update basessynchro refreshexpired updatedyndata)) {
         if ( !grep {
             lc($ini->val($_, 'type', '')) eq $section

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/Task/Update.pm

@@ -1 @@
-package LATMOS::Accounts::Task::Updatedyndata;
+package LATMOS::Accounts::Task::Update;
 
 use strict;
@@ -14 +14 @@
 =head1 DESCRIPTION
 
-Some base doesn't handle accounts expiration. One way to do it is to synchronize
-user with value denying login (wrong UNIX shell, password entry set to false,
-...).
-
-For performance issue, objects are not written at each synchronisation, only
-when they changes.
-
-This module find expired user and refresh modification time to ensure
-propagation to other database.
+This module update in the background objects that need some value to be recompute
 
 =cut
 
-# Every 10 minutes
-sub runDelay { 5 * 60 }
 
 sub init {
@@ -44 +34 @@
     my ($self) = @_;
 
-    $self->{_base}->PopulateDynData;
+    if ($self->{_base}->get_global_value('NeedRecomputeObject')) {
+        $self->{_base}->log(LA_INFO, "NeedRecomputeObject detected, recomputing objects");
+    } else {
+        return 1;
+    }
+
+    foreach my $otype (qw(user)) {
+        foreach my $name ($self->{_base}->listRealObjects($otype)) {
+            my $object = $self->{_base}->get_object($otype, $name);
+            $object->PostSetAttribute();
+            $self->{_base}->commit;
+        }
+    }
+
+    $self->{_base}->del_global_value('NeedRecomputeObject');
+    $self->{_base}->commit;
 
     1;

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/Task/Updatedyndata.pm

@@ -26 +26 @@
 =cut
 
-# Every 10 minutes
+# Every 5 minutes
 sub runDelay { 5 * 60 }