#!/usr/bin/php * modified for Friendica by Michael Vogel * published under GPL * * Latest version of the original script for joomla is available at: * http://87.230.15.86/~dado/ejabberd/joomla-login * * Installation: * * - Change it's owner to whichever user is running the server, ie. ejabberd * $ chown ejabberd:ejabberd /path/to/friendica/include/auth_ejabberd.php * * - Change the access mode so it is readable only to the user ejabberd and has exec * $ chmod 700 /path/to/friendica/include/auth_ejabberd.php * * - Edit your ejabberd.cfg file, comment out your auth_method and add: * {auth_method, external}. * {extauth_program, "/path/to/friendica/include/auth_ejabberd.php"}. * * - Restart your ejabberd service, you should be able to login with your friendica auth info * * Other hints: * - if your users have a space or a @ in their nickname, they'll run into trouble * registering with any client so they should be instructed to replace these chars * " " (space) is replaced with "%20" * "@" is replaced with "(a)" * */ use Friendica\App; use Friendica\Core\Config; use Friendica\Database\DBM; if (sizeof($_SERVER["argv"]) == 0) die(); $directory = dirname($_SERVER["argv"][0]); if (substr($directory, 0, 1) != "/") $directory = $_SERVER["PWD"]."/".$directory; $directory = realpath($directory."/.."); chdir($directory); require_once("boot.php"); global $a; if (empty($a)) { $a = new App(dirname(__DIR__)); } @include(".htconfig.php"); require_once("include/dba.php"); dba::connect($db_host, $db_user, $db_pass, $db_data); unset($db_host, $db_user, $db_pass, $db_data); $oAuth = new exAuth(); class exAuth { private $bDebug; /** * @brief Create the class and do the authentification studd * * @param boolean $bDebug Debug mode */ public function __construct() { // setter $this->bDebug = (int)Config::get('jabber', 'debug'); openlog('auth_ejabberd', LOG_PID, LOG_USER); $this->writeLog(LOG_NOTICE, "start"); // We are connected to the SQL server. do { // Quit if the database connection went down if (!dba::connected()) { $this->writeLog(LOG_ERR, "the database connection went down"); return; } $iHeader = fgets(STDIN, 3); $aLength = unpack("n", $iHeader); $iLength = $aLength["1"]; // No data? Then quit if ($iLength == 0) { $this->writeLog(LOG_ERR, "we got no data, quitting"); return; } // Fetching the data $sData = fgets(STDIN, $iLength + 1); $this->writeLog(LOG_DEBUG, "received data: ". $sData); $aCommand = explode(":", $sData); if (is_array($aCommand)) { switch ($aCommand[0]) { case "isuser": // Check the existance of a given username $this->isuser($aCommand); break; case "auth": // Check if the givven password is correct $this->auth($aCommand); break; case "setpass": // We don't accept the setting of passwords here $this->writeLog(LOG_NOTICE, "setpass command disabled"); fwrite(STDOUT, pack("nn", 2, 0)); break; default: // We don't know the given command $this->writeLog(LOG_NOTICE, "unknown command ". $aCommand[0]); fwrite(STDOUT, pack("nn", 2, 0)); break; } } else { $this->writeLog(LOG_NOTICE, "invalid command string ".$sData); fwrite(STDOUT, pack("nn", 2, 0)); } } while (true); } /** * @brief Check if the given username exists * * @param array $aCommand The command array */ private function isuser($aCommand) { $a = get_app(); // Check if there is a username if (!isset($aCommand[1])) { $this->writeLog(LOG_NOTICE, "invalid isuser command, no username given"); fwrite(STDOUT, pack("nn", 2, 0)); return; } // Now we check if the given user is valid $sUser = str_replace(array("%20", "(a)"), array(" ", "@"), $aCommand[1]); // Does the hostname match? So we try directly if ($a->get_hostname() == $aCommand[2]) { $this->writeLog(LOG_INFO, "internal user check for ". $sUser."@".$aCommand[2]); $sQuery = "SELECT `uid` FROM `user` WHERE `nickname`='".dbesc($sUser)."'"; $this->writeLog(LOG_DEBUG, "using query ". $sQuery); $r = q($sQuery); $found = DBM::is_result($r); } else { $found = false; } // If the hostnames doesn't match or there is some failure, we try to check remotely if (!$found) { $found = $this->check_user($aCommand[2], $aCommand[1], true); } if ($found) { // The user is okay $this->writeLog(LOG_NOTICE, "valid user: ". $sUser); fwrite(STDOUT, pack("nn", 2, 1)); } else { // The user isn't okay $this->writeLog(LOG_WARNING, "invalid user: ". $sUser); fwrite(STDOUT, pack("nn", 2, 0)); } } /** * @brief Check remote user existance via HTTP(S) * * @param string $host The hostname * @param string $user Username * @param boolean $ssl Should the check be done via SSL? * * @return boolean Was the user found? */ private function check_user($host, $user, $ssl) { $this->writeLog(LOG_INFO, "external user check for ".$user."@".$host); $url = ($ssl ? "https":"http")."://".$host."/noscrape/".$user; $data = z_fetch_url($url); if (!is_array($data)) return(false); if ($data["return_code"] != "200") return(false); $json = @json_decode($data["body"]); if (!is_object($json)) return(false); return($json->nick == $user); } /** * @brief Authenticate the givven user and password * * @param array $aCommand The command array */ private function auth($aCommand) { $a = get_app(); // check user authentication if (sizeof($aCommand) != 4) { $this->writeLog(LOG_NOTICE, "invalid auth command, data missing"); fwrite(STDOUT, pack("nn", 2, 0)); return; } // We now check if the password match $sUser = str_replace(array("%20", "(a)"), array(" ", "@"), $aCommand[1]); // Does the hostname match? So we try directly if ($a->get_hostname() == $aCommand[2]) { $this->writeLog(LOG_INFO, "internal auth for ".$sUser."@".$aCommand[2]); $sQuery = "SELECT `uid`, `password` FROM `user` WHERE `nickname`='".dbesc($sUser)."'"; $this->writeLog(LOG_DEBUG, "using query ". $sQuery); if ($oResult = q($sQuery)) { $uid = $oResult[0]["uid"]; $Error = ($oResult[0]["password"] != hash('whirlpool',$aCommand[3])); } else { $this->writeLog(LOG_WARNING, "invalid query: ". $sQuery); $Error = true; $uid = -1; } if ($Error) { $oConfig = q("SELECT `v` FROM `pconfig` WHERE `uid` = %d AND `cat` = 'xmpp' AND `k`='password' LIMIT 1;", intval($uid)); $this->writeLog(LOG_INFO, "check against alternate password for ".$sUser."@".$aCommand[2]); $Error = ($aCommand[3] != $oConfig[0]["v"]); } } else { $Error = true; } // If the hostnames doesn't match or there is some failure, we try to check remotely if ($Error) { $Error = !$this->check_credentials($aCommand[2], $aCommand[1], $aCommand[3], true); } if ($Error) { $this->writeLog(LOG_WARNING, "authentification failed for user ".$sUser."@". $aCommand[2]); fwrite(STDOUT, pack("nn", 2, 0)); } else { $this->writeLog(LOG_NOTICE, "authentificated user ".$sUser."@".$aCommand[2]); fwrite(STDOUT, pack("nn", 2, 1)); } } /** * @brief Check remote credentials via HTTP(S) * * @param string $host The hostname * @param string $user Username * @param string $password Password * @param boolean $ssl Should the check be done via SSL? * * @return boolean Are the credentials okay? */ private function check_credentials($host, $user, $password, $ssl) { $url = ($ssl ? "https":"http")."://".$host."/api/account/verify_credentials.json"; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5); curl_setopt($ch, CURLOPT_HEADER, true); curl_setopt($ch, CURLOPT_NOBODY, true); curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); curl_setopt($ch, CURLOPT_USERPWD, $user.':'.$password); $header = curl_exec($ch); $curl_info = @curl_getinfo($ch); $http_code = $curl_info["http_code"]; curl_close($ch); $this->writeLog(LOG_INFO, "external auth for ".$user."@".$host." returned ".$http_code); return ($http_code == 200); } /** * @brief write data to the syslog * * @param integer $loglevel The syslog loglevel * @param string $sMessage The syslog message */ private function writeLog($loglevel, $sMessage) { if (!$this->bDebug && ($loglevel >= LOG_DEBUG)) { return; } syslog($loglevel, $sMessage); } /** * @brief destroy the class, close the syslog connection. */ public function __destruct() { $this->writeLog(LOG_NOTICE, "stop"); closelog(); } }