add more tests

aklivity · Nov 8, 2024 · 950d29e · 950d29e
1 parent 64a0321
commit 950d29e
Show file tree

Hide file tree

Showing 9 changed files with 319 additions and 28 deletions.
diff --git a/grpc.kafka.fanout/README.md b/grpc.kafka.fanout/README.md
@@ -29,14 +29,20 @@ docker compose up -d
 Prepare protobuf message to send to Kafka topic.
 
 ```bash
-echo 'message: "test"' | protoc --encode=example.FanoutMessage proto/fanout.proto > binary.data
+echo 'message: "test"' | protoc --encode=example.FanoutMessage fanout.proto > binary.data
+```
+
+Copy the binary file into the `kafkacat` service.
+
+```bash
+docker compose -p zilla-grpc-kafka-fanout cp binary.data kafkacat:/tmp/binary.data
 ```
 
 Produce protobuf message to Kafka topic, repeat to produce multiple messages.
 
 ```bash
 docker compose -p zilla-grpc-kafka-fanout exec kafkacat \
-  kafkacat -P -b kafka:29092 -t messages -k -e ./binary.data
+  kafkacat -P -b kafka:29092 -t messages -k -e /tmp/binary.data
 ```
 
 Stream messages via server streaming rpc.
@@ -95,7 +101,7 @@ Then produce another protobuf message to Kafka, repeat to produce multiple messa
 
 ```bash
 docker compose -p zilla-grpc-kafka-fanout exec kafkacat \
-  kafkacat -P -b kafka:29092 -t messages -k -e ./binary.data
+  kafkacat -P -b kafka:29092 -t messages -k -e /tmp/binary.data
 ```
 
 The reliable streaming client will recover and zilla deliver only the new message.

diff --git a/grpc.kafka.fanout/compose.yaml b/grpc.kafka.fanout/compose.yaml
@@ -57,8 +57,7 @@ services:
     command:
       - |
         echo -e "Creating kafka topic";
-        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic items-requests
-        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic items-responses --config cleanup.policy=compact
+        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic messages
         echo -e "Successfully created the following topics:";
         /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --list;
 

diff --git a/grpc.kafka.proxy/compose.yaml b/grpc.kafka.proxy/compose.yaml
@@ -72,8 +72,8 @@ services:
     command:
       - |
         echo -e "Creating kafka topic";
-        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic items-requests
-        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic items-responses --config cleanup.policy=compact
+        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic echo-requests
+        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --create --if-not-exists --topic echo-responses
         echo -e "Successfully created the following topics:";
         /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server kafka:29092 --list;
 

diff --git a/grpc.kafka.proxy/test.sh b/grpc.kafka.proxy/test.sh
@@ -0,0 +1,115 @@
+#!/bin/sh
+set -x
+
+EXIT=0
+
+# GIVEN
+PORT="7151"
+INPUT='{"message":"Hello World"}'
+EXPECTED='{
+  "message": "Hello World"
+}'
+echo \# Testing grpc.kafka.proxy/grpc.examples.echo.Echo.UnaryEcho
+echo PORT="$PORT"
+echo INPUT="$INPUT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(docker run --rm -v ./echo.proto:/echo.proto fullstorydev/grpcurl -plaintext -proto echo.proto  -d "$INPUT" host.docker.internal:$PORT grpc.examples.echo.Echo.UnaryEcho)
+RESULT=$?
+echo RESULT="$RESULT"
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+# GIVEN
+PORT="7151"
+INPUT='{"message":"Hello World"}'
+EXPECTED='{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}'
+echo \# Testing grpc.kafka.proxy/grpc.examples.echo.Echo.ServerStreamingEcho
+echo PORT="$PORT"
+echo INPUT="$INPUT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(docker run --rm -v ./echo.proto:/echo.proto fullstorydev/grpcurl -plaintext -proto echo.proto  -d "$INPUT" host.docker.internal:$PORT grpc.examples.echo.Echo.ServerStreamingEcho)
+RESULT=$?
+echo RESULT="$RESULT"
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+
+# GIVEN
+PORT="7151"
+INPUT='{"message":"Hello World"}'
+EXPECTED='{
+  "message": "Hello World"
+}'
+echo \# Testing grpc.kafka.proxy/grpc.examples.echo.Echo.BidirectionalStreamingEcho
+echo PORT="$PORT"
+echo INPUT="$INPUT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(docker run --rm -v ./echo.proto:/echo.proto fullstorydev/grpcurl -plaintext -proto echo.proto  -d "$INPUT" host.docker.internal:$PORT grpc.examples.echo.Echo.BidirectionalStreamingEcho)
+RESULT=$?
+echo RESULT="$RESULT"
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+exit $EXIT
diff --git a/grpc.proxy/README.md b/grpc.proxy/README.md
@@ -28,7 +28,7 @@ docker compose up -d
 Echo `{"message":"Hello World"}` message via unary rpc.
 
 ```bash
-grpcurl -insecure -proto echo.proto  -d '{"message":"Hello World"}' localhost:7151 grpc.examples.echo.Echo.UnaryEcho
+grpcurl -insecure -proto echo.proto  -d '{"message":"Hello World"}' localhost:7153 grpc.examples.echo.Echo.UnaryEcho
 ```
 
 output:
