ubi integration

pages/Semantic_Search.py

@@ -785,6 +785,7 @@ def render_answer(answer,index):
     placeholder_no_results  = st.empty()
 
     col_1, col_2,col_3 = st.columns([70,10,20])
+    lambda_url = "https://npf3wa47evhz44ee7us4gozomi0gcvkn.lambda-url.us-west-2.on.aws/"
     i = 0
     filter_out = 0
     if len(answer) == 0:
@@ -869,30 +870,40 @@ def render_answer(answer,index):
                     item_id =  ans['id']  # use a real ID if available
                     expander_key = f"expander_{item_id}"
                     opened_key = f"{item_id}_opened"
-                    expander = st.expander("Document Metadata:", expanded=False, key=expander_key)
-
-                    if expander:
-                        with expander:
-                            st.write(":green[default:]")
-                            st.json({"category:":ans['category'],"price":str(ans['price']),"gender_affinity":ans['gender_affinity'],"style":ans['style']},expanded = True)
-                            if("rekog" in ans):
-                                st.write(":green[enriched:]")
-                                st.json(ans['rekog'],expanded = True)
-                            # Log event only on first open
-                            if not st.session_state.get(opened_key):
-                                st.session_state[opened_key] = True
-
-                                # ✅ Build event
-                                event_payload = {
-                                    "action_name": "expander_open",
-                                    "query_id": st.session_state.get("query_id"),
-                                    "session_id": st.session_state.get("session_id"),
-                                    "item_id": item_id,
-                                    "timestamp": datetime.utcnow().isoformat() + "Z",
-                                    "message_type": "INFO",
-                                    "message": f"Expander opened for item {item_id}"
-                                }  
-                                status = ubi.send_to_lambda("ubi_events", event_payload)  
+                    
+                    with expander:
+                        st.write(":green[default:]")
+                        st.json({"category:":ans['category'],"price":str(ans['price']),"gender_affinity":ans['gender_affinity'],"style":ans['style']},expanded = True)
+                        if("rekog" in ans):
+                            st.write(":green[enriched:]")
+                            st.json(ans['rekog'],expanded = True)
+                        # Inject the hidden div for JS to hook into
+                        components.html(f"""
+                        <div id="{doc_id}" onclick="sendEvent('{doc_id}')"></div>
+
+                        <script>
+                        function sendEvent(itemId) {{
+                            fetch("{lambda_url}", {{
+                                method: "POST",
+                                headers: {{
+                                    "Content-Type": "application/json"
+                                }},
+                                body: JSON.stringify({{
+                                    action_name: "expander_open",
+                                    item_id: itemId,
+                                    session_id: "{st.session_state.get('session_id', 'unknown')}",
+                                    query_id: "{st.session_state.get('query_id', 'unknown')}",
+                                    timestamp: new Date().toISOString(),
+                                    message_type: "INFO",
+                                    message: "Expander opened for item " + itemId
+                                }})
+                            }}).then(response => console.log("Event sent for", itemId));
+                        }}
+
+                        // Automatically trigger click when the expander is opened
+                        document.getElementById("{doc_id}").click();
+                        </script>
+                        """, height=0)
                 with inner_col_1:
                     
                     if(st.session_state.input_evaluate == "enabled"):