thibaud-lclr/ltbxd-actorle
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

Starting actors populate

Browse Source
This commit is contained in:
thibaud-leclere
2026-01-15 14:01:45 +01:00
parent be171b45b4
commit dcc47fcb65
5 changed files with 95 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/Gateway/TMDBGateway.php
View File

@@ -2,18 +2,22 @@
namespace App\Gateway;
use App\Context\TMDB\MovieCreditsContext;
use App\Context\TMDB\MovieSearchContext;
use App\Exception\GatewayException;
use App\Model\TMDB\TMDBMovie;
use Symfony\Component\DependencyInjection\Attribute\Autowire;
use Symfony\Component\Serializer\SerializerInterface;
use Symfony\Contracts\Cache\CacheInterface;
use Symfony\Contracts\Cache\ItemInterface;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Contracts\HttpClient\ResponseInterface;
use function Symfony\Component\String\u;
class TMDBGateway
{
private const string SEARCH_URI = '/search/movie';
private const string MOVIE_CREDITS_URI = '/movie/{id}/credits';
public function __construct(
private readonly HttpClientInterface $client,
@@ -25,24 +29,50 @@ class TMDBGateway
) {
}
/**
* @throws GatewayException
*/
public function searchMovie(string $movieName): ?TMDBMovie
{
$url = $this->host.self::SEARCH_URI.'?'.http_build_query(['query' => $movieName]);
try {
$response = $this->client->request('GET', $url, ['headers' => $this->getHeaders()]);
$result = $response->getContent();
$searchContext = $this->serializer->deserialize($result, MovieSearchContext::class, 'json');
if (empty($searchResult = $searchContext->getResults())) {
return null;
}
return reset($searchResult);
} catch (\Throwable) {
$searchContext = $this->fetchSerialized('GET', $url, MovieSearchContext::class);
if (empty($searchResult = $searchContext->getResults())) {
return null;
}
return reset($searchResult);
}
/**
* @throws GatewayException
*/
public function getMovieCredits(int $movieId): ?MovieCreditsContext
{
$url = str_replace('{id}', $movieId, $this->host.self::MOVIE_CREDITS_URI);
return $this->fetchSerialized('GET', $url, MovieCreditsContext::class);
}
/**
* @throws GatewayException
*/
private function fetch(string $method, string $url): ResponseInterface
{
try {
return $this->client->request($method, $url, ['headers' => ['Authorization' => 'Bearer '.$this->apiToken, 'accept' => 'application/json']]);
} catch (\Throwable $e) {
throw new GatewayException(self::class, $e->getMessage(), $e);
}
}
private function getHeaders(): array
/**
* @throws GatewayException
*/
private function fetchSerialized(string $method, string $url, string $class, string $type = 'json'): mixed
{
return ['Authorization' => 'Bearer '.$this->apiToken, 'accept' => 'application/json'];
$result = $this->fetch($method, $url);
try {
return $this->serializer->deserialize($result->getContent(), $class, $type);
} catch (\Throwable $e) {
throw new GatewayException(self::class, $e->getMessage(), $e);
}
}
}