. */ declare(strict_types=1); namespace App\Services\InfoProviderSystem\Providers; use App\Services\InfoProviderSystem\DTOs\FileDTO; use App\Services\InfoProviderSystem\DTOs\PartDetailDTO; use App\Services\InfoProviderSystem\DTOs\PriceDTO; use App\Services\InfoProviderSystem\DTOs\PurchaseInfoDTO; use App\Services\InfoProviderSystem\DTOs\SearchResultDTO; use App\Settings\InfoProviderSystem\BuerklinSettings; use App\Settings\InfoProviderSystem\CanopySettings; use Symfony\Component\DependencyInjection\Attribute\When; use Symfony\Contracts\HttpClient\HttpClientInterface; /** * Use canopy API to retrieve infos from amazon */ class CanopyProvider implements InfoProviderInterface { public const BASE_URL = "https://rest.canopyapi.co/api"; public const SEARCH_API_URL = self::BASE_URL . "/amazon/search"; public const DETAIL_API_URL = self::BASE_URL . "/amazon/product"; public const DISTRIBUTOR_NAME = 'Amazon'; public function __construct(private readonly CanopySettings $settings, private readonly HttpClientInterface $httpClient) { } public function getProviderInfo(): array { return [ 'name' => 'Amazon (Canopy)', 'description' => 'Retrieves part infos from Amazon using the Canopy API', 'url' => 'https://canopyapi.co', 'disabled_help' => 'Set Canopy API key in the provider configuration to enable this provider', 'settings_class' => CanopySettings::class ]; } public function getProviderKey(): string { return 'canopy'; } public function isActive(): bool { return $this->settings->apiKey !== null; } private function productPageFromASIN(string $asin): string { return "https://www.amazon.{$this->settings->domain}/dp/{$asin}"; } public function searchByKeyword(string $keyword): array { $response = $this->httpClient->request('GET', self::SEARCH_API_URL, [ 'query' => [ 'domain' => $this->settings->domain, 'searchTerm' => $keyword, ], 'headers' => [ 'API-KEY' => $this->settings->apiKey, ] ]); $data = $response->toArray(); $results = $data['data']['amazonProductSearchResults']['productResults']['results'] ?? []; $out = []; foreach ($results as $result) { $out[] = new SearchResultDTO( provider_key: $this->getProviderKey(), provider_id: $result['asin'], name: $result["title"], description: "", preview_image_url: $result["mainImageUrl"] ?? null, provider_url: $this->productPageFromASIN($result['asin']), ); } return $out; } private function categoriesToCategory(array $categories): ?string { if (count($categories) === 0) { return null; } return implode(" -> ", array_map(static fn($cat) => $cat['name'], $categories)); } private function feauturesBulletsToNotes(array $featureBullets): string { $notes = "

"; foreach ($featureBullets as $bullet) { $notes .= "
• " . $bullet . "
"; } $notes .= "

"; return $notes; } private function priceToPurchaseInfo(array $price, string $asin): PurchaseInfoDTO { $priceDto = new PriceDTO(minimum_discount_amount: 1, price: (string) $price['value'], currency_iso_code: $price['currency'], includes_tax: true); return new PurchaseInfoDTO(self::DISTRIBUTOR_NAME, order_number: $asin, prices: [$priceDto], product_url: $this->productPageFromASIN($asin)); } public function getDetails(string $id): PartDetailDTO { //Check that the id is a valid ASIN (10 characters, letters and numbers) if (!preg_match('/^[A-Z0-9]{10}$/', $id)) { throw new \InvalidArgumentException("The id must be a valid ASIN (10 characters, letters and numbers)"); } $response = $this->httpClient->request('GET', self::DETAIL_API_URL, [ 'query' => [ 'asin' => $id, 'domain' => $this->settings->domain, ], 'headers' => [ 'API-KEY' => $this->settings->apiKey, ], ]); $product = $response->toArray()['data']['amazonProduct']; return new PartDetailDTO( provider_key: $this->getProviderKey(), provider_id: $product['asin'], name: $product['title'], description: '', category: $this->categoriesToCategory($product['categories']), manufacturer: $product['brand'] ?? null, preview_image_url: $product['mainImageUrl'] ?? $product['imageUrls'][0] ?? null, provider_url: $this->productPageFromASIN($product['asin']), notes: $this->feauturesBulletsToNotes($product['featureBullets'] ?? []), vendor_infos: [$this->priceToPurchaseInfo($product['price'], $product['asin'])] ); } public function getCapabilities(): array { return [ ProviderCapabilities::BASIC, ProviderCapabilities::PICTURE, ProviderCapabilities::PRICE, ]; } }