feat: Attempt to append offset and timestamp message

Author: Alan Christie

app/app.py

@@ -331,7 +331,9 @@ async def on_message_for_websocket(
         # - timestamp: int (milliseconds since Python time epoch)
         #              It's essentially time.time() x 1000
         r_stream = message_context.consumer.get_stream(message_context.subscriber_name)
-        _LOGGER.info("Got msg='%s' stream=%s es_id=%s", msg, r_stream, es_id)
+        _LOGGER.info(
+            "Got msg='%s' (type=%s) stream=%s es_id=%s", msg, type(msg), r_stream, es_id
+        )
         _LOGGER.info(
             "With offset=%s timestamp=%s",
             message_context.offset,
@@ -344,6 +346,10 @@ async def on_message_for_websocket(
             _LOGGER.info("Taking POISON for %s (stopping)...", es_id)
             shutdown = True
         elif msg:
+            # Add offset and timestamp to the end of the protobuf string
+            msg_str: str = msg.decode("utf-8")
+            msg_str += f"|{message_context.offset}|{message_context.timestamp}"
+            msg = msg_str.encode("utf-8")
             try:
                 await websocket.send_text(str(msg))
             except WebSocketDisconnect: