| | |
| | | } |
| | | |
| | | unset($msg->flags); |
| | | $msg = serialize($this->db->encode($msg)); |
| | | $msg = $this->db->encode($msg, true); |
| | | |
| | | // update cache record (even if it exists, the update |
| | | // here will work as select, assume row exist if affected_rows=0) |
| | |
| | | |
| | | if ($sql_arr = $this->db->fetch_assoc($sql_result)) { |
| | | $data = explode('@', $sql_arr['data']); |
| | | $index = @unserialize($data[0]); |
| | | $index = $this->db->decode($data[0], true); |
| | | unset($data[0]); |
| | | |
| | | if (empty($index)) { |
| | |
| | | |
| | | if ($sql_arr = $this->db->fetch_assoc($sql_result)) { |
| | | $data = explode('@', $sql_arr['data']); |
| | | $thread = @unserialize($data[0]); |
| | | $thread = $this->db->decode($data[0], true); |
| | | unset($data[0]); |
| | | |
| | | if (empty($thread)) { |
| | |
| | | $data, $mbox_data = array(), $exists = false, $modseq = null) |
| | | { |
| | | $data = array( |
| | | serialize($data), |
| | | $this->db->encode($data, true), |
| | | $sort_field, |
| | | (int) $this->skip_deleted, |
| | | (int) $mbox_data['UIDVALIDITY'], |
| | |
| | | private function add_thread_row($mailbox, $data, $mbox_data = array(), $exists = false) |
| | | { |
| | | $data = array( |
| | | serialize($data), |
| | | $this->db->encode($data, true), |
| | | (int) $this->skip_deleted, |
| | | (int) $mbox_data['UIDVALIDITY'], |
| | | (int) $mbox_data['UIDNEXT'], |
| | |
| | | */ |
| | | private function build_message($sql_arr) |
| | | { |
| | | $message = $this->db->decode(unserialize($sql_arr['data'])); |
| | | $message = $this->db->decode($sql_arr['data'], true); |
| | | |
| | | if ($message) { |
| | | $message->flags = array(); |