Eloquent المتقدم: الأحداث والمراقبين

// app/Models/Post.php
namespace App\Models;

use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Str;

class Post extends Model
{
    protected static function booted()
    {
        // توليد slug عند إنشاء منشور جديد
        static::creating(function ($post) {
            if (empty($post->slug)) {
                $post->slug = Str::slug($post->title);
            }
        });

        // تحديث slug عند تغيير العنوان
        static::updating(function ($post) {
            if ($post->isDirty('title')) {
                $post->slug = Str::slug($post->title);
            }
        });

        // زيادة عدد المشاهدات عند استرجاع المنشور
        static::retrieved(function ($post) {
            // كن حذراً مع هذا - يمكن أن يسبب مشاكل في الأداء
            // من الأفضل استخدام قائمة انتظار أو تحديث دفعي
        });

        // التسجيل عند حذف المنشور
        static::deleted(function ($post) {
            \Log::info("Post deleted: {$post->title}");
        });
    }
}

// app/Models/Order.php
namespace App\Models;

use App\Notifications\OrderCreatedNotification;
use Illuminate\Database\Eloquent\Model;

class Order extends Model
{
    protected static function booted()
    {
        // إرسال إشعار عند إنشاء الطلب
        static::created(function ($order) {
            $order->user->notify(new OrderCreatedNotification($order));
        });

        // حساب الإجماليات قبل الحفظ
        static::saving(function ($order) {
            $order->total = $order->items->sum(function ($item) {
                return $item->quantity * $item->price;
            });
            $order->tax = $order->total * 0.1; // ضريبة 10٪
            $order->grand_total = $order->total + $order->tax;
        });

        // تحديث المخزون عند اكتمال الطلب
        static::updated(function ($order) {
            if ($order->wasChanged('status') && $order->status === 'completed') {
                foreach ($order->items as $item) {
                    $item->product->decrement('stock', $item->quantity);
                }
            }
        });

        // منع حذف الطلبات المكتملة
        static::deleting(function ($order) {
            if ($order->status === 'completed') {
                return false; // إلغاء عملية الحذف
            }
        });
    }
}

// توليد مراقب باستخدام artisan
php artisan make:observer PostObserver --model=Post

// app/Observers/PostObserver.php
namespace App\Observers;

use App\Models\Post;
use Illuminate\Support\Str;

class PostObserver
{
    /**
     * معالجة حدث Post "creating".
     */
    public function creating(Post $post): void
    {
        // توليد slug تلقائياً
        if (empty($post->slug)) {
            $post->slug = Str::slug($post->title);
        }

        // تعيين المؤلف الافتراضي إذا لم يتم توفيره
        if (empty($post->author_id)) {
            $post->author_id = auth()->id();
        }
    }

    /**
     * معالجة حدث Post "created".
     */
    public function created(Post $post): void
    {
        // تسجيل الإنشاء
        \Log::info("New post created: {$post->title}");

        // إرسال إشعار للمتابعين
        $post->author->followers->each(function ($follower) use ($post) {
            $follower->notify(new \App\Notifications\NewPostPublished($post));
        });
    }

    /**
     * معالجة حدث Post "updating".
     */
    public function updating(Post $post): void
    {
        // تحديث slug إذا تغير العنوان
        if ($post->isDirty('title')) {
            $post->slug = Str::slug($post->title);
        }

        // تسجيل من قام بالتحديث
        $post->last_updated_by = auth()->id();
    }

    /**
     * معالجة حدث Post "updated".
     */
    public function updated(Post $post): void
    {
        // مسح الذاكرة المؤقتة عند تحديث المنشور
        \Cache::forget("post.{$post->id}");
        \Cache::forget("posts.recent");

        // إرسال إشعار إذا تغيرت حالة النشر
        if ($post->wasChanged('status') && $post->status === 'published') {
            $post->author->notify(new \App\Notifications\PostPublished($post));
        }
    }

