neko/internal/webrtc/cursor/position.go

package cursor

import (
	"reflect"
	"sync"

	"github.com/rs/zerolog"
	"github.com/rs/zerolog/log"
)

func NewPosition() *PositionCtx {
	return &PositionCtx{
		logger:    log.With().Str("module", "webrtc").Str("submodule", "cursor-position").Logger(),
		listeners: map[uintptr]*func(x, y int){},
	}
}

type PositionCtx struct {
	logger zerolog.Logger

	listeners   map[uintptr]*func(x, y int)
	listenersMu sync.Mutex
}

func (manager *PositionCtx) Shutdown() {
	manager.logger.Info().Msg("shutdown")

	manager.listenersMu.Lock()
	for key := range manager.listeners {
		delete(manager.listeners, key)
	}
	manager.listenersMu.Unlock()
}

func (manager *PositionCtx) Set(x, y int) {
	manager.listenersMu.Lock()
	defer manager.listenersMu.Unlock()

	for _, emit := range manager.listeners {
		(*emit)(x, y)
	}
}

func (manager *PositionCtx) AddListener(listener *func(x, y int)) {
	manager.listenersMu.Lock()
	defer manager.listenersMu.Unlock()

	if listener != nil {
		ptr := reflect.ValueOf(listener).Pointer()
		manager.listeners[ptr] = listener
	}
}

func (manager *PositionCtx) RemoveListener(listener *func(x, y int)) {
	manager.listenersMu.Lock()
	defer manager.listenersMu.Unlock()

	if listener != nil {
		ptr := reflect.ValueOf(listener).Pointer()
		delete(manager.listeners, ptr)
	}
}