--- bin/ldap.pl 2008/03/13 14:22:53 11 +++ bin/ldap.pl 2008/04/09 21:32:34 61 @@ -6,57 +6,53 @@ use lib 'lib'; use Jifty; -use Net::LDAP; +use A3C::LDAP; use Data::Dump qw/dump/; +use Getopt::Long; BEGIN { Jifty->new; }; +Jifty->web->request(Jifty::Request->new); +Jifty->web->response(Jifty::Response->new); -my $ldap_config = Jifty->config->app('LDAP'); -Jifty->log->debug( "config->app(LDAP) = ",dump( $ldap_config ) ); - -my $ldap = Net::LDAP->new( Jifty->config->app('LDAP')->{Server} ) or die "$@"; - -# an anonymous bind -#my $mesg = $ldap->bind; -my $mesg = $ldap->bind( - DN => Jifty->config->app('LDAP')->{DN}, - password => Jifty->config->app('LDAP')->{Password}, +my $limit = 0; +my @models; +GetOptions( + 'limit=i', => \$limit, + 'model=s', => \@models, ); -# perform a search -$mesg = $ldap->search( - base => "dc=skole,dc=hr", -# filter => "(&(sn=Barr) (o=Texas Instruments))", - filter => "(objectClass=hrEduPerson)", - sizelimit => 100, # 0 = off -); +my $ldap = A3C::LDAP->new; -if ( $mesg->code ) { - warn $mesg->code, ": ", $mesg->error, "\n"; -} +if ( @models ) { -Jifty->log->info( "found ", $mesg->count, " entries" ); + Jifty->log->info( 'syncing: ', join(',', @models) ); -foreach my $entry ( $mesg->entries ) { + foreach my $model ( @models ) { + my $collection = $ldap->collection( $model, limit => $limit ); + Jifty->log->info( 'found ', $collection->count, ' entries for ', $model ); + } +} else { - $entry->dump; + Jifty->log->info( 'syncing all organizations and users' ); - my $data; - my $user = A3C::Model::User->new; + my $orgs = $ldap->collection( 'Organization', limit => $limit ); - my @columns = map { $_->name } $user->columns; - #warn "# columns = ",dump( @columns ); + my $o_nr = 1; - foreach my $attr ( $entry->attributes ) { - if ( grep(/^\Q$attr\E$/, @columns ) ) { - $data->{$attr} = $entry->get_value( $attr ); + while ( my $o = $orgs->next ) { + Jifty->log->info( 'sync organization ', $o_nr++, '/', $orgs->count, ' ', $o->name ); + my $action = Jifty->web->new_action( + class => 'SyncOrganization', + moniker => 'sync', + arguments => { + cn => $o->cn, + } + ); + $action->run; + if ( $action->result->success ) { + Jifty->log->info( $action->result->message ); } else { - warn "model ",ref($user)," doesn't have column $attr\n"; + Jifty->log->error( "Can't sync ", $o->name ); } } - - Jifty->log->debug( dump( $data ) ); - - $user->load_or_create( %$data ); } -