Revert "feat: add self-hosted mem0 MCP bridge"

integrations/mem0-plugin/scripts/_search.py

@@ -6,10 +6,11 @@
 
 from __future__ import annotations
 
+import json
 import os
+import urllib.request
 
-from _api import search_memories as api_search_memories
-
+SEARCH_URL = "https://api.mem0.ai/v3/memories/search/"
 SEARCH_TIMEOUT = 5
 
 
@@ -32,8 +33,16 @@ def should_rerank() -> bool:
 
 
 def _do_search(api_key: str, payload: dict) -> list[dict]:
-    _status, data = api_search_memories(api_key, payload, timeout=SEARCH_TIMEOUT)
-    return data if isinstance(data, list) else data.get("results", [])
+    body = json.dumps(payload).encode()
+    req = urllib.request.Request(
+        SEARCH_URL,
+        data=body,
+        headers={"Authorization": f"Token {api_key}", "Content-Type": "application/json"},
+        method="POST",
+    )
+    with urllib.request.urlopen(req, timeout=SEARCH_TIMEOUT) as r:
+        data = json.loads(r.read())
+        return data if isinstance(data, list) else data.get("results", [])
 
 
 def search_memories(

integrations/mem0-plugin/scripts/auto_capture.py

@@ -17,9 +17,9 @@
 import os
 import sys
 import urllib.error
+import urllib.request
 
 sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))
-from _api import add_memory
 from _identity import resolve_api_key, resolve_user_id
 from _project import resolve_branch, resolve_project_id
 
@@ -39,6 +39,7 @@
     except OSError:
         pass
 
+API_URL = "https://api.mem0.ai"
 TAIL_LINES = 200
 MAX_CONTENT_CHARS = 8000
 MIN_CONTENT_CHARS = 100
@@ -126,14 +127,25 @@ def store_exchange(api_key: str, messages: list[dict], user_id: str,
         "infer": True,
     }
 
+    data = json.dumps(body).encode("utf-8")
+    req = urllib.request.Request(
+        f"{API_URL}/v3/memories/add/",
+        data=data,
+        headers={
+            "Content-Type": "application/json",
+            "Authorization": f"Token {api_key}",
+        },
+        method="POST",
+    )
     try:
-        status, result = add_memory(api_key, body, timeout=15)
-        if status in (200, 201):
-            log.info("Auto-captured: event_id=%s status=%s",
-                     result.get("event_id", "?"), result.get("status", "?"))
-            return True
-        log.warning("API returned status %d", status)
-        return False
+        with urllib.request.urlopen(req, timeout=15) as resp:
+            if resp.status in (200, 201):
+                result = json.loads(resp.read())
+                log.info("Auto-captured: event_id=%s status=%s",
+                         result.get("event_id", "?"), result.get("status", "?"))
+                return True
+            log.warning("API returned status %d", resp.status)
+            return False
     except urllib.error.URLError as e:
         log.warning("API call failed: %s", e)
         return False