refactor: Alchemy API v3 migration

app/Console/Commands/LiveDumpNfts.php

@@ -43,30 +43,28 @@ class LiveDumpNfts extends Command
     /**
      * @var array<mixed>
      */
-    protected $requiredAttributes = [
-        'title',
+    protected array $requiredAttributes = [
+        'name',
         'description',
+        'tokenId',
         'contract' => [
             'address',
-        ],
-        'id' => [
-            'tokenId',
-        ],
-        'media' => [
-            '0' => ['thumbnail', 'gateway', 'raw'],
-        ],
-        'contractMetadata' => [
             'symbol',
             'name',
             'totalSupply',
-            'openSea' => ['twitterUsername', 'discordUrl', 'floorPrice', 'collectionName', 'imageUrl', 'externalUrl', 'description'],
+            'openSeaMetadata' => ['twitterUsername', 'discordUrl', 'floorPrice', 'collectionName', 'imageUrl', 'externalUrl', 'description'],
             'deployedBlockNumber',
         ],
-        'metadata' => [
-            'image',
-            'attributes',
-            'properties',
-            'external_url',
+        'image' => [
+            'thumbnailUrl', 'cachedUrl', 'originalUrl',
+        ],
+        'raw' => [
+            'metadata' => [
+                'image',
+                'attributes',
+                'properties',
+                'external_url',
+            ],
         ],
     ];
 
@@ -188,10 +186,10 @@ private function getTopCollections(Chain $chain, int $limit = 25): IlluminateCol
     private function removeEncodedAttributes(array $nft): array
     {
         $potentiallyEncodedAttributes = [
-            'media.0.thumbnail',
-            'media.0.gateway',
-            'media.0.raw',
-            'metadata.image',
+            'image.thumbnailUrl',
+            'image.cachedUrl',
+            'image.originalUrl',
+            'raw.metadata.image',
         ];
 
         foreach ($potentiallyEncodedAttributes as $attribute) {
@@ -291,7 +289,7 @@ private function getTokenCursorForChunk(int $chunk, Chain $chain, string $contra
 
         $nftChunk = json_decode($file, true);
 
-        return Arr::get($nftChunk, 'nextToken');
+        return Arr::get($nftChunk, 'pageKey');
     }
 
     private function getCollectionTraitsAndPersist(Chain $chain, string $address): void

tests/App/Console/Commands/LiveDumpNftsTest.php

@@ -10,6 +10,7 @@
 use App\Support\Facades\Mnemonic;
 use Illuminate\Console\Command;
 use Illuminate\Http\Client\Request;
+use Illuminate\Support\Arr;
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Facades\Storage;
 use Illuminate\Support\Str;
@@ -19,7 +20,7 @@
         if ($request->method() == 'GET') {
             $path = $request->toPsrRequest()->getUri()->getPath();
             if (Str::contains($path, 'getNFTsForCollection')) {
-                return Http::response(fixtureData('alchemy.get_nfts_for_collection_last_page'), 200);
+                return Http::response(fixtureData('alchemy.get_nfts_for_contract'), 200);
             }
         }
 
@@ -101,6 +102,9 @@
     $this->artisan('nfts:live-dump --collection-index=0 --chain-id=1');
 
     $liveDumps->each(fn ($liveDump) => expect($this->fakeFileSystem->exists($liveDump))->toBeTrue());
+
+    $dump = json_decode($this->fakeFileSystem->get($liveDumps[0]));
+    expect(Arr::get($dump, 'raw.metadata.image'))->toBe(null);
 });
 
 it('should run only in non-production environments', function () {
@@ -131,10 +135,10 @@
         ->assertExitCode(Command::INVALID);
 });
 
-it('should continue continue from the given chunk', function () {
+it('should continue from the given chunk', function () {
     $this->fakeFileSystem->put(
         'collection-nfts/eth_0x4e1f41613c9084fdb9e34e11fae9412427480e56/nft-chunks/1.json',
-        json_encode(fixtureData('alchemy.get_nfts_for_collection'))
+        json_encode(fixtureData('alchemy.get_nfts_for_contract'))
     );
 
     $this->artisan('nfts:live-dump --collection-index=0 --chain-id=1 --start-chunk-index=1');

tests/App/Console/Commands/LiveDumpWalletsTest.php

@@ -18,8 +18,8 @@
     Alchemy::fake(function (Request $request) {
         if ($request->method() == 'GET') {
             $path = $request->toPsrRequest()->getUri()->getPath();
-            if (Str::endsWith($path, 'getNFTs')) {
-                return Http::response(fixtureData('alchemy.nfts'), 200);
+            if (Str::endsWith($path, 'getNFTsForOwner')) {
+                return Http::response(fixtureData('alchemy.nfts_for_owner_2'), 200);
             }
         }
 

tests/App/Http/Client/Alchemy/AlchemyPendingRequestTest.php

@@ -49,8 +49,8 @@
 
 it('should handle arrays in NFT descriptions', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_description'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
@@ -61,8 +61,8 @@
 
 it('should increment default size for banner image if it is not null in parseNft', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_description_with_banner'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
@@ -88,7 +88,7 @@
     $nfts->push($nft);
 
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::response(fixtureData('alchemy.nft_batch_metadata'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::response(fixtureData('alchemy.nft_batch_metadata_2'), 200),
     ]);
 
     $fetchedNfts = Alchemy::nftMetadataBatch($nfts, $network);
@@ -98,8 +98,8 @@
 
 it('should add a flag in case of responses with errors', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_with_error'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
@@ -111,28 +111,28 @@
 
 it('should not add a flag in case of valid responses', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_valid'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
     $network = Network::polygon();
 
     $collection = Alchemy::getWalletNfts($wallet, $network);
-    expect($collection->nfts[0]->hasError)->not->toBeTrue();
+    expect($collection->nfts[1]->hasError)->not->toBeTrue();
 });
 
 it('should not filter nfts with errors if the flag is set as true', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_with_error'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
     $network = Network::polygon();
 
     $collection = Alchemy::getWalletNfts($wallet, $network);
-    expect($collection->nfts)->toHaveCount(1);
+    expect($collection->nfts)->toHaveCount(4);
 });
 
 it('should filter nfts with errors by default', function () {
@@ -150,18 +150,18 @@
     $nfts->push($nft);
 
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::response(fixtureData('alchemy.nft_batch_metadata_with_error'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::response(fixtureData('alchemy.nft_batch_metadata_2'), 200),
     ]);
 
     $fetchedNfts = Alchemy::nftMetadataBatch($nfts, $network);
 
-    expect($fetchedNfts->nfts)->toHaveCount(0);
+    expect($fetchedNfts->nfts)->toHaveCount(1);
 });
 
 it('should return error field with METADATA_OUTDATED if parent metadata object is empty', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_with_error_and_empty_metadata_object'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
@@ -175,45 +175,45 @@
 
 it('should return error field with METADATA_OUTDATED if metadata.metadata object is empty', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_with_error_and_empty_metadata_metadata_object'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
     $network = Network::polygon();
 
     $collection = Alchemy::getWalletNfts($wallet, $network);
 
-    expect($collection->nfts[0]->hasError)->toBetrue();
-    expect($collection->nfts[0]->info)->toBe(NftInfo::MetadataOutdated->value);
+    expect($collection->nfts[2]->hasError)->toBetrue();
+    expect($collection->nfts[2]->info)->toBe(NftInfo::MetadataOutdated->value);
 });
 
 it('should ignore arrays in trait values', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_collection_array_traits'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
     $network = Network::polygon();
 
     $collection = Alchemy::getWalletNfts($wallet, $network);
 
-    expect($collection->nfts[0]->traits[1])->toContain('Tails');
+    expect($collection->nfts[1]->traits[1])->toContain('Kick Kick Snare');
 });
 
 it('should handle unexpected trait values', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*' => Http::sequence()
-            ->push(fixtureData('alchemy.nfts_array_unexpected_traits'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*' => Http::sequence()
+            ->push(fixtureData('alchemy.nfts_for_owner'), 200),
     ]);
 
     $wallet = Wallet::factory()->create();
     $network = Network::polygon();
 
     $collection = Alchemy::getWalletNfts($wallet, $network);
 
-    expect(count($collection->nfts[0]->traits))->toBe(1);
+    expect(count($collection->nfts[3]->traits))->toBe(1);
 });
 
 it('should fetch spam contracts', function () {

tests/App/Jobs/FetchCollectionBannerBatchTest.php

@@ -11,7 +11,7 @@
 
 it('should fetch nft collection banner', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract-metadata-batch'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract_metadata_batch'), 200),
     ]);
 
     $now = Carbon::now();
@@ -44,7 +44,7 @@
 
 it('should skip updating banner if it is null', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract-metadata-batch'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract_metadata_batch'), 200),
     ]);
 
     $network = Network::polygon();

tests/App/Jobs/FetchCollectionMetadataJobTest.php

@@ -11,7 +11,7 @@
 
 it('should update nft collection metadata', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract-metadata-batch'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract_metadata_batch'), 200),
     ]);
 
     $now = Carbon::now();
@@ -21,7 +21,7 @@
 
     /** @var Collection $collection */
     $collection = Collection::factory()->create([
-        'address' => '0xe785e82358879f061bc3dcac6f0444462d4b5330',
+        'address' => '0xe785E82358879F061BC3dcAC6f0444462D4b5330',
         'network_id' => $network->id,
         'supply' => 8000,
         'minted_block' => 12907765,
@@ -43,19 +43,20 @@
         ->and($collection->description)->toBe('World of Women is a collection of 10,000 NFTs.')
         ->and($updatedAt->timestamp)->toBe($now->timestamp)
         ->and($collection->image())->toBe('image-url')
+        ->and($collection->openSeaSlug())->toBe('world-of-women-nft')
         ->and($collection->banner())->toBe('https://i.seadn.io/gae/GHhptRLebBOWOy8kfXpYCVqsqdes-1-6I_jbuRnGTHHW6TD63CtciH75Dotfu2u8v6EmkWt-tjhkFRVLxRUwgMfKqqy5W24AolJayeo?w=500&auto=format');
 });
 
 it('should skip updating column if metadata is null', function () {
     Alchemy::fake([
-        'https://polygon-mainnet.g.alchemy.com/nft/v2/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract-metadata-batch'), 200),
+        'https://polygon-mainnet.g.alchemy.com/nft/v3/*/getContractMetadataBatch' => Http::response(fixtureData('alchemy.contract_metadata_batch'), 200),
     ]);
 
     $network = Network::polygon()->firstOrFail();
 
     /** @var Collection $collection */
     $collection = Collection::factory()->create([
-        'address' => '0xbc4ca0eda7647a8ab7c2061c2e118a18a936f13d',
+        'address' => '0xBC4CA0EdA7647A8aB7C2061c2E118A18a936f13D',
         'network_id' => $network->id,
         'supply' => 8000,
         'floor_price' => 80000000,