source: npl/mailserver/z_merge_agent/autocheck.php @ c5c522c

#!/usr/bin/php
<?php
/** 
 * Zarafa Z-Merge
 * 
 * Copyright (C) 2005 - 2008  Zarafa B.V.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License, version 3, 
 * and under the terms of the GNU General Public License, version 3,
 * as published by the Free Software Foundation.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU (Affero) General Public License for more details.
 * 
 * You should have received a copy of the GNU Affero General Public License 
 * and the GNU General Public License along with this program.  
 * If not, see <http://www.gnu.org/licenses/>.
 *  
 * Created on 07.11.2007 by Sebastian Kummer & Manfred Kutas
 *
 * @package Z-Merge
 */


echo "\n\n";
echo "Step 1 - Check configuration\n----------------------------------------------------------------------------\n";
define('BASEP', dirname($_SERVER['SCRIPT_FILENAME']) . "/");

echo "parsing of configuration: ";
$incfile = BASEP. '../z-merge.inc.php';
if (!file_exists($incfile)) die ("failed\n\nThe file $incfile could not be found"); 
        
exec('php '.$incfile, &$ret);
if (!empty($ret)) {
        echo "Configuration error! System claimed:\n";
        echo $ret[0] . $ret[1] . "\n\n";
        exit;   
}
require_once($incfile);
echo "ok\n";


//initialize logging 
$log =& LoggerManager::getLogger('main');
$log->info("initializing check tool");


echo "checking ZMERGE_DIR: ";
if (!file_exists(ZMERGE_DIR . "/z-merge.php")) die("Main directory: " . ZMERGE_DIR . " doesn't exist or agent not found\n\n");
echo "ok\n";


echo "checking ZMERGE_LOGFILE: ";
if (!file_exists(ZMERGE_LOGFILE)) {
        system("touch ". ZMERGE_LOGFILE);       
        if (!file_exists(ZMERGE_LOGFILE ))
                die("Logfile: ". ZMERGE_LOGFILE ." doesn't exist and directory isn't writable\n\n");    
}
echo "ok\n";

echo "checking ZMERGE_ERRORLOGFILE: ";
if (!file_exists(ZMERGE_ERRORLOGFILE )) {
        system("touch ". ZMERGE_ERRORLOGFILE);  
        if (!file_exists(ZMERGE_ERRORLOGFILE))
                die("Logfile: " . ZMERGE_ERRORLOGFILE ." doesn't exist and directory isn't writable\n\n");      
}
echo "ok\n"; 

echo "checking ZMERGE_SENDERRORS emailaddress: ";
if (ZMERGE_SENDERRORS !== false && !checkEmail(ZMERGE_SENDERRORS))
        die(ZMERGE_SENDERRORS ." invalid or domain not reachable\n\n");
echo "ok\n";    

echo "\n\n";            
echo "Step 2 - Check agent database connection\n----------------------------------------------------------------------------\n";
echo "connecting to database: ";
$logFake = new LogFake(); // prints logentries to the STDOUT
$db = new Database($logFake, false);
if ($logFake->hasError()) {
        if ($logFake->dbMissing()) {
                echo "fail\n\n";
                if (question("The database '". $db_dsn['database'] . "' not found. Would you like to create it? (y/n):", "ny") === false) {
                        $logFake->printErrors();
                        die("\n");
                }
                else {
                        system("echo \"CREATE DATABASE {$db_dsn['database']};\" | mysql -h{$db_dsn['hostspec']} -u{$db_dsn['username']} -p{$db_dsn['password']}");                      
                        system("mysql -h{$db_dsn['hostspec']} -u{$db_dsn['username']} -p{$db_dsn['password']} -D{$db_dsn['database']} < " . ZMERGE_DIR . "/tools/db.sql"); 
                }
                
                // retry connect
                echo "connecting to database (2): ";
                $logFake = new LogFake();
                $db = new Database($logFake, false);
                if ($logFake->dbMissing()) {
                        echo "fail\n\n";
                        echo "unsuccessfully creating the database\n";
                        $logFake->printErrors();
                        die("\n");
                }
        }
}
// shutdown the logFake
$logFake->disable();

echo "database structure: \n";
checkTable("lastmodes");
checkTable("objectmapping");
checkTable("usermapping");
checkTable("zmerge");

echo "\n\n";            
echo "Step 3 - Connector status and test\n----------------------------------------------------------------------------\n";
echo "loading connectors..";

try {
        $serv = MergeAgent::loadServers($servers, $log, $db);
}
catch (DynamicClassInstantiationZException $dci) {
        echo "\n\n". $dci->getTraceAsString();
        die("DynamicClassInstantiationZException: " . $dci->getMessage(). "\n");                
} 
catch (AuthenticationZException $ae) {
        die("\n\nAuthentication error: ".$ae->getMessage(). "\n");
}
echo "ok\n";


