gistfile1.txt
· 7.0 KiB · Text
Originalformat
#!/usr/bin/env bash
# ============================================
# Lifecycle
# ============================================
function cmd::block::on_load() {
flag::register --name
flag::register --type
flag::register --force
flag::register --quiet
flag::register --ip
flag::register --port
flag::register --proto
flag::register --subnet
flag::register --block-name
# System - NET Services
flag::register --service
}
# ============================================
# Help
# ============================================
function cmd::block::help() {
cat <<EOF
Usage: wgctl block --name <name> [options]
Block a client entirely or restrict access to specific IPs/ports/subnets.
Block rules are persisted and restored on WireGuard restart.
Options:
--name <name> Client name (e.g. phone-nuno)
--type <type> Device type (optional, combines with --name)
--ip <ip> Block access to specific IP (repeatable)
--subnet <cidr> Block access to subnet (repeatable)
--port <ip:port:proto> Block specific port, e.g. 10.0.0.210:9000:tcp (repeatable)
--force Skip confirmation prompt
--quiet Suppress output (used by group block)
Examples:
wgctl block --name phone-nuno
wgctl block --name nuno --type phone
wgctl block --name phone-nuno --ip 10.0.0.210
wgctl block --name phone-nuno --subnet 10.0.0.0/24
wgctl block --name phone-nuno --port 10.0.0.210:9000:tcp
wgctl ban --name phone-nuno
EOF
}
# ============================================
# Block Run
# ============================================
function cmd::block::run() {
local name="" type="" block_name=""
local ips=() subnets=() ports=() services=()
local quiet=false force=false
local changed=false
while [[ $# -gt 0 ]]; do
case "$1" in
--name) name="$2"; shift 2 ;;
--type) type="$2"; shift 2 ;;
--ip) ips+=("$2"); shift 2 ;;
--block-name) block_name="$2"; shift 2 ;;
--service) services+=("$2"); shift 2 ;;
--force) force=true; shift ;;
--quiet) quiet=true; shift ;;
--subnet) subnets+=("$2"); shift 2 ;;
--port) ports+=("$2"); shift 2 ;;
--help) cmd::block::help; return ;;
*)
log::error "Unknown flag: $1"
cmd::block::help
return 1 ;;
esac
done
[[ -z "$name" ]] && log::error "Missing required flag: --name" && \
cmd::block::help && return 1
name=$(peers::resolve_and_require "$name" "$type") || return 1
local client_ip
client_ip=$(peers::get_ip "$name") || return 1
# Full block if no specific targets
if [[ ${#ips[@]} -eq 0 && ${#ports[@]} -eq 0 && \
${#subnets[@]} -eq 0 && ${#services[@]} -eq 0 ]]; then
if peers::is_blocked "$name" || block::has_file "$name"; then
log::wg_warning "Client is already blocked: ${name}"
return 0
fi
monitor::update_endpoint_cache
cmd::block::_block_all "$name" "$client_ip" "$quiet"
return 0
fi
# Specific rules — check if already fully blocked
if block::has_file "$name"; then
local direct
direct=$(block::is_blocked_direct "$name")
if [[ "$direct" == "true" ]]; then
log::wg_warning "${name} is fully blocked — unblock first to add specific rules"
return 1
fi
fi
# Block specific IPs
for ip in "${ips[@]}"; do
ip::require_valid "$ip"
fw::block_ip "$client_ip" "$ip"
block::add_rule "$name" "$client_ip" "ip" "${block_name:-}" "$ip"
$quiet || log::wg_success "${ip} has been blocked for ${name}"
done
# Block specific subnets
for subnet in "${subnets[@]}"; do
ip::require_valid "$subnet"
fw::block_subnet "$client_ip" "$subnet"
block::add_rule "$name" "$client_ip" "subnet" "${block_name:-}" "$subnet"
$quiet || log::wg_success "${subnet} has been blocked for ${name}"
done
# Block specific ports
for entry in "${ports[@]}"; do
local b_target b_port b_proto
IFS=":" read -r b_target b_port b_proto <<< "$entry"
ip::require_valid "$b_target"
fw::block_port "$client_ip" "$b_target" "$b_port" "${b_proto:-tcp}"
block::add_rule "$name" "$client_ip" "port" "${block_name:-}" \
"$b_target" "$b_port" "${b_proto:-tcp}"
$quiet || log::wg_success "${client_ip}:${b_port}:${b_proto:-tcp} has been blocked for ${name}"
done
# Block services
for svc in "${services[@]}"; do
local resolved_lines=()
mapfile -t resolved_lines < <(net::resolve "$svc" 2>/dev/null)
if [[ ${#resolved_lines[@]} -eq 0 ]]; then
log::error "Service not found or has no ports: ${svc}"
return 1
fi
# Check if already blocked
local already_blocked=true
for resolved in "${resolved_lines[@]}"; do
if [[ "$resolved" == *:*:* ]]; then
local b_ip b_port b_proto
IFS=":" read -r b_ip b_port b_proto <<< "$resolved"
fw::has_block_rule "$client_ip" "$b_ip" "$b_proto" "$b_port" 2>/dev/null || \
{ already_blocked=false; break; }
else
fw::has_block_rule "$client_ip" "$resolved" 2>/dev/null || \
{ already_blocked=false; break; }
fi
done
if $already_blocked; then
$quiet || log::wg_warning "${svc} is already blocked for ${name}"
continue
fi
for resolved in "${resolved_lines[@]}"; do
if [[ "$resolved" == *:*:* ]]; then
local b_ip b_port b_proto
IFS=":" read -r b_ip b_port b_proto <<< "$resolved"
fw::block_port "$client_ip" "$b_ip" "$b_port" "$b_proto"
block::add_rule "$name" "$client_ip" "port" "$svc" \
"$b_ip" "$b_port" "$b_proto"
else
fw::block_ip "$client_ip" "$resolved"
block::add_rule "$name" "$client_ip" "ip" "$svc" "$resolved"
fi
done
changed=true
$quiet || log::wg_success "${svc} has been blocked for ${name}"
done
[[ ${#ips[@]} -gt 0 || ${#ports[@]} -gt 0 || \
${#subnets[@]} -gt 0 ]] && changed=true
# Reapply in correct order: rule ACCEPT first, then peer DROP rules
# Only reorder if rules were actually added
if $changed; then
local peer_rule
peer_rule=$(peers::get_meta "$name" "rule")
if [[ -n "$peer_rule" ]] && rule::exists "$peer_rule"; then
fw::flush_peer "$client_ip"
rule::apply "$peer_rule" "$client_ip" "$name"
block::restore_rules_for "$name" "$client_ip"
fi
fi
return 0
}
function cmd::block::_get_endpoint() {
local name="$1" public_key="$2"
local endpoint
endpoint=$(monitor::endpoint_for_key "$public_key")
if [[ -z "$endpoint" || "$endpoint" == "(none)" ]]; then
endpoint=$(monitor::get_cached_endpoint "$name")
fi
echo "$endpoint"
}
function cmd::block::_block_all() {
local name="${1:?name required}"
local client_ip="${2:?client_ip required}"
local quiet="${3:-false}"
# Apply fw rules and remove from server
block::apply_full "$name" "$client_ip"
# Mark as directly blocked
block::set_direct "$name" "$client_ip" "true"
$quiet || log::wg_success "${name} has been blocked."
}
| 1 | #!/usr/bin/env bash |
| 2 | |
| 3 | # ============================================ |
| 4 | # Lifecycle |
| 5 | # ============================================ |
| 6 | |
| 7 | function cmd::block::on_load() { |
| 8 | flag::register --name |
| 9 | flag::register --type |
| 10 | flag::register --force |
| 11 | flag::register --quiet |
| 12 | flag::register --ip |
| 13 | flag::register --port |
| 14 | flag::register --proto |
| 15 | flag::register --subnet |
| 16 | flag::register --block-name |
| 17 | |
| 18 | # System - NET Services |
| 19 | flag::register --service |
| 20 | } |
| 21 | |
| 22 | # ============================================ |
| 23 | # Help |
| 24 | # ============================================ |
| 25 | |
| 26 | function cmd::block::help() { |
| 27 | cat <<EOF |
| 28 | Usage: wgctl block --name <name> [options] |
| 29 | |
| 30 | Block a client entirely or restrict access to specific IPs/ports/subnets. |
| 31 | Block rules are persisted and restored on WireGuard restart. |
| 32 | |
| 33 | Options: |
| 34 | --name <name> Client name (e.g. phone-nuno) |
| 35 | --type <type> Device type (optional, combines with --name) |
| 36 | --ip <ip> Block access to specific IP (repeatable) |
| 37 | --subnet <cidr> Block access to subnet (repeatable) |
| 38 | --port <ip:port:proto> Block specific port, e.g. 10.0.0.210:9000:tcp (repeatable) |
| 39 | --force Skip confirmation prompt |
| 40 | --quiet Suppress output (used by group block) |
| 41 | |
| 42 | Examples: |
| 43 | wgctl block --name phone-nuno |
| 44 | wgctl block --name nuno --type phone |
| 45 | wgctl block --name phone-nuno --ip 10.0.0.210 |
| 46 | wgctl block --name phone-nuno --subnet 10.0.0.0/24 |
| 47 | wgctl block --name phone-nuno --port 10.0.0.210:9000:tcp |
| 48 | wgctl ban --name phone-nuno |
| 49 | EOF |
| 50 | } |
| 51 | |
| 52 | # ============================================ |
| 53 | # Block Run |
| 54 | # ============================================ |
| 55 | |
| 56 | function cmd::block::run() { |
| 57 | local name="" type="" block_name="" |
| 58 | local ips=() subnets=() ports=() services=() |
| 59 | local quiet=false force=false |
| 60 | local changed=false |
| 61 | |
| 62 | while [[ $# -gt 0 ]]; do |
| 63 | case "$1" in |
| 64 | --name) name="$2"; shift 2 ;; |
| 65 | --type) type="$2"; shift 2 ;; |
| 66 | --ip) ips+=("$2"); shift 2 ;; |
| 67 | --block-name) block_name="$2"; shift 2 ;; |
| 68 | --service) services+=("$2"); shift 2 ;; |
| 69 | --force) force=true; shift ;; |
| 70 | --quiet) quiet=true; shift ;; |
| 71 | --subnet) subnets+=("$2"); shift 2 ;; |
| 72 | --port) ports+=("$2"); shift 2 ;; |
| 73 | --help) cmd::block::help; return ;; |
| 74 | *) |
| 75 | log::error "Unknown flag: $1" |
| 76 | cmd::block::help |
| 77 | return 1 ;; |
| 78 | esac |
| 79 | done |
| 80 | |
| 81 | [[ -z "$name" ]] && log::error "Missing required flag: --name" && \ |
| 82 | cmd::block::help && return 1 |
| 83 | |
| 84 | name=$(peers::resolve_and_require "$name" "$type") || return 1 |
| 85 | |
| 86 | local client_ip |
| 87 | client_ip=$(peers::get_ip "$name") || return 1 |
| 88 | |
| 89 | # Full block if no specific targets |
| 90 | if [[ ${#ips[@]} -eq 0 && ${#ports[@]} -eq 0 && \ |
| 91 | ${#subnets[@]} -eq 0 && ${#services[@]} -eq 0 ]]; then |
| 92 | if peers::is_blocked "$name" || block::has_file "$name"; then |
| 93 | log::wg_warning "Client is already blocked: ${name}" |
| 94 | return 0 |
| 95 | fi |
| 96 | monitor::update_endpoint_cache |
| 97 | cmd::block::_block_all "$name" "$client_ip" "$quiet" |
| 98 | return 0 |
| 99 | fi |
| 100 | |
| 101 | # Specific rules — check if already fully blocked |
| 102 | if block::has_file "$name"; then |
| 103 | local direct |
| 104 | direct=$(block::is_blocked_direct "$name") |
| 105 | if [[ "$direct" == "true" ]]; then |
| 106 | log::wg_warning "${name} is fully blocked — unblock first to add specific rules" |
| 107 | return 1 |
| 108 | fi |
| 109 | fi |
| 110 | |
| 111 | # Block specific IPs |
| 112 | for ip in "${ips[@]}"; do |
| 113 | ip::require_valid "$ip" |
| 114 | fw::block_ip "$client_ip" "$ip" |
| 115 | block::add_rule "$name" "$client_ip" "ip" "${block_name:-}" "$ip" |
| 116 | $quiet || log::wg_success "${ip} has been blocked for ${name}" |
| 117 | done |
| 118 | |
| 119 | # Block specific subnets |
| 120 | for subnet in "${subnets[@]}"; do |
| 121 | ip::require_valid "$subnet" |
| 122 | fw::block_subnet "$client_ip" "$subnet" |
| 123 | block::add_rule "$name" "$client_ip" "subnet" "${block_name:-}" "$subnet" |
| 124 | $quiet || log::wg_success "${subnet} has been blocked for ${name}" |
| 125 | done |
| 126 | |
| 127 | # Block specific ports |
| 128 | for entry in "${ports[@]}"; do |
| 129 | local b_target b_port b_proto |
| 130 | IFS=":" read -r b_target b_port b_proto <<< "$entry" |
| 131 | ip::require_valid "$b_target" |
| 132 | fw::block_port "$client_ip" "$b_target" "$b_port" "${b_proto:-tcp}" |
| 133 | block::add_rule "$name" "$client_ip" "port" "${block_name:-}" \ |
| 134 | "$b_target" "$b_port" "${b_proto:-tcp}" |
| 135 | $quiet || log::wg_success "${client_ip}:${b_port}:${b_proto:-tcp} has been blocked for ${name}" |
| 136 | done |
| 137 | |
| 138 | # Block services |
| 139 | for svc in "${services[@]}"; do |
| 140 | local resolved_lines=() |
| 141 | mapfile -t resolved_lines < <(net::resolve "$svc" 2>/dev/null) |
| 142 | if [[ ${#resolved_lines[@]} -eq 0 ]]; then |
| 143 | log::error "Service not found or has no ports: ${svc}" |
| 144 | return 1 |
| 145 | fi |
| 146 | |
| 147 | # Check if already blocked |
| 148 | local already_blocked=true |
| 149 | for resolved in "${resolved_lines[@]}"; do |
| 150 | if [[ "$resolved" == *:*:* ]]; then |
| 151 | local b_ip b_port b_proto |
| 152 | IFS=":" read -r b_ip b_port b_proto <<< "$resolved" |
| 153 | fw::has_block_rule "$client_ip" "$b_ip" "$b_proto" "$b_port" 2>/dev/null || \ |
| 154 | { already_blocked=false; break; } |
| 155 | else |
| 156 | fw::has_block_rule "$client_ip" "$resolved" 2>/dev/null || \ |
| 157 | { already_blocked=false; break; } |
| 158 | fi |
| 159 | done |
| 160 | |
| 161 | if $already_blocked; then |
| 162 | $quiet || log::wg_warning "${svc} is already blocked for ${name}" |
| 163 | continue |
| 164 | fi |
| 165 | |
| 166 | for resolved in "${resolved_lines[@]}"; do |
| 167 | if [[ "$resolved" == *:*:* ]]; then |
| 168 | local b_ip b_port b_proto |
| 169 | IFS=":" read -r b_ip b_port b_proto <<< "$resolved" |
| 170 | fw::block_port "$client_ip" "$b_ip" "$b_port" "$b_proto" |
| 171 | block::add_rule "$name" "$client_ip" "port" "$svc" \ |
| 172 | "$b_ip" "$b_port" "$b_proto" |
| 173 | else |
| 174 | fw::block_ip "$client_ip" "$resolved" |
| 175 | block::add_rule "$name" "$client_ip" "ip" "$svc" "$resolved" |
| 176 | fi |
| 177 | done |
| 178 | |
| 179 | changed=true |
| 180 | $quiet || log::wg_success "${svc} has been blocked for ${name}" |
| 181 | done |
| 182 | |
| 183 | [[ ${#ips[@]} -gt 0 || ${#ports[@]} -gt 0 || \ |
| 184 | ${#subnets[@]} -gt 0 ]] && changed=true |
| 185 | |
| 186 | # Reapply in correct order: rule ACCEPT first, then peer DROP rules |
| 187 | # Only reorder if rules were actually added |
| 188 | if $changed; then |
| 189 | local peer_rule |
| 190 | peer_rule=$(peers::get_meta "$name" "rule") |
| 191 | if [[ -n "$peer_rule" ]] && rule::exists "$peer_rule"; then |
| 192 | fw::flush_peer "$client_ip" |
| 193 | rule::apply "$peer_rule" "$client_ip" "$name" |
| 194 | block::restore_rules_for "$name" "$client_ip" |
| 195 | fi |
| 196 | fi |
| 197 | |
| 198 | return 0 |
| 199 | } |
| 200 | |
| 201 | function cmd::block::_get_endpoint() { |
| 202 | local name="$1" public_key="$2" |
| 203 | local endpoint |
| 204 | endpoint=$(monitor::endpoint_for_key "$public_key") |
| 205 | if [[ -z "$endpoint" || "$endpoint" == "(none)" ]]; then |
| 206 | endpoint=$(monitor::get_cached_endpoint "$name") |
| 207 | fi |
| 208 | echo "$endpoint" |
| 209 | } |
| 210 | |
| 211 | function cmd::block::_block_all() { |
| 212 | local name="${1:?name required}" |
| 213 | local client_ip="${2:?client_ip required}" |
| 214 | local quiet="${3:-false}" |
| 215 | |
| 216 | # Apply fw rules and remove from server |
| 217 | block::apply_full "$name" "$client_ip" |
| 218 | |
| 219 | # Mark as directly blocked |
| 220 | block::set_direct "$name" "$client_ip" "true" |
| 221 | |
| 222 | $quiet || log::wg_success "${name} has been blocked." |
| 223 | } |