fix duplicate message

app/sheets.py

@@ -140,12 +140,46 @@ class SheetsClient:
             if not self.service:
                 raise RuntimeError("Google Sheets service not initialized")
 
+            # Get existing data to check for duplicates
+            result = self.service.spreadsheets().values().get(
+                spreadsheetId=self.sheet_id,
+                range=SHEET_RANGE
+            ).execute()
+            values = result.get('values', [])
+
             ts = datetime.now().isoformat()
 
             if not conversation_id:
-                # Create new conversation
+                # Check for duplicates before creating new conversation
+                for row in values:
+                    # Ensure row has enough columns
+                    if len(row) >= 11:
+                        row_timestamp = row[10]
+                        row_user_id = row[4]
+                        row_page_id = row[5]
+                        if (str(row_timestamp) == str(timestamp) and 
+                            str(row_user_id) == str(user_id) and 
+                            str(row_page_id) == str(page_id)):
+                            # Found duplicate, return existing conversation
+                            logger.info(f"Found duplicate conversation for user {user_id}, page {page_id}, timestamp {timestamp}")
+                            return {
+                                'conversation_id': row[0],
+                                'originalcommand': row[1],
+                                'originalcontent': row[2],
+                                'originalattachments': json.loads(row[3]) if row[3] else [],
+                                'recipient_id': row[4],
+                                'page_id': row[5],
+                                'originaltext': row[6],
+                                'originalvehicle': row[7],
+                                'originalaction': row[8],
+                                'originalpurpose': row[9],
+                                'timestamp': row[10],
+                                'isdone': row[11].lower() == 'true' if len(row) > 11 else False
+                            }
+
+                # No duplicate found, create new conversation
                 conversation_id = generate_conversation_id(user_id, page_id, ts)
-                values = [[
+                new_row = [
                     conversation_id,
                     command,
                     content,
@@ -158,10 +192,10 @@ class SheetsClient:
                     purpose,
                     timestamp,
                     str(is_done).lower()
-                ]]
+                ]
 
                 body = {
-                    'values': values
+                    'values': [new_row]
                 }
 
                 range_name = SHEET_RANGE
@@ -189,14 +223,6 @@ class SheetsClient:
                 }
             else:
                 # Update existing conversation
-              
-                # Find the row with this conversation_id
-                result = self.service.spreadsheets().values().get(
-                    spreadsheetId=self.sheet_id,
-                    range=SHEET_RANGE
-                ).execute()
-                
-                values = result.get('values', [])
                 row_index = None
                 
                 for i, row in enumerate(values):