2020-06-21 18:32:08 +08:00
|
|
|
package headscale
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"encoding/binary"
|
|
|
|
|
"encoding/json"
|
2021-06-24 21:44:19 +08:00
|
|
|
"errors"
|
2020-06-21 18:32:08 +08:00
|
|
|
"fmt"
|
|
|
|
|
"io"
|
|
|
|
|
"net/http"
|
2021-10-08 17:43:52 +08:00
|
|
|
"strings"
|
2020-06-21 18:32:08 +08:00
|
|
|
"time"
|
|
|
|
|
|
2021-08-06 01:11:26 +08:00
|
|
|
"github.com/rs/zerolog/log"
|
|
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
"github.com/gin-gonic/gin"
|
|
|
|
|
"github.com/klauspost/compress/zstd"
|
2021-06-24 21:44:19 +08:00
|
|
|
"gorm.io/gorm"
|
2020-06-21 18:32:08 +08:00
|
|
|
"tailscale.com/tailcfg"
|
2021-06-26 00:57:08 +08:00
|
|
|
"tailscale.com/types/wgkey"
|
2020-06-21 18:32:08 +08:00
|
|
|
)
|
|
|
|
|
|
2021-02-28 07:58:09 +08:00
|
|
|
// KeyHandler provides the Headscale pub key
|
|
|
|
|
// Listens in /key
|
2020-06-21 18:32:08 +08:00
|
|
|
func (h *Headscale) KeyHandler(c *gin.Context) {
|
|
|
|
|
c.Data(200, "text/plain; charset=utf-8", []byte(h.publicKey.HexString()))
|
|
|
|
|
}
|
|
|
|
|
|
2021-02-28 07:58:09 +08:00
|
|
|
// RegisterWebAPI shows a simple message in the browser to point to the CLI
|
|
|
|
|
// Listens in /register
|
|
|
|
|
func (h *Headscale) RegisterWebAPI(c *gin.Context) {
|
|
|
|
|
mKeyStr := c.Query("key")
|
|
|
|
|
if mKeyStr == "" {
|
|
|
|
|
c.String(http.StatusBadRequest, "Wrong params")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
c.Data(http.StatusOK, "text/html; charset=utf-8", []byte(fmt.Sprintf(`
|
|
|
|
|
<html>
|
|
|
|
|
<body>
|
|
|
|
|
<h1>headscale</h1>
|
|
|
|
|
<p>
|
2021-05-15 06:05:41 +08:00
|
|
|
Run the command below in the headscale server to add this machine to your network:
|
2021-02-28 07:58:09 +08:00
|
|
|
</p>
|
|
|
|
|
|
|
|
|
|
<p>
|
|
|
|
|
<code>
|
2021-11-05 06:18:06 +08:00
|
|
|
<b>headscale -n NAMESPACE nodes register --key %s</b>
|
2021-02-28 07:58:09 +08:00
|
|
|
</code>
|
|
|
|
|
</p>
|
|
|
|
|
|
|
|
|
|
</body>
|
|
|
|
|
</html>
|
2021-05-25 03:59:03 +08:00
|
|
|
|
2021-02-28 07:58:09 +08:00
|
|
|
`, mKeyStr)))
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// RegistrationHandler handles the actual registration process of a machine
|
|
|
|
|
// Endpoint /machine/:id
|
2020-06-21 18:32:08 +08:00
|
|
|
func (h *Headscale) RegistrationHandler(c *gin.Context) {
|
2021-02-22 06:54:15 +08:00
|
|
|
body, _ := io.ReadAll(c.Request.Body)
|
2020-06-21 18:32:08 +08:00
|
|
|
mKeyStr := c.Param("id")
|
2021-06-26 00:57:08 +08:00
|
|
|
mKey, err := wgkey.ParseHex(mKeyStr)
|
2020-06-21 18:32:08 +08:00
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot parse machine key")
|
2021-10-10 17:22:42 +08:00
|
|
|
machineRegistrations.WithLabelValues("unknown", "web", "error", "unknown").Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.String(http.StatusInternalServerError, "Sad!")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
req := tailcfg.RegisterRequest{}
|
|
|
|
|
err = decode(body, &req, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot decode message")
|
2021-10-10 17:22:42 +08:00
|
|
|
machineRegistrations.WithLabelValues("unknown", "web", "error", "unknown").Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.String(http.StatusInternalServerError, "Very sad!")
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-05-06 06:59:26 +08:00
|
|
|
|
2021-08-19 06:24:22 +08:00
|
|
|
now := time.Now().UTC()
|
2021-10-10 17:22:42 +08:00
|
|
|
m, err := h.GetMachineByMachineKey(mKey.HexString())
|
|
|
|
|
if errors.Is(err, gorm.ErrRecordNotFound) {
|
2021-08-06 03:57:47 +08:00
|
|
|
log.Info().Str("machine", req.Hostinfo.Hostname).Msg("New machine")
|
2021-10-10 17:22:42 +08:00
|
|
|
newMachine := Machine{
|
|
|
|
|
Expiry: &time.Time{},
|
|
|
|
|
MachineKey: mKey.HexString(),
|
|
|
|
|
Name: req.Hostinfo.Hostname,
|
2021-06-05 18:13:55 +08:00
|
|
|
}
|
2021-10-10 17:22:42 +08:00
|
|
|
if err := h.db.Create(&newMachine).Error; err != nil {
|
2021-08-06 01:16:21 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:16:21 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Could not create row")
|
2021-10-10 17:22:42 +08:00
|
|
|
machineRegistrations.WithLabelValues("unknown", "web", "error", m.Namespace.Name).Inc()
|
2021-06-05 18:13:55 +08:00
|
|
|
return
|
|
|
|
|
}
|
2021-10-10 17:22:42 +08:00
|
|
|
m = &newMachine
|
2021-06-05 18:13:55 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if !m.Registered && req.Auth.AuthKey != "" {
|
2021-10-10 17:22:42 +08:00
|
|
|
h.handleAuthKey(c, h.db, mKey, req, *m)
|
2020-06-21 18:32:08 +08:00
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2021-06-05 18:13:55 +08:00
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
// We have the updated key!
|
2021-06-26 00:57:08 +08:00
|
|
|
if m.NodeKey == wgkey.Key(req.NodeKey).HexString() {
|
2021-10-08 17:43:52 +08:00
|
|
|
|
2021-10-29 21:35:07 +08:00
|
|
|
// The client sends an Expiry in the past if the client is requesting to expire the key (aka logout)
|
|
|
|
|
// https://github.com/tailscale/tailscale/blob/main/tailcfg/tailcfg.go#L648
|
2021-10-08 17:43:52 +08:00
|
|
|
if !req.Expiry.IsZero() && req.Expiry.UTC().Before(now) {
|
2021-10-10 17:22:42 +08:00
|
|
|
log.Info().
|
2021-10-08 17:43:52 +08:00
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Str("machine", m.Name).
|
|
|
|
|
Msg("Client requested logout")
|
|
|
|
|
|
2021-10-10 17:22:42 +08:00
|
|
|
m.Expiry = &req.Expiry // save the expiry so that the machine is marked as expired
|
2021-10-08 17:43:52 +08:00
|
|
|
h.db.Save(&m)
|
|
|
|
|
|
|
|
|
|
resp.AuthURL = ""
|
|
|
|
|
resp.MachineAuthorized = false
|
|
|
|
|
resp.User = *m.Namespace.toUser()
|
|
|
|
|
respBody, err := encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
|
|
|
|
c.String(http.StatusInternalServerError, "")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if m.Registered && m.Expiry.UTC().After(now) {
|
2021-10-10 17:22:42 +08:00
|
|
|
// The machine registration is valid, respond with redirect to /map
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 06:21:34 +08:00
|
|
|
Msg("Client is registered and we have the current NodeKey. All clear to /map")
|
2021-08-06 01:11:26 +08:00
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
resp.AuthURL = ""
|
2021-05-07 05:25:40 +08:00
|
|
|
resp.MachineAuthorized = true
|
2021-06-05 18:13:55 +08:00
|
|
|
resp.User = *m.Namespace.toUser()
|
2021-10-15 23:09:55 +08:00
|
|
|
resp.Login = *m.Namespace.toLogin()
|
|
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
respBody, err := encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("update", "web", "error", m.Namespace.Name).Inc()
|
2021-06-05 18:13:55 +08:00
|
|
|
c.String(http.StatusInternalServerError, "")
|
2020-06-21 18:32:08 +08:00
|
|
|
return
|
|
|
|
|
}
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("update", "web", "success", m.Namespace.Name).Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2021-10-10 17:22:42 +08:00
|
|
|
// The client has registered before, but has expired
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Str("machine", m.Name).
|
2021-10-10 17:22:42 +08:00
|
|
|
Msg("Machine registration has expired. Sending a authurl to register")
|
2021-09-26 16:53:05 +08:00
|
|
|
|
2021-10-19 03:27:52 +08:00
|
|
|
if h.cfg.OIDC.Issuer != "" {
|
2021-10-08 17:43:52 +08:00
|
|
|
resp.AuthURL = fmt.Sprintf("%s/oidc/register/%s",
|
|
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), mKey.HexString())
|
2021-09-26 16:53:05 +08:00
|
|
|
} else {
|
|
|
|
|
resp.AuthURL = fmt.Sprintf("%s/register?key=%s",
|
2021-10-08 15:26:31 +08:00
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), mKey.HexString())
|
2021-09-26 16:53:05 +08:00
|
|
|
}
|
2021-10-08 17:43:52 +08:00
|
|
|
|
2021-10-29 21:35:07 +08:00
|
|
|
// When a client connects, it may request a specific expiry time in its
|
|
|
|
|
// RegisterRequest (https://github.com/tailscale/tailscale/blob/main/tailcfg/tailcfg.go#L634)
|
2021-10-30 23:33:01 +08:00
|
|
|
// RequestedExpiry is used to store the clients requested expiry time since the authentication flow is broken
|
2021-10-29 21:35:07 +08:00
|
|
|
// into two steps (which cant pass arbitrary data between them easily) and needs to be
|
|
|
|
|
// retrieved again after the user has authenticated. After the authentication flow
|
|
|
|
|
// completes, RequestedExpiry is copied into Expiry.
|
2021-10-30 23:33:01 +08:00
|
|
|
m.RequestedExpiry = &req.Expiry
|
2021-10-29 21:35:07 +08:00
|
|
|
|
2021-10-08 17:43:52 +08:00
|
|
|
h.db.Save(&m)
|
|
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
respBody, err := encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "web", "error", m.Namespace.Name).Inc()
|
2021-06-05 18:13:55 +08:00
|
|
|
c.String(http.StatusInternalServerError, "")
|
2020-06-21 18:32:08 +08:00
|
|
|
return
|
|
|
|
|
}
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "web", "success", m.Namespace.Name).Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2021-10-08 17:43:52 +08:00
|
|
|
// The NodeKey we have matches OldNodeKey, which means this is a refresh after a key expiration
|
|
|
|
|
if m.NodeKey == wgkey.Key(req.OldNodeKey).HexString() && m.Expiry.UTC().After(now) {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("We have the OldNodeKey in the database. This is a key refresh")
|
2021-06-26 00:57:08 +08:00
|
|
|
m.NodeKey = wgkey.Key(req.NodeKey).HexString()
|
2021-07-05 03:40:46 +08:00
|
|
|
h.db.Save(&m)
|
2021-06-05 18:13:55 +08:00
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
resp.AuthURL = ""
|
2021-02-28 07:58:09 +08:00
|
|
|
resp.User = *m.Namespace.toUser()
|
2020-06-21 18:32:08 +08:00
|
|
|
respBody, err := encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2020-06-21 18:32:08 +08:00
|
|
|
c.String(http.StatusInternalServerError, "Extremely sad!")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2021-10-10 17:22:42 +08:00
|
|
|
// The machine registration is new, redirect the client to the registration URL
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("The node is sending us a new NodeKey, sending auth url")
|
2021-10-19 03:27:52 +08:00
|
|
|
if h.cfg.OIDC.Issuer != "" {
|
2021-10-08 15:26:31 +08:00
|
|
|
resp.AuthURL = fmt.Sprintf("%s/oidc/register/%s", strings.TrimSuffix(h.cfg.ServerURL, "/"), mKey.HexString())
|
2021-09-26 16:53:05 +08:00
|
|
|
} else {
|
|
|
|
|
resp.AuthURL = fmt.Sprintf("%s/register?key=%s",
|
2021-10-08 15:26:31 +08:00
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), mKey.HexString())
|
2021-09-26 16:53:05 +08:00
|
|
|
}
|
2021-10-08 17:43:52 +08:00
|
|
|
|
2021-10-30 23:33:01 +08:00
|
|
|
// save the requested expiry time for retrieval later in the authentication flow
|
|
|
|
|
m.RequestedExpiry = &req.Expiry
|
2021-10-10 17:22:42 +08:00
|
|
|
m.NodeKey = wgkey.Key(req.NodeKey).HexString() // save the NodeKey
|
2021-10-08 17:43:52 +08:00
|
|
|
h.db.Save(&m)
|
|
|
|
|
|
2021-06-05 18:13:55 +08:00
|
|
|
respBody, err := encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("handler", "Registration").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-06-05 18:13:55 +08:00
|
|
|
c.String(http.StatusInternalServerError, "")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
2020-06-21 18:32:08 +08:00
|
|
|
}
|
|
|
|
|
|
2021-10-05 01:39:01 +08:00
|
|
|
func (h *Headscale) getMapResponse(mKey wgkey.Key, req tailcfg.MapRequest, m *Machine) ([]byte, error) {
|
2021-08-06 04:47:06 +08:00
|
|
|
log.Trace().
|
|
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Str("machine", req.Hostinfo.Hostname).
|
|
|
|
|
Msg("Creating Map response")
|
2021-10-05 05:49:16 +08:00
|
|
|
node, err := m.toNode(h.cfg.BaseDomain, h.cfg.DNSConfig, true)
|
2020-06-21 18:32:08 +08:00
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "getMapResponse").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot convert to node")
|
2020-06-21 18:32:08 +08:00
|
|
|
return nil, err
|
|
|
|
|
}
|
2021-10-03 04:58:28 +08:00
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
peers, err := h.getPeers(m)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "getMapResponse").
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot fetch peers")
|
2020-06-21 18:32:08 +08:00
|
|
|
return nil, err
|
|
|
|
|
}
|
2021-07-11 22:39:19 +08:00
|
|
|
|
2021-10-17 18:07:01 +08:00
|
|
|
profiles := getMapResponseUserProfiles(*m, peers)
|
2021-07-11 22:39:19 +08:00
|
|
|
|
2021-10-05 05:49:16 +08:00
|
|
|
nodePeers, err := peers.toNodes(h.cfg.BaseDomain, h.cfg.DNSConfig, true)
|
2021-10-03 05:03:34 +08:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to convert peers to Tailscale nodes")
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
|
2021-10-17 18:10:03 +08:00
|
|
|
dnsConfig, err := getMapResponseDNSConfig(h.cfg.DNSConfig, h.cfg.BaseDomain, *m, peers)
|
2021-10-17 17:57:53 +08:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed generate the DNSConfig")
|
|
|
|
|
return nil, err
|
2021-10-02 18:13:19 +08:00
|
|
|
}
|
|
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
resp := tailcfg.MapResponse{
|
2021-10-02 17:20:42 +08:00
|
|
|
KeepAlive: false,
|
|
|
|
|
Node: node,
|
2021-10-05 05:43:42 +08:00
|
|
|
Peers: nodePeers,
|
2021-10-02 18:13:19 +08:00
|
|
|
DNSConfig: dnsConfig,
|
2021-10-02 17:20:42 +08:00
|
|
|
Domain: h.cfg.BaseDomain,
|
2021-11-05 06:18:06 +08:00
|
|
|
PacketFilter: h.aclRules,
|
2021-10-23 00:56:00 +08:00
|
|
|
DERPMap: h.DERPMap,
|
2021-10-17 18:07:01 +08:00
|
|
|
UserProfiles: profiles,
|
2021-02-24 07:31:58 +08:00
|
|
|
}
|
2021-10-17 18:07:01 +08:00
|
|
|
|
2021-08-13 17:33:19 +08:00
|
|
|
log.Trace().
|
|
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Str("machine", req.Hostinfo.Hostname).
|
2021-10-06 00:51:42 +08:00
|
|
|
// Interface("payload", resp).
|
2021-08-13 17:33:19 +08:00
|
|
|
Msgf("Generated map response: %s", tailMapResponseToString(resp))
|
2020-06-21 18:32:08 +08:00
|
|
|
|
|
|
|
|
var respBody []byte
|
|
|
|
|
if req.Compress == "zstd" {
|
|
|
|
|
src, _ := json.Marshal(resp)
|
2021-08-13 17:33:19 +08:00
|
|
|
|
2020-06-21 18:32:08 +08:00
|
|
|
encoder, _ := zstd.NewWriter(nil)
|
|
|
|
|
srcCompressed := encoder.EncodeAll(src, nil)
|
|
|
|
|
respBody, err = encodeMsg(srcCompressed, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
respBody, err = encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// declare the incoming size on the first 4 bytes
|
|
|
|
|
data := make([]byte, 4)
|
|
|
|
|
binary.LittleEndian.PutUint32(data, uint32(len(respBody)))
|
|
|
|
|
data = append(data, respBody...)
|
2021-10-05 01:39:01 +08:00
|
|
|
return data, nil
|
2020-06-21 18:32:08 +08:00
|
|
|
}
|
|
|
|
|
|
2021-10-05 01:39:01 +08:00
|
|
|
func (h *Headscale) getMapKeepAliveResponse(mKey wgkey.Key, req tailcfg.MapRequest, m *Machine) ([]byte, error) {
|
2020-06-21 18:32:08 +08:00
|
|
|
resp := tailcfg.MapResponse{
|
|
|
|
|
KeepAlive: true,
|
|
|
|
|
}
|
|
|
|
|
var respBody []byte
|
|
|
|
|
var err error
|
|
|
|
|
if req.Compress == "zstd" {
|
|
|
|
|
src, _ := json.Marshal(resp)
|
|
|
|
|
encoder, _ := zstd.NewWriter(nil)
|
|
|
|
|
srcCompressed := encoder.EncodeAll(src, nil)
|
|
|
|
|
respBody, err = encodeMsg(srcCompressed, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
respBody, err = encode(resp, &mKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
data := make([]byte, 4)
|
|
|
|
|
binary.LittleEndian.PutUint32(data, uint32(len(respBody)))
|
|
|
|
|
data = append(data, respBody...)
|
2021-10-05 01:39:01 +08:00
|
|
|
return data, nil
|
2020-06-21 18:32:08 +08:00
|
|
|
}
|
|
|
|
|
|
2021-10-23 00:56:00 +08:00
|
|
|
func (h *Headscale) handleAuthKey(
|
|
|
|
|
c *gin.Context,
|
|
|
|
|
db *gorm.DB,
|
|
|
|
|
idKey wgkey.Key,
|
|
|
|
|
req tailcfg.RegisterRequest,
|
|
|
|
|
m Machine,
|
|
|
|
|
) {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", req.Hostinfo.Hostname).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msgf("Processing auth key for %s", req.Hostinfo.Hostname)
|
2021-05-06 06:59:26 +08:00
|
|
|
resp := tailcfg.RegisterResponse{}
|
2021-06-05 18:13:55 +08:00
|
|
|
pak, err := h.checkKeyValidity(req.Auth.AuthKey)
|
|
|
|
|
if err != nil {
|
2021-10-05 00:03:44 +08:00
|
|
|
log.Error().
|
|
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed authentication via AuthKey")
|
2021-06-05 18:13:55 +08:00
|
|
|
resp.MachineAuthorized = false
|
2021-05-06 06:59:26 +08:00
|
|
|
respBody, err := encode(resp, &idKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-06-05 18:13:55 +08:00
|
|
|
c.String(http.StatusInternalServerError, "")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "authkey", "error", m.Namespace.Name).Inc()
|
2021-05-06 06:59:26 +08:00
|
|
|
return
|
|
|
|
|
}
|
2021-10-05 00:28:07 +08:00
|
|
|
c.Data(401, "application/json; charset=utf-8", respBody)
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("Failed authentication via AuthKey")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "authkey", "error", m.Namespace.Name).Inc()
|
2021-06-05 18:13:55 +08:00
|
|
|
return
|
|
|
|
|
}
|
2021-08-06 01:11:26 +08:00
|
|
|
|
|
|
|
|
log.Debug().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("Authentication key was valid, proceeding to acquire an IP address")
|
2021-06-05 18:13:55 +08:00
|
|
|
ip, err := h.getAvailableIP()
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("Failed to find an available IP")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "authkey", "error", m.Namespace.Name).Inc()
|
2021-05-06 06:59:26 +08:00
|
|
|
return
|
2020-06-21 18:32:08 +08:00
|
|
|
}
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Info().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
|
|
|
|
Str("ip", ip.String()).
|
2021-08-19 06:24:22 +08:00
|
|
|
Msgf("Assigning %s to %s", ip, m.Name)
|
2020-06-21 18:32:08 +08:00
|
|
|
|
2021-06-05 18:13:55 +08:00
|
|
|
m.AuthKeyID = uint(pak.ID)
|
|
|
|
|
m.IPAddress = ip.String()
|
|
|
|
|
m.NamespaceID = pak.NamespaceID
|
2021-06-26 00:57:08 +08:00
|
|
|
m.NodeKey = wgkey.Key(req.NodeKey).HexString() // we update it just in case
|
2021-06-05 18:13:55 +08:00
|
|
|
m.Registered = true
|
|
|
|
|
m.RegisterMethod = "authKey"
|
|
|
|
|
db.Save(&m)
|
2021-05-06 06:59:26 +08:00
|
|
|
|
2021-10-14 04:51:55 +08:00
|
|
|
pak.Used = true
|
2021-10-14 00:13:26 +08:00
|
|
|
db.Save(&pak)
|
2021-10-10 17:22:42 +08:00
|
|
|
|
2021-06-05 18:13:55 +08:00
|
|
|
resp.MachineAuthorized = true
|
|
|
|
|
resp.User = *pak.Namespace.toUser()
|
2020-06-21 18:32:08 +08:00
|
|
|
respBody, err := encode(resp, &idKey, h.privateKey)
|
|
|
|
|
if err != nil {
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Error().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
2021-08-06 01:11:26 +08:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "authkey", "error", m.Namespace.Name).Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.String(http.StatusInternalServerError, "Extremely sad!")
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-10-05 00:28:07 +08:00
|
|
|
machineRegistrations.WithLabelValues("new", "authkey", "success", m.Namespace.Name).Inc()
|
2020-06-21 18:32:08 +08:00
|
|
|
c.Data(200, "application/json; charset=utf-8", respBody)
|
2021-08-06 01:11:26 +08:00
|
|
|
log.Info().
|
2021-08-06 03:57:47 +08:00
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", m.Name).
|
|
|
|
|
Str("ip", ip.String()).
|
2021-08-06 01:11:26 +08:00
|
|
|
Msg("Successfully authenticated via AuthKey")
|
2020-06-21 18:32:08 +08:00
|
|
|
}
|
