From 227ee756f4b825f04d8fb343d4ca1fa755ac7bc9 Mon Sep 17 00:00:00 2001
From: Ittipat Lusuk <ittipat.l@forth.co.th>
Date: Tue, 26 May 2026 14:13:27 +0700
Subject: [PATCH] [sheet-service] add ref

---
 main.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/main.py b/main.py
index 26c3419..1eb659c 100644
--- a/main.py
+++ b/main.py
@@ -340,6 +340,7 @@ def redis_message_handler():
                             "from": SERVICE_NAME,
                             "level": "content",
                             "to": user_id, 
+                            "ref": "catalog",
                             "content": result
                         }
                     }
@@ -541,7 +542,8 @@ def send_stream_notification(msg_type: str, content: any, batch_id: str, current
             "current_chunk": current_chunk,
             "total_chunks": total_chunks,
             "total_items": total_items,
-            "to": user_id, 
+            "to": user_id,
+            "ref": "catalog",
             "content": content
         }
     }
@@ -1638,6 +1640,7 @@ def handle_get_price(country: str, user_id: str, content: list):
                     "from": SERVICE_NAME,
                     "level": "content",
                     "to": user_id,
+                    "ref": "price",
                     "content": result
                 }
             }
@@ -1667,6 +1670,7 @@ def handle_get_price(country: str, user_id: str, content: list):
                     "from": SERVICE_NAME,
                     "level": "content",
                     "to": user_id,
+                    "ref": "price",
                     "content": {"error": str(e)}
                 }
             }