Events & Observers

সমস্যা: সব কন্ট্রোলারে

Event ছাড়া side effect জমা হতে থাকে controller, model method বা service class-এ:

• রেজিস্ট্রেশনের পর ইমেইল → registration মেথডের অংশ
• মডেল আপডেটের পর search index sync → update মেথডে
• অডিট ট্রেইল → যেখানে অ্যাকশন ঘটে সেখানেই

Event কী সমাধান করে

Event কীভাবে কাজ করে

1. একটি event dispatch হয় — সাধারণত যা ঘটেছে তার বর্ণনা দেওয়া একটি object।
2. Dispatcher ওই event-এর রেজিস্টার্ড listener খোঁজে।
3. Listener চলে — synchronously বা asynchronously।
4. Queued listener queue worker-এ যায়, retry ও backoff সাপোর্টসহ।

Event ডেটা বহন করে। Listener প্রতিক্রিয়া বহন করে।

নিজের কোডে: Event ও Listener

ধাপ ১: Event তৈরি

php artisan make:event OrderPlaced

class OrderPlaced
{
    use Dispatchable;

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

ধাপ ২: Listener তৈরি

php artisan make:listener SendOrderConfirmation --event=OrderPlaced

class SendOrderConfirmation implements ShouldQueue
{
    public function handle(OrderPlaced $event): void
    {
        Mail::to($event->order->user)->send(new OrderReceipt($event->order));
    }
}

class UpdateInventoryLevels implements ShouldQueue
{
    public function handle(OrderPlaced $event): void
    {
        $event->order->items->each->reduceInventory();
    }
}

নিজের কোডে: Register ও Dispatch

ধাপ ৩: Listener রেজিস্টার

ম্যানুয়ালি করতে চাইলে AppServiceProvider::boot()-এ:

Event::listen(OrderPlaced::class, SendOrderConfirmation::class);
Event::listen(OrderPlaced::class, UpdateInventoryLevels::class);

পুরোনো ভার্সনে EventServiceProvider-এর $listen array:

protected $listen = [
    OrderPlaced::class => [
        SendOrderConfirmation::class,
        UpdateInventoryLevels::class,
    ],
];

ধাপ ৪: Event Dispatch

public function store(Request $request)
{
    $order = Order::create($request->validated());

    OrderPlaced::dispatch($order); // অথবা event(new OrderPlaced($order));

    return response('Order successful');
}

Model Observers

Observer হলো Eloquent model-এর lifecycle hook-এ event প্যাটার্ন:

• creating
• created
• updating
• updated
• saving
• saved
• deleting
• deleted
• restoring
• restored

class UserObserver
{
    public function created(User $user): void
    {
        // নতুন ইউজার রেজিস্টার হলে ওয়েলকাম মেইল
        Mail::to($user)->send(new WelcomeEmail());
    }

    public function deleted(User $user): void
    {
        // ইউজার ডিলিট হলে প্রোফাইল পিকচার রিমুভ
        Storage::delete($user->avatar);
    }
}

Observer রেজিস্টার করা

use Illuminate\Database\Eloquent\Attributes\ObservedBy;

#[ObservedBy([UserObserver::class])]
class User extends Authenticatable
{
    // ...
}

সাধারণ ব্যবহার: slug তৈরি, search index sync, সংশ্লিষ্ট cache ক্লিয়ার, পরিবর্তন লগ, domain event dispatch।

লারাভেল নিজেও Event ব্যবহার করে

লারাভেল এত সামঞ্জস্যপূর্ণ মনে হওয়ার একটা কারণ — ভেতরে অনেক সাবসিস্টেমে একই event প্যাটার্ন।

ফ্রেমওয়ার্ক Event-এ হুক করা

আপনার নিজের event-এর মতোই লারাভেলের event শোনা যায় — ফ্রেমওয়ার্কের কোড না ছুঁয়ে।

Job ফেইল করলে Slack অ্যালার্ট

use Illuminate\Queue\Events\JobFailed;

Event::listen(function (JobFailed $event) {
    Log::channel('slack')->error('Job failed', [
        'job'   => $event->job->resolveName(),
        'error' => $event->exception->getMessage(),
    ]);
});

প্রতিটি লগইন অডিট করা

use Illuminate\Auth\Events\Login;

Event::listen(function (Login $event) {
    $event->user->update(['last_login_at' => now()]);
});

ধীর external API খুঁজে বের করা

use Illuminate\Http\Client\Events\ResponseReceived;

Event::listen(function (ResponseReceived $event) {
    if ($event->response->transferStats?->getTransferTime() > 2) {
        Log::warning('Slow API: ' . $event->request->url());
    }
});

Queued Listeners

Listener সাধারণত সাথে সাথে চলে। কিন্তু তার মানে এই না যে ছোট কাজেই সীমাবদ্ধ। Background job বানাতে শুধু একটা ধাপ — ShouldQueue interface:

class SendOrderConfirmation implements ShouldQueue
{
    public $tries = 3;           // অধ্যায় ২-এর retry এখানেও!
    public $queue = 'emails';    // কোন queue-তে যাবে

    public function handle(OrderPlaced $event): void
    {
        // ...
    }

    public function failed(OrderPlaced $event, Throwable $e): void
    {
        // সব চেষ্টা ব্যর্থ হলে
    }
}

লারাভেল সামলায়: queue-তে dispatch, serialization, retry, backoff, failure handling। রিকোয়েস্ট পারফরম্যান্স বাড়ানোর অন্যতম সহজ উপায় — কোড রিস্ট্রাকচার না করেই।

কখন Event, কখন নয়

পুরো লারাভেলে Events

সারসংক্ষেপ ও যাচাই

• Event = কী ঘটলো (ডেটা)। Listener = এরপর কী (প্রতিক্রিয়া)।
• ShouldQueue দিলেই listener background job — retry/backoff সহ।
• Observer = Eloquent lifecycle-এর জন্য event প্যাটার্ন।
• লারাভেলের নিজের event (Queue, Auth, HTTP…) শুনে ফ্রেমওয়ার্ক না ছুঁয়ে মনিটরিং যোগ করা যায়।
• জরুরি business logic listener-এ লুকাবেন না।

নিজেকে যাচাই করুন