User management for the world wide web

Properties.php

<?php

class GenieGate_Properties_Section {

  var $DBH;
  var $uid;
  var $skey;
  var $prmap = array(); // property names to numerical ID's.
  var $pm;

  function GenieGate_Properties_Section(&$pm, $uid,$skey){
    $this->DBH = $pm->DBH;
    $this->pm = $pm;
    $this->skey = $skey;
    $this->uid = mysql_escape_string($uid);
    $this->prmap = $pm->getPropertyId($skey); // Map
    if(! $this->prmap){
      $this->prmap = array(); // Empty array.
    }
  }
  function getDescription($property_key = FALSE){    
    return($this->pm->getDescription($this->skey, $property_key));
  }
  function getUserId(){ return($this->uid); }
  function getSectionKey(){ return($this->skey); }

  function getPropertyNames(){
    return(array_keys($this->prmap));
  }
  function isProperty($property) {
    return(isset($this->prmap[$property]));
  }
  function getProperty($name){
    $prid = $this->prmap[$name];
    if(! $prid){
      return;
    }    
    $sql = "SELECT val FROM ua_prop WHERE prid='$prid' AND uid='$this->uid'";
    $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    if($result){
      list($v) = mysql_fetch_row($result);
      mysql_free_result($result);
      return($v);
    }
    return;
  }
  function setProperty($name,$value){
    $old_v = $this->getProperty($name);
    $prid = $this->prmap[$name];
    if(! $prid){
      die("Invalid property: [$this->skey/$name]");
    }
    if(isset($old_v)){
      $sql = sprintf("UPDATE ua_prop SET val='%s' WHERE uid='$this->uid' AND prid='$prid'",
             mysql_escape_string($value));
    }else{
      $sql = sprintf("INSERT INTO ua_prop (prid,uid,val) VALUES('$prid','$this->uid','%s')",
             mysql_escape_string($value));
    }
    mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    $this->pm->firePropertyChanged($this->uid,$this->skey,$name,$old_v,$value);
  }


  function removeAll(){
    $this->pm->removeUser($this->skey,$this->uid);
  }

}

class GenieGate_Properties {
  
  var $DBH;

  //Section names -> sid's
  var $SECT_CACHE = array();

  var $LISTENERS = array();

  function GenieGate_Properties(&$dbh){
    $this->DBH = $dbh;
  }
  
  function getSection($section,$uid){
    return(new GenieGate_Properties_Section($this,$uid,$section));
  }

  function createSection($skey,$name){
    $sid = $this->getSectionId($skey);
    if($sid){
      die("Section $skey already exists");     
    }
    $sql = sprintf("INSERT INTO ua_psect (skey,name) VALUES('%s','%s')",
           mysql_escape_string($skey),
           mysql_escape_string($name));
    mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    $id = mysql_insert_id(); 
    $this->SECT_CACHE[$skey] = $id;
    return($id);
  }
  function updateSection($skey,$label){
      $sid = $this->getSectionId($skey);
      if(! $sid){
          $this->createSection($skey,$label);
          return;
      }
      $sql = sprintf("UPDATE ua_psect SET name='%s' WHERE sid='%s'",
                     mysql_escape_string($label),
                     $sid);
      mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
      return($id);      
  }

  function getSectionId($skey){
    if(! isset($this->SECT_CACHE[$skey])){
      $key = mysql_escape_string($skey);
      $sql = "SELECT sid FROM ua_psect WHERE skey='$key'";
      $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
      if($result){
          $row =  mysql_fetch_row($result); 
          if($row[0]){
              $this->SECT_CACHE[$skey] = $row[0];
          }else{
              $this->SECT_CACHE[$skey] = ''; // so isset() works on it.
          }
          mysql_free_result($result);
      }
    }
    return($this->SECT_CACHE[$skey]);
  }


  function getSections($depth = FALSE){
    $sql = "SELECT skey,name FROM ua_psect";
    $all = array();
    $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    if($result){
      while( list($key,$name) = mysql_fetch_row($result)){
    if($depth){
      $all[$key] = array($name,$this->getSectionProperties($key));
    }else{
      $all[$key] = $name;
    }
      }
      mysql_free_result($result);
    }
    return($all);
  }


  function removeUser($skey,$uid){
    $sid = $this->getSectionId($skey);
    $uid = mysql_escape_string($uid);

    $rm_sql = "DELETE FROM ua_prop WHERE prid='%s' AND uid='%s'";

    // Tricky, we need to first get a list of all the properties that will be changed.
    // so we can alert the plugins about it.
    $sql = "SELECT p.prid,uid,sid,pkey,val FROM ";
    $sql .= "ua_prnam as n, ua_prop as p ";
    $sql .= "WHERE n.sid='$sid' AND p.prid=n.prid AND uid='$uid'";
    $qry = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    if($qry){
      while( list($prid,$ud,$sc,$pn,$val) = mysql_fetch_row($qry)){
    // Remove said property.
    mysql_query(sprintf($rm_sql,$prid,$ud),$this->DBH) or die(mysql_error($this->DBH)); 
    // Tell the listeners about it. 
    $this->firePropertyRemoved($ud,$skey,$pn,$val);
      }
    }
  }


