*/ class CASClient { // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX CONFIGURATION XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // ######################################################################## // HTML OUTPUT // ######################################################################## /** * @addtogroup internalOutput * @{ */ /** * This method filters a string by replacing special tokens by appropriate values * and prints it. The corresponding tokens are taken into account: * - __CAS_VERSION__ * - __PHPCAS_VERSION__ * - __SERVER_BASE_URL__ * * Used by CASClient::PrintHTMLHeader() and CASClient::printHTMLFooter(). * * @param $str the string to filter and output * * @private */ function HTMLFilterOutput($str) { $str = str_replace('__CAS_VERSION__', $this->getServerVersion(), $str); $str = str_replace('__PHPCAS_VERSION__', phpCAS::getVersion(), $str); $str = str_replace('__SERVER_BASE_URL__', $this->getServerBaseURL(), $str); echo $str; } /** * A string used to print the header of HTML pages. Written by CASClient::setHTMLHeader(), * read by CASClient::printHTMLHeader(). * * @hideinitializer * @private * @see CASClient::setHTMLHeader, CASClient::printHTMLHeader() */ var $_output_header = ''; /** * This method prints the header of the HTML output (after filtering). If * CASClient::setHTMLHeader() was not used, a default header is output. * * @param $title the title of the page * * @see HTMLFilterOutput() * @private */ function printHTMLHeader($title) { $this->HTMLFilterOutput(str_replace('__TITLE__', $title, (empty($this->_output_header) ? '__TITLE__

__TITLE__

' : $this->_output_header) ) ); } /** * A string used to print the footer of HTML pages. Written by CASClient::setHTMLFooter(), * read by printHTMLFooter(). * * @hideinitializer * @private * @see CASClient::setHTMLFooter, CASClient::printHTMLFooter() */ var $_output_footer = ''; /** * This method prints the footer of the HTML output (after filtering). If * CASClient::setHTMLFooter() was not used, a default footer is output. * * @see HTMLFilterOutput() * @private */ function printHTMLFooter() { $this->HTMLFilterOutput(empty($this->_output_footer) ? ('
phpCAS __PHPCAS_VERSION__ ' . $this->getString(CAS_STR_USING_SERVER) . ' __SERVER_BASE_URL__ (CAS __CAS_VERSION__)
') : $this->_output_footer); } /** * This method set the HTML header used for all outputs. * * @param $header the HTML header. * * @public */ function setHTMLHeader($header) { $this->_output_header = $header; } /** * This method set the HTML footer used for all outputs. * * @param $footer the HTML footer. * * @public */ function setHTMLFooter($footer) { $this->_output_footer = $footer; } /** @} */ // ######################################################################## // INTERNATIONALIZATION // ######################################################################## /** * @addtogroup internalLang * @{ */ /** * A string corresponding to the language used by phpCAS. Written by * CASClient::setLang(), read by CASClient::getLang(). * @note debugging information is always in english (debug purposes only). * * @hideinitializer * @private * @sa CASClient::_strings, CASClient::getString() */ var $_lang = ''; /** * This method returns the language used by phpCAS. * * @return a string representing the language * * @private */ function getLang() { if (empty($this->_lang)) { $this->setLang(PHPCAS_LANG_DEFAULT); } return $this->_lang; } /** * array containing the strings used by phpCAS. Written by CASClient::setLang(), read by * CASClient::getString() and used by CASClient::setLang(). * * @note This array is filled by instructions in CAS/languages/<$this->_lang>.php * * @private * @see CASClient::_lang, CASClient::getString(), CASClient::setLang(), CASClient::getLang() */ var $_strings; /** * This method returns a string depending on the language. * * @param $str the index of the string in $_string. * * @return the string corresponding to $index in $string. * * @private */ function getString($str) { // call CASclient::getLang() to be sure the language is initialized $this->getLang(); if (!isset($this->_strings[$str])) { trigger_error('string `' . $str . '\' not defined for language `' . $this->getLang() . '\'', E_USER_ERROR); } return $this->_strings[$str]; } /** * This method is used to set the language used by phpCAS. * @note Can be called only once. * * @param $lang a string representing the language. * * @public * @sa CAS_LANG_FRENCH, CAS_LANG_ENGLISH */ function setLang($lang) { // include the corresponding language file include_once __DIR__.'/languages/'.$lang.'.php'; if (!is_array($this->_strings)) { trigger_error('language `'.$lang.'\' is not implemented', E_USER_ERROR); } $this->_lang = $lang; } /** @} */ // ######################################################################## // CAS SERVER CONFIG // ######################################################################## /** * @addtogroup internalConfig * @{ */ /** * a record to store information about the CAS server. * - $_server["version"]: the version of the CAS server * - $_server["hostname"]: the hostname of the CAS server * - $_server["port"]: the port the CAS server is running on * - $_server["uri"]: the base URI the CAS server is responding on * - $_server["base_url"]: the base URL of the CAS server * - $_server["login_url"]: the login URL of the CAS server * - $_server["service_validate_url"]: the service validating URL of the CAS server * - $_server["proxy_url"]: the proxy URL of the CAS server * - $_server["proxy_validate_url"]: the proxy validating URL of the CAS server * - $_server["logout_url"]: the logout URL of the CAS server * * $_server["version"], $_server["hostname"], $_server["port"] and $_server["uri"] * are written by CASClient::CASClient(), read by CASClient::getServerVersion(), * CASClient::getServerHostname(), CASClient::getServerPort() and CASClient::getServerURI(). * * The other fields are written and read by CASClient::getServerBaseURL(), * CASClient::getServerLoginURL(), CASClient::getServerServiceValidateURL(), * CASClient::getServerProxyValidateURL() and CASClient::getServerLogoutURL(). * * @hideinitializer * @private */ var $_server = array( 'version' => -1, 'hostname' => 'none', 'port' => -1, 'uri' => 'none' ); /** * This method is used to retrieve the version of the CAS server. * @return the version of the CAS server. * @private */ function getServerVersion() { return $this->_server['version']; } /** * This method is used to retrieve the hostname of the CAS server. * @return the hostname of the CAS server. * @private */ function getServerHostname() { return $this->_server['hostname']; } /** * This method is used to retrieve the port of the CAS server. * @return the port of the CAS server. * @private */ function getServerPort() { return $this->_server['port']; } /** * This method is used to retrieve the URI of the CAS server. * @return a URI. * @private */ function getServerURI() { return $this->_server['uri']; } /** * This method is used to retrieve the base URL of the CAS server. * @return a URL. * @private */ function getServerBaseURL() { // the URL is build only when needed if (empty($this->_server['base_url'])) { $this->_server['base_url'] = 'https://' . $this->getServerHostname() . ':' . $this->getServerPort() . $this->getServerURI(); } return $this->_server['base_url']; } /** * This method is used to retrieve the login URL of the CAS server. * @param $gateway true to check authentication, false to force it * @param $renew true to force the authentication with the CAS server * NOTE : It is recommended that CAS implementations ignore the * "gateway" parameter if "renew" is set * @return a URL. * @private */ function getServerLoginURL($gateway = false, $renew = false) { phpCAS::traceBegin(); // the URL is build only when needed if (empty($this->_server['login_url'])) { $this->_server['login_url'] = $this->getServerBaseURL(); $this->_server['login_url'] .= 'login?service='; // $this->_server['login_url'] .= preg_replace('/&/','%26',$this->getURL()); $this->_server['login_url'] .= urlencode($this->getURL()); if ($renew) { // It is recommended that when the "renew" parameter is set, its value be "true" $this->_server['login_url'] .= '&renew=true'; } elseif ($gateway) { // It is recommended that when the "gateway" parameter is set, its value be "true" $this->_server['login_url'] .= '&gateway=true'; } } phpCAS::traceEnd($this->_server['login_url']); return $this->_server['login_url']; } /** * This method sets the login URL of the CAS server. * @param $url the login URL * @private * @since 0.4.21 by Wyman Chan */ function setServerLoginURL($url) { return $this->_server['login_url'] = $url; } /** * This method sets the serviceValidate URL of the CAS server. * @param $url the serviceValidate URL * @private * @since 1.1.0 by Joachim Fritschi */ function setServerServiceValidateURL($url) { return $this->_server['service_validate_url'] = $url; } /** * This method sets the proxyValidate URL of the CAS server. * @param $url the proxyValidate URL * @private * @since 1.1.0 by Joachim Fritschi */ function setServerProxyValidateURL($url) { return $this->_server['proxy_validate_url'] = $url; } /** * This method sets the samlValidate URL of the CAS server. * @param $url the samlValidate URL * @private * @since 1.1.0 by Joachim Fritschi */ function setServerSamlValidateURL($url) { return $this->_server['saml_validate_url'] = $url; } /** * This method is used to retrieve the service validating URL of the CAS server. * @return a URL. * @private */ function getServerServiceValidateURL() { // the URL is build only when needed if (empty($this->_server['service_validate_url'])) { switch ($this->getServerVersion()) { case CAS_VERSION_1_0: $this->_server['service_validate_url'] = $this->getServerBaseURL() . 'validate'; break; case CAS_VERSION_2_0: $this->_server['service_validate_url'] = $this->getServerBaseURL() . 'serviceValidate'; break; } } // return $this->_server['service_validate_url'].'?service='.preg_replace('/&/','%26',$this->getURL()); return $this->_server['service_validate_url'] . '?service=' . urlencode($this->getURL()); } /** * This method is used to retrieve the SAML validating URL of the CAS server. * @return a URL. * @private */ function getServerSamlValidateURL() { phpCAS::traceBegin(); // the URL is build only when needed if (empty($this->_server['saml_validate_url'])) { switch ($this->getServerVersion()) { case SAML_VERSION_1_1: $this->_server['saml_validate_url'] = $this->getServerBaseURL() . 'samlValidate'; break; } } phpCAS::traceEnd($this->_server['saml_validate_url'] . '?TARGET=' . urlencode($this->getURL())); return $this->_server['saml_validate_url'] . '?TARGET=' . urlencode($this->getURL()); } /** * This method is used to retrieve the proxy validating URL of the CAS server. * @return a URL. * @private */ function getServerProxyValidateURL() { // the URL is build only when needed if (empty($this->_server['proxy_validate_url'])) { switch ($this->getServerVersion()) { case CAS_VERSION_1_0: $this->_server['proxy_validate_url'] = ''; break; case CAS_VERSION_2_0: $this->_server['proxy_validate_url'] = $this->getServerBaseURL() . 'proxyValidate'; break; } } // return $this->_server['proxy_validate_url'].'?service='.preg_replace('/&/','%26',$this->getURL()); return $this->_server['proxy_validate_url'] . '?service=' . urlencode($this->getURL()); } /** * This method is used to retrieve the proxy URL of the CAS server. * @return a URL. * @private */ function getServerProxyURL() { // the URL is build only when needed if (empty($this->_server['proxy_url'])) { switch ($this->getServerVersion()) { case CAS_VERSION_1_0: $this->_server['proxy_url'] = ''; break; case CAS_VERSION_2_0: $this->_server['proxy_url'] = $this->getServerBaseURL() . 'proxy'; break; } } return $this->_server['proxy_url']; } /** * This method is used to retrieve the logout URL of the CAS server. * @return a URL. * @private */ function getServerLogoutURL() { // the URL is build only when needed if (empty($this->_server['logout_url'])) { $this->_server['logout_url'] = $this->getServerBaseURL() . 'logout'; } return $this->_server['logout_url']; } /** * This method sets the logout URL of the CAS server. * @param $url the logout URL * @private * @since 0.4.21 by Wyman Chan */ function setServerLogoutURL($url) { return $this->_server['logout_url'] = $url; } /** * An array to store extra curl options. */ var $_curl_options = array(); /** * This method is used to set additional user curl options. */ function setExtraCurlOption($key, $value) { $this->_curl_options[$key] = $value; } /** * This method checks to see if the request is secured via HTTPS * @return true if https, false otherwise * @private */ function isHttps() { //if ( isset($_SERVER['HTTPS']) && !empty($_SERVER['HTTPS']) ) { //0.4.24 by Hinnack if (isset($_SERVER['HTTPS']) && !empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] == 'on') { return true; } else { return false; } } // ######################################################################## // CONSTRUCTOR // ######################################################################## /** * CASClient constructor. * * @param $server_version the version of the CAS server * @param $proxy TRUE if the CAS client is a CAS proxy, FALSE otherwise * @param $server_hostname the hostname of the CAS server * @param $server_port the port the CAS server is running on * @param $server_uri the URI the CAS server is responding on * @param $start_session Have phpCAS start PHP sessions (default true) * * @return a newly created CASClient object * * @public */ function CASClient( $server_version, $proxy, $server_hostname, $server_port, $server_uri, $start_session = true ) { phpCAS::traceBegin(); // the redirect header() call and DOM parsing code from domxml-php4-php5.php won't work in PHP4 compatibility mode if (version_compare(PHP_VERSION, '5', '>=') && ini_get('zend.ze1_compatibility_mode')) { phpCAS::error('phpCAS cannot support zend.ze1_compatibility_mode. Sorry.'); } // skip Session Handling for logout requests and if don't want it' if ($start_session && !$this->isLogoutRequest()) { phpCAS::trace("Starting session handling"); // Check for Tickets from the CAS server if (empty($_GET['ticket'])) { phpCAS::trace("No ticket found"); // only create a session if necessary if (!session_id()) { phpCAS::trace("No session found, creating new session"); session_start(); } } else { phpCAS::trace("Ticket found"); // We have to copy any old data before renaming the session if (session_id()) { phpCAS::trace("Old active session found, saving old data and destroying session"); $old_session = $_SESSION; session_destroy(); } else { session_start(); phpCAS::trace("Starting possible old session to copy variables"); $old_session = $_SESSION; session_destroy(); } // set up a new session, of name based on the ticket $session_id = preg_replace('/[^\w]/', '', $_GET['ticket']); phpCAS::LOG("Session ID: " . $session_id); session_id($session_id); session_start(); // restore old session vars if (isset($old_session)) { phpCAS::trace("Restoring old session vars"); $_SESSION = $old_session; } } } else { phpCAS::trace("Skipping session creation"); } // are we in proxy mode ? $this->_proxy = $proxy; //check version switch ($server_version) { case CAS_VERSION_1_0: if ($this->isProxy()) { phpCAS::error('CAS proxies are not supported in CAS ' . $server_version); } break; case CAS_VERSION_2_0: break; case SAML_VERSION_1_1: break; default: phpCAS::error('this version of CAS (`' . $server_version . '\') is not supported by phpCAS ' . phpCAS::getVersion()); } $this->_server['version'] = $server_version; // check hostname if (empty($server_hostname) || !preg_match('/[\.\d\-abcdefghijklmnopqrstuvwxyz]*/', $server_hostname) ) { phpCAS::error('bad CAS server hostname (`' . $server_hostname . '\')'); } $this->_server['hostname'] = $server_hostname; // check port if ($server_port == 0 || !is_int($server_port) ) { phpCAS::error('bad CAS server port (`' . $server_hostname . '\')'); } $this->_server['port'] = $server_port; // check URI if (!preg_match('/[\.\d\-_abcdefghijklmnopqrstuvwxyz\/]*/', $server_uri)) { phpCAS::error('bad CAS server URI (`' . $server_uri . '\')'); } // add leading and trailing `/' and remove doubles $server_uri = preg_replace('/\/\//', '/', '/' . $server_uri . '/'); $this->_server['uri'] = $server_uri; // set to callback mode if PgtIou and PgtId CGI GET parameters are provided if ($this->isProxy()) { $this->setCallbackMode(!empty($_GET['pgtIou']) && !empty($_GET['pgtId'])); } if ($this->isCallbackMode()) { //callback mode: check that phpCAS is secured if (!$this->isHttps()) { phpCAS::error('CAS proxies must be secured to use phpCAS; PGT\'s will not be received from the CAS server'); } } else { //normal mode: get ticket and remove it from CGI parameters for developpers $ticket = (isset($_GET['ticket']) ? $_GET['ticket'] : null); switch ($this->getServerVersion()) { case CAS_VERSION_1_0: // check for a Service Ticket if (preg_match('/^ST-/', $ticket)) { phpCAS::trace('ST \'' . $ticket . '\' found'); //ST present $this->setST($ticket); //ticket has been taken into account, unset it to hide it to applications unset($_GET['ticket']); } else { if (!empty($ticket)) { //ill-formed ticket, halt phpCAS::error('ill-formed ticket found in the URL (ticket=`' . htmlentities($ticket) . '\')'); } } break; case CAS_VERSION_2_0: // check for a Service or Proxy Ticket if (preg_match('/^[SP]T-/', $ticket)) { phpCAS::trace('ST or PT \'' . $ticket . '\' found'); $this->setPT($ticket); unset($_GET['ticket']); } else { if (!empty($ticket)) { //ill-formed ticket, halt phpCAS::error('ill-formed ticket found in the URL (ticket=`' . htmlentities($ticket) . '\')'); } } break; case SAML_VERSION_1_1: // SAML just does Service Tickets if (preg_match('/^[SP]T-/', $ticket)) { phpCAS::trace('SA \'' . $ticket . '\' found'); $this->setSA($ticket); unset($_GET['ticket']); } else { if (!empty($ticket)) { //ill-formed ticket, halt phpCAS::error('ill-formed ticket found in the URL (ticket=`' . htmlentities($ticket) . '\')'); } } break; } } phpCAS::traceEnd(); } /** @} */ // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX AUTHENTICATION XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX /** * @addtogroup internalAuthentication * @{ */ /** * The Authenticated user. Written by CASClient::setUser(), read by CASClient::getUser(). * @attention client applications should use phpCAS::getUser(). * * @hideinitializer * @private */ var $_user = ''; /** * This method sets the CAS user's login name. * * @param $user the login name of the authenticated user. * * @private */ function setUser($user) { $this->_user = $user; } /** * This method returns the CAS user's login name. * @warning should be called only after CASClient::forceAuthentication() or * CASClient::isAuthenticated(), otherwise halt with an error. * * @return the login name of the authenticated user */ function getUser() { if (empty($this->_user)) { phpCAS::error('this method should be used only after ' . __CLASS__ . '::forceAuthentication() or ' . __CLASS__ . '::isAuthenticated()'); } return $this->_user; } /*********************************************************************************************************************** * Atrributes section * * @author Matthias Crauwels , Ghent University, Belgium * ***********************************************************************************************************************/ /** * The Authenticated users attributes. Written by CASClient::setAttributes(), read by CASClient::getAttributes(). * @attention client applications should use phpCAS::getAttributes(). * * @hideinitializer * @private */ var $_attributes = array(); function setAttributes($attributes) { $this->_attributes = $attributes; } function getAttributes() { if (empty($this->_user)) { // if no user is set, there shouldn't be any attributes also... phpCAS::error('this method should be used only after ' . __CLASS__ . '::forceAuthentication() or ' . __CLASS__ . '::isAuthenticated()'); } return $this->_attributes; } function hasAttributes() { return !empty($this->_attributes); } function hasAttribute($key) { return (is_array($this->_attributes) && array_key_exists($key, $this->_attributes)); } function getAttribute($key) { if ($this->hasAttribute($key)) { return $this->_attributes[$key]; } } /** * This method is called to renew the authentication of the user * If the user is authenticated, renew the connection * If not, redirect to CAS * @public */ function renewAuthentication() { phpCAS::traceBegin(); // Either way, the user is authenticated by CAS if (isset($_SESSION['phpCAS']['auth_checked'])) { unset($_SESSION['phpCAS']['auth_checked']); } if ($this->isAuthenticated()) { phpCAS::trace('user already authenticated; renew'); $this->redirectToCas(false, true); } else { $this->redirectToCas(); } phpCAS::traceEnd(); } /** * This method is called to be sure that the user is authenticated. When not * authenticated, halt by redirecting to the CAS server; otherwise return TRUE. * @return TRUE when the user is authenticated; otherwise halt. * @public */ function forceAuthentication() { phpCAS::traceBegin(); if ($this->isAuthenticated()) { // the user is authenticated, nothing to be done. phpCAS::trace('no need to authenticate'); $res = true; } else { // the user is not authenticated, redirect to the CAS server if (isset($_SESSION['phpCAS']['auth_checked'])) { unset($_SESSION['phpCAS']['auth_checked']); } $this->redirectToCas(false/* no gateway */); // never reached $res = false; } phpCAS::traceEnd($res); return $res; } /** * An integer that gives the number of times authentication will be cached before rechecked. * * @hideinitializer * @private */ var $_cache_times_for_auth_recheck = 0; /** * Set the number of times authentication will be cached before rechecked. * * @param $n an integer. * * @public */ function setCacheTimesForAuthRecheck($n) { $this->_cache_times_for_auth_recheck = $n; } /** * This method is called to check whether the user is authenticated or not. * @return TRUE when the user is authenticated, FALSE otherwise. * @public */ function checkAuthentication() { phpCAS::traceBegin(); if ($this->isAuthenticated()) { phpCAS::trace('user is authenticated'); $res = true; } else { if (isset($_SESSION['phpCAS']['auth_checked'])) { // the previous request has redirected the client to the CAS server with gateway=true // comment line bellow to // unset($_SESSION['phpCAS']['auth_checked']); $res = false; } else { // $_SESSION['phpCAS']['auth_checked'] = true; // $this->redirectToCas(TRUE/* gateway */); // // never reached // $res = FALSE; // avoid a check against CAS on every request if (!isset($_SESSION['phpCAS']['unauth_count'])) { $_SESSION['phpCAS']['unauth_count'] = -2; } // uninitialized if (($_SESSION['phpCAS']['unauth_count'] != -2 && $this->_cache_times_for_auth_recheck == -1) || ($_SESSION['phpCAS']['unauth_count'] >= 0 && $_SESSION['phpCAS']['unauth_count'] < $this->_cache_times_for_auth_recheck) ) { $res = false; if ($this->_cache_times_for_auth_recheck != -1) { $_SESSION['phpCAS']['unauth_count']++; phpCAS::trace('user is not authenticated (cached for ' . $_SESSION['phpCAS']['unauth_count'] . ' times of ' . $this->_cache_times_for_auth_recheck . ')'); } else { phpCAS::trace('user is not authenticated (cached for until login pressed)'); } } else { $_SESSION['phpCAS']['unauth_count'] = 0; $_SESSION['phpCAS']['auth_checked'] = true; phpCAS::trace('user is not authenticated (cache reset)'); // $this->redirectToCas(TRUE/* gateway */); // never reached $res = false; } } } phpCAS::traceEnd($res); return $res; } /** * This method is called to check if the user is authenticated (previously or by * tickets given in the URL). * * @return TRUE when the user is authenticated. Also may redirect to the same URL without the ticket. * * @public */ function isAuthenticated() { phpCAS::traceBegin(); $res = false; $validate_url = ''; if ($this->wasPreviouslyAuthenticated()) { // the user has already (previously during the session) been // authenticated, nothing to be done. phpCAS::trace('user was already authenticated, no need to look for tickets'); $res = true; } else { if ($this->hasST()) { // if a Service Ticket was given, validate it phpCAS::trace('ST `' . $this->getST() . '\' is present'); $this->validateST($validate_url, $text_response, $tree_response); // if it fails, it halts phpCAS::trace('ST `' . $this->getST() . '\' was validated'); if ($this->isProxy()) { $this->validatePGT($validate_url, $text_response, $tree_response); // idem phpCAS::trace('PGT `' . $this->getPGT() . '\' was validated'); $_SESSION['phpCAS']['pgt'] = $this->getPGT(); } $_SESSION['phpCAS']['user'] = $this->getUser(); $res = true; } elseif ($this->hasPT()) { // if a Proxy Ticket was given, validate it phpCAS::trace('PT `' . $this->getPT() . '\' is present'); $this->validatePT($validate_url, $text_response, $tree_response); // note: if it fails, it halts phpCAS::trace('PT `' . $this->getPT() . '\' was validated'); if ($this->isProxy()) { $this->validatePGT($validate_url, $text_response, $tree_response); // idem phpCAS::trace('PGT `' . $this->getPGT() . '\' was validated'); $_SESSION['phpCAS']['pgt'] = $this->getPGT(); } $_SESSION['phpCAS']['user'] = $this->getUser(); $res = true; } elseif ($this->hasSA()) { // if we have a SAML ticket, validate it. phpCAS::trace('SA `' . $this->getSA() . '\' is present'); $this->validateSA($validate_url, $text_response, $tree_response); // if it fails, it halts phpCAS::trace('SA `' . $this->getSA() . '\' was validated'); $_SESSION['phpCAS']['user'] = $this->getUser(); $_SESSION['phpCAS']['attributes'] = $this->getAttributes(); $res = true; } else { // no ticket given, not authenticated phpCAS::trace('no ticket found'); } if ($res) { // if called with a ticket parameter, we need to redirect to the app without the ticket so that CAS-ification is transparent to the browser (for later POSTS) // most of the checks and errors should have been made now, so we're safe for redirect without masking error messages. header('Location: ' . $this->getURL()); phpCAS::log("Prepare redirect to : " . $this->getURL()); } } phpCAS::traceEnd($res); return $res; } /** * This method tells if the current session is authenticated. * @return true if authenticated based soley on $_SESSION variable * @since 0.4.22 by Brendan Arnold */ function isSessionAuthenticated() { return !empty($_SESSION['phpCAS']['user']); } /** * This method tells if the user has already been (previously) authenticated * by looking into the session variables. * * @note This function switches to callback mode when needed. * * @return TRUE when the user has already been authenticated; FALSE otherwise. * * @private */ function wasPreviouslyAuthenticated() { phpCAS::traceBegin(); if ($this->isCallbackMode()) { $this->callback(); } $auth = false; if ($this->isProxy()) { // CAS proxy: username and PGT must be present if ($this->isSessionAuthenticated() && !empty($_SESSION['phpCAS']['pgt'])) { // authentication already done $this->setUser($_SESSION['phpCAS']['user']); $this->setPGT($_SESSION['phpCAS']['pgt']); phpCAS::trace('user = `' . $_SESSION['phpCAS']['user'] . '\', PGT = `' . $_SESSION['phpCAS']['pgt'] . '\''); $auth = true; } elseif ($this->isSessionAuthenticated() && empty($_SESSION['phpCAS']['pgt'])) { // these two variables should be empty or not empty at the same time phpCAS::trace('username found (`' . $_SESSION['phpCAS']['user'] . '\') but PGT is empty'); // unset all tickets to enforce authentication unset($_SESSION['phpCAS']); $this->setST(''); $this->setPT(''); } elseif (!$this->isSessionAuthenticated() && !empty($_SESSION['phpCAS']['pgt'])) { // these two variables should be empty or not empty at the same time phpCAS::trace('PGT found (`' . $_SESSION['phpCAS']['pgt'] . '\') but username is empty'); // unset all tickets to enforce authentication unset($_SESSION['phpCAS']); $this->setST(''); $this->setPT(''); } else { phpCAS::trace('neither user not PGT found'); } } else { // `simple' CAS client (not a proxy): username must be present if ($this->isSessionAuthenticated()) { // authentication already done $this->setUser($_SESSION['phpCAS']['user']); if (isset($_SESSION['phpCAS']['attributes'])) { $this->setAttributes($_SESSION['phpCAS']['attributes']); } phpCAS::trace('user = `' . $_SESSION['phpCAS']['user'] . '\''); $auth = true; } else { phpCAS::trace('no user found'); } } phpCAS::traceEnd($auth); return $auth; } /** * This method is used to redirect the client to the CAS server. * It is used by CASClient::forceAuthentication() and CASClient::checkAuthentication(). * @param $gateway true to check authentication, false to force it * @param $renew true to force the authentication with the CAS server * @public */ function redirectToCas($gateway = false, $renew = false) { phpCAS::traceBegin(); $cas_url = $this->getServerLoginURL($gateway, $renew); header('Location: ' . $cas_url); phpCAS::log("Redirect to : " . $cas_url); $this->printHTMLHeader($this->getString(CAS_STR_AUTHENTICATION_WANTED)); printf('

' . $this->getString(CAS_STR_SHOULD_HAVE_BEEN_REDIRECTED) . '

', $cas_url); $this->printHTMLFooter(); phpCAS::traceExit(); exit(); } /** * This method is used to logout from CAS. * @params $params an array that contains the optional url and service parameters that will be passed to the CAS server * @public */ function logout($params) { phpCAS::traceBegin(); $cas_url = $this->getServerLogoutURL(); $paramSeparator = '?'; if (isset($params['url'])) { $cas_url = $cas_url . $paramSeparator . "url=" . urlencode($params['url']); $paramSeparator = '&'; } if (isset($params['service'])) { $cas_url = $cas_url . $paramSeparator . "service=" . urlencode($params['service']); } header('Location: ' . $cas_url); phpCAS::log("Prepare redirect to : " . $cas_url); session_unset(); session_destroy(); $this->printHTMLHeader($this->getString(CAS_STR_LOGOUT)); printf('

' . $this->getString(CAS_STR_SHOULD_HAVE_BEEN_REDIRECTED) . '

', $cas_url); $this->printHTMLFooter(); phpCAS::traceExit(); exit(); } /** * @return true if the current request is a logout request. * @private */ function isLogoutRequest() { return !empty($_POST['logoutRequest']); } /** * @return true if a logout request is allowed. * @private */ function isLogoutRequestAllowed() { } /** * This method handles logout requests. * @param $check_client true to check the client bofore handling the request, * false not to perform any access control. True by default. * @param $allowed_clients an array of host names allowed to send logout requests. * By default, only the CAs server (declared in the constructor) will be allowed. * @public */ function handleLogoutRequests($check_client = true, $allowed_clients = false) { phpCAS::traceBegin(); if (!$this->isLogoutRequest()) { phpCAS::log("Not a logout request"); phpCAS::traceEnd(); return; } phpCAS::log("Logout requested"); phpCAS::log("SAML REQUEST: " . $_POST['logoutRequest']); if ($check_client) { if (!$allowed_clients) { $allowed_clients = array($this->getServerHostname()); } $client_ip = $_SERVER['REMOTE_ADDR']; $client = gethostbyaddr($client_ip); phpCAS::log("Client: " . $client . "/" . $client_ip); $allowed = false; foreach ($allowed_clients as $allowed_client) { if (($client == $allowed_client) or ($client_ip == $allowed_client)) { phpCAS::log("Allowed client '" . $allowed_client . "' matches, logout request is allowed"); $allowed = true; break; } else { phpCAS::log("Allowed client '" . $allowed_client . "' does not match"); } } if (!$allowed) { phpCAS::error("Unauthorized logout request from client '" . $client . "'"); printf("Unauthorized!"); phpCAS::traceExit(); exit(); } } else { phpCAS::log("No access control set"); } // Extract the ticket from the SAML Request preg_match("|(.*)|", $_POST['logoutRequest'], $tick, PREG_OFFSET_CAPTURE, 3); $wrappedSamlSessionIndex = preg_replace('||', '', $tick[0][0]); $ticket2logout = preg_replace('||', '', $wrappedSamlSessionIndex); phpCAS::log("Ticket to logout: " . $ticket2logout); $session_id = preg_replace('/[^\w]/', '', $ticket2logout); phpCAS::log("Session id: " . $session_id); // destroy a possible application session created before phpcas if (session_id()) { session_unset(); session_destroy(); } // fix session ID session_id($session_id); $_COOKIE[session_name()] = $session_id; $_GET[session_name()] = $session_id; // Overwrite session session_start(); session_unset(); session_destroy(); printf("Disconnected!"); phpCAS::traceExit(); exit(); } /** @} */ // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX BASIC CLIENT FEATURES (CAS 1.0) XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // ######################################################################## // ST // ######################################################################## /** * @addtogroup internalBasic * @{ */ /** * the Service Ticket provided in the URL of the request if present * (empty otherwise). Written by CASClient::CASClient(), read by * CASClient::getST() and CASClient::hasPGT(). * * @hideinitializer * @private */ var $_st = ''; /** * This method returns the Service Ticket provided in the URL of the request. * @return The service ticket. * @private */ function getST() { return $this->_st; } /** * This method stores the Service Ticket. * @param $st The Service Ticket. * @private */ function setST($st) { $this->_st = $st; } /** * This method tells if a Service Ticket was stored. * @return TRUE if a Service Ticket has been stored. * @private */ function hasST() { return !empty($this->_st); } /** @} */ // ######################################################################## // ST VALIDATION // ######################################################################## /** * @addtogroup internalBasic * @{ */ /** * the certificate of the CAS server. * * @hideinitializer * @private */ var $_cas_server_cert = ''; /** * the certificate of the CAS server CA. * * @hideinitializer * @private */ var $_cas_server_ca_cert = ''; /** * Set to true not to validate the CAS server. * * @hideinitializer * @private */ var $_no_cas_server_validation = false; /** * Set the certificate of the CAS server. * * @param $cert the PEM certificate */ function setCasServerCert($cert) { $this->_cas_server_cert = $cert; } /** * Set the CA certificate of the CAS server. * * @param $cert the PEM certificate of the CA that emited the cert of the server */ function setCasServerCACert($cert) { $this->_cas_server_ca_cert = $cert; } /** * Set no SSL validation for the CAS server. */ function setNoCasServerValidation() { $this->_no_cas_server_validation = true; } /** * This method is used to validate a ST; halt on failure, and sets $validate_url, * $text_reponse and $tree_response on success. These parameters are used later * by CASClient::validatePGT() for CAS proxies. * Used for all CAS 1.0 validations * @param $validate_url the URL of the request to the CAS server. * @param $text_response the response of the CAS server, as is (XML text). * @param $tree_response the response of the CAS server, as a DOM XML tree. * * @return bool TRUE when successfull, halt otherwise by calling CASClient::authError(). * * @private */ function validateST($validate_url, &$text_response, &$tree_response) { phpCAS::traceBegin(); // build the URL to validate the ticket $validate_url = $this->getServerServiceValidateURL() . '&ticket=' . $this->getST(); if ($this->isProxy()) { // pass the callback url for CAS proxies $validate_url .= '&pgtUrl=' . $this->getCallbackURL(); } // open and read the URL if (!$this->readURL($validate_url, ''/*cookies*/, $headers, $text_response, $err_msg)) { phpCAS::trace('could not open URL \'' . $validate_url . '\' to validate (' . $err_msg . ')'); $this->authError('ST not validated', $validate_url, true/*$no_response*/); } // analyze the result depending on the version switch ($this->getServerVersion()) { case CAS_VERSION_1_0: if (preg_match('/^no\n/', $text_response)) { phpCAS::trace('ST has not been validated'); $this->authError('ST not validated', $validate_url, false/*$no_response*/, false/*$bad_response*/, $text_response); } if (!preg_match('/^yes\n/', $text_response)) { phpCAS::trace('ill-formed response'); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // ST has been validated, extract the user name $arr = preg_split('/\n/', $text_response); $this->setUser(trim($arr[1])); break; case CAS_VERSION_2_0: // read the response of the CAS server into a DOM object if (!($dom = domxml_open_mem($text_response))) { phpCAS::trace('domxml_open_mem() failed'); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // read the root node of the XML tree if (!($tree_response = $dom->document_element())) { phpCAS::trace('document_element() failed'); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // insure that tag name is 'serviceResponse' if ($tree_response->node_name() != 'serviceResponse') { phpCAS::trace('bad XML root node (should be `serviceResponse\' instead of `' . $tree_response->node_name() . '\''); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } if (sizeof($success_elements = $tree_response->get_elements_by_tagname("authenticationSuccess")) != 0) { // authentication succeded, extract the user name if (sizeof($user_elements = $success_elements[0]->get_elements_by_tagname("user")) == 0) { phpCAS::trace(' found, but no '); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } $user = trim($user_elements[0]->get_content()); phpCAS::trace('user = `' . $user); $this->setUser($user); } else { if (sizeof($failure_elements = $tree_response->get_elements_by_tagname("authenticationFailure")) != 0) { phpCAS::trace(' found'); // authentication failed, extract the error code and message $this->authError('ST not validated', $validate_url, false/*$no_response*/, false/*$bad_response*/, $text_response, $failure_elements[0]->get_attribute('code')/*$err_code*/, trim($failure_elements[0]->get_content())/*$err_msg*/); } else { phpCAS::trace('neither nor found'); $this->authError('ST not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } } break; } // at this step, ST has been validated and $this->_user has been set, phpCAS::traceEnd(true); return true; } // ######################################################################## // SAML VALIDATION // ######################################################################## /** * @addtogroup internalBasic * @{ */ /** * This method is used to validate a SAML TICKET; halt on failure, and sets $validate_url, * $text_reponse and $tree_response on success. These parameters are used later * by CASClient::validatePGT() for CAS proxies. * * @param $validate_url the URL of the request to the CAS server. * @param $text_response the response of the CAS server, as is (XML text). * @param $tree_response the response of the CAS server, as a DOM XML tree. * * @return bool TRUE when successfull, halt otherwise by calling CASClient::authError(). * * @private */ function validateSA($validate_url, &$text_response, &$tree_response) { phpCAS::traceBegin(); // build the URL to validate the ticket $validate_url = $this->getServerSamlValidateURL(); // open and read the URL if (!$this->readURL($validate_url, ''/*cookies*/, $headers, $text_response, $err_msg)) { phpCAS::trace('could not open URL \'' . $validate_url . '\' to validate (' . $err_msg . ')'); $this->authError('SA not validated', $validate_url, true/*$no_response*/); } phpCAS::trace('server version: ' . $this->getServerVersion()); // analyze the result depending on the version switch ($this->getServerVersion()) { case SAML_VERSION_1_1: // read the response of the CAS server into a DOM object if (!($dom = domxml_open_mem($text_response))) { phpCAS::trace('domxml_open_mem() failed'); $this->authError('SA not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // read the root node of the XML tree if (!($tree_response = $dom->document_element())) { phpCAS::trace('document_element() failed'); $this->authError('SA not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // insure that tag name is 'Envelope' if ($tree_response->node_name() != 'Envelope') { phpCAS::trace('bad XML root node (should be `Envelope\' instead of `' . $tree_response->node_name() . '\''); $this->authError('SA not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // check for the NameIdentifier tag in the SAML response if (sizeof($success_elements = $tree_response->get_elements_by_tagname("NameIdentifier")) != 0) { phpCAS::trace('NameIdentifier found'); $user = trim($success_elements[0]->get_content()); phpCAS::trace('user = `' . $user . '`'); $this->setUser($user); $this->setSessionAttributes($text_response); } else { phpCAS::trace('no tag found in SAML payload'); $this->authError('SA not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } break; } // at this step, ST has been validated and $this->_user has been set, phpCAS::traceEnd(true); return true; } /** * This method will parse the DOM and pull out the attributes from the SAML * payload and put them into an array, then put the array into the session. * * @param $text_response the SAML payload. * @return bool TRUE when successfull, halt otherwise by calling CASClient::authError(). * * @private */ function setSessionAttributes($text_response) { phpCAS::traceBegin(); $result = false; if (isset($_SESSION[SAML_ATTRIBUTES])) { phpCAS::trace("session attrs already set."); //testbml - do we care? } $attr_array = array(); if (($dom = domxml_open_mem($text_response))) { $xPath = $dom->xpath_new_context(); $xPath->xpath_register_ns('samlp', 'urn:oasis:names:tc:SAML:1.0:protocol'); $xPath->xpath_register_ns('saml', 'urn:oasis:names:tc:SAML:1.0:assertion'); $nodelist = $xPath->xpath_eval("//saml:Attribute"); $attrs = $nodelist->nodeset; phpCAS::trace($text_response); foreach ($attrs as $attr) { $xres = $xPath->xpath_eval("saml:AttributeValue", $attr); $name = $attr->get_attribute("AttributeName"); $value_array = array(); foreach ($xres->nodeset as $node) { $value_array[] = $node->get_content(); } phpCAS::trace("* " . $name . "=" . $value_array); $attr_array[$name] = $value_array; } $_SESSION[SAML_ATTRIBUTES] = $attr_array; // UGent addition... foreach ($attr_array as $attr_key => $attr_value) { if (count($attr_value) > 1) { $this->_attributes[$attr_key] = $attr_value; } else { $this->_attributes[$attr_key] = $attr_value[0]; } } $result = true; } phpCAS::traceEnd($result); return $result; } /** @} */ // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX PROXY FEATURES (CAS 2.0) XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // ######################################################################## // PROXYING // ######################################################################## /** * @addtogroup internalProxy * @{ */ /** * A boolean telling if the client is a CAS proxy or not. Written by CASClient::CASClient(), * read by CASClient::isProxy(). * * @private */ var $_proxy; /** * Tells if a CAS client is a CAS proxy or not * * @return TRUE when the CAS client is a CAs proxy, FALSE otherwise * * @private */ function isProxy() { return $this->_proxy; } /** @} */ // ######################################################################## // PGT // ######################################################################## /** * @addtogroup internalProxy * @{ */ /** * the Proxy Grnting Ticket given by the CAS server (empty otherwise). * Written by CASClient::setPGT(), read by CASClient::getPGT() and CASClient::hasPGT(). * * @hideinitializer * @private */ var $_pgt = ''; /** * This method returns the Proxy Granting Ticket given by the CAS server. * @return The Proxy Granting Ticket. * @private */ function getPGT() { return $this->_pgt; } /** * This method stores the Proxy Granting Ticket. * @param $pgt The Proxy Granting Ticket. * @private */ function setPGT($pgt) { $this->_pgt = $pgt; } /** * This method tells if a Proxy Granting Ticket was stored. * @return TRUE if a Proxy Granting Ticket has been stored. * @private */ function hasPGT() { return !empty($this->_pgt); } /** @} */ // ######################################################################## // CALLBACK MODE // ######################################################################## /** * @addtogroup internalCallback * @{ */ /** * each PHP script using phpCAS in proxy mode is its own callback to get the * PGT back from the CAS server. callback_mode is detected by the constructor * thanks to the GET parameters. */ /** * a boolean to know if the CAS client is running in callback mode. Written by * CASClient::setCallBackMode(), read by CASClient::isCallbackMode(). * * @hideinitializer * @private */ var $_callback_mode = false; /** * This method sets/unsets callback mode. * * @param $callback_mode TRUE to set callback mode, FALSE otherwise. * * @private */ function setCallbackMode($callback_mode) { $this->_callback_mode = $callback_mode; } /** * This method returns TRUE when the CAs client is running i callback mode, * FALSE otherwise. * * @return A boolean. * * @private */ function isCallbackMode() { return $this->_callback_mode; } /** * the URL that should be used for the PGT callback (in fact the URL of the * current request without any CGI parameter). Written and read by * CASClient::getCallbackURL(). * * @hideinitializer * @private */ var $_callback_url = ''; /** * This method returns the URL that should be used for the PGT callback (in * fact the URL of the current request without any CGI parameter, except if * phpCAS::setFixedCallbackURL() was used). * * @return The callback URL * * @private */ function getCallbackURL() { // the URL is built when needed only if (empty($this->_callback_url)) { $final_uri = ''; // remove the ticket if present in the URL $final_uri = 'https://'; /* replaced by Julien Marchal - v0.4.6 * $this->uri .= $_SERVER['SERVER_NAME']; */ if (empty($_SERVER['HTTP_X_FORWARDED_SERVER'])) { /* replaced by teedog - v0.4.12 * $final_uri .= $_SERVER['SERVER_NAME']; */ if (empty($_SERVER['SERVER_NAME'])) { $final_uri .= $_SERVER['HTTP_HOST']; } else { $final_uri .= $_SERVER['SERVER_NAME']; } } else { $final_uri .= $_SERVER['HTTP_X_FORWARDED_SERVER']; } if (($this->isHttps() && $_SERVER['SERVER_PORT'] != 443) || (!$this->isHttps() && $_SERVER['SERVER_PORT'] != 80) ) { $final_uri .= ':'; $final_uri .= $_SERVER['SERVER_PORT']; } $request_uri = $_SERVER['REQUEST_URI']; $request_uri = preg_replace('/\?.*$/', '', $request_uri); $final_uri .= $request_uri; $this->setCallbackURL($final_uri); } return $this->_callback_url; } /** * This method sets the callback url. * * @param $callback_url url to set callback * * @private */ function setCallbackURL($url) { return $this->_callback_url = $url; } /** * This method is called by CASClient::CASClient() when running in callback * mode. It stores the PGT and its PGT Iou, prints its output and halts. * * @private */ function callback() { phpCAS::traceBegin(); $this->printHTMLHeader('phpCAS callback'); $pgt_iou = $_GET['pgtIou']; $pgt = $_GET['pgtId']; phpCAS::trace('Storing PGT `' . $pgt . '\' (id=`' . $pgt_iou . '\')'); echo '

