einundzwanzig-verein/app/Traits/NostrFetcherTrait.php

<?php

namespace App\Traits;

use App\Models\Profile;
use swentel\nostr\Filter\Filter;
use swentel\nostr\Key\Key;
use swentel\nostr\Message\RequestMessage;
use swentel\nostr\Relay\Relay;
use swentel\nostr\Request\Request;
use swentel\nostr\Subscription\Subscription;

trait NostrFetcherTrait
{
    public function fetchProfile($npubs)
    {
        $hex = collect([]);
        foreach ($npubs as $item) {
            // check if $item is already a hex string
            if (preg_match('/^[0-9a-fA-F]+$/', $item)) {
                $hex->push([
                    'hex' => $item,
                    'npub' => (new Key)->convertPublicKeyToBech32($item),
                ]);
                continue;
            }
            $hex->push([
                'hex' => (new Key)->convertToHex($item),
                'npub' => $item,
            ]);
        }

        $subscription = new Subscription();
        $subscriptionId = $subscription->setId();

        $filter1 = new Filter();
        $filter1->setKinds([0]); // You can add multiple kind numbers
        $filter1->setAuthors($hex->pluck('hex')->toArray()); // You can add multiple author ids
        $filters = [$filter1];
        $requestMessage = new RequestMessage($subscriptionId, $filters);

        $relayUrls = [
            'wss://relay.nostr.band',
            'wss://purplepag.es',
            'wss://nostr.wine',
            'wss://relay.damus.io',
            'wss://nostr.einundzwanzig.space',
        ];

        $data = null;
        foreach ($relayUrls as $relayUrl) {
            $relay = new Relay($relayUrl);
            $relay->setMessage($requestMessage);
            $request = new Request($relay, $requestMessage);
            try {
                $response = $request->send();
                $data = $response[$relayUrl];
                if (!empty($data)) {
                    \Log::info('Successfully fetched data from relay: '.$relayUrl);
                    break; // Exit the loop if data is not empty
                }
            } catch (\Exception $e) {
                \Log::warning('Failed to fetch from relay '.$relayUrl.': '.$e->getMessage());
            }
        }

        if (empty($data)) {
            \Log::warning('No data found from any relay');
            return;
        }
        foreach ($data as $item) {
            try {
                if (isset($item->event)) {
                    $result = json_decode($item->event->content, true, 512, JSON_THROW_ON_ERROR);
                    Profile::query()->updateOrCreate(
                        ['pubkey' => $item->event->pubkey],
                        [
                            'name' => $result['name'] ?? null,
                            'display_name' => $result['display_name'] ?? null,
                            'picture' => $result['picture'] ?? null,
                            'banner' => $result['banner'] ?? null,
                            'website' => $result['website'] ?? null,
                            'about' => $result['about'] ?? null,
                            'nip05' => $result['nip05'] ?? null,
                            'lud16' => $result['lud16'] ?? null,
                            'lud06' => $result['lud06'] ?? null,
                            'deleted' => $result['deleted'] ?? false,
                        ],
                    );
                    \Log::info('Profile updated/created for pubkey: '.$item->event->pubkey);
                }
            } catch (\JsonException $e) {
                \Log::error('Error decoding JSON: '.$e->getMessage());
                throw new \RuntimeException('Error decoding JSON: '.$e->getMessage());
            }
        }
    }

}