  function getSectionProperties($skey){
    $all = array();
    $sid = $this->getSectionId($skey);
    $sql = "SELECT pkey,diz FROM ua_prnam WHERE sid='$sid'";
    $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    if($result){
      while(list($key,$diz) = mysql_fetch_row($result)){
    $all[$key] = $diz;
      }
      mysql_free_result($result);
    }
    return($all);
  }

  function createProperty($skey,$name,$desc){
    $sid = $this->getSectionId($skey);   
    if(! $sid){
      die("Section $skey unknown");
    }
    if(preg_match("/[^\w\.]/",$name)){
      die("Property names must be alphanumeric");
    }
    $prid = $this->getPropertyId($skey,$name);
    if($prid){
      return(FALSE);
    }
    $sql = sprintf("INSERT INTO ua_prnam(sid,pkey,diz) VALUES('$sid','%s','%s')",
           mysql_escape_string($name),
           mysql_escape_string($desc));
    mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
    $prid = mysql_insert_id(); 
    $this->firePropertyCreated($skey,$name,$desc);
    return($prid);
  }


  function undefineProperty($skey,$prop){    
    $sid = $this->getSectionId($skey);
    if(! $sid){
      return;
    }    
    $psql = "SELECT prid FROM ua_prnam WHERE sid='$sid' AND pkey='$prop'";
    $result = mysql_query($psql,$this->DBH) or die(mysql_error($this->DBH));
    if($result){
      $this->firePropertyUndefine($skey,$prop);
      $row = mysql_fetch_row($result);
      $prid = $row[0];
      mysql_free_result($result);      
      // Nuke everyones properties.
      mysql_query("DELETE FROM ua_prop WHERE prid='$prid'",$this->DBH) or die(mysql_error($this->DBH));
      mysql_query("DELETE FROM ua_prnam WHERE prid='$prid'",$this->DBH) or die(mysql_error($this->DBH));
      return(TRUE);
    }
    return(FALSE);
  }

  function getPropertyId($section_key,$property_key = FALSE){
    $sid = $this->getSectionId($section_key);
    if(! $property_key){
      return($this->_getPropertyId($sid)); // Pretend to polymorph.
    }
    $pkey = mysql_escape_string($property_key);
    $sql = "SELECT prid FROM ua_prnam WHERE sid='$sid' AND pkey='$pkey'";
    $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));                
    if($result){
      $row =  mysql_fetch_row($result);      
      mysql_free_result($result);
      return($row[0]);
    }
    return(FALSE);
  }
   
  // What getPropertyId($section_key) should be.
  function _getPropertyId($sid){    
    $sql = "SELECT pkey,prid FROM ua_prnam WHERE sid='$sid'";
    $result = mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));

    if($result){
      $map = array();
      while( list($key,$id) = mysql_fetch_row($result) ) {
    $map[$key] = $id;
      }
      return($map);
    }

    return(FALSE);
  }

  function getDescription($section_key, $property_key = FALSE){
    $sid = $this->getSectionId($section_key);
    if(! $property_key){            
      return($this->_getSectionDescription($sid));
    }
    $key = mysql_escape_string($property_key);
    $sql = "SELECT diz FROM ua_prnam WHERE sid='$sid' AND pkey='$key'";
    $result = mysql_query($sql,$this->DBH) or die(mysql_error());
    if($result){
      $diz =  mysql_fetch_row($result);      
      mysql_free_result($result);
      return($diz[0]);
    }
    return;
  }

  // Return the description of a section.
  function _getSectionDescription($sid){    
    $result = mysql_query("SELECT name FROM ua_psect WHERE sid='$sid'",$this->DBH) or die(mysql_error());
    if($result){
      list($diz) =  mysql_fetch_row($result);      
      mysql_free_result($result);
      return($diz);
    }
    return;
  }



  function addListener(&$listener){
    array_push($this->LISTENERS,$listener);
  }

  function changePropertyLabel($sect,$prop,$label){
    $sid = $this->getSectionId($sect);
    $prop = mysql_escape_string($prop);
    $label = mysql_escape_string($label);
    $sql = "UPDATE ua_prnam SET diz='$label' WHERE sid='$sid' AND pkey='$prop'";
    mysql_query($sql,$this->DBH) or die(mysql_error($this->DBH));
  }

  function firePropertyCreated($section,$property,$description){
    foreach($this->LISTENERS as $l){
      $l->propertyCreated($this,$section,$property,$description);
    }
  }
  function firePropertyChanged($uid,$section, $property, $old_value, $new_value) {
    foreach($this->LISTENERS as $l){
      $l->propertyChanged($this,$uid, $section,$property,$old_value, $new_value);
    }
  }

  function firePropertyRemoved($uid,$skey,$prop,$old_value){
    foreach($this->LISTENERS as $l){
      $l->propertyRemoved($this,$section,$property,$description,$old_value);
    }
  }


  function firePropertyUndefine($skey,$prop){
    foreach($this->LISTENERS as $l){
      $l->propertyUndefine($this,$skey,$prop);
    }
  }

}

?>

---

Documentation generated by DoxyGen