2020-06-21 06:32:08 -04:00
|
|
|
package headscale
|
|
|
|
|
|
|
|
|
|
import (
|
2021-12-22 21:43:53 -05:00
|
|
|
"bytes"
|
2020-06-21 06:32:08 -04:00
|
|
|
"encoding/json"
|
2021-12-22 21:43:53 -05:00
|
|
|
"html/template"
|
2020-06-21 06:32:08 -04:00
|
|
|
"net/http"
|
|
|
|
|
"time"
|
|
|
|
|
|
2022-06-20 06:30:41 -04:00
|
|
|
"github.com/gorilla/mux"
|
2021-11-13 03:39:04 -05:00
|
|
|
"github.com/rs/zerolog/log"
|
2022-09-23 04:39:42 -04:00
|
|
|
"tailscale.com/types/key"
|
2020-06-21 06:32:08 -04:00
|
|
|
)
|
|
|
|
|
|
2021-11-18 03:49:55 -05:00
|
|
|
const (
|
2022-08-12 03:36:17 -04:00
|
|
|
// TODO(juan): remove this once https://github.com/juanfont/headscale/issues/727 is fixed.
|
2022-08-12 03:02:58 -04:00
|
|
|
registrationHoldoff = time.Second * 5
|
2021-11-22 14:32:52 -05:00
|
|
|
reservedResponseHeaderSize = 4
|
2022-02-27 12:48:12 -05:00
|
|
|
RegisterMethodAuthKey = "authkey"
|
2021-11-22 14:32:52 -05:00
|
|
|
RegisterMethodOIDC = "oidc"
|
|
|
|
|
RegisterMethodCLI = "cli"
|
|
|
|
|
ErrRegisterMethodCLIDoesNotSupportExpire = Error(
|
|
|
|
|
"machines registered with CLI does not support expire",
|
|
|
|
|
)
|
2021-11-18 03:49:55 -05:00
|
|
|
)
|
2021-11-14 12:31:51 -05:00
|
|
|
|
2022-07-06 07:39:10 -04: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")
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2022-09-04 05:43:09 -04:00
|
|
|
if err := h.pingDB(req.Context()); err != nil {
|
2022-07-06 07:39:10 -04:00
|
|
|
respond(err)
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
respond(nil)
|
|
|
|
|
}
|
|
|
|
|
|
2021-12-22 21:43:53 -05:00
|
|
|
type registerWebAPITemplateConfig struct {
|
|
|
|
|
Key string
|
|
|
|
|
}
|
2021-02-27 18:58:09 -05:00
|
|
|
|
2021-12-22 21:43:53 -05:00
|
|
|
var registerWebAPITemplate = template.Must(
|
2022-03-08 03:34:46 -05:00
|
|
|
template.New("registerweb").Parse(`
|
|
|
|
|
<html>
|
|
|
|
|
<head>
|
|
|
|
|
<title>Registration - Headscale</title>
|
|
|
|
|
</head>
|
2021-02-27 18:58:09 -05:00
|
|
|
<body>
|
2022-03-08 03:34:46 -05: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-27 18:58:09 -05:00
|
|
|
</body>
|
2022-03-08 03:34:46 -05:00
|
|
|
</html>
|
|
|
|
|
`))
|
2021-12-22 21:43:53 -05:00
|
|
|
|
|
|
|
|
// RegisterWebAPI shows a simple message in the browser to point to the CLI
|
2022-08-11 06:11:02 -04:00
|
|
|
// Listens in /register/:nkey.
|
2022-08-11 06:16:50 -04:00
|
|
|
//
|
|
|
|
|
// This is not part of the Tailscale control API, as we could send whatever URL
|
|
|
|
|
// in the RegisterResponse.AuthURL field.
|
2022-06-17 10:48:04 -04:00
|
|
|
func (h *Headscale) RegisterWebAPI(
|
2022-06-26 05:55:37 -04:00
|
|
|
writer http.ResponseWriter,
|
|
|
|
|
req *http.Request,
|
2022-06-17 10:48:04 -04:00
|
|
|
) {
|
2022-08-11 06:11:02 -04:00
|
|
|
vars := mux.Vars(req)
|
|
|
|
|
nodeKeyStr, ok := vars["nkey"]
|
2022-09-23 04:39:42 -04:00
|
|
|
|
2022-09-23 05:51:38 -04:00
|
|
|
if !NodePublicKeyRegex.Match([]byte(nodeKeyStr)) {
|
|
|
|
|
log.Warn().Str("node_key", nodeKeyStr).Msg("Invalid node key passed to registration url")
|
|
|
|
|
|
|
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusUnauthorized)
|
|
|
|
|
_, err := writer.Write([]byte("Unauthorized"))
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
2022-09-23 04:39:42 -04:00
|
|
|
// We need to make sure we dont open for XSS style injections, if the parameter that
|
|
|
|
|
// is passed as a key is not parsable/validated as a NodePublic key, then fail to render
|
|
|
|
|
// the template and log an error.
|
|
|
|
|
var nodeKey key.NodePublic
|
|
|
|
|
err := nodeKey.UnmarshalText(
|
|
|
|
|
[]byte(NodePublicKeyEnsurePrefix(nodeKeyStr)),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
if !ok || nodeKeyStr == "" || err != nil {
|
|
|
|
|
log.Warn().Err(err).Msg("Failed to parse incoming nodekey")
|
|
|
|
|
|
2022-06-26 05:55:37 -04:00
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusBadRequest)
|
2022-06-26 06:21:35 -04:00
|
|
|
_, err := writer.Write([]byte("Wrong params"))
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-12-22 21:43:53 -05:00
|
|
|
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var content bytes.Buffer
|
|
|
|
|
if err := registerWebAPITemplate.Execute(&content, registerWebAPITemplateConfig{
|
2022-08-10 09:35:26 -04:00
|
|
|
Key: nodeKeyStr,
|
2021-12-22 21:43:53 -05:00
|
|
|
}); err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Str("func", "RegisterWebAPI").
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Could not render register web API template")
|
2022-06-26 05:55:37 -04:00
|
|
|
writer.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusInternalServerError)
|
2022-06-26 06:21:35 -04: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 05:55:37 -04:00
|
|
|
|
|
|
|
|
return
|
2021-12-22 21:43:53 -05:00
|
|
|
}
|
2021-05-24 15:59:03 -04:00
|
|
|
|
2022-06-26 05:55:37 -04:00
|
|
|
writer.Header().Set("Content-Type", "text/html; charset=utf-8")
|
|
|
|
|
writer.WriteHeader(http.StatusOK)
|
2022-09-23 04:39:42 -04:00
|
|
|
_, err = writer.Write(content.Bytes())
|
2022-06-26 06:21:35 -04:00
|
|
|
if err != nil {
|
|
|
|
|
log.Error().
|
|
|
|
|
Caller().
|
|
|
|
|
Err(err).
|
|
|
|
|
Msg("Failed to write response")
|
|
|
|
|
}
|
2021-02-27 18:58:09 -05:00
|
|
|
}
|
