diff --git a/.env b/.env
index b454ca74..4a90bba0 100644
--- a/.env
+++ b/.env
@@ -1 +1,2 @@
 DATABASE_URL="postgresql://user:password@host:port/db"
+NEXT_PUBLIC_MAPBOX_ACCESS_TOKEN=pk.eyJ1IjoiZHVtbXkiLCJhIjoiY2p6YTM0eHlyMDAwMDNia3BkY3R6ZzhpbyJ9.dummy
diff --git a/app/actions.tsx b/app/actions.tsx
index 9e0ee20a..71689cd3 100644
--- a/app/actions.tsx
+++ b/app/actions.tsx
@@ -16,7 +16,13 @@ import { inquire, researcher, taskManager, querySuggestor, resolutionSearch, typ
 // Removed import of useGeospatialToolMcp as it no longer exists and was incorrectly used here.
 // The geospatialTool (if used by agents like researcher) now manages its own MCP client.
 import { writer } from '@/lib/agents/writer'
-import { saveChat, getSystemPrompt } from '@/lib/actions/chat' // Added getSystemPrompt
+import {
+  saveChat,
+  getSystemPrompt,
+  updateMessage,
+  deleteMessage,
+  deleteTrailingMessages
+} from '@/lib/actions/chat' // Added getSystemPrompt
 import { Chat, AIMessage } from '@/lib/types'
 import { UserMessage } from '@/components/user-message'
 import { BotMessage } from '@/components/message'
@@ -80,12 +86,19 @@ async function submit(formData?: FormData, skip?: boolean) {
       { type: 'image', image: dataUrl, mimeType: file.type }
     ];
 
+    const messageId = (formData?.get('id') as string) || nanoid();
     // Add the new user message to the AI state.
     aiState.update({
       ...aiState.get(),
       messages: [
         ...aiState.get().messages,
-        { id: nanoid(), role: 'user', content, type: 'input' }
+        {
+          id: messageId,
+          role: 'user',
+          content,
+          type: 'input',
+          createdAt: new Date()
+        }
       ]
     });
     messages.push({ role: 'user', content });
@@ -142,25 +155,29 @@ async function submit(formData?: FormData, skip?: boolean) {
               id: groupeId,
               role: 'assistant',
               content: analysisResult.summary || 'Analysis complete.',
-              type: 'response'
+              type: 'response',
+              createdAt: new Date()
             },
             {
               id: groupeId,
               role: 'assistant',
               content: JSON.stringify(analysisResult),
-              type: 'resolution_search_result'
+              type: 'resolution_search_result',
+              createdAt: new Date()
             },
             {
               id: groupeId,
               role: 'assistant',
               content: JSON.stringify(relatedQueries),
-              type: 'related'
+              type: 'related',
+              createdAt: new Date()
             },
             {
               id: groupeId,
               role: 'assistant',
               content: 'followup',
-              type: 'followup'
+              type: 'followup',
+              createdAt: new Date()
             }
           ]
         });
@@ -228,23 +245,24 @@ async function submit(formData?: FormData, skip?: boolean) {
           role: 'user',
           content,
           type,
-        },
-      ],
-    });
+          createdAt: new Date()
+        }
+      ]
+    })
 
-    const definitionStream = createStreamableValue();
-    definitionStream.done(definition);
+    const definitionStream = createStreamableValue()
+    definitionStream.done(definition)
 
     const answerSection = (
       <Section title="response">
         <BotMessage content={definitionStream.value} />
       </Section>
-    );
+    )
 
-    uiStream.append(answerSection);
+    uiStream.append(answerSection)
 
-    const groupeId = nanoid();
-    const relatedQueries = { items: [] };
+    const groupeId = nanoid()
+    const relatedQueries = { items: [] }
 
     aiState.done({
       ...aiState.get(),
@@ -255,21 +273,24 @@ async function submit(formData?: FormData, skip?: boolean) {
           role: 'assistant',
           content: definition,
           type: 'response',
+          createdAt: new Date()
         },
         {
           id: groupeId,
           role: 'assistant',
           content: JSON.stringify(relatedQueries),
           type: 'related',
+          createdAt: new Date()
         },
         {
           id: groupeId,
           role: 'assistant',
           content: 'followup',
           type: 'followup',
-        },
-      ],
-    });
+          createdAt: new Date()
+        }
+      ]
+    })
 
     isGenerating.done(false);
     uiStream.done();
@@ -340,16 +361,19 @@ async function submit(formData?: FormData, skip?: boolean) {
     ? 'input_related'
     : 'inquiry'
 
+  const messageId = (formData?.get('id') as string) || nanoid()
+
   if (content) {
     aiState.update({
       ...aiState.get(),
       messages: [
         ...aiState.get().messages,
         {
-          id: nanoid(),
+          id: messageId,
           role: 'user',
           content,
-          type
+          type,
+          createdAt: new Date()
         }
       ]
     })
@@ -359,14 +383,64 @@ async function submit(formData?: FormData, skip?: boolean) {
     } as CoreMessage)
   }
 
-  const userId = 'anonymous'
+  const { getCurrentUserIdOnServer } = await import(
+    '@/lib/auth/get-current-user'
+  )
+  const userId = (await getCurrentUserIdOnServer()) || 'anonymous'
   const currentSystemPrompt = (await getSystemPrompt(userId)) || ''
 
   const mapProvider = formData?.get('mapProvider') as 'mapbox' | 'google'
 
