#!/usr/local/bin/php -q 
<?php

$log_file = '/var/log/roundcube/postfixadmin-update-name.log';

ini_set("memory_limit", "256M");

function logging($file_handler, $message_type, $message_text, $stderr = false) {
	fputs($file_handler, ($message_type ? date("Y-m-d H:i:s ").$message_type." " : "").$message_text);
	if ((isset($stderr)) and ($stderr)) fputs($stderr, $message_text);
}

$stderr = fopen("php://stderr", "w");
if ($stderr) {
	$log = fopen($log_file, "a");
	if (!$log) {
		fputs($stderr, "couldn't open file ".$log_file." for appending\n");
	} else {
		$data = array();

		$mysql_config = '';
		if (file_exists('/usr/local/www/roundcube/config/db.inc.php')) {
			include('/usr/local/www/roundcube/config/db.inc.php');
			 $mysql_config= $rcmail_config['db_dsnw'];
		} elseif (file_exists('/usr/local/www/roundcube/config/config.inc.php')) {
			include('/usr/local/www/roundcube/config/config.inc.php');
			$mysql_config = $config['db_dsnw'];
		}
		if ($mysql_config) {
			logging($log, "", "======================================================================\n");
			logging($log, "info:   ", "try to detect MySQL connection parameters for roundcube DB...", $stderr);
			if (!preg_match('/mysql:\/\/([^:\@]+)(?::([^@]*))\@([^\/]+)\/(.+)/', $mysql_config, $matches)) {
				logging($log, "", " failed\n", $stderr);
				logging($log, "error:  ", "couldn't detect MySQL connection parameters for roundcube DB\n", $stderr);
			} else {
				$mysql_user = $matches[1];
				$mysql_pass = $matches[2];
				$mysql_host = $matches[3];
				$mysql_db = $matches[4];
				logging($log, "", " success\n", $stderr);
				logging($log, "info:   ", "connect to MySQL server '$mysql_host' as user '$mysql_user'...", $stderr);
				$db_connect_id = mysqli_connect($mysql_host, $mysql_user, $mysql_pass, $mysql_db);
				if (!$db_connect_id) {
					logging($log, "", " failed\n", $stderr);
					logging($log, "error:  ", "couldn't connect to MySQL server '$mysql_host' as user '$mysql_user'\n", $stderr);
				} else {
					logging($log, "", " success\n", $stderr);

					logging($log, "info:   ", "get roundcube users info\n", $stderr);
					$users = array();
					$query = sprintf("SELECT email, name FROM identities;");
					logging($log, "info:   ", "execute MySQL query '$query'...", $stderr);
					$res = mysqli_query($db_connect_id, $query);
					if (!$res) {
						logging($log, "", " failed\n", $stderr);
						logging($log, "error:  ", "couldn't execute MySQL query '$query'\n", $stderr);
						$ok = false;
					} else {
						logging($log, "", " success\n", $stderr);
						while ($row = mysqli_fetch_array($res)) {
							$data[$row['email']] = $row['name'];
						}
						mysqli_free_result($res);
					}

					logging($log, "info:   ", "close MySQL connection...", $stderr);
					if (mysqli_close($db_connect_id)) {
						logging($log, "", " success\n", $stderr);
					} else {
						logging($log, "", " failed\n", $stderr);
						logging($log, "error:  ", "couldn't close connection to MySQL server '$mysql_host'\n", $stderr);
					}
				}
			}
		}
//print_r($data); die();

		define('IN_VMA','1');
		include('/usr/local/www/postfixadmin/config.inc.php');
		include('/usr/local/www/postfixadmin/config.local.php');
		logging($log, "", "======================================================================\n");
		logging($log, "info:   ", "try to detect MySQL connection parameters for postfixadmin DB...", $stderr);
		if (!isset($CONF) or !is_array($CONF) or !isset($CONF['database_host']) or !$CONF['database_host'] or !isset($CONF['database_name']) or !$CONF['database_name'] or !isset($CONF['database_user']) or !$CONF['database_user'] or !isset($CONF['database_password']) or !$CONF['database_password']) {
			logging($log, "", " failed\n", $stderr);
			logging($log, "error:  ", "couldn't detect MySQL connection parameters for postfixadmin DB\n", $stderr);
		} else {
			$mysql_user = $CONF['database_user'];
			$mysql_pass = $CONF['database_password'];
			$mysql_host = $CONF['database_host'];
			$mysql_db = $CONF['database_name'];
			logging($log, "", " success\n", $stderr);
			logging($log, "info:   ", "connect to MySQL server '$mysql_host' as user '$mysql_user'...", $stderr);
			$db_connect_id = mysqli_connect($mysql_host, $mysql_user, $mysql_pass, $mysql_db);
			if (!$db_connect_id) {
				logging($log, "", " failed\n", $stderr);
				logging($log, "error:  ", "couldn't connect to MySQL server '$mysql_host' as user '$mysql_user'\n", $stderr);
			} else {
				logging($log, "", " success\n", $stderr);

				// for each identity from RoundCube
				logging($log, "info:   ", "update mail user names\n", $stderr);
				foreach ($data as $email => $name) {
					if ($name == "") {
						logging($log, "info:   ", "got empty name for email " . $email . ", skip updating\n", $stderr);
					} elseif ($name == $email) {
						logging($log, "info:   ", "got name matched email for email " . $email . ", skip updating\n", $stderr);
					} else {
						logging($log, "info:   ", "update name for email " . $email . " to '" . $name . "'\n", $stderr);

						$query = sprintf(
							"UPDATE mailbox SET name='%s' WHERE username = '%s' AND name = username;",
							$name, $email
						);
//print($query);
//die();
						logging($log, "info:   ", "execute MySQL query '$query'...", $stderr);
						$res = mysqli_query($db_connect_id, $query);
						if (!$res) {
							logging($log, "", " failed\n", $stderr);
							logging($log, "error:  ", "couldn't execute MySQL query '$query'\n", $stderr);
						} else {
							logging($log, "", " success\n", $stderr);
						}
					}
				}

				logging($log, "info:   ", "close MySQL connection...", $stderr);
				if (mysqli_close($db_connect_id)) {
					logging($log, "", " success\n", $stderr);
				} else {
					logging($log, "", " failed\n", $stderr);
					logging($log, "error:  ", "couldn't close connection to MySQL server '$mysql_host'\n", $stderr);
				}
			}
		}

		fclose($log);
	}
	fclose($stderr);
}

?>