Latest changes

routes/real_estate_chat.py

@@ -3,35 +3,45 @@ from typing import Any, Dict, List, Optional
 from fastapi import APIRouter, Depends, Request, BackgroundTasks
 from pydantic import BaseModel
 
+import logging
+
+logger = logging.getLogger(__name__)
+
 from services.groq_service import process_chat_message
 from services.rate_limiter import limiter
 
-router = APIRouter(prefix="/api/v1/real-estate", tags=["Real Estate Intelligence Layer"])
+router = APIRouter(
+    prefix="/api/v1/real-estate", tags=["Real Estate Intelligence Layer"]
+)
+
 
 class ChatRequest(BaseModel):
     message: str
     session_id: str
     context: Optional[Dict[str, Any]] = {}
 
+
 class ChatResponse(BaseModel):
     reply: str
     path_used: str
     tools_called: List[Dict[str, Any]]
     suggested_actions: Optional[List[str]] = []
 
+
 @router.post("/chat", response_model=ChatResponse)
 async def handle_real_estate_chat(payload: ChatRequest, request: Request):
     # Enforce token bucket rate limiting by session ID or client IP
     client_key = payload.session_id or request.client.host
     limiter.check_rate_limit(client_key)
-    
+
     try:
         result = await process_chat_message(
             user_query=payload.message,
             session_id=payload.session_id,
-            session_context=payload.context or {}
+            session_context=payload.context or {},
         )
     except Exception as e:
+        logger.error(f"Error in handle_real_estate_chat: {e}")
         return ChatResponse(
             reply="Unable to reach the intelligence layer. Please try again shortly.",
             path_used="ERROR",
@@ -42,9 +52,10 @@ async def handle_real_estate_chat(payload: ChatRequest, request: Request):
         reply=result["reply"],
         path_used=result["path_used"],
         tools_called=result["tools_called"],
-        suggested_actions=result.get("suggested_actions", [])
+        suggested_actions=result.get("suggested_actions", []),
     )
 
+
 @router.get("/chat/starters")
 async def get_starter_prompts():
     return {
@@ -52,6 +63,6 @@ async def get_starter_prompts():
             "What's today's biggest rate spike?",
             "What does the 7-day average mean?",
             "Which Miami properties are unavailable right now?",
-            "How often is listing data refreshed?"
+            "How often is listing data refreshed?",
         ]
     }

services/supabase_service.py

@@ -14,7 +14,12 @@ _PYTHON_SIDE_TOOLS = {"generate_data_export", "geocode_address"}
 def is_valid_uuid(val):
     if not isinstance(val, str):
         return False
-    return bool(re.match(r'^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$', val.lower()))
+    return bool(
+        re.match(
+            r"^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$",
+            val.lower(),
+        )
+    )
 
 
 def _clamp(value, lo, hi, default=None):
@@ -26,13 +31,16 @@ def _clamp(value, lo, hi, default=None):
 
 async def execute_tool_rpc(func_name: str, args: dict) -> dict:
     """Executes a read-only Supabase RPC matching the tool schema.
-    
+
     All parameter clamping and validation is applied here so the LLM
     cannot craft out-of-bound inputs that would return huge datasets.
     """
     if func_name in _PYTHON_SIDE_TOOLS:
         # Safety guard — these should be intercepted before reaching here
-        return {"status": "error", "message": f"Tool '{func_name}' is handled client-side and should not route to Supabase."}
+        return {
+            "status": "error",
+            "message": f"Tool '{func_name}' is handled client-side and should not route to Supabase.",
+        }
 
     # ── Per-function validation & clamping ────────────────────────────────────
 
@@ -41,12 +49,17 @@ async def execute_tool_rpc(func_name: str, args: dict) -> dict:
 
     elif func_name == "get_property_rate_changes":
         args["days_param"] = _clamp(args.get("days_param"), 1, 30, default=14)
-        args["compare_window_days"] = _clamp(args.get("compare_window_days"), 1, 14, default=1)
+        args["compare_window_days"] = _clamp(
+            args.get("compare_window_days"), 1, 14, default=1
+        )
         # Validate optional date range params
         start = args.get("start_date")
         end = args.get("end_date")
         if (start and not end) or (end and not start):
-            return {"status": "error", "message": "Both start_date and end_date must be provided together."}
+            return {
+                "status": "error",
+                "message": "Both start_date and end_date must be provided together.",
+            }
         # If dates provided, remove days_param to let SQL use date range mode
         if start and end:
             args.pop("days_param", None)