    /**
     * معالجة حدث Post "deleting".
     */
    public function deleting(Post $post): void
    {
        // حذف التعليقات المرتبطة
        $post->comments()->delete();

        // حذف الوسائط المرتبطة
        $post->media()->each(function ($media) {
            \Storage::delete($media->path);
            $media->delete();
        });
    }

    /**
     * معالجة حدث Post "deleted".
     */
    public function deleted(Post $post): void
    {
        // مسح الذاكرة المؤقتة
        \Cache::forget("post.{$post->id}");

        // تسجيل الحذف
        \Log::warning("Post deleted: {$post->title} by user " . auth()->id());
    }

    /**
     * معالجة حدث Post "restored".
     */
    public function restored(Post $post): void
    {
        // استعادة التعليقات المرتبطة
        $post->comments()->restore();

        \Log::info("Post restored: {$post->title}");
    }
}

// app/Providers/EventServiceProvider.php
namespace App\Providers;

use App\Models\Post;
use App\Observers\PostObserver;
use Illuminate\Support\ServiceProvider;

class EventServiceProvider extends ServiceProvider
{
    /**
     * تسجيل أي أحداث لتطبيقك.
     */
    public function boot(): void
    {
        // تسجيل المراقب
        Post::observe(PostObserver::class);
    }
}

// بديل: التسجيل في AppServiceProvider
// app/Providers/AppServiceProvider.php
public function boot(): void
{
    Post::observe(PostObserver::class);
}

// app/Observers/UserObserver.php
namespace App\Observers;

use App\Models\User;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Str;

class UserObserver
{
    /**
     * معالجة حدث User "creating".
     */
    public function creating(User $user): void
    {
        // تجزئة كلمة المرور إذا لم تكن مجزأة بالفعل
        if ($user->password && !Hash::needsRehash($user->password)) {
            $user->password = Hash::make($user->password);
        }

        // توليد اسم مستخدم فريد إذا لم يتم توفيره
        if (empty($user->username)) {
            $base = Str::slug($user->name);
            $username = $base;
            $counter = 1;

            while (User::where('username', $username)->exists()) {
                $username = $base . $counter++;
            }

            $user->username = $username;
        }

        // توليد رمز API
        $user->api_token = Str::random(80);
    }

    /**
     * معالجة حدث User "created".
     */
    public function created(User $user): void
    {
        // إنشاء ملف تعريف افتراضي
        $user->profile()->create([
            'bio' => '',
            'avatar' => 'default-avatar.png',
        ]);

        // إنشاء إعدادات افتراضية
        $user->settings()->create([
            'notifications_enabled' => true,
            'email_frequency' => 'daily',
        ]);

        // إرسال بريد ترحيبي
        $user->sendEmailVerificationNotification();

        // تسجيل التسجيل
        activity()
            ->performedOn($user)
            ->log('User registered');
    }

    /**
     * معالجة حدث User "updating".
     */
    public function updating(User $user): void
    {
        // إعادة تجزئة كلمة المرور إذا تغيرت
        if ($user->isDirty('password')) {
            $user->password = Hash::make($user->password);
        }

        // التحقق من أن البريد الإلكتروني فريد إذا تغير
        if ($user->isDirty('email')) {
            $user->email_verified_at = null;
        }
    }

    /**
     * معالجة حدث User "deleting".
     */
    public function deleting(User $user): void
    {
        // حذف البيانات المرتبطة
        $user->posts()->delete();
        $user->comments()->delete();
        $user->profile()->delete();
        $user->settings()->delete();

        // إلغاء رموز API
        $user->tokens()->delete();

        // تسجيل الحذف
        activity()
            ->performedOn($user)
            ->log('User account deleted');
    }
}

// app/Events/OrderShipped.php
namespace App\Events;

use App\Models\Order;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;

class OrderShipped
{
    use Dispatchable, SerializesModels;

    public function __construct(
        public Order $order
    ) {}
}

// app/Events/PaymentProcessed.php
namespace App\Events;

use App\Models\Payment;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;

class PaymentProcessed
{
    use Dispatchable, SerializesModels;

