Create openfda.py

mcp/openfda.py

@@ -0,0 +1,24 @@
+# mcp/openfda.py
+
+import httpx
+
+OPENFDA_DRUG_EVENT = "https://api.fda.gov/drug/event.json"
+
+async def fetch_drug_safety(drug: str, max_results: int = 3):
+    """Fetch recent adverse event reports for the drug from OpenFDA."""
+    params = {"search": f'patient.drug.medicinalproduct:"{drug}"', "limit": max_results}
+    async with httpx.AsyncClient() as client:
+        try:
+            resp = await client.get(OPENFDA_DRUG_EVENT, params=params)
+            results = resp.json().get("results", [])
+            output = []
+            for ev in results:
+                output.append({
+                    "safety_report_id": ev.get("safetyreportid"),
+                    "serious": ev.get("serious"),
+                    "reactions": [r["reactionmeddrapt"] for r in ev.get("patient", {}).get("reaction", [])],
+                    "receivedate": ev.get("receivedate"),
+                })
+            return output
+        except Exception:
+            return []