added travel assistant app

.vscode/launch.json

@@ -0,0 +1,20 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Solara: Launch",
+            "type": "python",
+            "request": "launch",
+            "program": "C:/Users/Sam/.conda/envs/solara/Scripts/solara.exe",
+            "args": [
+                "run",
+                "C:/Users/Sam/Projects/solara-projects/pages/02_openAI.py"
+            ],
+            "console": "integratedTerminal",
+            "justMyCode": true,
+            "env": {
+                "PYTHONNOUSERSITE": "True"
+            }
+        }
+    ]
+}

pages/.vscode/launch.json

@@ -0,0 +1,20 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Solara: Launch",
+            "type": "python",
+            "request": "launch",
+            "program": "C:/Users/Sam/.conda/envs/solara/Scripts/solara.exe",
+            "args": [
+                "run",
+                "C:/Users/Sam/Projects/solara-projects/pages/02_openAI.py"
+            ],
+            "console": "integratedTerminal",
+            "justMyCode": true,
+            "env": {
+                "PYTHONNOUSERSITE": "True"
+            }
+        }
+    ]
+}

pages/01_leafmap.py

@@ -1,33 +0,0 @@
-import leafmap
-import solara
-
-zoom = solara.reactive(2)
-center = solara.reactive((20, 0))
-
-
-class Map(leafmap.Map):
-    def __init__(self, **kwargs):
-        super().__init__(**kwargs)
-        # Add what you want below
-        
-
-
-@solara.component
-def Page():
-    with solara.Column(style={"min-width": "500px"}):
-        # solara components support reactive variables
-        # solara.SliderInt(label="Zoom level", value=zoom, min=1, max=20)
-        # using 3rd party widget library require wiring up the events manually
-        # using zoom.value and zoom.set
-        Map.element(  # type: ignore
-            zoom=zoom.value,
-            on_zoom=zoom.set,
-            center=center.value,
-            on_center=center.set,
-            scroll_wheel_zoom=True, 
-            toolbar_ctrl=False,
-            data_ctrl=False,
-            height="780px",
-        )
-        # solara.Text(f"Zoom: {zoom.value}")
-        # solara.Text(f"Center: {center.value}")

pages/01_openAI.py