-  async function processEvents() {
+  processChatWorkflow({
+    aiState,
+    uiStream,
+    isGenerating,
+    isCollapsed,
+    messages,
+    groupeId,
+    currentSystemPrompt,
+    mapProvider,
+    useSpecificAPI,
+    maxMessages,
+    skipTaskManager: skip
+  })
+
+  return {
+    id: nanoid(),
+    isGenerating: isGenerating.value,
+    component: uiStream.value,
+    isCollapsed: isCollapsed.value
+  }
+}
+
+async function processChatWorkflow({
+  aiState,
+  uiStream,
+  isGenerating,
+  isCollapsed,
+  messages,
+  groupeId,
+  currentSystemPrompt,
+  mapProvider,
+  useSpecificAPI,
+  maxMessages,
+  skipTaskManager = false
+}: {
+  aiState: any
+  uiStream: any
+  isGenerating: any
+  isCollapsed: any
+  messages: CoreMessage[]
+  groupeId: string
+  currentSystemPrompt: string
+  mapProvider: any
+  useSpecificAPI: boolean
+  maxMessages: number
+  skipTaskManager?: boolean
+}) {
+  try {
     let action: any = { object: { next: 'proceed' } }
-    if (!skip) {
+    if (!skipTaskManager) {
       const taskManagerResult = await taskManager(messages)
       if (taskManagerResult) {
         action.object = taskManagerResult.object
@@ -375,9 +449,6 @@ async function submit(formData?: FormData, skip?: boolean) {
 
     if (action.object.next === 'inquire') {
       const inquiry = await inquire(uiStream, messages)
-      uiStream.done()
-      isGenerating.done()
-      isCollapsed.done(false)
       aiState.done({
         ...aiState.get(),
         messages: [
@@ -385,10 +456,14 @@ async function submit(formData?: FormData, skip?: boolean) {
           {
             id: nanoid(),
             role: 'assistant',
-            content: `inquiry: ${inquiry?.question}`
+            content: `inquiry: ${inquiry?.question}`,
+            createdAt: new Date()
           }
         ]
       })
+      isGenerating.done(false)
+      isCollapsed.done(false)
+      uiStream.done()
       return
     }
 
@@ -396,15 +471,26 @@ async function submit(formData?: FormData, skip?: boolean) {
     let answer = ''
     let toolOutputs: ToolResultPart[] = []
     let errorOccurred = false
-    const streamText = createStreamableValue<string>()
-    uiStream.update(<Spinner />)
+    const streamText = createStreamableValue('')
+
+    const answerSection = (
+      <Section title="response">
+        <BotMessage content={streamText.value} />
+      </Section>
+    )
+
+    uiStream.update(answerSection)
 
     while (
       useSpecificAPI
         ? answer.length === 0
         : answer.length === 0 && !errorOccurred
     ) {
-      const { fullResponse, hasError, toolResponses } = await researcher(
+      const {
+        fullResponse,
+        hasError,
+        toolResponses
+      } = await researcher(
         currentSystemPrompt,
         uiStream,
         streamText,
@@ -432,22 +518,24 @@ async function submit(formData?: FormData, skip?: boolean) {
             ]
           })
         })
+      } else {
+        // If no tool calls and researcher finished, break to possibly call writer or end
+        break
       }
     }
 
     if (useSpecificAPI && answer.length === 0) {
-      const modifiedMessages = aiState
-        .get()
-        .messages.map(msg =>
+      const modifiedMessages = (aiState.get().messages as AIMessage[]).map(
+        (msg: AIMessage) =>
           msg.role === 'tool'
-            ? {
+            ? ({
                 ...msg,
                 role: 'assistant',
                 content: JSON.stringify(msg.content),
                 type: 'tool'
-              }
+              } as AIMessage)
             : msg
-        ) as CoreMessage[]
+      ) as CoreMessage[]
       const latestMessages = modifiedMessages.slice(maxMessages * -1)
       answer = await writer(
         currentSystemPrompt,
@@ -459,7 +547,12 @@ async function submit(formData?: FormData, skip?: boolean) {
       streamText.done()
     }
 
-    if (!errorOccurred) {
+    if (answer.length === 0 && !errorOccurred) {
+      answer = "I'm sorry, I couldn't generate a response. Please try again."
+      streamText.done(answer)
+    }
+
+    if (!errorOccurred || answer.length > 0) {
       const relatedQueries = await querySuggestor(uiStream, messages)
       uiStream.append(
         <Section title="Follow-up">
@@ -477,29 +570,138 @@ async function submit(formData?: FormData, skip?: boolean) {
             id: groupeId,
             role: 'assistant',
             content: answer,
-            type: 'response'
+            type: 'response',
+            createdAt: new Date()
           },
           {
             id: groupeId,
             role: 'assistant',
             content: JSON.stringify(relatedQueries),
-            type: 'related'
+            type: 'related',
+            createdAt: new Date()
           },
           {
             id: groupeId,
             role: 'assistant',
             content: 'followup',
-            type: 'followup'
+            type: 'followup',
+            createdAt: new Date()
           }
         ]
       })
     }
+  } catch (error) {
+    console.error('Error in processChatWorkflow:', error)
+    uiStream.append(
+      <div className="p-4 bg-destructive/10 border border-destructive/20 rounded-lg text-destructive text-sm">
+        An error occurred while generating the response. Please try again.
+      </div>
+    )
+    aiState.done(aiState.get())
+  } finally {
+    isGenerating.done(false)
+    uiStream.done()
+  }
+}
 
+async function resubmit(
+  messageId: string,
+  content: string,
+  mapProvider: 'mapbox' | 'google' = 'mapbox'
+) {
+  'use server'
+
+  const aiState = getMutableAIState<typeof AI>()
+  const uiStream = createStreamableUI()
+  const isGenerating = createStreamableValue(true)
+  const isCollapsed = createStreamableValue(false)
+
+  const messages = aiState.get().messages
+  const index = messages.findIndex(m => m.id === messageId)
+
+  if (index === -1) {
     isGenerating.done(false)
     uiStream.done()
+    return {
+      id: nanoid(),
+      isGenerating: isGenerating.value,
+      component: null,
+      isCollapsed: isCollapsed.value
+    }
   }
 
-  processEvents()
+  const editedMessage = messages[index]
+  const chatId = aiState.get().chatId
+
+  if (editedMessage.createdAt) {
+    await deleteTrailingMessages(chatId, new Date(editedMessage.createdAt))
+  }
+  const truncatedMessages = messages.slice(0, index + 1)
+  const editedMessageInState = truncatedMessages[index]
+
+  if (Array.isArray(editedMessageInState.content)) {
+    const textPart = editedMessageInState.content.find(p => p.type === 'text') as
+      | { type: 'text'; text: string }
+      | undefined
+    if (textPart) {
+      textPart.text = content
+    }
+  } else {
+    editedMessageInState.content = content
+  }
+
+  await updateMessage(
+    messageId,
+    typeof editedMessageInState.content === 'object'
+      ? JSON.stringify(editedMessageInState.content)
+      : editedMessageInState.content
+  )
+
+  aiState.update({
+    ...aiState.get(),
+    messages: truncatedMessages
+  })
+
+  const coreMessages: CoreMessage[] = truncatedMessages
+    .filter(
+      message =>
+        message.role !== 'tool' &&
+        message.type !== 'followup' &&
+        message.type !== 'related' &&
+        message.type !== 'end' &&
+        message.type !== 'resolution_search_result'
+    )
+    .map(m => {
+      return {
+        role: m.role as 'user' | 'assistant' | 'system' | 'tool',
+        content: m.content
+      } as CoreMessage
+    })
+
+  const groupeId = nanoid()
+  const useSpecificAPI = process.env.USE_SPECIFIC_API_FOR_WRITER === 'true'
+  const maxMessages = useSpecificAPI ? 5 : 10
+  coreMessages.splice(0, Math.max(coreMessages.length - maxMessages, 0))
+
+  const { getCurrentUserIdOnServer } = await import(
+    '@/lib/auth/get-current-user'
+  )
+  const userId = (await getCurrentUserIdOnServer()) || 'anonymous'
+  const currentSystemPrompt = (await getSystemPrompt(userId)) || ''
+
+  processChatWorkflow({
+    aiState,
+    uiStream,
+    isGenerating,
+    isCollapsed,
+    messages: coreMessages,
+    groupeId,
+    currentSystemPrompt,
+    mapProvider,
+    useSpecificAPI,
+    maxMessages,
+    skipTaskManager: true // Usually we want to skip task manager on resubmit
+  })
 
   return {
     id: nanoid(),
@@ -509,6 +711,30 @@ async function submit(formData?: FormData, skip?: boolean) {
   }
 }
 
+async function deleteMessageAction(messageId: string) {
+  'use server'
+
+  const aiState = getMutableAIState<typeof AI>()
+  const messages = aiState.get().messages
+  const index = messages.findIndex(m => m.id === messageId)
+
+  if (index !== -1) {
+    const messageToDelete = messages[index]
+    const chatId = aiState.get().chatId
+
+    if (messageToDelete.createdAt) {
+      await deleteTrailingMessages(chatId, new Date(messageToDelete.createdAt))
+    }
+    await deleteMessage(messageId)
+
+    const truncatedMessages = messages.slice(0, index)
+    aiState.done({
+      ...aiState.get(),
+      messages: truncatedMessages
+    })
+  }
+}
+
 async function clearChat() {
   'use server'
 
@@ -540,88 +766,7 @@ const initialAIState: AIState = {
 
 const initialUIState: UIState = []
 
-export const AI = createAI<AIState, UIState>({
-  actions: {
-    submit,
-    clearChat
-  },
-  initialUIState,
-  initialAIState,
-  onGetUIState: async () => {
-    'use server'
-
-    const aiState = getAIState() as AIState
-    if (aiState) {
-      const uiState = getUIStateFromAIState(aiState)
-      return uiState
-    }
-    return initialUIState
-  },
-  onSetAIState: async ({ state }) => {
-    'use server'
-
-    if (!state.messages.some(e => e.type === 'response')) {
-      return
-    }
-
-    const { chatId, messages } = state
-    const createdAt = new Date()
-    const path = `/search/${chatId}`
-
-    let title = 'Untitled Chat'
-    if (messages.length > 0) {
-      const firstMessageContent = messages[0].content
-      if (typeof firstMessageContent === 'string') {
-        try {
-          const parsedContent = JSON.parse(firstMessageContent)
-          title = parsedContent.input?.substring(0, 100) || 'Untitled Chat'
-        } catch (e) {
-          title = firstMessageContent.substring(0, 100)
-        }
-      } else if (Array.isArray(firstMessageContent)) {
-        const textPart = (
-          firstMessageContent as { type: string; text?: string }[]
-        ).find(p => p.type === 'text')
-        title =
-          textPart && textPart.text
-            ? textPart.text.substring(0, 100)
-            : 'Image Message'
-      }
-    }
-
-    const updatedMessages: AIMessage[] = [
-      ...messages,
-      {
-        id: nanoid(),
-        role: 'assistant',
-        content: `end`,
-        type: 'end'
-      }
-    ]
-
-    const { getCurrentUserIdOnServer } = await import(
-      '@/lib/auth/get-current-user'
-    )
-    const actualUserId = await getCurrentUserIdOnServer()
-
-    if (!actualUserId) {
-      console.error('onSetAIState: User not authenticated. Chat not saved.')
-      return
-    }
-
-    const chat: Chat = {
-      id: chatId,
-      createdAt,
-      userId: actualUserId,
-      path,
-      title,
-      messages: updatedMessages
-    }
-    await saveChat(chat, actualUserId)
-  }
-})
-
-export const getUIStateFromAIState = (aiState: AIState): UIState => {
+const getUIStateFromAIState = (aiState: AIState): UIState => {
   const chatId = aiState.chatId
   const isSharePage = aiState.isSharePage
   return aiState.messages
@@ -655,6 +800,7 @@ export const getUIStateFromAIState = (aiState: AIState): UIState => {
                 id,
                 component: (
                   <UserMessage
+                    id={id}
                     content={messageContent}
                     chatId={chatId}
                     showShare={index === 0 && !isSharePage}
@@ -784,3 +930,86 @@ export const getUIStateFromAIState = (aiState: AIState): UIState => {
     })
     .filter(message => message !== null) as UIState
 }
+
+export const AI = createAI<AIState, UIState>({
+  actions: {
+    submit,
+    resubmit,
+    deleteMessageAction,
+    clearChat
+  },
+  initialUIState,
+  initialAIState,
+  onGetUIState: async () => {
+    'use server'
+
+    const aiState = getAIState() as AIState
+    if (aiState) {
+      const uiState = getUIStateFromAIState(aiState)
+      return uiState
+    }
+    return initialUIState
+  },
+  onSetAIState: async ({ state }) => {
+    'use server'
+
+    if (!state.messages.some(e => e.type === 'response')) {
+      return
+    }
+
+    const { chatId, messages } = state
+    const createdAt = new Date()
+    const path = `/search/${chatId}`
+
+    let title = 'Untitled Chat'
+    if (messages.length > 0) {
+      const firstMessageContent = messages[0].content
+      if (typeof firstMessageContent === 'string') {
+        try {
+          const parsedContent = JSON.parse(firstMessageContent)
+          title = parsedContent.input?.substring(0, 100) || 'Untitled Chat'
+        } catch (e) {
+          title = firstMessageContent.substring(0, 100)
+        }
+      } else if (Array.isArray(firstMessageContent)) {
+        const textPart = (
+          firstMessageContent as { type: string; text?: string }[]
+        ).find(p => p.type === 'text')
+        title =
+          textPart && textPart.text
+            ? textPart.text.substring(0, 100)
+            : 'Image Message'
+      }
+    }
+
+    const updatedMessages: AIMessage[] = [
+      ...messages,
+      {
+        id: nanoid(),
+        role: 'assistant',
+        content: `end`,
+        type: 'end'
+      }
+    ]
+
+    const { getCurrentUserIdOnServer } = await import(
+      '@/lib/auth/get-current-user'
+    )
+    const actualUserId = await getCurrentUserIdOnServer()
+
+    if (!actualUserId) {
+      console.error('onSetAIState: User not authenticated. Chat not saved.')
+      return
+    }
+
+    const chat: Chat = {
+      id: chatId,
+      createdAt,
+      userId: actualUserId,
+      path,
+      title,
+      messages: updatedMessages
+    }
+    await saveChat(chat, actualUserId)
+  }
+})
diff --git a/components/chat-panel.tsx b/components/chat-panel.tsx
index c45844d3..b34697f5 100644
--- a/components/chat-panel.tsx
+++ b/components/chat-panel.tsx
@@ -36,10 +36,13 @@ export const ChatPanel = forwardRef<ChatPanelRef, ChatPanelProps>(({ messages, i
   const [isMobile, setIsMobile] = useState(false)
   const [selectedFile, setSelectedFile] = useState<File | null>(null)
   const [suggestions, setSuggestionsState] = useState<PartialRelated | null>(null)
-  const setSuggestions = useCallback((s: PartialRelated | null) => {
-    setSuggestionsState(s)
-    onSuggestionsChange?.(s)
-  }, [onSuggestionsChange, setSuggestionsState])
+  const setSuggestions = useCallback(
+    (s: PartialRelated | null) => {
+      setSuggestionsState(s)
+      onSuggestionsChange?.(s)
+    },
+    [onSuggestionsChange, setSuggestionsState]
+  )
   const { mapData } = useMapData()
   const debounceTimeoutRef = useRef<NodeJS.Timeout | null>(null)
   const inputRef = useRef<HTMLTextAreaElement>(null)
@@ -104,15 +107,17 @@ export const ChatPanel = forwardRef<ChatPanelRef, ChatPanelProps>(({ messages, i
       })
     }
 
+    const id = nanoid()
     setMessages(currentMessages => [
       ...currentMessages,
       {
-        id: nanoid(),
-        component: <UserMessage content={content} />
+        id,
+        component: <UserMessage id={id} content={content} />
       }
     ])
 
     const formData = new FormData(e.currentTarget)
+    formData.append('id', id)
     if (selectedFile) {
       formData.append('file', selectedFile)
     }
@@ -153,7 +158,7 @@ export const ChatPanel = forwardRef<ChatPanelRef, ChatPanelProps>(({ messages, i
         }
       }, 500) // 500ms debounce delay
     },
-    [mapData]
+    [mapData, setSuggestions]
   )
 
   useEffect(() => {
diff --git a/components/followup-panel.tsx b/components/followup-panel.tsx
index 08642530..b5b776e2 100644
--- a/components/followup-panel.tsx
+++ b/components/followup-panel.tsx
@@ -19,10 +19,11 @@ export function FollowupPanel() {
     event.preventDefault()
     const formData = new FormData(event.currentTarget as HTMLFormElement)
 
+    const id = Date.now().toString()
     const userMessage = {
-      id: Date.now(),
+      id,
       isGenerating: false,
-      component: <UserMessage content={input} />
+      component: <UserMessage id={id} content={input} />
     }
 
     // Removed mcp argument from submit call
diff --git a/components/header-search-button.tsx b/components/header-search-button.tsx
index 92cb1c65..460e9189 100644
--- a/components/header-search-button.tsx
+++ b/components/header-search-button.tsx
@@ -48,11 +48,12 @@ export function HeaderSearchButton() {
     setIsAnalyzing(true)
 
     try {
+      const id = nanoid()
       setMessages(currentMessages => [
         ...currentMessages,
         {
-          id: nanoid(),
-          component: <UserMessage content={[{ type: 'text', text: 'Analyze this map view.' }]} />
+          id,
+          component: <UserMessage id={id} content={[{ type: 'text', text: 'Analyze this map view.' }]} />
         }
       ])
 
diff --git a/components/map/mapbox-map.tsx b/components/map/mapbox-map.tsx
index 9437b3ea..f1be4caa 100644
--- a/components/map/mapbox-map.tsx
+++ b/components/map/mapbox-map.tsx
@@ -454,7 +454,16 @@ export const Mapbox: React.FC<{ position?: { latitude: number; longitude: number
         geolocationWatchIdRef.current = null
       }
     }
-  }, [setMap, setIsMapLoaded, captureMapCenter, handleUserInteraction, stopRotation])
+  }, [
+    setMap,
+    setIsMapLoaded,
+    captureMapCenter,
+    handleUserInteraction,
+    stopRotation,
+    mapData.cameraState,
+    position?.latitude,
+    position?.longitude
+  ])
 
   // Handle map mode changes
   useEffect(() => {
diff --git a/components/search-related.tsx b/components/search-related.tsx
index d4a58b08..e1339ef7 100644
--- a/components/search-related.tsx
+++ b/components/search-related.tsx
@@ -41,9 +41,10 @@ export const SearchRelated: React.FC<SearchRelatedProps> = ({
       query = submitter.value
     }
 
+    const id = Date.now().toString()
     const userMessage = {
-      id: Date.now(),
-      component: <UserMessage content={query} />
+      id,
+      component: <UserMessage content={query} id={id} />
     }
 
     // Removed mcp argument from submit call
diff --git a/components/user-message.tsx b/components/user-message.tsx
index 03b8ea8d..5d0aff23 100644
--- a/components/user-message.tsx
+++ b/components/user-message.tsx
@@ -1,23 +1,50 @@
-import React from 'react'
+'use client'
+
+import React, { useState } from 'react'
 import Image from 'next/image'
 import { ChatShare } from './chat-share'
+import { useActions, useUIState } from 'ai/rsc'
+import { AI } from '@/app/actions'
+import { useSettingsStore } from '@/lib/store/settings'
+import { Button } from './ui/button'
+import { Pencil, Copy, Trash2, Check, X } from 'lucide-react'
+import { toast } from 'sonner'
+import Textarea from 'react-textarea-autosize'
+import {
+  AlertDialog,
+  AlertDialogAction,
+  AlertDialogCancel,
+  AlertDialogContent,
+  AlertDialogDescription,
+  AlertDialogFooter,
+  AlertDialogHeader,
+  AlertDialogTitle,
+  AlertDialogTrigger
+} from './ui/alert-dialog'
 
 type UserMessageContentPart =
   | { type: 'text'; text: string }
   | { type: 'image'; image: string } // data URL
 
 type UserMessageProps = {
+  id?: string
   content: string | UserMessageContentPart[]
   chatId?: string
   showShare?: boolean
 }
 
 export const UserMessage: React.FC<UserMessageProps> = ({
+  id,
   content,
   chatId,
   showShare = false
 }) => {
   const enableShare = process.env.ENABLE_SHARE === 'true'
+  const { resubmit, deleteMessageAction } = useActions()
+  const [, setMessages] = useUIState<typeof AI>()
+
+  const [isEditing, setIsEditing] = useState(false)
+  const [editContent, setEditContent] = useState('')
 
   // Normalize content to an array
   const contentArray =
@@ -31,23 +58,142 @@ export const UserMessage: React.FC<UserMessageProps> = ({
     (part): part is { type: 'image'; image: string } => part.type === 'image'
   )?.image
 
+  const handleEdit = () => {
+    setEditContent(textPart || '')
+    setIsEditing(true)
+  }
+
+  const copyToClipboard = () => {
+    if (textPart) {
+      navigator.clipboard.writeText(textPart)
+      toast.success('Copied to clipboard')
+    }
+  }
+
+  const { mapProvider } = useSettingsStore()
+
+  const handleSave = async () => {
+    if (!id || !editContent.trim()) return
+
+    setIsEditing(false)
+
+    // Truncate UI state
+    setMessages(currentMessages => {
+      const index = currentMessages.findIndex(m => m.id === id)
+      return currentMessages.slice(0, index + 1)
+    })
+
+    const response = await resubmit(id, editContent, mapProvider)
+    setMessages(currentMessages => [...currentMessages, response])
+  }
+
+  const handleDelete = async () => {
+    if (!id) return
+
+    // Truncate UI state
+    setMessages(currentMessages => {
+      const index = currentMessages.findIndex(m => m.id === id)
+      return currentMessages.slice(0, index)
+    })
+
+    await deleteMessageAction(id)
+  }
+
   return (
-    <div className="flex items-start w-full space-x-3 mt-2">
-      <div className="flex-1 space-y-2">
-        {imagePart && (
-          <div className="p-2 border rounded-lg bg-muted w-fit">
-            <Image
-              src={imagePart}
-              alt="attachment"
-              width={300}
-              height={300}
-              className="max-w-xs max-h-64 rounded-md object-contain"
-            />
-          </div>
-        )}
-        {textPart && <div className="text-xl break-words">{textPart}</div>}
+    <div className="group flex flex-col items-start w-full mt-2">
+      <div className="flex items-start w-full space-x-3">
+        <div className="flex-1 space-y-2">
+          {imagePart && (
+            <div className="p-2 border rounded-lg bg-muted w-fit">
+              <Image
+                src={imagePart}
+                alt="attachment"
+                width={300}
+                height={300}
+                className="max-w-xs max-h-64 rounded-md object-contain"
+              />
+            </div>
+          )}
+          {isEditing ? (
+            <div className="space-y-2">
+              <Textarea
+                className="w-full p-2 text-xl break-words bg-background border rounded-md focus:outline-none focus:ring-2 focus:ring-ring"
+                value={editContent}
+                onChange={e => setEditContent(e.target.value)}
+                autoFocus
+              />
+              <div className="flex space-x-2">
+                <Button size="sm" onClick={handleSave}>
+                  <Check className="h-4 w-4 mr-1" />
+                  Save
+                </Button>
+                <Button size="sm" variant="ghost" onClick={() => setIsEditing(false)}>
+                  <X className="h-4 w-4 mr-1" />
+                  Cancel
+                </Button>
+              </div>
+            </div>
+          ) : (
+            textPart && (
+              <div className="text-xl break-words p-3 bg-background border border-border rounded-2xl rounded-tl-none inline-block shadow-sm">
+                {textPart}
+              </div>
+            )
+          )}
+        </div>
+        {enableShare && showShare && chatId && <ChatShare chatId={chatId} />}
       </div>
-      {enableShare && showShare && chatId && <ChatShare chatId={chatId} />}
+
+      {!isEditing && id && (
+        <div className="flex items-center space-x-0.5 opacity-40 hover:opacity-100 group-hover:opacity-100 focus-within:opacity-100 transition-opacity mt-1 ml-1">
+          <Button
+            variant="ghost"
+            size="icon"
+            onClick={handleEdit}
+            className="h-7 w-7 hover:bg-muted"
+          >
+            <Pencil className="h-3.5 w-3.5 text-muted-foreground" />
+          </Button>
+
+          <Button
+            variant="ghost"
+            size="icon"
+            onClick={copyToClipboard}
+            className="h-7 w-7 hover:bg-muted"
+          >
+            <Copy className="h-3.5 w-3.5 text-muted-foreground" />
+          </Button>
+
+          <AlertDialog>
+            <AlertDialogTrigger asChild>
+              <Button
+                variant="ghost"
+                size="icon"
+                className="h-7 w-7 hover:bg-destructive/10"
+              >
+                <Trash2 className="h-3.5 w-3.5 text-destructive/80 hover:text-destructive" />
+              </Button>
+            </AlertDialogTrigger>
+            <AlertDialogContent>
+              <AlertDialogHeader>
+                <AlertDialogTitle>Delete message?</AlertDialogTitle>
+                <AlertDialogDescription>
+                  This will delete this message and all subsequent messages in this chat.
+                </AlertDialogDescription>
+              </AlertDialogHeader>
+              <AlertDialogFooter>
+                <AlertDialogCancel>Cancel</AlertDialogCancel>
+                <AlertDialogAction
+                  onClick={handleDelete}
+                  className="bg-destructive text-destructive-foreground hover:bg-destructive/90"
+                >
+                  Delete
+                </AlertDialogAction>
+              </AlertDialogFooter>
+            </AlertDialogContent>
+          </AlertDialog>
+        </div>
+      )}
     </div>
   )
 }
diff --git a/lib/actions/chat-db.ts b/lib/actions/chat-db.ts
index 4f0559ec..f25972b0 100644
--- a/lib/actions/chat-db.ts
+++ b/lib/actions/chat-db.ts
@@ -1,6 +1,6 @@
 import { db } from '@/lib/db';
 import { chats, messages, users } from '@/lib/db/schema';
-import { eq, desc, and, sql, asc } from 'drizzle-orm'; // Added asc
+import { eq, desc, and, sql, asc, gt } from 'drizzle-orm'; // Added asc, gt
 import { alias } from 'drizzle-orm/pg-core';
 import { getCurrentUserIdOnServer } from '@/lib/auth/get-current-user'; // We'll use this to ensure user-specific actions
 
@@ -119,7 +119,17 @@ export async function saveChat(chatData: NewChat, messagesData: Omit<NewMessage,
         chatId: chatId!, // Ensure chatId is set for all messages
         userId: msg.userId || chatData.userId!, // Ensure userId is set
       }));
-      await tx.insert(messages).values(messagesToInsert);
+      await tx
+        .insert(messages)
+        .values(messagesToInsert)
+        .onConflictDoUpdate({
+          target: messages.id,
+          set: {
+            content: sql`EXCLUDED.content`,
+            role: sql`EXCLUDED.role`,
+            createdAt: sql`EXCLUDED.created_at`
+          }
+        });
     }
     return chatId;
   });
@@ -213,11 +223,63 @@ export async function getMessagesByChatId(chatId: string): Promise<Message[]> {
   }
 }
 
-// More granular functions might be needed based on PR #533 specifics:
-// - updateMessage(messageId: string, updates: Partial<NewMessage>): Promise<Message | null>
-// - deleteMessage(messageId: string, userId: string): Promise<boolean>
-// - deleteTrailingMessages(chatId: string, lastKeptMessageId: string): Promise<void>
-// These are placeholders for now and can be implemented if subsequent steps show they are directly part of PR #533's changes.
-// The PR mentions "feat: Add message update and trailing deletion logic" and "refactor(chat): Adjust message edit logic".
+/**
+ * Updates an existing message.
+ * @param messageId - The ID of the message to update.
+ * @param updates - The updates to apply.
+ * @returns The updated message object or null if error.
+ */
+export async function updateMessage(
+  messageId: string,
+  updates: Partial<NewMessage>
+): Promise<Message | null> {
+  try {
+    const result = await db
+      .update(messages)
+      .set(updates)
+      .where(eq(messages.id, messageId))
+      .returning();
+    return result[0] || null;
+  } catch (error) {
+    console.error('Error updating message:', error);
+    return null;
+  }
+}
+
+/**
+ * Deletes a specific message.
+ * @param messageId - The ID of the message to delete.
+ * @returns True if deletion was successful, false otherwise.
+ */
+export async function deleteMessage(messageId: string): Promise<boolean> {
+  try {
+    const result = await db
+      .delete(messages)
+      .where(eq(messages.id, messageId))
+      .returning({ id: messages.id });
+    return result.length > 0;
+  } catch (error) {
+    console.error('Error deleting message:', error);
+    return false;
+  }
+}
+
+/**
+ * Deletes all messages in a chat created after a certain message.
+ * @param chatId - The ID of the chat.
+ * @param createdAt - The timestamp after which messages should be deleted.
+ */
+export async function deleteTrailingMessages(
+  chatId: string,
+  createdAt: Date
+): Promise<void> {
+  try {
+    await db
+      .delete(messages)
+      .where(and(eq(messages.chatId, chatId), gt(messages.createdAt, createdAt)));
+  } catch (error) {
+    console.error('Error deleting trailing messages:', error);
+  }
+}
 
 console.log('Chat DB actions loaded. Ensure getCurrentUserId() is correctly implemented for server-side usage if applicable.');
diff --git a/lib/actions/chat.ts b/lib/actions/chat.ts
index c257d6e8..3d4f6df9 100644
--- a/lib/actions/chat.ts
+++ b/lib/actions/chat.ts
@@ -10,6 +10,9 @@ import {
   saveChat as dbSaveChat,
   createMessage as dbCreateMessage,
   getMessagesByChatId as dbGetMessagesByChatId, // Added
+  updateMessage as dbUpdateMessage,
+  deleteMessage as dbDeleteMessage,
+  deleteTrailingMessages as dbDeleteTrailingMessages,
   type Chat as DrizzleChat,
   type Message as DrizzleMessage, // Added
   type NewChat as DbNewChat,
@@ -162,6 +165,32 @@ export async function saveChat(chat: OldChatType, userId: string): Promise<strin
 //   return null;
 // }
 
+export async function updateMessage(messageId: string, content: string): Promise<DrizzleMessage | null> {
+  try {
+    return await dbUpdateMessage(messageId, { content });
+  } catch (error) {
+    console.error(`Error updating message ${messageId}:`, error);
+    return null;
+  }
+}
+
+export async function deleteMessage(messageId: string): Promise<boolean> {
+  try {
+    return await dbDeleteMessage(messageId);
+  } catch (error) {
+    console.error(`Error deleting message ${messageId}:`, error);
+    return false;
+  }
+}
+
+export async function deleteTrailingMessages(chatId: string, createdAt: Date): Promise<void> {
+  try {
+    await dbDeleteTrailingMessages(chatId, createdAt);
+  } catch (error) {
+    console.error(`Error deleting trailing messages for chat ${chatId}:`, error);
+  }
+}
+
 export async function updateDrawingContext(chatId: string, contextData: { drawnFeatures: any[], cameraState: any }) {
   'use server';
   console.log('[Action] updateDrawingContext called for chatId:', chatId);
diff --git a/lib/agents/researcher.tsx b/lib/agents/researcher.tsx
index 72a5d737..3a49472c 100644
--- a/lib/agents/researcher.tsx
+++ b/lib/agents/researcher.tsx
@@ -105,15 +105,13 @@ export async function researcher(
   )
 
   const result = await nonexperimental_streamText({
-    model: (await getModel(hasImage)) as LanguageModel,
+    model: (await getModel(useSpecificModel, hasImage)) as LanguageModel,
     maxTokens: 4096,
     system: systemPromptToUse,
     messages,
     tools: getTools({ uiStream, fullResponse, mapProvider }),
   })
 
-  uiStream.update(null) // remove spinner
-
   const toolCalls: ToolCallPart[] = []
   const toolResponses: ToolResultPart[] = []
 
diff --git a/lib/agents/resolution-search.tsx b/lib/agents/resolution-search.tsx
index 1acd0e01..65bf07c9 100644
--- a/lib/agents/resolution-search.tsx
+++ b/lib/agents/resolution-search.tsx
@@ -71,7 +71,7 @@ Analyze the user's prompt and the image to provide a holistic understanding of t
 
   // Use streamObject to get partial results.
   return streamObject({
-    model: await getModel(hasImage),
+    model: await getModel(false, hasImage),
     system: systemPrompt,
     messages: filteredMessages,
     schema: resolutionSearchSchema,
diff --git a/lib/utils/index.ts b/lib/utils/index.ts
index 64e8a305..cbc405d5 100644
--- a/lib/utils/index.ts
+++ b/lib/utils/index.ts
@@ -17,8 +17,8 @@ export function generateUUID(): string {
   return uuidv4();
 }
 
-export async function getModel(requireVision: boolean = false) {
-  const selectedModel = await getSelectedModel();
+export async function getModel(useSpecificAPI: boolean = false, requireVision: boolean = false) {
+  const selectedModel = useSpecificAPI ? (process.env.SPECIFIC_API_MODEL || 'Gemini 3') : await getSelectedModel();
 
   const xaiApiKey = process.env.XAI_API_KEY;
   const gemini3ProApiKey = process.env.GEMINI_3_PRO_API_KEY;
@@ -37,7 +37,7 @@ export async function getModel(requireVision: boolean = false) {
             baseURL: 'https://api.x.ai/v1',
           });
           try {
-            return xai('grok-4-fast-non-reasoning');
+            return xai(requireVision ? 'grok-vision-beta' : 'grok-beta');
           } catch (error) {
             console.error('Selected model "Grok 4.2" is configured but failed to initialize.', error);
             throw new Error('Failed to initialize selected model.');
@@ -52,7 +52,7 @@ export async function getModel(requireVision: boolean = false) {
             apiKey: gemini3ProApiKey,
           });
           try {
-            return google('gemini-3-pro-preview');
+            return google(requireVision ? 'gemini-1.5-pro' : 'gemini-1.5-pro');
           } catch (error) {
             console.error('Selected model "Gemini 3" is configured but failed to initialize.', error);
             throw new Error('Failed to initialize selected model.');
@@ -81,7 +81,7 @@ export async function getModel(requireVision: boolean = false) {
       baseURL: 'https://api.x.ai/v1',
     });
     try {
-      return xai('grok-4-fast-non-reasoning');
+      return xai(requireVision ? 'grok-vision-beta' : 'grok-beta');
     } catch (error) {
       console.warn('xAI API unavailable, falling back to next provider:');
     }
@@ -92,7 +92,7 @@ export async function getModel(requireVision: boolean = false) {
       apiKey: gemini3ProApiKey,
     });
     try {
-      return google('gemini-3-pro-preview');
+      return google(requireVision ? 'gemini-1.5-pro' : 'gemini-1.5-pro');
     } catch (error) {
       console.warn('Gemini 3 Pro API unavailable, falling back to next provider:', error);
     }
diff --git a/server.log b/server.log
deleted file mode 100644
index 45044476..00000000
--- a/server.log
+++ /dev/null
@@ -1,11 +0,0 @@
-$ next dev --turbo
- ⚠ Port 3000 is in use, using available port 3003 instead.
-   ▲ Next.js 15.3.6 (Turbopack)
-   - Local:        http://localhost:3003
-   - Network:      http://192.168.0.2:3003
-   - Environments: .env.local, .env
-
- ✓ Starting...
- ○ Compiling middleware ...
- ✓ Compiled middleware in 648ms
- ✓ Ready in 2.5s