@@ -60,30 +73,50 @@ async def execute_tool_rpc(func_name: str, args: dict) -> dict:
             args["threshold"] = max(5.0, min(float(args["threshold"]), 100.0))
 
     elif func_name == "get_distance_km":
-        if not is_valid_uuid(args.get("property_a_id")) or not is_valid_uuid(args.get("property_b_id")):
-            return {"status": "error", "message": "Invalid UUID format. Both property IDs must be valid UUIDs."}
+        if not is_valid_uuid(args.get("property_a_id")) or not is_valid_uuid(
+            args.get("property_b_id")
+        ):
+            return {
+                "status": "error",
+                "message": "Invalid UUID format. Both property IDs must be valid UUIDs.",
+            }
 
     elif func_name == "get_rate_anomaly_report":
         args["days_param"] = _clamp(args.get("days_param"), 1, 90, default=30)
         if "deviation_threshold" in args and args["deviation_threshold"] is not None:
-            args["deviation_threshold"] = max(5.0, min(float(args["deviation_threshold"]), 100.0))
+            args["deviation_threshold"] = max(
+                5.0, min(float(args["deviation_threshold"]), 100.0)
+            )
 
     elif func_name == "get_market_snapshot":
         start = args.get("start_date")
         end = args.get("end_date")
         if not start or not end:
-            return {"status": "error", "message": "get_market_snapshot requires both start_date and end_date."}
+            return {
+                "status": "error",
+                "message": "get_market_snapshot requires both start_date and end_date.",
+            }
         # Enforce max 90-day span to prevent massive aggregations
         try:
             from datetime import date
+
             d1 = date.fromisoformat(start)
             d2 = date.fromisoformat(end)
             if d2 < d1:
-                return {"status": "error", "message": "end_date must be after start_date."}
+                return {
+                    "status": "error",
+                    "message": "end_date must be after start_date.",
+                }
             if (d2 - d1).days > 90:
-                return {"status": "error", "message": "Date range cannot exceed 90 days for get_market_snapshot."}
+                return {
+                    "status": "error",
+                    "message": "Date range cannot exceed 90 days for get_market_snapshot.",
+                }
         except ValueError:
-            return {"status": "error", "message": "Invalid date format. Use YYYY-MM-DD."}
+            return {
+                "status": "error",
+                "message": "Invalid date format. Use YYYY-MM-DD.",
+            }
 
     elif func_name == "get_market_trend":
         args["days"] = _clamp(args.get("days"), 7, 90, default=14)
@@ -91,7 +124,10 @@ async def execute_tool_rpc(func_name: str, args: dict) -> dict:
     elif func_name == "compare_properties":
         ids = args.get("property_ids", [])
         if not isinstance(ids, list) or len(ids) < 2:
-            return {"status": "error", "message": "compare_properties requires a list of 2–5 property names or UUIDs."}
+            return {
+                "status": "error",
+                "message": "compare_properties requires a list of 2–5 property names or UUIDs.",
+            }
         args["property_ids"] = ids[:5]  # Hard cap at 5
 
     elif func_name == "get_most_volatile_properties":
@@ -103,10 +139,32 @@ async def execute_tool_rpc(func_name: str, args: dict) -> dict:
 
     elif func_name == "get_nearby_properties":
         if args.get("latitude") is None or args.get("longitude") is None:
-            return {"status": "error", "message": "get_nearby_properties requires latitude and longitude coordinates. Call geocode_address first if you only have an address."}
+            return {
+                "status": "error",
+                "message": "get_nearby_properties requires latitude and longitude coordinates. Call geocode_address first if you only have an address.",
+            }
         args["radius_km"] = max(0.1, min(float(args.get("radius_km", 5.0)), 20.0))
         args["limit"] = _clamp(args.get("limit"), 1, 20, default=10)
+    elif func_name == "get_market_averages":
+        # DB expects market_param text
+        if "market_param" not in args and "market" in args:
+            args["market_param"] = args.pop("market")
+
+    elif func_name == "get_market_trend":
+        # DB expects p_market, p_days
+        if "p_market" not in args and "market" in args:
+            args["p_market"] = args.pop("market")
+        if "days" in args and "p_days" not in args:
+            args["p_days"] = args.pop("days")
 
+    elif func_name == "get_market_snapshot":
+        # DB expects p_market, p_start_date, p_end_date
+        if "p_market" not in args and "market" in args:
+            args["p_market"] = args.pop("market")
+        if "start_date" in args and "p_start_date" not in args:
+            args["p_start_date"] = args.pop("start_date")
+        if "end_date" in args and "p_end_date" not in args:
+            args["p_end_date"] = args.pop("end_date")
     # ── Execute RPC ───────────────────────────────────────────────────────────
     try:
         res = supabase.rpc(func_name, args).execute()
