| | |
| | | +-----------------------------------------------------------------------+ |
| | | | Author: Thomas Bruederli <roundcube@gmail.com> | |
| | | +-----------------------------------------------------------------------+ |
| | | |
| | | $Id$ |
| | | |
| | | */ |
| | | |
| | | |
| | |
| | | private $db; |
| | | |
| | | /** |
| | | * rcmail object. |
| | | * Framework object. |
| | | * |
| | | * @var rcmail |
| | | * @var rcube |
| | | */ |
| | | private $rc; |
| | | |
| | |
| | | */ |
| | | function __construct($id = null, $sql_arr = null) |
| | | { |
| | | $this->rc = rcmail::get_instance(); |
| | | $this->rc = rcube::get_instance(); |
| | | $this->db = $this->rc->get_dbh(); |
| | | |
| | | if ($id && !$sql_arr) { |
| | | $sql_result = $this->db->query( |
| | | "SELECT * FROM ".get_table_name('users')." WHERE user_id = ?", $id); |
| | | "SELECT * FROM ".$this->db->table_name('users')." WHERE user_id = ?", $id); |
| | | $sql_arr = $this->db->fetch_assoc($sql_result); |
| | | } |
| | | |
| | |
| | | if (!empty($_SESSION['preferences'])) { |
| | | // Check last write attempt time, try to write again (every 5 minutes) |
| | | if ($_SESSION['preferences_time'] < time() - 5 * 60) { |
| | | $saved_prefs = unserialize($_SESSION['preferences']); |
| | | $saved_prefs = unserialize($_SESSION['preferences']); |
| | | $this->rc->session->remove('preferences'); |
| | | $this->rc->session->remove('preferences_time'); |
| | | $this->rc->session->remove('preferences_time'); |
| | | $this->save_prefs($saved_prefs); |
| | | } |
| | | else { |
| | |
| | | $save_prefs = serialize($save_prefs); |
| | | |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name('users'). |
| | | "UPDATE ".$this->db->table_name('users'). |
| | | " SET preferences = ?". |
| | | ", language = ?". |
| | | " WHERE user_id = ?", |
| | |
| | | $result = array(); |
| | | |
| | | $sql_result = $this->db->query( |
| | | "SELECT * FROM ".get_table_name('identities'). |
| | | "SELECT * FROM ".$this->db->table_name('identities'). |
| | | " WHERE del <> 1 AND user_id = ?". |
| | | ($sql_add ? " ".$sql_add : ""). |
| | | " ORDER BY ".$this->db->quoteIdentifier('standard')." DESC, name ASC, identity_id ASC", |
| | |
| | | $query_params[] = $iid; |
| | | $query_params[] = $this->ID; |
| | | |
| | | $sql = "UPDATE ".get_table_name('identities'). |
| | | $sql = "UPDATE ".$this->db->table_name('identities'). |
| | | " SET changed = ".$this->db->now().", ".join(', ', $query_cols). |
| | | " WHERE identity_id = ?". |
| | | " AND user_id = ?". |
| | |
| | | $insert_cols[] = 'user_id'; |
| | | $insert_values[] = $this->ID; |
| | | |
| | | $sql = "INSERT INTO ".get_table_name('identities'). |
| | | $sql = "INSERT INTO ".$this->db->table_name('identities'). |
| | | " (changed, ".join(', ', $insert_cols).")". |
| | | " VALUES (".$this->db->now().", ".join(', ', array_pad(array(), sizeof($insert_values), '?')).")"; |
| | | |
| | |
| | | return false; |
| | | |
| | | $sql_result = $this->db->query( |
| | | "SELECT count(*) AS ident_count FROM ".get_table_name('identities'). |
| | | "SELECT count(*) AS ident_count FROM ".$this->db->table_name('identities'). |
| | | " WHERE user_id = ? AND del <> 1", |
| | | $this->ID); |
| | | |
| | |
| | | return -1; |
| | | |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name('identities'). |
| | | "UPDATE ".$this->db->table_name('identities'). |
| | | " SET del = 1, changed = ".$this->db->now(). |
| | | " WHERE user_id = ?". |
| | | " AND identity_id = ?", |
| | |
| | | { |
| | | if ($this->ID && $iid) { |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name('identities'). |
| | | "UPDATE ".$this->db->table_name('identities'). |
| | | " SET ".$this->db->quoteIdentifier('standard')." = '0'". |
| | | " WHERE user_id = ?". |
| | | " AND identity_id <> ?". |
| | |
| | | { |
| | | if ($this->ID) { |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name('users'). |
| | | "UPDATE ".$this->db->table_name('users'). |
| | | " SET last_login = ".$this->db->now(). |
| | | " WHERE user_id = ?", |
| | | $this->ID); |
| | |
| | | */ |
| | | static function query($user, $host) |
| | | { |
| | | $dbh = rcmail::get_instance()->get_dbh(); |
| | | $dbh = rcube::get_instance()->get_dbh(); |
| | | |
| | | // query for matching user name |
| | | $query = "SELECT * FROM ".get_table_name('users')." WHERE mail_host = ? AND %s = ?"; |
| | | $query = "SELECT * FROM ".$dbh->table_name('users')." WHERE mail_host = ? AND %s = ?"; |
| | | $sql_result = $dbh->query(sprintf($query, 'username'), $host, $user); |
| | | |
| | | // query for matching alias |
| | |
| | | { |
| | | $user_name = ''; |
| | | $user_email = ''; |
| | | $rcmail = rcmail::get_instance(); |
| | | $rcube = rcube::get_instance(); |
| | | |
| | | // try to resolve user in virtuser table and file |
| | | if ($email_list = self::user2email($user, false, true)) { |
| | | $user_email = is_array($email_list[0]) ? $email_list[0]['email'] : $email_list[0]; |
| | | } |
| | | |
| | | $data = $rcmail->plugins->exec_hook('user_create', |
| | | $data = $rcube->plugins->exec_hook('user_create', |
| | | array('user'=>$user, 'user_name'=>$user_name, 'user_email'=>$user_email, 'host'=>$host)); |
| | | |
| | | // plugin aborted this operation |
| | |
| | | $user_name = $data['user_name']; |
| | | $user_email = $data['user_email']; |
| | | |
| | | $dbh = $rcmail->get_dbh(); |
| | | $dbh = $rcube->get_dbh(); |
| | | |
| | | $dbh->query( |
| | | "INSERT INTO ".get_table_name('users'). |
| | | "INSERT INTO ".$dbh->table_name('users'). |
| | | " (created, last_login, username, mail_host, alias, language)". |
| | | " VALUES (".$dbh->now().", ".$dbh->now().", ?, ?, ?, ?)", |
| | | strip_newlines($user), |
| | |
| | | if ($user_id = $dbh->insert_id('users')) { |
| | | // create rcube_user instance to make plugin hooks work |
| | | $user_instance = new rcube_user($user_id); |
| | | $rcmail->user = $user_instance; |
| | | $rcube->user = $user_instance; |
| | | |
| | | $mail_domain = $rcmail->config->mail_domain($host); |
| | | $mail_domain = $rcube->config->mail_domain($host); |
| | | |
| | | if ($user_email == '') { |
| | | $user_email = strpos($user, '@') ? $user : sprintf('%s@%s', $user, $mail_domain); |
| | |
| | | if (empty($email_list)) |
| | | $email_list[] = strip_newlines($user_email); |
| | | // identities_level check |
| | | else if (count($email_list) > 1 && $rcmail->config->get('identities_level', 0) > 1) |
| | | else if (count($email_list) > 1 && $rcube->config->get('identities_level', 0) > 1) |
| | | $email_list = array($email_list[0]); |
| | | |
| | | // create new identities records |
| | |
| | | $record['user_id'] = $user_id; |
| | | $record['standard'] = $standard; |
| | | |
| | | $plugin = $rcmail->plugins->exec_hook('identity_create', |
| | | $plugin = $rcube->plugins->exec_hook('identity_create', |
| | | array('login' => true, 'record' => $record)); |
| | | |
| | | if (!$plugin['abort'] && $plugin['record']['email']) { |
| | | $rcmail->user->insert_identity($plugin['record']); |
| | | $rcube->user->insert_identity($plugin['record']); |
| | | } |
| | | $standard = 0; |
| | | } |
| | | } |
| | | else { |
| | | raise_error(array( |
| | | rcube::raise_error(array( |
| | | 'code' => 500, |
| | | 'type' => 'php', |
| | | 'line' => __LINE__, |
| | |
| | | */ |
| | | static function email2user($email) |
| | | { |
| | | $rcmail = rcmail::get_instance(); |
| | | $plugin = $rcmail->plugins->exec_hook('email2user', |
| | | $rcube = rcube::get_instance(); |
| | | $plugin = $rcube->plugins->exec_hook('email2user', |
| | | array('email' => $email, 'user' => NULL)); |
| | | |
| | | return $plugin['user']; |
| | |
| | | */ |
| | | static function user2email($user, $first=true, $extended=false) |
| | | { |
| | | $rcmail = rcmail::get_instance(); |
| | | $plugin = $rcmail->plugins->exec_hook('user2email', |
| | | $rcube = rcube::get_instance(); |
| | | $plugin = $rcube->plugins->exec_hook('user2email', |
| | | array('email' => NULL, 'user' => $user, |
| | | 'first' => $first, 'extended' => $extended)); |
| | | |
| | |
| | | |
| | | $sql_result = $this->db->query( |
| | | "SELECT search_id AS id, ".$this->db->quoteIdentifier('name') |
| | | ." FROM ".get_table_name('searches') |
| | | ." FROM ".$this->db->table_name('searches') |
| | | ." WHERE user_id = ?" |
| | | ." AND ".$this->db->quoteIdentifier('type')." = ?" |
| | | ." ORDER BY ".$this->db->quoteIdentifier('name'), |
| | |
| | | "SELECT ".$this->db->quoteIdentifier('name') |
| | | .", ".$this->db->quoteIdentifier('data') |
| | | .", ".$this->db->quoteIdentifier('type') |
| | | ." FROM ".get_table_name('searches') |
| | | ." FROM ".$this->db->table_name('searches') |
| | | ." WHERE user_id = ?" |
| | | ." AND search_id = ?", |
| | | (int) $this->ID, (int) $id); |
| | |
| | | return false; |
| | | |
| | | $this->db->query( |
| | | "DELETE FROM ".get_table_name('searches') |
| | | "DELETE FROM ".$this->db->table_name('searches') |
| | | ." WHERE user_id = ?" |
| | | ." AND search_id = ?", |
| | | (int) $this->ID, $sid); |
| | |
| | | $insert_cols[] = $this->db->quoteIdentifier('data'); |
| | | $insert_values[] = serialize($data['data']); |
| | | |
| | | $sql = "INSERT INTO ".get_table_name('searches') |
| | | $sql = "INSERT INTO ".$this->db->table_name('searches') |
| | | ." (".join(', ', $insert_cols).")" |
| | | ." VALUES (".join(', ', array_pad(array(), sizeof($insert_values), '?')).")"; |
| | | |