Firewalld tests
Signed-off-by: Jiri Popelka <jpopelka@redhat.com>
This commit is contained in:
parent
bc71145164
commit
4bc66e193f
1 changed files with 78 additions and 0 deletions
78
iptables/firewalld_test.go
Normal file
78
iptables/firewalld_test.go
Normal file
|
@ -0,0 +1,78 @@
|
||||||
|
package iptables
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net"
|
||||||
|
"strconv"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestFirewalldInit(t *testing.T) {
|
||||||
|
FirewalldInit()
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestReloaded(t *testing.T) {
|
||||||
|
var err error
|
||||||
|
var fwdChain *Chain
|
||||||
|
|
||||||
|
fwdChain, err = NewChain("FWD", "lo", Filter)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
defer fwdChain.Remove()
|
||||||
|
|
||||||
|
// copy-pasted from iptables_test:TestLink
|
||||||
|
ip1 := net.ParseIP("192.168.1.1")
|
||||||
|
ip2 := net.ParseIP("192.168.1.2")
|
||||||
|
port := 1234
|
||||||
|
proto := "tcp"
|
||||||
|
|
||||||
|
err = fwdChain.Link(Append, ip1, ip2, port, proto)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
} else {
|
||||||
|
// to be re-called again later
|
||||||
|
OnReloaded(func() { fwdChain.Link(Append, ip1, ip2, port, proto) })
|
||||||
|
}
|
||||||
|
|
||||||
|
rule1 := []string{
|
||||||
|
"-i", fwdChain.Bridge,
|
||||||
|
"-o", fwdChain.Bridge,
|
||||||
|
"-p", proto,
|
||||||
|
"-s", ip1.String(),
|
||||||
|
"-d", ip2.String(),
|
||||||
|
"--dport", strconv.Itoa(port),
|
||||||
|
"-j", "ACCEPT"}
|
||||||
|
|
||||||
|
if !Exists(fwdChain.Table, fwdChain.Name, rule1...) {
|
||||||
|
t.Fatalf("rule1 does not exist")
|
||||||
|
}
|
||||||
|
|
||||||
|
// flush all rules
|
||||||
|
fwdChain.Remove()
|
||||||
|
|
||||||
|
reloaded()
|
||||||
|
|
||||||
|
// make sure the rules have been recreated
|
||||||
|
if !Exists(fwdChain.Table, fwdChain.Name, rule1...) {
|
||||||
|
t.Fatalf("rule1 hasn't been recreated")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPassthrough(t *testing.T) {
|
||||||
|
rule1 := []string{
|
||||||
|
"-i", "lo",
|
||||||
|
"-p", "udp",
|
||||||
|
"--dport", "123",
|
||||||
|
"-j", "ACCEPT"}
|
||||||
|
|
||||||
|
if firewalldRunning {
|
||||||
|
_, err := Passthrough(Iptables, append([]string{"-A"}, rule1...)...)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if !Exists(Filter, "INPUT", rule1...) {
|
||||||
|
t.Fatalf("rule1 does not exist")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
Loading…
Reference in a new issue