headscale/routes.go

57 lines
1.3 KiB
Go
Raw Normal View History

2021-04-28 16:55:29 +02:00
package headscale
import (
"encoding/json"
"errors"
2021-05-15 00:05:41 +02:00
"gorm.io/datatypes"
2021-04-28 16:55:29 +02:00
"inet.af/netaddr"
)
// GetNodeRoutes returns the subnet routes advertised by a node (identified by
// namespace and node name)
func (h *Headscale) GetNodeRoutes(namespace string, nodeName string) (*[]netaddr.IPPrefix, error) {
m, err := h.GetMachine(namespace, nodeName)
if err != nil {
return nil, err
}
hi, err := m.GetHostInfo()
if err != nil {
return nil, err
}
return &hi.RoutableIPs, nil
}
// EnableNodeRoute enables a subnet route advertised by a node (identified by
// namespace and node name)
func (h *Headscale) EnableNodeRoute(namespace string, nodeName string, routeStr string) (*netaddr.IPPrefix, error) {
2021-04-28 16:55:29 +02:00
m, err := h.GetMachine(namespace, nodeName)
if err != nil {
return nil, err
2021-04-28 16:55:29 +02:00
}
hi, err := m.GetHostInfo()
if err != nil {
return nil, err
2021-04-28 16:55:29 +02:00
}
route, err := netaddr.ParseIPPrefix(routeStr)
if err != nil {
return nil, err
2021-04-28 16:55:29 +02:00
}
for _, rIP := range hi.RoutableIPs {
if rIP == route {
routes, _ := json.Marshal([]string{routeStr}) // TODO: only one for the time being, so overwriting the rest
2021-05-15 00:05:41 +02:00
m.EnabledRoutes = datatypes.JSON(routes)
2021-07-04 21:40:46 +02:00
h.db.Save(&m)
2021-04-28 16:55:29 +02:00
err = h.RequestMapUpdates(m.NamespaceID)
if err != nil {
return nil, err
2021-04-28 16:55:29 +02:00
}
return &rIP, nil
2021-04-28 16:55:29 +02:00
}
}
return nil, errors.New("could not find routable range")
2021-04-28 16:55:29 +02:00
}