// general check of the servers
$servVal = array();
foreach ($serv as $s) {
        echo "\nchecking server ------- \"". $s->getName() . "\"\n";
        $sp = "           ";
        $stat = getServerInfo($s);
                $servVal[$s->getName()] = $stat;
        if (array_search("failed", $stat['info'])) {
            echo $sp . "The connector presents ERRORS!! \n";
            echo $sp . "Please check the values below and consult the installation manual troubleshooting area!\n\n";
        }
        else {
                echo $sp . "The connector test was completed sucessfully.\n\n";
        }
        foreach ($stat['info'] as $k=>$v) {
                if (substr($k, -1) == "2") continue;

                echo $sp . "- ". strip_tags($k);
                echo str_repeat(" ", 30 - strlen($k) + 6);
                echo strip_tags($v) . "\n";
                // print detailed information if available
                if (isset($stat['info'][$k . "2"])) {
                        echo $sp . "  " .str_repeat("^", strlen($k)). "--->";
                        echo str_repeat(" ", 30 - strlen($k) + 2);
                        echo strip_tags($stat['info'][$k . "2"]) . "\n";
                }
        }

        echo "\n" . $sp . "Users on the system: ". count($stat['users']) ."\n";

        
        if (isset($stat['appointments'])) {
                echo "\n" . $sp . "Statistics\n";
                echo $sp . "  - Appointments  : ". $stat['appointments'] . "\n";
        }
        if (isset($stat['contacts'])) 
                echo $sp . "  - Contacts      : ". $stat['contacts'] . "\n";
        if (isset($stat['tasks']))  
                echo $sp . "  - Tasks         : ". $stat['tasks'] . "\n";
        if (isset($stat['notes'])) 
                echo $sp . "  - Notes         : ". $stat['notes'] . "\n";

}


echo "\n\n";            
echo "Step 4: Automap users for connectors\n----------------------------------------------------------------------------\n";

// check for potential groups or double mapping
$stmt = "SELECT count(*) as c FROM usermapping u1, usermapping u2 WHERE u1.servername = u2.servername AND u1.serveruser = u2.serveruser AND u1.userid <> u2.userid";
if ($db->executeStatement($stmt, false) > 0) {
        echo "Usermapping contains double mapping or virtual groups. Automapping not possible.\n"; 
}

// no potential problems found.. try automap
else {
        $users_ids = array();
        
        // build list of already mapped users
        foreach ($serv as $s) {
                // get the userlist for this server
                $users = $servVal[$s->getName()]['users'];
                // loop through users and check if they are already mapped
                foreach ($users as $u) {
                        $userid = getUserMapping($s->getName(), $u);
        
                        // save userid for other servers
                        if ($userid !== false) $users_ids[$u] = array(true, $userid);
                }
        }
        
        // now look for unmapped users
        foreach ($serv as $s) {
                // get the userlist for this server
                $users = $servVal[$s->getName()]['users'];
                echo "\nprocessing ". count($users) . " users from \"" . $s->getName() . "\"\n";
                
                // loop through users and check if they are already mapped
                foreach ($users as $u) {
                        $userid = getUserMapping($s->getName(), $u);
        
                        // look for unmapped users
                        if ($userid == false) {
                                $users_found = &$users_ids[$u];
                                
                                if (is_array($users_found) && $users_found[0] == true) {
                                        // user already mapped,but not for this server.. just add mapping
                                        echo "User '$u' from \"" . $s->getName() . "\" is already mapped on another server. \n";
        
                                $a = question("Do you want to automap this user? (y/n) ", "yn");
                                if ($a === false) {echo "\n\n"; continue;}
                                
                                // MAP user!!!
                                if ($a == "y") {
                                                addUserMapping($s->getName(), $u, $users_found[1]);
                                                echo " --> user '$u' mapped for '{$s->getName()}'\n";
                                }                                       
                                }
                                // user found on other server, but not already mapped
                                else if (is_array($users_found) && $users_found[0] == false) {
                                        $users_found[1]++;
                                }
                                // completely new
                                else {
                                        $users_ids[$u] = array(false, 1);
                                }
                        }       
                        
                }
        }
        
        
        echo "\n";
        $unmapped = array();
        foreach ($users_ids as $user=>$found) {
                if ($found[0] == true) echo " -> username '$user' mapped for at least one system\n";
                else {
                        if ($found[1] == 1)     
                                $unmapped[] = "'" . $user . "'";
                        else {
                                echo "Found possible new user mapping. The username '$user' is available on {$found[1]} systems!\n";
        
                        $a = question("Do you want to automap this user? (y/n) ", "yn");
                        if ($a === false) {echo "\n\n"; continue;}
                        
                        // MAP user!!!
                        if ($a == "y") {
                                        $newId = false;
                                        foreach ($serv as $s) {
                                                $users = $servVal[$s->getName()]['users'];
                                                // user available for that server?
                                                if (in_array($user, $users)) {
                                                        if (! $newId) $newId = addUserMapping($s->getName(), $user, false);
                                                        else              $newId = addUserMapping($s->getName(), $user, $newId);
                                                        echo " --> user '$user' mapped for '{$s->getName()}'\n";
                                                }
                                        }                       
                        }
                        echo "\n";
                        }               
                }       
        }
        
        
        echo "\nThe username(s) ".implode(', ', $unmapped)." were found each only on one system. No mapping possible.\n";
} // end if no groups