    public function __construct(
        public Payment $payment,
        public bool $successful
    ) {}
}

// app/Listeners/SendShipmentNotification.php
namespace App\Listeners;

use App\Events\OrderShipped;
use App\Notifications\OrderShippedNotification;

class SendShipmentNotification
{
    public function handle(OrderShipped $event): void
    {
        $event->order->user->notify(
            new OrderShippedNotification($event->order)
        );
    }
}

// app/Listeners/UpdateInventory.php
namespace App\Listeners;

use App\Events\OrderShipped;

class UpdateInventory
{
    public function handle(OrderShipped $event): void
    {
        foreach ($event->order->items as $item) {
            $item->product->decrement('stock', $item->quantity);
        }
    }
}

// app/Providers/EventServiceProvider.php
namespace App\Providers;

use App\Events\OrderShipped;
use App\Events\PaymentProcessed;
use App\Listeners\SendShipmentNotification;
use App\Listeners\UpdateInventory;
use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;

class EventServiceProvider extends ServiceProvider
{
    /**
     * تعيينات مستمع الأحداث للتطبيق.
     */
    protected $listen = [
        OrderShipped::class => [
            SendShipmentNotification::class,
            UpdateInventory::class,
        ],
        PaymentProcessed::class => [
            // إضافة المستمعين هنا
        ],
    ];

    /**
     * تسجيل أي أحداث لتطبيقك.
     */
    public function boot(): void
    {
        //
    }
}

// في controller أو الخدمة الخاصة بك
use App\Events\OrderShipped;
use App\Models\Order;

public function shipOrder(Order $order)
{
    // تحديث حالة الطلب
    $order->update([
        'status' => 'shipped',
        'shipped_at' => now(),
    ]);

    // إرسال الحدث
    event(new OrderShipped($order));

    // صيغة بديلة
    OrderShipped::dispatch($order);

    return response()->json(['message' => 'Order shipped successfully']);
}

// app/Listeners/UserEventSubscriber.php
namespace App\Listeners;

use App\Events\UserRegistered;
use App\Events\UserLoggedIn;
use App\Events\UserProfileUpdated;
use Illuminate\Events\Dispatcher;

class UserEventSubscriber
{
    /**
     * معالجة أحداث تسجيل المستخدم.
     */
    public function handleUserRegistration($event)
    {
        // إرسال بريد ترحيبي
        $event->user->sendWelcomeEmail();

        // إنشاء سجل نشاط
        activity()
            ->performedOn($event->user)
            ->log('User registered');
    }

    /**
     * معالجة أحداث تسجيل دخول المستخدم.
     */
    public function handleUserLogin($event)
    {
        // تحديث طابع زمني لآخر تسجيل دخول
        $event->user->update([
            'last_login_at' => now(),
            'last_login_ip' => request()->ip(),
        ]);
    }

    /**
     * معالجة أحداث تحديث ملف تعريف المستخدم.
     */
    public function handleProfileUpdate($event)
    {
        // مسح الذاكرة المؤقتة
        \Cache::forget("user.{$event->user->id}");

        // تسجيل التحديث
        activity()
            ->performedOn($event->user)
            ->log('Profile updated');
    }

    /**
     * تسجيل المستمعين للمشترك.
     */
    public function subscribe(Dispatcher $events): void
    {
        $events->listen(
            UserRegistered::class,
            [UserEventSubscriber::class, 'handleUserRegistration']
        );

        $events->listen(
            UserLoggedIn::class,
            [UserEventSubscriber::class, 'handleUserLogin']
        );

        $events->listen(
            UserProfileUpdated::class,
            [UserEventSubscriber::class, 'handleProfileUpdate']
        );
    }
}

// app/Providers/EventServiceProvider.php
namespace App\Providers;

use App\Listeners\UserEventSubscriber;
use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;

class EventServiceProvider extends ServiceProvider
{
    /**
     * فئات المشتركين للتسجيل.
     */
    protected $subscribe = [
        UserEventSubscriber::class,
    ];
}