GitlabClient.php•6.48 kB
<?php
declare(strict_types=1);
namespace Butschster\ContextGenerator\Lib\GitlabClient;
use Butschster\ContextGenerator\Application\Logger\LoggerPrefix;
use Butschster\ContextGenerator\Lib\GitlabClient\Model\GitlabRepository;
use Butschster\ContextGenerator\Lib\HttpClient\Exception\HttpException;
use Butschster\ContextGenerator\Lib\HttpClient\HttpClientInterface;
use Psr\Log\LoggerInterface;
/**
 * GitLab API client implementation
 */
final class GitlabClient implements GitlabClientInterface
{
    private string $serverUrl = 'https://gitlab.com';
    private ?string $token = null;
    /**
     * Custom HTTP headers
     *
     * @var array<string, string>
     */
    private array $headers = [];
    /**
     * Create a new GitLab client
     */
    public function __construct(
        private readonly HttpClientInterface $httpClient,
        #[LoggerPrefix(prefix: 'gitlab-client')]
        private readonly ?LoggerInterface $logger = null,
    ) {}
    public function getContents(GitlabRepository $repository, string $path = ''): array
    {
        $this->logger?->debug('Getting repository contents', [
            'repository' => $repository->repository,
            'branch' => $repository->branch,
            'path' => $path,
        ]);
        // Format URL for GitLab API v4
        $url = $this->buildApiUrl("/projects/{$repository->projectId}/repository/tree", [
            'ref' => $repository->branch,
            'path' => $path,
            'recursive' => 'false',
        ]);
        $this->logger?->debug('Making GitLab API request', [
            'url' => $url,
        ]);
        $response = $this->makeApiRequest($url);
        $items = \json_decode($response, true);
        if (!\is_array($items)) {
            $errorMessage = "Failed to parse GitLab API response for path: $path";
            $this->logger?->error($errorMessage, [
                'response' => $response,
            ]);
            throw new \RuntimeException($errorMessage);
        }
        $this->logger?->debug('Got repository contents', [
            'itemCount' => \count($items),
        ]);
        return $items;
    }
    public function getFileContent(GitlabRepository $repository, string $path): string
    {
        $this->logger?->debug('Getting file content', [
            'repository' => $repository->repository,
            'branch' => $repository->branch,
            'path' => $path,
        ]);
        // Format URL for GitLab API v4
        $url = $this->buildApiUrl("/projects/{$repository->projectId}/repository/files/" . \rawurlencode($path), [
            'ref' => $repository->branch,
        ]);
        $this->logger?->debug('Making GitLab API request', [
            'url' => $url,
        ]);
        $response = $this->makeApiRequest($url);
        $data = \json_decode($response, true);
        if (!\is_array($data) || !isset($data['content'])) {
            $errorMessage = "Failed to get file content for path: $path";
            $this->logger?->error($errorMessage, [
                'response' => $response,
            ]);
            throw new \RuntimeException($errorMessage);
        }
        // GitLab returns file content as base64 encoded
        $content = \base64_decode((string) $data['content']);
        if ($content === false) {
            $errorMessage = "Failed to decode base64 content for path: $path";
            $this->logger?->error($errorMessage);
            throw new \RuntimeException($errorMessage);
        }
        $this->logger?->debug('Got file content', [
            'contentLength' => \strlen($content),
        ]);
        return $content;
    }
    public function setToken(?string $token): void
    {
        $this->logger?->debug('Setting GitLab API token', [
            'hasToken' => $token !== null,
        ]);
        $this->token = $token;
    }
    public function setServerUrl(string $serverUrl): void
    {
        $this->logger?->debug('Setting GitLab server URL', [
            'serverUrl' => $serverUrl,
        ]);
        $this->serverUrl = \rtrim($serverUrl, '/');
    }
    public function setHeaders(array $headers): void
    {
        $this->logger?->debug('Setting custom HTTP headers', [
            'headerCount' => \count($headers),
            'headers' => \array_keys($headers),
        ]);
        $this->headers = $headers;
    }
    /**
     * Build a GitLab API URL
     *
     * @param string $path API endpoint path
     * @param array<string, string> $queryParams Query parameters
     * @return string Full API URL
     */
    private function buildApiUrl(string $path, array $queryParams = []): string
    {
        $url = "{$this->serverUrl}/api/v4{$path}";
        if (!empty($queryParams)) {
            $url .= '?' . \http_build_query($queryParams);
        }
        return $url;
    }
    /**
     * Make a GET request to the GitLab API
     *
     * @param string $url API URL
     * @return string API response
     * @throws \RuntimeException If the request fails
     */
    private function makeApiRequest(string $url): string
    {
        // Prepare headers
        $headers = $this->prepareHeaders();
        try {
            $response = $this->httpClient->get($url, $headers);
            if (!$response->isSuccess()) {
                $errorMessage = "GitLab API request failed with HTTP code {$response->getStatusCode()}";
                $this->logger?->error($errorMessage, [
                    'url' => $url,
                    'statusCode' => $response->getStatusCode(),
                    'response' => $response->getBody(),
                ]);
                throw new \RuntimeException($errorMessage);
            }
            return $response->getBody();
        } catch (HttpException $e) {
            $errorMessage = "GitLab API request failed: {$e->getMessage()}";
            $this->logger?->error($errorMessage, [
                'url' => $url,
                'exception' => $e,
            ]);
            throw new \RuntimeException($errorMessage, 0, $e);
        }
    }
    /**
     * Prepare request headers for GitLab API
     *
     * @return array<string, string> Headers to send with the request
     */
    private function prepareHeaders(): array
    {
        $headers = $this->headers;
        // Add authorization header if token is set
        if ($this->token !== null) {
            $headers['PRIVATE-TOKEN'] = $this->token;
        }
        return $headers;
    }
}