@@ -121,14 +179,12 @@ async def search_methodology_rag(query: str, top_k: int = 3) -> list:
         vector = embedder.encode(query).tolist()
         res = supabase.rpc(
             "match_re_methodology",
-            {
-                "query_embedding": vector,
-                "match_threshold": 0.45,
-                "match_count": top_k
-            }
+            {"query_embedding": vector, "match_threshold": 0.45, "match_count": top_k},
         ).execute()
-        
-        return [f"### {item['section_title']}\n{item['chunk_content']}" for item in res.data]
+
+        return [
+            f"### {item['section_title']}\n{item['chunk_content']}" for item in res.data
+        ]
     except Exception as e:
         print(f"RAG Retrieval Error: {e}")
         return []

services/tools.py

@@ -10,8 +10,8 @@ REAL_ESTATE_TOOLS = [
         "function": {
             "name": "get_dashboard_kpis",
             "description": "Fetch overall Real Estate Rate Monitor KPIs: tracked property count, 7-day rate changes, spike count, and scrape health status per platform. Use for general 'how is the system doing?' or market health questions.",
-            "parameters": {"type": "object", "properties": {}, "required": []}
-        }
+            "parameters": {"type": "object", "properties": {}, "required": []},
+        },
     },
     {
         "type": "function",
@@ -21,11 +21,14 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "market": {"type": "string", "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'. Omit to get all markets."}
+                    "market_param": {
+                        "type": "string",
+                        "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'. Omit to get all markets.",
+                    }
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
     {
         "type": "function",
@@ -35,13 +38,22 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "market": {"type": "string", "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'"},
-                    "start_date": {"type": "string", "description": "Start date, YYYY-MM-DD"},
-                    "end_date": {"type": "string", "description": "End date, YYYY-MM-DD"}
+                    "p_market": {
+                        "type": "string",
+                        "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'",
+                    },
+                    "p_start_date": {
+                        "type": "string",
+                        "description": "Start date, YYYY-MM-DD",
+                    },
+                    "p_end_date": {
+                        "type": "string",
+                        "description": "End date, YYYY-MM-DD",
+                    },
                 },
-                "required": ["market", "start_date", "end_date"]
-            }
-        }
+                "required": ["p_market", "p_start_date", "p_end_date"],
+            },
+        },
     },
     {
         "type": "function",
@@ -51,14 +63,20 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "market": {"type": "string", "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'"},
-                    "days": {"type": "integer", "default": 14, "description": "Period to analyse in days (7–90)"}
+                    "p_market": {
+                        "type": "string",
+                        "description": "Market region name, e.g. 'Miami' or 'NYC/NJ Metro'",
+                    },
+                    "p_days": {
+                        "type": "integer",
+                        "default": 14,
+                        "description": "Period to analyse in days (7–90)",
+                    },
                 },
-                "required": ["market"]
-            }
-        }
+                "required": ["market"],
+            },
+        },
     },
