Fix supabase reverse

Author: sid22

mcp/main.py

@@ -827,12 +827,16 @@ async def revert_supabase_row(change_id: str, skip_tracking: bool = False):
         restored_row = None
 
         if operation == "INSERT":
-            # Revert INSERT by DELETING the row
+            # Revert INSERT by DELETING the row (with CASCADE for clients table)
             print(f"   → Deleting inserted row...")
             try:
-                api.delete_row(table_name, row_id)
+                # Use CASCADE delete for clients table to automatically delete child records
+                cascade = (table_name == "clients")
+                api.delete_row(table_name, row_id, cascade=cascade)
                 restored_row = {"deleted": True}
                 status_msg = f"Row {row_id} deleted (reverted INSERT)"
+                if cascade:
+                    status_msg += " with CASCADE"
             except requests.exceptions.HTTPError as e:
                 if e.response.status_code == 409:
                     # Foreign key constraint violation

mcp/supabase_api.py

@@ -113,18 +113,24 @@ def update_row(
         result = response.json()
         return result[0] if result else {}
 
-    def delete_row(self, table_name: str, row_id: int, id_column: str = "id") -> bool:
+    def delete_row(self, table_name: str, row_id: int, id_column: str = "id", cascade: bool = False) -> bool:
         """
-        Delete a row
+        Delete a row, optionally with CASCADE behavior
 
         Args:
             table_name: Name of the table
             row_id: Row ID
             id_column: Name of the ID column (default: id)
+            cascade: If True, delete child records first (default: False)
 
         Returns:
             True if successful
         """
+        # If cascade is enabled and this is the clients table, delete child records first
+        if cascade and table_name == "clients":
+            print(f"🔄 CASCADE delete enabled for clients table")
+            self._cascade_delete_client(row_id)
+
         url = f"{self.rest_url}/{table_name}?{id_column}=eq.{row_id}"
 
         print(f"🔧 Supabase DELETE request:")
@@ -138,6 +144,33 @@ def delete_row(self, table_name: str, row_id: int, id_column: str = "id") -> boo
         response.raise_for_status()
         return True
 
+    def _cascade_delete_client(self, client_id: int) -> None:
+        """
+        Delete all child records for a client before deleting the client itself
+
+        Args:
+            client_id: Client ID
+        """
+        # Define child tables that reference clients
+        child_tables = ["transactions", "accounts", "alerts"]
+
+        for table in child_tables:
+            try:
+                url = f"{self.rest_url}/{table}?client_id=eq.{client_id}"
+                print(f"   → Deleting {table} for client {client_id}...")
+                response = requests.delete(url, headers=self.headers)
+
+                if response.status_code == 200 or response.status_code == 204:
+                    # Count how many were deleted
+                    deleted_count = len(response.json()) if response.text else 0
+                    if deleted_count > 0:
+                        print(f"      ✓ Deleted {deleted_count} {table} record(s)")
+                else:
+                    print(f"      ⚠ Status {response.status_code} for {table}")
+            except Exception as e:
+                print(f"      ⚠ Error deleting {table}: {e}")
+                # Continue with other tables even if one fails
+
     def insert_row(self, table_name: str, data: Dict[str, Any]) -> Dict[str, Any]:
         """
         Insert a new row