diff options
author | yehudah <yehudah@b8457f37-d9ea-0310-8a92-e5e31aec5664> | 2019-11-25 08:22:35 +0000 |
---|---|---|
committer | yehudah <yehudah@b8457f37-d9ea-0310-8a92-e5e31aec5664> | 2019-11-25 08:22:35 +0000 |
commit | c61784411988d36d9bbd93cd3a97e773990af342 (patch) | |
tree | 924e6e9dea2ba7b1eedb14d0c4b03a38aefdf179 /Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php | |
parent | 907ce8c044159ca8da6ccce3ec5362ac61e7c142 (diff) | |
download | Post-SMTP-c61784411988d36d9bbd93cd3a97e773990af342.zip |
Adding a folder
Diffstat (limited to 'Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php')
-rw-r--r-- | Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php | 171 |
1 files changed, 171 insertions, 0 deletions
diff --git a/Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php b/Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php new file mode 100644 index 0000000..7402ba7 --- /dev/null +++ b/Postman/Postman-Auth/PostmanAbstractAuthenticationManager.php @@ -0,0 +1,171 @@ +<?php +if ( ! defined( 'ABSPATH' ) ) { + exit; // Exit if accessed directly +} +if (! class_exists ( "PostmanAbstractAuthenticationManager" )) { + + require_once 'PostmanAuthenticationManager.php'; + + /** + */ + abstract class PostmanAbstractAuthenticationManager implements PostmanAuthenticationManager { + + // constants + const APPROVAL_PROMPT = 'force'; + const ACCESS_TYPE = 'offline'; + const ACCESS_TOKEN = 'access_token'; + const REFRESH_TOKEN = 'refresh_token'; + const EXPIRES = 'expires_in'; + + // the oauth authorization options + private $clientId; + private $clientSecret; + private $authorizationToken; + private $callbackUri; + private $logger; + + /** + * Constructor + */ + public function __construct(PostmanLogger $logger, $clientId, $clientSecret, PostmanOAuthToken $authorizationToken, $callbackUri) { + assert ( ! empty ( $clientId ) ); + assert ( ! empty ( $clientSecret ) ); + assert ( ! empty ( $authorizationToken ) ); + assert ( ! empty ( $callbackUri ) ); + $this->logger = $logger; + $this->clientId = $clientId; + $this->clientSecret = $clientSecret; + $this->authorizationToken = $authorizationToken; + $this->callbackUri = $callbackUri; + } + protected function getLogger() { + return $this->logger; + } + protected function getClientId() { + return $this->clientId; + } + protected function getClientSecret() { + return $this->clientSecret; + } + protected function getAuthorizationToken() { + return $this->authorizationToken; + } + + /** + * Create a state token to prevent request forgery. + * Store it in the session for later validation. + */ + public function generateRequestTransactionId() { + return $state = md5 ( rand () ); + } + + /** + */ + public function isAccessTokenExpired() { + $expireTime = ($this->authorizationToken->getExpiryTime () - self::FORCE_REFRESH_X_SECONDS_BEFORE_EXPIRE); + $tokenHasExpired = time () > $expireTime; + $this->logger->debug ( 'Access Token Expiry Time is ' . $expireTime . ', expires_in=' . ($expireTime - time ()) . ', expired=' . ($tokenHasExpired ? 'yes' : 'no') ); + return $tokenHasExpired; + } + + /** + * Decoded the received token + * This code is identical for Google and Hotmail + * + * @param mixed $response + * @throws Exception + */ + protected function processResponse($response) { + $authToken = json_decode ( stripslashes ( $response ) ); + if ($authToken === NULL) { + $this->getLogger ()->error ( $response ); + throw new Exception ( $response ); + } else if (isset ( $authToken->{'error'} )) { + if (isset ( $authToken->{'error_description'} )) { + $this->getLogger ()->error ( $authToken->{'error'} . ' processing response: ' . $authToken->{'error_description'} ); + throw new Exception ( $authToken->{'error_description'} . '(' . $authToken->{'error'} . ')' ); + } else { + // Yahoo doesn't give descriptions + $this->getLogger ()->error ( $authToken->{'error'} . ' processing response' ); + throw new Exception ( $authToken->{'error'} ); + } + } else { + $this->getLogger ()->trace ( 'Processing response:' ); + $this->getLogger ()->trace ( $response ); + $this->decodeReceivedAuthorizationToken ( $authToken ); + } + } + + /** + * Parses the authorization token and extracts the expiry time, accessToken, + * and if this is a first-time authorization, a refresh token. + * + * This code is identical for Google and Hotmail + * + * @param mixed $client + */ + protected function decodeReceivedAuthorizationToken($newtoken) { + assert ( ! empty ( $newtoken ) ); + assert ( ! empty ( $newtoken->{self::EXPIRES} ) ); + assert ( ! empty ( $newtoken->{self::ACCESS_TOKEN} ) ); + + // update expiry time + if (empty ( $newtoken->{self::EXPIRES} )) { + throw new Exception ( '[expires_in] value is missing from the authentication token' ); + } + $newExpiryTime = time () + $newtoken->{self::EXPIRES}; + $this->getAuthorizationToken ()->setExpiryTime ( $newExpiryTime ); + $this->getLogger ()->debug ( 'Updating Access Token Expiry Time ' ); + + // update acccess token + if (empty ( $newtoken->{self::ACCESS_TOKEN} )) { + throw new Exception ( '[access_token] value is missing from the authentication token' ); + } + $newAccessToken = $newtoken->{self::ACCESS_TOKEN}; + $this->getAuthorizationToken ()->setAccessToken ( $newAccessToken ); + $this->getLogger ()->debug ( 'Updating Access Token' ); + + // update refresh token, if there is one + if (isset ( $newtoken->{self::REFRESH_TOKEN} )) { + $newRefreshToken = $newtoken->{self::REFRESH_TOKEN}; + $this->getAuthorizationToken ()->setRefreshToken ( $newRefreshToken ); + $this->getLogger ()->debug ( 'Updating Refresh Token ' ); + } + } + + /** + * Given an OAuth provider-specific URL and redirectUri, + * issue an HttpRequest to refresh the access token + * + * This code is identical for Google and Hotmail + */ + public function refreshToken() { + $this->getLogger ()->debug ( 'Refreshing Token' ); + $refreshUrl = $this->getTokenUrl (); + $callbackUrl = $this->getCallbackUri (); + assert ( ! empty ( $refreshUrl ) ); + assert ( ! empty ( $callbackUrl ) ); + // the format of the URL is + // client_id=CLIENT_ID&client_secret=CLIENT_SECRET&redirect_uri=REDIRECT_URI&grant_type=refresh_token&refresh_token=REFRESH_TOKEN + $postvals = array ( + 'client_id' => $this->getClientId (), + 'client_secret' => $this->getClientSecret (), + 'redirect_uri' => $callbackUrl, + 'grant_type' => 'refresh_token', + 'refresh_token' => $this->getAuthorizationToken ()->getRefreshToken () + ); + // example request string + // client_id=0000000603DB0F&redirect_uri=http%3A%2F%2Fwww.contoso.com%2Fcallback.php&client_secret=LWILlT555GicSrIATma5qgyBXebRI&refresh_token=*LA9...//refresh token string shortened for example//...xRoX&grant_type=refresh_token + $response = PostmanUtils::remotePostGetBodyOnly ( $refreshUrl, $postvals ); + $this->processResponse ( $response ); + } + /** + * (non-PHPdoc) + * + * @see PostmanAuthenticationManager::getCallbackUri() + */ + public function getCallbackUri() { + return $this->callbackUri; + } + } +} |