Update tools_service.py

tools_service.py

@@ -84,9 +84,14 @@ class ToolsService:
             }
         ]
 
-    async def execute_tool(self, tool_name: str, arguments: Dict) -> Any:
+    async def execute_tool(self, tool_name: str, arguments: Dict, access_token: Optional[str] = None) -> Any:
         """
         Execute a tool by name with arguments
+        
+        Args:
+            tool_name: Name of the tool
+            arguments: Tool arguments
+            access_token: JWT token for authenticated API calls
         """
         print(f"🔧 Executing Tool: {tool_name} with args: {arguments}")
         
@@ -95,7 +100,10 @@ class ToolsService:
                 return await self._get_event_details(arguments.get("event_id") or arguments.get("event_code"))
             
             elif tool_name == "get_purchased_events":
-                return await self._get_purchased_events(arguments.get("user_id"))
+                return await self._get_purchased_events(
+                    arguments.get("user_id"),
+                    access_token=access_token  # Pass access_token
+                )
             
             elif tool_name == "save_feedback":
                 return await self._save_feedback(
@@ -137,8 +145,8 @@ class ToolsService:
         except Exception as e:
             return {"error": str(e)}
 
-    async def _get_purchased_events(self, user_id: str) -> List[Dict]:
-        """Call API to get purchased events for user"""
+    async def _get_purchased_events(self, user_id: str, access_token: Optional[str] = None) -> List[Dict]:
+        """Call API to get purchased events for user (requires auth)"""
         if not user_id:
             return []
             
@@ -146,7 +154,13 @@ class ToolsService:
             url = f"{self.base_url}/event/get-purchase-event-by-user-id/{user_id}"
             print(f"🔍 Calling API: {url}")
             
-            response = await self.client.get(url)
+            # Add Authorization header if access_token provided
+            headers = {}
+            if access_token:
+                headers["Authorization"] = f"Bearer {access_token}"
+                print(f"🔐 Using access_token for authentication")
+            
+            response = await self.client.get(url, headers=headers)
             if response.status_code == 200:
                 data = response.json()
                 # API returns {data: [...]}