-
     # ─── SPIKE & ANOMALY DETECTION ───────────────────────────────────────────
     {
         "type": "function",
@@ -68,12 +86,20 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "threshold": {"type": "number", "default": 25.0, "description": "Minimum absolute % deviation from 7-day trailing average"},
-                    "days": {"type": "integer", "default": 7, "description": "Lookback window in days"}
+                    "threshold": {
+                        "type": "number",
+                        "default": 25.0,
+                        "description": "Minimum absolute % deviation from 7-day trailing average",
+                    },
+                    "days": {
+                        "type": "integer",
+                        "default": 7,
+                        "description": "Lookback window in days",
+                    },
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
     {
         "type": "function",
@@ -83,13 +109,24 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "property_search": {"type": "string", "description": "Property name or UUID"},
-                    "days_param": {"type": "integer", "default": 30, "description": "Lookback window in days (max 90)"},
-                    "deviation_threshold": {"type": "number", "default": 25.0, "description": "Minimum absolute % deviation to qualify as anomaly"}
+                    "p_property_search": {
+                        "type": "string",
+                        "description": "Property name or UUID",
+                    },
+                    "p_days": {
+                        "type": "integer",
+                        "default": 30,
+                        "description": "Lookback window in days (max 90)",
+                    },
+                    "p_deviation_threshold": {
+                        "type": "number",
+                        "default": 25.0,
+                        "description": "Minimum absolute % deviation to qualify as anomaly",
+                    },
                 },
-                "required": ["property_search"]
-            }
-        }
+                "required": ["property_search"],
+            },
+        },
     },
     {
         "type": "function",
@@ -99,15 +136,25 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "market": {"type": "string", "description": "Optional market filter ('Miami' or 'NYC/NJ Metro')"},
-                    "days": {"type": "integer", "default": 14, "description": "Period to analyse in days"},
-                    "limit": {"type": "integer", "default": 5, "description": "Number of top results to return (max 10)"}
+                    "market": {
+                        "type": "string",
+                        "description": "Optional market filter ('Miami' or 'NYC/NJ Metro')",
+                    },
+                    "days": {
+                        "type": "integer",
+                        "default": 14,
+                        "description": "Period to analyse in days",
+                    },
+                    "limit": {
+                        "type": "integer",
+                        "default": 5,
+                        "description": "Number of top results to return (max 10)",
+                    },
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
-
     # ─── PROPERTY-SPECIFIC QUERIES ───────────────────────────────────────────
     {
         "type": "function",
@@ -117,11 +164,14 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "property_search": {"type": "string", "description": "Property name or UUID"}
+                    "property_search": {
+                        "type": "string",
+                        "description": "Property name or UUID",
+                    }
                 },
-                "required": ["property_search"]
-            }
-        }
+                "required": ["property_search"],
+            },
+        },
     },
     {
         "type": "function",
@@ -131,15 +181,32 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "property_search": {"type": "string", "description": "Property name or UUID (required)"},
-                    "days_param": {"type": "integer", "default": 14, "description": "Rolling lookback window in days (max 30). Ignored if start_date/end_date are provided."},
-                    "compare_window_days": {"type": "integer", "default": 1, "description": "Days to compare against for pct_change_vs_prev (max 14)"},
-                    "start_date": {"type": "string", "description": "Optional explicit start date YYYY-MM-DD. Use instead of days_param when user gives a specific date range."},
-                    "end_date": {"type": "string", "description": "Optional explicit end date YYYY-MM-DD. Must be provided together with start_date."}
+                    "property_search": {
+                        "type": "string",
+                        "description": "Property name or UUID (required)",
+                    },
+                    "days_param": {
+                        "type": "integer",
+                        "default": 14,
+                        "description": "Rolling lookback window in days (max 30). Ignored if start_date/end_date are provided.",
+                    },
+                    "compare_window_days": {
+                        "type": "integer",
+                        "default": 1,
+                        "description": "Days to compare against for pct_change_vs_prev (max 14)",
+                    },
+                    "start_date": {
+                        "type": "string",
+                        "description": "Optional explicit start date YYYY-MM-DD. Use instead of days_param when user gives a specific date range.",
+                    },
+                    "end_date": {
+                        "type": "string",
+                        "description": "Optional explicit end date YYYY-MM-DD. Must be provided together with start_date.",
+                    },
                 },
-                "required": ["property_search"]
-            }
-        }
+                "required": ["property_search"],
+            },
+        },
     },
     {
         "type": "function",
@@ -152,14 +219,13 @@ REAL_ESTATE_TOOLS = [
                     "property_ids": {
                         "type": "array",
                         "items": {"type": "string"},
-                        "description": "2–5 property names or UUIDs to compare side-by-side"
+                        "description": "2–5 property names or UUIDs to compare side-by-side",
                     }
                 },
-                "required": ["property_ids"]
-            }
-        }
+                "required": ["property_ids"],
+            },
+        },
     },