echo "\n\n";            
echo "Step 5: Check the agents last-modification-ids\n----------------------------------------------------------------------------\n";


// get lastmodes of every server
foreach ($serv as $s) {
        foreach ($serv as $s2) {
                // don't query yourself
                if ($s->getName() == $s2->getName()) continue;
                $lastmod = $s->getLastModID($s2);
                                $fromConnId = $servVal[$s2->getName()]['modid'];                        

                                if (!is_numeric($fromConnId)) 
                        die("The connector from '{$s2->getName()}' hasn't reported an modification id. \n\nThe installation is NOT complete. Exiting.\n\n");

                if ($lastmod !== false && ($fromConnId - $lastmod) >= 0) {
                        echo "Overview for syncs to '{$s->getName()}' from '{$s2->getName()}'\n";
                        echo "     id saved by agent: $lastmod\n";
                        echo "       id on connector: $fromConnId\n";
                        echo "   unprocessed changes: " . ($fromConnId - $lastmod) . "\n\n";
                }
                // modid resetted on the connector
                else if (($fromConnId - $lastmod) < 0) {
                        echo "The modificationID for '{$s->getName()}' from '{$s2->getName()}' is greater than the id reported by the connector!!\n";
                        echo "That is not a normal behaviour. The connectors installation was changed. You must reinitialize the ids.\n";
                         
                        
                        echo "\nDo you want to set: \n";
                        echo "   (0) modificationID to zero (will produce $fromConnId changes when starting the agent!!)\n";
                        echo "   (c) to the last value reported from the connector (no old changes found when starting the agent)\n";
                        echo "   (n) do nothing (exit - installation incomplete)\n";
                        $a = question("Please choose (0/c/n) ", "0nc");
                        if ($a === false) {echo "\n\n"; continue;}

                        // insert into lastmods table
                        if ($a == "0" || $a == "c") {
                                                if ($a == "c") $a = $fromConnId;
                                echo "inserted into lastmodes: ". 
                                        ($db->executeStatement("UPDATE lastmodes SET lastmod = $a WHERE servername = '{$s->getName()}' AND targetserver = '{$s2->getName()}'"))
                                                ?"ok\n\n":"fail\n\n";
                        }                       
                }
                else {
                        echo "The modificationID for '{$s->getName()}' from '{$s2->getName()}' could not be found!!\n";
                        echo "The value reported from '{$s2->getName()}' is: ". $fromConnId . "\n";
                         
                        
                        echo "\nDo you want to set: \n";
                        echo "   (0) modificationID to zero (will produce $fromConnId changes when starting the agent!!)\n";
                        echo "   (c) to the last value reported from the connector (no old changes found when starting the agent)\n";
                        echo "   (n) do nothing (exit - installation incomplete)\n";
                        $a = question("Please choose (0/c/n) ", "0nc");
                        if ($a === false) {echo "\n\n"; continue;}

                        // insert into lastmods table
                        if ($a == "0" || $a == "c") {
                                                if ($a == "c") $a = $fromConnId;
                                echo "inserted into lastmodes: ". 
                                        ($db->executeStatement("INSERT INTO lastmodes (servername,targetserver,lastmod) VALUES('{$s->getName()}','{$s2->getName()}',$a)"))
                                                ?"ok\n\n":"fail\n\n";
                        }

                }
        }
}




function checkTable($table) {
        global $db;

        echo "   $table";
        echo str_repeat(" ", 13 - strlen($table));
        echo "      : "; 
        if ($db->tableExists($table))
                echo "ok\n"; 
        else 
                die("fail\n\nDatabase structure compromised");
}



function getUserMapping($serverName, $serveruser) {
        global $db;
        return $db->executeStatement("SELECT userid FROM usermapping WHERE servername='$serverName' AND serveruser='$serveruser' LIMIT 1", false);
}

