78 lines
1.9 KiB
Go
78 lines
1.9 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/urfave/cli/v3"
|
|
|
|
"git.maze.io/go/ham/protocol/aprs/aprsis"
|
|
|
|
"git.maze.io/ham/hamview"
|
|
"git.maze.io/ham/hamview/internal/cmd"
|
|
)
|
|
|
|
type aprsisConfig struct {
|
|
Broker hamview.BrokerConfig `yaml:"broker"`
|
|
Receiver hamview.APRSISConfig `yaml:"receiver"`
|
|
Include []string `yaml:"include"`
|
|
}
|
|
|
|
func (config *aprsisConfig) Includes() []string {
|
|
includes := config.Include
|
|
config.Include = nil
|
|
return includes
|
|
}
|
|
|
|
func runAPRSIS(ctx context.Context, command *cli.Command) error {
|
|
var config = aprsisConfig{
|
|
Receiver: hamview.APRSISConfig{
|
|
Listen: hamview.DefaultAPRSISListen,
|
|
Server: hamview.DefaultAPRSISServer,
|
|
},
|
|
}
|
|
if err := cmd.Load(logger, command.String(cmd.FlagConfig), &config); err != nil {
|
|
return err
|
|
}
|
|
|
|
logger.Infof("receiver: starting APRS-IS proxy on tcp://%s to tcp://%s",
|
|
config.Receiver.Listen,
|
|
config.Receiver.Server)
|
|
proxy, err := aprsis.NewProxy(config.Receiver.Listen, config.Receiver.Server)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
proxy.OnClient = func(callsign string, client *aprsis.ProxyClient) {
|
|
go receiveAPRSIS(&config.Broker, callsign, client)
|
|
}
|
|
|
|
return waitForInterrupt()
|
|
}
|
|
|
|
func receiveAPRSIS(config *hamview.BrokerConfig, callsign string, client *aprsis.ProxyClient) {
|
|
defer client.Close()
|
|
|
|
broker, err := hamview.NewBroker(config)
|
|
if err != nil {
|
|
logger.Errorf("receiver: can't setup to broker: %v", err)
|
|
return
|
|
}
|
|
defer broker.Close()
|
|
|
|
info := client.Info() // TODO: enrich info from config?
|
|
|
|
if err = broker.StartRadio("aprs", info); err != nil {
|
|
logger.Fatalf("receiver: can't start broker: %v", err)
|
|
return
|
|
}
|
|
|
|
logger.Infof("receiver: start receiving packets from station: %s", callsign)
|
|
for packet := range client.RawPackets() {
|
|
logger.Debugf("aprs packet: %#+v", packet)
|
|
if err := broker.PublishPacket("aprs/packet", packet); err != nil {
|
|
logger.Error(err)
|
|
}
|
|
}
|
|
logger.Info("receiver: stopped receiving packets from station: %s", callsign)
|
|
}
|