include/class_ldap.inc

   1 <?php
   2 /*****************************************************************************
   3   newldap.inc - version 1.0
   4   Copyright (C) 2003 Alejandro Escanero Blanco <alex@ofmin.com>
   5   Copyright (C) 2004 Cajus Pollmeier <pollmeier@gonicus.de>
   6
   7   Based in code of ldap.inc of
   8   Copyright (C) 1998  Eric Kilfoil <eric@ipass.net>
   9  *****************************************************************************/
  10
  11 define("ALREADY_EXISTING_ENTRY",-10001);
  12 define("UNKNOWN_TOKEN_IN_LDIF_FILE",-10002);
  13 define("NO_FILE_UPLOADED",10003);
  14 define("INSERT_OK",10000);
  15 define("COLON_OVERRIDE", TRUE);
  16
  17 class LDAP{
  18
  19   var $hascon   =false;
  20   var $hasres   =false;
  21   var $reconnect=false;
  22   var $tls      = false;
  23   var $basedn   ="";
  24   var $cid;
  25   var $error    = ""; // Any error messages to be returned can be put here
  26   var $start    = 0; // 0 if we are fetching the first entry, otherwise 1
  27   var $objectClasses = array(); // Information read from slapd.oc.conf
  28   var $binddn   = "";
  29   var $bindpw   = "";
  30   var $hostname = "";
  31   var $follow_referral = FALSE;
  32   var $referrals= array();
  33
  34   function LDAP($binddn,$bindpw, $hostname, $follow_referral= FALSE, $tls= FALSE)
  35   {
  36     $this->follow_referral= $follow_referral;
  37     $this->tls=$tls;
  38     $this->binddn=$this->convert($binddn);
  39
  40     $this->bindpw=$bindpw;
  41     $this->hostname=$hostname;
  42     $this->connect();
  43   }
  44
  45
  46   function convert($dn)
  47   {
  48     if (COLON_OVERRIDE == TRUE){
  49       $res= preg_replace("/\\\\,/", '###GOSAREPLACED###', $dn);
  50       $res= preg_replace("/\\\\2C/", '###GOSAREPLACED###', $res);
  51       #if ($dn != $res){
  52       #  echo "Conversation from '$dn' to '$res'<br>";
  53       #}
  54       return ($res);
  55     } else {
  56       return ($dn);
  57     }
  58   }
  59
  60
  61   function fix($dn)
  62   {
  63     if (COLON_OVERRIDE == TRUE){
  64       $res= preg_replace("/###GOSAREPLACED###/", '\,', $dn);
  65       #if ($dn != $res){
  66       #  echo "Fix from '$dn' to '$res'<br>";
  67       #}
  68       return ($res);
  69     } else {
  70       return ($dn);
  71     }
  72   }
  73
  74
  75   function connect()
  76   {
  77     $this->hascon=false;
  78     $this->reconnect=false;
  79     if ($this->cid= @ldap_connect($this->hostname)) {
  80       @ldap_set_option($this->cid, LDAP_OPT_PROTOCOL_VERSION, 3);
  81       if (function_exists("ldap_set_rebind_proc") && $this->follow_referral) {
  82         @ldap_set_option($this->cid, LDAP_OPT_REFERRALS, 1);
  83         @ldap_set_rebind_proc($this->cid, array(&$this, "rebind"));
  84       }
  85       if (function_exists("ldap_start_tls") && $this->tls){
  86         @ldap_start_tls($this->cid);
  87       }
  88
  89       $this->error = "No Error";
  90       if ($bid = @ldap_bind($this->cid, $this->fix($this->binddn), $this->bindpw)) {
  91         $this->error = "Success";
  92         $this->hascon=true;
  93       } else {
  94         if ($this->reconnect){
  95           if ($this->error != "Success"){
  96             $this->error = "Could not rebind to " . $this->binddn;
  97           }
  98         } else {
  99           $this->error = "Could not bind to " . $this->binddn;
 100         }
 101       }
 102     } else {
 103       $this->error = "Could not connect to LDAP server";
 104     }
 105   }
 106
 107   function rebind($ldap, $referral)
 108   {
 109     $credentials= $this->get_credentials($referral);
 110     if (@ldap_bind($ldap, $this->fix($credentials['ADMIN']), $credentials['PASSWORD'])) {
 111       $this->error = "Success";
 112       $this->hascon=true;
 113       $this->reconnect= true;
 114       return (0);
 115     } else {
 116       $this->error = "Could not bind to " . $credentials['ADMIN'];
 117       return NULL;
 118     }
 119   }
 120
 121   function reconnect()
 122   {
 123     if ($this->reconnect){
 124       @ldap_unbind($this->cid);
 125       $this->cid = NULL;
 126     }
 127   }
 128
 129   function unbind()
 130   {
 131     @ldap_unbind($this->cid);
 132     $this->cid = NULL;
 133   }
 134
 135   function disconnect()
 136   {
 137     if($this->hascon){
 138       @ldap_close($this->cid);
 139       $this->hascon=false;
 140     }
 141   }
 142
 143   function cd($dir)
 144   {
 145     if ($dir == "..")
 146       $this->basedn = $this->getParentDir();
 147     else
 148       $this->basedn = $this->convert($dir);
 149   }
 150
 151   function getParentDir($basedn = "")
 152   {
 153     if ($basedn=="")
 154       $basedn = $this->basedn;
 155     else
 156       $basedn = $this->convert($this->basedn);
 157     return(ereg_replace("[^,]*[,]*[ ]*(.*)", "\\1", $basedn));
 158   }
 159
 160   function search($filter, $attrs= array())
 161   {
 162     if($this->hascon){
 163       if ($this->reconnect) $this->connect();
 164       $this->clearResult();
 165       $this->sr = @ldap_search($this->cid, $this->fix($this->basedn), $filter, $attrs);
 166       $this->error = @ldap_error($this->cid);
 167       $this->resetResult();
 168       $this->hasres=true;
 169
 170       return($this->sr);
 171     }else{
 172       $this->error = "Could not connect to LDAP server";
 173       return("");
 174     }
 175   }
 176
 177   function ls($filter = "(objectclass=*)", $basedn = "",$attrs = array("*"))
 178   {
 179     if($this->hascon){
 180       if ($this->reconnect) $this->connect();
 181       $this->clearResult();
 182       if ($basedn == "")
 183         $basedn = $this->basedn;
 184       else
 185         $basedn= $this->convert($basedn);
 186       $this->sr = @ldap_list($this->cid, $this->fix($basedn), $filter,$attrs);
 187       $this->error = @ldap_error($this->cid);
 188       $this->resetResult();
 189       $this->hasres=true;
 190       return($this->sr);
 191     }else{
 192       $this->error = "Could not connect to LDAP server";
 193       return("");
 194     }
 195   }
 196
 197   function cat($dn,$attrs= array("*"))
 198   {
 199     if($this->hascon){
 200       if ($this->reconnect) $this->connect();
 201       $this->clearResult();
 202       $filter = "(objectclass=*)";
 203       $this->sr = @ldap_read($this->cid, $this->fix($dn), $filter,$attrs);
 204       $this->error = @ldap_error($this->cid);
 205       $this->resetResult();
 206       $this->hasres=true;
 207       return($this->sr);
 208     }else{
 209       $this->error = "Could not connect to LDAP server";
 210       return("");
 211     }
 212   }
 213
 214   function set_size_limit($size)
 215   {
 216     /* Ignore zero settings */
 217     if ($size == 0){
 218       @ldap_set_option($this->cid, LDAP_OPT_SIZELIMIT, 10000000);
 219     }
 220     if($this->hascon){
 221       @ldap_set_option($this->cid, LDAP_OPT_SIZELIMIT, $size);
 222     } else {
 223       $this->error = "Could not connect to LDAP server";
 224     }
 225   }
 226
 227   function fetch()
 228   {
 229     if($this->hascon){
 230       if($this->hasres){
 231         if ($this->start == 0)
 232         {
 233           $this->start = 1;
 234           $this->re= @ldap_first_entry($this->cid, $this->sr);
 235         } else {
 236           $this->re= @ldap_next_entry($this->cid, $this->re);
 237         }
 238         if ($this->re)
 239         {
 240           $att= @ldap_get_attributes($this->cid, $this->re);
 241           $att['dn']= $this->convert(@ldap_get_dn($this->cid, $this->re));
 242         }
 243         $this->error = @ldap_error($this->cid);
 244         if (!isset($att)){
 245           $att= array();
 246         }
 247         return($att);
 248       }else{
 249         $this->error = "Perform a Fetch with no Search";
 250         return("");
 251       }
 252     }else{
 253       $this->error = "Could not connect to LDAP server";
 254       return("");
 255     }
 256   }
 257
 258   function resetResult()
 259   {
 260     $this->start = 0;
 261   }
 262
 263   function clearResult()
 264   {
 265     if($this->hasres){
 266       $this->hasres = false;
 267       @ldap_free_result($this->sr);
 268     }
 269   }
 270
 271   function getDN()
 272   {
 273     if($this->hascon){
 274       if($this->hasres){
 275
 276         if(!$this->re)
 277           {
 278           $this->error = "Perform a Fetch with no valid Result";
 279           }
 280           else
 281           {
 282           $rv = @ldap_get_dn($this->cid, $this->re);
 283
 284           $this->error = @ldap_error($this->cid);
 285           return($this->convert($rv));
 286            }
 287       }else{
 288         $this->error = "Perform a Fetch with no Search";
 289         return("");
 290       }
 291     }else{
 292       $this->error = "Could not connect to LDAP server";
 293       return("");
 294     }
 295   }
 296
 297   function count()
 298   {
 299     if($this->hascon){
 300       if($this->hasres){
 301         $rv = @ldap_count_entries($this->cid, $this->sr);
 302         $this->error = @ldap_error($this->cid);
 303         return($rv);
 304       }else{
 305         $this->error = "Perform a Fetch with no Search";
 306         return("");
 307       }
 308     }else{
 309       $this->error = "Could not connect to LDAP server";
 310       return("");
 311     }
 312   }
 313
 314   function rm($attrs = "", $dn = "")
 315   {
 316     if($this->hascon){
 317       if ($this->reconnect) $this->connect();
 318       if ($dn == "")
 319         $dn = $this->basedn;
 320
 321       $r = @ldap_mod_del($this->cid, $this->fix($dn), $attrs);
 322       $this->error = @ldap_error($this->cid);
 323       return($r);
 324     }else{
 325       $this->error = "Could not connect to LDAP server";
 326       return("");
 327     }
 328   }
 329
 330   function rename($attrs, $dn = "")
 331   {
 332     if($this->hascon){
 333       if ($this->reconnect) $this->connect();
 334       if ($dn == "")
 335         $dn = $this->basedn;
 336
 337       $r = @ldap_mod_replace($this->cid, $this->fix($dn), $attrs);
 338       $this->error = @ldap_error($this->cid);
 339       return($r);
 340     }else{
 341       $this->error = "Could not connect to LDAP server";
 342       return("");
 343     }
 344   }
 345
 346   function rmdir($deletedn)
 347   {
 348     if($this->hascon){
 349       if ($this->reconnect) $this->connect();
 350       $r = @ldap_delete($this->cid, $this->fix($deletedn));
 351       $this->error = @ldap_error($this->cid);
 352       return($r ? $r : 0);
 353     }else{
 354       $this->error = "Could not connect to LDAP server";
 355       return("");
 356     }
 357   }
 358
 359   /**
 360   *  Function rmdir_recursive
 361   *
 362   *  Description: Based in recursive_remove, adding two thing: full subtree remove, and delete own node.
 363   *  Parameters:  The dn to delete
 364   *  GiveBack:    True on sucessfull , 0 in error, and "" when we don't get a ldap conection
 365   *
 366   */
 367
 368   function rmdir_recursive($deletedn)
 369   {
 370     if($this->hascon){
 371       if ($this->reconnect) $this->connect();
 372       $delarray= array();
 373
 374       /* Get sorted list of dn's to delete */
 375       $this->ls ("(objectClass=*)",$deletedn);
 376       while ($this->fetch()){
 377         $deldn= $this->getDN();
 378         $delarray[$deldn]= strlen($deldn);
 379       }
 380       arsort ($delarray);
 381       reset ($delarray);
 382
 383       /* Really Delete ALL dn's in subtree */
 384       foreach ($delarray as $key => $value){
 385         $this->rmdir_recursive($key);
 386       }
 387
 388       /* Finally Delete own Node */
 389       $r = @ldap_delete($this->cid, $this->fix($deletedn));
 390       $this->error = @ldap_error($this->cid);
 391       return($r ? $r : 0);
 392     }else{
 393       $this->error = "Could not connect to LDAP server";
 394       return("");
 395     }
 396   }
 397
 398   /* Copy given attributes and sub-dns with attributes to destination dn
 399   */
 400   function copy_FAI_resource_recursive($sourcedn,$destinationdn,$type="branch",$is_first = true,$depth=0)
 401   {
 402     error_reporting(E_ALL);
 403
 404     if($is_first){
 405       echo "<font style='font-size:11px;'><h4>".
 406               sprintf(_("Creating duplicate of %s in %s"),"<br><i>".$sourcedn."</i><br>","<br><i>".$destinationdn."</i><br>")."</h4>";
 407     }else{
 408       if($depth == 1 ){
 409         echo "<br><h3>"._("Processing")." : ".preg_replace("/,.*$/","",$destinationdn)."</h3>";
 410       }else{
 411         $tmp = split(",",$sourcedn);
 412         echo "<b>Current object : ";
 413         for($i = 0; $i < ($depth -1 ) ; $i ++) {
 414           echo preg_replace("/^.*=/","",$tmp[$i])." ";
 415         }
 416         echo "</b>";
 417         echo ": <br>";
 418
 419         $deststr = $destinationdn;
 420         if(strlen($deststr) > 96){
 421           $deststr = substr($deststr,0,96)."...";
 422         }
 423
 424         echo "".$deststr."</br>";
 425       }
 426     }
 427
 428     if($this->hascon){
 429       if ($this->reconnect) $this->connect();
 430
 431       /* Save base dn */
 432       $basedn= $this->basedn;
 433       $delarray= array();
 434
 435       /* Check if destination entry already exists */
 436       $this->cat($destinationdn);
 437
 438       if($this->count()){
 439         return;
 440       }else{
 441
 442         $this->clearResult();
 443
 444         /* Get source entry */
 445         $this->cd($basedn);
 446         $this->cat($sourcedn);
 447         $attr = $this->fetch();
 448
 449         /* Error while fetching object / attribute abort*/
 450         if((!$attr) || (count($attr)) ==0) {
 451           echo "error while fetching source dn ..";
 452           return;
 453         }
 454
 455         /* check if this is a department */
 456         if(in_array("organizationalUnit",$attr['objectClass'])){
 457           $attr['dn'] = $this->convert($destinationdn);
 458           $this->cd($basedn);
 459           $this->create_missing_trees($destinationdn);
 460           $this->cd($destinationdn);
 461
 462           /* If is first entry, append FAIbranch to department entry */
 463           if($is_first){
 464             $attr= $this->fetch($this->cat($destinationdn));
 465
 466             /* Filter unneeded informations */
 467             foreach($attr as $key => $value){
 468               if(is_numeric($key)) unset($attr[$key]);
 469               if(isset($attr[$key]['count'])){
 470                 if(is_array($attr[$key])){
 471                   unset($attr[$key]['count']);
 472                 }
 473               }
 474             }
 475
 476             unset($attr['count']);
 477             unset($attr['dn']);
 478
 479             /* Add marking attribute */
 480             $attr['objectClass'][] = "FAIbranch";
 481
 482             /* Add this entry */
 483             $this->modify($attr);
 484           }
 485           echo "Department";
 486         }else{
 487           echo "Object";
 488         /* If this is no department */
 489           foreach($attr as $key => $value){
 490
 491             if(in_array($key ,array("FAItemplateFile","FAIscript"))){
 492               $sr= ldap_read($this->cid, $this->fix($sourcedn), "(objectClass=FAIclass)", array($key));
 493               $ei= ldap_first_entry($this->cid, $sr);
 494               $tmp = (@ldap_get_values_len($this->cid, $ei,$key));
 495               if(is_array($tmp)){
 496                 $attr[$key] = $tmp;
 497               }
 498             }
 499
 500             if(is_numeric($key)) unset($attr[$key]);
 501             if(isset($attr[$key]['count'])){
 502               if(is_array($attr[$key])){
 503                 unset($attr[$key]['count']);
 504               }
 505             }
 506           }
 507           unset($attr['count']);
 508           unset($attr['dn']);
 509
 510           if(!in_array("gosaApplication" , $attr['objectClass'])){
 511             if($type=="branch"){
 512               $attr['FAIstate'] ="branch";
 513             }elseif($type=="freeze"){
 514               $attr['FAIstate'] ="freeze";
 515             }else{
 516               print_red(_("Unknown FAIstate %s"),$type);
 517             }
 518           }
 519
 520           /* Add entry */
 521           $this->cd($destinationdn);
 522           $a = $this->fetch($this->cat($destinationdn));
 523           if(!count($a)){
 524             $this->add($attr);
 525           }
 526
 527           if($this->error != "Success"){
 528             /* Some error occured */
 529             print "---------------------------------------------";
 530             print $this->get_error()."<br>";
 531             print $sourcedn."<br>";
 532             print $destinationdn."<br>";
 533             print_a( $attr);
 534             exit();
 535           }
 536         }
 537       }
 538
 539       $this->ls ("(objectClass=*)",$sourcedn);
 540       while ($this->fetch()){
 541         $deldn= $this->getDN();
 542         $delarray[$deldn]= strlen($deldn);
 543       }
 544       asort ($delarray);
 545       reset ($delarray);
 546
 547        $depth ++;
 548       foreach($delarray as $dn => $bla){
 549         if($dn != $destinationdn){
 550           $this->cd($basedn);
 551           $item = $this->fetch($this->cat($dn));
 552           if(!in_array("FAIbranch",$item['objectClass'])){
 553             $this->copy_FAI_resource_recursive($dn,str_replace($sourcedn,$destinationdn,$dn),$type,false,$depth);
 554           }
 555         }
 556       }
 557     }
 558     if($is_first){
 559       echo "<br><br><b>"._("Successfully finished")."</b></font>";
 560     }
 561
 562   }
 563
 564   function modify($attrs)
 565   {
 566     if(count($attrs) == 0){
 567       return (0);
 568     }
 569     if($this->hascon){
 570       if ($this->reconnect) $this->connect();
 571       $r = @ldap_modify($this->cid, $this->fix($this->basedn), $attrs);
 572       $this->error = @ldap_error($this->cid);
 573       return($r ? $r : 0);
 574     }else{
 575       $this->error = "Could not connect to LDAP server";
 576       return("");
 577     }
 578   }
 579
 580   function add($attrs)
 581   {
 582     if($this->hascon){
 583       if ($this->reconnect) $this->connect();
 584       $r = @ldap_add($this->cid, $this->fix($this->basedn), $attrs);
 585       $this->error = @ldap_error($this->cid);
 586       return($r ? $r : 0);
 587     }else{
 588       $this->error = "Could not connect to LDAP server";
 589       return("");
 590     }
 591   }
 592
 593   function create_missing_trees($target)
 594   {
 595     /* Ignore create_missing trees if the base equals target */
 596     if ($target == $this->basedn){
 597      return;
 598     }
 599     $l= array_reverse(explode(",", preg_replace("/,".$this->basedn."/", "", $target)));
 600     $cdn= $this->basedn;
 601     foreach ($l as $part){
 602       $cdn= "$part,$cdn";
 603
 604       /* Ignore referrals */
 605       $found= false;
 606       foreach($this->referrals as $ref){
 607         $base= preg_replace('!^[^:]+://[^/]+/([^?]+).*$!', '\\1', $ref['URL']);
 608         if ($base == $cdn){
 609           $found= true;
 610           break;
 611         }
 612       }
 613       if ($found){
 614         continue;
 615       }
 616
 617       $this->cat ($cdn);
 618       $attrs= $this->fetch();
 619
 620       /* Create missing entry? */
 621       if (!count ($attrs)){
 622         $type= preg_replace('/^([^=]+)=.*$/', '\\1', $cdn);
 623         $param= preg_replace('/^[^=]+=([^,]+),.*$/', '\\1', $cdn);
 624
 625         $na= array();
 626         switch ($type){
 627           case 'ou':
 628             $na["objectClass"]= "organizationalUnit";
 629             $na["ou"]= $param;
 630             break;
 631           case 'dc':
 632             $na["objectClass"]= array("dcObject", "top", "locality");
 633             $na["dc"]= $param;
 634             break;
 635           default:
 636             print_red(sprintf(_("Autocreation of type '%s' is currently not supported. Please report to the GOsa team."), $type));
 637             echo $_SESSION['errors'];
 638             exit;
 639         }
 640         $this->cd($cdn);
 641         $this->add($na);
 642       }
 643     }
 644   }
 645
 646   function recursive_remove()
 647   {
 648     $delarray= array();
 649
 650     /* Get sorted list of dn's to delete */
 651     $this->search ("(objectClass=*)");
 652     while ($this->fetch()){
 653       $deldn= $this->getDN();
 654       $delarray[$deldn]= strlen($deldn);
 655     }
 656     arsort ($delarray);
 657     reset ($delarray);
 658
 659     /* Delete all dn's in subtree */
 660     foreach ($delarray as $key => $value){
 661       $this->rmdir($key);
 662     }
 663   }
 664
 665   function get_attribute($dn, $name,$r_array=0)
 666   {
 667     $data= "";
 668     if ($this->reconnect) $this->connect();
 669     $sr= @ldap_read($this->cid, $this->fix($dn), "objectClass=*", array("$name"));
 670
 671     /* fill data from LDAP */
 672     if ($sr) {
 673       $ei= @ldap_first_entry($this->cid, $sr);
 674       if ($ei) {
 675         if ($info= @ldap_get_values_len($this->cid, $ei, "$name")){
 676           $data= $info[0];
 677         }
 678
 679       }
 680     }
 681     if($r_array==0)
 682     return ($data);
 683     else
 684     return ($info);
 685
 686
 687   }
 688
 689
 690
 691   function get_additional_error()
 692   {
 693     $error= "";
 694     @ldap_get_option ($this->cid, LDAP_OPT_ERROR_STRING, $error);
 695     return ($error);
 696   }
 697
 698   function get_error()
 699   {
 700     if ($this->error == 'Success'){
 701       return $this->error;
 702     } else {
 703       $error= $this->error." (".$this->get_additional_error().")";
 704       return $error;
 705     }
 706   }
 707
 708   function get_credentials($url, $referrals= NULL)
 709   {
 710     $ret= array();
 711     $url= preg_replace('!\?\?.*$!', '', $url);
 712     $server= preg_replace('!^([^:]+://[^/]+)/.*$!', '\\1', $url);
 713
 714     if ($referrals == NULL){
 715       $referrals= $this->referrals;
 716     }
 717
 718     if (isset($referrals[$server])){
 719       return ($referrals[$server]);
 720     } else {
 721       $ret['ADMIN']= $this->fix($this->binddn);
 722       $ret['PASSWORD']= $this->bindpw;
 723     }
 724
 725     return ($ret);
 726   }
 727
 728
 729   function gen_ldif ($dn, $filter= "(objectClass=*)", $attributes= array('*'), $recursive= TRUE)
 730   {
 731     $display= "";
 732
 733     if ($recursive){
 734       $this->cd($dn);
 735       $this->search("$filter", array('dn'));
 736       while ($attrs= $this->fetch()){
 737         $display.= $this->gen_one_entry($attrs['dn'], $filter, $attributes);
 738         $display.= "\n";
 739       }
 740     } else {
 741       $display.= $this->gen_one_entry($dn);
 742     }
 743
 744     return ($display);
 745   }
 746
 747 function gen_xls ($dn, $filter= "(objectClass=*)", $attributes= array('*'), $recursive= TRUE,$r_array=0)
 748   {
 749     $display= "";
 750
 751       $this->cd($dn);
 752       $this->search("$filter");
 753
 754       $i=0;
 755       while ($attrs= $this->fetch()){
 756         $j=0;
 757
 758         foreach ($attributes as $at){
 759           $display[$i][$j]= $this->get_attribute($attrs['dn'], $at,$r_array);
 760           $j++;
 761         }
 762
 763         $i++;
 764       }
 765
 766     return ($display);
 767   }
 768
 769
 770   function gen_one_entry($dn, $filter= "(objectClass=*)" , $name= array("*"))
 771   {
 772     $ret = "";
 773     $data = "";
 774     if($this->reconnect){
 775       $this->connect();
 776     }
 777
 778     /* Searching Ldap Tree */
 779     $sr= @ldap_read($this->cid, $this->fix($dn), $filter, $name);
 780
 781     /* Get the first entry */
 782     $entry= @ldap_first_entry($this->cid, $sr);
 783
 784     /* Get all attributes related to that Objekt */
 785     $atts = array();
 786
 787     /* Assemble dn */
 788     $atts[0]['name']  = "dn";
 789     $atts[0]['value'] = array('count' => 1, 0 => $dn);
 790
 791     /* Reset index */
 792     $i = 1 ;
 793   $identifier = array();
 794     $attribute= @ldap_first_attribute($this->cid,$entry,$identifier);
 795     while ($attribute) {
 796       $i++;
 797       $atts[$i]['name']  = $attribute;
 798       $atts[$i]['value'] = @ldap_get_values_len($this->cid, $entry, "$attribute");
 799
 800       /* Next one */
 801       $attribute= @ldap_next_attribute($this->cid,$entry,$identifier);
 802     }
 803
 804     foreach($atts as $at)
 805     {
 806       for ($i= 0; $i<$at['value']['count']; $i++){
 807
 808         /* Check if we must encode the data */
 809         if(!preg_match('/^[a-z0-9+@#.=, \/ -]+$/i', $at['value'][$i])) {
 810           $ret .= $at['name'].":: ".base64_encode($at['value'][$i])."\n";
 811         } else {
 812           $ret .= $at['name'].": ".$at['value'][$i]."\n";
 813         }
 814       }
 815     }
 816
 817     return($ret);
 818   }
 819
 820
 821   function dn_exists($dn)
 822   {
 823     return @ldap_list($this->cid, $this->fix($dn), "(objectClass=*)", array("objectClass"));
 824   }
 825
 826
 827
 828   function import_complete_ldif($str_attr,&$error,$overwrite,$cleanup)
 829   {
 830     if($this->reconnect) $this->connect();
 831
 832     /* First we have to splitt the string ito detect empty lines
 833        An empty line indicates an new Entry */
 834     $entries = split("\n",$str_attr);
 835
 836     $data = "";
 837     $cnt = 0;
 838     $current_line = 0;
 839
 840     /* Every single line ... */
 841     foreach($entries as $entry) {
 842       $current_line ++;
 843
 844       /* Removing Spaces to ..
 845          .. test if a new entry begins */
 846       $tmp  = str_replace(" ","",$data );
 847
 848       /* .. prevent empty lines in an entry */
 849       $tmp2 = str_replace(" ","",$entry);
 850
 851       /* If the Block ends (Empty Line) */
 852       if((empty($entry))&&(!empty($tmp))) {
 853         /* Add collected lines as a complete block */
 854         $all[$cnt] = $data;
 855         $cnt ++;
 856         $data ="";
 857       } else {
 858
 859         /* Append lines ... */
 860         if(!empty($tmp2)) {
 861           /* check if we need base64_decode for this line */
 862           if(ereg("::",$tmp2))
 863           {
 864             $encoded = split("::",$entry);
 865             $attr  = $encoded[0];
 866             $value = base64_decode($encoded[1]);
 867             /* Add linenumber */
 868             $data .= $current_line."#".$attr.":".$value."\n";
 869           }
 870           else
 871           {
 872             /* Add Linenumber */
 873             $data .= $current_line."#".$entry."\n";
 874           }
 875         }
 876       }
 877     }
 878
 879     /* The Data we collected is not in the array all[];
 880        For example the Data is stored like this..
 881
 882        all[0] = "1#dn : .... \n
 883        2#ObjectType: person \n ...."
 884
 885        Now we check every insertblock and try to insert */
 886     foreach ( $all as $single) {
 887       $lineone = split("\n",$single);
 888       $ndn = split("#", $lineone[0]);
 889       $line = $ndn[1];
 890
 891       $dnn = split (":",$line);
 892       $current_line = $ndn[0];
 893       $dn    = $dnn[0];
 894       $value = $dnn[1];
 895
 896       /* Every block must begin with a dn */
 897       if($dn != "dn") {
 898         $error= sprintf(_("This is not a valid DN: '%s'. A block for import should begin with 'dn: ...' in line %s"), $line, $current_line);
 899         return -2;
 900       }
 901
 902       /* Should we use Modify instead of Add */
 903       $usemodify= false;
 904
 905       /* Delete before insert */
 906       $usermdir= false;
 907
 908       /* The dn address already exists! */
 909       if (($this->dn_exists($value))&&((!$overwrite)&&(!$cleanup))) {
 910
 911         $error= sprintf(_("The dn: '%s' (from line %s) already exists in the LDAP database."), $line, $current_line);
 912         return ALREADY_EXISTING_ENTRY;
 913
 914       } elseif(($this->dn_exists($value))&&($cleanup)){
 915
 916         /* Delete first, then add */
 917         $usermdir = true;
 918
 919       } elseif(($this->dn_exists($value))&&($overwrite)) {
 920
 921         /* Modify instead of Add */
 922         $usemodify = true;
 923       }
 924
 925       /* If we can't Import, return with a file error */
 926       if(!$this->import_single_entry($single,$usemodify,$usermdir) ) {
 927         $error= sprintf(_("Error while importing dn: '%s', please check your LDIF from line %s on!"), $line,
 928                         $current_line);
 929         return UNKNOWN_TOKEN_IN_LDIF_FILE;      }
 930     }
 931
 932     return (INSERT_OK);
 933   }
 934
 935
 936   /* Imports a single entry */
 937   function import_single_entry($str_attr,$modify,$delete)
 938   {
 939     if($this->reconnect) $this->connect();
 940
 941     $ret = false;
 942     $rows= split("\n",$str_attr);
 943     $data= false;
 944
 945     foreach($rows as $row) {
 946
 947       /* Check if we use Linenumbers (when import_complete_ldif is called we use
 948          Linenumbers) Linenumbers are use like this 123#attribute : value */
 949       if(!empty($row)) {
 950         if((strpos($row,"#")!=FALSE)&&(strpos($row,"#")<strpos($row,":"))) {
 951
 952           /* We are using line numbers
 953              Because there is a # before a : */
 954           $tmp1= split("#",$row);
 955           $current_line= $tmp1[0];
 956           $row= $tmp1[1];
 957         }
 958
 959         /* Split the line into  attribute  and value */
 960         $attr   = split(":", $row);
 961         $attr[0]= trim($attr[0]);  /* attribute */
 962         $attr[1]= trim($attr[1]);  /* value */
 963
 964         /* Check for attributes that are used more than once */
 965         if(!isset($data[$attr[0]])) {
 966           $data[$attr[0]]=$attr[1];
 967         } else {
 968           $tmp = $data[$attr[0]];
 969
 970           if(!is_array($tmp)) {
 971             $new[0]=$tmp;
 972             $new[1]=$attr[1];
 973             $datas[$attr[0]]['count']=1;
 974             $data[$attr[0]]=$new;
 975           } else {
 976             $cnt = $datas[$attr[0]]['count'];
 977             $cnt ++;
 978             $data[$attr[0]][$cnt]=$attr[1];
 979             $datas[$attr[0]]['count'] = $cnt;
 980           }
 981         }
 982       }
 983     }
 984
 985     /* If dn is an index of data, we should try to insert the data */
 986     if(isset($data['dn'])) {
 987       /* Creating Entry */
 988       $this->cd($data['dn']);
 989
 990       /* Delete existing entry */
 991       if($delete){
 992         $this->rmdir($data['dn']);
 993       }
 994
 995       /* Create missing trees */
 996       $this->create_missing_trees($data['dn']);
 997       unset($data['dn']);
 998
 999       /* If entry exists use modify */
1000       if(!$modify){
1001         $ret = $this->add($data);
1002       } else {
1003         $ret = $this->modify($data);
1004       }
1005     }
1006
1007     return($ret);
1008   }
1009
1010
1011   function importcsv($str)
1012   {
1013     $lines = split("\n",$str);
1014     foreach($lines as $line)
1015     {
1016       /* continue if theres a comment */
1017       if(substr(trim($line),0,1)=="#"){
1018         continue;
1019       }
1020
1021       $line= str_replace ("\t\t","\t",$line);
1022       $line= str_replace ("\t"  ,"," ,$line);
1023       echo $line;
1024
1025       $cells = split(",",$line )  ;
1026       $linet= str_replace ("\t\t",",",$line);
1027       $cells = split("\t",$line);
1028       $count = count($cells);
1029     }
1030
1031   }
1032
1033 }
1034
1035 // vim:tabstop=2:expandtab:shiftwidth=2:filetype=php:syntax:ruler:
1036 ?>