refactor: events refactor (Listen, Dispatch)

contracts/event/events.go

@@ -1,40 +1,75 @@
 package event
 
-type Instance interface {
-	// Register event listeners to the application.
-	Register(map[Event][]Listener)
-	// Job create a new event task.
-	Job(event Event, args []Arg) Task
-	// GetEvents gets all registered events.
-	GetEvents() map[Event][]Listener
+type Arg struct {
+	Type  string
+	Value any
 }
 
 type Event interface {
 	// Handle the event.
 	Handle(args []Arg) ([]Arg, error)
 }
 
-type Listener interface {
-	// Signature returns the unique identifier for the listener.
-	Signature() string
+type EventListener interface {
+	// Handle the event.
+	Handle(event any, args ...any) error
+}
+
+type EventQueueListener interface {
 	// Queue configure the event queue options.
 	Queue(args ...any) Queue
-	// Handle the event.
-	Handle(args ...any) error
+
+	EventListener
+	Signature
+	ShouldQueue
 }
 
-type Task interface {
-	// Dispatch an event and call the listeners.
-	Dispatch() error
+type Instance interface {
+	// Dispatch fires an event and calls the listeners.
+	Dispatch(event any, payload ...[]Arg) []any
+	// GetEvents gets all registered events.
+	GetEvents() map[Event][]Listener
+	// Job create a new event task.
+	// Deprecated: Use Dispatch instead. Job will be removed in a future version.
+	Job(event Event, args []Arg) Task
+	// Listen registers an event listener with the dispatcher.
+	// events can be: string, []string, Event, []Event, or any other type
+	// listener can be: function, class, or any callable
+	Listen(events any, listener ...any) error
+	// Register event listeners to the application.
+	Register(map[Event][]Listener)
 }
 
-type Arg struct {
-	Value any
-	Type  string
+type Listener interface {
+	// Handle the event.
+	Handle(args ...any) error
+	// Queue configure the event queue options.
+	Queue(args ...any) Queue
+	// Signature returns the unique identifier for the listener.
+	Signature() string
 }
 
 type Queue struct {
 	Connection string
-	Queue      string
 	Enable     bool
+	Queue      string
+}
+
+type QueueListener interface {
+	Listener
+	Signature
+	ShouldQueue
+}
+
+type ShouldQueue interface {
+	ShouldQueue() bool
+}
+
+type Signature interface {
+	Signature() string
+}
+
+type Task interface {
+	// Dispatch an event and call the listeners.
+	Dispatch() error
 }

event/application.go

@@ -2,22 +2,58 @@ package event
 
 import (
 	"slices"
+	"sync"
 
 	"github.com/goravel/framework/contracts/event"
 	"github.com/goravel/framework/contracts/queue"
 )
 
 type Application struct {
-	events map[event.Event][]event.Listener
-	queue  queue.Queue
+	listeners      map[string][]any
+	mu             sync.RWMutex
+	wildcards      map[string][]any
+	wildcardsCache sync.Map
+	events         map[event.Event][]event.Listener
+	queue          queue.Queue
 }
 
 func NewApplication(queue queue.Queue) *Application {
 	return &Application{
-		queue: queue,
+		listeners:      make(map[string][]any),
+		mu:             sync.RWMutex{},
+		wildcards:      make(map[string][]any),
+		wildcardsCache: sync.Map{},
+		queue:          queue,
 	}
 }
 
+// GetEvents returns all registered events and their listeners.
+func (app *Application) GetEvents() map[event.Event][]event.Listener {
+	return app.events
+}
+
+// Job returns a new Task for the given event and arguments.
+// Deprecated: Use Dispatch instead. Job will be removed in a future version.
+// The new Dispatch method fires events immediately and returns listener responses.
+//
+// Migration example:
+//
+//	// Old way
+//	task := app.Job(event, args)
+//	task.Dispatch()
+//
+//	// New way
+//	responses := app.Dispatch(event, args)
+func (app *Application) Job(e event.Event, args []event.Arg) event.Task {
+	listeners, ok := app.events[e]
+	if !ok {
+		listeners = make([]event.Listener, 0)
+	}
+
+	return NewTask(app.queue, args, e, listeners)
+}
+
+// Register registers events and their listeners.
 func (app *Application) Register(events map[event.Event][]event.Listener) {
 	var (
 		jobs     []queue.Job
@@ -40,16 +76,3 @@ func (app *Application) Register(events map[event.Event][]event.Listener) {
 
 	app.queue.Register(jobs)
 }
-
-func (app *Application) GetEvents() map[event.Event][]event.Listener {
-	return app.events
-}
-
-func (app *Application) Job(e event.Event, args []event.Arg) event.Task {
-	listeners, ok := app.events[e]
-	if !ok {
-		listeners = make([]event.Listener, 0)
-	}
-
-	return NewTask(app.queue, args, e, listeners)
-}