Spaces:
No application file
No application file
File size: 3,990 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 |
<?php
declare(strict_types=1);
namespace Mautic\IntegrationsBundle\Auth\Provider\ApiKey;
use GuzzleHttp\Client;
use GuzzleHttp\ClientInterface;
use GuzzleHttp\Handler\CurlHandler;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Middleware;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Psr7\Uri;
use Mautic\IntegrationsBundle\Auth\Provider\ApiKey\Credentials\HeaderCredentialsInterface;
use Mautic\IntegrationsBundle\Auth\Provider\ApiKey\Credentials\ParameterCredentialsInterface;
use Mautic\IntegrationsBundle\Auth\Provider\AuthConfigInterface;
use Mautic\IntegrationsBundle\Auth\Provider\AuthCredentialsInterface;
use Mautic\IntegrationsBundle\Auth\Provider\AuthProviderInterface;
use Mautic\IntegrationsBundle\Exception\InvalidCredentialsException;
use Mautic\IntegrationsBundle\Exception\PluginNotConfiguredException;
/**
* Factory for building HTTP clients using basic auth.
*/
class HttpFactory implements AuthProviderInterface
{
public const NAME = 'api_key';
/**
* Cache of initialized clients.
*
* @var Client[]
*/
private array $initializedClients = [];
private HeaderCredentialsInterface|ParameterCredentialsInterface|null $credentials = null;
public function getAuthType(): string
{
return self::NAME;
}
/**
* @param HeaderCredentialsInterface|ParameterCredentialsInterface $credentials
*
* @throws PluginNotConfiguredException
* @throws InvalidCredentialsException
*/
public function getClient(AuthCredentialsInterface $credentials, ?AuthConfigInterface $config = null): ClientInterface
{
if (!$this->credentialsAreValid($credentials)) {
throw new InvalidCredentialsException(sprintf('Credentials must implement either the %s or %s interfaces', HeaderCredentialsInterface::class, ParameterCredentialsInterface::class));
}
if (!$this->credentialsAreConfigured($credentials)) {
throw new PluginNotConfiguredException('API key is missing');
}
// Return cached initialized client if there is one.
if (!empty($this->initializedClients[$credentials->getKeyName()])) {
return $this->initializedClients[$credentials->getKeyName()];
}
$this->credentials = $credentials;
if ($credentials instanceof HeaderCredentialsInterface) {
$this->initializedClients[$credentials->getKeyName()] = $this->getHeaderClient();
return $this->initializedClients[$credentials->getKeyName()];
}
$this->initializedClients[$credentials->getKeyName()] = $this->getParameterClient();
return $this->initializedClients[$credentials->getKeyName()];
}
private function credentialsAreValid(AuthCredentialsInterface $credentials): bool
{
return $credentials instanceof HeaderCredentialsInterface || $credentials instanceof ParameterCredentialsInterface;
}
/**
* @param HeaderCredentialsInterface|ParameterCredentialsInterface|AuthCredentialsInterface $credentials
*/
private function credentialsAreConfigured(AuthCredentialsInterface $credentials): bool
{
return !empty($credentials->getApiKey());
}
private function getHeaderClient(): ClientInterface
{
return new Client(
[
'headers' => [$this->credentials->getKeyName() => $this->credentials->getApiKey()],
]
);
}
private function getParameterClient(): ClientInterface
{
$handler = new HandlerStack();
$handler->setHandler(new CurlHandler());
$handler->unshift(
Middleware::mapRequest(
fn (Request $request) => $request->withUri(
Uri::withQueryValue($request->getUri(), $this->credentials->getKeyName(), $this->credentials->getApiKey())
)
)
);
return new Client(
[
'handler' => $handler,
]
);
}
}
|