function addUserMapping($serverName, $serveruser, $newId) {
        global $db;
        
        if ($newId === false) {
                // get the next user id! (not threadsafe, but should not be a problem)
                $newId = $db->executeStatement("SELECT MAX(userid)+1 FROM usermapping", false);
                if (! $newId) $newId = 1;
        }

        $db->executeStatement("INSERT INTO usermapping (userid, servername, serveruser) VALUES($newId, '$serverName', '$serveruser')", false);
        return $newId;
}

function checkEmail($email) {
        if(preg_match("/^([a-zA-Z0-9])+([a-zA-Z0-9\._-])*@([a-zA-Z0-9_-])+([a-zA-Z0-9\._-]+)+$/" , $email)){
                list($username,$domain)=split('@',$email);
                if(!checkdnsrr($domain,'MX')) return false;
                return true;
        }
        return false;
}



function question($question, $validanswers) {
        if (!in_array("--auto", $_SERVER['argv']))
        {
                while(!isset($k) || strpos($k, $validanswers) !== false) {
                        echo $question;
                        fscanf(STDIN, "%s", $k);
                        $k = trim($k);
                }
        }
        else
        {
            $k=$validanswers[0];
            echo "$question (automaticly choosing default: $k)\n";
        }
        if ($k == "n") return false;
        return $k;
}

// contact servers
function getServerInfo($serverProfile) {
        // connect to the check script
        try {
                        $serverProfile->getConnection()->initializeConnection("check");
                }
                catch (AuthenticationZException $ae) {
                        die("\n\nAuthentication error: ".$ae->getMessage(). "\n");
                }               

        $stat = array();
        $info = array();
        $users = array();
        if (! ($serverProfile->getConnection()->getRawError())) {
                        $result = $serverProfile->getConnection()->soapCall('check');

                if (!$serverProfile->getConnection()->getRawFault()) {
                        if ($err = $serverProfile->getConnection()->getRawError()) {

                                echo "Could not connect to the server \"{$serverProfile->getName()}\" - Error: $err\n";
                                $response = strip_tags($serverProfile->getConnection()->getRawResponse());

                                if ((preg_match("/HTTP\/1.+(\d{3}.*)/", $response, &$errs) && $errs[1] != 200) ||
                                         preg_match("/Fatal error:.((\w| |\.|\/|-|,|\(|\)|\[|\]|:|'|=)*)/", $response, &$errs) ||
                                         preg_match("/Parse error:.((\w| |\.|\/|-|,|\(|\)|\[|\]|:|'|=)*)/", $response, &$errs) ||
                                         preg_match("/Warning:.((\w| |\.|\/|-|,|\(|\)|\[|\]|:|'|=)*)/", $response, &$errs) ||
                                                                         preg_match("/(.+)$/", $response, &$errs)                                         
                                        ) {
                                        echo "Server \"{$serverProfile->getName()}\" said: " . $errs[1] . "\n";
                                }
                                
                                die();
                        }
                        else {
                                foreach ($result as $kv) {
                                        $n = $kv['name'];
                                        if ($n == 'modid' || $n == 'contacts' || $n == 'notes' || $n == 'tasks' || $n == 'appointments') {
                                                $stat[$n] = $kv['value'];
                                        }
                                        else if (stripos($n,'usr_') === 0) {
                                                $users[] = $kv['value'];
                                        }
                                        else {
                                                $info[$n] = $kv['value'];
                                        }
                                }
                                $stat['info'] = $info;
                                $stat['users'] = $users;
                                return $stat;
                        }
                }
                else echo "SOAP-Fault: ". $serverProfile->getConnection()->getRawFault . "\n";
                die();
        }
}

class LogFake {
        private $_err;
        private $_errors;
        
        function LogFake() {
                $this->_err = 0;
                $this->_errors = array();
                $this->_print = true;
        }
        
        function info($string) {
                if ($this->_print) echo $string . "\n"; 
        }
        
        function debug($string) {
                if ($this->_print) echo $string . "\n"; 
        }
        
        function warn($string) {
                if ($this->_print) echo $string . "\n"; 
        }
                
        function error($string) {
                if ($this->_print) {
                        $this->_errors[] = $string;
                        $this->_err++;  
                }
        }
        
        function hasError() {
                return ($this->_err > 0);
        }
        
        function dbMissing() {
                $dbMiss = false;
                foreach ($this->_errors as $e) {
                        if (stripos($e, "not select") !== true ||  stripos($e, "Unknown database") !== true) 
                                $dbMiss = true;
                }                               
                return $dbMiss;
        }

        function printErrors() {
                foreach ($this->_errors as $e) echo $e ."\n"; 
        }
        
        function disable() {
                $this->_print = false;
        }
}

?>