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

Timestamp:

12/01/15 09:25:48 (9 years ago)

Author:

nanardon

Message:

Add filter based aliases (dynamics)

Location:

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/Bases

Files:

• Sql.pm (modified) (1 diff)
• Sql/Aliases.pm (modified) (3 diffs)

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

@@ -137 +137 @@
 }
 
+sub _sync_dyn_aliases {
+    my ($self) = @_;
+
+    my @groups = $self->search_objects('aliases', 'autoMemberFilter=*');
+
+    foreach (@groups) {
+        my $g = $self->get_object('aliases', $_) or next;
+        $g->populate_dyn_aliases;
+    }
+}
+
 sub _commit {
     my ($self) = @_;
 
     $self->_sync_dyn_group;
+    $self->_sync_dyn_aliases;
 
     if ($ENV{LA_NO_COMMIT}) {

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

@@ -77 +77 @@
                     );
                 },
+                ro => sub {
+                    $_[0] && $_[0]->_get_c_field('autoMemberFilter') ? 1 : 0
+                },
             },
             finalpoint      => {
@@ -136 +139 @@
             },
             comment => { },
+            autoMemberFilter => {
+                multiple => 1,
+                set => sub {
+                    my ($self, $data) = @_;
+                    $self->object->set_fields($self->name, $data) or return;
+                    $self->object->populate_dyn_aliases;
+                    return 1;
+                }
+
+            },
+            autoExclude => {
+                multiple => 1,
+                reference => 'user',
+            },
         }
     )
@@ -186 +203 @@
 }
 
+=head2 populate_dyn_aliases
+
+Synchronise aliase's forward according filter set into C<autoMemberFilter> attribute.
+
+=cut
+
+sub populate_dyn_aliases {
+    my ($self) = @_;
+
+
+    if (!$self->get_field('autoMemberFilter')) {
+        return 0;
+    }
+
+    my %email = $self->base->attributes_summary_by_object('user', 'mail');
+
+    $self->base->log(LA_DEBUG,
+        "Populating alaises %s from autoMemberFilter attribute",
+        $self->id
+    );
+    my $filter = $self->get_field('autoMemberFilter');
+    my $autoex = $self->get_field('autoExclude');
+    my %exclude = map { $_ => 1 } grep { $_  } (ref $autoex ? @$autoex : $autoex);
+
+    my @users = $self->base->search_objects('user', ref $filter ? @{ $filter } : $filter);
+
+    my @forward = ();
+
+    foreach my $user (@users) {
+        $exclude{$user} and next;
+        $email{$user} or next;
+        my $mail = $email{$user}->[0] or next;
+        push(@forward, $mail);
+    }
+
+    my $sth = $self->base->db->prepare_cached(
+        'UPDATE aliases SET forward = ? WHERE ikey = ?'
+    );
+    if (!$sth->execute(\@forward, $self->Iid)) {
+        $self->base->log(LA_ERR, "Cannot update forward for aliases %s: %s", $self->id, $sth->errstr());
+        return;
+    }
+
+    return 1;
+}
 
 1;