src/Jwt/Jwt.php - main - githubmirror/ydb-php-sdk

src/Jwt/Jwt.php
147 строк3 KB
Илья
Move decodeHeaderAndPayload function to Jwt
12 сен 2023, 19:11
12 сен 2023, 19:1142eabb4
<?php

namespace YdbPlatform\Ydb\Jwt;

use DateTimeInterface;

use phpseclib\Crypt\RSA as LegacyRSA;
use phpseclib3\Crypt\RSA;
use phpseclib3\Crypt\PublicKeyLoader;

class Jwt
{
    /**
     * @var array
     */
	protected $header = [
		'typ' => 'JWT',
		'alg' => 'PS256',
	];

    /**
     * @var array
     */
	protected $payload = [];

    /**
     * @var string
     */
	protected $privateKey;

    /**
     * @param string $privateKey
     * @param string $keyId
     */
	public function __construct($privateKey, $keyId)
	{
		$this->privateKey = $privateKey;
		$this->header['kid'] = $keyId;
	}

    /**
     * @param string $value
     * @return $this
     */
	public function issuedBy($value)
	{
		$this->payload['iss'] = $value;
		return $this;
	}

    /**
     * @param DateTimeInterface $value
     * @return $this
     */
	public function issuedAt(DateTimeInterface $value)
	{
		$this->payload['iat'] = $value->getTimestamp();
		return $this;
	}

    /**
     * @param DateTimeInterface $value
     * @return $this
     */
	public function expiresAt(DateTimeInterface $value)
	{
		$this->payload['exp'] = $value->getTimestamp();
		return $this;
	}

    /**
     * @param string $value
     * @return $this
     */
	public function permittedFor($value)
	{
		$this->payload['aud'] = $value;
		return $this;
	}

    /**
     * @return string
     */
	public function getToken()
	{
        $segments = [];

        $segments[] = $this->urlEncode($this->header);
        $segments[] = $this->urlEncode($this->payload);
        $segments[] = $this->urlEncode($this->sign(implode('.', $segments)));

        return implode('.', $segments);
	}

    /**
     * @param string
     * @return string
     */
	public function sign($input)
	{
        if (class_exists(LegacyRSA::class))
        {
            $rsa = new LegacyRSA;
            $rsa->loadKey($this->privateKey);
            $rsa->setHash('sha256');
            $rsa->setMGFHash('sha256');
            $rsa->setSignatureMode(LegacyRSA::SIGNATURE_PSS);
        }
        else
        {
            $rsa = PublicKeyLoader::load($this->privateKey);
            $rsa->withPadding(RSA::SIGNATURE_PSS);
        }

        return $rsa->sign($input);
	}

    /**
     * @param array $value
     * @return string
     */
	public function jsonEncode($value)
	{
		return json_encode($value, JSON_UNESCAPED_SLASHES);
	}

    /**
     * @param string|array $value
     * @return string
     */
	public function urlEncode($value)
    {
    	if (is_array($value))
    	{
    		$value = $this->jsonEncode($value);
    	}
        return str_replace('=', '', strtr(base64_encode($value), '+/', '-_'));
    }

    public static function decodeHeaderAndPayload(string $jwtToken) : array {
        $paths = explode(".", $jwtToken);
        $result = [];
        $result["header"] = json_decode(base64_decode($paths[0]), true);
        $result["payload"] = json_decode(base64_decode($paths[1]), true);
        return $result;
    }
}