2020-06-21 12:32:08 +02:00
|
|
|
package headscale
|
|
|
|
|
|
|
|
|
|
import (
|
2021-12-22 19:43:53 -07:00
|
|
|
"bytes"
|
2020-06-21 12:32:08 +02:00
|
|
|
"encoding/binary"
|
|
|
|
|
"encoding/json"
|
2021-06-24 15:44:19 +02:00
|
|
|
"errors"
|
2020-06-21 12:32:08 +02:00
|
|
|
"fmt"
|
2021-12-22 19:43:53 -07:00
|
|
|
"html/template"
|
2020-06-21 12:32:08 +02:00
|
|
|
"io"
|
|
|
|
|
"net/http"
|
2021-10-08 17:43:52 +08:00
|
|
|
"strings"
|
2020-06-21 12:32:08 +02:00
|
|
|
"time"
|
|
|
|
|
|
2022-06-20 12:30:41 +02:00
|
|
|
"github.com/gorilla/mux"
|
2020-06-21 12:32:08 +02:00
|
|
|
"github.com/klauspost/compress/zstd"
|
2021-11-13 08:39:04 +00:00
|
|
|
"github.com/rs/zerolog/log"
|
2021-06-24 15:44:19 +02:00
|
|
|
"gorm.io/gorm"
|
2020-06-21 12:32:08 +02:00
|
|
|
"tailscale.com/tailcfg"
|
2021-11-26 23:30:42 +00:00
|
|
|
"tailscale.com/types/key"
|
2020-06-21 12:32:08 +02:00
|
|
|
)
|
|
|
|
|
|
2021-11-18 08:49:55 +00:00
|
|
|
const (
|
2022-08-12 09:36:17 +02:00
|
|
|
// TODO(juan): remove this once https://github.com/juanfont/headscale/issues/727 is fixed.
|
2022-08-12 09:02:58 +02:00
|
|
|
registrationHoldoff = time.Second * 5
|
2021-11-22 19:32:52 +00:00
|
|
|
reservedResponseHeaderSize = 4
|
2022-02-27 18:48:12 +01:00
|
|
|
RegisterMethodAuthKey = "authkey"
|
2021-11-22 19:32:52 +00:00
|
|
|
RegisterMethodOIDC = "oidc"
|
|
|
|
|
RegisterMethodCLI = "cli"
|
|
|
|
|
ErrRegisterMethodCLIDoesNotSupportExpire = Error(
|
|
|
|
|
"machines registered with CLI does not support expire",
|
|
|
|
|
)
|
2021-11-18 08:49:55 +00:00
|
|
|
)
|
2021-11-14 18:31:51 +01:00
|
|
|
|
2022-07-06 13:39:10 +02:00
|
|
|
func (h *Headscale) HealthHandler(
|
|
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
|
|
|
|
) {
|
|
|
|
|
respond := func(err error) {
|
|
|
|
|
writer.Header().Set("Content-Type", "application/health+json; charset=utf-8")
|
|
|
|
|
|
|
|
|
|
res := struct {
|
|
|
|
|
Status string `json:"status"`
|
|
|
|
|
}{
|
|
|
|
|
Status: "pass",
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
|
writer.WriteHeader(http.StatusInternalServerError)
|
|
|
|
|
log.Error().Caller().Err(err).Msg("health check failed")
|
|
|
|
|
res.Status = "fail"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
buf, err := json.Marshal(res)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().Caller().Err(err).Msg("marshal failed")
|
|
|
|
|
}
|
|
|
|
|
_, err = writer.Write(buf)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().Caller().Err(err).Msg("write failed")
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if err := h.pingDB(); err != nil {
|
|
|
|
|
respond(err)
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
respond(nil)
|
|
|
|
|
}
|
|
|
|
|
|
2021-02-28 00:58:09 +01:00
|
|
|
// KeyHandler provides the Headscale pub key
|
2021-11-13 08:39:04 +00:00
|
|
|
// Listens in /key.
|
2022-06-17 16:48:04 +02:00
|
|
|
func (h *Headscale) KeyHandler(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2022-06-17 16:48:04 +02:00
|
|
|
) {
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err := writer.Write([]byte(MachinePublicKeyStripPrefix(h.privateKey.Public())))
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
|
|
|
|
|
2021-12-22 19:43:53 -07:00
|
|
|
type registerWebAPITemplateConfig struct {
|
|
|
|
|
Key string
|
|
|
|
|
}
|
2021-02-28 00:58:09 +01:00
|
|
|
|
2021-12-22 19:43:53 -07:00
|
|
|
var registerWebAPITemplate = template.Must(
|
2022-03-08 18:34:46 +10:00
|
|
|
template.New("registerweb").Parse(`
|
|
|
|
|
<html>
|
|
|
|
|
<head>
|
|
|
|
|
<title>Registration - Headscale</title>
|
|
|
|
|
</head>
|
2021-02-28 00:58:09 +01:00
|
|
|
<body>
|
2022-03-08 18:34:46 +10:00
|
|
|
<h1>headscale</h1>
|
|
|
|
|
<h2>Machine registration</h2>
|
|
|
|
|
<p>
|
|
|
|
|
Run the command below in the headscale server to add this machine to your network:
|
|
|
|
|
</p>
|
|
|
|
|
<pre><code>headscale -n NAMESPACE nodes register --key {{.Key}}</code></pre>
|
2021-02-28 00:58:09 +01:00
|
|
|
</body>
|
2022-03-08 18:34:46 +10:00
|
|
|
</html>
|
|
|
|
|
`))
|
2021-12-22 19:43:53 -07:00
|
|
|
|
|
|
|
|
// RegisterWebAPI shows a simple message in the browser to point to the CLI
|
2022-08-11 12:11:02 +02:00
|
|
|
// Listens in /register/:nkey.
|
2022-08-11 12:16:50 +02:00
|
|
|
//
|
|
|
|
|
// This is not part of the Tailscale control API, as we could send whatever URL
|
|
|
|
|
// in the RegisterResponse.AuthURL field.
|
2022-06-17 16:48:04 +02:00
|
|
|
func (h *Headscale) RegisterWebAPI(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2022-06-17 16:48:04 +02:00
|
|
|
) {
|
2022-08-11 12:11:02 +02:00
|
|
|
vars := mux.Vars(req)
|
|
|
|
|
nodeKeyStr, ok := vars["nkey"]
|
|
|
|
|
if !ok || nodeKeyStr == "" {
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusBadRequest)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err := writer.Write([]byte("Wrong params"))
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-12-22 19:43:53 -07:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var content bytes.Buffer
|
|
|
|
|
if err := registerWebAPITemplate.Execute(&content, registerWebAPITemplateConfig{
|
2022-08-10 15:35:26 +02:00
|
|
|
Key: nodeKeyStr,
|
2021-12-22 19:43:53 -07:00
|
|
|
}); err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("func", "RegisterWebAPI").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Could not render register web API template")
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusInternalServerError)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write([]byte("Could not render register web API template"))
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2022-06-26 11:55:37 +02:00
|
|
|
|
|
|
|
|
return
|
2021-12-22 19:43:53 -07:00
|
|
|
}
|
2021-05-24 21:59:03 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "text/html; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err := writer.Write(content.Bytes())
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-02-28 00:58:09 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// RegistrationHandler handles the actual registration process of a machine
|
2022-06-20 12:30:41 +02:00
|
|
|
// Endpoint /machine/:mkey.
|
|
|
|
|
func (h *Headscale) RegistrationHandler(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2022-06-20 12:30:41 +02:00
|
|
|
) {
|
2022-06-26 11:55:37 +02:00
|
|
|
vars := mux.Vars(req)
|
2022-06-20 12:30:41 +02:00
|
|
|
machineKeyStr, ok := vars["mkey"]
|
|
|
|
|
if !ok || machineKeyStr == "" {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("handler", "RegistrationHandler").
|
|
|
|
|
Msg("No machine ID in request")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "No machine ID in request", http.StatusBadRequest)
|
2022-06-20 12:30:41 +02:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
body, _ := io.ReadAll(req.Body)
|
2021-11-26 23:50:42 +00:00
|
|
|
|
|
|
|
|
var machineKey key.MachinePublic
|
2021-11-27 20:25:12 +00:00
|
|
|
err := machineKey.UnmarshalText([]byte(MachinePublicKeyEnsurePrefix(machineKeyStr)))
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot parse machine key")
|
2021-10-10 17:22:42 +08:00
|
|
|
machineRegistrations.WithLabelValues("unknown", "web", "error", "unknown").Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Cannot parse machine key", http.StatusBadRequest)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return
|
|
|
|
|
}
|
2022-06-26 11:55:37 +02:00
|
|
|
registerRequest := tailcfg.RegisterRequest{}
|
|
|
|
|
err = decode(body, ®isterRequest, &machineKey, h.privateKey)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot decode message")
|
2021-10-10 17:22:42 +08:00
|
|
|
machineRegistrations.WithLabelValues("unknown", "web", "error", "unknown").Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Cannot decode message", http.StatusBadRequest)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return
|
|
|
|
|
}
|
2021-05-06 00:59:26 +02:00
|
|
|
|
2021-08-18 23:24:22 +01:00
|
|
|
now := time.Now().UTC()
|
2021-11-26 23:30:42 +00:00
|
|
|
machine, err := h.GetMachineByMachineKey(machineKey)
|
2021-10-10 17:22:42 +08:00
|
|
|
if errors.Is(err, gorm.ErrRecordNotFound) {
|
2022-02-28 08:06:39 +00:00
|
|
|
machineKeyStr := MachinePublicKeyStripPrefix(machineKey)
|
|
|
|
|
|
|
|
|
|
// If the machine has AuthKey set, handle registration via PreAuthKeys
|
2022-06-26 11:55:37 +02:00
|
|
|
if registerRequest.Auth.AuthKey != "" {
|
|
|
|
|
h.handleAuthKey(writer, req, machineKey, registerRequest)
|
2022-02-28 08:06:39 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2022-04-24 21:12:45 +01:00
|
|
|
|
2022-08-12 09:36:17 +02:00
|
|
|
// Check if the node is waiting for interactive login.
|
2022-08-11 12:11:02 +02:00
|
|
|
//
|
|
|
|
|
// TODO(juan): We could use this field to improve our protocol implementation,
|
|
|
|
|
// and hold the request until the client closes it, or the interactive
|
|
|
|
|
// login is completed (i.e., the user registers the machine).
|
|
|
|
|
// This is not implemented yet, as it is no strictly required. The only side-effect
|
|
|
|
|
// is that the client will hammer headscale with requests until it gets a
|
|
|
|
|
// successful RegisterResponse.
|
|
|
|
|
if registerRequest.Followup != "" {
|
|
|
|
|
if _, ok := h.registrationCache.Get(NodePublicKeyStripPrefix(registerRequest.NodeKey)); ok {
|
|
|
|
|
log.Debug().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2022-08-12 09:03:32 +02:00
|
|
|
Str("node_key", registerRequest.NodeKey.ShortString()).
|
|
|
|
|
Str("node_key_old", registerRequest.OldNodeKey.ShortString()).
|
|
|
|
|
Str("follow_up", registerRequest.Followup).
|
2022-08-11 12:11:02 +02:00
|
|
|
Msg("Machine is waiting for interactive login")
|
|
|
|
|
|
2022-08-11 13:37:25 +02:00
|
|
|
ticker := time.NewTicker(registrationHoldoff)
|
|
|
|
|
select {
|
|
|
|
|
case <-req.Context().Done():
|
|
|
|
|
return
|
|
|
|
|
case <-ticker.C:
|
|
|
|
|
h.handleMachineRegistrationNew(writer, req, machineKey, registerRequest)
|
2022-08-11 12:11:02 +02:00
|
|
|
|
2022-08-11 13:37:25 +02:00
|
|
|
return
|
|
|
|
|
}
|
2022-08-11 12:11:02 +02:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
log.Info().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2022-08-12 09:03:11 +02:00
|
|
|
Str("node_key", registerRequest.NodeKey.ShortString()).
|
|
|
|
|
Str("node_key_old", registerRequest.OldNodeKey.ShortString()).
|
|
|
|
|
Str("follow_up", registerRequest.Followup).
|
2022-08-11 12:11:02 +02:00
|
|
|
Msg("New machine not yet in the database")
|
|
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
givenName, err := h.GenerateGivenName(registerRequest.Hostinfo.Hostname)
|
2022-03-07 22:46:29 +01:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("func", "RegistrationHandler").
|
2022-06-26 11:55:37 +02:00
|
|
|
Str("hostinfo.name", registerRequest.Hostinfo.Hostname).
|
2022-03-07 22:46:29 +01:00
|
|
|
Err(err)
|
2022-03-07 23:20:30 +01:00
|
|
|
|
2022-03-07 22:46:29 +01:00
|
|
|
return
|
|
|
|
|
}
|
2022-02-28 08:06:39 +00:00
|
|
|
|
|
|
|
|
// The machine did not have a key to authenticate, which means
|
|
|
|
|
// that we rely on a method that calls back some how (OpenID or CLI)
|
|
|
|
|
// We create the machine and then keep it around until a callback
|
|
|
|
|
// happens
|
2021-10-10 17:22:42 +08:00
|
|
|
newMachine := Machine{
|
2022-02-28 08:06:39 +00:00
|
|
|
MachineKey: machineKeyStr,
|
2022-06-26 11:55:37 +02:00
|
|
|
Hostname: registerRequest.Hostinfo.Hostname,
|
2022-05-16 20:32:37 +02:00
|
|
|
GivenName: givenName,
|
2022-06-26 11:55:37 +02:00
|
|
|
NodeKey: NodePublicKeyStripPrefix(registerRequest.NodeKey),
|
2022-02-28 08:06:39 +00:00
|
|
|
LastSeen: &now,
|
2022-03-02 07:15:20 +00:00
|
|
|
Expiry: &time.Time{},
|
2021-06-05 12:13:55 +02:00
|
|
|
}
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
if !registerRequest.Expiry.IsZero() {
|
2022-02-28 22:42:30 +00:00
|
|
|
log.Trace().
|
|
|
|
|
Caller().
|
2022-06-26 11:55:37 +02:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
|
|
|
|
Time("expiry", registerRequest.Expiry).
|
2022-02-28 22:42:30 +00:00
|
|
|
Msg("Non-zero expiry time requested")
|
2022-06-26 11:55:37 +02:00
|
|
|
newMachine.Expiry = ®isterRequest.Expiry
|
2022-02-28 22:42:30 +00:00
|
|
|
}
|
|
|
|
|
|
2022-02-28 08:06:39 +00:00
|
|
|
h.registrationCache.Set(
|
2022-08-10 15:35:26 +02:00
|
|
|
newMachine.NodeKey,
|
2022-02-28 08:06:39 +00:00
|
|
|
newMachine,
|
2022-02-28 22:42:30 +00:00
|
|
|
registerCacheExpiration,
|
2022-02-28 08:06:39 +00:00
|
|
|
)
|
|
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
h.handleMachineRegistrationNew(writer, req, machineKey, registerRequest)
|
2022-02-28 16:34:50 +00:00
|
|
|
|
2022-02-28 08:06:39 +00:00
|
|
|
return
|
2021-06-05 12:13:55 +02:00
|
|
|
}
|
|
|
|
|
|
2022-02-28 08:06:39 +00:00
|
|
|
// The machine is already registered, so we need to pass through reauth or key update.
|
|
|
|
|
if machine != nil {
|
2021-11-21 13:59:24 +00:00
|
|
|
// If the NodeKey stored in headscale is the same as the key presented in a registration
|
|
|
|
|
// request, then we have a node that is either:
|
|
|
|
|
// - Trying to log out (sending a expiry in the past)
|
|
|
|
|
// - A valid, registered machine, looking for the node map
|
|
|
|
|
// - Expired machine wanting to reauthenticate
|
2022-06-26 11:55:37 +02:00
|
|
|
if machine.NodeKey == NodePublicKeyStripPrefix(registerRequest.NodeKey) {
|
2021-11-21 13:59:24 +00: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
|
2022-08-04 10:47:00 +02:00
|
|
|
if !registerRequest.Expiry.IsZero() &&
|
|
|
|
|
registerRequest.Expiry.UTC().Before(now) {
|
2022-06-26 11:55:37 +02:00
|
|
|
h.handleMachineLogOut(writer, req, machineKey, *machine)
|
2021-11-21 13:59:24 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// If machine is not expired, and is register, we have a already accepted this machine,
|
|
|
|
|
// let it proceed with a valid registration
|
|
|
|
|
if !machine.isExpired() {
|
2022-06-26 11:55:37 +02:00
|
|
|
h.handleMachineValidRegistration(writer, req, machineKey, *machine)
|
2021-11-21 13:59:24 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-10-08 17:43:52 +08:00
|
|
|
}
|
|
|
|
|
|
2021-11-21 13:59:24 +00:00
|
|
|
// The NodeKey we have matches OldNodeKey, which means this is a refresh after a key expiration
|
2022-06-26 11:55:37 +02:00
|
|
|
if machine.NodeKey == NodePublicKeyStripPrefix(registerRequest.OldNodeKey) &&
|
2021-11-21 13:59:24 +00:00
|
|
|
!machine.isExpired() {
|
2022-08-04 10:47:00 +02:00
|
|
|
h.handleMachineRefreshKey(
|
|
|
|
|
writer,
|
|
|
|
|
req,
|
|
|
|
|
machineKey,
|
|
|
|
|
registerRequest,
|
|
|
|
|
*machine,
|
|
|
|
|
)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return
|
|
|
|
|
}
|
2021-11-21 21:14:13 +00:00
|
|
|
|
|
|
|
|
// The machine has expired
|
2022-06-26 11:55:37 +02:00
|
|
|
h.handleMachineExpired(writer, req, machineKey, registerRequest, *machine)
|
2021-11-21 21:14:13 +00:00
|
|
|
|
|
|
|
|
return
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2021-11-13 08:36:45 +00:00
|
|
|
func (h *Headscale) getMapResponse(
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2022-06-26 11:55:37 +02:00
|
|
|
mapRequest tailcfg.MapRequest,
|
2021-11-14 20:32:03 +01:00
|
|
|
machine *Machine,
|
2021-11-13 08:36:45 +00:00
|
|
|
) ([]byte, error) {
|
2021-08-05 21:47:06 +01:00
|
|
|
log.Trace().
|
|
|
|
|
Str("func", "getMapResponse").
|
2022-06-26 11:55:37 +02:00
|
|
|
Str("machine", mapRequest.Hostinfo.Hostname).
|
2021-08-05 21:47:06 +01:00
|
|
|
Msg("Creating Map response")
|
2021-11-14 20:32:03 +01:00
|
|
|
node, err := machine.toNode(h.cfg.BaseDomain, h.cfg.DNSConfig, true)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "getMapResponse").
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot convert to node")
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return nil, err
|
|
|
|
|
}
|
2021-10-02 21:58:28 +01:00
|
|
|
|
2021-11-22 19:51:16 +00:00
|
|
|
peers, err := h.getValidPeers(machine)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "getMapResponse").
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot fetch peers")
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return nil, err
|
|
|
|
|
}
|
2021-07-11 16:39:19 +02:00
|
|
|
|
2021-11-14 20:32:03 +01:00
|
|
|
profiles := getMapResponseUserProfiles(*machine, peers)
|
2021-07-11 16:39:19 +02:00
|
|
|
|
2021-10-04 23:49:16 +02:00
|
|
|
nodePeers, err := peers.toNodes(h.cfg.BaseDomain, h.cfg.DNSConfig, true)
|
2021-10-02 22:03:34 +01:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-10-02 22:03:34 +01:00
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to convert peers to Tailscale nodes")
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2021-10-02 22:03:34 +01:00
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
|
2021-11-14 18:03:21 +01:00
|
|
|
dnsConfig := getMapResponseDNSConfig(
|
2021-11-13 08:36:45 +00:00
|
|
|
h.cfg.DNSConfig,
|
|
|
|
|
h.cfg.BaseDomain,
|
2021-11-14 20:32:03 +01:00
|
|
|
*machine,
|
2021-11-13 08:36:45 +00:00
|
|
|
peers,
|
|
|
|
|
)
|
2021-10-02 12:13:19 +02:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
resp := tailcfg.MapResponse{
|
2021-10-02 11:20:42 +02:00
|
|
|
KeepAlive: false,
|
|
|
|
|
Node: node,
|
2021-10-04 23:43:42 +02:00
|
|
|
Peers: nodePeers,
|
2021-10-02 12:13:19 +02:00
|
|
|
DNSConfig: dnsConfig,
|
2021-10-02 11:20:42 +02:00
|
|
|
Domain: h.cfg.BaseDomain,
|
2021-11-04 22:18:06 +00:00
|
|
|
PacketFilter: h.aclRules,
|
2021-10-22 16:56:00 +00:00
|
|
|
DERPMap: h.DERPMap,
|
2021-10-17 12:07:01 +02:00
|
|
|
UserProfiles: profiles,
|
2022-05-30 14:52:50 +02:00
|
|
|
Debug: &tailcfg.Debug{
|
2022-06-09 21:20:11 +02:00
|
|
|
DisableLogTail: !h.cfg.LogTail.Enabled,
|
|
|
|
|
RandomizeClientPort: h.cfg.RandomizeClientPort,
|
2022-05-30 14:52:50 +02:00
|
|
|
},
|
2021-02-24 00:31:58 +01:00
|
|
|
}
|
2021-10-17 12:07:01 +02:00
|
|
|
|
2021-08-13 10:33:19 +01:00
|
|
|
log.Trace().
|
|
|
|
|
Str("func", "getMapResponse").
|
2022-06-26 11:55:37 +02:00
|
|
|
Str("machine", mapRequest.Hostinfo.Hostname).
|
2021-10-05 16:51:42 +00:00
|
|
|
// Interface("payload", resp).
|
2021-08-13 10:33:19 +01:00
|
|
|
Msgf("Generated map response: %s", tailMapResponseToString(resp))
|
2020-06-21 12:32:08 +02:00
|
|
|
|
|
|
|
|
var respBody []byte
|
2022-06-26 11:55:37 +02:00
|
|
|
if mapRequest.Compress == "zstd" {
|
2022-02-14 15:26:54 +01:00
|
|
|
src, err := json.Marshal(resp)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("func", "getMapResponse").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to marshal response for the client")
|
|
|
|
|
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
2021-08-13 10:33:19 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
encoder, _ := zstd.NewWriter(nil)
|
|
|
|
|
srcCompressed := encoder.EncodeAll(src, nil)
|
2021-11-26 23:30:42 +00:00
|
|
|
respBody = h.privateKey.SealTo(machineKey, srcCompressed)
|
2020-06-21 12:32:08 +02:00
|
|
|
} else {
|
2021-11-14 20:32:03 +01:00
|
|
|
respBody, err = encode(resp, &machineKey, h.privateKey)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// declare the incoming size on the first 4 bytes
|
2021-11-15 17:24:24 +00:00
|
|
|
data := make([]byte, reservedResponseHeaderSize)
|
2020-06-21 12:32:08 +02:00
|
|
|
binary.LittleEndian.PutUint32(data, uint32(len(respBody)))
|
|
|
|
|
data = append(data, respBody...)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2021-10-04 17:39:01 +00:00
|
|
|
return data, nil
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
|
|
|
|
|
2021-11-13 08:36:45 +00:00
|
|
|
func (h *Headscale) getMapKeepAliveResponse(
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-14 20:32:03 +01:00
|
|
|
mapRequest tailcfg.MapRequest,
|
2021-11-13 08:36:45 +00:00
|
|
|
) ([]byte, error) {
|
2021-11-14 20:32:03 +01:00
|
|
|
mapResponse := tailcfg.MapResponse{
|
2020-06-21 12:32:08 +02:00
|
|
|
KeepAlive: true,
|
|
|
|
|
}
|
|
|
|
|
var respBody []byte
|
|
|
|
|
var err error
|
2021-11-14 20:32:03 +01:00
|
|
|
if mapRequest.Compress == "zstd" {
|
2022-02-14 15:26:54 +01:00
|
|
|
src, err := json.Marshal(mapResponse)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("func", "getMapKeepAliveResponse").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to marshal keepalive response for the client")
|
|
|
|
|
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
2020-06-21 12:32:08 +02:00
|
|
|
encoder, _ := zstd.NewWriter(nil)
|
|
|
|
|
srcCompressed := encoder.EncodeAll(src, nil)
|
2021-11-26 23:30:42 +00:00
|
|
|
respBody = h.privateKey.SealTo(machineKey, srcCompressed)
|
2020-06-21 12:32:08 +02:00
|
|
|
} else {
|
2021-11-14 20:32:03 +01:00
|
|
|
respBody, err = encode(mapResponse, &machineKey, h.privateKey)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
}
|
2021-11-15 17:24:24 +00:00
|
|
|
data := make([]byte, reservedResponseHeaderSize)
|
2020-06-21 12:32:08 +02:00
|
|
|
binary.LittleEndian.PutUint32(data, uint32(len(respBody)))
|
|
|
|
|
data = append(data, respBody...)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2021-10-04 17:39:01 +00:00
|
|
|
return data, nil
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
|
|
|
|
|
2021-11-17 22:39:41 +00:00
|
|
|
func (h *Headscale) handleMachineLogOut(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-17 22:39:41 +00:00
|
|
|
machine Machine,
|
|
|
|
|
) {
|
|
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
log.Info().
|
2022-04-24 20:54:38 +01:00
|
|
|
Str("machine", machine.Hostname).
|
2021-11-17 22:39:41 +00:00
|
|
|
Msg("Client requested logout")
|
|
|
|
|
|
2022-06-26 12:30:52 +02:00
|
|
|
err := h.ExpireMachine(&machine)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("func", "handleMachineLogOut").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to expire machine")
|
|
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
resp.AuthURL = ""
|
|
|
|
|
resp.MachineAuthorized = false
|
|
|
|
|
resp.User = *machine.Namespace.toUser()
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-11-17 22:39:41 +00:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-11-17 22:39:41 +00:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (h *Headscale) handleMachineValidRegistration(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-17 22:39:41 +00:00
|
|
|
machine Machine,
|
|
|
|
|
) {
|
|
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
// The machine registration is valid, respond with redirect to /map
|
|
|
|
|
log.Debug().
|
2022-04-24 20:54:38 +01:00
|
|
|
Str("machine", machine.Hostname).
|
2021-11-17 22:39:41 +00:00
|
|
|
Msg("Client is registered and we have the current NodeKey. All clear to /map")
|
|
|
|
|
|
|
|
|
|
resp.AuthURL = ""
|
|
|
|
|
resp.MachineAuthorized = true
|
|
|
|
|
resp.User = *machine.Namespace.toUser()
|
|
|
|
|
resp.Login = *machine.Namespace.toLogin()
|
|
|
|
|
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-11-17 22:39:41 +00:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-11-17 22:39:41 +00:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
|
|
|
|
machineRegistrations.WithLabelValues("update", "web", "error", machine.Namespace.Name).
|
|
|
|
|
Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
machineRegistrations.WithLabelValues("update", "web", "success", machine.Namespace.Name).
|
|
|
|
|
Inc()
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (h *Headscale) handleMachineExpired(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-24 12:15:55 +00:00
|
|
|
registerRequest tailcfg.RegisterRequest,
|
2021-11-17 22:39:41 +00:00
|
|
|
machine Machine,
|
|
|
|
|
) {
|
|
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
// The client has registered before, but has expired
|
|
|
|
|
log.Debug().
|
2022-04-24 20:54:38 +01:00
|
|
|
Str("machine", machine.Hostname).
|
2021-11-17 22:39:41 +00:00
|
|
|
Msg("Machine registration has expired. Sending a authurl to register")
|
|
|
|
|
|
2021-11-24 12:15:32 +00:00
|
|
|
if registerRequest.Auth.AuthKey != "" {
|
2022-06-26 11:55:37 +02:00
|
|
|
h.handleAuthKey(writer, req, machineKey, registerRequest)
|
2021-11-24 12:15:32 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2021-11-17 22:39:41 +00:00
|
|
|
if h.cfg.OIDC.Issuer != "" {
|
|
|
|
|
resp.AuthURL = fmt.Sprintf("%s/oidc/register/%s",
|
2021-11-26 23:30:42 +00:00
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), machineKey.String())
|
2021-11-17 22:39:41 +00:00
|
|
|
} else {
|
|
|
|
|
resp.AuthURL = fmt.Sprintf("%s/register?key=%s",
|
2021-11-26 23:30:42 +00:00
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), machineKey.String())
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
2021-11-24 12:15:32 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-11-17 22:39:41 +00:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-11-17 22:39:41 +00:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2021-11-22 19:32:11 +00:00
|
|
|
machineRegistrations.WithLabelValues("reauth", "web", "error", machine.Namespace.Name).
|
2021-11-17 22:39:41 +00:00
|
|
|
Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-11-22 19:32:11 +00:00
|
|
|
machineRegistrations.WithLabelValues("reauth", "web", "success", machine.Namespace.Name).
|
2021-11-17 22:39:41 +00:00
|
|
|
Inc()
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (h *Headscale) handleMachineRefreshKey(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-22 19:35:24 +00:00
|
|
|
registerRequest tailcfg.RegisterRequest,
|
2021-11-17 22:39:41 +00:00
|
|
|
machine Machine,
|
|
|
|
|
) {
|
|
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
log.Debug().
|
2022-04-24 20:54:38 +01:00
|
|
|
Str("machine", machine.Hostname).
|
2021-11-17 22:39:41 +00:00
|
|
|
Msg("We have the OldNodeKey in the database. This is a key refresh")
|
2021-11-26 23:30:42 +00:00
|
|
|
machine.NodeKey = NodePublicKeyStripPrefix(registerRequest.NodeKey)
|
2022-05-30 15:39:24 +02:00
|
|
|
|
|
|
|
|
if err := h.db.Save(&machine).Error; err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to update machine key in the database")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2022-05-30 15:39:24 +02:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
resp.AuthURL = ""
|
|
|
|
|
resp.User = *machine.Namespace.toUser()
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-11-17 22:39:41 +00:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-11-17 22:39:41 +00:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (h *Headscale) handleMachineRegistrationNew(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-22 19:35:24 +00:00
|
|
|
registerRequest tailcfg.RegisterRequest,
|
2021-11-17 22:39:41 +00:00
|
|
|
) {
|
|
|
|
|
resp := tailcfg.RegisterResponse{}
|
|
|
|
|
|
|
|
|
|
// The machine registration is new, redirect the client to the registration URL
|
|
|
|
|
log.Debug().
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2022-08-11 12:11:02 +02:00
|
|
|
Msg("The node seems to be new, sending auth url")
|
2021-11-17 22:39:41 +00:00
|
|
|
if h.cfg.OIDC.Issuer != "" {
|
|
|
|
|
resp.AuthURL = fmt.Sprintf(
|
|
|
|
|
"%s/oidc/register/%s",
|
|
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"),
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey.String(),
|
2021-11-17 22:39:41 +00:00
|
|
|
)
|
|
|
|
|
} else {
|
2022-08-11 12:11:02 +02:00
|
|
|
resp.AuthURL = fmt.Sprintf("%s/register/%s",
|
|
|
|
|
strings.TrimSuffix(h.cfg.ServerURL, "/"), NodePublicKeyStripPrefix(registerRequest.NodeKey))
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-11-17 22:39:41 +00:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-11-17 22:39:41 +00:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-17 22:39:41 +00:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-11-17 22:39:41 +00:00
|
|
|
}
|
|
|
|
|
|
2022-01-16 14:16:59 +01:00
|
|
|
// TODO: check if any locks are needed around IP allocation.
|
2021-10-22 16:56:00 +00:00
|
|
|
func (h *Headscale) handleAuthKey(
|
2022-06-26 11:55:37 +02:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2021-11-26 23:30:42 +00:00
|
|
|
machineKey key.MachinePublic,
|
2021-11-22 19:35:24 +00:00
|
|
|
registerRequest tailcfg.RegisterRequest,
|
2021-10-22 16:56:00 +00:00
|
|
|
) {
|
2022-02-28 08:06:39 +00:00
|
|
|
machineKeyStr := MachinePublicKeyStripPrefix(machineKey)
|
|
|
|
|
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Debug().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "handleAuthKey").
|
2021-11-22 19:35:24 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
|
|
|
|
Msgf("Processing auth key for %s", registerRequest.Hostinfo.Hostname)
|
2021-05-06 00:59:26 +02:00
|
|
|
resp := tailcfg.RegisterResponse{}
|
2022-02-28 08:06:39 +00:00
|
|
|
|
2021-11-22 19:35:24 +00:00
|
|
|
pak, err := h.checkKeyValidity(registerRequest.Auth.AuthKey)
|
2021-06-05 12:13:55 +02:00
|
|
|
if err != nil {
|
2021-10-04 18:03:44 +02:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-10-04 18:03:44 +02:00
|
|
|
Str("func", "handleAuthKey").
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2021-10-04 18:03:44 +02:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed authentication via AuthKey")
|
2021-06-05 12:13:55 +02:00
|
|
|
resp.MachineAuthorized = false
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2021-05-06 00:59:26 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "handleAuthKey").
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2022-02-28 08:06:39 +00:00
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", pak.Namespace.Name).
|
2021-11-13 08:36:45 +00:00
|
|
|
Inc()
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2021-05-06 00:59:26 +02:00
|
|
|
return
|
|
|
|
|
}
|
2022-02-28 08:06:39 +00:00
|
|
|
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusUnauthorized)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2022-06-20 12:30:41 +02:00
|
|
|
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "handleAuthKey").
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2021-08-05 18:11:26 +01:00
|
|
|
Msg("Failed authentication via AuthKey")
|
2022-03-10 08:59:28 -05:00
|
|
|
|
|
|
|
|
if pak != nil {
|
|
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", pak.Namespace.Name).
|
|
|
|
|
Inc()
|
|
|
|
|
} else {
|
2022-03-21 15:49:14 +07:00
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", "unknown").Inc()
|
2022-03-10 08:59:28 -05:00
|
|
|
}
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2021-06-05 12:13:55 +02:00
|
|
|
return
|
|
|
|
|
}
|
2021-08-05 18:11:26 +01:00
|
|
|
|
2022-02-28 08:06:39 +00:00
|
|
|
log.Debug().
|
|
|
|
|
Str("func", "handleAuthKey").
|
|
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
|
|
|
|
Msg("Authentication key was valid, proceeding to acquire IP addresses")
|
2021-11-22 19:32:11 +00:00
|
|
|
|
2022-02-28 08:06:39 +00:00
|
|
|
nodeKey := NodePublicKeyStripPrefix(registerRequest.NodeKey)
|
2022-02-28 16:34:50 +00:00
|
|
|
|
2022-03-10 08:59:28 -05:00
|
|
|
// retrieve machine information if it exist
|
|
|
|
|
// The error is not important, because if it does not
|
|
|
|
|
// exist, then this is a new machine and we will move
|
|
|
|
|
// on to registration.
|
|
|
|
|
machine, _ := h.GetMachineByMachineKey(machineKey)
|
|
|
|
|
if machine != nil {
|
|
|
|
|
log.Trace().
|
2022-02-28 08:06:39 +00:00
|
|
|
Caller().
|
2022-04-24 20:54:38 +01:00
|
|
|
Str("machine", machine.Hostname).
|
2022-03-10 08:59:28 -05:00
|
|
|
Msg("machine already registered, refreshing with new auth key")
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2022-03-10 08:59:28 -05:00
|
|
|
machine.NodeKey = nodeKey
|
|
|
|
|
machine.AuthKeyID = uint(pak.ID)
|
2022-06-26 12:30:52 +02:00
|
|
|
err := h.RefreshMachine(machine, registerRequest.Expiry)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("machine", machine.Hostname).
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to refresh machine")
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2022-03-10 08:59:28 -05:00
|
|
|
} else {
|
|
|
|
|
now := time.Now().UTC()
|
2022-05-17 22:02:18 +02:00
|
|
|
|
|
|
|
|
givenName, err := h.GenerateGivenName(registerRequest.Hostinfo.Hostname)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Str("func", "RegistrationHandler").
|
|
|
|
|
Str("hostinfo.name", registerRequest.Hostinfo.Hostname).
|
|
|
|
|
Err(err)
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2022-03-10 08:59:28 -05:00
|
|
|
machineToRegister := Machine{
|
2022-04-24 20:54:38 +01:00
|
|
|
Hostname: registerRequest.Hostinfo.Hostname,
|
2022-05-17 22:02:18 +02:00
|
|
|
GivenName: givenName,
|
2022-03-10 08:59:28 -05:00
|
|
|
NamespaceID: pak.Namespace.ID,
|
|
|
|
|
MachineKey: machineKeyStr,
|
|
|
|
|
RegisterMethod: RegisterMethodAuthKey,
|
|
|
|
|
Expiry: ®isterRequest.Expiry,
|
|
|
|
|
NodeKey: nodeKey,
|
|
|
|
|
LastSeen: &now,
|
|
|
|
|
AuthKeyID: uint(pak.ID),
|
|
|
|
|
}
|
2022-03-10 10:22:21 -05:00
|
|
|
|
2022-03-10 08:59:28 -05:00
|
|
|
machine, err = h.RegisterMachine(
|
|
|
|
|
machineToRegister,
|
|
|
|
|
)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("could not register machine")
|
|
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", pak.Namespace.Name).
|
|
|
|
|
Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2022-03-10 10:22:21 -05:00
|
|
|
|
2022-03-10 08:59:28 -05:00
|
|
|
return
|
2022-03-10 10:22:21 -05:00
|
|
|
}
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
2021-05-06 00:59:26 +02:00
|
|
|
|
2022-06-26 12:30:52 +02:00
|
|
|
err = h.UsePreAuthKey(pak)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to use pre-auth key")
|
|
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", pak.Namespace.Name).
|
|
|
|
|
Inc()
|
|
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
2021-10-10 17:22:42 +08:00
|
|
|
|
2021-06-05 12:13:55 +02:00
|
|
|
resp.MachineAuthorized = true
|
|
|
|
|
resp.User = *pak.Namespace.toUser()
|
2021-11-24 12:15:55 +00:00
|
|
|
respBody, err := encode(resp, &machineKey, h.privateKey)
|
2020-06-21 12:32:08 +02:00
|
|
|
if err != nil {
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Error().
|
2021-11-26 23:30:42 +00:00
|
|
|
Caller().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "handleAuthKey").
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2021-08-05 18:11:26 +01:00
|
|
|
Err(err).
|
|
|
|
|
Msg("Cannot encode message")
|
2022-02-28 08:06:39 +00:00
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "error", pak.Namespace.Name).
|
2021-11-13 08:36:45 +00:00
|
|
|
Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
http.Error(writer, "Internal server error", http.StatusInternalServerError)
|
2021-11-14 16:46:09 +01:00
|
|
|
|
2020-06-21 12:32:08 +02:00
|
|
|
return
|
|
|
|
|
}
|
2022-02-28 08:06:39 +00:00
|
|
|
machineRegistrations.WithLabelValues("new", RegisterMethodAuthKey, "success", pak.Namespace.Name).
|
2021-11-13 08:36:45 +00:00
|
|
|
Inc()
|
2022-06-26 11:55:37 +02:00
|
|
|
writer.Header().Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-06-26 12:21:35 +02:00
|
|
|
_, err = writer.Write(respBody)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
|
|
|
|
|
2021-08-05 18:11:26 +01:00
|
|
|
log.Info().
|
2021-08-05 20:57:47 +01:00
|
|
|
Str("func", "handleAuthKey").
|
2022-02-28 08:06:39 +00:00
|
|
|
Str("machine", registerRequest.Hostinfo.Hostname).
|
2022-01-16 14:16:59 +01:00
|
|
|
Str("ips", strings.Join(machine.IPAddresses.ToStringSlice(), ", ")).
|
2021-08-05 18:11:26 +01:00
|
|
|
Msg("Successfully authenticated via AuthKey")
|
2020-06-21 12:32:08 +02:00
|
|
|
}
|
