mirror of
https://github.com/HolgerHatGarKeineNode/einundzwanzig-app.git
synced 2025-12-20 13:40:15 +00:00
🚀 Add Nostr profile job, Hungarian translations, and Horizon integration
- Introduced `FetchNostrProfileJob` for retrieving and updating user Nostr profiles. - Added Hungarian translations (`auth.php`, `passwords.php`, `validation.php`, and others) for improved localization. - Integrated Laravel Horizon for enhanced queue management (`HorizonServiceProvider` added, `composer.json` updated). - Updated German and Spanish language files to fix duplicate keys. - Minor route addition for testing Nostr profile job dispatch.
This commit is contained in:
HolgerHatGarKeineNode
203
app/Jobs/FetchNostrProfileJob.php
Normal file
203
app/Jobs/FetchNostrProfileJob.php
Normal file
@@ -0,0 +1,203 @@
|
||||
<?php
|
||||
|
||||
namespace App\Jobs;
|
||||
|
||||
use App\Models\User;
|
||||
use Illuminate\Bus\Queueable;
|
||||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||||
use Illuminate\Foundation\Bus\Dispatchable;
|
||||
use Illuminate\Queue\InteractsWithQueue;
|
||||
use Illuminate\Queue\SerializesModels;
|
||||
use Illuminate\Support\Facades\Http;
|
||||
use Illuminate\Support\Facades\Storage;
|
||||
use Ramsey\Uuid\Uuid;
|
||||
use swentel\nostr\Filter\Filter;
|
||||
use swentel\nostr\Key\Key;
|
||||
use swentel\nostr\Message\RequestMessage;
|
||||
use swentel\nostr\Relay\Relay;
|
||||
use swentel\nostr\Relay\RelaySet;
|
||||
use swentel\nostr\Request\Request;
|
||||
use swentel\nostr\Subscription\Subscription;
|
||||
|
||||
class FetchNostrProfileJob implements ShouldQueue
|
||||
{
|
||||
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||||
|
||||
public function __construct(
|
||||
public ?User $user = null,
|
||||
) {}
|
||||
|
||||
public function handle(): void
|
||||
{
|
||||
// Determine which users to process
|
||||
if ($this->user) {
|
||||
if (!$this->user->nostr) {
|
||||
\Log::info('No nostr profile for user', ['user_id' => $this->user->id]);
|
||||
return;
|
||||
}
|
||||
$users = collect([$this->user]);
|
||||
} else {
|
||||
$users = User::query()->whereNotNull('nostr')->get();
|
||||
\Log::info('Fetching nostr profiles for multiple users', ['count' => $users->count()]);
|
||||
}
|
||||
|
||||
// Filter valid npub authors
|
||||
$authors = $users
|
||||
->pluck('nostr')
|
||||
->map(fn($nostr) => trim($nostr))
|
||||
->filter(fn($nostr) => str_starts_with($nostr, 'npub1'))
|
||||
->unique()
|
||||
->values()
|
||||
->toArray();
|
||||
|
||||
if (empty($authors)) {
|
||||
\Log::warning('No valid nostr authors found');
|
||||
return;
|
||||
}
|
||||
|
||||
// Setup filter for kind 0 (profile metadata)
|
||||
$subscription = new Subscription();
|
||||
$filter = new Filter();
|
||||
$filter->setAuthors($authors);
|
||||
$filter->setKinds([0]);
|
||||
$requestMessage = new RequestMessage($subscription->getId(), [$filter]);
|
||||
|
||||
// Setup relay set
|
||||
$relays = [
|
||||
new Relay('wss://nos.lol'),
|
||||
new Relay('wss://relay.nostr.band'),
|
||||
];
|
||||
$relaySet = new RelaySet();
|
||||
$relaySet->setRelays($relays);
|
||||
|
||||
// Send request
|
||||
$request = new Request($relaySet, $requestMessage);
|
||||
|
||||
try {
|
||||
\Log::info('Fetching from relays', ['relay_count' => count($relays), 'author_count' => count($authors)]);
|
||||
$response = $request->send();
|
||||
|
||||
$updated = 0;
|
||||
$totalMessages = 0;
|
||||
|
||||
foreach ($response as $relayUrl => $relayResponses) {
|
||||
$messageCount = count($relayResponses);
|
||||
$totalMessages += $messageCount;
|
||||
|
||||
\Log::info('Received messages from relay', ['url' => $relayUrl, 'count' => $messageCount]);
|
||||
|
||||
foreach ($relayResponses as $message) {
|
||||
if (!isset($message->event)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
try {
|
||||
$profile = json_decode($message->event->content, true, 512, JSON_THROW_ON_ERROR);
|
||||
|
||||
if (isset($profile['picture'])) {
|
||||
$npub = (new Key)->convertPublicKeyToBech32($message->event->pubkey);
|
||||
$user = User::query()->where('nostr', $npub)->first();
|
||||
if (isset($profile['name'])) {
|
||||
$user->name = $profile['name'];
|
||||
$user->save();
|
||||
}
|
||||
|
||||
if ($user) {
|
||||
$this->downloadAndSaveProfilePhoto($user, $profile['picture']);
|
||||
$updated++;
|
||||
}
|
||||
}
|
||||
} catch (\JsonException $e) {
|
||||
\Log::error('Failed to decode profile', [
|
||||
'error' => $e->getMessage(),
|
||||
'relay' => $relayUrl,
|
||||
'pubkey' => $message->event->pubkey,
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
\Log::error('Failed to download profile photo', [
|
||||
'error' => $e->getMessage(),
|
||||
'relay' => $relayUrl,
|
||||
'pubkey' => $message->event->pubkey,
|
||||
]);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
\Log::info('Finished updating nostr profiles', [
|
||||
'total_messages' => $totalMessages,
|
||||
'updated_count' => $updated,
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
\Log::error('Failed to fetch from relays', ['error' => $e->getMessage()]);
|
||||
}
|
||||
}
|
||||
|
||||
private function downloadAndSaveProfilePhoto(User $user, string $photoUrl): void
|
||||
{
|
||||
try {
|
||||
// Download the image from the URL
|
||||
$response = Http::timeout(10)->get($photoUrl);
|
||||
|
||||
if (!$response->successful()) {
|
||||
\Log::warning('Failed to download profile photo', [
|
||||
'user_id' => $user->id,
|
||||
'url' => $photoUrl,
|
||||
'status' => $response->status(),
|
||||
]);
|
||||
return;
|
||||
}
|
||||
|
||||
// Store the file and update the user
|
||||
tap($user->profile_photo_path, function ($previous) use ($user, $response, $photoUrl) {
|
||||
$extension = $this->getImageExtension($response->header('Content-Type'), $photoUrl);
|
||||
$path = 'profile-photos/'.Uuid::uuid1().$extension;
|
||||
Storage::disk('public')
|
||||
->put(
|
||||
$path,
|
||||
$response->body(),
|
||||
);
|
||||
|
||||
$user->forceFill([
|
||||
'profile_photo_path' => $path,
|
||||
])->save();
|
||||
|
||||
if ($previous) {
|
||||
Storage::disk('public')->delete($previous);
|
||||
}
|
||||
});
|
||||
|
||||
\Log::info('Profile photo updated from Nostr', [
|
||||
'user_id' => $user->id,
|
||||
'url' => $photoUrl,
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
\Log::error('Failed to save profile photo', [
|
||||
'user_id' => $user->id,
|
||||
'url' => $photoUrl,
|
||||
'error' => $e->getMessage(),
|
||||
]);
|
||||
}
|
||||
}
|
||||
|
||||
private function getImageExtension(?string $contentType, string $url): string
|
||||
{
|
||||
// Try to get extension from content type
|
||||
if ($contentType) {
|
||||
$mimeMap = [
|
||||
'image/jpeg' => 'jpg',
|
||||
'image/jpg' => 'jpg',
|
||||
'image/png' => 'png',
|
||||
'image/gif' => 'gif',
|
||||
'image/webp' => 'webp',
|
||||
];
|
||||
|
||||
if (isset($mimeMap[$contentType])) {
|
||||
return $mimeMap[$contentType];
|
||||
}
|
||||
}
|
||||
|
||||
// Fallback to URL extension
|
||||
$pathInfo = pathinfo(parse_url($url, PHP_URL_PATH));
|
||||
return $pathInfo['extension'] ?? 'jpg';
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user