Compare commits
1 Commits
v0.107.27
...
fix-contex
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
cc1060d428 |
@@ -489,7 +489,7 @@ func (a *Auth) GetCurrentUser(r *http.Request) User {
|
|||||||
// there's no Cookie, check Basic authentication
|
// there's no Cookie, check Basic authentication
|
||||||
user, pass, ok := r.BasicAuth()
|
user, pass, ok := r.BasicAuth()
|
||||||
if ok {
|
if ok {
|
||||||
u := Context.auth.UserFind(user, pass)
|
u := a.UserFind(user, pass)
|
||||||
return u
|
return u
|
||||||
}
|
}
|
||||||
return User{}
|
return User{}
|
||||||
|
|||||||
102
home/context.go
Normal file
102
home/context.go
Normal file
@@ -0,0 +1,102 @@
|
|||||||
|
package home
|
||||||
|
|
||||||
|
import (
|
||||||
|
"crypto/x509"
|
||||||
|
"net/http"
|
||||||
|
"os"
|
||||||
|
"path/filepath"
|
||||||
|
"sync"
|
||||||
|
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/dhcpd"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/dnsfilter"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/dnsforward"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/querylog"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/stats"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/update"
|
||||||
|
"github.com/AdguardTeam/AdGuardHome/util"
|
||||||
|
|
||||||
|
"github.com/AdguardTeam/golibs/log"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Global context
|
||||||
|
type homeContext struct {
|
||||||
|
// Modules
|
||||||
|
// --
|
||||||
|
|
||||||
|
clients clientsContainer // per-client-settings module
|
||||||
|
stats stats.Stats // statistics module
|
||||||
|
queryLog querylog.QueryLog // query log module
|
||||||
|
dnsServer *dnsforward.Server // DNS module
|
||||||
|
rdns *RDNS // rDNS module
|
||||||
|
whois *Whois // WHOIS module
|
||||||
|
dnsFilter *dnsfilter.Dnsfilter // DNS filtering module
|
||||||
|
dhcpServer *dhcpd.Server // DHCP module
|
||||||
|
auth *Auth // HTTP authentication module
|
||||||
|
filters Filtering // DNS filtering module
|
||||||
|
web *Web // Web (HTTP, HTTPS) module
|
||||||
|
tls *TLSMod // TLS module
|
||||||
|
autoHosts util.AutoHosts // IP-hostname pairs taken from system configuration (e.g. /etc/hosts) files
|
||||||
|
updater *update.Updater
|
||||||
|
|
||||||
|
// Runtime properties
|
||||||
|
// --
|
||||||
|
|
||||||
|
controlLock sync.Mutex
|
||||||
|
configFilename string // Config filename (can be overridden via the command line arguments)
|
||||||
|
workDir string // Location of our directory, used to protect against CWD being somewhere else
|
||||||
|
firstRun bool // if set to true, don't run any services except HTTP web inteface, and serve only first-run html
|
||||||
|
pidFileName string // PID file name. Empty if no PID file was created.
|
||||||
|
disableUpdate bool // If set, don't check for updates
|
||||||
|
tlsRoots *x509.CertPool // list of root CAs for TLSv1.2
|
||||||
|
tlsCiphers []uint16 // list of TLS ciphers to use
|
||||||
|
transport *http.Transport
|
||||||
|
client *http.Client
|
||||||
|
appSignalChannel chan os.Signal // Channel for receiving OS signals by the console app
|
||||||
|
// runningAsService flag is set to true when options are passed from the service runner
|
||||||
|
runningAsService bool
|
||||||
|
}
|
||||||
|
|
||||||
|
// getDataDir returns path to the directory where we store databases and filters
|
||||||
|
func (c *homeContext) getDataDir() string {
|
||||||
|
return filepath.Join(c.workDir, dataDir)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Context - a global context object
|
||||||
|
var Context homeContext
|
||||||
|
|
||||||
|
func (c *homeContext) cleanup() {
|
||||||
|
log.Info("Stopping AdGuard Home")
|
||||||
|
|
||||||
|
if c.web != nil {
|
||||||
|
c.web.Close()
|
||||||
|
c.web = nil
|
||||||
|
}
|
||||||
|
if c.auth != nil {
|
||||||
|
c.auth.Close()
|
||||||
|
c.auth = nil
|
||||||
|
}
|
||||||
|
|
||||||
|
err := c.stopDNSServer()
|
||||||
|
if err != nil {
|
||||||
|
log.Error("Couldn't stop DNS server: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if c.dhcpServer != nil {
|
||||||
|
c.dhcpServer.Stop()
|
||||||
|
}
|
||||||
|
|
||||||
|
c.autoHosts.Close()
|
||||||
|
|
||||||
|
if c.tls != nil {
|
||||||
|
c.tls.Close()
|
||||||
|
c.tls = nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// This function is called before application exits
|
||||||
|
func (c *homeContext) cleanupAlways() {
|
||||||
|
if len(c.pidFileName) != 0 {
|
||||||
|
_ = os.Remove(c.pidFileName)
|
||||||
|
}
|
||||||
|
log.Info("Stopped")
|
||||||
|
}
|
||||||
@@ -47,10 +47,10 @@ func handleStatus(w http.ResponseWriter, r *http.Request) {
|
|||||||
Context.dnsServer.WriteDiskConfig(&c)
|
Context.dnsServer.WriteDiskConfig(&c)
|
||||||
}
|
}
|
||||||
data := map[string]interface{}{
|
data := map[string]interface{}{
|
||||||
"dns_addresses": getDNSAddresses(),
|
"dns_addresses": Context.getDNSAddresses(),
|
||||||
"http_port": config.BindPort,
|
"http_port": config.BindPort,
|
||||||
"dns_port": config.DNS.Port,
|
"dns_port": config.DNS.Port,
|
||||||
"running": isRunning(),
|
"running": Context.isRunning(),
|
||||||
"version": versionString,
|
"version": versionString,
|
||||||
"language": config.Language,
|
"language": config.Language,
|
||||||
|
|
||||||
|
|||||||
@@ -119,8 +119,8 @@ func getVersionResp(info update.VersionInfo) []byte {
|
|||||||
// Complete an update procedure
|
// Complete an update procedure
|
||||||
func finishUpdate() {
|
func finishUpdate() {
|
||||||
log.Info("Stopping all tasks")
|
log.Info("Stopping all tasks")
|
||||||
cleanup()
|
Context.cleanup()
|
||||||
cleanupAlways()
|
Context.cleanupAlways()
|
||||||
|
|
||||||
exeName := "AdGuardHome"
|
exeName := "AdGuardHome"
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
|
|||||||
213
home/dns.go
213
home/dns.go
@@ -23,9 +23,9 @@ func onConfigModified() {
|
|||||||
// initDNSServer creates an instance of the dnsforward.Server
|
// initDNSServer creates an instance of the dnsforward.Server
|
||||||
// Please note that we must do it even if we don't start it
|
// Please note that we must do it even if we don't start it
|
||||||
// so that we had access to the query log and the stats
|
// so that we had access to the query log and the stats
|
||||||
func initDNSServer() error {
|
func (c *homeContext) initDNSServer() error {
|
||||||
var err error
|
var err error
|
||||||
baseDir := Context.getDataDir()
|
baseDir := c.getDataDir()
|
||||||
|
|
||||||
statsConf := stats.Config{
|
statsConf := stats.Config{
|
||||||
Filename: filepath.Join(baseDir, "stats.db"),
|
Filename: filepath.Join(baseDir, "stats.db"),
|
||||||
@@ -34,7 +34,7 @@ func initDNSServer() error {
|
|||||||
ConfigModified: onConfigModified,
|
ConfigModified: onConfigModified,
|
||||||
HTTPRegister: httpRegister,
|
HTTPRegister: httpRegister,
|
||||||
}
|
}
|
||||||
Context.stats, err = stats.New(statsConf)
|
c.stats, err = stats.New(statsConf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("couldn't initialize statistics module")
|
return fmt.Errorf("couldn't initialize statistics module")
|
||||||
}
|
}
|
||||||
@@ -48,7 +48,7 @@ func initDNSServer() error {
|
|||||||
ConfigModified: onConfigModified,
|
ConfigModified: onConfigModified,
|
||||||
HTTPRegister: httpRegister,
|
HTTPRegister: httpRegister,
|
||||||
}
|
}
|
||||||
Context.queryLog = querylog.New(conf)
|
c.queryLog = querylog.New(conf)
|
||||||
|
|
||||||
filterConf := config.DNS.DnsfilterConf
|
filterConf := config.DNS.DnsfilterConf
|
||||||
bindhost := config.DNS.BindHost
|
bindhost := config.DNS.BindHost
|
||||||
@@ -56,93 +56,39 @@ func initDNSServer() error {
|
|||||||
bindhost = "127.0.0.1"
|
bindhost = "127.0.0.1"
|
||||||
}
|
}
|
||||||
filterConf.ResolverAddress = fmt.Sprintf("%s:%d", bindhost, config.DNS.Port)
|
filterConf.ResolverAddress = fmt.Sprintf("%s:%d", bindhost, config.DNS.Port)
|
||||||
filterConf.AutoHosts = &Context.autoHosts
|
filterConf.AutoHosts = &c.autoHosts
|
||||||
filterConf.ConfigModified = onConfigModified
|
filterConf.ConfigModified = onConfigModified
|
||||||
filterConf.HTTPRegister = httpRegister
|
filterConf.HTTPRegister = httpRegister
|
||||||
Context.dnsFilter = dnsfilter.New(&filterConf, nil)
|
c.dnsFilter = dnsfilter.New(&filterConf, nil)
|
||||||
|
|
||||||
p := dnsforward.DNSCreateParams{
|
p := dnsforward.DNSCreateParams{
|
||||||
DNSFilter: Context.dnsFilter,
|
DNSFilter: c.dnsFilter,
|
||||||
Stats: Context.stats,
|
Stats: c.stats,
|
||||||
QueryLog: Context.queryLog,
|
QueryLog: c.queryLog,
|
||||||
}
|
}
|
||||||
if Context.dhcpServer != nil {
|
if c.dhcpServer != nil {
|
||||||
p.DHCPServer = Context.dhcpServer
|
p.DHCPServer = c.dhcpServer
|
||||||
}
|
}
|
||||||
Context.dnsServer = dnsforward.NewServer(p)
|
c.dnsServer = dnsforward.NewServer(p)
|
||||||
dnsConfig := generateServerConfig()
|
dnsConfig := c.generateServerConfig()
|
||||||
err = Context.dnsServer.Prepare(&dnsConfig)
|
err = c.dnsServer.Prepare(&dnsConfig)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
closeDNSServer()
|
c.closeDNSServer()
|
||||||
return fmt.Errorf("dnsServer.Prepare: %s", err)
|
return fmt.Errorf("dnsServer.Prepare: %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
Context.rdns = InitRDNS(Context.dnsServer, &Context.clients)
|
c.rdns = InitRDNS(c.dnsServer, &c.clients)
|
||||||
Context.whois = initWhois(&Context.clients)
|
c.whois = initWhois(&c.clients)
|
||||||
|
|
||||||
Context.filters.Init()
|
c.filters.Init()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func isRunning() bool {
|
func (c *homeContext) isRunning() bool {
|
||||||
return Context.dnsServer != nil && Context.dnsServer.IsRunning()
|
return c.dnsServer != nil && c.dnsServer.IsRunning()
|
||||||
}
|
}
|
||||||
|
|
||||||
// nolint (gocyclo)
|
func (c *homeContext) onDNSRequest(d *proxy.DNSContext) {
|
||||||
// Return TRUE if IP is within public Internet IP range
|
|
||||||
func isPublicIP(ip net.IP) bool {
|
|
||||||
ip4 := ip.To4()
|
|
||||||
if ip4 != nil {
|
|
||||||
switch ip4[0] {
|
|
||||||
case 0:
|
|
||||||
return false //software
|
|
||||||
case 10:
|
|
||||||
return false //private network
|
|
||||||
case 127:
|
|
||||||
return false //loopback
|
|
||||||
case 169:
|
|
||||||
if ip4[1] == 254 {
|
|
||||||
return false //link-local
|
|
||||||
}
|
|
||||||
case 172:
|
|
||||||
if ip4[1] >= 16 && ip4[1] <= 31 {
|
|
||||||
return false //private network
|
|
||||||
}
|
|
||||||
case 192:
|
|
||||||
if (ip4[1] == 0 && ip4[2] == 0) || //private network
|
|
||||||
(ip4[1] == 0 && ip4[2] == 2) || //documentation
|
|
||||||
(ip4[1] == 88 && ip4[2] == 99) || //reserved
|
|
||||||
(ip4[1] == 168) { //private network
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
case 198:
|
|
||||||
if (ip4[1] == 18 || ip4[2] == 19) || //private network
|
|
||||||
(ip4[1] == 51 || ip4[2] == 100) { //documentation
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
case 203:
|
|
||||||
if ip4[1] == 0 && ip4[2] == 113 { //documentation
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
case 224:
|
|
||||||
if ip4[1] == 0 && ip4[2] == 0 { //multicast
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
case 255:
|
|
||||||
if ip4[1] == 255 && ip4[2] == 255 && ip4[3] == 255 { //subnet
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
if ip.IsLoopback() || ip.IsLinkLocalMulticast() || ip.IsLinkLocalUnicast() {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
func onDNSRequest(d *proxy.DNSContext) {
|
|
||||||
ip := dnsforward.GetIPString(d.Addr)
|
ip := dnsforward.GetIPString(d.Addr)
|
||||||
if ip == "" {
|
if ip == "" {
|
||||||
// This would be quite weird if we get here
|
// This would be quite weird if we get here
|
||||||
@@ -151,25 +97,25 @@ func onDNSRequest(d *proxy.DNSContext) {
|
|||||||
|
|
||||||
ipAddr := net.ParseIP(ip)
|
ipAddr := net.ParseIP(ip)
|
||||||
if !ipAddr.IsLoopback() {
|
if !ipAddr.IsLoopback() {
|
||||||
Context.rdns.Begin(ip)
|
c.rdns.Begin(ip)
|
||||||
}
|
}
|
||||||
if isPublicIP(ipAddr) {
|
if util.IsPublicIP(ipAddr) {
|
||||||
Context.whois.Begin(ip)
|
c.whois.Begin(ip)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func generateServerConfig() dnsforward.ServerConfig {
|
func (c *homeContext) generateServerConfig() dnsforward.ServerConfig {
|
||||||
newconfig := dnsforward.ServerConfig{
|
newconfig := dnsforward.ServerConfig{
|
||||||
UDPListenAddr: &net.UDPAddr{IP: net.ParseIP(config.DNS.BindHost), Port: config.DNS.Port},
|
UDPListenAddr: &net.UDPAddr{IP: net.ParseIP(config.DNS.BindHost), Port: config.DNS.Port},
|
||||||
TCPListenAddr: &net.TCPAddr{IP: net.ParseIP(config.DNS.BindHost), Port: config.DNS.Port},
|
TCPListenAddr: &net.TCPAddr{IP: net.ParseIP(config.DNS.BindHost), Port: config.DNS.Port},
|
||||||
FilteringConfig: config.DNS.FilteringConfig,
|
FilteringConfig: config.DNS.FilteringConfig,
|
||||||
ConfigModified: onConfigModified,
|
ConfigModified: onConfigModified,
|
||||||
HTTPRegister: httpRegister,
|
HTTPRegister: httpRegister,
|
||||||
OnDNSRequest: onDNSRequest,
|
OnDNSRequest: c.onDNSRequest,
|
||||||
}
|
}
|
||||||
|
|
||||||
tlsConf := tlsConfigSettings{}
|
tlsConf := tlsConfigSettings{}
|
||||||
Context.tls.WriteDiskConfig(&tlsConf)
|
c.tls.WriteDiskConfig(&tlsConf)
|
||||||
if tlsConf.Enabled {
|
if tlsConf.Enabled {
|
||||||
newconfig.TLSConfig = tlsConf.TLSConfig
|
newconfig.TLSConfig = tlsConf.TLSConfig
|
||||||
if tlsConf.PortDNSOverTLS != 0 {
|
if tlsConf.PortDNSOverTLS != 0 {
|
||||||
@@ -179,17 +125,17 @@ func generateServerConfig() dnsforward.ServerConfig {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
newconfig.TLSv12Roots = Context.tlsRoots
|
newconfig.TLSv12Roots = c.tlsRoots
|
||||||
newconfig.TLSCiphers = Context.tlsCiphers
|
newconfig.TLSCiphers = c.tlsCiphers
|
||||||
newconfig.TLSAllowUnencryptedDOH = tlsConf.AllowUnencryptedDOH
|
newconfig.TLSAllowUnencryptedDOH = tlsConf.AllowUnencryptedDOH
|
||||||
|
|
||||||
newconfig.FilterHandler = applyAdditionalFiltering
|
newconfig.FilterHandler = c.applyAdditionalFiltering
|
||||||
newconfig.GetCustomUpstreamByClient = Context.clients.FindUpstreams
|
newconfig.GetCustomUpstreamByClient = c.clients.FindUpstreams
|
||||||
return newconfig
|
return newconfig
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get the list of DNS addresses the server is listening on
|
// Get the list of DNS addresses the server is listening on
|
||||||
func getDNSAddresses() []string {
|
func (c *homeContext) getDNSAddresses() []string {
|
||||||
dnsAddresses := []string{}
|
dnsAddresses := []string{}
|
||||||
|
|
||||||
if config.DNS.BindHost == "0.0.0.0" {
|
if config.DNS.BindHost == "0.0.0.0" {
|
||||||
@@ -209,7 +155,7 @@ func getDNSAddresses() []string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
tlsConf := tlsConfigSettings{}
|
tlsConf := tlsConfigSettings{}
|
||||||
Context.tls.WriteDiskConfig(&tlsConf)
|
c.tls.WriteDiskConfig(&tlsConf)
|
||||||
if tlsConf.Enabled && len(tlsConf.ServerName) != 0 {
|
if tlsConf.Enabled && len(tlsConf.ServerName) != 0 {
|
||||||
|
|
||||||
if tlsConf.PortHTTPS != 0 {
|
if tlsConf.PortHTTPS != 0 {
|
||||||
@@ -231,75 +177,75 @@ func getDNSAddresses() []string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// If a client has his own settings, apply them
|
// If a client has his own settings, apply them
|
||||||
func applyAdditionalFiltering(clientAddr string, setts *dnsfilter.RequestFilteringSettings) {
|
func (c *homeContext) applyAdditionalFiltering(clientAddr string, setts *dnsfilter.RequestFilteringSettings) {
|
||||||
Context.dnsFilter.ApplyBlockedServices(setts, nil, true)
|
c.dnsFilter.ApplyBlockedServices(setts, nil, true)
|
||||||
|
|
||||||
if len(clientAddr) == 0 {
|
if len(clientAddr) == 0 {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
setts.ClientIP = clientAddr
|
setts.ClientIP = clientAddr
|
||||||
|
|
||||||
c, ok := Context.clients.Find(clientAddr)
|
cl, ok := c.clients.Find(clientAddr)
|
||||||
if !ok {
|
if !ok {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Debug("Using settings for client %s with IP %s", c.Name, clientAddr)
|
log.Debug("Using settings for client %s with IP %s", cl.Name, clientAddr)
|
||||||
|
|
||||||
if c.UseOwnBlockedServices {
|
if cl.UseOwnBlockedServices {
|
||||||
Context.dnsFilter.ApplyBlockedServices(setts, c.BlockedServices, false)
|
c.dnsFilter.ApplyBlockedServices(setts, cl.BlockedServices, false)
|
||||||
}
|
}
|
||||||
|
|
||||||
setts.ClientName = c.Name
|
setts.ClientName = cl.Name
|
||||||
setts.ClientTags = c.Tags
|
setts.ClientTags = cl.Tags
|
||||||
|
|
||||||
if !c.UseOwnSettings {
|
if !cl.UseOwnSettings {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
setts.FilteringEnabled = c.FilteringEnabled
|
setts.FilteringEnabled = cl.FilteringEnabled
|
||||||
setts.SafeSearchEnabled = c.SafeSearchEnabled
|
setts.SafeSearchEnabled = cl.SafeSearchEnabled
|
||||||
setts.SafeBrowsingEnabled = c.SafeBrowsingEnabled
|
setts.SafeBrowsingEnabled = cl.SafeBrowsingEnabled
|
||||||
setts.ParentalEnabled = c.ParentalEnabled
|
setts.ParentalEnabled = cl.ParentalEnabled
|
||||||
}
|
}
|
||||||
|
|
||||||
func startDNSServer() error {
|
func (c *homeContext) startDNSServer() error {
|
||||||
if isRunning() {
|
if c.isRunning() {
|
||||||
return fmt.Errorf("unable to start forwarding DNS server: Already running")
|
return fmt.Errorf("unable to start forwarding DNS server: Already running")
|
||||||
}
|
}
|
||||||
|
|
||||||
enableFilters(false)
|
enableFilters(false)
|
||||||
|
|
||||||
Context.clients.Start()
|
c.clients.Start()
|
||||||
|
|
||||||
err := Context.dnsServer.Start()
|
err := c.dnsServer.Start()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errorx.Decorate(err, "Couldn't start forwarding DNS server")
|
return errorx.Decorate(err, "Couldn't start forwarding DNS server")
|
||||||
}
|
}
|
||||||
|
|
||||||
Context.dnsFilter.Start()
|
c.dnsFilter.Start()
|
||||||
Context.filters.Start()
|
c.filters.Start()
|
||||||
Context.stats.Start()
|
c.stats.Start()
|
||||||
Context.queryLog.Start()
|
c.queryLog.Start()
|
||||||
|
|
||||||
const topClientsNumber = 100 // the number of clients to get
|
const topClientsNumber = 100 // the number of clients to get
|
||||||
topClients := Context.stats.GetTopClientsIP(topClientsNumber)
|
topClients := c.stats.GetTopClientsIP(topClientsNumber)
|
||||||
for _, ip := range topClients {
|
for _, ip := range topClients {
|
||||||
ipAddr := net.ParseIP(ip)
|
ipAddr := net.ParseIP(ip)
|
||||||
if !ipAddr.IsLoopback() {
|
if !ipAddr.IsLoopback() {
|
||||||
Context.rdns.Begin(ip)
|
c.rdns.Begin(ip)
|
||||||
}
|
}
|
||||||
if isPublicIP(ipAddr) {
|
if util.IsPublicIP(ipAddr) {
|
||||||
Context.whois.Begin(ip)
|
c.whois.Begin(ip)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func reconfigureDNSServer() error {
|
func (c *homeContext) reconfigureDNSServer() error {
|
||||||
newconfig := generateServerConfig()
|
newconfig := c.generateServerConfig()
|
||||||
err := Context.dnsServer.Reconfigure(&newconfig)
|
err := c.dnsServer.Reconfigure(&newconfig)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errorx.Decorate(err, "Couldn't start forwarding DNS server")
|
return errorx.Decorate(err, "Couldn't start forwarding DNS server")
|
||||||
}
|
}
|
||||||
@@ -307,43 +253,42 @@ func reconfigureDNSServer() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func stopDNSServer() error {
|
func (c *homeContext) stopDNSServer() error {
|
||||||
if !isRunning() {
|
if !c.isRunning() {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
err := Context.dnsServer.Stop()
|
err := c.dnsServer.Stop()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errorx.Decorate(err, "Couldn't stop forwarding DNS server")
|
return errorx.Decorate(err, "Couldn't stop forwarding DNS server")
|
||||||
}
|
}
|
||||||
|
|
||||||
closeDNSServer()
|
c.closeDNSServer()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func closeDNSServer() {
|
func (c *homeContext) closeDNSServer() {
|
||||||
// DNS forward module must be closed BEFORE stats or queryLog because it depends on them
|
// DNS forward module must be closed BEFORE stats or queryLog because it depends on them
|
||||||
if Context.dnsServer != nil {
|
if c.dnsServer != nil {
|
||||||
Context.dnsServer.Close()
|
c.dnsServer.Close()
|
||||||
Context.dnsServer = nil
|
c.dnsServer = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if Context.dnsFilter != nil {
|
if c.dnsFilter != nil {
|
||||||
Context.dnsFilter.Close()
|
c.dnsFilter.Close()
|
||||||
Context.dnsFilter = nil
|
c.dnsFilter = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if Context.stats != nil {
|
if c.stats != nil {
|
||||||
Context.stats.Close()
|
c.stats.Close()
|
||||||
Context.stats = nil
|
c.stats = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if Context.queryLog != nil {
|
if c.queryLog != nil {
|
||||||
Context.queryLog.Close()
|
c.queryLog.Close()
|
||||||
Context.queryLog = nil
|
c.queryLog = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
Context.filters.Close()
|
c.filters.Close()
|
||||||
|
|
||||||
log.Debug("Closed all DNS modules")
|
log.Debug("Closed all DNS modules")
|
||||||
}
|
}
|
||||||
|
|||||||
104
home/home.go
104
home/home.go
@@ -3,7 +3,6 @@ package home
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"crypto/x509"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net"
|
"net"
|
||||||
@@ -14,7 +13,6 @@ import (
|
|||||||
"path/filepath"
|
"path/filepath"
|
||||||
"runtime"
|
"runtime"
|
||||||
"strconv"
|
"strconv"
|
||||||
"sync"
|
|
||||||
"syscall"
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -29,9 +27,6 @@ import (
|
|||||||
|
|
||||||
"github.com/AdguardTeam/AdGuardHome/dhcpd"
|
"github.com/AdguardTeam/AdGuardHome/dhcpd"
|
||||||
"github.com/AdguardTeam/AdGuardHome/dnsfilter"
|
"github.com/AdguardTeam/AdGuardHome/dnsfilter"
|
||||||
"github.com/AdguardTeam/AdGuardHome/dnsforward"
|
|
||||||
"github.com/AdguardTeam/AdGuardHome/querylog"
|
|
||||||
"github.com/AdguardTeam/AdGuardHome/stats"
|
|
||||||
"github.com/AdguardTeam/golibs/log"
|
"github.com/AdguardTeam/golibs/log"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -48,52 +43,6 @@ var (
|
|||||||
ARMVersion = ""
|
ARMVersion = ""
|
||||||
)
|
)
|
||||||
|
|
||||||
// Global context
|
|
||||||
type homeContext struct {
|
|
||||||
// Modules
|
|
||||||
// --
|
|
||||||
|
|
||||||
clients clientsContainer // per-client-settings module
|
|
||||||
stats stats.Stats // statistics module
|
|
||||||
queryLog querylog.QueryLog // query log module
|
|
||||||
dnsServer *dnsforward.Server // DNS module
|
|
||||||
rdns *RDNS // rDNS module
|
|
||||||
whois *Whois // WHOIS module
|
|
||||||
dnsFilter *dnsfilter.Dnsfilter // DNS filtering module
|
|
||||||
dhcpServer *dhcpd.Server // DHCP module
|
|
||||||
auth *Auth // HTTP authentication module
|
|
||||||
filters Filtering // DNS filtering module
|
|
||||||
web *Web // Web (HTTP, HTTPS) module
|
|
||||||
tls *TLSMod // TLS module
|
|
||||||
autoHosts util.AutoHosts // IP-hostname pairs taken from system configuration (e.g. /etc/hosts) files
|
|
||||||
updater *update.Updater
|
|
||||||
|
|
||||||
// Runtime properties
|
|
||||||
// --
|
|
||||||
|
|
||||||
configFilename string // Config filename (can be overridden via the command line arguments)
|
|
||||||
workDir string // Location of our directory, used to protect against CWD being somewhere else
|
|
||||||
firstRun bool // if set to true, don't run any services except HTTP web inteface, and serve only first-run html
|
|
||||||
pidFileName string // PID file name. Empty if no PID file was created.
|
|
||||||
disableUpdate bool // If set, don't check for updates
|
|
||||||
controlLock sync.Mutex
|
|
||||||
tlsRoots *x509.CertPool // list of root CAs for TLSv1.2
|
|
||||||
tlsCiphers []uint16 // list of TLS ciphers to use
|
|
||||||
transport *http.Transport
|
|
||||||
client *http.Client
|
|
||||||
appSignalChannel chan os.Signal // Channel for receiving OS signals by the console app
|
|
||||||
// runningAsService flag is set to true when options are passed from the service runner
|
|
||||||
runningAsService bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// getDataDir returns path to the directory where we store databases and filters
|
|
||||||
func (c *homeContext) getDataDir() string {
|
|
||||||
return filepath.Join(c.workDir, dataDir)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Context - a global context object
|
|
||||||
var Context homeContext
|
|
||||||
|
|
||||||
// Main is the entry point
|
// Main is the entry point
|
||||||
func Main(version string, channel string, armVer string) {
|
func Main(version string, channel string, armVer string) {
|
||||||
// Init update-related global variables
|
// Init update-related global variables
|
||||||
@@ -118,8 +67,8 @@ func Main(version string, channel string, armVer string) {
|
|||||||
Context.tls.Reload()
|
Context.tls.Reload()
|
||||||
|
|
||||||
default:
|
default:
|
||||||
cleanup()
|
Context.cleanup()
|
||||||
cleanupAlways()
|
Context.cleanupAlways()
|
||||||
os.Exit(0)
|
os.Exit(0)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -304,7 +253,7 @@ func run(args options) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if !Context.firstRun {
|
if !Context.firstRun {
|
||||||
err := initDNSServer()
|
err := Context.initDNSServer()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("%s", err)
|
log.Fatalf("%s", err)
|
||||||
}
|
}
|
||||||
@@ -312,7 +261,7 @@ func run(args options) {
|
|||||||
Context.autoHosts.Start()
|
Context.autoHosts.Start()
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
err := startDNSServer()
|
err := Context.startDNSServer()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
@@ -331,16 +280,16 @@ func run(args options) {
|
|||||||
|
|
||||||
// StartMods - initialize and start DNS after installation
|
// StartMods - initialize and start DNS after installation
|
||||||
func StartMods() error {
|
func StartMods() error {
|
||||||
err := initDNSServer()
|
err := Context.initDNSServer()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
Context.tls.Start()
|
Context.tls.Start()
|
||||||
|
|
||||||
err = startDNSServer()
|
err = Context.startDNSServer()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
closeDNSServer()
|
Context.closeDNSServer()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
@@ -489,43 +438,6 @@ func configureLogger(args options) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func cleanup() {
|
|
||||||
log.Info("Stopping AdGuard Home")
|
|
||||||
|
|
||||||
if Context.web != nil {
|
|
||||||
Context.web.Close()
|
|
||||||
Context.web = nil
|
|
||||||
}
|
|
||||||
if Context.auth != nil {
|
|
||||||
Context.auth.Close()
|
|
||||||
Context.auth = nil
|
|
||||||
}
|
|
||||||
|
|
||||||
err := stopDNSServer()
|
|
||||||
if err != nil {
|
|
||||||
log.Error("Couldn't stop DNS server: %s", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if Context.dhcpServer != nil {
|
|
||||||
Context.dhcpServer.Stop()
|
|
||||||
}
|
|
||||||
|
|
||||||
Context.autoHosts.Close()
|
|
||||||
|
|
||||||
if Context.tls != nil {
|
|
||||||
Context.tls.Close()
|
|
||||||
Context.tls = nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// This function is called before application exits
|
|
||||||
func cleanupAlways() {
|
|
||||||
if len(Context.pidFileName) != 0 {
|
|
||||||
_ = os.Remove(Context.pidFileName)
|
|
||||||
}
|
|
||||||
log.Info("Stopped")
|
|
||||||
}
|
|
||||||
|
|
||||||
// command-line arguments
|
// command-line arguments
|
||||||
type options struct {
|
type options struct {
|
||||||
verbose bool // is verbose logging enabled
|
verbose bool // is verbose logging enabled
|
||||||
@@ -734,7 +646,7 @@ func customDialContext(ctx context.Context, network, addr string) (net.Conn, err
|
|||||||
return nil, errorx.DecorateMany(fmt.Sprintf("couldn't dial to %s", addr), dialErrs...)
|
return nil, errorx.DecorateMany(fmt.Sprintf("couldn't dial to %s", addr), dialErrs...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func getHTTPProxy(req *http.Request) (*url.URL, error) {
|
func getHTTPProxy(*http.Request) (*url.URL, error) {
|
||||||
if len(config.ProxyURL) == 0 {
|
if len(config.ProxyURL) == 0 {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -182,6 +182,7 @@ func TestHome(t *testing.T) {
|
|||||||
time.Sleep(1 * time.Second)
|
time.Sleep(1 * time.Second)
|
||||||
}
|
}
|
||||||
|
|
||||||
cleanup()
|
ctx := &Context
|
||||||
cleanupAlways()
|
ctx.cleanup()
|
||||||
|
ctx.cleanupAlways()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -134,7 +134,7 @@ func (t *TLSMod) Reload() {
|
|||||||
|
|
||||||
t.certLastMod = fi.ModTime().UTC()
|
t.certLastMod = fi.ModTime().UTC()
|
||||||
|
|
||||||
_ = reconfigureDNSServer()
|
_ = Context.reconfigureDNSServer()
|
||||||
Context.web.TLSConfigChanged(tlsConf)
|
Context.web.TLSConfigChanged(tlsConf)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -277,7 +277,7 @@ func (t *TLSMod) handleTLSConfigure(w http.ResponseWriter, r *http.Request) {
|
|||||||
t.confLock.Unlock()
|
t.confLock.Unlock()
|
||||||
t.setCertFileTime()
|
t.setCertFileTime()
|
||||||
onConfigModified()
|
onConfigModified()
|
||||||
err = reconfigureDNSServer()
|
err = Context.reconfigureDNSServer()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
httpError(w, http.StatusInternalServerError, "%s", err)
|
httpError(w, http.StatusInternalServerError, "%s", err)
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -144,7 +144,7 @@ func (web *Web) Start() {
|
|||||||
}
|
}
|
||||||
err := web.httpServer.ListenAndServe()
|
err := web.httpServer.ListenAndServe()
|
||||||
if err != http.ErrServerClosed {
|
if err != http.ErrServerClosed {
|
||||||
cleanupAlways()
|
Context.cleanupAlways()
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
// We use ErrServerClosed as a sign that we need to rebind on new address, so go back to the start of the loop
|
// We use ErrServerClosed as a sign that we need to rebind on new address, so go back to the start of the loop
|
||||||
@@ -202,7 +202,7 @@ func (web *Web) tlsServerLoop() {
|
|||||||
printHTTPAddresses("https")
|
printHTTPAddresses("https")
|
||||||
err := web.httpsServer.server.ListenAndServeTLS("", "")
|
err := web.httpsServer.server.ListenAndServeTLS("", "")
|
||||||
if err != http.ErrServerClosed {
|
if err != http.ErrServerClosed {
|
||||||
cleanupAlways()
|
Context.cleanupAlways()
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
54
util/net.go
54
util/net.go
@@ -5,6 +5,60 @@ import (
|
|||||||
"net"
|
"net"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// nolint (gocyclo)
|
||||||
|
// Return TRUE if IP is within public Internet IP range
|
||||||
|
func IsPublicIP(ip net.IP) bool {
|
||||||
|
ip4 := ip.To4()
|
||||||
|
if ip4 != nil {
|
||||||
|
switch ip4[0] {
|
||||||
|
case 0:
|
||||||
|
return false //software
|
||||||
|
case 10:
|
||||||
|
return false //private network
|
||||||
|
case 127:
|
||||||
|
return false //loopback
|
||||||
|
case 169:
|
||||||
|
if ip4[1] == 254 {
|
||||||
|
return false //link-local
|
||||||
|
}
|
||||||
|
case 172:
|
||||||
|
if ip4[1] >= 16 && ip4[1] <= 31 {
|
||||||
|
return false //private network
|
||||||
|
}
|
||||||
|
case 192:
|
||||||
|
if (ip4[1] == 0 && ip4[2] == 0) || //private network
|
||||||
|
(ip4[1] == 0 && ip4[2] == 2) || //documentation
|
||||||
|
(ip4[1] == 88 && ip4[2] == 99) || //reserved
|
||||||
|
(ip4[1] == 168) { //private network
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
case 198:
|
||||||
|
if (ip4[1] == 18 || ip4[2] == 19) || //private network
|
||||||
|
(ip4[1] == 51 || ip4[2] == 100) { //documentation
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
case 203:
|
||||||
|
if ip4[1] == 0 && ip4[2] == 113 { //documentation
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
case 224:
|
||||||
|
if ip4[1] == 0 && ip4[2] == 0 { //multicast
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
case 255:
|
||||||
|
if ip4[1] == 255 && ip4[2] == 255 && ip4[3] == 255 { //subnet
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if ip.IsLoopback() || ip.IsLinkLocalMulticast() || ip.IsLinkLocalUnicast() {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
// CanBindPort - checks if we can bind to this port or not
|
// CanBindPort - checks if we can bind to this port or not
|
||||||
func CanBindPort(port int) (bool, error) {
|
func CanBindPort(port int) (bool, error) {
|
||||||
addr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf("127.0.0.1:%d", port))
|
addr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf("127.0.0.1:%d", port))
|
||||||
|
|||||||
Reference in New Issue
Block a user