drupal.plugin.php

Go to the documentation of this file.

<?php

include_once("embient.plugin.php");

function embient_create_drupal_plugin()
{
  return new EmbientDrupal();
}

function embient_drupal_encrypt($password)
{
  return md5($password);
}

class EmbientDrupal extends EmbientPlugin
{
  var $conf;

  var $vars;

  // -------------------------

  function EmbientDrupal()
  {
    $this->EmbientPlugin('drupal');

    // user field mapping for Drupal
    $this->_mapping = array
    (
      'name'       => 'name',
      'passwd'     => 'pass',
      'mail'       => 'mail',
      'signature'  => 'signature',
      'timezone'   => 'timezone',
    );
  }

  function Init($cfg)
  {
    // load settings to class's properties
    $this->conf = $cfg;

    // load database params
    $db_params = array(
                  'db_host'   => $this->conf['db_server']['value'],
                  'db_user'   => $this->conf['db_user']['value'],
                  'db_passwd' => $this->conf['db_passwd']['value'],
                  'db_name'   => $this->conf['db_name']['value'],
                  'prefix'    => $this->conf['db_prefix']['value'],
                 );

    // connect to database
    if ( ! parent::Init($db_params) )
    {
      return false;
    }

    // load settings from database
    $query = "SELECT name, value FROM {variable}";

    if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
    {
      return false;
    }

    $this->vars = array();

    $rows = $this->_db->GetRowscount();

    for ( $i = 0; $i < $rows; $i++ )
    {
      $var = $this->_db->FetchArray();
      $this->vars[$var['name']] = $var['value'];
    }

    return ! empty($this->vars);
  }

  function Login($username)
  {
    // load user information
    if ( ! $this->_Load($username) )
    {
      embient_error("User ". $username ." cannot be loaded", __FILE__, __LINE__);
    }

    $sid = session_id();

    // check, if session is already available in database?
    $query = "SELECT u.*, s.* FROM {users} u INNER JOIN {sessions} s ON u.uid = s.uid "
           . "WHERE s.sid = '". $sid ."' AND u.status < 3";
    
    if ( ! $this->_db->Query($query, __FILE__, __LINE__) || $this->_db->GetRowsCount() <= 0 )
    {
      // create one, if not exists
      $query = "INSERT INTO {sessions} (sid, uid, hostname, timestamp) "
             . "VALUES ('". $sid ."', 0, '". $_SERVER["REMOTE_ADDR"] ."', ". time() .")";

      if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
      {
        embient_error("Cannot create session for ". $this->user['name']);
        return;
      }

    }
    else
    {
      $query = "UPDATE {sessions} SET uid = '". $this->user['uid'] ."' WHERE sid = '". session_id() ."'";

      if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
      {
        embient_error("Cannot update session for ". $this->user['name']);
        return;
      }
    }

    // check, if cookie is available?
    $cookie_name = session_name();

    if ( ! isset($_COOKIE[$cookie_name]) )
    {
      setcookie($cookie_name, $sid, session_get_cookie_params());
      $_COOKIE[$cookie_name] = $sid;
    }
  }

  function Logout($username)
  {
    $query = "UPDATE {sessions} SET uid = '0' WHERE sid = '". session_id() ."'";

    $this->_db->Query($query, __FILE__, __LINE__);
    $this->user = array();
  }

  function Add($user)
  {
    // initialise the user info
    $this->user = Array();
    $this->_ConvertUserInfo($user, true);

    // encrypt password
    $this->user['pass'] = embient_drupal_encrypt($this->user['pass']);

    // format query
    $val = '';
    foreach( $this->user as $v)
    {
      $val = $val.($val != '' ? ', ' : '')."'$v'";
    }    

    $query = "INSERT INTO {users} "
                 . "(" . implode(', ', array_keys($this->user)) . ") "
           . "VALUES (". $val .')';

    if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
    {
      embient_error("Cannot add new user [". $this->user['name'] ."] into database");
      return;
    }

    // apply Drupal default role (authenticated user) to user
    $query = "INSERT INTO {users_roles} "
           . "(uid, rid) "
           . "VALUES ( '". $this->user['uid'] ."', '2')";

    $this->_db->Query($query, __FILE__, __LINE__);
  }

