54 lines
1.3 KiB
Bash
Executable File
54 lines
1.3 KiB
Bash
Executable File
#!/usr/bin/env bash
|
|
set -Eeuo pipefail
|
|
|
|
# https://www.rabbitmq.com/tutorials/tutorial-one-python.html
|
|
|
|
dir="$(dirname "$(readlink -f "$BASH_SOURCE")")"
|
|
|
|
serverImage="$1"
|
|
|
|
clientImage="$("$dir/../image-name.sh" librarytest/rabbitmq-basics "$serverImage")"
|
|
"$dir/../docker-build.sh" "$dir" "$clientImage" <<EOD
|
|
FROM python:3.10-alpine
|
|
# ensure pip does not complain about a new version being available
|
|
ENV PIP_DISABLE_PIP_VERSION_CHECK=1
|
|
RUN pip install pika==1.1.0
|
|
COPY dir/*.py /usr/local/bin/
|
|
EOD
|
|
|
|
cname="rabbitmq-container-$RANDOM-$RANDOM"
|
|
# use sh to create a minimal config so that we don't get this error on 3.9+:
|
|
# PLAIN login refused: user 'guest' can only connect via localhost
|
|
cid="$(
|
|
docker run -d \
|
|
--name "$cname" \
|
|
--user rabbitmq \
|
|
--entrypoint sh \
|
|
"$serverImage" \
|
|
-c 'echo "loopback_users.guest = false" >> /etc/rabbitmq/rabbitmq.conf && exec rabbitmq-server'
|
|
)"
|
|
trap "docker rm -vf $cid > /dev/null" EXIT
|
|
|
|
client() {
|
|
docker run -i --rm \
|
|
--link "$cname":rabbitmq \
|
|
"$clientImage" \
|
|
"$@"
|
|
}
|
|
|
|
. "$dir/../../retry.sh" 'client testconn.py'
|
|
|
|
test-send-recv() {
|
|
local payload="$1"; shift
|
|
client send.py "$payload"
|
|
response="$(client receive.py)"
|
|
if [ "$payload" != "$response" ]; then
|
|
echo >&2 "error: expected '$payload' but got '$response' instead"
|
|
return 1
|
|
fi
|
|
}
|
|
|
|
test-send-recv 'hello'
|
|
test-send-recv "$RANDOM"
|
|
test-send-recv $'a\nb\nc\td'
|