feat: accept join token in Provision payload

It's now possible to start the siderolink-agent with a join token
parameter. Clients are now required to submit that same token in Provision
requests or the request will fail.

Fixes #5592

Signed-off-by: Philipp Sauter <philipp.sauter@siderolabs.com>

Author: Philipp Sauter

api/siderolink/provision.pb.go

@@ -16,6 +16,8 @@ message ProvisionRequest {
     string node_uuid = 1;
     // Wireguard public key (as string) of the node.
     string node_public_key = 2;
+    // Join token (as string) of the node.
+    optional string join_token = 3;
 }
 
 message ProvisionResponse {

api/siderolink/provision.proto

@@ -20,6 +20,7 @@ import (
 func main() {
 	flag.StringVar(&sideroLinkFlags.wireguardEndpoint, "sidero-link-wireguard-endpoint", "172.20.0.1:51821", "advertised Wireguard endpoint")
 	flag.StringVar(&sideroLinkFlags.apiEndpoint, "sidero-link-api-endpoint", ":4000", "gRPC API endpoint for the SideroLink")
+	flag.StringVar(&sideroLinkFlags.joinToken, "sidero-link-join-token", "", "join token")
 	flag.StringVar(&eventSinkFlags.apiEndpoint, "event-sink-endpoint", ":8080", "gRPC API endpoint for the Event Sink")
 	flag.StringVar(&logReceiverFlags.endpoint, "log-receiver-endpoint", ":4001", "TCP log receiver endpoint")
 	flag.Parse()

api/siderolink/provision_vtproto.pb.go

@@ -23,6 +23,7 @@ import (
 var sideroLinkFlags struct {
 	wireguardEndpoint string
 	apiEndpoint       string
+	joinToken         string
 }
 
 func sideroLink(ctx context.Context, eg *errgroup.Group, logger *zap.Logger) error {
@@ -56,6 +57,7 @@ func sideroLink(ctx context.Context, eg *errgroup.Group, logger *zap.Logger) err
 		ServerAddress:   serverAddr.IP(),
 		ServerEndpoint:  wireguardEndpoint,
 		ServerPublicKey: privateKey.PublicKey(),
+		JoinToken:       sideroLinkFlags.joinToken,
 	})
 
 	s := grpc.NewServer()

cmd/siderolink-agent/main.go

@@ -33,6 +33,7 @@ type Config struct {
 	NodePrefix      netaddr.IPPrefix
 	ServerAddress   netaddr.IP
 	ServerEndpoint  netaddr.IPPort
+	JoinToken       string
 	ServerPublicKey wgtypes.Key
 }
 
@@ -51,6 +52,10 @@ func (srv *Server) EventCh() <-chan wireguard.PeerEvent {
 
 // Provision the SideroLink.
 func (srv *Server) Provision(ctx context.Context, req *pb.ProvisionRequest) (*pb.ProvisionResponse, error) {
+	if srv.cfg.JoinToken != "" && (req.JoinToken == nil || *req.JoinToken != srv.cfg.JoinToken) {
+		return nil, status.Error(codes.PermissionDenied, "invalid join token")
+	}
+
 	// generated random address for the node
 	raw := srv.cfg.NodePrefix.IP().As16()
 	salt := make([]byte, 8)