@@ -0,0 +1,157 @@
+import os
+import time
+from typing import List, Dict, Any
+import leafmap
+import solara
+import solara.lab
+from solara.website.utils import apidoc
+from ipyleaflet import Marker, Icon
+import openai
+f#rom dotenv import load_dotenv
+
+# Load environment variables
+#load_dotenv()
+
+# Initialize OpenAI client
+client = openai.OpenAI(api_key=os.environ.get("OPENAI_API_KEY"))
+
+# Function to get response from OpenAI API
+def get_bot_response(user_message: str) -> str:
+    max_retries = 5
+    for attempt in range(max_retries):
+        try:
+            print(f"Sending message to assistant: {user_message}")  # Debug print
+
+            # Create a new thread
+            thread = client.beta.threads.create()
+            print(f"Thread created: {thread.id}")  # Debug print
+            
+            # Add the user's message to the thread
+            client.beta.threads.messages.create(
+                thread_id=thread.id, role="user", content=user_message
+            )
+
+            # Create a run for the assistant to process the thread
+            run = client.beta.threads.runs.create(
+                thread_id=thread.id,
+                assistant_id="asst_T72b3iw4R9d74NEZ2MvvdSY8",
+            )
+            print(f"Run created: {run.id}")  # Debug print
+
+            # Poll for completion with a timeout
+            start_time = time.time()
+            while True:
+                run = client.beta.threads.runs.retrieve(thread_id=thread.id, run_id=run.id)
+                if run.status == "completed":
+                    print("Run completed")  # Debug print
+                    break
+                elif run.status == "failed":
+                    print("Run failed")  # Debug print
+                    return "Sorry, I couldn't process the request. Please try again later."
+                elif time.time() - start_time > 60:  # Timeout after 60 seconds
+                    print("Run timeout")  # Debug print
+                    return "Sorry, the request timed out. Please try again later."
+                time.sleep(1)  # Add a delay to avoid hitting the rate limit
+
+            # Retrieve messages in the thread
+            messages = client.beta.threads.messages.list(thread_id=thread.id)
+            print(f"Messages retrieved: {len(messages.data)}")  # Debug print
+
+            # Find the most recent assistant response
+            for msg in reversed(messages.data):
+                if msg.role == "assistant":
+                    if msg.content:
+                        content = msg.content[0]
+                        print(f"Assistant response content: {content}")  # Debug print
+                        if hasattr(content, 'text'):
+                            return content.text.value.strip()
+                        elif hasattr(content, 'value'):
+                            return content.value.strip()
+            
+            return "Sorry, I couldn't fetch a response. Please try again later."
+        except Exception as e:
+            print(f"Failed to get response from OpenAI: {str(e)}")
+            return "Sorry, I couldn't fetch a response. Please try again later."
+
+# Function to get location info using the assistant
+def get_location_info(lat: float, lon: float) -> str:
+    user_message = (
+        f"Provide interesting facts, historical details, cultural insights, popular attractions, and travel advice "
+        f"for the location at latitude {lat} and longitude {lon}."
+    )
+    print(f"Generated user message: {user_message}")  # Debug print
+    return get_bot_response(user_message)
+
+# Function to handle map clicks
+def handle_map_click(**kwargs):
+    latlon = kwargs.get('coordinates')
+    if kwargs.get('type') == 'click' and latlon:
+        print(f"Coordinates received: {latlon}")  # Debug print
+        clicked_coordinates.set((latlon[0], latlon[1]))
+        
+        # Set "thinking" message in the chatbox
+        messages.value = [{"role": "assistant", "content": "Thinking... please wait."}]
+        
+        # Get the actual response
+        info = get_location_info(latlon[0], latlon[1])
+        print(f"Assistant response: {info}")  # Debug print
+        
+        # Update the chatbox with the actual response
+        messages.value = [{"role": "assistant", "content": info}]
+
+        # Clear existing markers and add a new one for the most recent click
+        for layer in kwargs['map_instance'].layers:
+            if isinstance(layer, Marker):
+                kwargs['map_instance'].remove_layer(layer)
+
+        marker = Marker(location=[latlon[0], latlon[1]], draggable=False)
+        kwargs['map_instance'].add_layer(marker)
+
+# Custom Map class
+class Map(leafmap.Map):
+    def __init__(self, **kwargs):
+        super().__init__(**kwargs)
+        self.on_interaction(lambda **kwargs: handle_map_click(map_instance=self, **kwargs))
+        self.fit_bounds([[49.674, -14.015], [61.061, 2.091]])
+        self.min_zoom = 3
+
+# Reactive variables
+zoom = solara.reactive(3)
+center = solara.reactive((0, 0))
+messages = solara.reactive([{"role": "assistant", "content": "Welcome! Click on the map to get travel advice and interesting facts about the location."}])  # This will hold our chat messages
+clicked_coordinates = solara.reactive((0, 0))  # This will hold the latest clicked coordinates
+
+# Main Page component
+@solara.component
+def Page():
+    with solara.Row(style={"gap": "20px", "padding": "20px"}):
+        # Map View Column
+        with solara.Column(style={"flex": "2"}):
+            with solara.Card( margin=0, style={"padding": "10px", "box-shadow": "0 4px 8px rgba(0,0,0,0.1)"}): 
+                Map.element(
+                    zoom=zoom.value,
+                    on_zoom=zoom.set,
+                    center=center.value,
+                    on_center=center.set,
+                    scroll_wheel_zoom=True, 
+                    toolbar_ctrl=False,
+                    draw_control=False,
+                    data_ctrl=False,
+                    height="680px",
+                )
+                solara.Markdown(f"Zoom: {zoom.value}  Center: {center.value}  Clicked Coordinates: {clicked_coordinates.value}")
+
+        # Chat Box Column
+        with solara.Column(style={"flex": "1"}):
+            with solara.Card(style={"padding": "10px", "box-shadow": "0 4px 8px rgba(0,0,0,0.1)"}):
+                with solara.lab.ChatBox():
+                    for item in messages.value[-1:]:
+                        with solara.lab.ChatMessage(
+                            user=item["role"] == "user",
+                            name="Travel Assistant" if item["role"] == "assistant" else "User",
+                            style={"background-color": "#f4f4f8", "border-radius": "10px", "padding": "10px", "margin-bottom": "10px"}
+                        ):
+                            solara.Markdown(item["content"])
+
+# Render the Page component
+Page()

requirements.txt

@@ -1,4 +1,8 @@
 leafmap
 solara
 geopandas
-pydantic< 2.0 
+pydantic< 2.0 
+openai
+dotenv
+transformers
+ipyleaflet