mirror of
https://github.com/tailscale/tailscale.git
synced 2026-09-15 15:29:33 -04:00
Package tailcfg defines the types and constants used by the Tailscale protocol, but since everything is all in one package, it’s difficult to sift through the docs: https://pkg.go.dev/tailscale.com/tailcfg We define and enumerate capabilities as string constants for tailcfg.NodeCapability and tailcfg.PeerCapability. This PR extracts them into their own packages: - tailcfg.CapabilityFileSharing becomes nodecap.FileSharing - tailcfg.NodeAttrOnlyTCP443 becomes nodecap.OnlyTCP443 - tailcfg.PeerCapabilityTaildrive becomes peercap.Taildrive We originally intended for CapabilityFoo to grant an entitlement or permission for Foo, and for NodeAttrBar to configure Bar in the nodeAttrs section of the policy file. However, there was no technical enforcement of this convention, so new capabilities have used the NodeAttr prefix regardless of meaning. Therefore, this PR unifies tailcfg.CapabilityFoo and tailcfg.NodeAttrBar into a single package as nodecap.Foo and nodecap.Bar. Ran `go fix -inline ./...` and committed the changes that replaced uses of the tailcfg aliases with the authoritative ones. Updates #20259 Change-Id: Ieb7e7e6c8247c39faf42fdf15c68cdc7c621c730 Signed-off-by: Simon Law <sfllaw@tailscale.com>
245 lines
6.4 KiB
Go
245 lines
6.4 KiB
Go
// Copyright (c) Tailscale Inc & contributors
|
|
// SPDX-License-Identifier: BSD-3-Clause
|
|
|
|
// Package wakeonlan registers the Wake-on-LAN feature.
|
|
package wakeonlan
|
|
|
|
import (
|
|
"encoding/json"
|
|
"log"
|
|
"net"
|
|
"net/http"
|
|
"runtime"
|
|
"sort"
|
|
"strings"
|
|
"unicode"
|
|
|
|
"github.com/kortschak/wol"
|
|
"tailscale.com/envknob"
|
|
"tailscale.com/feature"
|
|
"tailscale.com/hostinfo"
|
|
"tailscale.com/ipn/ipnlocal"
|
|
"tailscale.com/tailcfg"
|
|
"tailscale.com/tailcfg/peercap"
|
|
"tailscale.com/util/clientmetric"
|
|
)
|
|
|
|
func init() {
|
|
feature.Register("wakeonlan")
|
|
ipnlocal.RegisterC2N("POST /wol", handleC2NWoL)
|
|
ipnlocal.RegisterPeerAPIHandler("/v0/wol", handlePeerAPIWakeOnLAN)
|
|
hostinfo.RegisterHostinfoNewHook(func(h *tailcfg.Hostinfo) {
|
|
h.WoLMACs = getWoLMACs()
|
|
})
|
|
}
|
|
|
|
func handleC2NWoL(b *ipnlocal.LocalBackend, w http.ResponseWriter, r *http.Request) {
|
|
r.ParseForm()
|
|
var macs []net.HardwareAddr
|
|
for _, macStr := range r.Form["mac"] {
|
|
mac, err := net.ParseMAC(macStr)
|
|
if err != nil {
|
|
http.Error(w, "bad 'mac' param", http.StatusBadRequest)
|
|
return
|
|
}
|
|
macs = append(macs, mac)
|
|
}
|
|
var res struct {
|
|
SentTo []string
|
|
Errors []string
|
|
}
|
|
st := b.NetMon().InterfaceState()
|
|
if st == nil {
|
|
res.Errors = append(res.Errors, "no interface state")
|
|
writeJSON(w, &res)
|
|
return
|
|
}
|
|
var password []byte // TODO(bradfitz): support? does anything use WoL passwords?
|
|
for _, mac := range macs {
|
|
for ifName, ips := range st.InterfaceIPs {
|
|
for _, ip := range ips {
|
|
if ip.Addr().IsLoopback() || ip.Addr().Is6() {
|
|
continue
|
|
}
|
|
local := &net.UDPAddr{
|
|
IP: ip.Addr().AsSlice(),
|
|
Port: 0,
|
|
}
|
|
remote := &net.UDPAddr{
|
|
IP: net.IPv4bcast,
|
|
Port: 0,
|
|
}
|
|
if err := wol.Wake(mac, password, local, remote); err != nil {
|
|
res.Errors = append(res.Errors, err.Error())
|
|
} else {
|
|
res.SentTo = append(res.SentTo, ifName)
|
|
}
|
|
break // one per interface is enough
|
|
}
|
|
}
|
|
}
|
|
sort.Strings(res.SentTo)
|
|
writeJSON(w, &res)
|
|
}
|
|
|
|
func writeJSON(w http.ResponseWriter, v any) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(v)
|
|
}
|
|
|
|
func canWakeOnLAN(h ipnlocal.PeerAPIHandler) bool {
|
|
if h.Peer().UnsignedPeerAPIOnly() {
|
|
return false
|
|
}
|
|
return h.IsSelfUntagged() || h.PeerCaps().HasCapability(peercap.WakeOnLAN)
|
|
}
|
|
|
|
var metricWakeOnLANCalls = clientmetric.NewCounter("peerapi_wol")
|
|
|
|
func handlePeerAPIWakeOnLAN(h ipnlocal.PeerAPIHandler, w http.ResponseWriter, r *http.Request) {
|
|
metricWakeOnLANCalls.Add(1)
|
|
if !canWakeOnLAN(h) {
|
|
http.Error(w, "no WoL access", http.StatusForbidden)
|
|
return
|
|
}
|
|
if r.Method != "POST" {
|
|
http.Error(w, "bad method", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
macStr := r.FormValue("mac")
|
|
if macStr == "" {
|
|
http.Error(w, "missing 'mac' param", http.StatusBadRequest)
|
|
return
|
|
}
|
|
mac, err := net.ParseMAC(macStr)
|
|
if err != nil {
|
|
http.Error(w, "bad 'mac' param", http.StatusBadRequest)
|
|
return
|
|
}
|
|
var password []byte // TODO(bradfitz): support? does anything use WoL passwords?
|
|
st := h.LocalBackend().NetMon().InterfaceState()
|
|
if st == nil {
|
|
http.Error(w, "failed to get interfaces state", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
var res struct {
|
|
SentTo []string
|
|
Errors []string
|
|
}
|
|
for ifName, ips := range st.InterfaceIPs {
|
|
for _, ip := range ips {
|
|
if ip.Addr().IsLoopback() || ip.Addr().Is6() {
|
|
continue
|
|
}
|
|
local := &net.UDPAddr{
|
|
IP: ip.Addr().AsSlice(),
|
|
Port: 0,
|
|
}
|
|
remote := &net.UDPAddr{
|
|
IP: net.IPv4bcast,
|
|
Port: 0,
|
|
}
|
|
if err := wol.Wake(mac, password, local, remote); err != nil {
|
|
res.Errors = append(res.Errors, err.Error())
|
|
} else {
|
|
res.SentTo = append(res.SentTo, ifName)
|
|
}
|
|
break // one per interface is enough
|
|
}
|
|
}
|
|
sort.Strings(res.SentTo)
|
|
writeJSON(w, res)
|
|
}
|
|
|
|
// TODO(bradfitz): this is all too simplistic and static. It needs to run
|
|
// continuously in response to netmon events (USB ethernet adapters might get
|
|
// plugged in) and look for the media type/status/etc. Right now on macOS it
|
|
// still detects a half dozen "up" en0, en1, en2, en3 etc interfaces that don't
|
|
// have any media. We should only report the one that's actually connected.
|
|
// But it works for now (2023-10-05) for fleshing out the rest.
|
|
|
|
var wakeMAC = envknob.RegisterString("TS_WAKE_MAC") // mac address, "false" or "auto". for https://github.com/tailscale/tailscale/issues/306
|
|
|
|
// getWoLMACs returns up to 10 MAC address of the local machine to send
|
|
// wake-on-LAN packets to in order to wake it up. The returned MACs are in
|
|
// lowercase hex colon-separated form ("xx:xx:xx:xx:xx:xx").
|
|
//
|
|
// If TS_WAKE_MAC=auto, it tries to automatically find the MACs based on the OS
|
|
// type and interface properties. (TODO(bradfitz): incomplete) If TS_WAKE_MAC is
|
|
// set to a MAC address, that sole MAC address is returned.
|
|
func getWoLMACs() (macs []string) {
|
|
switch runtime.GOOS {
|
|
case "ios", "android":
|
|
return nil
|
|
}
|
|
if s := wakeMAC(); s != "" {
|
|
switch s {
|
|
case "auto":
|
|
ifs, _ := net.Interfaces()
|
|
for _, iface := range ifs {
|
|
if iface.Flags&net.FlagLoopback != 0 {
|
|
continue
|
|
}
|
|
if iface.Flags&net.FlagBroadcast == 0 ||
|
|
iface.Flags&net.FlagRunning == 0 ||
|
|
iface.Flags&net.FlagUp == 0 {
|
|
continue
|
|
}
|
|
if keepMAC(iface.Name, iface.HardwareAddr) {
|
|
macs = append(macs, iface.HardwareAddr.String())
|
|
}
|
|
if len(macs) == 10 {
|
|
break
|
|
}
|
|
}
|
|
return macs
|
|
case "false", "off": // fast path before ParseMAC error
|
|
return nil
|
|
}
|
|
mac, err := net.ParseMAC(s)
|
|
if err != nil {
|
|
log.Printf("invalid MAC %q", s)
|
|
return nil
|
|
}
|
|
return []string{mac.String()}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
var ignoreWakeOUI = map[[3]byte]bool{
|
|
{0x00, 0x15, 0x5d}: true, // Hyper-V
|
|
{0x00, 0x50, 0x56}: true, // VMware
|
|
{0x00, 0x1c, 0x14}: true, // VMware
|
|
{0x00, 0x05, 0x69}: true, // VMware
|
|
{0x00, 0x0c, 0x29}: true, // VMware
|
|
{0x00, 0x1c, 0x42}: true, // Parallels
|
|
{0x08, 0x00, 0x27}: true, // VirtualBox
|
|
{0x00, 0x21, 0xf6}: true, // VirtualBox
|
|
{0x00, 0x14, 0x4f}: true, // VirtualBox
|
|
{0x00, 0x0f, 0x4b}: true, // VirtualBox
|
|
{0x52, 0x54, 0x00}: true, // VirtualBox/Vagrant
|
|
}
|
|
|
|
func keepMAC(ifName string, mac []byte) bool {
|
|
if len(mac) != 6 {
|
|
return false
|
|
}
|
|
base := strings.TrimRightFunc(ifName, unicode.IsNumber)
|
|
switch runtime.GOOS {
|
|
case "darwin":
|
|
switch base {
|
|
case "llw", "awdl", "utun", "bridge", "lo", "gif", "stf", "anpi", "ap":
|
|
return false
|
|
}
|
|
}
|
|
if mac[0] == 0x02 && mac[1] == 0x42 {
|
|
// Docker container.
|
|
return false
|
|
}
|
|
oui := [3]byte{mac[0], mac[1], mac[2]}
|
|
if ignoreWakeOUI[oui] {
|
|
return false
|
|
}
|
|
return true
|
|
}
|