package events

import (
	"sync"
)

type eventHandler func(args ...interface{})

var (
	eventMap     = make(map[string][]eventHandler)
	eventMapLock sync.RWMutex

	allListeners = make([]eventHandler, 0)

	initialized = false
)

func On(name string, f eventHandler) {
	eventMapLock.Lock()
	defer eventMapLock.Unlock()

	handlers, exists := eventMap[name]

	if !exists {
		handlers = make([]eventHandler, 0)
	}

	handlers = append(handlers, f)

	eventMap[name] = handlers
}

func OnALl(f eventHandler) {
	allListeners = append(allListeners, f)
}

func Call(name string, args ...interface{}) {
	if !initialized && name != Init {
		Call(Init)
		initialized = true
	}

	eventMapLock.RLock()
	handlers, exists := eventMap[name]
	eventMapLock.RUnlock()

	if !exists {
		return
	}

	for _, handler := range handlers {
		handler(args...)
	}
}