mirror of
https://github.com/gravitl/netmaker.git
synced 2026-10-12 02:15:06 +00:00
abhishek9686
881c9d120d
Add TLS mode, listen addr, optional public hostname, and proxy-mode client port (443 / TCP_PROXY_PUBLIC_PORT) when building tcp_proxy_endpoint.
209 lines
9.0 KiB
Go
209 lines
9.0 KiB
Go
package models
|
|
|
|
import (
|
|
"net"
|
|
"net/netip"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/gravitl/netmaker/schema"
|
|
"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
|
|
)
|
|
|
|
// OS_Types - list of OS types Netmaker cares about
|
|
var OS_Types = struct {
|
|
Linux string
|
|
Windows string
|
|
Mac string
|
|
FreeBSD string
|
|
IoT string
|
|
}{
|
|
Linux: "linux",
|
|
Windows: "windows",
|
|
Mac: "darwin",
|
|
FreeBSD: "freebsd",
|
|
IoT: "iot",
|
|
}
|
|
|
|
// NAT_Types - the type of NAT in which a HOST currently resides (simplified)
|
|
var NAT_Types = struct {
|
|
Public string
|
|
BehindNAT string
|
|
}{
|
|
Public: "public",
|
|
BehindNAT: "behind_nat",
|
|
}
|
|
|
|
// WIREGUARD_INTERFACE name of wireguard interface
|
|
const (
|
|
WIREGUARD_INTERFACE = "netmaker"
|
|
DefaultPersistentKeepAlive = 20 * time.Second
|
|
)
|
|
|
|
// Host - represents a host on the network
|
|
type Host struct {
|
|
ID uuid.UUID `json:"id" yaml:"id"`
|
|
Verbosity int `json:"verbosity" yaml:"verbosity"`
|
|
FirewallInUse string `json:"firewallinuse" yaml:"firewallinuse"`
|
|
Version string `json:"version" yaml:"version"`
|
|
IPForwarding bool `json:"ipforwarding" yaml:"ipforwarding"`
|
|
DaemonInstalled bool `json:"daemoninstalled" yaml:"daemoninstalled"`
|
|
AutoUpdate bool `json:"autoupdate" yaml:"autoupdate"`
|
|
HostPass string `json:"hostpass" yaml:"hostpass"`
|
|
Name string `json:"name" yaml:"name"`
|
|
OS string `json:"os" yaml:"os"`
|
|
OSFamily string `json:"os_family" yaml:"os_family"`
|
|
OSVersion string `json:"os_version" yaml:"os_version"`
|
|
KernelVersion string `json:"kernel_version" yaml:"kernel_version"`
|
|
Interface string `json:"interface" yaml:"interface"`
|
|
Debug bool `json:"debug" yaml:"debug"`
|
|
ListenPort int `json:"listenport" yaml:"listenport"`
|
|
WgPublicListenPort int `json:"wg_public_listen_port" yaml:"wg_public_listen_port"`
|
|
TcpProxyEnabled bool `json:"tcp_proxy_enabled" yaml:"tcp_proxy_enabled"`
|
|
TcpProxyListenPort int `json:"tcp_proxy_listen_port" yaml:"tcp_proxy_listen_port"`
|
|
TcpProxyTLSMode string `json:"tcp_proxy_tls_mode" yaml:"tcp_proxy_tls_mode"`
|
|
TcpProxyListenAddr string `json:"tcp_proxy_listen_addr,omitempty" yaml:"tcp_proxy_listen_addr,omitempty"`
|
|
TcpProxyPublicHostname string `json:"tcp_proxy_public_hostname,omitempty" yaml:"tcp_proxy_public_hostname,omitempty"`
|
|
TcpProxyCertFingerprint string `json:"tcp_proxy_cert_fingerprint,omitempty" yaml:"tcp_proxy_cert_fingerprint,omitempty"`
|
|
MTU int `json:"mtu" yaml:"mtu"`
|
|
PublicKey wgtypes.Key `json:"publickey" yaml:"publickey"`
|
|
MacAddress net.HardwareAddr `json:"macaddress" yaml:"macaddress"`
|
|
TrafficKeyPublic []byte `json:"traffickeypublic" yaml:"traffickeypublic"`
|
|
Nodes []string `json:"nodes" yaml:"nodes"`
|
|
Interfaces []schema.Iface `json:"interfaces" yaml:"interfaces"`
|
|
DefaultInterface string `json:"defaultinterface" yaml:"defaultinterface"`
|
|
EndpointIP net.IP `json:"endpointip" yaml:"endpointip"`
|
|
EndpointIPv6 net.IP `json:"endpointipv6" yaml:"endpointipv6"`
|
|
IsDocker bool `json:"isdocker" yaml:"isdocker"`
|
|
IsK8S bool `json:"isk8s" yaml:"isk8s"`
|
|
IsStaticPort bool `json:"isstaticport" yaml:"isstaticport"`
|
|
IsStatic bool `json:"isstatic" yaml:"isstatic"`
|
|
IsDefault bool `json:"isdefault" yaml:"isdefault"`
|
|
DNS string `json:"dns_status" yaml:"dns_status"`
|
|
NatType string `json:"nat_type,omitempty" yaml:"nat_type,omitempty"`
|
|
TurnEndpoint *netip.AddrPort `json:"turn_endpoint,omitempty" yaml:"turn_endpoint,omitempty"`
|
|
PersistentKeepalive time.Duration `json:"persistentkeepalive" swaggertype:"primitive,integer" format:"int64" yaml:"persistentkeepalive"`
|
|
Location string `json:"location"` // Format: "lat,lon"
|
|
CountryCode string `json:"country_code"`
|
|
EnableFlowLogs bool `json:"enable_flow_logs" yaml:"enable_flow_logs"`
|
|
|
|
// MDM device-matching identifiers. Reported by netclient on host check-in
|
|
// and consumed by the MDM sync worker to match a Netmaker host to its
|
|
// upstream MDM-managed device record.
|
|
EntraDeviceID string `json:"entra_device_id" yaml:"entra_device_id"`
|
|
SerialNumber string `json:"serial_number" yaml:"serial_number"`
|
|
HardwareUUID string `json:"hardware_uuid" yaml:"hardware_uuid"`
|
|
OwnerUsername string `json:"owner_username" yaml:"owner_username"`
|
|
}
|
|
|
|
// FormatBool converts a boolean to a [yes|no] string
|
|
func FormatBool(b bool) string {
|
|
s := "no"
|
|
if b {
|
|
s = "yes"
|
|
}
|
|
return s
|
|
}
|
|
|
|
// ParseBool parses a [yes|no] string to boolean value
|
|
func ParseBool(s string) bool {
|
|
b := false
|
|
if s == "yes" {
|
|
b = true
|
|
}
|
|
return b
|
|
}
|
|
|
|
// HostMqAction - type for host update action
|
|
type HostMqAction string
|
|
|
|
const (
|
|
// Upgrade - const to request host to update it's client
|
|
Upgrade HostMqAction = "UPGRADE"
|
|
// ForceUpgrade - const for forcing a host to upgrade its client binary
|
|
ForceUpgrade HostMqAction = "FORCE_UPGRADE"
|
|
// SignalHost - const for host signal action
|
|
SignalHost HostMqAction = "SIGNAL_HOST"
|
|
// UpdateHost - constant for host update action
|
|
UpdateHost HostMqAction = "UPDATE_HOST"
|
|
// UpdateNode - constant for Node update action
|
|
UpdateNode HostMqAction = "UPDATE_NODE"
|
|
// DeleteHost - constant for host delete action
|
|
DeleteHost HostMqAction = "DELETE_HOST"
|
|
// JoinHostToNetwork - constant for host network join action
|
|
JoinHostToNetwork HostMqAction = "JOIN_HOST_TO_NETWORK"
|
|
// Acknowledgement - ACK response for hosts
|
|
Acknowledgement HostMqAction = "ACK"
|
|
// RequestAck - request an ACK
|
|
RequestAck HostMqAction = "REQ_ACK"
|
|
// CheckIn - update last check in times and public address and interfaces
|
|
CheckIn HostMqAction = "CHECK_IN"
|
|
// UpdateKeys - update wireguard private/public keys
|
|
UpdateKeys HostMqAction = "UPDATE_KEYS"
|
|
// RequestPull - request a pull from a host
|
|
RequestPull HostMqAction = "REQ_PULL"
|
|
// SignalPull - request a pull from a host without restart
|
|
SignalPull HostMqAction = "SIGNAL_PULL"
|
|
// UpdateMetrics - updates metrics data
|
|
UpdateMetrics HostMqAction = "UPDATE_METRICS"
|
|
// EgressUpdate - const for egress update action
|
|
EgressUpdate HostMqAction = "EGRESS_UPDATE"
|
|
// CHECK_ASSIGN_GW - const for to auto assign gw action
|
|
CheckAutoAssignGw HostMqAction = "CHECK_AUTO_ASSIGN_GW"
|
|
// CollectMetrics - request the host to immediately collect and publish metrics
|
|
CollectMetrics HostMqAction = "COLLECT_METRICS"
|
|
)
|
|
|
|
// SignalAction - turn peer signal action
|
|
type SignalAction string
|
|
|
|
const (
|
|
// ConnNegotiation - action to negotiate connection between peers
|
|
ConnNegotiation SignalAction = "CONNECTION_NEGOTIATION"
|
|
// RelayME - action to relay the peer
|
|
RelayME SignalAction = "RELAY_ME"
|
|
)
|
|
|
|
// HostUpdate - struct for host update
|
|
type HostUpdate struct {
|
|
Action HostMqAction
|
|
Host schema.Host
|
|
Node Node
|
|
Signal Signal
|
|
EgressDomain EgressDomain
|
|
NewMetrics Metrics
|
|
}
|
|
|
|
// HostTurnRegister - struct for host turn registration
|
|
type HostTurnRegister struct {
|
|
HostID string `json:"host_id"`
|
|
HostPassHash string `json:"host_pass_hash"`
|
|
}
|
|
|
|
// Signal - struct for signalling peer
|
|
type Signal struct {
|
|
Server string `json:"server"`
|
|
FromHostPubKey string `json:"from_host_pubkey"`
|
|
ToHostPubKey string `json:"to_host_pubkey"`
|
|
FromHostID string `json:"from_host_id"`
|
|
ToHostID string `json:"to_host_id"`
|
|
FromNodeID string `json:"from_node_id"`
|
|
ToNodeID string `json:"to_node_id"`
|
|
NetworkID string `json:"networkID"`
|
|
Reply bool `json:"reply"`
|
|
AutoRelayNodeMetrics map[string]int64 `json:"auto_relay_node_metrics"`
|
|
Action SignalAction `json:"action"`
|
|
IsPro bool `json:"is_pro"`
|
|
TimeStamp int64 `json:"timestamp"`
|
|
}
|
|
|
|
// RegisterMsg - login message struct for hosts to join via SSO login
|
|
type RegisterMsg struct {
|
|
RegisterHost schema.Host `json:"host"`
|
|
Network string `json:"network,omitempty"`
|
|
User string `json:"user,omitempty"`
|
|
Password string `json:"password,omitempty"`
|
|
JoinAll bool `json:"join_all,omitempty"`
|
|
Relay string `json:"relay,omitempty"`
|
|
}
|