fix: avoid buffering of messages

The while-loop was re-introduced, because without it 5-10 messages have been buffered before they were delivered.

Author: git-developer

image/signal-mqtt

@@ -113,12 +113,15 @@ subscribe_for_jsonrpc() {
   export MQTT_SUBSCRIBE_TOPIC
   printf %s "${MQTT_SUBSCRIBE_OPTIONS}" \
   | xargs mosquitto_sub -t "${MQTT_SUBSCRIBE_TOPIC}/#" -F %j \
-  | jq --raw-output --compact-output 'to_jsonrpc(env.MQTT_SUBSCRIBE_TOPIC)' \
-  | if [ "${LOG_JSONRPC:-false}" != 'true' ]; then
-      cat -
+  | while read -r json; do
+    printf '%s\n' "${json}" \
+    | jq --raw-output --compact-output 'to_jsonrpc(env.MQTT_SUBSCRIBE_TOPIC)' \
+    | if [ "${LOG_JSONRPC:-false}" = 'true' ]; then
+      { log "$(tee /dev/fd/3)"; } 3>&1
     else
-      while read -r line; do echo "${line}"; log "${line}"; done
+      cat -
     fi
+  done
 }
 
 #######################################