mirror of
https://github.com/qdm12/gluetun.git
synced 2026-05-06 20:10:11 +02:00
Quentin McGaw
4a78989d9d
- main reason being it's a burden to always define sentinel errors at global scope, wrap them with `%w` instead of using a string directly - only use sentinel errors when it has to be checked using `errors.Is` - replace all usage of these sentinel errors in `fmt.Errorf` with direct strings that were in the sentinel error - exclude the sentinel error definition requirement from .golangci.yml - update unit tests to use ContainersError instead of ErrorIs so it stays as a "not a change detector test" without requiring a sentinel error
70 lines
1.8 KiB
Go
70 lines
1.8 KiB
Go
package vpn
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/qdm12/gluetun/internal/portforward"
|
|
"github.com/qdm12/gluetun/internal/portforward/service"
|
|
pfutils "github.com/qdm12/gluetun/internal/provider/utils"
|
|
)
|
|
|
|
func getPortForwarder(provider Provider, providers Providers, //nolint:ireturn
|
|
customPortForwarderName string,
|
|
) (portForwarder PortForwarder) {
|
|
if customPortForwarderName != "" {
|
|
provider = providers.Get(customPortForwarderName)
|
|
}
|
|
portForwarder, ok := provider.(PortForwarder)
|
|
if ok {
|
|
return portForwarder
|
|
}
|
|
return newNoPortForwarder(provider.Name())
|
|
}
|
|
|
|
func (l *Loop) startPortForwarding(data tunnelUpData) (err error) {
|
|
partialUpdate := portforward.Settings{
|
|
VPNIsUp: ptrTo(true),
|
|
Service: service.Settings{
|
|
PortForwarder: data.portForwarder,
|
|
Interface: data.vpnIntf,
|
|
ServerName: data.serverName,
|
|
CanPortForward: data.canPortForward,
|
|
Username: data.username,
|
|
Password: data.password,
|
|
},
|
|
}
|
|
return l.portForward.UpdateWith(partialUpdate)
|
|
}
|
|
|
|
func (l *Loop) stopPortForwarding() (err error) {
|
|
partialUpdate := portforward.Settings{
|
|
VPNIsUp: ptrTo(false),
|
|
}
|
|
return l.portForward.UpdateWith(partialUpdate)
|
|
}
|
|
|
|
type noPortForwarder struct {
|
|
providerName string
|
|
}
|
|
|
|
func newNoPortForwarder(providerName string) *noPortForwarder {
|
|
return &noPortForwarder{
|
|
providerName: providerName,
|
|
}
|
|
}
|
|
|
|
func (n *noPortForwarder) Name() string {
|
|
return n.providerName
|
|
}
|
|
|
|
func (n *noPortForwarder) PortForward(context.Context, pfutils.PortForwardObjects) (
|
|
internalToExternalPorts map[uint16]uint16, err error,
|
|
) {
|
|
return nil, fmt.Errorf("custom port forwarding obtention is not supported: for %s", n.providerName)
|
|
}
|
|
|
|
func (n *noPortForwarder) KeepPortForward(context.Context, pfutils.PortForwardObjects) (err error) {
|
|
return fmt.Errorf("custom port forwarding obtention is not supported: for %s", n.providerName)
|
|
}
|