]>
git.proxmox.com Git - pve-firewall.git/blob - test/fwtester.pl
25 my ($chain, $rule, $pkg) = @_;
27 $rule =~ s/^-A $chain // || die "got strange rule: $rule";
29 if ($rule =~ s/^-m conntrack\s*//) {
30 return undef; # simply ignore
33 if ($rule =~ s/^-m addrtype\s*//) {
34 return undef; # simply ignore
37 if ($rule =~ s/^-i (\S+)\s*//) {
38 die "missing iface_in" if !$pkg->{iface_in
};
39 return undef if $pkg->{iface_in
} ne $1; # no match
41 if ($rule =~ s/^-o (\S+)\s*//) {
42 die "missing iface_out" if !$pkg->{iface_out
};
43 return undef if $pkg->{iface_out
} ne $1; # no match
46 if ($rule =~ s/^-p (tcp|udp)\s*//) {
47 die "missing proto" if !$pkg->{proto
};
48 return undef if $pkg->{proto
} ne $1; # no match
51 if ($rule =~ s/^--dport (\d+):(\d+)\s*//) {
52 die "missing dport" if !$pkg->{dport
};
53 return undef if ($pkg->{dport
} < $1) || ($pkg->{dport
} > $2); # no match
56 if ($rule =~ s/^--dport (\d+)\s*//) {
57 die "missing dport" if !$pkg->{dport
};
58 return undef if $pkg->{dport
} != $1; # no match
61 if ($rule =~ s/^-s (\S+)\s*//) {
62 die "missing source" if !$pkg->{source
};
63 return undef if $pkg->{source
} ne $1; # no match
66 if ($rule =~ s/^-d (\S+)\s*//) {
67 die "missing destination" if !$pkg->{dest
};
68 return undef if $pkg->{dest
} ne $1; # no match
71 if ($rule =~ s/^-m mac ! --mac-source (\S+)\s*//) {
72 die "missing source mac" if !$pkg->{mac_source
};
73 return undef if $pkg->{mac_source
} eq $1; # no match
76 if ($rule =~ s/^-m physdev --physdev-is-bridged --physdev-in (\S+)\s*//) {
79 return undef if !$pkg->{physdev_in
};
80 return undef if $pkg->{physdev_in
} !~ m/^${devre}$/;
83 if ($rule =~ s/^-m physdev --physdev-is-bridged --physdev-out (\S+)\s*//) {
86 return undef if !$pkg->{physdev_out
};
87 return undef if $pkg->{physdev_out
} !~ m/^${devre}$/;
90 if ($rule =~ s/^-j MARK --set-mark (\d+)\s*$//) {
95 if ($rule =~ s/^-j (\S+)\s*$//) {
99 if ($rule =~ s/^-g (\S+)\s*$//) {
103 die "unable to parse rule: $rule";
106 sub ruleset_simulate_chain
{
107 my ($ruleset, $chain, $pkg) = @_;
109 add_trace
("ENTER chain $chain\n");
111 if ($chain eq 'PVEFW-Drop') {
112 add_trace
("LEAVE chain $chain\n");
115 if ($chain eq 'PVEFW-reject') {
116 add_trace
("LEAVE chain $chain\n");
120 if ($chain eq 'PVEFW-tcpflags') {
121 add_trace
("LEAVE chain $chain\n");
125 my $rules = $ruleset->{$chain} ||
126 die "no such chain '$chain'";
128 foreach my $rule (@$rules) {
129 my ($goto, $action) = rule_match
($chain, $rule, $pkg);
130 if (!defined($action)) {
131 add_trace
("SKIP: $rule\n");
134 add_trace
("MATCH: $rule\n");
136 if ($action eq 'ACCEPT' || $action eq 'DROP' || $action eq 'REJECT') {
137 add_trace
("TERMINATE chain $chain: $action\n");
139 } elsif ($action eq 'RETURN') {
140 add_trace
("RETURN FROM chain $chain\n");
144 add_trace
("LEAVE chain $chain - goto $action\n");
145 return ruleset_simulate_chain
($ruleset, $action, $pkg)
147 #$rules = $ruleset->{$chain} || die "no such chain '$chain'";
149 if ($action = ruleset_simulate_chain
($ruleset, $action, $pkg)) {
152 add_trace
("CONTINUE chain $chain\n");
157 add_trace
("LEAVE chain $chain\n");
158 if ($chain =~ m/^PVEFW-(INPUT|OUTPUT|FORWARD)$/) {
159 return 'ACCEPT'; # default policy
170 while (my ($k,$v) = each %$pkg) {
177 # Try to simulate packet traversal inside kernel. This invokes iptable
178 # checks several times.
180 my ($ruleset, $ipset_ruleset, $pkg, $from_info, $target, $start_state) = @_;
182 my $route_state = $start_state;
186 while ($route_state ne $target->{iface
}) {
189 my $next_route_state;
192 $pkg->{iface_in
} = $pkg->{iface_out
} = undef;
193 $pkg->{physdev_in
} = $pkg->{physdev_out
} = undef;
195 if ($route_state eq 'host') {
197 if ($target->{type
} eq 'ct') {
198 $pkg->{iface_in
} = 'lo';
199 $pkg->{iface_out
} = 'venet0';
200 $chain = 'PVEFW-OUTPUT';
201 $next_route_state = 'venet-in';
202 } elsif ($target->{type
} eq 'vm') {
203 $pkg->{iface_in
} = 'lo';
204 $pkg->{iface_out
} = $target->{bridge
} || die 'internal error';
205 $chain = 'PVEFW-OUTPUT';
206 $next_route_state = 'fwbr-in';
211 } elsif ($route_state eq 'venet-out') {
213 if ($target->{type
} eq 'host') {
215 $chain = 'PVEFW-INPUT';
216 $pkg->{iface_in
} = 'venet0';
217 $pkg->{iface_out
} = 'lo';
218 $next_route_state = 'host';
220 } elsif ($target->{type
} eq 'vm') {
222 $chain = 'PVEFW-FORWARD';
223 $pkg->{iface_in
} = 'venet0';
224 $pkg->{iface_out
} = $target->{bridge
} || die 'internal error';
225 $next_route_state = 'fwbr-in';
227 } elsif ($target->{type
} eq 'ct') {
229 $chain = 'PVEFW-FORWARD';
230 $pkg->{iface_in
} = 'venet0';
231 $pkg->{iface_out
} = 'venet0';
232 $next_route_state = 'venet-in';
238 } elsif ($route_state eq 'fwbr-out') {
240 $chain = 'PVEFW-FORWARD';
241 $next_route_state = $from_info->{bridge
} || die 'internal error';
242 $next_physdev_in = $from_info->{fwpr
} || die 'internal error';
243 $pkg->{iface_in
} = $from_info->{fwbr
} || die 'internal error';
244 $pkg->{iface_out
} = $from_info->{fwbr
} || die 'internal error';
245 $pkg->{physdev_in
} = $from_info->{tapdev
} || die 'internal error';
246 $pkg->{physdev_out
} = $from_info->{fwln
} || die 'internal error';
248 } elsif ($route_state eq 'fwbr-in') {
250 $chain = 'PVEFW-FORWARD';
251 $next_route_state = $target->{tapdev
};
252 $pkg->{iface_in
} = $target->{fwbr
} || die 'internal error';
253 $pkg->{iface_out
} = $target->{fwbr
} || die 'internal error';
254 $pkg->{physdev_in
} = $target->{fwln
} || die 'internal error';
255 $pkg->{physdev_out
} = $target->{tapdev
} || die 'internal error';
257 } elsif ($route_state =~ m/^vmbr\d+$/) {
259 die "missing physdev_in - internal error?" if !$physdev_in;
261 if ($target->{type
} eq 'host') {
263 $chain = 'PVEFW-INPUT';
264 $pkg->{iface_in
} = $route_state;
265 $pkg->{iface_out
} = 'lo';
266 $next_route_state = 'host';
268 } elsif ($target->{type
} eq 'ct') {
270 $chain = 'PVEFW-FORWARD';
271 $pkg->{iface_in
} = $route_state;
272 $pkg->{iface_out
} = 'venet0';
273 $next_route_state = 'venet-in';
275 } elsif ($target->{type
} eq 'vm') {
277 $chain = 'PVEFW-FORWARD';
278 if ($route_state eq $target->{bridge
}) {
279 $pkg->{iface_in
} = $route_state;
280 $pkg->{iface_out
} = $route_state;
281 $pkg->{physdev_in
} = $physdev_in;
282 $pkg->{physdev_out
} = $target->{fwpr
} || die 'internal error';
284 $pkg->{iface_in
} = $route_state;
285 $pkg->{iface_out
} = $route_state;
286 $pkg->{physdev_in
} = $physdev_in;
287 # do not set physdev_out (same behavior as kernel)
289 $next_route_state = 'fwbr-in';
296 die "implement me $route_state";
299 die "internal error" if !defined($next_route_state);
302 add_trace
("IPT check at $route_state (chain $chain)\n");
303 add_trace
(Dumper
($pkg));
304 my $res = ruleset_simulate_chain
($ruleset, $chain, $pkg);
305 return $res if $res ne 'ACCEPT';
308 $route_state = $next_route_state;
310 $physdev_in = $next_physdev_in;
316 sub extract_ct_info
{
317 my ($vmdata, $vmid) = @_;
319 my $info = { type
=> 'ct', vmid
=> $vmid };
321 my $conf = $vmdata->{openvz
}->{$vmid} || die "no such CT '$vmid'";
322 if ($conf->{ip_address
}) {
323 $info->{ip_address
} = $conf->{ip_address
}->{value
};
330 sub extract_vm_info
{
331 my ($vmdata, $vmid) = @_;
333 my $info = { type
=> 'vm', vmid
=> $vmid };
335 my $conf = $vmdata->{qemu
}->{$vmid} || die "no such VM '$vmid'";
336 my $net = PVE
::QemuServer
::parse_net
($conf->{net0
});
337 $info->{macaddr
} = $net->{macaddr
} || die "unable to get mac address";
338 $info->{bridge
} = $net->{bridge
} || die "unable to get bridge";
339 $info->{fwbr
} = "fwbr${vmid}i0";
340 $info->{tapdev
} = "tap${vmid}i0";
341 $info->{fwln
} = "fwln${vmid}i0";
342 $info->{fwpr
} = "fwpr${vmid}p0";
347 sub simulate_firewall
{
348 my ($ruleset, $ipset_ruleset, $vmdata, $test) = @_;
350 my $from = delete $test->{from
} || die "missing 'from' field";
351 my $to = delete $test->{to
} || die "missing 'to' field";
352 my $action = delete $test->{action
} || die "missing 'action'";
354 die "from/to needs to be different" if $from eq $to;
360 source
=> '10.11.12.13',
361 dest
=> '10.11.12.14',
364 while (my ($k,$v) = each %$test) {
372 if ($from eq 'host') {
373 $from_info->{type
} = 'host';
374 $start_state = 'host';
375 } elsif ($from =~ m/^ct(\d+)$/) {
377 $from_info = extract_ct_info
($vmdata, $vmid);
378 if ($from_info->{ip_address
}) {
379 $pkg->{source
} = $from_info->{ip_address
};
380 $start_state = 'venet-out';
384 } elsif ($from =~ m/^vm(\d+)$/) {
386 $from_info = extract_vm_info
($vmdata, $vmid);
387 $start_state = 'fwbr-out';
388 $pkg->{mac_source
} = $from_info->{macaddr
};
396 $target->{type
} = 'host';
397 $target->{iface
} = 'host';
398 } elsif ($to =~ m/^ct(\d+)$/) {
400 $target = extract_ct_info
($vmdata, $vmid);
401 $target->{iface
} = 'venet-in';
403 if ($target->{ip_address
}) {
404 $pkg->{dest
} = $target->{ip_address
};
408 } elsif ($to =~ m/^vm(\d+)$/) {
410 $target = extract_vm_info
($vmdata, $vmid);
411 $target->{iface
} = $target->{tapdev
};
416 my $res = route_packet
($ruleset, $ipset_ruleset, $pkg, $from_info, $target, $start_state);
418 die "test failed ($res != $action)\n" if $action ne $res;
424 my ($vmdata, $testdir) = @_;
426 $vmdata->{testdir
} = $testdir;
428 my ($ruleset, $ipset_ruleset) =
429 PVE
::Firewall
::compile
(undef, undef, $vmdata);
431 my $testfile = "$testdir/tests";
432 my $fh = IO
::File-
>new($testfile) ||
433 die "unable to open '$testfile' - $!\n";
435 while (defined(my $line = <$fh>)) {
436 next if $line =~ m/^\s*$/;
437 next if $line =~ m/^#.*$/;
438 if ($line =~ m/^\{.*\}\s*$/) {
439 my $test = eval $line;
442 print Dumper
($ruleset) if $debug;
443 eval { simulate_firewall
($ruleset, $ipset_ruleset, $vmdata, $test); };
446 print Dumper
($ruleset) if !$debug;
448 print "$trace\n" if !$debug;
450 print "$testfile line $.: $line";
452 print "test failed: $err\n";
461 print "PASS: $testfile\n";
469 net0
=> "e1000=0E:0B:38:B8:B3:21,bridge=vmbr0",
472 net0
=> "e1000=0E:0B:38:B8:B3:22,bridge=vmbr0",
476 net0
=> "e1000=0E:0B:38:B8:B4:21,bridge=vmbr1",
481 ip_address
=> { value
=> '10.0.200.1' },
484 ip_address
=> { value
=> '10.0.200.2' },
489 foreach my $dir (<test-
*>) {
491 run_tests
($vmdata, $dir);
494 print "OK - all tests passed\n";