| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 1 | #!/bin/sh | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 2 | # -*-sh-basic-offset: 4-*- | 
|  | 3 | # Usage: udp_proxy_wrapper.sh [PROXY_PARAM...] -- [SERVER_PARAM...] | 
| Bence Szépkúti | 700ee44 | 2020-05-26 00:33:31 +0200 | [diff] [blame] | 4 | # | 
| Bence Szépkúti | 1e14827 | 2020-08-07 13:07:28 +0200 | [diff] [blame] | 5 | # Copyright The Mbed TLS Contributors | 
| Bence Szépkúti | c7da1fe | 2020-05-26 01:54:15 +0200 | [diff] [blame] | 6 | # SPDX-License-Identifier: Apache-2.0 | 
|  | 7 | # | 
|  | 8 | # Licensed under the Apache License, Version 2.0 (the "License"); you may | 
|  | 9 | # not use this file except in compliance with the License. | 
|  | 10 | # You may obtain a copy of the License at | 
|  | 11 | # | 
|  | 12 | # http://www.apache.org/licenses/LICENSE-2.0 | 
|  | 13 | # | 
|  | 14 | # Unless required by applicable law or agreed to in writing, software | 
|  | 15 | # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT | 
|  | 16 | # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | 17 | # See the License for the specific language governing permissions and | 
|  | 18 | # limitations under the License. | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 19 |  | 
|  | 20 | set -u | 
|  | 21 |  | 
| Hanno Becker | 22829e9 | 2017-10-23 15:28:55 +0100 | [diff] [blame] | 22 | MBEDTLS_BASE="$(dirname -- "$0")/../.." | 
|  | 23 | TPXY_BIN="$MBEDTLS_BASE/programs/test/udp_proxy" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 24 | SRV_BIN="$MBEDTLS_BASE/programs/ssl/ssl_server2" | 
|  | 25 |  | 
|  | 26 | : ${VERBOSE:=0} | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 27 |  | 
|  | 28 | stop_proxy() { | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 29 | if [ -n "${tpxy_pid:-}" ]; then | 
|  | 30 | echo | 
|  | 31 | echo "  * Killing proxy (pid $tpxy_pid) ..." | 
|  | 32 | kill $tpxy_pid | 
|  | 33 | fi | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 34 | } | 
|  | 35 |  | 
|  | 36 | stop_server() { | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 37 | if [ -n "${srv_pid:-}" ]; then | 
|  | 38 | echo | 
|  | 39 | echo "  * Killing server (pid $srv_pid) ..." | 
|  | 40 | kill $srv_pid >/dev/null 2>/dev/null | 
|  | 41 | fi | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 42 | } | 
|  | 43 |  | 
|  | 44 | cleanup() { | 
|  | 45 | stop_server | 
|  | 46 | stop_proxy | 
| Gilles Peskine | 8149321 | 2017-10-24 12:22:40 +0200 | [diff] [blame] | 47 | exit 129 | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 48 | } | 
|  | 49 |  | 
|  | 50 | trap cleanup INT TERM HUP | 
|  | 51 |  | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 52 | # Extract the proxy parameters | 
|  | 53 | tpxy_cmd_snippet='"$TPXY_BIN"' | 
|  | 54 | while [ $# -ne 0 ] && [ "$1" != "--" ]; do | 
|  | 55 | tail="$1" quoted="" | 
|  | 56 | while [ -n "$tail" ]; do | 
|  | 57 | case "$tail" in | 
|  | 58 | *\'*) quoted="${quoted}${tail%%\'*}'\\''" tail="${tail#*\'}";; | 
|  | 59 | *) quoted="${quoted}${tail}"; tail=; false;; | 
|  | 60 | esac | 
|  | 61 | done | 
|  | 62 | tpxy_cmd_snippet="$tpxy_cmd_snippet '$quoted'" | 
|  | 63 | shift | 
|  | 64 | done | 
|  | 65 | unset tail quoted | 
|  | 66 | if [ $# -eq 0 ]; then | 
|  | 67 | echo "  * No server arguments (must be preceded by \" -- \") - exit" | 
|  | 68 | exit 3 | 
|  | 69 | fi | 
|  | 70 | shift | 
| Hanno Becker | a677cdd | 2017-10-23 15:29:31 +0100 | [diff] [blame] | 71 |  | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 72 | dtls_enabled= | 
|  | 73 | ipv6_in_use= | 
|  | 74 | server_port_orig= | 
|  | 75 | server_addr_orig= | 
|  | 76 | for param; do | 
|  | 77 | case "$param" in | 
|  | 78 | server_port=*) server_port_orig="${param#*=}";; | 
|  | 79 | server_addr=*:*) server_addr_orig="${param#*=}"; ipv6_in_use=1;; | 
|  | 80 | server_addr=*) server_addr_orig="${param#*=}";; | 
|  | 81 | dtls=[!0]*) dtls_enabled=1;; | 
|  | 82 | esac | 
|  | 83 | done | 
|  | 84 |  | 
|  | 85 | if [ -z "$dtls_enabled" ] || [ -n "$ipv6_in_use" ]; then | 
|  | 86 | echo >&2 "$0: Couldn't find DTLS enabling, or IPv6 is in use - immediate fallback to server application..." | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 87 | if [ $VERBOSE -gt 0 ]; then | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 88 | echo "[ $SRV_BIN $* ]" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 89 | fi | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 90 | exec "$SRV_BIN" "$@" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 91 | fi | 
|  | 92 |  | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 93 | if [ -z "$server_port_orig" ]; then | 
|  | 94 | server_port_orig=4433 | 
|  | 95 | fi | 
|  | 96 | echo "  * Server port:       $server_port_orig" | 
|  | 97 | tpxy_cmd_snippet="$tpxy_cmd_snippet \"listen_port=\$server_port_orig\"" | 
|  | 98 | tpxy_cmd_snippet="$tpxy_cmd_snippet \"server_port=\$server_port\"" | 
|  | 99 |  | 
|  | 100 | if [ -n "$server_addr_orig" ]; then | 
|  | 101 | echo "  * Server address:    $server_addr_orig" | 
|  | 102 | tpxy_cmd_snippet="$tpxy_cmd_snippet \"server_addr=\$server_addr_orig\"" | 
|  | 103 | tpxy_cmd_snippet="$tpxy_cmd_snippet \"listen_addr=\$server_addr_orig\"" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 104 | fi | 
|  | 105 |  | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 106 | server_port=$(( server_port_orig + 1 )) | 
|  | 107 | set -- "$@" "server_port=$server_port" | 
|  | 108 | echo "  * Intermediate port: $server_port" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 109 |  | 
|  | 110 | echo "  * Start proxy in background ..." | 
|  | 111 | if [ $VERBOSE -gt 0 ]; then | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 112 | echo "[ $tpxy_cmd_snippet ]" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 113 | fi | 
| Gilles Peskine | 8149321 | 2017-10-24 12:22:40 +0200 | [diff] [blame] | 114 | eval exec "$tpxy_cmd_snippet" >/dev/null 2>&1 & | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 115 | tpxy_pid=$! | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 116 |  | 
|  | 117 | if [ $VERBOSE -gt 0 ]; then | 
|  | 118 | echo "  * Proxy ID:          $TPXY_PID" | 
|  | 119 | fi | 
|  | 120 |  | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 121 | echo "  * Starting server ..." | 
|  | 122 | if [ $VERBOSE -gt 0 ]; then | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 123 | echo "[ $SRV_BIN $* ]" | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 124 | fi | 
|  | 125 |  | 
| Gilles Peskine | 8149321 | 2017-10-24 12:22:40 +0200 | [diff] [blame] | 126 | exec "$SRV_BIN" "$@" >&2 & | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 127 | srv_pid=$! | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 128 |  | 
| Gilles Peskine | afc4f89 | 2017-10-24 10:00:17 +0200 | [diff] [blame] | 129 | wait $srv_pid | 
| Hanno Becker | f65ca32 | 2017-10-10 14:44:57 +0100 | [diff] [blame] | 130 |  | 
|  | 131 | stop_proxy | 
|  | 132 | return 0 |