mirror of
https://github.com/whyvl/wireproxy.git
synced 2025-04-29 19:01:42 +02:00
fix config parsing
This commit is contained in:
parent
e749217090
commit
ff99bfd4a6
3 changed files with 100 additions and 9 deletions
16
config.go
16
config.go
|
@ -149,13 +149,17 @@ func parseCIDRNetIP(section *ini.Section, keyName string) ([]netip.Addr, error)
|
||||||
keys := key.StringsWithShadows(",")
|
keys := key.StringsWithShadows(",")
|
||||||
var ips = make([]netip.Addr, 0, len(keys))
|
var ips = make([]netip.Addr, 0, len(keys))
|
||||||
for _, str := range keys {
|
for _, str := range keys {
|
||||||
prefix, err := netip.ParsePrefix(str)
|
if addr, err := netip.ParseAddr(str); err == nil {
|
||||||
if err != nil {
|
ips = append(ips, addr)
|
||||||
return nil, err
|
} else {
|
||||||
}
|
prefix, err := netip.ParsePrefix(str)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
addr := prefix.Addr()
|
addr := prefix.Addr()
|
||||||
ips = append(ips, addr)
|
ips = append(ips, addr)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return ips, nil
|
return ips, nil
|
||||||
}
|
}
|
||||||
|
|
87
config_test.go
Normal file
87
config_test.go
Normal file
|
@ -0,0 +1,87 @@
|
||||||
|
package wireproxy
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/go-ini/ini"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func loadIniConfig(config string) (*ini.File, error) {
|
||||||
|
iniOpt := ini.LoadOptions{
|
||||||
|
Insensitive: true,
|
||||||
|
AllowShadows: true,
|
||||||
|
AllowNonUniqueSections: true,
|
||||||
|
}
|
||||||
|
|
||||||
|
return ini.LoadSources(iniOpt, []byte(config))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestWireguardConfWithoutSubnet(t *testing.T) {
|
||||||
|
const config = `
|
||||||
|
[Interface]
|
||||||
|
PrivateKey = LAr1aNSNF9d0MjwUgAVC4020T0N/E5NUtqVv5EnsSz0=
|
||||||
|
Address = 10.5.0.2
|
||||||
|
DNS = 1.1.1.1
|
||||||
|
|
||||||
|
[Peer]
|
||||||
|
PublicKey = e8LKAc+f9xEzq9Ar7+MfKRrs+gZ/4yzvpRJLRJ/VJ1w=
|
||||||
|
AllowedIPs = 0.0.0.0/0, ::/0
|
||||||
|
Endpoint = 94.140.11.15:51820
|
||||||
|
PersistentKeepalive = 25`
|
||||||
|
var cfg DeviceConfig
|
||||||
|
iniData, err := loadIniConfig(config)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = ParseInterface(iniData, &cfg)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestWireguardConfWithSubnet(t *testing.T) {
|
||||||
|
const config = `
|
||||||
|
[Interface]
|
||||||
|
PrivateKey = LAr1aNSNF9d0MjwUgAVC4020T0N/E5NUtqVv5EnsSz0=
|
||||||
|
Address = 10.5.0.2/23
|
||||||
|
DNS = 1.1.1.1
|
||||||
|
|
||||||
|
[Peer]
|
||||||
|
PublicKey = e8LKAc+f9xEzq9Ar7+MfKRrs+gZ/4yzvpRJLRJ/VJ1w=
|
||||||
|
AllowedIPs = 0.0.0.0/0, ::/0
|
||||||
|
Endpoint = 94.140.11.15:51820
|
||||||
|
PersistentKeepalive = 25`
|
||||||
|
var cfg DeviceConfig
|
||||||
|
iniData, err := loadIniConfig(config)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = ParseInterface(iniData, &cfg)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestWireguardConfWithManyAddress(t *testing.T) {
|
||||||
|
const config = `
|
||||||
|
[Interface]
|
||||||
|
PrivateKey = mBsVDahr1XIu9PPd17UmsDdB6E53nvmS47NbNqQCiFM=
|
||||||
|
Address = 100.96.0.190,2606:B300:FFFF:fe8a:2ac6:c7e8:b021:6f5f/128
|
||||||
|
DNS = 198.18.0.1,198.18.0.2
|
||||||
|
|
||||||
|
[Peer]
|
||||||
|
PublicKey = SHnh4C2aDXhp1gjIqceGhJrhOLSeNYcqWLKcYnzj00U=
|
||||||
|
AllowedIPs = 0.0.0.0/0,::/0
|
||||||
|
Endpoint = 192.200.144.22:51820`
|
||||||
|
var cfg DeviceConfig
|
||||||
|
iniData, err := loadIniConfig(config)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = ParseInterface(iniData, &cfg)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
}
|
|
@ -20,8 +20,8 @@ type DeviceSetting struct {
|
||||||
mtu int
|
mtu int
|
||||||
}
|
}
|
||||||
|
|
||||||
// serialize the config into an IPC request and DeviceSetting
|
// CreateIPCRequest serialize the config into an IPC request and DeviceSetting
|
||||||
func createIPCRequest(conf *DeviceConfig) (*DeviceSetting, error) {
|
func CreateIPCRequest(conf *DeviceConfig) (*DeviceSetting, error) {
|
||||||
var request bytes.Buffer
|
var request bytes.Buffer
|
||||||
|
|
||||||
request.WriteString(fmt.Sprintf("private_key=%s\n", conf.SecretKey))
|
request.WriteString(fmt.Sprintf("private_key=%s\n", conf.SecretKey))
|
||||||
|
@ -60,7 +60,7 @@ func createIPCRequest(conf *DeviceConfig) (*DeviceSetting, error) {
|
||||||
|
|
||||||
// StartWireguard creates a tun interface on netstack given a configuration
|
// StartWireguard creates a tun interface on netstack given a configuration
|
||||||
func StartWireguard(conf *DeviceConfig, logLevel int) (*VirtualTun, error) {
|
func StartWireguard(conf *DeviceConfig, logLevel int) (*VirtualTun, error) {
|
||||||
setting, err := createIPCRequest(conf)
|
setting, err := CreateIPCRequest(conf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue