* 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/bin/auth_ejabberd.php * * - Change the access mode so it is readable only to the user ejabberd and has exec * $ chmod 700 /path/to/friendica/bin/auth_ejabberd.php * * - Edit your ejabberd.cfg file, comment out your auth_method and add: * {auth_method, external}. * {extauth_program, "/path/to/friendica/bin/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)" * */ namespace Friendica\Util; use Exception; use Friendica\App; use Friendica\Core\Config\IConfig; use Friendica\Core\PConfig\IPConfig; use Friendica\Database\Database; use Friendica\DI; use Friendica\Model\User; use Friendica\Network\HTTPException; class ExAuth { private $bDebug; private $host; /** * @var App\Mode */ private $appMode; /** * @var IConfig */ private $config; /** * @var IPConfig */ private $pConfig; /** * @var Database */ private $dba; /** * @var App\BaseURL */ private $baseURL; /** * @param App\Mode $appMode * @param IConfig $config * @param IPConfig $pConfig * @param Database $dba * @param App\BaseURL $baseURL * @throws Exception */ public function __construct(App\Mode $appMode, IConfig $config, IPConfig $pConfig, Database $dba, App\BaseURL $baseURL) { $this->appMode = $appMode; $this->config = $config; $this->pConfig = $pConfig; $this->dba = $dba; $this->baseURL = $baseURL; $this->bDebug = (int)$config->get('jabber', 'debug'); openlog('auth_ejabberd', LOG_PID, LOG_USER); $this->writeLog(LOG_NOTICE, 'start'); } /** * Standard input reading function, executes the auth with the provided * parameters * * @throws HTTPException\InternalServerErrorException */ public function readStdin() { if (!$this->appMode->isNormal()) { $this->writeLog(LOG_ERR, 'The node isn\'t ready.'); return; } while (!feof(STDIN)) { // Quit if the database connection went down if (!$this->dba->isConnected()) { $this->writeLog(LOG_ERR, 'the database connection went down'); return; } $iHeader = fgets(STDIN, 3); if (empty($iHeader)) { $this->writeLog(LOG_ERR, 'empty stdin'); return; } $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)); } } } /** * Check if the given username exists * * @param array $aCommand The command array * @throws HTTPException\InternalServerErrorException */ private function isUser(array $aCommand) { // 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; } // We only allow one process per hostname. So we set a lock file // Problem: We get the firstname after the first auth - not before $this->setHost($aCommand[2]); // Now we check if the given user is valid $sUser = str_replace(['%20', '(a)'], [' ', '@'], $aCommand[1]); // Does the hostname match? So we try directly if ($this->baseURL->getHostname() == $aCommand[2]) { $this->writeLog(LOG_INFO, 'internal user check for ' . $sUser . '@' . $aCommand[2]); $found = $this->dba->exists('user', ['nickname' => $sUser]); } else { $found = false; } // If the hostnames doesn't match or there is some failure, we try to check remotely if (!$found) { $found = $this->checkUser($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)); } } /** * 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? * @throws HTTPException\InternalServerErrorException */ private function checkUser($host, $user, $ssl) { $this->writeLog(LOG_INFO, 'external user check for ' . $user . '@' . $host); $url = ($ssl ? 'https' : 'http') . '://' . $host . '/noscrape/' . $user; $curlResult = DI::httpRequest()->get($url); if (!$curlResult->isSuccess()) { return false; } if ($curlResult->getReturnCode() != 200) { return false; } $json = @json_decode($curlResult->getBody()); if (!is_object($json)) { return false; } return $json->nick == $user; } /** * Authenticate the given user and password * * @param array $aCommand The command array * @throws Exception */ private function auth(array $aCommand) { // check user authentication if (sizeof($aCommand) != 4) { $this->writeLog(LOG_NOTICE, 'invalid auth command, data missing'); fwrite(STDOUT, pack('nn', 2, 0)); return; } // We only allow one process per hostname. So we set a lock file // Problem: We get the firstname after the first auth - not before $this->setHost($aCommand[2]); // We now check if the password match $sUser = str_replace(['%20', '(a)'], [' ', '@'], $aCommand[1]); $Error = false; // Does the hostname match? So we try directly if ($this->baseURL->getHostname() == $aCommand[2]) { try { $this->writeLog(LOG_INFO, 'internal auth for ' . $sUser . '@' . $aCommand[2]); User::getIdFromPasswordAuthentication($sUser, $aCommand[3], true); } catch (HTTPException\ForbiddenException $ex) { // User exists, authentication failed $this->writeLog(LOG_INFO, 'check against alternate password for ' . $sUser . '@' . $aCommand[2]); $aUser = User::getByNickname($sUser, ['uid']); $sPassword = $this->pConfig->get($aUser['uid'], 'xmpp', 'password', null, true); $Error = ($aCommand[3] != $sPassword); } catch (\Throwable $ex) { // User doesn't exist and any other failure case $this->writeLog(LOG_WARNING, $ex->getMessage() . ': ' . $sUser); $Error = true; } } else { $Error = true; } // If the hostnames doesn't match or there is some failure, we try to check remotely if ($Error && !$this->checkCredentials($aCommand[2], $aCommand[1], $aCommand[3], true)) { $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)); } } /** * 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 checkCredentials($host, $user, $password, $ssl) { $this->writeLog(LOG_INFO, 'external credential check for ' . $user . '@' . $host); $url = ($ssl ? 'https' : 'http') . '://' . $host . '/api/account/verify_credentials.json?skip_status=true'; $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); 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; } /** * Set the hostname for this process * * @param string $host The hostname */ private function setHost($host) { if (!empty($this->host)) { return; } $this->writeLog(LOG_INFO, 'Hostname for process ' . getmypid() . ' is ' . $host); $this->host = $host; $lockpath = $this->config->get('jabber', 'lockpath'); if (is_null($lockpath)) { $this->writeLog(LOG_INFO, 'No lockpath defined.'); return; } $file = $lockpath . DIRECTORY_SEPARATOR . $host; if (PidFile::isRunningProcess($file)) { if (PidFile::killProcess($file)) { $this->writeLog(LOG_INFO, 'Old process was successfully killed'); } else { $this->writeLog(LOG_ERR, "The old Process wasn't killed in time. We now quit our process."); die(); } } // Now it is safe to create the pid file PidFile::create($file); if (!file_exists($file)) { $this->writeLog(LOG_WARNING, 'Logfile ' . $file . " couldn't be created."); } } /** * 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); } /** * destroy the class, close the syslog connection. */ public function __destruct() { $this->writeLog(LOG_NOTICE, 'stop'); closelog(); } }