@@ -44,7 +44,7 @@ output:
 Echo messages via bidirectional streaming rpc.
 
 ```bash
-grpcurl -insecure -proto echo.proto -d @ localhost:7151 grpc.examples.echo.Echo.BidirectionalStreamingEcho
+grpcurl -insecure -proto echo.proto -d @ localhost:7153 grpc.examples.echo.Echo.BidirectionalStreamingEcho
 ```
 
 Paste below message.

diff --git a/grpc.proxy/test.sh b/grpc.proxy/test.sh
@@ -0,0 +1,91 @@
+#!/bin/sh
+set -x
+
+EXIT=0
+
+# GIVEN
+PORT="7153"
+INPUT='{"message":"Hello World"}'
+EXPECTED='{
+  "message": "Hello World"
+}'
+echo \# Testing grpc.kafka.proxy/grpc.examples.echo.Echo.UnaryEcho
+echo PORT="$PORT"
+echo INPUT="$INPUT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(docker run --rm -v ./echo.proto:/echo.proto fullstorydev/grpcurl -insecure -proto echo.proto  -d "$INPUT" host.docker.internal:$PORT grpc.examples.echo.Echo.UnaryEcho)
+RESULT=$?
+echo RESULT="$RESULT"
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+# GIVEN
+PORT="7153"
+INPUT='{"message":"Hello World"}'
+EXPECTED='{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}
+{
+  "message": "Hello World"
+}'
+echo \# Testing grpc.kafka.proxy/grpc.examples.echo.Echo.ServerStreamingEcho
+echo PORT="$PORT"
+echo INPUT="$INPUT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(docker run --rm -v ./echo.proto:/echo.proto fullstorydev/grpcurl -insecure -proto echo.proto  -d "$INPUT" host.docker.internal:$PORT grpc.examples.echo.Echo.ServerStreamingEcho)
+RESULT=$?
+echo RESULT="$RESULT"
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+# TODO remove once fixed
+echo '❌ Tested on main. and does not work with described instructions'
+EXIT=1
+
+exit $EXIT
diff --git a/http.filesystem/README.md b/http.filesystem/README.md
@@ -4,9 +4,7 @@ Listens on http port `7114` and serves files from the Zilla container's `/var/ww
 
 ## Requirements
 
-- jq, nc
 - Compose compatible host
-- curl
 
 ## Setup
 
@@ -41,23 +39,6 @@ output:
 </html>
 ```
 
-```bash
-curl --cacert test-ca.crt http://localhost:7114/index.html
-```
-
-output:
-
-```html
-<html>
-  <head>
-    <title>Welcome to Zilla!</title>
-  </head>
-  <body>
-    <h1>Welcome to Zilla!</h1>
-  </body>
-</html>
-```
-
 ## Teardown
 
 The `teardown.sh` script will remove any resources created.

diff --git a/http.filesystem/test.sh b/http.filesystem/test.sh
@@ -0,0 +1,37 @@
+#!/bin/sh
+set -x
+
+EXIT=0
+
+# GIVEN
+PORT="7114"
+EXPECTED='<html>
+<head>
+<title>Welcome to Zilla!</title>
+</head>
+<body>
+<h1>Welcome to Zilla!</h1>
+</body>
+</html>'
+echo \# Testing http.filesystem/
+echo PORT="$PORT"
+echo EXPECTED="$EXPECTED"
+echo
+
+# WHEN
+OUTPUT=$(curl http://localhost:$PORT/index.html)
+RESULT=$?
+echo RESULT="$RESULT"
+
+# THEN
+echo OUTPUT="$OUTPUT"
+echo EXPECTED="$EXPECTED"
+echo
+if [ "$RESULT" -eq 0 ] && [ "$OUTPUT" = "$EXPECTED" ]; then
+  echo ✅
+else
+  echo ❌
+  EXIT=1
+fi
+
+exit $EXIT