email.class.inc

groupoffice

<?php
/*
Copyright Intermesh 2003
Author: Merijn Schering <[e-mail]>
Version: 1.0 Release date: 08 July 2003

This program is free software; you can redistribute it and/or modify it
under the terms of the GNU General Public License as published by the
Free Software Foundation; either version 2 of the License, or (at your
option) any later version.
*/

class email extends db
{
	var $last_error;
	var $mail;

	function get_accounts($user_id=0)
	{
		$sql = "SELECT * FROM emAccounts";
		
		if($user_id > 0)
		{
			$sql .= " WHERE user_id='$user_id'";
		}
		$sql .= " ORDER BY standard DESC";
		$result = $this->query($sql);
		return $this->num_rows($result);
	}

	function set_sorting($user_id, $sort_field, $sort_order)
	{
		$sql = "UPDATE em_settings SET sort_field='$sort_field' , sort_order='$sort_order' WHERE user_id='$user_id'";
		return $this->query($sql);
	}

	function save_send_format($user_id, $send_format)
	{
		$sql = "UPDATE em_settings SET send_format='$send_format'  WHERE user_id='$user_id'";
		return $this->query($sql);
	}
	
	
	function update_settings($settings)
	{
		if(!isset($settings['user_id']))
		{
			global $GO_SECURITY;
			$settings['user_id'] = $GO_SECURITY->user_id;
		}
		return $this->update_row('em_settings', 'user_id', $settings);
	}

	function get_settings($user_id)
	{
		$this->query("SELECT * FROM em_settings WHERE user_id='$user_id'");
		if ($this->next_record())
		{
			return $this->Record;
		}else
		{
			$this->query("INSERT INTO em_settings (user_id, send_format, add_recievers, add_senders, request_notification, charset) VALUES ('$user_id', 'text/HTML', '0', '0', '0', 'UTF-8')");
			return $this->get_settings($user_id);
		}
	}

	function add_account($user_id, $type, $host, $port, $use_ssl, $novalidate_cert, $mbroot, $username, $password, $name, $email, $signature, $auto_check=0)
	{
		global $GO_CONFIG, $GO_LANGUAGE;

		require_once($GO_CONFIG->class_path."mail/imap.class.inc");
		require($GO_LANGUAGE->get_language_file('email'));
		$this->mail= new imap();
				
		if (!$this->mail->open($host, $type, $port, $username, $password, "INBOX", 0, $use_ssl, $novalidate_cert))
		{
			$this->last_error = "<p class=\"Error\">".imap_last_error()."</p>";
			return false;
		}else
		{
			if (!$account['mbroot'] = $this->mail->check_mbroot($mbroot))
			{
				$account['mbroot'] = '';
			}	
			$account['spamtag']='***SPAM***';
			$account['trash'] = '';
			$account['sent'] = '';
			$account['drafts'] = '';
			$account['spam'] = '';
					
			if ($type=='imap')
			{
				$mailboxes =  $this->mail->get_mailboxes($mbroot);
				$subscribed =  $this->mail->get_subscribed($mbroot);

				$mailbox_names = array();
				while($mailbox = array_shift($mailboxes))
				{
					$mailbox_names[]=$mailbox['name'];
				}

				$subscribed_names = array();
				while($mailbox = array_shift($subscribed))
				{
					$subscribed_names[]=$mailbox['name'];
				}
				
				if($this->_add_folder($account['mbroot'].$ml_trash, $mailbox_names, $subscribed_names))
				{
					$account['trash'] = $account['mbroot'].utf7_imap_encode($ml_trash);
				}elseif($account['mbroot'] = $this->mail->check_mbroot($mailbox_names[0]))
				{
					if($this->_add_folder($account['mbroot'].utf7_imap_encode($ml_trash), $mailbox_names, $subscribed_names))
					{
						$account['trash'] = $account['mbroot'].utf7_imap_encode($ml_trash);
					}
				}
				
				if($this->_add_folder($account['mbroot'].utf7_imap_encode($ml_sent_items), $mailbox_names, $subscribed_names))
				{
					$account['sent'] = $account['mbroot'].utf7_imap_encode($ml_sent_items);
				}
				
				if($this->_add_folder($account['mbroot'].utf7_imap_encode($ml_drafts), $mailbox_names, $subscribed_names))
				{
					$account['drafts'] = $account['mbroot'].utf7_imap_encode($ml_drafts);
				}
				
				if($this->_add_folder($account['mbroot'].utf7_imap_encode($ml_spam), $mailbox_names, $subscribed_names))
				{
					$account['spam']= $account['mbroot'].utf7_imap_encode($ml_spam);
				}				
			}
			$this->mail->close();
			
			if ($this->get_accounts($user_id) == 0)
			{
				$account['standard']="1";
			}else
			{
				$account['standard']="0";
			}
			$account['id'] = $this->nextid("emAccounts");
			if (!$account['id'])
			{
				$this->last_error = "<p class=\"Error\">".$strSaveError."</p>";
				return false;
			}else
			{
				$account['type']=$type;
				$account['user_id']=$user_id;
				$account['host']=$host;
				$account['port']=$port;
				$account['use_ssl']=$use_ssl;
				$account['novalidate_cert']=$novalidate_cert;
				$account['username']=$username;
				$account['password']=$password;
				$account['name']=$name;
				$account['email']=$email;
				$account['signature']=$signature;
				$account['auto_check']=$auto_check;
					

				if(!$this->insert_row('emAccounts', $account))
				{
					$this->last_error = "<p class=\"Error\">".$strSaveError."</p>";
					return false;
				}else
				{					
					return $account['id'];
				}
			}			
		}
	}

