476 lines
12 KiB
PHP
476 lines
12 KiB
PHP
|
<?php
|
||
|
|
/**
|
||
|
|
* Class for verifying Yubico One-Time-Passcodes
|
||
|
|
*
|
||
|
|
* @category Auth
|
||
|
|
* @package Auth_Yubico
|
||
|
|
* @author Simon Josefsson <simon@yubico.com>, Olov Danielson <olov@yubico.com>
|
||
|
|
* @copyright 2007-2015 Yubico AB
|
||
|
|
* @license http://opensource.org/licenses/bsd-license.php New BSD License
|
||
|
|
* @version 2.0
|
||
|
|
* @link http://www.yubico.com/
|
||
|
|
*/
|
||
|
|
|
||
|
|
require_once 'PEAR.php';
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Class for verifying Yubico One-Time-Passcodes
|
||
|
|
*
|
||
|
|
* Simple example:
|
||
|
|
* <code>
|
||
|
|
* require_once 'Auth/Yubico.php';
|
||
|
|
* $otp = "ccbbddeertkrctjkkcglfndnlihhnvekchkcctif";
|
||
|
|
*
|
||
|
|
* # Generate a new id+key from https://api.yubico.com/get-api-key/
|
||
|
|
* $yubi = new Auth_Yubico('42', 'FOOBAR=');
|
||
|
|
* $auth = $yubi->verify($otp);
|
||
|
|
* if (PEAR::isError($auth)) {
|
||
|
|
* print "<p>Authentication failed: " . $auth->getMessage();
|
||
|
|
* print "<p>Debug output from server: " . $yubi->getLastResponse();
|
||
|
|
* } else {
|
||
|
|
* print "<p>You are authenticated!";
|
||
|
|
* }
|
||
|
|
* </code>
|
||
|
|
*/
|
||
|
|
class Auth_Yubico
|
||
|
|
{
|
||
|
|
/**#@+
|
||
|
|
* @access private
|
||
|
|
*/
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Yubico client ID
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
var $_id;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Yubico client key
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
var $_key;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* URL part of validation server
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
var $_url;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* List with URL part of validation servers
|
||
|
|
* @var array
|
||
|
|
*/
|
||
|
|
var $_url_list;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* index to _url_list
|
||
|
|
* @var int
|
||
|
|
*/
|
||
|
|
var $_url_index;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Last query to server
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
var $_lastquery;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Response from server
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
var $_response;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Flag whether to use https or not.
|
||
|
|
* @var boolean
|
||
|
|
*/
|
||
|
|
var $_https;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Flag whether to verify HTTPS server certificates or not.
|
||
|
|
* @var boolean
|
||
|
|
*/
|
||
|
|
var $_httpsverify;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Constructor
|
||
|
|
*
|
||
|
|
* Sets up the object
|
||
|
|
* @param string $id The client identity
|
||
|
|
* @param string $key The client MAC key (optional)
|
||
|
|
* @param boolean $https Flag whether to use https (optional)
|
||
|
|
* @param boolean $httpsverify Flag whether to use verify HTTPS
|
||
|
|
* server certificates (optional,
|
||
|
|
* default true)
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function __construct($id, $key = '', $https = 0, $httpsverify = 1)
|
||
|
|
{
|
||
|
|
$this->_id = $id;
|
||
|
|
$this->_key = base64_decode($key);
|
||
|
|
$this->_https = $https;
|
||
|
|
$this->_httpsverify = $httpsverify;
|
||
|
|
}
|
||
|
|
|
||
|
|
function Auth_Yubico($id, $key = '', $https = 0, $httpsverify = 1)
|
||
|
|
{
|
||
|
|
self::__construct();
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Specify to use a different URL part for verification.
|
||
|
|
* The default is "api.yubico.com/wsapi/verify".
|
||
|
|
*
|
||
|
|
* @param string $url New server URL part to use
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function setURLpart($url)
|
||
|
|
{
|
||
|
|
$this->_url = $url;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Get URL part to use for validation.
|
||
|
|
*
|
||
|
|
* @return string Server URL part
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function getURLpart()
|
||
|
|
{
|
||
|
|
if ($this->_url) {
|
||
|
|
return $this->_url;
|
||
|
|
} else {
|
||
|
|
return "api.yubico.com/wsapi/verify";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Get next URL part from list to use for validation.
|
||
|
|
*
|
||
|
|
* @return mixed string with URL part of false if no more URLs in list
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function getNextURLpart()
|
||
|
|
{
|
||
|
|
if ($this->_url_list) $url_list=$this->_url_list;
|
||
|
|
else $url_list=array('api.yubico.com/wsapi/2.0/verify',
|
||
|
|
'api2.yubico.com/wsapi/2.0/verify',
|
||
|
|
'api3.yubico.com/wsapi/2.0/verify',
|
||
|
|
'api4.yubico.com/wsapi/2.0/verify',
|
||
|
|
'api5.yubico.com/wsapi/2.0/verify');
|
||
|
|
|
||
|
|
if ($this->_url_index>=count($url_list)) return false;
|
||
|
|
else return $url_list[$this->_url_index++];
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Resets index to URL list
|
||
|
|
*
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function URLreset()
|
||
|
|
{
|
||
|
|
$this->_url_index=0;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Add another URLpart.
|
||
|
|
*
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function addURLpart($URLpart)
|
||
|
|
{
|
||
|
|
$this->_url_list[]=$URLpart;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Return the last query sent to the server, if any.
|
||
|
|
*
|
||
|
|
* @return string Request to server
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function getLastQuery()
|
||
|
|
{
|
||
|
|
return $this->_lastquery;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Return the last data received from the server, if any.
|
||
|
|
*
|
||
|
|
* @return string Output from server
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function getLastResponse()
|
||
|
|
{
|
||
|
|
return $this->_response;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Parse input string into password, yubikey prefix,
|
||
|
|
* ciphertext, and OTP.
|
||
|
|
*
|
||
|
|
* @param string Input string to parse
|
||
|
|
* @param string Optional delimiter re-class, default is '[:]'
|
||
|
|
* @return array Keyed array with fields
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function parsePasswordOTP($str, $delim = '[:]')
|
||
|
|
{
|
||
|
|
if (!preg_match("/^((.*)" . $delim . ")?" .
|
||
|
|
"(([cbdefghijklnrtuv]{0,16})" .
|
||
|
|
"([cbdefghijklnrtuv]{32}))$/i",
|
||
|
|
$str, $matches)) {
|
||
|
|
/* Dvorak? */
|
||
|
|
if (!preg_match("/^((.*)" . $delim . ")?" .
|
||
|
|
"(([jxe\.uidchtnbpygk]{0,16})" .
|
||
|
|
"([jxe\.uidchtnbpygk]{32}))$/i",
|
||
|
|
$str, $matches)) {
|
||
|
|
return false;
|
||
|
|
} else {
|
||
|
|
$ret['otp'] = strtr($matches[3], "jxe.uidchtnbpygk", "cbdefghijklnrtuv");
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$ret['otp'] = $matches[3];
|
||
|
|
}
|
||
|
|
$ret['password'] = $matches[2];
|
||
|
|
$ret['prefix'] = $matches[4];
|
||
|
|
$ret['ciphertext'] = $matches[5];
|
||
|
|
return $ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* TODO? Add functions to get parsed parts of server response? */
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Parse parameters from last response
|
||
|
|
*
|
||
|
|
* example: getParameters("timestamp", "sessioncounter", "sessionuse");
|
||
|
|
*
|
||
|
|
* @param array @parameters Array with strings representing
|
||
|
|
* parameters to parse
|
||
|
|
* @return array parameter array from last response
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function getParameters($parameters)
|
||
|
|
{
|
||
|
|
if ($parameters == null) {
|
||
|
|
$parameters = array('timestamp', 'sessioncounter', 'sessionuse');
|
||
|
|
}
|
||
|
|
$param_array = array();
|
||
|
|
foreach ($parameters as $param) {
|
||
|
|
if(!preg_match("/" . $param . "=([0-9]+)/", $this->_response, $out)) {
|
||
|
|
return PEAR::raiseError('Could not parse parameter ' . $param . ' from response');
|
||
|
|
}
|
||
|
|
$param_array[$param]=$out[1];
|
||
|
|
}
|
||
|
|
return $param_array;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Verify Yubico OTP against multiple URLs
|
||
|
|
* Protocol specification 2.0 is used to construct validation requests
|
||
|
|
*
|
||
|
|
* @param string $token Yubico OTP
|
||
|
|
* @param int $use_timestamp 1=>send request with ×tamp=1 to
|
||
|
|
* get timestamp and session information
|
||
|
|
* in the response
|
||
|
|
* @param boolean $wait_for_all If true, wait until all
|
||
|
|
* servers responds (for debugging)
|
||
|
|
* @param string $sl Sync level in percentage between 0
|
||
|
|
* and 100 or "fast" or "secure".
|
||
|
|
* @param int $timeout Max number of seconds to wait
|
||
|
|
* for responses
|
||
|
|
* @return mixed PEAR error on error, true otherwise
|
||
|
|
* @access public
|
||
|
|
*/
|
||
|
|
function verify($token, $use_timestamp=null, $wait_for_all=False,
|
||
|
|
$sl=null, $timeout=null)
|
||
|
|
{
|
||
|
|
/* Construct parameters string */
|
||
|
|
$ret = $this->parsePasswordOTP($token);
|
||
|
|
if (!$ret) {
|
||
|
|
return PEAR::raiseError('Could not parse Yubikey OTP');
|
||
|
|
}
|
||
|
|
$params = array('id'=>$this->_id,
|
||
|
|
'otp'=>$ret['otp'],
|
||
|
|
'nonce'=>md5(uniqid(rand())));
|
||
|
|
/* Take care of protocol version 2 parameters */
|
||
|
|
if ($use_timestamp) $params['timestamp'] = 1;
|
||
|
|
if ($sl) $params['sl'] = $sl;
|
||
|
|
if ($timeout) $params['timeout'] = $timeout;
|
||
|
|
ksort($params);
|
||
|
|
$parameters = '';
|
||
|
|
foreach($params as $p=>$v) $parameters .= "&" . $p . "=" . $v;
|
||
|
|
$parameters = ltrim($parameters, "&");
|
||
|
|
|
||
|
|
/* Generate signature. */
|
||
|
|
if($this->_key <> "") {
|
||
|
|
$signature = base64_encode(hash_hmac('sha1', $parameters,
|
||
|
|
$this->_key, true));
|
||
|
|
$signature = preg_replace('/\+/', '%2B', $signature);
|
||
|
|
$parameters .= '&h=' . $signature;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Generate and prepare request. */
|
||
|
|
$this->_lastquery=null;
|
||
|
|
$this->URLreset();
|
||
|
|
$mh = curl_multi_init();
|
||
|
|
$ch = array();
|
||
|
|
while($URLpart=$this->getNextURLpart())
|
||
|
|
{
|
||
|
|
/* Support https. */
|
||
|
|
if ($this->_https) {
|
||
|
|
$query = "https://";
|
||
|
|
} else {
|
||
|
|
$query = "http://";
|
||
|
|
}
|
||
|
|
$query .= $URLpart . "?" . $parameters;
|
||
|
|
|
||
|
|
if ($this->_lastquery) { $this->_lastquery .= " "; }
|
||
|
|
$this->_lastquery .= $query;
|
||
|
|
|
||
|
|
$handle = curl_init($query);
|
||
|
|
curl_setopt($handle, CURLOPT_USERAGENT, "PEAR Auth_Yubico");
|
||
|
|
curl_setopt($handle, CURLOPT_RETURNTRANSFER, 1);
|
||
|
|
if (!$this->_httpsverify) {
|
||
|
|
curl_setopt($handle, CURLOPT_SSL_VERIFYPEER, 0);
|
||
|
|
curl_setopt($handle, CURLOPT_SSL_VERIFYHOST, 0);
|
||
|
|
}
|
||
|
|
curl_setopt($handle, CURLOPT_FAILONERROR, true);
|
||
|
|
/* If timeout is set, we better apply it here as well
|
||
|
|
in case the validation server fails to follow it.
|
||
|
|
*/
|
||
|
|
if ($timeout) curl_setopt($handle, CURLOPT_TIMEOUT, $timeout);
|
||
|
|
curl_multi_add_handle($mh, $handle);
|
||
|
|
|
||
|
|
$ch[(int)$handle] = $handle;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Execute and read request. */
|
||
|
|
$this->_response=null;
|
||
|
|
$replay=False;
|
||
|
|
$valid=False;
|
||
|
|
do {
|
||
|
|
/* Let curl do its work. */
|
||
|
|
while (($mrc = curl_multi_exec($mh, $active))
|
||
|
|
== CURLM_CALL_MULTI_PERFORM)
|
||
|
|
;
|
||
|
|
|
||
|
|
while ($info = curl_multi_info_read($mh)) {
|
||
|
|
if ($info['result'] == CURLE_OK) {
|
||
|
|
|
||
|
|
/* We have a complete response from one server. */
|
||
|
|
|
||
|
|
$str = curl_multi_getcontent($info['handle']);
|
||
|
|
$cinfo = curl_getinfo ($info['handle']);
|
||
|
|
|
||
|
|
if ($wait_for_all) { # Better debug info
|
||
|
|
$this->_response .= 'URL=' . $cinfo['url'] ."\n"
|
||
|
|
. $str . "\n";
|
||
|
|
}
|
||
|
|
|
||
|
|
if (preg_match("/status=([a-zA-Z0-9_]+)/", $str, $out)) {
|
||
|
|
$status = $out[1];
|
||
|
|
|
||
|
|
/*
|
||
|
|
* There are 3 cases.
|
||
|
|
*
|
||
|
|
* 1. OTP or Nonce values doesn't match - ignore
|
||
|
|
* response.
|
||
|
|
*
|
||
|
|
* 2. We have a HMAC key. If signature is invalid -
|
||
|
|
* ignore response. Return if status=OK or
|
||
|
|
* status=REPLAYED_OTP.
|
||
|
|
*
|
||
|
|
* 3. Return if status=OK or status=REPLAYED_OTP.
|
||
|
|
*/
|
||
|
|
if (!preg_match("/otp=".$params['otp']."/", $str) ||
|
||
|
|
!preg_match("/nonce=".$params['nonce']."/", $str)) {
|
||
|
|
/* Case 1. Ignore response. */
|
||
|
|
}
|
||
|
|
elseif ($this->_key <> "") {
|
||
|
|
/* Case 2. Verify signature first */
|
||
|
|
$rows = explode("\r\n", trim($str));
|
||
|
|
$response=array();
|
||
|
|
while (list($key, $val) = each($rows)) {
|
||
|
|
/* = is also used in BASE64 encoding so we only replace the first = by # which is not used in BASE64 */
|
||
|
|
$val = preg_replace('/=/', '#', $val, 1);
|
||
|
|
$row = explode("#", $val);
|
||
|
|
$response[$row[0]] = $row[1];
|
||
|
|
}
|
||
|
|
|
||
|
|
$parameters=array('nonce','otp', 'sessioncounter', 'sessionuse', 'sl', 'status', 't', 'timeout', 'timestamp');
|
||
|
|
sort($parameters);
|
||
|
|
$check=Null;
|
||
|
|
foreach ($parameters as $param) {
|
||
|
|
if (array_key_exists($param, $response)) {
|
||
|
|
if ($check) $check = $check . '&';
|
||
|
|
$check = $check . $param . '=' . $response[$param];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$checksignature =
|
||
|
|
base64_encode(hash_hmac('sha1', utf8_encode($check),
|
||
|
|
$this->_key, true));
|
||
|
|
|
||
|
|
if($response['h'] == $checksignature) {
|
||
|
|
if ($status == 'REPLAYED_OTP') {
|
||
|
|
if (!$wait_for_all) { $this->_response = $str; }
|
||
|
|
$replay=True;
|
||
|
|
}
|
||
|
|
if ($status == 'OK') {
|
||
|
|
if (!$wait_for_all) { $this->_response = $str; }
|
||
|
|
$valid=True;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
/* Case 3. We check the status directly */
|
||
|
|
if ($status == 'REPLAYED_OTP') {
|
||
|
|
if (!$wait_for_all) { $this->_response = $str; }
|
||
|
|
$replay=True;
|
||
|
|
}
|
||
|
|
if ($status == 'OK') {
|
||
|
|
if (!$wait_for_all) { $this->_response = $str; }
|
||
|
|
$valid=True;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if (!$wait_for_all && ($valid || $replay))
|
||
|
|
{
|
||
|
|
/* We have status=OK or status=REPLAYED_OTP, return. */
|
||
|
|
foreach ($ch as $h) {
|
||
|
|
curl_multi_remove_handle($mh, $h);
|
||
|
|
curl_close($h);
|
||
|
|
}
|
||
|
|
curl_multi_close($mh);
|
||
|
|
if ($replay) return PEAR::raiseError('REPLAYED_OTP');
|
||
|
|
if ($valid) return true;
|
||
|
|
return PEAR::raiseError($status);
|
||
|
|
}
|
||
|
|
|
||
|
|
curl_multi_remove_handle($mh, $info['handle']);
|
||
|
|
curl_close($info['handle']);
|
||
|
|
unset ($ch[(int)$info['handle']]);
|
||
|
|
}
|
||
|
|
curl_multi_select($mh);
|
||
|
|
}
|
||
|
|
} while ($active);
|
||
|
|
|
||
|
|
/* Typically this is only reached for wait_for_all=true or
|
||
|
|
* when the timeout is reached and there is no
|
||
|
|
* OK/REPLAYED_REQUEST answer (think firewall).
|
||
|
|
*/
|
||
|
|
|
||
|
|
foreach ($ch as $h) {
|
||
|
|
curl_multi_remove_handle ($mh, $h);
|
||
|
|
curl_close ($h);
|
||
|
|
}
|
||
|
|
curl_multi_close ($mh);
|
||
|
|
|
||
|
|
if ($replay) return PEAR::raiseError('REPLAYED_OTP');
|
||
|
|
if ($valid) return true;
|
||
|
|
return PEAR::raiseError('NO_VALID_ANSWER');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
?>
|