-
     # ─── SEARCH & FILTERING ───────────────────────────────────────────────────
     {
         "type": "function",
@@ -169,16 +235,35 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "p_search": {"type": "string", "description": "Search text (property name or UUID)"},
-                    "p_market": {"type": "string", "description": "Market region name (e.g. 'Miami' or 'NYC/NJ Metro')"},
-                    "p_platform": {"type": "string", "description": "Platform filter (e.g. 'airbnb' or 'vrbo')"},
-                    "p_bedrooms": {"type": "integer", "description": "Number of bedrooms"},
-                    "p_available": {"type": "boolean", "description": "true = available only, false = unavailable only"},
-                    "p_limit": {"type": "integer", "default": 20, "description": "Results to return (max 50)"}
+                    "p_search": {
+                        "type": "string",
+                        "description": "Search text (property name or UUID)",
+                    },
+                    "p_market": {
+                        "type": "string",
+                        "description": "Market region name (e.g. 'Miami' or 'NYC/NJ Metro')",
+                    },
+                    "p_platform": {
+                        "type": "string",
+                        "description": "Platform filter (e.g. 'airbnb' or 'vrbo')",
+                    },
+                    "p_bedrooms": {
+                        "type": "integer",
+                        "description": "Number of bedrooms",
+                    },
+                    "p_available": {
+                        "type": "boolean",
+                        "description": "true = available only, false = unavailable only",
+                    },
+                    "p_limit": {
+                        "type": "integer",
+                        "default": 20,
+                        "description": "Results to return (max 50)",
+                    },
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
     {
         "type": "function",
@@ -188,14 +273,19 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "market": {"type": "string", "description": "Optional market filter ('Miami' or 'NYC/NJ Metro')"},
-                    "platform": {"type": "string", "description": "Optional platform filter ('airbnb' or 'vrbo')"}
+                    "p_market": {
+                        "type": "string",
+                        "description": "Optional market filter ('Miami' or 'NYC/NJ Metro')",
+                    },
+                    "p_platform": {
+                        "type": "string",
+                        "description": "Optional platform filter ('airbnb' or 'vrbo')",
+                    },
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
-
     # ─── GEO / LOCATION ──────────────────────────────────────────────────────
     {
         "type": "function",
@@ -205,11 +295,14 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "address": {"type": "string", "description": "Street address, city, or general location text supplied by the user (US locations only)"}
+                    "address": {
+                        "type": "string",
+                        "description": "Street address, city, or general location text supplied by the user (US locations only)",
+                    }
                 },
-                "required": ["address"]
-            }
-        }
+                "required": ["address"],
+            },
+        },
     },
     {
         "type": "function",
@@ -219,14 +312,28 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "latitude": {"type": "number", "description": "Latitude of search center"},
-                    "longitude": {"type": "number", "description": "Longitude of search center"},
-                    "radius_km": {"type": "number", "default": 5.0, "description": "Search radius in kilometres (max 20)"},
-                    "limit": {"type": "integer", "default": 10, "description": "Max results to return (max 20)"}
+                    "p_latitude": {
+                        "type": "number",
+                        "description": "Latitude of search center",
+                    },
+                    "p_longitude": {
+                        "type": "number",
+                        "description": "Longitude of search center",
+                    },
+                    "p_radius_km": {
+                        "type": "number",
+                        "default": 5.0,
+                        "description": "Search radius in kilometres (max 20)",
+                    },
+                    "p_limit": {
+                        "type": "integer",
+                        "default": 10,
+                        "description": "Max results to return (max 20)",
+                    },
                 },
-                "required": ["latitude", "longitude"]
-            }
-        }
+                "required": ["latitude", "longitude"],
+            },
+        },
     },
     {
         "type": "function",
@@ -236,14 +343,19 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "property_a_id": {"type": "string", "description": "UUID of the first property"},
-                    "property_b_id": {"type": "string", "description": "UUID of the second property"}
+                    "property_a_id": {
+                        "type": "string",
+                        "description": "UUID of the first property",
+                    },
+                    "property_b_id": {
+                        "type": "string",
+                        "description": "UUID of the second property",
+                    },
                 },
-                "required": ["property_a_id", "property_b_id"]
-            }
-        }
+                "required": ["property_a_id", "property_b_id"],
+            },
+        },
     },
-
     # ─── TRACKING & SYSTEM META ───────────────────────────────────────────────
     {
         "type": "function",
@@ -253,11 +365,14 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "p_platform": {"type": "string", "description": "Optional platform filter (e.g. 'Airbnb' or 'Vrbo')"}
+                    "p_platform": {
+                        "type": "string",
+                        "description": "Optional platform filter (e.g. 'Airbnb' or 'Vrbo')",
+                    }
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
     {
         "type": "function",
@@ -267,13 +382,16 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "days": {"type": "integer", "default": 30, "description": "Lookback window in days"}
+                    "p_days": {
+                        "type": "integer",
+                        "default": 30,
+                        "description": "Lookback window in days",
+                    }
                 },
-                "required": []
-            }
-        }
+                "required": [],
+            },
+        },
     },
-
     # ─── DATA EXPORT ─────────────────────────────────────────────────────────
     {
         "type": "function",
@@ -283,11 +401,17 @@ REAL_ESTATE_TOOLS = [
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "format": {"type": "string", "description": "Export format: 'csv' or 'md'"},
-                    "content": {"type": "string", "description": "Full text content or CSV data to export"}
+                    "format": {
+                        "type": "string",
+                        "description": "Export format: 'csv' or 'md'",
+                    },
+                    "content": {
+                        "type": "string",
+                        "description": "Full text content or CSV data to export",
+                    },
                 },
-                "required": ["format", "content"]
-            }
-        }
-    }
+                "required": ["format", "content"],
+            },
+        },
+    },
 ]