	function disable_auto_check($account_id)
	{
		return $this->query("UPDATE emAccounts SET auto_check='0' WHERE id='$account_id'");
	}
	
	function _update_account($account)
	{
		return $this->update_row('emAccounts', 'id', $account);
	}

	function update_account($account_id, $type, $host, $port, $use_ssl, $novalidate_cert, $mbroot, $username, $password, $name, $email, $signature, $auto_check=0)
	{
		global $GO_CONFIG;

		require_once($GO_CONFIG->class_path."mail/imap.class.inc");
		$this->mail= new imap();

		if ($this->mail->open($host, $type, $port, $username, $password, "INBOX", 0, $use_ssl, $novalidate_cert))
		{
			if (!$mbroot = $this->mail->check_mbroot($mbroot))
			{
				$mbroot = '';
			}
			$sql  = "UPDATE emAccounts SET type='$type', host='$host', port='$port'".
			", use_ssl='$use_ssl', novalidate_cert='$novalidate_cert'".
			", mbroot='$mbroot', username='$username', password='".$password."',".
			" name='$name', email='$email'".
			", signature='$signature', auto_check='$auto_check' WHERE ".
			"id='$account_id'";

			if ($this->query($sql))
			{
				$this->mail->close();
			}
			return true;
		}
		return false;
	}

	function _add_folder($name, $mailbox_names, $subscribed_names)
	{
		if (!in_array($name, $mailbox_names))
		{
			return @$this->mail->create_folder($name);
		}else
		{
			if (!in_array($name, $subscribed_names))
			{
				return $this->mail->subscribe($name);
			}
			return true;
		}
		return false;
	}

	function update_password($host, $username, $password)
	{
		$sql = "UPDATE emAccounts SET password='".$password.
		"' WHERE username='$username' AND host='$host'";
		return $this->query($sql);
	}

	function update_folders($account_id, $sent, $trash, $drafts, $spam)
	{
		$sql = "UPDATE emAccounts SET sent='$sent', ".
		"trash='$trash',drafts='$drafts', spam='$spam'  WHERE id='$account_id'";
		return $this->query($sql);
	}

	function get_account($id = 0)
	{
		if ($id == 0)
		{
			$sql = "SELECT * FROM emAccounts WHERE standard='1' AND user_id='".
			$_SESSION['GO_SESSION']['user_id']."'";
		}else
		{
			$sql = "SELECT * FROM emAccounts WHERE id='$id'";
		}

		$this->query($sql);
		if ($this->next_record())
		{
			return $this->Record;
		}else
		{
			return false;
		}
	}

	function is_default_account($id)
	{
		$sql = "SELECT * FROM emAccounts WHERE id='$id' AND standard='1'";
		$this->query($sql);
		if ($this->num_rows() == 1)
		{
			return true;
		}else
		{
			return false;
		}
	}

	function delete_account($user_id, $id)
	{
		$default = $this->is_default_account($id);

		$sql = "DELETE FROM emAccounts WHERE id='$id' AND user_id='$user_id'";
		if ($this->query($sql))
		{
			$sql = "DELETE FROM emFolders WHERE account_id='$id'";
			$this->query($sql);
			$sql = "DELETE FROM emFilters WHERE account_id='$id'";
			$this->query($sql);
		}
		if ($default)
		{
			$this->get_accounts($user_id);
			$this->next_record();
			$this->set_as_default($this->f("id"), $user_id);
		}
		return true;
	}

