fa33568fab
Merge in DNS/adguard-home from imp-errcheck to master
Squashed commit of the following:
commit ed046b8ef59a092a27c623cd14b3fc2ef305fc3d
Author: Ainar Garipov <A.Garipov@AdGuard.COM>
Date: Thu Feb 4 15:00:04 2021 +0300
stats: imp cleanup more
commit e53a9240d3e3eec2417c768b98c267a8cd54d992
Merge: da734317 676f8c76
Author: Ainar Garipov <A.Garipov@AdGuard.COM>
Date: Thu Feb 4 14:59:40 2021 +0300
Merge branch 'master' into imp-errcheck
commit da734317035543b52e5a9030813084bdc92ba90a
Author: Ainar Garipov <A.Garipov@AdGuard.COM>
Date: Thu Feb 4 14:37:26 2021 +0300
stats: imp cleanup
commit 8b4ad150129111a09be6fa2944a21bd06ab8e5a1
Merge: 385c8a6c 5081ead0
Author: Ainar Garipov <A.Garipov@AdGuard.COM>
Date: Thu Feb 4 14:34:26 2021 +0300
Merge branch 'master' into imp-errcheck
commit 385c8a6c91e3bf07a457da370c8cc77820b91600
Author: Ainar Garipov <A.Garipov@AdGuard.COM>
Date: Fri Jan 29 20:41:57 2021 +0300
all: imp errcheck in tests
242 lines
7.6 KiB
Go
242 lines
7.6 KiB
Go
// +build aix darwin dragonfly freebsd linux netbsd openbsd solaris
|
|
|
|
package dhcpd
|
|
|
|
import (
|
|
"net"
|
|
"testing"
|
|
|
|
"github.com/insomniacslk/dhcp/dhcpv4"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func notify4(flags uint32) {
|
|
}
|
|
|
|
func TestV4StaticLeaseAddRemove(t *testing.T) {
|
|
conf := V4ServerConf{
|
|
Enabled: true,
|
|
RangeStart: net.IP{192, 168, 10, 100},
|
|
RangeEnd: net.IP{192, 168, 10, 200},
|
|
GatewayIP: net.IP{192, 168, 10, 1},
|
|
SubnetMask: net.IP{255, 255, 255, 0},
|
|
notify: notify4,
|
|
}
|
|
s, err := v4Create(conf)
|
|
assert.Nil(t, err)
|
|
|
|
ls := s.GetLeases(LeasesStatic)
|
|
assert.Empty(t, ls)
|
|
|
|
// add static lease
|
|
l := Lease{}
|
|
l.IP = net.IP{192, 168, 10, 150}
|
|
l.HWAddr, _ = net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
assert.Nil(t, s.AddStaticLease(l))
|
|
|
|
// try to add the same static lease - fail
|
|
assert.NotNil(t, s.AddStaticLease(l))
|
|
|
|
// check
|
|
ls = s.GetLeases(LeasesStatic)
|
|
assert.Len(t, ls, 1)
|
|
assert.True(t, net.IP{192, 168, 10, 150}.Equal(ls[0].IP))
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", ls[0].HWAddr.String())
|
|
assert.EqualValues(t, leaseExpireStatic, ls[0].Expiry.Unix())
|
|
|
|
// try to remove static lease - fail
|
|
l.IP = net.IP{192, 168, 10, 110}
|
|
l.HWAddr, _ = net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
assert.NotNil(t, s.RemoveStaticLease(l))
|
|
|
|
// remove static lease
|
|
l.IP = net.IP{192, 168, 10, 150}
|
|
l.HWAddr, _ = net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
assert.Nil(t, s.RemoveStaticLease(l))
|
|
|
|
// check
|
|
ls = s.GetLeases(LeasesStatic)
|
|
assert.Empty(t, ls)
|
|
}
|
|
|
|
func TestV4StaticLeaseAddReplaceDynamic(t *testing.T) {
|
|
conf := V4ServerConf{
|
|
Enabled: true,
|
|
RangeStart: net.IP{192, 168, 10, 100},
|
|
RangeEnd: net.IP{192, 168, 10, 200},
|
|
GatewayIP: net.IP{192, 168, 10, 1},
|
|
SubnetMask: net.IP{255, 255, 255, 0},
|
|
notify: notify4,
|
|
}
|
|
sIface, err := v4Create(conf)
|
|
s, ok := sIface.(*v4Server)
|
|
assert.True(t, ok)
|
|
assert.Nil(t, err)
|
|
|
|
// add dynamic lease
|
|
ld := Lease{}
|
|
ld.IP = net.IP{192, 168, 10, 150}
|
|
ld.HWAddr, _ = net.ParseMAC("11:aa:aa:aa:aa:aa")
|
|
s.addLease(&ld)
|
|
|
|
// add dynamic lease
|
|
{
|
|
ld := Lease{}
|
|
ld.IP = net.IP{192, 168, 10, 151}
|
|
ld.HWAddr, _ = net.ParseMAC("22:aa:aa:aa:aa:aa")
|
|
s.addLease(&ld)
|
|
}
|
|
|
|
// add static lease with the same IP
|
|
l := Lease{}
|
|
l.IP = net.IP{192, 168, 10, 150}
|
|
l.HWAddr, _ = net.ParseMAC("33:aa:aa:aa:aa:aa")
|
|
assert.Nil(t, s.AddStaticLease(l))
|
|
|
|
// add static lease with the same MAC
|
|
l = Lease{}
|
|
l.IP = net.IP{192, 168, 10, 152}
|
|
l.HWAddr, _ = net.ParseMAC("22:aa:aa:aa:aa:aa")
|
|
assert.Nil(t, s.AddStaticLease(l))
|
|
|
|
// check
|
|
ls := s.GetLeases(LeasesStatic)
|
|
assert.Len(t, ls, 2)
|
|
|
|
assert.True(t, net.IP{192, 168, 10, 150}.Equal(ls[0].IP))
|
|
assert.Equal(t, "33:aa:aa:aa:aa:aa", ls[0].HWAddr.String())
|
|
assert.EqualValues(t, leaseExpireStatic, ls[0].Expiry.Unix())
|
|
|
|
assert.True(t, net.IP{192, 168, 10, 152}.Equal(ls[1].IP))
|
|
assert.Equal(t, "22:aa:aa:aa:aa:aa", ls[1].HWAddr.String())
|
|
assert.EqualValues(t, leaseExpireStatic, ls[1].Expiry.Unix())
|
|
}
|
|
|
|
func TestV4StaticLeaseGet(t *testing.T) {
|
|
conf := V4ServerConf{
|
|
Enabled: true,
|
|
RangeStart: net.IP{192, 168, 10, 100},
|
|
RangeEnd: net.IP{192, 168, 10, 200},
|
|
GatewayIP: net.IP{192, 168, 10, 1},
|
|
SubnetMask: net.IP{255, 255, 255, 0},
|
|
notify: notify4,
|
|
}
|
|
sIface, err := v4Create(conf)
|
|
s, ok := sIface.(*v4Server)
|
|
assert.True(t, ok)
|
|
assert.Nil(t, err)
|
|
s.conf.dnsIPAddrs = []net.IP{{192, 168, 10, 1}}
|
|
|
|
l := Lease{}
|
|
l.IP = net.IP{192, 168, 10, 150}
|
|
l.HWAddr, _ = net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
assert.Nil(t, s.AddStaticLease(l))
|
|
|
|
// "Discover"
|
|
mac, _ := net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
req, _ := dhcpv4.NewDiscovery(mac)
|
|
resp, _ := dhcpv4.NewReplyFromRequest(req)
|
|
assert.Equal(t, 1, s.process(req, resp))
|
|
|
|
// check "Offer"
|
|
assert.Equal(t, dhcpv4.MessageTypeOffer, resp.MessageType())
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", resp.ClientHWAddr.String())
|
|
assert.True(t, net.IP{192, 168, 10, 150}.Equal(resp.YourIPAddr))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.Router()[0]))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.ServerIdentifier()))
|
|
assert.True(t, net.IP{255, 255, 255, 0}.Equal(net.IP(resp.SubnetMask())))
|
|
assert.Equal(t, s.conf.leaseTime.Seconds(), resp.IPAddressLeaseTime(-1).Seconds())
|
|
|
|
// "Request"
|
|
req, _ = dhcpv4.NewRequestFromOffer(resp)
|
|
resp, _ = dhcpv4.NewReplyFromRequest(req)
|
|
assert.Equal(t, 1, s.process(req, resp))
|
|
|
|
// check "Ack"
|
|
assert.Equal(t, dhcpv4.MessageTypeAck, resp.MessageType())
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", resp.ClientHWAddr.String())
|
|
assert.True(t, net.IP{192, 168, 10, 150}.Equal(resp.YourIPAddr))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.Router()[0]))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.ServerIdentifier()))
|
|
assert.True(t, net.IP{255, 255, 255, 0}.Equal(net.IP(resp.SubnetMask())))
|
|
assert.Equal(t, s.conf.leaseTime.Seconds(), resp.IPAddressLeaseTime(-1).Seconds())
|
|
|
|
dnsAddrs := resp.DNS()
|
|
assert.Len(t, dnsAddrs, 1)
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(dnsAddrs[0]))
|
|
|
|
// check lease
|
|
ls := s.GetLeases(LeasesStatic)
|
|
assert.Len(t, ls, 1)
|
|
assert.True(t, net.IP{192, 168, 10, 150}.Equal(ls[0].IP))
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", ls[0].HWAddr.String())
|
|
}
|
|
|
|
func TestV4DynamicLeaseGet(t *testing.T) {
|
|
conf := V4ServerConf{
|
|
Enabled: true,
|
|
RangeStart: net.IP{192, 168, 10, 100},
|
|
RangeEnd: net.IP{192, 168, 10, 200},
|
|
GatewayIP: net.IP{192, 168, 10, 1},
|
|
SubnetMask: net.IP{255, 255, 255, 0},
|
|
notify: notify4,
|
|
Options: []string{
|
|
"81 hex 303132",
|
|
"82 ip 1.2.3.4",
|
|
},
|
|
}
|
|
sIface, err := v4Create(conf)
|
|
s, ok := sIface.(*v4Server)
|
|
assert.True(t, ok)
|
|
assert.Nil(t, err)
|
|
s.conf.dnsIPAddrs = []net.IP{{192, 168, 10, 1}}
|
|
|
|
// "Discover"
|
|
mac, _ := net.ParseMAC("aa:aa:aa:aa:aa:aa")
|
|
req, _ := dhcpv4.NewDiscovery(mac)
|
|
resp, _ := dhcpv4.NewReplyFromRequest(req)
|
|
assert.Equal(t, 1, s.process(req, resp))
|
|
|
|
// check "Offer"
|
|
assert.Equal(t, dhcpv4.MessageTypeOffer, resp.MessageType())
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", resp.ClientHWAddr.String())
|
|
assert.True(t, net.IP{192, 168, 10, 100}.Equal(resp.YourIPAddr))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.Router()[0]))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.ServerIdentifier()))
|
|
assert.True(t, net.IP{255, 255, 255, 0}.Equal(net.IP(resp.SubnetMask())))
|
|
assert.Equal(t, s.conf.leaseTime.Seconds(), resp.IPAddressLeaseTime(-1).Seconds())
|
|
assert.Equal(t, []byte("012"), resp.Options[uint8(dhcpv4.OptionFQDN)])
|
|
assert.True(t, net.IP{1, 2, 3, 4}.Equal(net.IP(resp.Options[uint8(dhcpv4.OptionRelayAgentInformation)])))
|
|
|
|
// "Request"
|
|
req, _ = dhcpv4.NewRequestFromOffer(resp)
|
|
resp, _ = dhcpv4.NewReplyFromRequest(req)
|
|
assert.Equal(t, 1, s.process(req, resp))
|
|
|
|
// check "Ack"
|
|
assert.Equal(t, dhcpv4.MessageTypeAck, resp.MessageType())
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", resp.ClientHWAddr.String())
|
|
assert.True(t, net.IP{192, 168, 10, 100}.Equal(resp.YourIPAddr))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.Router()[0]))
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(resp.ServerIdentifier()))
|
|
assert.True(t, net.IP{255, 255, 255, 0}.Equal(net.IP(resp.SubnetMask())))
|
|
assert.Equal(t, s.conf.leaseTime.Seconds(), resp.IPAddressLeaseTime(-1).Seconds())
|
|
|
|
dnsAddrs := resp.DNS()
|
|
assert.Len(t, dnsAddrs, 1)
|
|
assert.True(t, net.IP{192, 168, 10, 1}.Equal(dnsAddrs[0]))
|
|
|
|
// check lease
|
|
ls := s.GetLeases(LeasesDynamic)
|
|
assert.Len(t, ls, 1)
|
|
assert.True(t, net.IP{192, 168, 10, 100}.Equal(ls[0].IP))
|
|
assert.Equal(t, "aa:aa:aa:aa:aa:aa", ls[0].HWAddr.String())
|
|
|
|
start := net.IP{192, 168, 10, 100}
|
|
stop := net.IP{192, 168, 10, 200}
|
|
assert.False(t, ip4InRange(start, stop, net.IP{192, 168, 10, 99}))
|
|
assert.False(t, ip4InRange(start, stop, net.IP{192, 168, 11, 100}))
|
|
assert.False(t, ip4InRange(start, stop, net.IP{192, 168, 11, 201}))
|
|
assert.True(t, ip4InRange(start, stop, net.IP{192, 168, 10, 100}))
|
|
}
|