gateway.go

package basicstation

import (
	"errors"
	"sync"
	"time"

	"github.com/gorilla/websocket"

	"github.com/ThingsIXFoundation/packet-handling/external/chirpstack/gateway-bridge/backend/events"
	"github.com/ThingsIXFoundation/packet-handling/external/chirpstack/gateway-bridge/backend/stats"
	"github.com/brocaar/lorawan"
)

var (
	errGatewayDoesNotExist = errors.New("gateway does not exist")
)

type connection struct {
	sync.Mutex
	conn         *websocket.Conn
	stats        *stats.Collector
	lastTimesync time.Time
}

type gateways struct {
	sync.RWMutex
	gateways map[lorawan.EUI64]*connection

	subscribeEventFunc func(events.Subscribe)
}

func (g *gateways) get(id lorawan.EUI64) (*connection, error) {
	g.RLock()
	defer g.RUnlock()

	gw, ok := g.gateways[id]
	if !ok {
		return gw, errGatewayDoesNotExist
	}
	return gw, nil
}

func (g *gateways) set(id lorawan.EUI64, c *connection) error {
	g.Lock()
	defer g.Unlock()

	g.gateways[id] = c

	if g.subscribeEventFunc != nil {
		g.subscribeEventFunc(events.Subscribe{Subscribe: true, GatewayID: id})
	}

	return nil
}

func (g *gateways) getLastTimesync(id lorawan.EUI64) (time.Time, error) {
	g.RLock()
	defer g.RUnlock()

	gw, ok := g.gateways[id]
	if !ok {
		return time.Time{}, errGatewayDoesNotExist
	}

	return gw.lastTimesync, nil
}

func (g *gateways) setLastTimesync(id lorawan.EUI64, ts time.Time) error {
	g.Lock()
	defer g.Unlock()

	gw, ok := g.gateways[id]
	if !ok {
		return errGatewayDoesNotExist
	}

	gw.lastTimesync = ts
	g.gateways[id] = gw

	return nil
}

func (g *gateways) remove(id lorawan.EUI64) error {
	g.Lock()
	defer g.Unlock()

	if g.subscribeEventFunc != nil {
		g.subscribeEventFunc(events.Subscribe{Subscribe: false, GatewayID: id})
	}

	delete(g.gateways, id)
	return nil
}