Storing PGT `' . $pgt . '\' (id=`' . $pgt_iou . '\').

'; $this->storePGT($pgt, $pgt_iou); $this->printHTMLFooter(); phpCAS::traceExit(); exit(); } /** @} */ // ######################################################################## // PGT STORAGE // ######################################################################## /** * @addtogroup internalPGTStorage * @{ */ /** * an instance of a class inheriting of PGTStorage, used to deal with PGT * storage. Created by CASClient::setPGTStorageFile() or CASClient::setPGTStorageDB(), used * by CASClient::setPGTStorageFile(), CASClient::setPGTStorageDB() and CASClient::initPGTStorage(). * * @hideinitializer * @private */ var $_pgt_storage = null; /** * This method is used to initialize the storage of PGT's. * Halts on error. * * @private */ function initPGTStorage() { // if no SetPGTStorageXxx() has been used, default to file if (!is_object($this->_pgt_storage)) { $this->setPGTStorageFile(); } // initializes the storage $this->_pgt_storage->init(); } /** * This method stores a PGT. Halts on error. * * @param $pgt the PGT to store * @param $pgt_iou its corresponding Iou * * @private */ function storePGT($pgt, $pgt_iou) { // ensure that storage is initialized $this->initPGTStorage(); // writes the PGT $this->_pgt_storage->write($pgt, $pgt_iou); } /** * This method reads a PGT from its Iou and deletes the corresponding storage entry. * * @param $pgt_iou the PGT Iou * * @return The PGT corresponding to the Iou, FALSE when not found. * * @private */ function loadPGT($pgt_iou) { // ensure that storage is initialized $this->initPGTStorage(); // read the PGT return $this->_pgt_storage->read($pgt_iou); } /** * This method is used to tell phpCAS to store the response of the * CAS server to PGT requests onto the filesystem. * * @param $format the format used to store the PGT's (`plain' and `xml' allowed) * @param $path the path where the PGT's should be stored * * @public */ function setPGTStorageFile( $format = '', $path = '' ) { // check that the storage has not already been set if (is_object($this->_pgt_storage)) { phpCAS::error('PGT storage already defined'); } // create the storage object $this->_pgt_storage = new PGTStorageFile($this, $format, $path); } /** * This method is used to tell phpCAS to store the response of the * CAS server to PGT requests into a database. * @note The connection to the database is done only when needed. * As a consequence, bad parameters are detected only when * initializing PGT storage. * * @param $user the user to access the data with * @param $password the user's password * @param $database_type the type of the database hosting the data * @param $hostname the server hosting the database * @param $port the port the server is listening on * @param $database the name of the database * @param $table the name of the table storing the data * * @public */ function setPGTStorageDB( $user, $password, $database_type, $hostname, $port, $database, $table ) { // check that the storage has not already been set if (is_object($this->_pgt_storage)) { phpCAS::error('PGT storage already defined'); } // warn the user that he should use file storage... trigger_error('PGT storage into database is an experimental feature, use at your own risk', E_USER_WARNING); // create the storage object $this->_pgt_storage = new PGTStorageDB($this, $user, $password, $database_type, $hostname, $port, $database, $table); } // ######################################################################## // PGT VALIDATION // ######################################################################## /** * This method is used to validate a PGT; halt on failure. * * @param $validate_url the URL of the request to the CAS server. * @param $text_response the response of the CAS server, as is (XML text); result * of CASClient::validateST() or CASClient::validatePT(). * @param $tree_response the response of the CAS server, as a DOM XML tree; result * of CASClient::validateST() or CASClient::validatePT(). * * @return bool TRUE when successfull, halt otherwise by calling CASClient::authError(). * * @private */ function validatePGT(&$validate_url, $text_response, $tree_response) { // here cannot use phpCAS::traceBegin(); alongside domxml-php4-to-php5.php phpCAS::log('start validatePGT()'); if (sizeof($arr = $tree_response->get_elements_by_tagname("proxyGrantingTicket")) == 0) { phpCAS::trace(' not found'); // authentication succeded, but no PGT Iou was transmitted $this->authError('Ticket validated but no PGT Iou transmitted', $validate_url, false/*$no_response*/, false/*$bad_response*/, $text_response); } else { // PGT Iou transmitted, extract it $pgt_iou = trim($arr[0]->get_content()); $pgt = $this->loadPGT($pgt_iou); if ($pgt == false) { phpCAS::trace('could not load PGT'); $this->authError('PGT Iou was transmitted but PGT could not be retrieved', $validate_url, false/*$no_response*/, false/*$bad_response*/, $text_response); } $this->setPGT($pgt); } // here, cannot use phpCAS::traceEnd(TRUE); alongside domxml-php4-to-php5.php phpCAS::log('end validatePGT()'); return true; } // ######################################################################## // PGT VALIDATION // ######################################################################## /** * This method is used to retrieve PT's from the CAS server thanks to a PGT. * * @param $target_service the service to ask for with the PT. * @param $err_code an error code (PHPCAS_SERVICE_OK on success). * @param $err_msg an error message (empty on success). * * @return a Proxy Ticket, or FALSE on error. * * @private */ function retrievePT($target_service, &$err_code, &$err_msg) { phpCAS::traceBegin(); // by default, $err_msg is set empty and $pt to TRUE. On error, $pt is // set to false and $err_msg to an error message. At the end, if $pt is FALSE // and $error_msg is still empty, it is set to 'invalid response' (the most // commonly encountered error). $err_msg = ''; // build the URL to retrieve the PT // $cas_url = $this->getServerProxyURL().'?targetService='.preg_replace('/&/','%26',$target_service).'&pgt='.$this->getPGT(); $cas_url = $this->getServerProxyURL() . '?targetService=' . urlencode($target_service) . '&pgt=' . $this->getPGT(); // open and read the URL if (!$this->readURL($cas_url, ''/*cookies*/, $headers, $cas_response, $err_msg)) { phpCAS::trace('could not open URL \'' . $cas_url . '\' to validate (' . $err_msg . ')'); $err_code = PHPCAS_SERVICE_PT_NO_SERVER_RESPONSE; $err_msg = 'could not retrieve PT (no response from the CAS server)'; phpCAS::traceEnd(false); return false; } $bad_response = false; if (!$bad_response) { // read the response of the CAS server into a DOM object if (!($dom = @domxml_open_mem($cas_response))) { phpCAS::trace('domxml_open_mem() failed'); // read failed $bad_response = true; } } if (!$bad_response) { // read the root node of the XML tree if (!($root = $dom->document_element())) { phpCAS::trace('document_element() failed'); // read failed $bad_response = true; } } if (!$bad_response) { // insure that tag name is 'serviceResponse' if ($root->node_name() != 'serviceResponse') { phpCAS::trace('node_name() failed'); // bad root node $bad_response = true; } } if (!$bad_response) { // look for a proxySuccess tag if (sizeof($arr = $root->get_elements_by_tagname("proxySuccess")) != 0) { // authentication succeded, look for a proxyTicket tag if (sizeof($arr = $root->get_elements_by_tagname("proxyTicket")) != 0) { $err_code = PHPCAS_SERVICE_OK; $err_msg = ''; phpCAS::trace('original PT: ' . trim($arr[0]->get_content())); $pt = trim($arr[0]->get_content()); phpCAS::traceEnd($pt); return $pt; } else { phpCAS::trace(' was found, but not '); } } // look for a proxyFailure tag else { if (sizeof($arr = $root->get_elements_by_tagname("proxyFailure")) != 0) { // authentication failed, extract the error $err_code = PHPCAS_SERVICE_PT_FAILURE; $err_msg = 'PT retrieving failed (code=`' . $arr[0]->get_attribute('code') . '\', message=`' . trim($arr[0]->get_content()) . '\')'; phpCAS::traceEnd(false); return false; } else { phpCAS::trace('neither nor found'); } } } // at this step, we are sure that the response of the CAS server was ill-formed $err_code = PHPCAS_SERVICE_PT_BAD_SERVER_RESPONSE; $err_msg = 'Invalid response from the CAS server (response=`' . $cas_response . '\')'; phpCAS::traceEnd(false); return false; } // ######################################################################## // ACCESS TO EXTERNAL SERVICES // ######################################################################## /** * This method is used to acces a remote URL. * * @param $url the URL to access. * @param $cookies an array containing cookies strings such as 'name=val' * @param $headers an array containing the HTTP header lines of the response * (an empty array on failure). * @param $body the body of the response, as a string (empty on failure). * @param $err_msg an error message, filled on failure. * * @return TRUE on success, FALSE otherwise (in this later case, $err_msg * contains an error message). * * @private */ function readURL($url, $cookies, &$headers, &$body, &$err_msg) { phpCAS::traceBegin(); $headers = ''; $body = ''; $err_msg = ''; $res = true; // initialize the CURL session $ch = curl_init($url); if (version_compare(PHP_VERSION, '5.1.3', '>=')) { //only avaible in php5 curl_setopt_array($ch, $this->_curl_options); } else { foreach ($this->_curl_options as $key => $value) { curl_setopt($ch, $key, $value); } } if ($this->_cas_server_cert == '' && $this->_cas_server_ca_cert == '' && !$this->_no_cas_server_validation) { phpCAS::error('one of the methods phpCAS::setCasServerCert(), phpCAS::setCasServerCACert() or phpCAS::setNoCasServerValidation() must be called.'); } if ($this->_cas_server_cert != '' && $this->_cas_server_ca_cert != '') { // This branch added by IDMS. Seems phpCAS implementor got a bit confused about the curl options CURLOPT_SSLCERT and CURLOPT_CAINFO curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1); curl_setopt($ch, CURLOPT_SSLCERT, $this->_cas_server_cert); curl_setopt($ch, CURLOPT_CAINFO, $this->_cas_server_ca_cert); curl_setopt($ch, CURLOPT_VERBOSE, '1'); phpCAS::trace('CURL: Set all required opts for mutual authentication ------'); } else { if ($this->_cas_server_cert != '') { curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1); curl_setopt($ch, CURLOPT_SSLCERT, $this->_cas_server_cert); } else { if ($this->_cas_server_ca_cert != '') { curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1); curl_setopt($ch, CURLOPT_CAINFO, $this->_cas_server_ca_cert); } else { curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); } } } // return the CURL output into a variable curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); // get the HTTP header with a callback $this->_curl_headers = array(); // empty the headers array curl_setopt($ch, CURLOPT_HEADERFUNCTION, array($this, '_curl_read_headers')); // add cookies headers if (is_array($cookies)) { curl_setopt($ch, CURLOPT_COOKIE, implode(';', $cookies)); } // add extra stuff if SAML if ($this->hasSA()) { $more_headers = array( "soapaction: http://www.oasis-open.org/committees/security", "cache-control: no-cache", "pragma: no-cache", "accept: text/xml", "connection: keep-alive", "content-type: text/xml" ); curl_setopt($ch, CURLOPT_HTTPHEADER, $more_headers); curl_setopt($ch, CURLOPT_POST, 1); $data = $this->buildSAMLPayload(); //phpCAS::trace('SAML Payload: '.print_r($data, TRUE)); curl_setopt($ch, CURLOPT_POSTFIELDS, $data); } // perform the query $buf = curl_exec($ch); //phpCAS::trace('CURL: Call completed. Response body is: \''.$buf.'\''); if ($buf === false) { phpCAS::trace('curl_exec() failed'); $err_msg = 'CURL error #' . curl_errno($ch) . ': ' . curl_error($ch); //phpCAS::trace('curl error: '.$err_msg); // close the CURL session curl_close($ch); $res = false; } else { // close the CURL session curl_close($ch); $headers = $this->_curl_headers; $body = $buf; } phpCAS::traceEnd($res); return $res; } /** * This method is used to build the SAML POST body sent to /samlValidate URL. * * @return the SOAP-encased SAMLP artifact (the ticket). * * @private */ function buildSAMLPayload() { phpCAS::traceBegin(); //get the ticket $sa = $this->getSA(); //phpCAS::trace("SA: ".$sa); $body = SAML_SOAP_ENV . SAML_SOAP_BODY . SAMLP_REQUEST . SAML_ASSERTION_ARTIFACT . $sa . SAML_ASSERTION_ARTIFACT_CLOSE . SAMLP_REQUEST_CLOSE . SAML_SOAP_BODY_CLOSE . SAML_SOAP_ENV_CLOSE; phpCAS::traceEnd($body); return ($body); } /** * This method is the callback used by readURL method to request HTTP headers. */ var $_curl_headers = array(); function _curl_read_headers($ch, $header) { $this->_curl_headers[] = $header; return strlen($header); } /** * This method is used to access an HTTP[S] service. * * @param $url the service to access. * @param $err_code an error code Possible values are PHPCAS_SERVICE_OK (on * success), PHPCAS_SERVICE_PT_NO_SERVER_RESPONSE, PHPCAS_SERVICE_PT_BAD_SERVER_RESPONSE, * PHPCAS_SERVICE_PT_FAILURE, PHPCAS_SERVICE_NOT AVAILABLE. * @param $output the output of the service (also used to give an error * message on failure). * * @return TRUE on success, FALSE otherwise (in this later case, $err_code * gives the reason why it failed and $output contains an error message). * * @public */ function serviceWeb($url, &$err_code, &$output) { phpCAS::traceBegin(); // at first retrieve a PT $pt = $this->retrievePT($url, $err_code, $output); $res = true; // test if PT was retrieved correctly if (!$pt) { // note: $err_code and $err_msg are filled by CASClient::retrievePT() phpCAS::trace('PT was not retrieved correctly'); $res = false; } else { // add cookies if necessary if (is_array($_SESSION['phpCAS']['services'][$url]['cookies'])) { foreach ($_SESSION['phpCAS']['services'][$url]['cookies'] as $name => $val) { $cookies[] = $name . '=' . $val; } } // build the URL including the PT if (strstr($url, '?') === false) { $service_url = $url . '?ticket=' . $pt; } else { $service_url = $url . '&ticket=' . $pt; } phpCAS::trace('reading URL`' . $service_url . '\''); if (!$this->readURL($service_url, $cookies, $headers, $output, $err_msg)) { phpCAS::trace('could not read URL`' . $service_url . '\''); $err_code = PHPCAS_SERVICE_NOT_AVAILABLE; // give an error message $output = sprintf($this->getString(CAS_STR_SERVICE_UNAVAILABLE), $service_url, $err_msg); $res = false; } else { // URL has been fetched, extract the cookies phpCAS::trace('URL`' . $service_url . '\' has been read, storing cookies:'); foreach ($headers as $header) { // test if the header is a cookie if (preg_match('/^Set-Cookie:/', $header)) { // the header is a cookie, remove the beginning $header_val = preg_replace('/^Set-Cookie: */', '', $header); // extract interesting information $name_val = strtok($header_val, '; '); // extract the name and the value of the cookie $cookie_name = strtok($name_val, '='); $cookie_val = strtok('='); // store the cookie $_SESSION['phpCAS']['services'][$url]['cookies'][$cookie_name] = $cookie_val; phpCAS::trace($cookie_name . ' -> ' . $cookie_val); } } } } phpCAS::traceEnd($res); return $res; } /** * This method is used to access an IMAP/POP3/NNTP service. * * @param $url a string giving the URL of the service, including the mailing box * for IMAP URLs, as accepted by imap_open(). * @param $service a string giving for CAS retrieve Proxy ticket * @param $flags options given to imap_open(). * @param $err_code an error code Possible values are PHPCAS_SERVICE_OK (on * success), PHPCAS_SERVICE_PT_NO_SERVER_RESPONSE, PHPCAS_SERVICE_PT_BAD_SERVER_RESPONSE, * PHPCAS_SERVICE_PT_FAILURE, PHPCAS_SERVICE_NOT AVAILABLE. * @param $err_msg an error message on failure * @param $pt the Proxy Ticket (PT) retrieved from the CAS server to access the URL * on success, FALSE on error). * * @return an IMAP stream on success, FALSE otherwise (in this later case, $err_code * gives the reason why it failed and $err_msg contains an error message). * * @public */ function serviceMail($url, $service, $flags, &$err_code, &$err_msg, &$pt) { phpCAS::traceBegin(); // at first retrieve a PT $pt = $this->retrievePT($service, $err_code, $output); $stream = false; // test if PT was retrieved correctly if (!$pt) { // note: $err_code and $err_msg are filled by CASClient::retrievePT() phpCAS::trace('PT was not retrieved correctly'); } else { phpCAS::trace('opening IMAP URL `' . $url . '\'...'); $stream = @imap_open($url, $this->getUser(), $pt, $flags); if (!$stream) { phpCAS::trace('could not open URL'); $err_code = PHPCAS_SERVICE_NOT_AVAILABLE; // give an error message $err_msg = sprintf($this->getString(CAS_STR_SERVICE_UNAVAILABLE), $service_url, var_export(imap_errors(), true)); $pt = false; $stream = false; } else { phpCAS::trace('ok'); } } phpCAS::traceEnd($stream); return $stream; } /** @} */ // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX PROXIED CLIENT FEATURES (CAS 2.0) XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // ######################################################################## // PT // ######################################################################## /** * @addtogroup internalProxied * @{ */ /** * the Proxy Ticket provided in the URL of the request if present * (empty otherwise). Written by CASClient::CASClient(), read by * CASClient::getPT() and CASClient::hasPGT(). * * @hideinitializer * @private */ var $_pt = ''; /** * This method returns the Proxy Ticket provided in the URL of the request. * @return The proxy ticket. * @private */ function getPT() { // return 'ST'.substr($this->_pt, 2); return $this->_pt; } /** * This method stores the Proxy Ticket. * @param $pt The Proxy Ticket. * @private */ function setPT($pt) { $this->_pt = $pt; } /** * This method tells if a Proxy Ticket was stored. * @return TRUE if a Proxy Ticket has been stored. * @private */ function hasPT() { return !empty($this->_pt); } /** * This method returns the SAML Ticket provided in the URL of the request. * @return The SAML ticket. * @private */ function getSA() { return 'ST' . substr($this->_sa, 2); } /** * This method stores the SAML Ticket. * @param $sa The SAML Ticket. * @private */ function setSA($sa) { $this->_sa = $sa; } /** * This method tells if a SAML Ticket was stored. * @return TRUE if a SAML Ticket has been stored. * @private */ function hasSA() { return !empty($this->_sa); } /** @} */ // ######################################################################## // PT VALIDATION // ######################################################################## /** * @addtogroup internalProxied * @{ */ /** * This method is used to validate a ST or PT; halt on failure * Used for all CAS 2.0 validations * @return bool TRUE when successfull, halt otherwise by calling CASClient::authError(). * * @private */ function validatePT(&$validate_url, &$text_response, &$tree_response) { phpCAS::traceBegin(); // build the URL to validate the ticket $validate_url = $this->getServerProxyValidateURL() . '&ticket=' . $this->getPT(); if ($this->isProxy()) { // pass the callback url for CAS proxies $validate_url .= '&pgtUrl=' . $this->getCallbackURL(); } // open and read the URL if (!$this->readURL($validate_url, ''/*cookies*/, $headers, $text_response, $err_msg)) { phpCAS::trace('could not open URL \'' . $validate_url . '\' to validate (' . $err_msg . ')'); $this->authError('PT not validated', $validate_url, true/*$no_response*/); } // read the response of the CAS server into a DOM object if (!($dom = domxml_open_mem($text_response))) { // read failed $this->authError('PT not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // read the root node of the XML tree if (!($tree_response = $dom->document_element())) { // read failed $this->authError('PT not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } // insure that tag name is 'serviceResponse' if ($tree_response->node_name() != 'serviceResponse') { // bad root node $this->authError('PT not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } if (sizeof($arr = $tree_response->get_elements_by_tagname("authenticationSuccess")) != 0) { // authentication succeded, extract the user name if (sizeof($arr = $tree_response->get_elements_by_tagname("user")) == 0) { // no user specified => error $this->authError('PT not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } $this->setUser(trim($arr[0]->get_content())); } else { if (sizeof($arr = $tree_response->get_elements_by_tagname("authenticationFailure")) != 0) { // authentication succeded, extract the error code and message $this->authError('PT not validated', $validate_url, false/*$no_response*/, false/*$bad_response*/, $text_response, $arr[0]->get_attribute('code')/*$err_code*/, trim($arr[0]->get_content())/*$err_msg*/); } else { $this->authError('PT not validated', $validate_url, false/*$no_response*/, true/*$bad_response*/, $text_response); } } // at this step, PT has been validated and $this->_user has been set, phpCAS::traceEnd(true); return true; } /** @} */ // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX // XX XX // XX MISC XX // XX XX // XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX /** * @addtogroup internalMisc * @{ */ // ######################################################################## // URL // ######################################################################## /** * the URL of the current request (without any ticket CGI parameter). Written * and read by CASClient::getURL(). * * @hideinitializer * @private */ var $_url = ''; /** * This method returns the URL of the current request (without any ticket * CGI parameter). * * @return The URL * * @private */ function getURL() { phpCAS::traceBegin(); // the URL is built when needed only if (empty($this->_url)) { $final_uri = ''; // remove the ticket if present in the URL $final_uri = ($this->isHttps()) ? 'https' : 'http'; $final_uri .= '://'; /* replaced by Julien Marchal - v0.4.6 * $this->_url .= $_SERVER['SERVER_NAME']; */ if (empty($_SERVER['HTTP_X_FORWARDED_SERVER'])) { /* replaced by teedog - v0.4.12 * $this->_url .= $_SERVER['SERVER_NAME']; */ if (empty($_SERVER['SERVER_NAME'])) { $server_name = $_SERVER['HTTP_HOST']; } else { $server_name = $_SERVER['SERVER_NAME']; } } else { $server_name = $_SERVER['HTTP_X_FORWARDED_SERVER']; } $final_uri .= $server_name; if (!strpos($server_name, ':')) { if (($this->isHttps() && $_SERVER['SERVER_PORT'] != 443) || (!$this->isHttps() && $_SERVER['SERVER_PORT'] != 80) ) { $final_uri .= ':'; $final_uri .= $_SERVER['SERVER_PORT']; } } $request_uri = explode('?', $_SERVER['REQUEST_URI'], 2); $final_uri .= $request_uri[0]; if (isset($request_uri[1]) && $request_uri[1]) { $query_string = $this->removeParameterFromQueryString('ticket', $request_uri[1]); // If the query string still has anything left, append it to the final URI if ($query_string !== '') { $final_uri .= "?$query_string"; } } phpCAS::trace("Final URI: $final_uri"); $this->setURL($final_uri); } phpCAS::traceEnd($this->_url); return $this->_url; } /** * Removes a parameter from a query string * * @param string $parameterName * @param string $queryString * @return string * * @link http://stackoverflow.com/questions/1842681/regular-expression-to-remove-one-parameter-from-query-string */ function removeParameterFromQueryString($parameterName, $queryString) { $parameterName = preg_quote($parameterName); return preg_replace("/&$parameterName(=[^&]*)?|^$parameterName(=[^&]*)?&?/", '', $queryString); } /** * This method sets the URL of the current request * * @param $url url to set for service * * @private */ function setURL($url) { $this->_url = $url; } // ######################################################################## // AUTHENTICATION ERROR HANDLING // ######################################################################## /** * This method is used to print the HTML output when the user was not authenticated. * * @param $failure the failure that occured * @param $cas_url the URL the CAS server was asked for * @param $no_response the response from the CAS server (other * parameters are ignored if TRUE) * @param $bad_response bad response from the CAS server ($err_code * and $err_msg ignored if TRUE) * @param $cas_response the response of the CAS server * @param $err_code the error code given by the CAS server * @param $err_msg the error message given by the CAS server * * @private */ function authError( $failure, $cas_url, $no_response, $bad_response = '', $cas_response = '', $err_code = '', $err_msg = '' ) { phpCAS::traceBegin(); $this->printHTMLHeader($this->getString(CAS_STR_AUTHENTICATION_FAILED)); printf($this->getString(CAS_STR_YOU_WERE_NOT_AUTHENTICATED), htmlentities($this->getURL()), $_SERVER['SERVER_ADMIN']); phpCAS::trace('CAS URL: ' . $cas_url); phpCAS::trace('Authentication failure: ' . $failure); if ($no_response) { phpCAS::trace('Reason: no response from the CAS server'); } else { if ($bad_response) { phpCAS::trace('Reason: bad response from the CAS server'); } else { switch ($this->getServerVersion()) { case CAS_VERSION_1_0: phpCAS::trace('Reason: CAS error'); break; case CAS_VERSION_2_0: if (empty($err_code)) { phpCAS::trace('Reason: no CAS error'); } else { phpCAS::trace('Reason: [' . $err_code . '] CAS error: ' . $err_msg); } break; } } phpCAS::trace('CAS response: ' . $cas_response); } $this->printHTMLFooter(); phpCAS::traceExit(); exit(); } /** @} */ }