]> git.proxmox.com Git - pve-firewall.git/blobdiff - src/PVE/Firewall.pm
verify macro parameters when updating a rule using API
[pve-firewall.git] / src / PVE / Firewall.pm
index 6d4127e8585917c51c841497959d902a8a8620cd..1b83334c170ea293402a3364e866f31d04b3ff4e 100644 (file)
@@ -6,6 +6,7 @@ use POSIX;
 use Data::Dumper;
 use Digest::SHA;
 use PVE::INotify;
+use PVE::Exception qw(raise raise_param_exc);
 use PVE::JSONSchema qw(get_standard_option);
 use PVE::Cluster;
 use PVE::ProcFSTools;
@@ -68,124 +69,134 @@ my $log_level_hash = {
 # imported/converted from: /usr/share/shorewall/macro.*
 my $pve_fw_macros = {
     'Amanda' => [
+       "Amanda Backup",
        { action => 'PARAM', proto => 'udp', dport => '10080' },
        { action => 'PARAM', proto => 'tcp', dport => '10080' },
     ],
     'Auth' => [
+       "Auth (identd) traffic",
        { action => 'PARAM', proto => 'tcp', dport => '113' },
     ],
     'BGP' => [
+       "Border Gateway Protocol traffic",
        { action => 'PARAM', proto => 'tcp', dport => '179' },
     ],
     'BitTorrent' => [
+       "BitTorrent traffic for BitTorrent 3.1 and earlier",
        { action => 'PARAM', proto => 'tcp', dport => '6881:6889' },
        { action => 'PARAM', proto => 'udp', dport => '6881' },
     ],
     'BitTorrent32' => [
+       "BitTorrent traffic for BitTorrent 3.2 and later",
        { action => 'PARAM', proto => 'tcp', dport => '6881:6999' },
        { action => 'PARAM', proto => 'udp', dport => '6881' },
     ],
     'CVS' => [
+       "Concurrent Versions System pserver traffic",
        { action => 'PARAM', proto => 'tcp', dport => '2401' },
     ],
     'Citrix' => [
+       "Citrix/ICA traffic (ICA, ICA Browser, CGP)",
        { action => 'PARAM', proto => 'tcp', dport => '1494' },
        { action => 'PARAM', proto => 'udp', dport => '1604' },
        { action => 'PARAM', proto => 'tcp', dport => '2598' },
     ],
     'DAAP' => [
+       "Digital Audio Access Protocol traffic (iTunes, Rythmbox daemons)",
        { action => 'PARAM', proto => 'tcp', dport => '3689' },
        { action => 'PARAM', proto => 'udp', dport => '3689' },
     ],
     'DCC' => [
+       "Distributed Checksum Clearinghouse spam filtering mechanism",
        { action => 'PARAM', proto => 'tcp', dport => '6277' },
     ],
     'DHCPfwd' => [
+       "Forwarded DHCP traffic (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '67:68', sport => '67:68' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '67:68', sport => '67:68' },
     ],
     'DNS' => [
+       "Domain Name System traffic (upd and tcp)",
        { action => 'PARAM', proto => 'udp', dport => '53' },
        { action => 'PARAM', proto => 'tcp', dport => '53' },
     ],
     'Distcc' => [
+       "Distributed Compiler service",
        { action => 'PARAM', proto => 'tcp', dport => '3632' },
     ],
-    'Edonkey' => [
-       { action => 'PARAM', proto => 'tcp', dport => '4662' },
-       { action => 'PARAM', proto => 'udp', dport => '4665' },
-    ],
     'FTP' => [
+       "File Transfer Protocol",
        { action => 'PARAM', proto => 'tcp', dport => '21' },
     ],
     'Finger' => [
+       "Finger protocol (RFC 742)",
        { action => 'PARAM', proto => 'tcp', dport => '79' },
     ],
     'GNUnet' => [
+       "GNUnet secure peer-to-peer networking traffic",
        { action => 'PARAM', proto => 'tcp', dport => '2086' },
        { action => 'PARAM', proto => 'udp', dport => '2086' },
        { action => 'PARAM', proto => 'tcp', dport => '1080' },
        { action => 'PARAM', proto => 'udp', dport => '1080' },
     ],
     'GRE' => [
+       "Generic Routing Encapsulation tunneling protocol (bidirectional)",
        { action => 'PARAM', proto => '47' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '47' },
     ],
     'Git' => [
+       "Git distributed revision control traffic",
        { action => 'PARAM', proto => 'tcp', dport => '9418' },
     ],
-    'Gnutella' => [
-       { action => 'PARAM', proto => 'tcp', dport => '6346' },
-       { action => 'PARAM', proto => 'udp', dport => '6346' },
-    ],
     'HKP' => [
+       "OpenPGP HTTP keyserver protocol traffic",
        { action => 'PARAM', proto => 'tcp', dport => '11371' },
     ],
     'HTTP' => [
+       "Hypertext Transfer Protocol (WWW)",
        { action => 'PARAM', proto => 'tcp', dport => '80' },
     ],
     'HTTPS' => [
+       "Hypertext Transfer Protocol (WWW) over SSL",
        { action => 'PARAM', proto => 'tcp', dport => '443' },
     ],
     'ICPV2' => [
+       "Internet Cache Protocol V2 (Squid) traffic",
        { action => 'PARAM', proto => 'udp', dport => '3130' },
     ],
     'ICQ' => [
+       "AOL Instant Messenger traffic",
        { action => 'PARAM', proto => 'tcp', dport => '5190' },
     ],
     'IMAP' => [
+       "Internet Message Access Protocol",
        { action => 'PARAM', proto => 'tcp', dport => '143' },
     ],
     'IMAPS' => [
+       "Internet Message Access Protocol over SSL",
        { action => 'PARAM', proto => 'tcp', dport => '993' },
     ],
     'IPIP' => [
+       "IPIP capsulation traffic (bidirectional)",
        { action => 'PARAM', proto => '94' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '94' },
     ],
-    'IPP' => [
-       { action => 'PARAM', proto => 'tcp', dport => '631' },
-    ],
-    'IPPbrd' => [
-       { action => 'PARAM', proto => 'udp', dport => '631' },
-    ],
-    'IPPserver' => [
-       { action => 'PARAM', source => 'SOURCE', dest => 'DEST', proto => 'tcp', dport => '631' },
-       { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '631' },
-    ],
     'IPsec' => [
+       "IPsec traffic (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '500', sport => '500' },
        { action => 'PARAM', proto => '50' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '500', sport => '500' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '50' },
     ],
     'IPsecah' => [
+       "IPsec authentication (AH) traffic (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '500', sport => '500' },
        { action => 'PARAM', proto => '51' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '500', sport => '500' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '51' },
     ],
     'IPsecnat' => [
+       "IPsec traffic and Nat-Traversal (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '500' },
        { action => 'PARAM', proto => 'udp', dport => '4500' },
        { action => 'PARAM', proto => '50' },
@@ -194,123 +205,142 @@ my $pve_fw_macros = {
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '50' },
     ],
     'IRC' => [
+       "Internet Relay Chat traffic",
        { action => 'PARAM', proto => 'tcp', dport => '6667' },
     ],
-    'JabberPlain' => [
-       { action => 'PARAM', proto => 'tcp', dport => '5222' },
-    ],
-    'JabberSecure' => [
-       { action => 'PARAM', proto => 'tcp', dport => '5223' },
-    ],
-    'Jabberd' => [
-       { action => 'PARAM', proto => 'tcp', dport => '5269' },
-    ],
     'Jetdirect' => [
+       "HP Jetdirect printing",
        { action => 'PARAM', proto => 'tcp', dport => '9100' },
     ],
     'L2TP' => [
+       "Layer 2 Tunneling Protocol traffic",
        { action => 'PARAM', proto => 'udp', dport => '1701' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '1701' },
     ],
     'LDAP' => [
+       "Lightweight Directory Access Protocol traffic",
        { action => 'PARAM', proto => 'tcp', dport => '389' },
     ],
     'LDAPS' => [
+       "Secure Lightweight Directory Access Protocol traffic",
        { action => 'PARAM', proto => 'tcp', dport => '636' },
     ],
     'MSNP' => [
+       "Microsoft Notification Protocol",
        { action => 'PARAM', proto => 'tcp', dport => '1863' },
     ],
     'MSSQL' => [
+       "Microsoft SQL Server",
        { action => 'PARAM', proto => 'tcp', dport => '1433' },
     ],
     'Mail' => [
+       "Mail traffic (SMTP, SMTPS, Submission)",
        { action => 'PARAM', proto => 'tcp', dport => '25' },
        { action => 'PARAM', proto => 'tcp', dport => '465' },
        { action => 'PARAM', proto => 'tcp', dport => '587' },
     ],
     'Munin' => [
+       "Munin networked resource monitoring traffic",
        { action => 'PARAM', proto => 'tcp', dport => '4949' },
     ],
     'MySQL' => [
+       "MySQL server",
        { action => 'PARAM', proto => 'tcp', dport => '3306' },
     ],
     'NNTP' => [
+       "NNTP traffic (Usenet).",
        { action => 'PARAM', proto => 'tcp', dport => '119' },
     ],
     'NNTPS' => [
+       "Encrypted NNTP traffic (Usenet)",
        { action => 'PARAM', proto => 'tcp', dport => '563' },
     ],
     'NTP' => [
+       "Network Time Protocol (ntpd)",
        { action => 'PARAM', proto => 'udp', dport => '123' },
     ],
     'NTPbi' => [
+       "Bi-directional NTP (for NTP peers)",
        { action => 'PARAM', proto => 'udp', dport => '123' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '123' },
     ],
-    'NTPbrd' => [
-       { action => 'PARAM', proto => 'udp', dport => '123' },
-       { action => 'PARAM', proto => 'udp', dport => '1024:65535', sport => '123' },
-    ],
     'OSPF' => [
+       "OSPF multicast traffic",
        { action => 'PARAM', proto => '89' },
     ],
     'OpenVPN' => [
+       "OpenVPN traffic",
        { action => 'PARAM', proto => 'udp', dport => '1194' },
     ],
     'PCA' => [
+       "Symantec PCAnywere (tm)",
        { action => 'PARAM', proto => 'udp', dport => '5632' },
        { action => 'PARAM', proto => 'tcp', dport => '5631' },
     ],
     'POP3' => [
+       "POP3 traffic",
        { action => 'PARAM', proto => 'tcp', dport => '110' },
     ],
     'POP3S' => [
+       "Encrypted POP3 traffic",
        { action => 'PARAM', proto => 'tcp', dport => '995' },
     ],
     'PPtP' => [
+       "Point-to-Point Tunneling Protocol",
        { action => 'PARAM', proto => '47' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => '47' },
        { action => 'PARAM', proto => 'tcp', dport => '1723' },
     ],
     'Ping' => [
+       "ICMP echo request",
        { action => 'PARAM', proto => 'icmp', dport => 'echo-request' },
     ],
     'PostgreSQL' => [
+       "PostgreSQL server",
        { action => 'PARAM', proto => 'tcp', dport => '5432' },
     ],
     'Printer' => [
+       "Line Printer protocol printing",
        { action => 'PARAM', proto => 'tcp', dport => '515' },
     ],
     'RDP' => [
+       "Microsoft Remote Desktop Protocol traffic",
        { action => 'PARAM', proto => 'tcp', dport => '3389' },
     ],
     'RIPbi' => [
+       "Routing Information Protocol (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '520' },
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'udp', dport => '520' },
     ],
     'RNDC' => [
+       "BIND remote management protocol",
        { action => 'PARAM', proto => 'tcp', dport => '953' },
     ],
     'Razor' => [
+       "Razor Antispam System",
        { action => 'ACCEPT', proto => 'tcp', dport => '2703' },
     ],
     'Rdate' => [
+       "Remote time retrieval (rdate)",
        { action => 'PARAM', proto => 'tcp', dport => '37' },
     ],
     'Rsync' => [
+       "Rsync server",
        { action => 'PARAM', proto => 'tcp', dport => '873' },
     ],
     'SANE' => [
+       "SANE network scanning",
        { action => 'PARAM', proto => 'tcp', dport => '6566' },
     ],
     'SMB' => [
+       "Microsoft SMB traffic",
        { action => 'PARAM', proto => 'udp', dport => '135,445' },
        { action => 'PARAM', proto => 'udp', dport => '137:139' },
        { action => 'PARAM', proto => 'udp', dport => '1024:65535', sport => '137' },
        { action => 'PARAM', proto => 'tcp', dport => '135,139,445' },
     ],
     'SMBBI' => [
+       "Microsoft SMB traffic (bidirectional)",
        { action => 'PARAM', proto => 'udp', dport => '135,445' },
        { action => 'PARAM', proto => 'udp', dport => '137:139' },
        { action => 'PARAM', proto => 'udp', dport => '1024:65535', sport => '137' },
@@ -321,81 +351,104 @@ my $pve_fw_macros = {
        { action => 'PARAM', source => 'DEST', dest => 'SOURCE', proto => 'tcp', dport => '135,139,445' },
     ],
     'SMBswat' => [
+       "Samba Web Administration Tool",
        { action => 'PARAM', proto => 'tcp', dport => '901' },
     ],
     'SMTP' => [
+       "Simple Mail Transfer Protocol",
        { action => 'PARAM', proto => 'tcp', dport => '25' },
     ],
     'SMTPS' => [
+       "Encrypted Simple Mail Transfer Protocol",
        { action => 'PARAM', proto => 'tcp', dport => '465' },
     ],
     'SNMP' => [
+       "Simple Network Management Protocol",
        { action => 'PARAM', proto => 'udp', dport => '161:162' },
        { action => 'PARAM', proto => 'tcp', dport => '161' },
     ],
     'SPAMD' => [
+       "Spam Assassin SPAMD traffic",
        { action => 'PARAM', proto => 'tcp', dport => '783' },
     ],
     'SSH' => [
+       "Secure shell traffic",
        { action => 'PARAM', proto => 'tcp', dport => '22' },
     ],
     'SVN' => [
+       "Subversion server (svnserve)",
        { action => 'PARAM', proto => 'tcp', dport => '3690' },
     ],
     'SixXS' => [
+       "SixXS IPv6 Deployment and Tunnel Broker",
        { action => 'PARAM', proto => 'tcp', dport => '3874' },
        { action => 'PARAM', proto => 'udp', dport => '3740' },
        { action => 'PARAM', proto => '41' },
        { action => 'PARAM', proto => 'udp', dport => '5072,8374' },
     ],
     'Squid' => [
+       "Squid web proxy traffic",
        { action => 'PARAM', proto => 'tcp', dport => '3128' },
     ],
     'Submission' => [
+       "Mail message submission traffic",
        { action => 'PARAM', proto => 'tcp', dport => '587' },
     ],
     'Syslog' => [
+       "Syslog protocol (RFC 5424) traffic",
        { action => 'PARAM', proto => 'udp', dport => '514' },
        { action => 'PARAM', proto => 'tcp', dport => '514' },
     ],
     'TFTP' => [
+       "Trivial File Transfer Protocol traffic",
        { action => 'PARAM', proto => 'udp', dport => '69' },
     ],
     'Telnet' => [
+       "Telnet traffic",
        { action => 'PARAM', proto => 'tcp', dport => '23' },
     ],
     'Telnets' => [
+       "Telnet over SSL",
        { action => 'PARAM', proto => 'tcp', dport => '992' },
     ],
     'Time' => [
+       "RFC 868 Time protocol",
        { action => 'PARAM', proto => 'tcp', dport => '37' },
     ],
     'Trcrt' => [
+       "Traceroute (for up to 30 hops) traffic",
        { action => 'PARAM', proto => 'udp', dport => '33434:33524' },
        { action => 'PARAM', proto => 'icmp', dport => 'echo-request' },
     ],
     'VNC' => [
+       "VNC traffic for VNC display's 0 - 9",
        { action => 'PARAM', proto => 'tcp', dport => '5900:5909' },
     ],
     'VNCL' => [
+       "VNC traffic from Vncservers to Vncviewers in listen mode",
        { action => 'PARAM', proto => 'tcp', dport => '5500' },
     ],
     'Web' => [
+       "WWW traffic (HTTP and HTTPS)",
        { action => 'PARAM', proto => 'tcp', dport => '80' },
        { action => 'PARAM', proto => 'tcp', dport => '443' },
     ],
     'Webcache' => [
+       "Web Cache/Proxy traffic (port 8080)",
        { action => 'PARAM', proto => 'tcp', dport => '8080' },
     ],
     'Webmin' => [
+       "Webmin traffic",
        { action => 'PARAM', proto => 'tcp', dport => '10000' },
     ],
     'Whois' => [
+       "Whois (nicname, RFC 3912) traffic",
        { action => 'PARAM', proto => 'tcp', dport => '43' },
     ],
 };
 
 my $pve_fw_parsed_macros;
+my $pve_fw_macro_descr;
 my $pve_fw_preferred_macro_names = {};
 
 my $pve_std_chains = {
@@ -533,6 +586,9 @@ sub init_firewall_macros {
     foreach my $k (keys %$pve_fw_macros) {
        my $lc_name = lc($k);
        my $macro = $pve_fw_macros->{$k};
+       if (!ref($macro->[0])) {
+           $pve_fw_macro_descr->{$k} = shift @$macro;
+       }
        $pve_fw_preferred_macro_names->{$lc_name} = $k;
        $pve_fw_parsed_macros->{$k} = $macro;
     }
@@ -540,6 +596,10 @@ sub init_firewall_macros {
 
 init_firewall_macros();
 
+sub get_macros {
+    return wantarray ? ($pve_fw_parsed_macros, $pve_fw_macro_descr): $pve_fw_parsed_macros;
+}
+
 my $etc_services;
 
 sub get_etc_services {
@@ -633,31 +693,29 @@ sub parse_port_name_number_or_range {
     my ($str) = @_;
 
     my $services = PVE::Firewall::get_etc_services();
-    my $nbports = 0;
+    my $count = 0;
     foreach my $item (split(/,/, $str)) {
-       my $portlist = "";
-       my $oldpon = undef;
-       $nbports++;
-       foreach my $pon (split(':', $item, 2)) {
-           $pon = $services->{byname}->{$pon}->{port} if $services->{byname}->{$pon}->{port};
-           if ($pon =~ m/^\d+$/){
-               die "invalid port '$pon'\n" if $pon < 0 && $pon > 65535;
-               die "port '$pon' must be bigger than port '$oldpon' \n" if $oldpon && ($pon < $oldpon);
-               $oldpon = $pon;
-           }else{
-               die "invalid port $services->{byname}->{$pon}\n" if !$services->{byname}->{$pon};
-           }
+       $count++;
+       if ($item =~ m/^(\d+):(\d+)$/) {
+           my ($port1, $port2) = ($1, $2);
+           die "invalid port '$port1'\n" if $port1 > 65535;
+           die "invalid port '$port2'\n" if $port2 > 65535;
+       } elsif ($item =~ m/^(\d+)$/) {
+           my $port = $1;
+           die "invalid port '$port'\n" if $port > 65535;
+       } else {
+           die "invalid port '$item'\n" if !$services->{byname}->{$item}; 
        }
     }
 
-    return ($nbports);
+    return $count;
 }
 
 PVE::JSONSchema::register_format('pve-fw-port-spec', \&pve_fw_verify_port_spec);
 sub pve_fw_verify_port_spec {
    my ($portstr) = @_;
 
-    parse_port_name_number_or_range($portstr);
+   parse_port_name_number_or_range($portstr);
 
    return $portstr;
 }
@@ -789,6 +847,112 @@ sub delete_rule_properties {
     return $rule;
 }
 
+my $apply_macro = sub {
+    my ($macro_name, $param, $verify) = @_;
+
+    my $macro_rules = $pve_fw_parsed_macros->{$macro_name};
+    die "unknown macro '$macro_name'\n" if !$macro_rules; # should not happen
+
+    my $rules = [];
+
+    foreach my $templ (@$macro_rules) {
+       my $rule = {};
+       my $param_used = {};
+       foreach my $k (keys %$templ) {
+           my $v = $templ->{$k};
+           if ($v eq 'PARAM') {
+               $v = $param->{$k};
+               $param_used->{$k} = 1;
+           } elsif ($v eq 'DEST') {
+               $v = $param->{dest};
+               $param_used->{dest} = 1;
+           } elsif ($v eq 'SOURCE') {
+               $v = $param->{source};
+               $param_used->{source} = 1;
+           }
+
+           if (!defined($v)) {
+               my $msg = "missing parameter '$k' in macro '$macro_name'";
+               raise_param_exc({ macro => $msg }) if $verify; 
+               die "$msg\n";
+           }
+           $rule->{$k} = $v;
+       }
+       foreach my $k (keys %$param) {
+           next if $k eq 'macro';
+           next if !defined($param->{$k});
+           next if $param_used->{$k};
+           if (defined($rule->{$k})) {
+               if ($rule->{$k} ne $param->{$k}) {
+                   my $msg = "parameter '$k' already define in macro (value = '$rule->{$k}')";
+                   raise_param_exc({ $k => $msg }) if $verify; 
+                   die "$msg\n";
+               }
+           } else {
+               $rule->{$k} = $param->{$k};
+           }
+       }
+       push @$rules, $rule;
+    }
+
+    return $rules;
+};
+
+sub verify_rule {
+    my ($rule, $allow_groups) = @_;
+
+    my $type = $rule->{type};
+
+    raise_param_exc({ type => "missing property"}) if !$type;
+    raise_param_exc({ action => "missing property"}) if !$rule->{action};
+    if ($type eq  'in' || $type eq 'out') {
+       raise_param_exc({ action => "unknown action '$rule->{action}'"})
+           if $rule->{action} !~ m/^(ACCEPT|DROP|REJECT)$/;
+    } elsif ($type eq 'group') {
+       raise_param_exc({ type => "security groups not allowed"}) 
+           if !$allow_groups;
+       raise_param_exc({ action => "invalid characters in security group name"}) 
+           if $rule->{action} !~ m/^[A-Za-z0-9_\-]+$/;
+    } else {
+       raise_param_exc({ type => "unknown rule type '$type'"});
+    }
+   
+    # fixme: verify $rule->{iface}?
+
+    if ($rule->{macro}) {
+       my $preferred_name = $pve_fw_preferred_macro_names->{lc($rule->{macro})};
+       raise_param_exc({ macro => "unknown macro '$rule->{macro}'"}) if !$preferred_name;
+       $rule->{macro} = $preferred_name;
+    }
+
+    if ($rule->{dport}) {
+       eval { parse_port_name_number_or_range($rule->{dport}); };
+       raise_param_exc({ dport => $@ }) if $@;
+    }
+
+    if ($rule->{sport}) {
+       eval { parse_port_name_number_or_range($rule->{sport}); };
+       raise_param_exc({ sport => $@ }) if $@;
+    }
+
+    if ($rule->{source}) {
+       eval { parse_address_list($rule->{source}); };
+       raise_param_exc({ source => $@ }) if $@;
+    }
+
+    if ($rule->{dest}) {
+       eval { parse_address_list($rule->{dest}); };
+       raise_param_exc({ dest => $@ }) if $@;
+    }
+
+    if ($rule->{macro}) {
+       &$apply_macro($rule->{macro}, $rule, 1);
+    }
+
+    return $rule;
+}
+
 sub copy_rule_data {
     my ($rule, $param) = @_;
 
@@ -803,6 +967,9 @@ sub copy_rule_data {
            delete $rule->{$k};
        }
     }
+
+    # verify rule now
+
     return $rule;
 }
 
@@ -1042,50 +1209,6 @@ sub ruleset_generate_cmdstr {
     return scalar(@cmd) ? join(' ', @cmd) : undef;
 }
 
-my $apply_macro = sub {
-    my ($macro_name, $param) = @_;
-
-    my $macro_rules = $pve_fw_parsed_macros->{$macro_name};
-    die "unknown macro '$macro_name'\n" if !$macro_rules; # should not happen
-
-    my $rules = [];
-
-    foreach my $templ (@$macro_rules) {
-       my $rule = {};
-       my $param_used = {};
-       foreach my $k (keys %$templ) {
-           my $v = $templ->{$k};
-           if ($v eq 'PARAM') {
-               $v = $param->{$k};
-               $param_used->{$k} = 1;
-           } elsif ($v eq 'DEST') {
-               $v = $param->{dest};
-               $param_used->{dest} = 1;
-           } elsif ($v eq 'SOURCE') {
-               $v = $param->{source};
-               $param_used->{source} = 1;
-           }
-
-           die "missing parameter '$k' in macro '$macro_name'\n" if !defined($v);
-           $rule->{$k} = $v;
-       }
-       foreach my $k (keys %$param) {
-           next if $k eq 'macro';
-           next if !defined($param->{$k});
-           next if $param_used->{$k};
-           if (defined($rule->{$k})) {
-               die "parameter '$k' already define in macro (value = '$rule->{$k}')\n"
-                   if $rule->{$k} ne $param->{$k};
-           } else {
-               $rule->{$k} = $param->{$k};
-           }
-       }
-       push @$rules, $rule;
-    }
-
-    return $rules;
-};
-
 sub ruleset_generate_rule {
     my ($ruleset, $chain, $rule, $actions, $goto, $cluster_conf) = @_;
 
@@ -1974,7 +2097,11 @@ my $format_rules = sub {
        if ($rule->{type} eq  'in' || $rule->{type} eq 'out') {
            $raw .= '|' if defined($rule->{enable}) && !$rule->{enable};
            $raw .= uc($rule->{type});
-           $raw .= " " . $rule->{action};
+           if ($rule->{macro}) {
+               $raw .= " $rule->{macro}($rule->{action})";
+           } else {
+               $raw .= " " . $rule->{action};
+           }
            $raw .= " " . ($rule->{iface} || '-') if $need_iface;
            $raw .= " " . ($rule->{source} || '-');
            $raw .= " " . ($rule->{dest} || '-');