Add metadata event

src/Commands/SyncMetadata.php

@@ -47,7 +47,11 @@ public function handle(): void
             'collection:id,collection_chain_id',
         ];
         foreach ($query->with($withs)->lazy(config('enjin-platform.sync_metadata.data_chunk_size')) as $attribute) {
-            SyncMetadataJob::dispatch($attribute->value_string);
+            SyncMetadataJob::dispatch(
+                $attribute->collection->collection_chain_id,
+                $attribute->token?->token_chain_id,
+                $attribute->value_string
+            );
             $progress->advance();
         }
 

src/Events/Substrate/MultiTokens/MetadataUpdated.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Enjin\Platform\Events\Substrate\MultiTokens;
+
+use Enjin\Platform\Channels\PlatformAppChannel;
+use Enjin\Platform\Events\PlatformBroadcastEvent;
+use Illuminate\Broadcasting\Channel;
+
+class MetadataUpdated extends PlatformBroadcastEvent
+{
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(string $collectionId, ?string $tokenId = null)
+    {
+        parent::__construct();
+
+        $this->broadcastData = [
+            'collectionId' => $collectionId,
+            'tokenId'      => $tokenId,
+        ];
+
+        $this->broadcastChannels = [
+            new Channel("collection;{$collectionId}"),
+            new Channel("token;{$collectionId}-{$tokenId}"),
+            new PlatformAppChannel(),
+        ];
+    }
+}

src/GraphQL/Schemas/Primary/Substrate/Mutations/RefreshMetadataMutation.php

@@ -103,7 +103,7 @@ public function resolve(
                 )
             )
             ->get()
-            ->each(fn ($attribute) => $metadataService->fetchAndCache($attribute->value_string));
+            ->each(fn ($attribute) => $metadataService->fetchAttributeWithEvent($attribute));
 
         return true;
     }

src/Jobs/SyncMetadata.php

@@ -3,9 +3,9 @@
 namespace Enjin\Platform\Jobs;
 
 use Enjin\Platform\Services\Database\MetadataService;
-use Enjin\Platform\Support\Hex;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Database\Eloquent\Model;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
@@ -22,19 +22,17 @@ class SyncMetadata implements ShouldQueue
     /**
      * Create a new job instance.
      */
-    public function __construct(protected string $url) {}
+    public function __construct(protected Model $attribute) {}
 
     /**
      * Execute the job.
      */
     public function handle(MetadataService $service): void
     {
         try {
-            $service->fetchAndCache(
-                Hex::isHexEncoded($this->url) ? Hex::safeConvertToString($this->url) : $this->url
-            );
+            $service->fetchAttributeWithEvent($this->attribute);
         } catch (Throwable $e) {
-            Log::error("Unable to sync metadata for url {$this->url}", $e->getMessage());
+            Log::error("Unable to sync metadata for url {$this->attribute->value_string}", $e->getMessage());
         }
     }
 }

src/Services/Database/MetadataService.php

@@ -3,6 +3,7 @@
 namespace Enjin\Platform\Services\Database;
 
 use Enjin\Platform\Clients\Implementations\MetadataHttpClient;
+use Enjin\Platform\Events\Substrate\MultiTokens\MetadataUpdated;
 use Enjin\Platform\Models\Laravel\Attribute;
 use Enjin\Platform\Support\Hex;
 use Illuminate\Support\Facades\Cache;
@@ -41,6 +42,20 @@ public function fetchUrl(string $url): mixed
         return $this->client->fetch($url) ?: null;
     }
 
+    public function fetchAttributeWithEvent(Attribute $attribute): mixed
+    {
+        $old = $this->getCache($url = $attribute->value_string);
+        $new = $this->fetchAndCache($url);
+        if ($old !== $new) {
+            event(new MetadataUpdated(
+                $attribute->collection->collection_chain_id,
+                $attribute->token?->token_chain_id,
+            ));
+        }
+
+        return $new;
+    }
+
     public function fetchAndCache(string $url, bool $forget = true): mixed
     {
         $url = $this->convertHexToString($url);