run.sh 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. #!/usr/bin/env bash
  2. set -Eeuo pipefail
  3. # https://www.rabbitmq.com/tutorials/tutorial-one-python.html
  4. dir="$(dirname "$(readlink -f "$BASH_SOURCE")")"
  5. serverImage="$1"
  6. clientImage="$("$dir/../image-name.sh" librarytest/rabbitmq-basics "$serverImage")"
  7. "$dir/../docker-build.sh" "$dir" "$clientImage" <<EOD
  8. FROM python:3.7-alpine
  9. # ensure pip does not complain about a new version being available
  10. ENV PIP_DISABLE_PIP_VERSION_CHECK=1
  11. RUN pip install pika==1.1.0
  12. COPY dir/*.py /usr/local/bin/
  13. EOD
  14. cname="rabbitmq-container-$RANDOM-$RANDOM"
  15. cid="$(docker run -d --name "$cname" "$serverImage")"
  16. trap "docker rm -vf $cid > /dev/null" EXIT
  17. client() {
  18. docker run -i --rm \
  19. --link "$cname":rabbitmq \
  20. "$clientImage" \
  21. "$@"
  22. }
  23. . "$dir/../../retry.sh" 'client testconn.py'
  24. test-send-recv() {
  25. local payload="$1"; shift
  26. client send.py "$payload"
  27. response="$(client receive.py)"
  28. if [ "$payload" != "$response" ]; then
  29. echo >&2 "error: expected '$payload' but got '$response' instead"
  30. return 1
  31. fi
  32. }
  33. test-send-recv 'hello'
  34. test-send-recv "$RANDOM"
  35. test-send-recv $'a\nb\nc\td'