	function set_as_default($account_id, $user_id)
	{
		$sql = "UPDATE emAccounts SET standard='0' WHERE user_id='$user_id'".
		"AND standard='1'";
		$this->query($sql);
		$sql = "UPDATE emAccounts SET standard='1' WHERE id='$account_id'";
		$this->query($sql);
	}
	/*
	gets the subfolder of a folder id. Account id is only usefull for the root
	level where all folders have parent 0
	*/

	function get_subscribed($account_id, $folder_id=-1)
	{
		$sql = "SELECT * FROM emFolders WHERE account_id='$account_id'".
			  " AND (subscribed='1' OR name='INBOX')";

		if ($folder_id > -1)
		{
			$sql .= " AND parent_id='$folder_id'";
		}
		$sql .= " ORDER BY sort_order ASC, name ASC";

		$this->query($sql);
		return $this->num_rows();
	}
	
	function get_mailboxes($account_id, $folder_id=-1)
	{
		$sql = "SELECT * FROM emFolders WHERE account_id='$account_id'";

		if ($folder_id > -1)
		{
			$sql .= " AND parent_id='$folder_id'";
		}
		$sql .= " ORDER BY sort_order ASC, name ASC";

		$this->query($sql);
		return $this->num_rows();
	}
	
	function get_folders($account_id, $folder_id=-1)
	{
		$sql = "SELECT * FROM emFolders WHERE account_id='$account_id'";
		
		if ($folder_id > -1)
		{
			$sql .= " AND parent_id='$folder_id' ";
		}
		$sql .= "ORDER BY sort_order ASC, name ASC";

		$this->query($sql);
		return $this->num_rows();
	}
/*
	function get_all_folders($account_id, $subscribed_only=false)
	{
		if ($subscribed_only)
		{
			$sql = "SELECT * FROM emFolders WHERE account_id='$account_id' AND ".
			"subscribed='1' ORDER BY NAME ASC";
		}else
		{
			$sql = "SELECT * FROM emFolders WHERE account_id='$account_id' ORDER ".
			"BY NAME ASC";
		}
		$this->query($sql);
		return $this->num_rows();
	}

*/
	function add_folder($account_id, $name, $parent_id=0, $subscribed=1,
	$delimiter='/', $attributes=0, $sort_order=10)
	{
		$next_id = $this->nextid("emFolders");
		if ($next_id > 0)
		{
			$sql = "INSERT INTO emFolders (id, parent_id, account_id, subscribed, ".
			"name, attributes, delimiter, sort_order) VALUES ('$next_id', '$parent_id', ".
			"'$account_id', '$subscribed', '$name', ".
			"'$attributes', '$delimiter', '$sort_order')";
			if ($this->query($sql))
			{
				return $next_id;
			}
		}
		return false;
	}
	function rename_folder($account_id, $old_name, $new_name)
	{
		$sql = "UPDATE emFolders SET name='$new_name' WHERE".
		" name='".smart_addslashes($old_name)."' AND ".
		"account_id='$account_id'";

		$this->query($sql);
		$sql = "UPDATE emFilters SET folder='$new_name' ".
		"WHERE folder='$old_name' AND ".
		"account_id='$account_id'";
		$this->query($sql);

	}

	function update_folder($folder_id, $parent_id, $subscribed, $attributes, $sort_order=10)
	{
		$sql = "UPDATE emFolders SET subscribed='$subscribed', ".
		"parent_id='$parent_id', attributes='$attributes', sort_order='$sort_order' ".
		"WHERE id='$folder_id'";

		$this->query($sql);
	}
	
	function __update_folder($folder)
	{
		return $this->update_row('emFolders','id', $folder);
	}
	
	function __add_folder($folder)
	{
		$folder['id'] = $this->nextid("emFolders");
		if ($folder['id'] > 0)
		{
			if ($this->insert_row('emFolders', $folder))
			{
				return $folder['id'];
			}
		}
		return false;
	}

	function delete_folder($account_id, $name)
	{
		$sql = "DELETE FROM emFolders WHERE account_id='$account_id' ".
		"AND name='$name'";
		$this->query($sql);