mirror of
https://github.com/qdm12/gluetun.git
synced 2025-12-11 04:38:54 -06:00
85890520ab
- New option: `HEALTH_ICMP_TARGET_IP` defaults to `0.0.0.0` meaning use the VPN server public IP address. - Options removed: `HEALTH_VPN_INITIAL_DURATION` and `HEALTH_VPN_ADDITIONAL_DURATION` - times and retries are handpicked and hardcoded. - Less aggressive checks and less false positive detection
101 lines
2.8 KiB
Go
101 lines
2.8 KiB
Go
package vpn
|
|
|
|
import (
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/qdm12/gluetun/internal/configuration/settings"
|
|
"github.com/qdm12/gluetun/internal/constants"
|
|
"github.com/qdm12/gluetun/internal/loopstate"
|
|
"github.com/qdm12/gluetun/internal/models"
|
|
"github.com/qdm12/gluetun/internal/vpn/state"
|
|
"github.com/qdm12/log"
|
|
)
|
|
|
|
type Loop struct {
|
|
statusManager *loopstate.State
|
|
state *state.State
|
|
providers Providers
|
|
storage Storage
|
|
healthSettings settings.Health
|
|
healthChecker HealthChecker
|
|
healthServer HealthServer
|
|
// Fixed parameters
|
|
buildInfo models.BuildInformation
|
|
versionInfo bool
|
|
ipv6Supported bool
|
|
vpnInputPorts []uint16 // TODO make changeable through stateful firewall
|
|
// Configurators
|
|
openvpnConf OpenVPN
|
|
netLinker NetLinker
|
|
fw Firewall
|
|
routing Routing
|
|
portForward PortForward
|
|
publicip PublicIPLoop
|
|
dnsLooper DNSLoop
|
|
// Other objects
|
|
starter CmdStarter // for OpenVPN
|
|
logger log.LoggerInterface
|
|
client *http.Client
|
|
// Internal channels and values
|
|
stop <-chan struct{}
|
|
stopped chan<- struct{}
|
|
start <-chan struct{}
|
|
running chan<- models.LoopStatus
|
|
userTrigger bool
|
|
// Internal constant values
|
|
backoffTime time.Duration
|
|
}
|
|
|
|
const (
|
|
defaultBackoffTime = 15 * time.Second
|
|
)
|
|
|
|
func NewLoop(vpnSettings settings.VPN, ipv6Supported bool, vpnInputPorts []uint16,
|
|
providers Providers, storage Storage, healthSettings settings.Health,
|
|
healthChecker HealthChecker, healthServer HealthServer, openvpnConf OpenVPN,
|
|
netLinker NetLinker, fw Firewall, routing Routing,
|
|
portForward PortForward, starter CmdStarter,
|
|
publicip PublicIPLoop, dnsLooper DNSLoop,
|
|
logger log.LoggerInterface, client *http.Client,
|
|
buildInfo models.BuildInformation, versionInfo bool,
|
|
) *Loop {
|
|
start := make(chan struct{})
|
|
running := make(chan models.LoopStatus)
|
|
stop := make(chan struct{})
|
|
stopped := make(chan struct{})
|
|
|
|
statusManager := loopstate.New(constants.Stopped, start, running, stop, stopped)
|
|
state := state.New(statusManager, vpnSettings)
|
|
|
|
return &Loop{
|
|
statusManager: statusManager,
|
|
state: state,
|
|
providers: providers,
|
|
storage: storage,
|
|
healthSettings: healthSettings,
|
|
healthChecker: healthChecker,
|
|
healthServer: healthServer,
|
|
buildInfo: buildInfo,
|
|
versionInfo: versionInfo,
|
|
ipv6Supported: ipv6Supported,
|
|
vpnInputPorts: vpnInputPorts,
|
|
openvpnConf: openvpnConf,
|
|
netLinker: netLinker,
|
|
fw: fw,
|
|
routing: routing,
|
|
portForward: portForward,
|
|
publicip: publicip,
|
|
dnsLooper: dnsLooper,
|
|
starter: starter,
|
|
logger: logger,
|
|
client: client,
|
|
start: start,
|
|
running: running,
|
|
stop: stop,
|
|
stopped: stopped,
|
|
userTrigger: true,
|
|
backoffTime: defaultBackoffTime,
|
|
}
|
|
}
|