  function Update($username, $user)
  {

    // get database key for this user
    $this->_Load($username);
    $uid = $this->user['uid'];

    // if new password is supplied, re-encrypt the password
    $newpass = '';
    if ( ! empty($user['passwd']) )
    {
//      embient_debug("password for ". $user['name'] ." (currently known as ". $username .") is set to ". $user['passwd']);
      $newpass = embient_drupal_encrypt($user['passwd']);
    }

    // load value
    $this->user = Array();                 // clear buffer
    $this->_ConvertUserInfo($user, false); // not load default

    // load new encrpyted password, if available
    if ( ! empty($newpass) )
    {
      $this->user['pass'] = $newpass;
    }

    // create query
    $fields = array();

    foreach ($this->user as $key => $val)
    {
      array_push($fields, "$key = '$val'");
    }

    $query = "UPDATE {users} "
           . "SET "
           . implode(', ', $fields) ." "
           . "WHERE uid = '$uid'";

    $this->_db->Query($query, __FILE__, __LINE__);
  }

  function Delete($username)
  {
    $this->_Load($username);

    $query = "DELETE FROM {users} "
           . "WHERE uid = '". $this->user['uid'] ."'";

    $this->_db->Query($query, __FILE__, __LINE__);

    $query = "DELETE FROM {users_roles} "
           . "WHERE uid = '". $this->user['uid'] ."'";

    $this->_db->Query($query, __FILE__, __LINE__);

    $query = "DELETE FROM {sessions} "
           . "WHERE uid = '". $this->user['uid'] ."'";
    
    $this->_db->Query($query, __FILE__, __LINE__);

    $query = "DELETE FROM {authmap} "
           . "WHERE uid = '". $this->user['uid'] ."'";

    $this->_db->Query($query, __FILE__, __LINE__);
  }

  // -------------------------

  function _Load($username)
  {
    if ( $this->_db->connection == false )
    {
      embient_error("Drupal Database is not connected", __FILE__, __LINE__);
      return false;
    }

    $query = "SELECT u.* FROM {users} u WHERE u.name = '$username' LIMIT 1";

    if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
    {
      return false;
    }

    if ( $this->_db->GetRowsCount() <= 0 )
    {
      embient_error("User [$username] could not be found in Drupal database.", __FILE__, __LINE__);
      return false;
    }

    // fetch info
    $this->user = $this->_db->FetchArray();

    foreach ($this->user as $key => $val)
    {
      $this->user[$key] = $val;
    }

/*
    // load user roles
    $this->user['roles'] = array();

    $query = "SELECT r.rid, r.name FROM {role} r INNER JOIN {users_roles} ur ON ur.rid = r.rid "
           . "WHERE ur.uid = '". $this->user['uid'] ."' ";

    if ( ! $this->_db->Query($query, __FILE__, __LINE__) )
    {
      return false;
    }

    $c = $this->_db->GetRowsCount();

    for ($i = 0; $i < $c; $i++)
    {
      $roles = $this->_db->FetchArray();
      $this->user['roles'][$roles['rid']] = $roles['name'];
    }
*/

    return true;
  }

  function _ConvertUserInfo($user, $default = true)
  {
    // -----------------------
    // convert Embient info to SMF info
    parent::_ConvertUserInfo($user, $default);

    // -----------------------
    // Postprocessing

    // -----------------------
    // load default value
    if ( $default )
    {
      // load next uid from database, if required
      if ( ! isset($this->user['uid']) )
      {
        $this->user['uid'] = $this->_db->GetNextID('{sequences}', '{users}_uid');
      }

      $this->user['mode']      = embient_load_with_default( $this->user['mode'],      "0"    );
      $this->user['sort']      = embient_load_with_default( $this->user['sort'],      "0"    );
      $this->user['theme']     = embient_load_with_default( $this->user['theme'],     $this->vars['theme_default'] );
      $this->user['signature'] = embient_load_with_default( $this->user['signature'], ""     );
      $this->user['created']   = embient_load_with_default( $this->user['created'],   time() );
      $this->user['access']    = embient_load_with_default( $this->user['access'],    time() );
      $this->user['login']     = embient_load_with_default( $this->user['login'],     "0"    );
      $this->user['status']    = embient_load_with_default( $this->user['status'],    "1"    );
      $this->user['timezone']  = embient_load_with_default( $this->user['timezone'],  $this->vars['date_default_timezone'] );
      $this->user['language']  = embient_load_with_default( $this->user['language'],  ""     );
      $this->user['picture']   = embient_load_with_default( $this->user['picture'],   ""     );
      $this->user['init']      = embient_load_with_default( $this->user['init'],      $this->user['mail']);
      $this->user['data']      = embient_load_with_default( $this->user['data'],      ""     );
    }
  }
}

---