event.go

package emitter

import "sync"

// Event is an interface representing the structure of an event.
type Event interface {
	Topic() string
	Payload() interface{}
	SetPayload(interface{})
	SetAborted(bool)
	IsAborted() bool
}

// BaseEvent provides a basic implementation of the Event interface.
type BaseEvent struct {
	topic   string
	payload interface{}
	aborted bool
	mu      sync.RWMutex // Changed from sync.Mutex to sync.RWMutex
}

// NewBaseEvent creates a new instance of BaseEvent with a payload.
func NewBaseEvent(topic string, payload interface{}) *BaseEvent {
	return &BaseEvent{
		topic:   topic,
		payload: payload,
	}
}

// Topic returns the event's topic.
func (e *BaseEvent) Topic() string {
	return e.topic
}

// Payload returns the event's payload.
func (e *BaseEvent) Payload() interface{} {
	e.mu.RLock() // Read lock
	defer e.mu.RUnlock()
	return e.payload
}

// SetPayload sets the event's payload.
func (e *BaseEvent) SetPayload(payload interface{}) {
	e.mu.Lock() // Write lock
	defer e.mu.Unlock()
	e.payload = payload
}

// SetAborted sets the event's aborted status.
func (e *BaseEvent) SetAborted(abort bool) {
	e.mu.Lock() // Write lock
	defer e.mu.Unlock()
	e.aborted = abort
}

// IsAborted checks the event's aborted status.
func (e *BaseEvent) IsAborted() bool {
	e.mu.RLock() // Read lock
	defer e.mu.RUnlock()
	return e.aborted
}