Validate MQTT publisher to Zenoh subscriber pub/sub forwarding through configurable-streamer.
Run and validate this binary set:
utils/mosquitto/docker-compose.yamlconfigurable-streamerexample-streamer-uses bin mqtt_publisherexample-streamer-uses bin zenoh_subscribersource build/envsetup.sh highestexport REPORT_DIR="$OPENCODE_CONFIG_DIR/reports/transport-smoke-skills/smoke-zenoh-mqtt-ps-mqtt-publisher-zenoh-subscriber"mkdir -p "$REPORT_DIR"cargo build -p configurable-streamercargo build -p example-streamer-uses --bin mqtt_publisher --features mqtt-transportcargo build -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transportdocker compose -f utils/mosquitto/docker-compose.yaml up -dconfigurable-streamer:
source ../build/envsetup.sh highestRUST_LOG="up_streamer=debug,up_transport_mqtt5=debug" cargo run -- --config "CONFIG.json5" > "$REPORT_DIR/streamer.log" 2>&1 & echo $! > "$REPORT_DIR/streamer.pid"source build/envsetup.sh highestRUST_LOG=info cargo run -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transport -- --uauthority authority-b --uentity 0x5678 --uversion 0x1 --resource 0x1234 --source-authority authority-a --source-uentity 0x5BA0 --source-uversion 0x1 --source-resource 0x8001 > "$REPORT_DIR/subscriber.log" 2>&1 & echo $! > "$REPORT_DIR/subscriber.pid"source build/envsetup.sh highestexport RUST_LOG="info,up_transport_mqtt5=debug,example_streamer_uses=debug"timeout 45s cargo run -p example-streamer-uses --bin mqtt_publisher --features mqtt-transport -- --broker-uri localhost:1883 > "$REPORT_DIR/publisher.log" 2>&1; printf '%s\n' "$?" > "$REPORT_DIR/publisher.exit"rg -n "Sending Publish message" "$REPORT_DIR/publisher.log"rg -n "PublishReceiver: Received a message" "$REPORT_DIR/subscriber.log"rg -n "Sending on out_transport succeeded" "$REPORT_DIR/streamer.log"Pass only when all three checks match.
kill -INT "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || truekill -TERM "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || truedocker compose -f utils/mosquitto/docker-compose.yaml downpgrep -fa "configurable-streamer|mqtt_publisher|zenoh_subscriber" || true