1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
|
// Copyright 2018-present the CoreDHCP Authors. All rights reserved
// This source code is licensed under the MIT license found in the
// LICENSE file in the root directory of this source tree.
package staticroute
import (
"errors"
"net"
"strings"
"github.com/coredhcp/coredhcp/handler"
"github.com/coredhcp/coredhcp/logger"
"github.com/coredhcp/coredhcp/plugins"
"github.com/insomniacslk/dhcp/dhcpv4"
)
var log = logger.GetLogger("plugins/staticroute")
// Plugin wraps the information necessary to register a plugin.
var Plugin = plugins.Plugin{
Name: "staticroute",
Setup4: setup4,
}
var routes dhcpv4.Routes
func setup4(args ...string) (handler.Handler4, error) {
log.Printf("loaded plugin for DHCPv4.")
routes = make(dhcpv4.Routes, 0)
if len(args) < 1 {
return nil, errors.New("need at least one static route")
}
var err error
for _, arg := range args {
fields := strings.Split(arg, ",")
if len(fields) != 2 {
return Handler4, errors.New("expected a destination/gateway pair, got: " + arg)
}
route := &dhcpv4.Route{}
_, route.Dest, err = net.ParseCIDR(fields[0])
if err != nil {
return Handler4, errors.New("expected a destination subnet, got: " + fields[0])
}
route.Router = net.ParseIP(fields[1])
if route.Router == nil {
return Handler4, errors.New("expected a gateway address, got: " + fields[1])
}
routes = append(routes, route)
log.Debugf("adding static route %s", route)
}
log.Printf("loaded %d static routes.", len(routes))
return Handler4, nil
}
// Handler4 handles DHCPv4 packets for the static routes plugin
func Handler4(req, resp *dhcpv4.DHCPv4) (*dhcpv4.DHCPv4, bool) {
if len(routes) > 0 {
resp.Options.Update(dhcpv4.Option{
Code: dhcpv4.OptionCode(dhcpv4.OptionClasslessStaticRoute),
Value: routes,
})
}
return resp, false
}
|