refactor: rename memory tool set and update CLI alias handling

.agents/plugins/marketplace.json

@@ -8,7 +8,7 @@
       "name": "mem0",
       "source": {
         "source": "local",
-        "path": "./integrations/mem0-plugin"
+        "path": "./mem0-plugin"
       },
       "policy": {
         "installation": "AVAILABLE",

.claude-plugin/marketplace.json

@@ -10,9 +10,9 @@
   "plugins": [
     {
       "name": "mem0",
-      "source": "./integrations/mem0-plugin",
+      "source": "./mem0-plugin",
       "description": "Mem0 memory layer for AI applications. Add persistent memory, personalization, and semantic search to Claude workflows.",
-      "version": "0.2.11"
+      "version": "0.1.0"
     }
   ]
 }

.codex-plugin/marketplace.json

@@ -1,20 +0,0 @@
-{
-  "name": "mem0-plugins",
-  "interface": {
-    "displayName": "Mem0 Plugins"
-  },
-  "plugins": [
-    {
-      "name": "mem0",
-      "source": {
-        "source": "local",
-        "path": "./integrations/mem0-plugin"
-      },
-      "policy": {
-        "installation": "AVAILABLE",
-        "authentication": "ON_INSTALL"
-      },
-      "category": "Productivity"
-    }
-  ]
-}

.cursor-plugin/marketplace.json

@@ -10,9 +10,9 @@
   "plugins": [
     {
       "name": "mem0",
-      "source": "./integrations/mem0-plugin",
+      "source": "./mem0-plugin",
       "description": "Mem0 memory layer for AI applications. Add persistent memory, personalization, and semantic search.",
-      "version": "0.2.11"
+      "version": "0.1.0"
     }
   ]
 }

.github/workflows/cd.yml

@@ -1,33 +1,18 @@
 name: Publish Python 🐍 distributions 📦 to PyPI and TestPyPI
 
-# Dispatched by release.yml (Release Router) when a release tagged v* is
-# published. Can also be dispatched manually to re-publish a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. v1.2.3)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Unused for PyPI (pre-releases are expressed in the version itself); accepted for router uniformity'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish Python 🐍 distributions 📦 to PyPI and TestPyPI
-    # Pure SDK version tags only (v1.2.3) — excludes package-prefixed tags
-    # like vercel-ai-v* that also start with 'v'
-    if: startsWith(inputs.tag, 'v') && !contains(inputs.tag, '-v')
+    if: startsWith(github.event.release.tag_name, 'v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
     steps:
       - uses: actions/checkout@v2
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Set up Python
         uses: actions/setup-python@v2
@@ -54,6 +39,7 @@ jobs:
       #     packages_dir: dist/
 
       - name: Publish distribution 📦 to PyPI
+        if: startsWith(github.ref, 'refs/tags/v')
         uses: pypa/gh-action-pypi-publish@release/v1
         with:
           packages_dir: dist/

.github/workflows/ci-gate.yml

@@ -1,171 +0,0 @@
-name: CI Gate
-
-# Single required status check for all PRs.
-#
-# Path-filtered CI workflows can't be marked as required in branch
-# protection: on a PR that doesn't touch their paths they never report, and
-# the required check hangs at "Expected" forever. This gate solves that. It
-# runs on every PR, detects which packages changed, calls only the relevant
-# package CI workflows (as reusable workflows), and the final "CI Gate" job
-# reports the aggregate result — success when every invoked pipeline passed
-# (skipped pipelines are fine), failure when any failed.
-#
-# Branch protection should require exactly one status check: "CI Gate".
-#
-# Package CI workflows keep their own push-to-main and workflow_dispatch
-# triggers; only their pull_request triggers moved here. To wire in a new
-# package: add a filter under the `changes` job, a call job that `uses:` the
-# package workflow, and list the call job in the gate's `needs`.
-
-on:
-  pull_request:
-
-concurrency:
-  group: ci-gate-${{ github.event.pull_request.number }}
-  cancel-in-progress: true
-
-permissions:
-  contents: read
-  pull-requests: read
-
-jobs:
-  changes:
-    name: Detect changed packages
-    runs-on: ubuntu-latest
-    outputs:
-      python_sdk: ${{ steps.filter.outputs.python_sdk }}
-      ts_sdk: ${{ steps.filter.outputs.ts_sdk }}
-      cli_python: ${{ steps.filter.outputs.cli_python }}
-      cli_node: ${{ steps.filter.outputs.cli_node }}
-      openclaw: ${{ steps.filter.outputs.openclaw }}
-      opencode_plugin: ${{ steps.filter.outputs.opencode_plugin }}
-      pi_agent_plugin: ${{ steps.filter.outputs.pi_agent_plugin }}
-      docs_llms_txt: ${{ steps.filter.outputs.docs_llms_txt }}
-    steps:
-      - uses: dorny/paths-filter@v3
-        id: filter
-        with:
-          # Each filter mirrors the package workflow's old pull_request
-          # paths, plus the package workflow file itself and this gate file
-          # (changing either must re-exercise the pipeline).
-          filters: |
-            python_sdk:
-              - 'mem0/**'
-              - 'tests/**'
-              - 'pyproject.toml'
-              - '.github/workflows/ci.yml'
-              - '.github/workflows/ci-gate.yml'
-            ts_sdk:
-              - 'mem0-ts/**'
-              - '.github/workflows/ts-sdk-ci.yml'
-              - '.github/workflows/ci-gate.yml'
-            cli_python:
-              - 'cli/python/**'
-              - '.github/workflows/cli-python-ci.yml'
-              - '.github/workflows/ci-gate.yml'
-            cli_node:
-              - 'cli/node/**'
-              - '.github/workflows/cli-node-ci.yml'
-              - '.github/workflows/ci-gate.yml'
-            openclaw:
-              - 'integrations/openclaw/**'
-              - '.github/workflows/openclaw-checks.yml'
-              - '.github/workflows/ci-gate.yml'
-            opencode_plugin:
-              - 'integrations/mem0-plugin/.opencode-plugin/**'
-              - '.github/workflows/opencode-plugin-checks.yml'
-              - '.github/workflows/ci-gate.yml'
-            pi_agent_plugin:
-              - 'integrations/pi-agent-plugin/**'
-              - '.github/workflows/pi-agent-plugin-checks.yml'
-              - '.github/workflows/ci-gate.yml'
-            docs_llms_txt:
-              - 'docs/**/*.mdx'
-              - 'docs/llms.txt'
-              - 'scripts/check-llms-txt-coverage.py'
-              - 'scripts/llms-txt-ignore.txt'
-              - '.github/workflows/docs-llms-txt-check.yml'
-              - '.github/workflows/ci-gate.yml'
-
-  python-sdk:
-    name: Python SDK
-    needs: changes
-    if: needs.changes.outputs.python_sdk == 'true'
-    uses: ./.github/workflows/ci.yml
-    secrets: inherit
-
-  ts-sdk:
-    name: TypeScript SDK
-    needs: changes
-    if: needs.changes.outputs.ts_sdk == 'true'
-    uses: ./.github/workflows/ts-sdk-ci.yml
-    secrets: inherit
-
-  cli-python:
-    name: Python CLI
-    needs: changes
-    if: needs.changes.outputs.cli_python == 'true'
-    uses: ./.github/workflows/cli-python-ci.yml
-    secrets: inherit
-
-  cli-node:
-    name: Node CLI
-    needs: changes
-    if: needs.changes.outputs.cli_node == 'true'
-    uses: ./.github/workflows/cli-node-ci.yml
-    secrets: inherit
-
-  openclaw:
-    name: OpenClaw
-    needs: changes
-    if: needs.changes.outputs.openclaw == 'true'
-    uses: ./.github/workflows/openclaw-checks.yml
-    secrets: inherit
-
-  opencode-plugin:
-    name: OpenCode Plugin
-    needs: changes
-    if: needs.changes.outputs.opencode_plugin == 'true'
-    uses: ./.github/workflows/opencode-plugin-checks.yml
-    secrets: inherit
-
-  pi-agent-plugin:
-    name: Pi Agent Plugin
-    needs: changes
-    if: needs.changes.outputs.pi_agent_plugin == 'true'
-    uses: ./.github/workflows/pi-agent-plugin-checks.yml
-    secrets: inherit
-
-  docs-llms-txt:
-    name: docs llms.txt
-    needs: changes
-    if: needs.changes.outputs.docs_llms_txt == 'true'
-    uses: ./.github/workflows/docs-llms-txt-check.yml
-    secrets: inherit
-
-  gate:
-    name: CI Gate
-    needs:
-      - changes
-      - python-sdk
-      - ts-sdk
-      - cli-python
-      - cli-node
-      - openclaw
-      - opencode-plugin
-      - pi-agent-plugin
-      - docs-llms-txt
-    if: always()
-    runs-on: ubuntu-latest
-    steps:
-      - name: Evaluate pipeline results
-        env:
-          NEEDS: ${{ toJSON(needs) }}
-        run: |
-          echo "$NEEDS" | jq -r 'to_entries[] | "\(.key): \(.value.result)"'
-          failed=$(echo "$NEEDS" | jq -r '[to_entries[] | select(.value.result == "failure" or .value.result == "cancelled") | .key] | join(", ")')
-          if [ -n "$failed" ]; then
-            echo "::error::Failing pipelines: $failed"
-            exit 1
-          fi
-          echo "All pipelines relevant to this change passed."

.github/workflows/ci.yml

@@ -1,58 +1,28 @@
 name: ci
 
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main runs remain standalone.
 on:
   push:
     branches: [main]
-  workflow_call:
+    paths:
+      - 'mem0/**'
+      - 'tests/**'
+      - 'embedchain/**'
+      - '.github/workflows/**'
+      - 'pyproject.toml'
+  pull_request:
+    paths:
+      - 'mem0/**'
+      - 'tests/**'
+      - 'embedchain/**'
 
 jobs:
-  changelog_check:
-    if: github.event_name == 'pull_request'
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-
-      - name: Require CHANGELOG entry when Python SDK version changes
-        env:
-          BASE_SHA: ${{ github.event.pull_request.base.sha }}
-          HEAD_SHA: ${{ github.event.pull_request.head.sha }}
-        run: |
-          set -euo pipefail
-
-          extract_version() {
-            python3 -c "import sys, re; m = re.search(r'^\s*version\s*=\s*\"([^\"]+)\"', sys.stdin.read(), re.M); print(m.group(1) if m else '')"
-          }
-
-          base_version=$(git show "$BASE_SHA:pyproject.toml" 2>/dev/null | extract_version || echo "")
-          head_version=$(extract_version < pyproject.toml)
-
-          echo "Base version: ${base_version:-<unknown>}"
-          echo "Head version: $head_version"
-
-          if [ -z "$base_version" ] || [ "$base_version" = "$head_version" ]; then
-            echo "pyproject.toml version unchanged — no CHANGELOG entry required."
-            exit 0
-          fi
-
-          echo "Detected version bump ${base_version} -> ${head_version}. Checking docs/changelog/sdk.mdx…"
-
-          if git diff --name-only "$BASE_SHA" "$HEAD_SHA" -- docs/changelog/sdk.mdx | grep -q .; then
-            echo "Changelog update present in docs/changelog/sdk.mdx ✅"
-          else
-            echo "::error file=pyproject.toml::pyproject.toml version changed from ${base_version} to ${head_version} but docs/changelog/sdk.mdx was not updated in this PR. Add a new <Update> entry under the Python tab for v${head_version}."
-            exit 1
-          fi
-
   check_changes:
     runs-on: ubuntu-latest
     outputs:
       mem0_changed: ${{ steps.filter.outputs.mem0 }}
+      embedchain_changed: ${{ steps.filter.outputs.embedchain }}
     steps:
-    - uses: actions/checkout@v4
+    - uses: actions/checkout@v3
     - uses: dorny/paths-filter@v2
       id: filter
       with:
@@ -60,28 +30,25 @@ jobs:
           mem0:
             - 'mem0/**'
             - 'tests/**'
-            - '.github/workflows/ci.yml'
+            - '.github/workflows/**'
             - 'pyproject.toml'
+          embedchain:
+            - 'embedchain/**'
 
   build_mem0:
     needs: check_changes
+    if: needs.check_changes.outputs.mem0_changed == 'true'
     runs-on: ubuntu-latest
     strategy:
       matrix:
         python-version: ["3.10", "3.11", "3.12"]
     steps:
-      - name: Skip — no relevant changes
-        if: needs.check_changes.outputs.mem0_changed != 'true'
-        run: echo "No changes in mem0/, tests/, pyproject.toml, or ci.yml — skipping"
-      - uses: actions/checkout@v4
-        if: needs.check_changes.outputs.mem0_changed == 'true'
+      - uses: actions/checkout@v3
       - name: Set up Python ${{ matrix.python-version }}
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         uses: actions/setup-python@v4
         with:
           python-version: ${{ matrix.python-version }}
       - name: Clean up disk space
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         run: |
           df -h
           sudo rm -rf /usr/share/dotnet /usr/local/lib/android /opt/ghc /opt/hostedtoolcache/CodeQL
@@ -89,27 +56,61 @@ jobs:
           sudo docker builder prune -a
           df -h
       - name: Install Hatch
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         run: pip install hatch
       - name: Load cached venv
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         id: cached-hatch-dependencies
         uses: actions/cache@v3
         with:
           path: .venv
           key: venv-mem0-${{ runner.os }}-${{ hashFiles('**/pyproject.toml') }}
       - name: Install GEOS Libraries
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         run: sudo apt-get update && sudo apt-get install -y libgeos-dev
       - name: Install dependencies
-        if: needs.check_changes.outputs.mem0_changed == 'true' && steps.cached-hatch-dependencies.outputs.cache-hit != 'true'
         run: |
           pip install --upgrade pip
           pip install -e ".[test,graph,vector_stores,llms,extras]"
           pip install ruff
+        if: steps.cached-hatch-dependencies.outputs.cache-hit != 'true'
       - name: Run Linting
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         run: make lint
       - name: Run tests and generate coverage report
-        if: needs.check_changes.outputs.mem0_changed == 'true'
         run: make test
+
+  build_embedchain:
+    needs: check_changes
+    if: needs.check_changes.outputs.embedchain_changed == 'true'
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        python-version: ["3.9", "3.10", "3.11", "3.12"]
+    steps:
+      - uses: actions/checkout@v3
+      - name: Set up Python ${{ matrix.python-version }}
+        uses: actions/setup-python@v4
+        with:
+          python-version: ${{ matrix.python-version }}
+      - name: Install Hatch
+        run: pip install hatch
+      - name: Load cached venv
+        id: cached-hatch-dependencies
+        uses: actions/cache@v3
+        with:
+          path: .venv
+          key: venv-embedchain-${{ runner.os }}-${{ hashFiles('**/pyproject.toml') }}
+      - name: Install dependencies
+        run: cd embedchain && make install_all
+        if: steps.cached-hatch-dependencies.outputs.cache-hit != 'true'
+      - name: Run Formatting
+        run: |
+          mkdir -p embedchain/.ruff_cache && chmod -R 777 embedchain/.ruff_cache
+          cd embedchain && hatch run format
+      - name: Lint with ruff
+        run: cd embedchain && make lint
+      - name: Run tests and generate coverage report
+        run: cd embedchain && make coverage
+      - name: Upload coverage reports to Codecov
+        uses: codecov/codecov-action@v3
+        with:
+          file: coverage.xml
+        env:
+          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}

.github/workflows/cli-node-cd.yml

@@ -1,25 +1,13 @@
 name: Publish @mem0/cli 📦 to npm
 
-# Dispatched by release.yml (Release Router) when a release tagged
-# cli-node-v* is published. Can also be dispatched manually to re-publish
-# a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. cli-node-v0.2.0)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish @mem0/cli 📦 to npm
-    if: startsWith(inputs.tag, 'cli-node-v')
+    if: startsWith(github.event.release.tag_name, 'cli-node-v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
@@ -28,8 +16,6 @@ jobs:
         working-directory: cli/node
     steps:
       - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Install pnpm
         uses: pnpm/action-setup@v4
@@ -44,6 +30,9 @@ jobs:
           cache: 'pnpm'
           cache-dependency-path: cli/node/pnpm-lock.yaml
 
+      - name: Upgrade npm for OIDC trusted publishing
+        run: npm install -g npm@latest
+
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
 
@@ -52,9 +41,9 @@ jobs:
 
       - name: Publish to npm
         run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
+          if [ "${{ github.event.release.prerelease }}" = "true" ]; then
             PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
+            npm publish --provenance --access public --tag "$PREID"
           else
-            npx npm@latest publish --provenance --access public
+            npm publish --provenance --access public
           fi

.github/workflows/cli-node-ci.yml

@@ -1,7 +1,5 @@
 name: CLI Node CI
 
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main and manual runs remain standalone.
 on:
   workflow_dispatch:
   push:
@@ -9,7 +7,10 @@ on:
     paths:
       - 'cli/node/**'
       - '.github/workflows/cli-node-ci.yml'
-  workflow_call:
+  pull_request:
+    paths:
+      - 'cli/node/**'
+      - '.github/workflows/cli-node-ci.yml'
 
 jobs:
   lint:

.github/workflows/cli-python-cd.yml

@@ -1,24 +1,13 @@
 name: Publish mem0-cli 🐍 distributions 📦 to PyPI
 
-# Dispatched by release.yml (Release Router) when a release tagged cli-v* is
-# published. Can also be dispatched manually to re-publish a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. cli-v0.2.0)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Unused for PyPI (pre-releases are expressed in the version itself); accepted for router uniformity'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish mem0-cli 📦 to PyPI
-    if: startsWith(inputs.tag, 'cli-v')
+    if: startsWith(github.event.release.tag_name, 'cli-v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
@@ -27,8 +16,6 @@ jobs:
         working-directory: cli/python
     steps:
       - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Set up Python
         uses: actions/setup-python@v5

.github/workflows/cli-python-ci.yml

@@ -1,7 +1,5 @@
 name: CLI Python CI
 
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main and manual runs remain standalone.
 on:
   workflow_dispatch:
   push:
@@ -9,7 +7,10 @@ on:
     paths:
       - 'cli/python/**'
       - '.github/workflows/cli-python-ci.yml'
-  workflow_call:
+  pull_request:
+    paths:
+      - 'cli/python/**'
+      - '.github/workflows/cli-python-ci.yml'
 
 jobs:
   lint:

.github/workflows/docs-llms-txt-check.yml

@@ -1,42 +0,0 @@
-name: docs - llms.txt check
-
-# Blocks PRs that introduce new .mdx pages without a matching entry in
-# docs/llms.txt, or that link to pages that no longer exist. Contributors
-# must update docs/llms.txt in the same PR. Run locally with:
-#   python scripts/check-llms-txt-coverage.py           # read-only
-#   python scripts/check-llms-txt-coverage.py --write   # scaffold placeholders
-
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# manual runs remain standalone.
-on:
-  workflow_call:
-  workflow_dispatch: {}
-
-permissions:
-  contents: read
-
-jobs:
-  check-llms-txt:
-    runs-on: ubuntu-24.04-arm
-    timeout-minutes: 2
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Verify docs/llms.txt coverage
-        run: |
-          if ! python3 scripts/check-llms-txt-coverage.py; then
-            echo ""
-            echo "::error title=llms.txt out of sync::docs/llms.txt does not match docs/**/*.mdx."
-            echo ""
-            echo "To fix:"
-            echo "  1. Run locally:  python scripts/check-llms-txt-coverage.py --write"
-            echo "     This appends placeholder entries under '## Unclassified - needs triage'."
-            echo "  2. For each placeholder:"
-            echo "       - replace [TODO: Platform|OSS|Both] with the correct scope tag"
-            echo "       - rewrite the description as 'Use when ...'"
-            echo "       - move the entry into the appropriate section"
-            echo "       - delete the '## Unclassified - needs triage' heading once empty"
-            echo "  3. Resolve any stale URLs listed above by updating or removing the link."
-            echo "  4. Commit the updated docs/llms.txt to this PR."
-            exit 1
-          fi

.github/workflows/openclaw-cd.yml

@@ -1,35 +1,21 @@
 name: Publish @mem0/openclaw-mem0 📦 to npm
 
-# Dispatched by release.yml (Release Router) when a release tagged
-# openclaw-v* is published. Can also be dispatched manually to re-publish
-# a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. openclaw-v0.5.0)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish @mem0/openclaw-mem0 📦 to npm
-    if: startsWith(inputs.tag, 'openclaw-v')
+    if: startsWith(github.event.release.tag_name, 'openclaw-v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
     defaults:
       run:
-        working-directory: integrations/openclaw
+        working-directory: openclaw
     steps:
       - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Install pnpm
         uses: pnpm/action-setup@v4
@@ -42,7 +28,10 @@ jobs:
           node-version: '22'
           registry-url: 'https://registry.npmjs.org'
           cache: 'pnpm'
-          cache-dependency-path: integrations/openclaw/pnpm-lock.yaml
+          cache-dependency-path: openclaw/pnpm-lock.yaml
+
+      - name: Upgrade npm for OIDC trusted publishing
+        run: npm install -g npm@latest
 
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
@@ -52,9 +41,9 @@ jobs:
 
       - name: Publish to npm
         run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
+          if [ "${{ github.event.release.prerelease }}" = "true" ]; then
             PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
+            npm publish --provenance --access public --tag "$PREID"
           else
-            npx npm@latest publish --provenance --access public
+            npm publish --provenance --access public
           fi

.github/workflows/openclaw-checks.yml

@@ -1,15 +1,16 @@
 name: openclaw checks
 
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main and manual runs remain standalone.
 on:
   workflow_dispatch:
   push:
     branches: [main]
     paths:
-      - 'integrations/openclaw/**'
+      - 'openclaw/**'
+      - '.github/workflows/openclaw-checks.yml'
+  pull_request:
+    paths:
+      - 'openclaw/**'
       - '.github/workflows/openclaw-checks.yml'
-  workflow_call:
 
 jobs:
   lint:
@@ -27,13 +28,13 @@ jobs:
         with:
           node-version: 20
           cache: 'pnpm'
-          cache-dependency-path: integrations/openclaw/pnpm-lock.yaml
+          cache-dependency-path: openclaw/pnpm-lock.yaml
 
       - name: Install dependencies
-        run: cd integrations/openclaw && pnpm install --frozen-lockfile
+        run: cd openclaw && pnpm install --frozen-lockfile
 
       - name: Type check
-        run: cd integrations/openclaw && pnpm exec tsc --noEmit
+        run: cd openclaw && pnpm exec tsc --noEmit
 
   test:
     runs-on: ubuntu-latest
@@ -53,20 +54,20 @@ jobs:
         with:
           node-version: ${{ matrix.node-version }}
           cache: 'pnpm'
-          cache-dependency-path: integrations/openclaw/pnpm-lock.yaml
+          cache-dependency-path: openclaw/pnpm-lock.yaml
 
       - name: Install dependencies
-        run: cd integrations/openclaw && pnpm install --frozen-lockfile
+        run: cd openclaw && pnpm install --frozen-lockfile
 
       - name: Run tests with coverage
-        run: cd integrations/openclaw && pnpm exec vitest run --coverage
+        run: cd openclaw && pnpm exec vitest run --coverage
 
       - name: Upload coverage to Codecov
         if: matrix.node-version == 20
         uses: codecov/codecov-action@v4
         with:
           flags: openclaw
-          directory: integrations/openclaw/coverage
+          directory: openclaw/coverage
         env:
           CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
 
@@ -85,15 +86,15 @@ jobs:
         with:
           node-version: 20
           cache: 'pnpm'
-          cache-dependency-path: integrations/openclaw/pnpm-lock.yaml
+          cache-dependency-path: openclaw/pnpm-lock.yaml
 
       - name: Install dependencies
-        run: cd integrations/openclaw && pnpm install --frozen-lockfile
+        run: cd openclaw && pnpm install --frozen-lockfile
 
       - name: Build
-        run: cd integrations/openclaw && pnpm build
+        run: cd openclaw && pnpm build
 
       - name: Verify dist output exists
         run: |
-          test -f integrations/openclaw/dist/index.js || (echo "Build output missing: dist/index.js" && exit 1)
-          test -f integrations/openclaw/dist/index.d.ts || (echo "Build output missing: dist/index.d.ts" && exit 1)
+          test -f openclaw/dist/index.js || (echo "Build output missing: dist/index.js" && exit 1)
+          test -f openclaw/dist/index.d.ts || (echo "Build output missing: dist/index.d.ts" && exit 1)

.github/workflows/opencode-plugin-cd.yml

@@ -1,58 +0,0 @@
-name: Publish @mem0/opencode-plugin 📦 to npm
-
-# Dispatched by release.yml (Release Router) when a release tagged
-# opencode-v* is published. Can also be dispatched manually to re-publish
-# a tag.
-on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. opencode-v0.2.0)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
-
-jobs:
-  build-n-publish:
-    name: Build and publish @mem0/opencode-plugin 📦 to npm
-    if: startsWith(inputs.tag, 'opencode-v')
-    runs-on: ubuntu-latest
-    permissions:
-      id-token: write
-    defaults:
-      run:
-        working-directory: integrations/mem0-plugin/.opencode-plugin
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
-
-      - name: Install Bun
-        uses: oven-sh/setup-bun@v2
-        with:
-          bun-version: latest
-
-      - name: Set up Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: '22'
-          registry-url: 'https://registry.npmjs.org'
-
-      - name: Install dependencies
-        run: bun install --frozen-lockfile
-
-      - name: Build
-        run: bun run build
-
-      - name: Publish to npm
-        run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
-            PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
-          else
-            npx npm@latest publish --provenance --access public
-          fi

.github/workflows/opencode-plugin-checks.yml

@@ -1,39 +0,0 @@
-name: opencode-plugin checks
-
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main and manual runs remain standalone.
-on:
-  workflow_dispatch:
-  push:
-    branches: [main]
-    paths:
-      - 'integrations/mem0-plugin/.opencode-plugin/**'
-      - '.github/workflows/opencode-plugin-checks.yml'
-  workflow_call:
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    defaults:
-      run:
-        working-directory: integrations/mem0-plugin/.opencode-plugin
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install Bun
-        uses: oven-sh/setup-bun@v2
-        with:
-          bun-version: latest
-
-      - name: Install dependencies
-        run: bun install --frozen-lockfile
-
-      - name: Type check
-        run: bun run type-check
-
-      - name: Build
-        run: bun run build
-
-      - name: Verify dist output exists
-        run: |
-          test -f dist/index.js || (echo "Build output missing: dist/index.js" && exit 1)

.github/workflows/pi-agent-plugin-cd.yml

@@ -1,60 +0,0 @@
-name: Publish @mem0/pi-agent-plugin 📦 to npm
-
-# Dispatched by release.yml (Release Router) when a release tagged
-# pi-agent-v* is published. Can also be dispatched manually to re-publish
-# a tag.
-on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. pi-agent-v0.1.1)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
-
-jobs:
-  build-n-publish:
-    name: Build and publish @mem0/pi-agent-plugin 📦 to npm
-    if: startsWith(inputs.tag, 'pi-agent-v')
-    runs-on: ubuntu-latest
-    permissions:
-      id-token: write
-    defaults:
-      run:
-        working-directory: integrations/pi-agent-plugin
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 9
-
-      - name: Set up Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: '22'
-          registry-url: 'https://registry.npmjs.org'
-          cache: 'pnpm'
-          cache-dependency-path: integrations/pi-agent-plugin/pnpm-lock.yaml
-
-      - name: Install dependencies
-        run: pnpm install --frozen-lockfile
-
-      - name: Build
-        run: pnpm build
-
-      - name: Publish to npm
-        run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
-            PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
-          else
-            npx npm@latest publish --provenance --access public
-          fi

.github/workflows/pi-agent-plugin-checks.yml

@@ -1,92 +0,0 @@
-name: pi-agent-plugin checks
-
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main and manual runs remain standalone.
-on:
-  workflow_dispatch:
-  push:
-    branches: [main]
-    paths:
-      - 'integrations/pi-agent-plugin/**'
-      - '.github/workflows/pi-agent-plugin-checks.yml'
-  workflow_call:
-
-jobs:
-  lint:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 9
-
-      - name: Setup Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: 20
-          cache: 'pnpm'
-          cache-dependency-path: integrations/pi-agent-plugin/pnpm-lock.yaml
-
-      - name: Install dependencies
-        run: cd integrations/pi-agent-plugin && pnpm install --frozen-lockfile
-
-      - name: Type check
-        run: cd integrations/pi-agent-plugin && pnpm exec tsc --noEmit
-
-  test:
-    runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        node-version: [20, 22]
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 9
-
-      - name: Setup Node.js ${{ matrix.node-version }}
-        uses: actions/setup-node@v4
-        with:
-          node-version: ${{ matrix.node-version }}
-          cache: 'pnpm'
-          cache-dependency-path: integrations/pi-agent-plugin/pnpm-lock.yaml
-
-      - name: Install dependencies
-        run: cd integrations/pi-agent-plugin && pnpm install --frozen-lockfile
-
-      - name: Run tests
-        run: cd integrations/pi-agent-plugin && pnpm exec vitest run
-
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 9
-
-      - name: Setup Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: 20
-          cache: 'pnpm'
-          cache-dependency-path: integrations/pi-agent-plugin/pnpm-lock.yaml
-
-      - name: Install dependencies
-        run: cd integrations/pi-agent-plugin && pnpm install --frozen-lockfile
-
-      - name: Build
-        run: cd integrations/pi-agent-plugin && pnpm build
-
-      - name: Verify dist output exists
-        run: |
-          test -f integrations/pi-agent-plugin/dist/index.js || (echo "Build output missing: dist/index.js" && exit 1)
-          test -f integrations/pi-agent-plugin/dist/index.d.ts || (echo "Build output missing: dist/index.d.ts" && exit 1)
-          test -f integrations/pi-agent-plugin/dist/entry.js || (echo "Build output missing: dist/entry.js" && exit 1)
-          test -f integrations/pi-agent-plugin/dist/entry.d.ts || (echo "Build output missing: dist/entry.d.ts" && exit 1)

.github/workflows/release.yml

@@ -1,68 +0,0 @@
-name: Release Router 🚦
-
-# Single entry point for all release publishing.
-#
-# Package CD workflows no longer listen to release events themselves — this
-# router inspects the release tag and dispatches only the matching pipeline,
-# so each release produces one routed run instead of one real run plus seven
-# skipped ones.
-#
-# Re-publishing a release (e.g. after fixing registry settings) does NOT
-# require deleting and recreating it anymore — manually dispatch the
-# package's CD workflow from the tag instead:
-#
-#   gh workflow run <package>-cd.yml --ref refs/tags/<tag> -f tag=<tag>
-#
-# Note: dispatching runs the workflow file as it exists at the given ref, so
-# this router can only dispatch tags created after the workflow_dispatch
-# conversion landed on main. For older tags, dispatch manually from main.
-
-on:
-  release:
-    types: [published]
-
-permissions:
-  actions: write
-
-jobs:
-  route:
-    name: Route ${{ github.event.release.tag_name }} to its CD pipeline
-    runs-on: ubuntu-latest
-    steps:
-      - name: Match tag prefix to CD workflow
-        id: match
-        env:
-          TAG: ${{ github.event.release.tag_name }}
-        run: |
-          # Specific package prefixes first; the bare v* (Python SDK) arm
-          # must stay last so prefixed tags that also start with 'v'
-          # (vercel-ai-v*) can never be routed to the Python pipeline.
-          case "$TAG" in
-            ts-v*)        workflow="ts-sdk-cd.yml" ;;
-            cli-node-v*)  workflow="cli-node-cd.yml" ;;
-            cli-v*)       workflow="cli-python-cd.yml" ;;
-            vercel-ai-v*) workflow="vercel-ai-cd.yml" ;;
-            openclaw-v*)  workflow="openclaw-cd.yml" ;;
-            opencode-v*)  workflow="opencode-plugin-cd.yml" ;;
-            pi-agent-v*)  workflow="pi-agent-plugin-cd.yml" ;;
-            v*)           workflow="cd.yml" ;;
-            *)
-              echo "::error::Release tag '$TAG' does not match any known package prefix — nothing will be published. See the tag prefix table in AGENTS.md."
-              exit 1
-              ;;
-          esac
-          echo "workflow=$workflow" >> "$GITHUB_OUTPUT"
-          echo ":outbox_tray: Routed \`$TAG\` → \`$workflow\`" >> "$GITHUB_STEP_SUMMARY"
-
-      - name: Dispatch ${{ steps.match.outputs.workflow }}
-        env:
-          GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-          TAG: ${{ github.event.release.tag_name }}
-        run: |
-          # --ref points at the tag so the dispatched run builds (and signs
-          # provenance for) the exact tagged commit.
-          gh workflow run "${{ steps.match.outputs.workflow }}" \
-            --repo "$GITHUB_REPOSITORY" \
-            --ref "refs/tags/$TAG" \
-            -f tag="$TAG" \
-            -f prerelease="${{ github.event.release.prerelease }}"

.github/workflows/ts-sdk-cd.yml

@@ -1,24 +1,13 @@
 name: Publish mem0ai 📦 to npm
 
-# Dispatched by release.yml (Release Router) when a release tagged ts-v* is
-# published. Can also be dispatched manually to re-publish a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. ts-v2.1.0)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish mem0ai 📦 to npm
-    if: startsWith(inputs.tag, 'ts-v')
+    if: startsWith(github.event.release.tag_name, 'ts-v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
@@ -27,8 +16,6 @@ jobs:
         working-directory: mem0-ts
     steps:
       - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Install pnpm
         uses: pnpm/action-setup@v4
@@ -43,6 +30,9 @@ jobs:
           cache: 'pnpm'
           cache-dependency-path: mem0-ts/pnpm-lock.yaml
 
+      - name: Upgrade npm for OIDC trusted publishing
+        run: npm install -g npm@latest
+
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
 
@@ -51,9 +41,9 @@ jobs:
 
       - name: Publish to npm
         run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
+          if [ "${{ github.event.release.prerelease }}" = "true" ]; then
             PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
+            npm publish --provenance --access public --tag "$PREID"
           else
-            npx npm@latest publish --provenance --access public
+            npm publish --provenance --access public
           fi

.github/workflows/ts-sdk-ci.yml

@@ -1,14 +1,14 @@
 name: TypeScript SDK CI
 
-# On PRs this is invoked by ci-gate.yml (the single required check);
-# push-to-main runs remain standalone.
 on:
   push:
     branches: [main]
     paths:
       - 'mem0-ts/**'
       - '.github/workflows/ts-sdk-ci.yml'
-  workflow_call:
+  pull_request:
+    paths:
+      - 'mem0-ts/**'
 
 jobs:
   check_changes:
@@ -24,42 +24,6 @@ jobs:
             ts_sdk:
               - 'mem0-ts/**'
 
-  changelog_check:
-    needs: check_changes
-    if: github.event_name == 'pull_request' && needs.check_changes.outputs.ts_sdk_changed == 'true'
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-
-      - name: Require CHANGELOG entry when SDK version changes
-        env:
-          BASE_SHA: ${{ github.event.pull_request.base.sha }}
-          HEAD_SHA: ${{ github.event.pull_request.head.sha }}
-        run: |
-          set -euo pipefail
-
-          base_version=$(git show "$BASE_SHA:mem0-ts/package.json" 2>/dev/null | jq -r .version || echo "")
-          head_version=$(jq -r .version mem0-ts/package.json)
-
-          echo "Base version: ${base_version:-<unknown>}"
-          echo "Head version: $head_version"
-
-          if [ -z "$base_version" ] || [ "$base_version" = "$head_version" ]; then
-            echo "mem0-ts/package.json version unchanged — no CHANGELOG entry required."
-            exit 0
-          fi
-
-          echo "Detected version bump ${base_version} -> ${head_version}. Checking docs/changelog/sdk.mdx…"
-
-          if git diff --name-only "$BASE_SHA" "$HEAD_SHA" -- docs/changelog/sdk.mdx | grep -q .; then
-            echo "Changelog update present in docs/changelog/sdk.mdx ✅"
-          else
-            echo "::error file=mem0-ts/package.json::mem0-ts/package.json version changed from ${base_version} to ${head_version} but docs/changelog/sdk.mdx was not updated in this PR. Add a new <Update> entry under the TypeScript tab for v${head_version}."
-            exit 1
-          fi
-
   build_ts_sdk:
     needs: check_changes
     if: needs.check_changes.outputs.ts_sdk_changed == 'true'

.github/workflows/vercel-ai-cd.yml

@@ -1,35 +1,21 @@
 name: Publish @mem0/vercel-ai-provider 📦 to npm
 
-# Dispatched by release.yml (Release Router) when a release tagged
-# vercel-ai-v* is published. Can also be dispatched manually to re-publish
-# a tag.
 on:
-  workflow_dispatch:
-    inputs:
-      tag:
-        description: 'Release tag to build and publish (e.g. vercel-ai-v2.0.7)'
-        required: true
-        type: string
-      prerelease:
-        description: 'Publish under the version preid dist-tag instead of latest'
-        required: false
-        type: boolean
-        default: false
+  release:
+    types: [published]
 
 jobs:
   build-n-publish:
     name: Build and publish @mem0/vercel-ai-provider 📦 to npm
-    if: startsWith(inputs.tag, 'vercel-ai-v')
+    if: startsWith(github.event.release.tag_name, 'vercel-ai-v')
     runs-on: ubuntu-latest
     permissions:
       id-token: write
     defaults:
       run:
-        working-directory: integrations/vercel-ai-sdk
+        working-directory: vercel-ai-sdk
     steps:
       - uses: actions/checkout@v4
-        with:
-          ref: ${{ inputs.tag }}
 
       - name: Install pnpm
         uses: pnpm/action-setup@v4
@@ -42,7 +28,10 @@ jobs:
           node-version: '22'
           registry-url: 'https://registry.npmjs.org'
           cache: 'pnpm'
-          cache-dependency-path: integrations/vercel-ai-sdk/pnpm-lock.yaml
+          cache-dependency-path: vercel-ai-sdk/pnpm-lock.yaml
+
+      - name: Upgrade npm for OIDC trusted publishing
+        run: npm install -g npm@latest
 
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
@@ -52,9 +41,9 @@ jobs:
 
       - name: Publish to npm
         run: |
-          if [ "${{ inputs.prerelease }}" = "true" ]; then
+          if [ "${{ github.event.release.prerelease }}" = "true" ]; then
             PREID=$(node -p "require('./package.json').version.split('-')[1].split('.')[0]")
-            npx npm@latest publish --provenance --access public --tag "$PREID"
+            npm publish --provenance --access public --tag "$PREID"
           else
-            npx npm@latest publish --provenance --access public
+            npm publish --provenance --access public
           fi

.gitignore

@@ -4,10 +4,6 @@ __pycache__/
 *$py.class
 **/node_modules/
 
-# Self-hosted server local runtime state
-server/history/
-server/.env
-
 # C extensions
 *.so
 
@@ -19,8 +15,8 @@ dist/
 downloads/
 eggs/
 .eggs/
-/lib/
-/lib64/
+lib/
+lib64/
 parts/
 sdist/
 var/
@@ -170,6 +166,7 @@ cython_debug/
 # Database
 db
 test-db
+!embedchain/embedchain/core/db/
 
 .vscode
 .idea/
@@ -189,5 +186,3 @@ eval/
 qdrant_storage/
 .crossnote
 testing.ipynb
-.weave/
-

.gitmodules

@@ -1,4 +0,0 @@
-[submodule "evaluation"]
-	path = evaluation
-	url = https://github.com/mem0ai/memory-benchmarks
-	branch = main

AGENTS.md

@@ -1,611 +0,0 @@
-# AGENTS.md
-
-This file provides context for AI coding assistants (Claude Code, Cursor, GitHub Copilot, Codex, etc.) working with the Mem0 repository.
-
-## Project Overview
-
-**Mem0** ("mem-zero") is an intelligent memory layer for AI agents and assistants. It provides persistent, personalized memory via both a hosted platform API and self-hosted open-source SDKs.
-
-- **Repository**: https://github.com/mem0ai/mem0
-- **Documentation**: https://docs.mem0.ai
-- **License**: Apache-2.0
-
-## Repository Structure
-
-This is a **polyglot monorepo** containing Python and TypeScript packages, CLIs, servers, plugins, and documentation.
-
-### Key Directories
-
-| Directory | Description |
-|-----------|-------------|
-| `mem0/` | Core Python SDK (`mem0ai` on PyPI) — memory, LLMs, embeddings, vector stores, graphs, rerankers |
-| `mem0-ts/` | TypeScript SDK (`mem0ai` on npm) — client + OSS memory |
-| `cli/python/` | Python CLI (`mem0-cli` on PyPI) — Typer-based, entry point `mem0` |
-| `cli/node/` | Node CLI (`@mem0/cli` on npm) — Commander-based, entry point `mem0` |
-| `integrations/` | **Agent & editor integrations**, one directory per integration (see "Adding a New Integration") |
-| `integrations/mem0-plugin/` | AI editor plugins (Claude Code, Cursor, Codex) — MCP server connection, lifecycle hooks, skills. Contains nested `.opencode-plugin/` (`@mem0/opencode-plugin`) |
-| `integrations/openclaw/` | `@mem0/openclaw-mem0` — OpenClaw plugin for Claude Code / AI editors |
-| `integrations/pi-agent-plugin/` | `@mem0/pi-agent-plugin` — Pi Agent plugin |
-| `integrations/vercel-ai-sdk/` | `@mem0/vercel-ai-provider` — Vercel AI SDK memory provider |
-| `server/` | FastAPI REST server for self-hosted Mem0 (Docker: FastAPI + PostgreSQL/pgvector + Neo4j) |
-| `openmemory/` | Self-hosted memory platform — `api/` (FastAPI + Alembic + MCP server) and `ui/` (Next.js 15 + React 19) |
-| `skills/` | Claude Code skill definitions. Reference skills (SDK knowledge, always-on): `mem0/`, `mem0-cli/`, `mem0-vercel-ai-sdk/`. Pipeline skills (run on demand): `mem0-integrate/`, `mem0-test-integration/`, `mem0-oss-to-platform/` |
-| `docs/` | Documentation site (Mintlify) |
-| `tests/` | Python SDK tests (pytest) |
-| `evaluation/` | Submodule → [`mem0ai/memory-benchmarks`](https://github.com/mem0ai/memory-benchmarks) — benchmarking (LOCOMO, LongMemEval, BEAM) lives in that repo |
-| `examples/` | Sample projects & runnable demos — apps, Chrome extension, multi-agent patterns, and Jupyter notebooks (`notebooks/`) |
-| `pr-reviews/` | Pull request review materials |
-| `scripts/` | Repo-wide utility scripts (e.g., `check-llms-txt-coverage.py` for docs/llms.txt sync) |
-
-### Core Package Dependencies
-
-```
-mem0 (Python SDK)          mem0-ts (TypeScript SDK)
-├── mem0/memory/           ├── src/client/        (MemoryClient — hosted)
-├── mem0/llms/             └── src/oss/           (Memory — self-hosted)
-├── mem0/embeddings/           ├── src/llms/
-├── mem0/vector_stores/        ├── src/embeddings/
-├── mem0/graphs/               ├── src/vector_stores/
-└── mem0/reranker/             └── src/graphs/
-
-cli/python/ ──▶ mem0ai (optional, for OSS mode)
-cli/node/   ──▶ mem0ai (npm, for API calls)
-integrations/vercel-ai-sdk/ ──▶ ai, @ai-sdk/* providers
-integrations/openclaw/ ──▶ mem0ai (npm)
-```
-
-## Development Setup
-
-### Requirements
-
-- **Python**: 3.9+ (3.10+ for CLI)
-- **Node.js**: v18+ (v20 or v22 recommended)
-- **pnpm**: v10+ (`npm install -g pnpm@10`) — used for all TypeScript packages
-- **Hatch**: Python build/environment tool (`pip install hatch`)
-- **Docker**: Required for `server/` and `openmemory/` development
-
-### Initial Setup
-
-```bash
-# Python SDK
-hatch shell dev_py_3_11           # creates environment with all deps
-pre-commit install                # install git hooks
-
-# TypeScript packages
-cd mem0-ts && pnpm install        # TS SDK
-cd cli/node && pnpm install       # Node CLI
-cd integrations/vercel-ai-sdk && pnpm install  # Vercel AI provider
-cd integrations/openclaw && pnpm install       # OpenClaw plugin
-```
-
-## Build, Lint, and Test Commands
-
-### Python SDK (`mem0/`)
-
-```bash
-# Environment setup (uses Hatch)
-hatch shell dev_py_3_11           # or dev_py_3_9, dev_py_3_10, dev_py_3_12
-
-# Linting and formatting
-make lint                          # ruff check
-make format                        # ruff format
-make sort                          # isort mem0/
-
-# Tests
-make test                          # pytest tests/
-make test-py-3.9                   # test specific Python version (3.9–3.12)
-
-# Build and publish
-make build                         # hatch build
-make publish                       # hatch publish
-```
-
-- **Python:** 3.9, 3.10, 3.11, 3.12
-- **Linter/formatter:** Ruff (line length **120**)
-- **Import sorting:** isort (`profile = "black"`)
-- **Test framework:** pytest (with pytest-mock, pytest-asyncio)
-- **Pre-commit hooks:** ruff + isort — run `pre-commit install` before committing
-
-### TypeScript SDK (`mem0-ts/`)
-
-```bash
-cd mem0-ts
-pnpm install
-pnpm run build                     # tsup
-pnpm run test                      # jest (all tests)
-pnpm run test:unit                 # jest --coverage (unit tests only)
-pnpm run test:integration          # jest (integration tests, needs MEM0_API_KEY)
-pnpm run test:ci                   # jest --coverage --ci (CI mode)
-pnpm run test:watch                # jest watch mode
-```
-
-- **Node:** 20, 22 (CI-tested)
-- **Build:** tsup (CJS + ESM)
-- **Test:** jest
-- **Formatter:** prettier
-
-### Python CLI (`cli/python/`)
-
-```bash
-cd cli/python
-pip install -e ".[dev]"            # dev install with ruff + pytest
-ruff check .                       # lint
-ruff format .                      # format
-pytest                             # test
-hatch build                        # build
-```
-
-- **Python:** 3.10+ (not 3.9)
-- **Linter/formatter:** Ruff (line length **100** — different from root SDK)
-- **Ruff rules:** E, F, I, W, UP, B, SIM, RUF (ignores E501, B008 for Typer patterns, SIM108)
-- **Framework:** Typer + Rich + httpx
-- **Entry point:** `mem0 = "mem0_cli.app:main"`
-- **Source layout:** `src/mem0_cli/`
-- **Optional dependency:** `mem0ai` (for OSS mode, via `[oss]` extra)
-
-### Node CLI (`cli/node/`)
-
-```bash
-cd cli/node
-pnpm install
-pnpm run build                     # tsup
-pnpm run lint                      # biome check src/
-pnpm run lint:fix                  # biome check --write src/
-pnpm run typecheck                 # tsc --noEmit
-pnpm run test                      # vitest run
-pnpm run test:watch                # vitest (watch mode)
-pnpm run dev                       # tsx src/index.ts (development)
-```
-
-- **Node:** 18+ required
-- **Build:** tsup (ESM)
-- **Linter:** Biome (not ESLint, not Ruff)
-- **Test:** vitest (not jest)
-- **Framework:** Commander + Chalk + ora + cli-table3
-
-### Vercel AI SDK Provider (`integrations/vercel-ai-sdk/`)
-
-```bash
-cd integrations/vercel-ai-sdk
-pnpm install
-pnpm run build                     # tsup
-pnpm run lint                      # eslint
-pnpm run type-check                # tsc --noEmit
-pnpm run prettier-check            # prettier --check
-pnpm run test                      # jest
-pnpm run test:edge                 # vitest (edge runtime)
-pnpm run test:node                 # vitest (node runtime)
-```
-
-- **Build:** tsup (CJS + ESM)
-- **Lint:** ESLint + Prettier
-- **Test:** jest + vitest (edge/node configs)
-
-### OpenClaw Plugin (`integrations/openclaw/`)
-
-```bash
-cd integrations/openclaw
-pnpm install
-pnpm run build                     # tsup
-pnpm run test                      # vitest run
-```
-
-- **Build:** tsup (ESM)
-- **Test:** vitest (with Codecov in CI)
-- **Plugin manifest:** `openclaw.plugin.json`
-
-### Server (`server/`)
-
-```bash
-# Docker production build
-cd server
-make build                         # docker build -t mem0-api-server .
-make run_local                     # docker run -p 8000:8000 with .env
-
-# Docker Compose development (FastAPI + PostgreSQL/pgvector + Neo4j)
-cd server
-docker-compose up                  # starts all 3 services
-# mem0 API: localhost:8888
-# PostgreSQL: localhost:8432
-# Neo4j HTTP: localhost:8474, Bolt: localhost:8687
-```
-
-- **Framework:** FastAPI with uvicorn (auto-reload in dev)
-- **Services:** PostgreSQL with pgvector, Neo4j 5.x with APOC plugin
-- **Hot reload:** Dev Dockerfile mounts `server/` and `mem0/` for live changes
-
-### OpenMemory (`openmemory/`)
-
-```bash
-# Full stack via Docker Compose
-cd openmemory
-docker-compose up
-# Qdrant: localhost:6333
-# API (MCP): localhost:8765
-# UI: localhost:3000
-
-# Individual development
-cd openmemory/api && uvicorn main:app --reload       # FastAPI backend
-cd openmemory/ui && npm run dev                       # Next.js frontend
-
-# Tests
-cd openmemory/api && pytest tests/                   # API tests (e.g., test_mcp_server.py)
-```
-
-- **API:** FastAPI + Alembic (DB migrations) + MCP server (Model Context Protocol)
-- **UI:** Next.js 15, React 19, Radix UI, Redux Toolkit, TailwindCSS, Recharts
-- **Vector store:** Qdrant
-
-### Documentation (`docs/`)
-
-```bash
-make docs                          # or: cd docs && mintlify dev
-```
-
-- **Framework:** Mintlify
-- **API spec:** `docs/openapi.json`
-- **Structure:** `api-reference/`, `open-source/`, `platform/`, `integrations/`, `cookbooks/`, `core-concepts/`
-
-### Evaluation / Benchmarking
-
-Benchmarking lives in the external [`mem0ai/memory-benchmarks`](https://github.com/mem0ai/memory-benchmarks) repo (LOCOMO + LongMemEval + BEAM). The in-repo `evaluation/` path is a **git submodule** pinned to that repo's `main` — populate it with `git submodule update --init evaluation` (or clone mem0 with `--recurse-submodules`), or clone the benchmarks repo standalone:
-
-```bash
-git clone https://github.com/mem0ai/memory-benchmarks.git
-cd memory-benchmarks
-pip install -r requirements.txt
-
-# Run a benchmark (Mem0 Cloud; use docker compose for OSS)
-python -m benchmarks.locomo.run --project-name my-test --backend cloud --mem0-api-key $MEM0_API_KEY
-python -m benchmarks.longmemeval.run --project-name my-test --backend cloud --mem0-api-key $MEM0_API_KEY --all-questions
-python -m benchmarks.beam.run --project-name my-test --backend cloud --mem0-api-key $MEM0_API_KEY --chat-sizes 100K --conversations 0-9
-```
-
-## Core APIs
-
-### Python
-
-| Function / Class | Purpose | Import |
-|-----------------|---------|--------|
-| `Memory` | Self-hosted memory (sync) | `from mem0 import Memory` |
-| `AsyncMemory` | Self-hosted memory (async) | `from mem0 import AsyncMemory` |
-| `MemoryClient` | Hosted platform client (sync) | `from mem0 import MemoryClient` |
-| `AsyncMemoryClient` | Hosted platform client (async) | `from mem0 import AsyncMemoryClient` |
-
-**Key `Memory` / `MemoryClient` methods:**
-
-| Method | Purpose |
-|--------|---------|
-| `add(messages, *, user_id, agent_id, run_id, metadata)` | Store a new memory |
-| `search(query, *, user_id, agent_id, run_id, limit, filters)` | Search memories |
-| `get(memory_id)` | Retrieve a single memory by ID |
-| `get_all(*, user_id, agent_id, run_id, limit)` | List all memories |
-| `update(memory_id, data)` | Update a memory |
-| `delete(memory_id)` | Delete a memory |
-| `delete_all(*, user_id, agent_id, run_id)` | Delete all memories |
-| `history(memory_id)` | Get change history for a memory |
-
-### TypeScript
-
-| Export | Purpose | Import |
-|--------|---------|--------|
-| `MemoryClient` | Hosted platform client | `import { MemoryClient } from 'mem0ai'` |
-| `Memory` | Self-hosted OSS memory | `import { Memory } from 'mem0ai/oss'` |
-
-## Import Patterns
-
-### Python
-
-| What | Import |
-|------|--------|
-| Core memory classes | `from mem0 import Memory, AsyncMemory` |
-| Platform client | `from mem0 import MemoryClient, AsyncMemoryClient` |
-| Configuration | `from mem0.configs.base import MemoryConfig` |
-| LLM providers | `from mem0.llms.<provider> import <ProviderLLM>` |
-| Embedding providers | `from mem0.embeddings.<provider> import <ProviderEmbedding>` |
-| Vector store providers | `from mem0.vector_stores.<provider> import <ProviderVectorStore>` |
-
-### TypeScript
-
-| What | Import |
-|------|--------|
-| Hosted client | `import { MemoryClient } from 'mem0ai'` |
-| OSS memory | `import { Memory } from 'mem0ai/oss'` |
-| Specific providers (OSS) | `import { OpenAIEmbedding } from 'mem0ai/oss'` |
-
-## Coding Standards
-
-### File Naming Conventions
-
-- **Python source files:** `snake_case.py` (e.g., `azure_openai.py`, `cohere_reranker.py`)
-- **Python test files:** `test_<module>.py` (e.g., `test_memory.py`, `test_main.py`)
-- **TypeScript source files:** `snake_case.ts` (e.g., `azure_ai_search.ts`)
-- **TypeScript test files:** `<module>.test.ts` (e.g., `memory.test.ts`)
-- **Config/manifest files:** `kebab-case` (e.g., `openclaw.plugin.json`, `jest.config.js`)
-
-### Python Conventions
-
-- **Provider pattern:** All providers (LLMs, embeddings, vector stores, graphs, rerankers) inherit from a `base.py` abstract class in their directory. Config classes live in `configs.py`.
-- **Pydantic v2** for all data models and configuration.
-- **Ruff** is the single linting and formatting tool — no black, no flake8.
-  - Root SDK: line length **120**
-  - Python CLI: line length **100** with extended rule set (UP, B, SIM, RUF)
-- **isort** with `profile = "black"` for import sorting.
-- Ruff excludes `openmemory/` from root config.
-
-### TypeScript Conventions
-
-- **Build:** tsup across all packages.
-- **Package manager:** pnpm everywhere (no npm, no yarn).
-- **TypeScript strict mode** across all packages.
-- **Linting varies by package:**
-
-| Package | Linter | Formatter | Test Framework |
-|---------|--------|-----------|---------------|
-| `mem0-ts/` | — | Prettier | jest |
-| `cli/node/` | Biome | Biome | vitest |
-| `integrations/vercel-ai-sdk/` | ESLint | Prettier | jest + vitest |
-| `integrations/openclaw/` | — | — | vitest |
-
-### Type Checking
-
-Always run type checking after modifying TypeScript code:
-
-```bash
-cd <package> && pnpm run typecheck    # or: tsc --noEmit
-```
-
-## Architecture
-
-### Provider Pattern
-
-The SDK uses a consistent plugin architecture across 5 categories. Each category has a `base.py` abstract class and concrete provider implementations:
-
-| Category | Count | Examples |
-|----------|-------|---------|
-| **LLMs** | 24 | OpenAI, Anthropic, AWS Bedrock, Azure OpenAI, Gemini, Groq, Ollama, Together, DeepSeek, vLLM, LiteLLM, LM Studio, xAI |
-| **Vector Stores** | 30 | Qdrant, Pinecone, Chroma, Weaviate, Milvus, MongoDB, Redis, Elasticsearch, pgvector, Supabase, Faiss, S3 Vectors |
-| **Embeddings** | 15 | OpenAI, Azure OpenAI, Gemini, HuggingFace, FastEmbed, Together, AWS Bedrock, Ollama, Vertex AI |
-| **Graph Stores** | 4 | Neo4j, Memgraph, Kuzu, Apache AGE |
-| **Rerankers** | 5 | Cohere, HuggingFace, LLM-based, Sentence Transformer, Zero Entropy |
-
-### Two Usage Modes
-
-Self-hosted `Memory` / `AsyncMemory` classes and hosted-platform `MemoryClient` — both in Python and TypeScript.
-
-### Graph Memory
-
-Optional layer on top of vector memory for relationship-aware retrieval. Configured via the `graph` section of `MemoryConfig`.
-
-### MCP Integration
-
-Model Context Protocol support in multiple places:
-
-- **Remote:** MCP server at `mcp.mem0.ai`
-- **Local:** MCP server in `openmemory/api/` (FastAPI-based)
-- **Plugin:** MCP tools in `integrations/mem0-plugin/` — 9 tools: `add_memory`, `search_memories`, `get_memories`, `get_memory`, `update_memory`, `delete_memory`, `delete_all_memories`, `delete_entities`, `list_entities`
-
-### Plugin & Skills System
-
-- `integrations/mem0-plugin/` provides integrations for Claude Code, Cursor, and Codex via MCP server connections and lifecycle hooks for automatic memory capture.
-- `skills/` contains structured skill definitions for AI agents, split into two categories:
-  - **Reference skills** (always-on SDK knowledge): `mem0` (Python + TS SDKs, framework integrations), `mem0-cli` (terminal workflows), `mem0-vercel-ai-sdk` (Vercel AI provider).
-  - **Pipeline skills** (run on demand): `mem0-integrate` wires Mem0 into an existing repo via a TDD pipeline; `mem0-test-integration` verifies what the integrator produced on the same branch (the two are loosely coupled via `.mem0-integration/` artifacts); `mem0-oss-to-platform` migrates an existing project from Mem0 OSS to the hosted Platform SDK (plan, then execute on approval).
-
-### Adding a New Provider
-
-To add a new LLM, embedding, vector store, or reranker provider:
-
-1. Create `mem0/<category>/<provider_name>.py`
-2. Inherit from the abstract base class in `mem0/<category>/base.py`
-3. Add configuration to `mem0/<category>/configs.py` (if the category uses one)
-4. Register the provider in `mem0/<category>/__init__.py`
-5. Add tests in `tests/<category>/<provider_name>/`
-6. Add any new dependencies to the appropriate optional group in `pyproject.toml` (never to core `dependencies`)
-7. Follow the exact pattern of existing providers in the same category — match method signatures, error handling, and config structure
-
-### Adding a New Integration
-
-Agent/editor integrations live under `integrations/`. Each is a self-contained directory (its own `package.json`/lockfile, build, and tests). To add one:
-
-1. Create `integrations/<name>/` and build the integration there.
-2. If it publishes to a registry, set `repository.directory: "integrations/<name>"` in its `package.json` so npm provenance links to the correct subdirectory.
-3. Add CI/CD under `.github/workflows/` (`<name>-checks.yml`, `<name>-cd.yml`). Use `integrations/<name>` in `paths:` triggers, `working-directory`, and `cache-dependency-path`. Register the release tag prefix in the `case` block in `release.yml` (keep the bare `v*` arm last). Keep workflow **filenames** stable — npm OIDC trusted publishing is pinned to repo + workflow filename.
-4. If it is a Claude Code / editor marketplace plugin, register its path in the five `marketplace.json` files (root + `.claude-plugin/`, `.cursor-plugin/`, `.codex-plugin/`, `.agents/plugins/`).
-5. Document it under `docs/integrations/` and add the page to `docs/docs.json` and `docs/llms.txt`.
-6. Add rows to the "Key Directories" table and the CI/CD tables in this file.
-
-## CI/CD
-
-### CI Workflows (automated testing)
-
-PR testing is orchestrated by a single entry point: **`ci-gate.yml` (CI Gate)** runs on every PR, detects which packages changed, and invokes only the relevant package workflows below as reusable workflows (`workflow_call`). Its final **`CI Gate`** job aggregates the results (skipped pipelines pass; failed or cancelled ones fail) and is the **only status check that needs to be required** in branch protection. Package workflows keep their own push-to-main and manual triggers; their `pull_request` triggers moved into the gate's path filters.
-
-| Workflow | File | Standalone Triggers | Tests |
-|----------|------|---------------------|-------|
-| CI Gate | `ci-gate.yml` | All PRs | Routes to and aggregates the workflows below |
-| Python SDK | `ci.yml` | Push to main | Ruff lint + pytest on Python 3.10, 3.11, 3.12 |
-| TypeScript SDK | `ts-sdk-ci.yml` | Push to main (on `mem0-ts/`) | Prettier + build + jest on Node 20, 22 |
-| Python CLI | `cli-python-ci.yml` | Push to main (on `cli/python/`), manual | Ruff lint + pytest + hatch build on Python 3.10, 3.11, 3.12 |
-| Node CLI | `cli-node-ci.yml` | Push to main (on `cli/node/`), manual | Biome lint + tsc + vitest + tsup build on Node 20, 22 |
-| OpenClaw | `openclaw-checks.yml` | Push to main (on `integrations/openclaw/`), manual | tsc + vitest (with Codecov) + tsup build on Node 20, 22 |
-| OpenCode Plugin | `opencode-plugin-checks.yml` | Push to main (on `integrations/mem0-plugin/.opencode-plugin/`), manual | Bun: tsc type-check + build + dist artifact check |
-| Pi Agent Plugin | `pi-agent-plugin-checks.yml` | Push to main (on `integrations/pi-agent-plugin/`), manual | tsc + vitest + tsup build (dist artifact check) on Node 20, 22 |
-| docs llms.txt | `docs-llms-txt-check.yml` | Manual | `docs/llms.txt` coverage check |
-
-When adding a new package CI workflow: give it `workflow_call` (plus `push`/`workflow_dispatch` as needed, but no `pull_request` trigger), then register it in `ci-gate.yml` — a path filter under the `changes` job, a call job, and an entry in the gate job's `needs` list.
-
-### CD Workflows (automated publishing)
-
-Publishing is routed through a single entry point: **`release.yml` (Release Router)** is the only workflow that listens to `release: published` events. It matches the release tag prefix and dispatches the corresponding package workflow via `workflow_dispatch`, so each release produces exactly one routed run (no skipped runs from the other pipelines).
-
-| Workflow | File | Tag Prefix | Target |
-|----------|------|------------|--------|
-| Release Router | `release.yml` | (all releases) | dispatches the matching workflow below |
-| Python SDK | `cd.yml` | `v*` | PyPI (`mem0ai`) |
-| TypeScript SDK | `ts-sdk-cd.yml` | `ts-v*` | npm (`mem0ai`) |
-| Python CLI | `cli-python-cd.yml` | `cli-v*` | PyPI (`mem0-cli`) |
-| Node CLI | `cli-node-cd.yml` | `cli-node-v*` | npm (`@mem0/cli`) |
-| Vercel AI SDK | `vercel-ai-cd.yml` | `vercel-ai-v*` | npm (`@mem0/vercel-ai-provider`) |
-| OpenClaw | `openclaw-cd.yml` | `openclaw-v*` | npm (`@mem0/openclaw-mem0`) |
-| OpenCode Plugin | `opencode-plugin-cd.yml` | `opencode-v*` | npm (`@mem0/opencode-plugin`) |
-| Pi Agent Plugin | `pi-agent-plugin-cd.yml` | `pi-agent-v*` | npm (`@mem0/pi-agent-plugin`) |
-
-- Package CD workflows are `workflow_dispatch`-only (inputs: `tag`, `prerelease`); they check out and build the given tag. Registry trusted-publisher settings stay pinned to each package's own workflow filename.
-- All publishing uses **OIDC trusted publishing** — no tokens or secrets required.
-- First publish of a new npm package must be done manually; OIDC works for subsequent versions.
-- To re-publish a release (e.g. after a registry settings fix), do **not** delete/recreate the GitHub release — manually dispatch the package workflow instead: `gh workflow run <package>-cd.yml --ref refs/tags/<tag> -f tag=<tag>`.
-- When adding a new package: add its CD workflow (`workflow_dispatch` with `tag`/`prerelease` inputs), then register its tag prefix in the `case` block in `release.yml`. Keep the bare `v*` arm last.
-
-### Utility Workflows
-
-| Workflow | File | Purpose |
-|----------|------|---------|
-| Issue Labeler | `issue-labeler.yml` | Automatic issue labeling |
-| Stale Bot | `stale.yml` | Marks stale issues and PRs |
-| llms.txt Check | `docs-llms-txt-check.yml` | Blocks PRs touching `docs/**/*.mdx` when `docs/llms.txt` is out of sync. Fix locally with `python scripts/check-llms-txt-coverage.py --write`. |
-
-## Task Completion Guidelines
-
-These guidelines outline typical artifacts for different task types. Use judgment to adapt based on scope and context.
-
-### Bug Fixes
-
-1. **Unit tests**: Add tests that would fail without the fix (regression tests)
-2. **Implementation**: Fix the bug
-3. **Manual verification**: Run the relevant test suite to confirm the fix
-4. **Lint**: Run the appropriate linter for the package you modified
-
-### New Features
-
-1. **Implementation**: Build the feature following existing patterns
-2. **Unit tests**: Comprehensive test coverage for new functionality
-3. **Documentation**: Update relevant docs in `docs/` for public APIs
-4. **Examples**: Add usage examples if the feature introduces new user-facing behavior
-5. **llms.txt**: Any new `.mdx` page under `docs/` must be linked in `docs/llms.txt` with a scope tag (`[Platform]` / `[OSS]` / `[Both]`) and a `Use when ...` description. The `docs-llms-txt-check.yml` workflow runs on every PR that touches docs and **fails the check** if the index is out of sync. To fix: run `python scripts/check-llms-txt-coverage.py --write` locally to scaffold placeholders under `## Unclassified - needs triage`, then replace the `[TODO: ...]` tags, rewrite descriptions as `Use when ...`, move entries into the right section, and delete the triage heading when empty.
-
-### New Provider (LLM / Embedding / Vector Store / Reranker)
-
-1. **Implementation**: Follow the "Adding a New Provider" steps above
-2. **Tests**: Add unit tests matching the pattern of existing providers
-3. **Configuration**: Add to the appropriate `configs.py` and `__init__.py`
-4. **Dependencies**: Add to the correct optional group in `pyproject.toml`
-5. **Documentation**: Add an integration guide in `docs/integrations/`
-
-### Refactoring / Internal Changes
-
-- Unit tests for any changed behavior
-- No documentation needed for internal-only changes
-- Ensure all existing tests still pass
-
-### When to Deviate
-
-These are guidelines, not rigid rules. Adjust based on:
-
-- **Scope**: Trivial fixes (typos, comments) may not need tests
-- **Visibility**: Internal changes may not need documentation
-- **Context**: Some changes span multiple categories — use judgment
-
-When uncertain about expected artifacts, ask for clarification.
-
-## Contributing Guidelines
-
-### Workflow
-
-1. Fork and clone the repository.
-2. Create a feature branch from `main` (e.g., `feature/my-new-feature`).
-3. Make your changes — add tests, docs, and examples as appropriate.
-4. Run linting and tests for every package you modified (see commands above).
-5. Run `pre-commit install` on first setup — hooks run ruff + isort automatically.
-6. Commit with a clear message following [Conventional Commits](https://www.conventionalcommits.org/) (e.g., `feat:`, `fix:`, `docs:`, `refactor:`).
-7. Push and open a Pull Request against `main`.
-
-### Pull Request Requirements
-
-Every PR must follow the repo's PR template (`.github/PULL_REQUEST_TEMPLATE.md`):
-
-1. **Linked Issue** — Reference the issue with `Closes #<number>`. If no issue exists, create one first or explain why in the description.
-2. **Description** — Explain what the PR does and why it's needed.
-3. **Type of Change** — Check the appropriate box:
-   - Bug fix / New feature / Breaking change / Refactor / Documentation update
-4. **Breaking Changes** — If applicable, describe what breaks and the migration path.
-5. **Test Coverage** — Check what applies:
-   - Added/updated unit tests
-   - Added/updated integration tests
-   - Tested manually (describe how)
-   - No tests needed (explain why)
-6. **Checklist** — All must be checked before merge:
-   - [ ] Code follows the project's style guidelines
-   - [ ] Self-review performed
-   - [ ] Tests added that prove the fix/feature works
-   - [ ] New and existing tests pass locally
-   - [ ] Documentation updated if needed
-
-### PR Description Template
-
-```markdown
-## Linked Issue
-
-Closes #<!-- issue number -->
-
-## Description
-
-<!-- What does this PR do? Why is it needed? -->
-
-## Type of Change
-
-- [ ] Bug fix (non-breaking change that fixes an issue)
-- [ ] New feature (non-breaking change that adds functionality)
-- [ ] Breaking change (fix or feature that would cause existing functionality to change)
-- [ ] Refactor (no functional changes)
-- [ ] Documentation update
-
-## Breaking Changes
-
-N/A
-
-## Test Coverage
-
-- [ ] I added/updated unit tests
-- [ ] I added/updated integration tests
-- [ ] I tested manually (describe below)
-- [ ] No tests needed (explain why)
-
-## Checklist
-
-- [ ] My code follows the project's style guidelines
-- [ ] I have performed a self-review of my code
-- [ ] I have added tests that prove my fix/feature works
-- [ ] New and existing tests pass locally
-- [ ] I have updated documentation if needed
-```
-
-### General Rules
-
-- Follow existing code patterns — don't introduce new frameworks or abstractions without discussion.
-- Version bumps go in `pyproject.toml` (Python) or `package.json` (TypeScript).
-- For `server/` and `openmemory/` work, use Docker Compose for local development.
-- Do NOT use `pip` or `conda` for dependency management — use `hatch` (see `docs/contributing/development.mdx`).
-
-### Contributing Guides
-
-| Task | Guide |
-|------|-------|
-| Code contributions | `docs/contributing/development.mdx` |
-| Documentation contributions | `docs/contributing/documentation.mdx` |
-| PR template | `.github/PULL_REQUEST_TEMPLATE.md` |
-| Bug reports | `.github/ISSUE_TEMPLATE/bug_report.yml` |
-| Feature requests | `.github/ISSUE_TEMPLATE/feature_request.yml` |
-| Documentation issues | `.github/ISSUE_TEMPLATE/documentation_issue.yml` |
-
-## Do NOT
-
-- Modify CI/CD workflows without explicit approval.
-- Add new Python dependencies to the core `dependencies` list in `pyproject.toml` without discussion — use optional dependency groups instead.
-- Commit `.env` files, API keys, or credentials.
-- Skip pre-commit hooks.
-- Use npm or yarn in TypeScript packages — this repo uses pnpm exclusively.
-- Use `require()` for imports in TypeScript — use ES module `import` syntax.
-- Mix up linter configs: root Python SDK uses line-length 120, Python CLI uses 100, Node CLI uses Biome (not ESLint/Ruff).
-- Modify `openmemory/` database migrations without understanding the Alembic migration chain.
-- Change public APIs without updating documentation in `docs/`.

CLAUDE.md

@@ -1 +0,0 @@
-AGENTS.md

LLM.md

@@ -266,7 +266,7 @@ config = MemoryConfig(
     graph_store=GraphStoreConfig(provider="neo4j", config={...}),  # optional
     history_db_path="~/.mem0/history.db",
     version="v1.1",
-    custom_instructions="Custom prompt...",
+    custom_fact_extraction_prompt="Custom prompt...",
     custom_update_memory_prompt="Custom prompt..."
 )
 ```
@@ -684,7 +684,7 @@ Conversation: {messages}
 """
 
 config = MemoryConfig(
-    custom_instructions=custom_extraction_prompt
+    custom_fact_extraction_prompt=custom_extraction_prompt
 )
 memory = Memory(config)
 ```
@@ -1026,8 +1026,7 @@ def get_user_preferences(user_id: str):
 ### AutoGen Integration
 
 ```python
-# Mem0Teachability lives in examples/notebooks/helper/ — see examples/notebooks/mem0-autogen.ipynb
-from helper.mem0_teachability import Mem0Teachability
+from cookbooks.helper.mem0_teachability import Mem0Teachability
 from mem0 import Memory
 
 # Add memory capability to AutoGen agents
@@ -1314,7 +1313,7 @@ async def delete_memory(memory_id: str):
 - **Documentation**: https://docs.mem0.ai
 - **GitHub Repository**: https://github.com/mem0ai/mem0
 - **Discord Community**: https://mem0.dev/DiG
-- **Platform**: https://app.mem0.ai?utm_source=oss&utm_medium=llm
+- **Platform**: https://app.mem0.ai
 - **Research Paper**: https://mem0.ai/research
 - **Examples**: https://github.com/mem0ai/mem0/tree/main/examples
 

MIGRATION_GUIDE_v1.0.md

@@ -0,0 +1,221 @@
+# Migration Guide: Upgrading to mem0 1.0.0
+
+## TL;DR
+
+**What changed?** We simplified the API by removing confusing version parameters. Now everything returns a consistent format: `{"results": [...]}`.
+
+**What you need to do:**
+1. Upgrade: `pip install mem0ai==1.0.0`
+2. Remove `version` and `output_format` parameters from your code
+3. Update response handling to use `result["results"]` instead of treating responses as lists
+
+**Time needed:** ~5-10 minutes for most projects
+
+---
+
+## Quick Migration Guide
+
+### 1. Install the Update
+
+```bash
+pip install mem0ai==1.0.0
+```
+
+### 2. Update Your Code
+
+**If you're using the Memory API:**
+
+```python
+# Before
+memory = Memory(config=MemoryConfig(version="v1.1"))
+result = memory.add("I like pizza")
+
+# After
+memory = Memory()  # That's it - version is automatic now
+result = memory.add("I like pizza")
+```
+
+**If you're using the Client API:**
+
+```python
+# Before
+client.add(messages, output_format="v1.1")
+client.search(query, version="v2", output_format="v1.1")
+
+# After
+client.add(messages)  # Just remove those extra parameters
+client.search(query)
+```
+
+### 3. Update How You Handle Responses
+
+All responses now use the same format: a dictionary with `"results"` key.
+
+```python
+# Before - you might have done this
+result = memory.add("I like pizza")
+for item in result:  # Treating it as a list
+    print(item)
+
+# After - do this instead
+result = memory.add("I like pizza")
+for item in result["results"]:  # Access the results key
+    print(item)
+
+# Graph relations (if you use them)
+if "relations" in result:
+    for relation in result["relations"]:
+        print(relation)
+```
+
+---
+
+## Enhanced Message Handling
+
+The platform client (MemoryClient) now supports the same flexible message formats as the OSS version:
+
+```python
+from mem0 import MemoryClient
+
+client = MemoryClient(api_key="your-key")
+
+# All three formats now work:
+
+# 1. Single string (automatically converted to user message)
+client.add("I like pizza", user_id="alice")
+
+# 2. Single message dictionary
+client.add({"role": "user", "content": "I like pizza"}, user_id="alice")
+
+# 3. List of messages (conversation)
+client.add([
+    {"role": "user", "content": "I like pizza"},
+    {"role": "assistant", "content": "I'll remember that!"}
+], user_id="alice")
+```
+
+### Async Mode Configuration
+
+The `async_mode` parameter now defaults to `True` but can be configured:
+
+```python
+# Default behavior (async_mode=True)
+client.add(messages, user_id="alice")
+
+# Explicitly set async mode
+client.add(messages, user_id="alice", async_mode=True)
+
+# Disable async mode if needed
+client.add(messages, user_id="alice", async_mode=False)
+```
+
+**Note:** `async_mode=True` provides better performance for most use cases. Only set it to `False` if you have specific synchronous processing requirements.
+
+---
+
+## That's It!
+
+For most users, that's all you need to know. The changes are:
+- ✅ No more `version` or `output_format` parameters
+- ✅ Consistent `{"results": [...]}` response format
+- ✅ Cleaner, simpler API
+
+---
+
+## Common Issues
+
+**Getting `KeyError: 'results'`?**
+
+Your code is still treating the response as a list. Update it:
+```python
+# Change this:
+for memory in response:
+
+# To this:
+for memory in response["results"]:
+```
+
+**Getting `TypeError: unexpected keyword argument`?**
+
+You're still passing old parameters. Remove them:
+```python
+# Change this:
+client.add(messages, output_format="v1.1")
+
+# To this:
+client.add(messages)
+```
+
+**Seeing deprecation warnings?**
+
+Remove any explicit `version="v1.0"` from your config:
+```python
+# Change this:
+memory = Memory(config=MemoryConfig(version="v1.0"))
+
+# To this:
+memory = Memory()
+```
+
+---
+
+## What's New in 1.0.0
+
+- **Better vector stores:** Fixed OpenSearch and improved reliability across all stores
+- **Cleaner API:** One way to do things, no more confusing options
+- **Enhanced GCP support:** Better Vertex AI configuration options
+- **Flexible message input:** Platform client now accepts strings, dicts, and lists (aligned with OSS)
+- **Configurable async_mode:** Now defaults to `True` but users can override if needed
+
+---
+
+## Need Help?
+
+- Check [GitHub Issues](https://github.com/mem0ai/mem0/issues)
+- Read the [documentation](https://docs.mem0.ai/)
+- Open a new issue if you're stuck
+
+---
+
+## Advanced: Configuration Changes
+
+**If you configured vector stores with version:**
+
+```python
+# Before
+config = MemoryConfig(
+    version="v1.1",
+    vector_store=VectorStoreConfig(...)
+)
+
+# After
+config = MemoryConfig(
+    vector_store=VectorStoreConfig(...)
+)
+```
+
+---
+
+## Testing Your Migration
+
+Quick sanity check:
+
+```python
+from mem0 import Memory
+
+memory = Memory()
+
+# Add should return a dict with "results"
+result = memory.add("I like pizza", user_id="test")
+assert "results" in result
+
+# Search should return a dict with "results"
+search = memory.search("food", user_id="test")
+assert "results" in search
+
+# Get all should return a dict with "results"
+all_memories = memory.get_all(user_id="test")
+assert "results" in all_memories
+
+print("✅ Migration successful!")
+```

Makefile

@@ -42,6 +42,9 @@ clean:
 test:
 	hatch run test
 
+test-py-3.9:
+	hatch run dev_py_3_9:test
+
 test-py-3.10:
 	hatch run dev_py_3_10:test
 

README.md

@@ -39,33 +39,18 @@
 </p>
 
 <p align="center">
-  <a href="https://mem0.ai/research"><strong>📄 Benchmarking Mem0's token-efficient memory algorithm →</strong></a>
+  <a href="https://mem0.ai/research"><strong>📄 Building Production-Ready AI Agents with Scalable Long-Term Memory →</strong></a>
+</p>
+<p align="center">
+  <strong>⚡ +26% Accuracy vs. OpenAI Memory • 🚀 91% Faster • 💰 90% Fewer Tokens</strong>
 </p>
 
-## New Memory Algorithm (April 2026)
+> **🎉 mem0ai v1.0.0 is now available!** This major release includes API modernization, improved vector store support, and enhanced GCP integration. [See migration guide →](MIGRATION_GUIDE_v1.0.md)
 
-| Benchmark | Old | New  | Tokens  | Latency p50  |
-| --- | --- | --- | --- | --- |
-| **LoCoMo** | 71.4 | **91.6** | 7.0K  | 0.88s  |
-| **LongMemEval** | 67.8 | **94.8** | 6.8K  | 1.09s  |
-| **BEAM (1M)** | — | **64.1** | 6.7K  | 1.00s  |
-| **BEAM (10M)** | — | **48.6** | 6.9K  | 1.05s  |
-
-All benchmarks run on the same production-representative model stack. Single-pass retrieval (one call, no agentic loops).
-
-**What changed:**
-- **Single-pass ADD-only extraction** -- one LLM call, no UPDATE/DELETE. Memories accumulate; nothing is overwritten.
-- **Agent-generated facts are first-class** -- when an agent confirms an action, that information is now stored with equal weight.
-- **Entity linking** -- entities are extracted, embedded, and linked across memories for retrieval boosting.
-- **Multi-signal retrieval** -- semantic, BM25 keyword, and entity matching scored in parallel and fused.
-- **Temporal Reasoning** -- time-aware retrieval that ranks the right dated instance for queries about current state, past events, and upcoming plans.
-
-See the [migration guide](https://docs.mem0.ai/migration/oss-v2-to-v3) for upgrade instructions. The [evaluation framework](https://github.com/mem0ai/memory-benchmarks) is open-sourced so anyone can reproduce the numbers.
-
-## Research Highlights
-- **91.6 on LoCoMo** -- +20 points over the previous algorithm
-- **94.8 on LongMemEval** -- +27 points, with +53.6 on assistant memory recall
-- **64.1 on BEAM (1M)** -- production-scale memory evaluation at 1M tokens
+##  🔥 Research Highlights
+- **+26% Accuracy** over OpenAI Memory on the LOCOMO benchmark
+- **91% Faster Responses** than full-context, ensuring low-latency at scale
+- **90% Lower Token Usage** than full-context, cutting costs without compromise
 - [Read the full paper](https://mem0.ai/research)
 
 # Introduction
@@ -86,75 +71,28 @@ See the [migration guide](https://docs.mem0.ai/migration/oss-v2-to-v3) for upgra
 
 ## 🚀 Quickstart Guide <a name="quickstart"></a>
 
-### Sign up as an agent
+Choose between our hosted platform or self-hosted package:
 
-AI agents can mint a working Mem0 API key in under five seconds — no email, no dashboard, no OTP. Four commands end-to-end:
+### Hosted Platform
 
-```bash
-# 1. Install
-npm install -g @mem0/cli      # or: pip install mem0-cli
+Get up and running in minutes with automatic updates, analytics, and enterprise security.
 
-# 2. Sign up as an agent (replace `claude-code` with your name)
-mem0 init --agent --agent-caller claude-code
+1. Sign up on [Mem0 Platform](https://app.mem0.ai)
+2. Embed the memory layer via SDK or API keys
 
-# 3. Add a memory
-mem0 add "I am using mem0"
+### Self-Hosted (Open Source)
 
-# 4. Search
-mem0 search "am I using mem0"
-```
-
-The human owner can claim the account later with `mem0 init --email <their-email>` — same key, memories preserved. Full guide: [Sign up as an agent](https://docs.mem0.ai/platform/agent-signup).
-
-| | Library | Self-Hosted Server | Cloud Platform |
-|---|---------|-------------------|----------------|
-| **Best for** | Testing, prototyping | Teams running on their own infrastructure | Zero-ops production use |
-| **Setup** | `pip install mem0ai` | `docker compose up` | Sign up at [app.mem0.ai](https://app.mem0.ai?utm_source=oss&utm_medium=readme) |
-| **Dashboard** | -- | [Yes](https://docs.mem0.ai/open-source/setup) | Yes |
-| **Auth & API Keys** | -- | Yes | Yes |
-| **Advanced Features** | -- | Teasers | All included |
-
-Just testing? Use the library. Building for a team? Self-hosted. Want zero ops? Cloud.
-
-### Library (pip / npm)
+Install the sdk via pip:
 
 ```bash
 pip install mem0ai
 ```
 
-For enhanced hybrid search with BM25 keyword matching and entity extraction, install with NLP support:
-
-```bash
-pip install mem0ai[nlp]
-python -m spacy download en_core_web_sm
-```
-
 Install sdk via npm:
-
 ```bash
 npm install mem0ai
 ```
 
-### Self-Hosted Server
-
-> **Note:** Self-hosted auth is on by default. Upgrading from a pre-auth build? Set `ADMIN_API_KEY`, register an admin through the wizard, or `AUTH_DISABLED=true` for local dev only. See [upgrade notes](https://docs.mem0.ai/open-source/setup#upgrade-notes).
-
-```bash
-# Recommended: one command — start the stack, create an admin, issue the first API key.
-cd server && make bootstrap
-
-# Manual: start the stack and finish setup via the browser wizard.
-cd server && docker compose up -d    # http://localhost:3000
-```
-
-See the [self-hosted docs](https://docs.mem0.ai/open-source/overview) for configuration.
-
-### Cloud Platform
-
-1. Sign up on [Mem0 Platform](https://app.mem0.ai?utm_source=oss&utm_medium=readme)
-2. Embed the memory layer via SDK or API keys
-3. Using hosted Qdrant vectors? See the [Platform migration guide](https://docs.mem0.ai/migration/oss-to-platform) to import them into Mem0 Platform.
-
 ### CLI
 
 Manage memories from your terminal:
@@ -169,33 +107,9 @@ mem0 search "What does Alice prefer?" --user-id alice
 
 See the [CLI documentation](https://docs.mem0.ai/platform/cli) for the full command reference.
 
-### Agent Skills
-
-Teach your AI coding assistant (Claude Code, Codex, Cursor, Windsurf, OpenCode, OpenClaw, and any tool that supports the skills standard) how to build with Mem0. Two categories:
-
-**Reference skills — always on** (SDK knowledge loaded into the assistant's context):
-
-```bash
-npx skills add https://github.com/mem0ai/mem0 --skill mem0
-npx skills add https://github.com/mem0ai/mem0 --skill mem0-cli
-npx skills add https://github.com/mem0ai/mem0 --skill mem0-vercel-ai-sdk
-```
-
-**Pipeline skills — run on demand** (execute an end-to-end workflow in an existing repo):
-
-```bash
-npx skills add https://github.com/mem0ai/mem0 --skill mem0-integrate
-npx skills add https://github.com/mem0ai/mem0 --skill mem0-test-integration
-npx skills add https://github.com/mem0ai/mem0 --skill mem0-oss-to-platform
-```
-
-Use `/mem0-integrate` to wire Mem0 into an existing repo via a test-first pipeline, then `/mem0-test-integration` to verify. Use `/mem0-oss-to-platform` to migrate an existing project from Mem0 OSS to the hosted Platform SDK. See the [skills catalog](./skills/) or [Vibecoding with Mem0](https://docs.mem0.ai/vibecoding) for the full picture.
-
 ### Basic Usage
 
-Mem0 requires an LLM to function, with `gpt-5-mini` from OpenAI as the default. However, it supports a variety of LLMs; for details, refer to our [Supported LLMs documentation](https://docs.mem0.ai/components/llms/overview).
-
-Mem0 uses `text-embedding-3-small` from OpenAI as the default embedding model. For best results with hybrid search (semantic + keyword + entity boosting), we recommend using at least [Qwen 600M](https://huggingface.co/Alibaba-NLP/gte-Qwen2-1.5B-instruct) or a comparable embedding model. See [Supported Embeddings](https://docs.mem0.ai/components/embedders/overview) for configuration details.
+Mem0 requires an LLM to function, with `gpt-4.1-nano-2025-04-14 from OpenAI as the default. However, it supports a variety of LLMs; for details, refer to our [Supported LLMs documentation](https://docs.mem0.ai/components/llms/overview).
 
 First step is to instantiate the memory:
 
@@ -208,13 +122,13 @@ memory = Memory()
 
 def chat_with_memories(message: str, user_id: str = "default_user") -> str:
     # Retrieve relevant memories
-    relevant_memories = memory.search(query=message, filters={"user_id": user_id}, top_k=3)
+    relevant_memories = memory.search(query=message, user_id=user_id, limit=3)
     memories_str = "\n".join(f"- {entry['memory']}" for entry in relevant_memories["results"])
 
     # Generate Assistant response
     system_prompt = f"You are a helpful AI. Answer the question based on query and memories.\nUser Memories:\n{memories_str}"
     messages = [{"role": "system", "content": system_prompt}, {"role": "user", "content": message}]
-    response = openai_client.chat.completions.create(model="gpt-5-mini", messages=messages)
+    response = openai_client.chat.completions.create(model="gpt-4.1-nano-2025-04-14", messages=messages)
     assistant_response = response.choices[0].message.content
 
     # Create new memories from the conversation

cli/cli-spec.json

@@ -503,7 +503,7 @@
     },
     {
       "name": "init",
-      "description": "Setup wizard for mem0 CLI. Supports Agent Mode bootstrap (--agent), email login (--email), or manual API key (--api-key).",
+      "description": "Setup wizard for mem0 CLI. Supports email login (--email) or manual API key (--api-key).",
       "usage": "mem0 init [OPTIONS]",
       "needsBackend": false,
       "needsConfig": false,
@@ -516,9 +516,7 @@
         { "name": "user-id", "flags": ["-u", "--user-id"], "type": "string", "default": null, "help": "Default user ID (skip prompt)." },
         { "name": "email", "flags": ["--email"], "type": "string", "default": null, "help": "Login via email verification code." },
         { "name": "code", "flags": ["--code"], "type": "string", "default": null, "help": "Verification code (use with --email for non-interactive login)." },
-        { "name": "force", "flags": ["--force"], "type": "boolean", "default": false, "help": "Overwrite existing config without confirmation." },
-        { "name": "agent", "flags": ["--agent"], "type": "boolean", "default": false, "help": "Bootstrap an unattended Agent Mode account (no email required)." },
-        { "name": "source", "flags": ["--source"], "type": "string", "default": null, "help": "Channel attribution for signup (e.g. github, hn, ph)." }
+        { "name": "force", "flags": ["--force"], "type": "boolean", "default": false, "help": "Overwrite existing config without confirmation." }
       ]
     },
     {

cli/node/CHANGELOG.md

@@ -1,60 +0,0 @@
-# Changelog
-
-All notable changes to `@mem0/cli` are documented here.
-
-The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
-and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
-
-## [0.2.9] — 2026-06-19
-
-### Security
-
-- Telemetry no longer passes the Mem0 API key to its child process via
-  command-line arguments. The context is now sent over stdin, so the key is no
-  longer visible in the process list (`ps`, `/proc/<pid>/cmdline`, Activity
-  Monitor). Fixes #4862.
-
-## [0.2.8] — 2026-06-01
-
-### Security
-
-- Pinned transitive dependencies via pnpm overrides to remediate high-severity CVEs:
-  - `jws` → 4.0.1 (CVE-2025-65945)
-  - `langsmith` → ^0.6.0 (CVE-2026-45134)
-  - `tar-fs` → ^2.1.4 (CVE-2025-48387, CVE-2025-59343)
-  - `picomatch` → ^2.3.2 (CVE-2026-33671)
-  - `minimatch` → ^3.1.3 / ^5.1.8 / ^9.0.7 (CVE-2026-27903, CVE-2026-27904, CVE-2026-26996)
-  - `path-to-regexp` → ^8.4.0 (CVE-2026-4926)
-  - `rollup` → ^4.59.0 (CVE-2026-27606)
-  - `glob` → ^10.5.0 (CVE-2025-64756)
-  - `@modelcontextprotocol/sdk` → ^1.25.4 (CVE-2025-66414, CVE-2026-0621)
-
-## [0.2.7] — 2026-05-20
-
-### Added
-
-- `mem0 whoami` — print the active agent's `default_user_id` (the AGENTRUSH
-  leaderboard identifier). Reads from local config, no network call.
-- `mem0 agent-rush <add | search>` — subcommand group that wraps the new
-  `/v1/agent-rush/` platform endpoints for the 7-day AGENTRUSH game. Project
-  routing is implicit (resolved server-side); no flags exposed. Pretty-prints
-  platform error codes into actionable hints (e.g. `agentrush_search_first`
-  → "Run 3 'mem0 agent-rush search' commands before adding.").
-- PII safety prompt on first `mem0 agent-rush add`. Interactive runs require
-  explicit `y` to acknowledge that AGENTRUSH memories are public; the
-  acknowledgement is persisted in `~/.mem0/config.json` under
-  `agent_rush.acknowledged_at` so the prompt only appears once per machine.
-  Non-interactive (agent) invocations surface the warning to stderr without
-  blocking.
-- New config schema field: `agent_rush.acknowledged_at` (ISO timestamp,
-  empty until first interactive acknowledgement).
-
-### Changed
-
-- HTTP requests from the new agent-rush commands send `X-Mem0-Mode: agent-rush`
-  in addition to the existing source headers, so platform telemetry can split
-  game traffic from regular CLI usage.
-
-## [0.2.6] and earlier
-
-Unlogged historical releases. See git history under `cli/node/`.

cli/node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@mem0/cli",
-  "version": "0.2.9",
+  "version": "0.2.2",
   "description": "The official CLI for mem0 — the memory layer for AI agents",
   "type": "module",
   "bin": {
@@ -40,19 +40,8 @@
     "typescript": "^5.4.0",
     "tsup": "^8.0.0",
     "tsx": "^4.7.0",
-    "vite": "^6.0.0",
-    "vitest": "^4.1.0",
+    "vitest": "^1.5.0",
     "@biomejs/biome": "^1.7.0",
     "@types/node": "^20.0.0"
-  },
-  "pnpm": {
-    "overrides": {
-      "jws@4.0.0": "4.0.1",
-      "langsmith@<0.6.0": "^0.6.0",
-      "tar-fs@>=2.0.0 <2.1.4": "^2.1.4",
-      "picomatch@<2.3.2": "^2.3.2",
-      "postcss@<8.5.10": ">=8.5.10",
-      "esbuild": ">=0.28.1"
-    }
   }
 }

cli/node/pnpm-workspace.yaml

@@ -1,14 +0,0 @@
-packages:
-  - '.'
-
-onlyBuiltDependencies:
-  - "@biomejs/biome"
-  - esbuild
-
-overrides:
-  jws@4.0.0: 4.0.1
-  langsmith@<0.6.0: ^0.6.0
-  tar-fs@>=2.0.0 <2.1.4: ^2.1.4
-  picomatch@<2.3.2: ^2.3.2
-  "postcss@<8.5.10": ">=8.5.10"
-  "esbuild": ">=0.28.1"

cli/node/src/agent-detect.ts

@@ -1,32 +0,0 @@
-/**
- * Detect whether the CLI is being invoked from inside an AI-agent context.
- *
- * Used by `mem0 init` to auto-enter Agent Mode (Rule 3 bootstrap) when an
- * agent runtime env var is present. The return value is a context **trigger
- * only** — the canonical agent identity is self-declared by the agent via
- * `--agent-caller <name>` (Proof Editor-style) and never sniffed from env
- * vars to fill the `agent_caller` field on the APIKey row.
- *
- * Returns a short name or null. Honest reporting depends on `--agent-caller`;
- * this list is just enough to enable the zero-friction auto-bootstrap UX.
- */
-
-const AGENT_CALLER_ENV: ReadonlyArray<readonly [string, readonly string[]]> = [
-	["claude-code", ["CLAUDECODE", "CLAUDE_CODE"]],
-	["cursor", ["CURSOR_AGENT", "CURSOR_SESSION_ID"]],
-	["codex", ["CODEX_CLI", "OPENAI_CODEX"]],
-	["cline", ["CLINE_AGENT", "CLINE"]],
-	["continue", ["CONTINUE_AGENT", "CONTINUE_SESSION"]],
-	["aider", ["AIDER_SESSION"]],
-	["goose", ["GOOSE_AGENT"]],
-	["windsurf", ["WINDSURF_AGENT"]],
-] as const;
-
-export function detectAgentCaller(): string | null {
-	for (const [name, envVars] of AGENT_CALLER_ENV) {
-		if (envVars.some((v) => process.env[v])) {
-			return name;
-		}
-	}
-	return null;
-}

cli/node/src/backend/base.ts

@@ -15,6 +15,7 @@ export interface AddOptions {
 	infer?: boolean;
 	expires?: string;
 	categories?: string[];
+	enableGraph?: boolean;
 }
 
 export interface SearchOptions {
@@ -28,6 +29,7 @@ export interface SearchOptions {
 	keyword?: boolean;
 	filters?: Record<string, unknown>;
 	fields?: string[];
+	enableGraph?: boolean;
 }
 
 export interface ListOptions {
@@ -40,6 +42,7 @@ export interface ListOptions {
 	category?: string;
 	after?: string;
 	before?: string;
+	enableGraph?: boolean;
 }
 
 export interface DeleteOptions {

cli/node/src/backend/platform.ts

@@ -3,7 +3,7 @@
  */
 
 import type { PlatformConfig } from "../config.js";
-import { captureNotice, isAgentMode } from "../state.js";
+import { isAgentMode } from "../state.js";
 import { CLI_VERSION } from "../version.js";
 import {
 	APIError,
@@ -90,39 +90,7 @@ export class PlatformBackend implements Backend {
 		if (resp.status === 204) {
 			return {};
 		}
-
-		const data = await resp.json();
-
-		// Pull the unclaimed-Agent-Mode notice out of the body (or the header
-		// fallback for endpoints returning non-dict / non-dict-leading payloads)
-		// and stash for end-of-command surfacing.
-		let notice: string | null = null;
-		if (
-			data &&
-			typeof data === "object" &&
-			!Array.isArray(data) &&
-			"mem0_notice" in data
-		) {
-			notice = (data as Record<string, unknown>).mem0_notice as string;
-			// biome-ignore lint/performance/noDelete: intentional strip so downstream consumers don't see duplicate notice
-			delete (data as Record<string, unknown>).mem0_notice;
-		} else if (
-			Array.isArray(data) &&
-			data.length > 0 &&
-			typeof data[0] === "object" &&
-			data[0] !== null &&
-			"mem0_notice" in data[0]
-		) {
-			notice = (data[0] as Record<string, unknown>).mem0_notice as string;
-			// biome-ignore lint/performance/noDelete: see above.
-			delete (data[0] as Record<string, unknown>).mem0_notice;
-		}
-		if (!notice) {
-			notice = resp.headers.get("X-Mem0-Notice-Message") ?? null;
-		}
-		captureNotice(notice);
-
-		return data;
+		return resp.json();
 	}
 
 	async add(
@@ -147,9 +115,9 @@ export class PlatformBackend implements Backend {
 		if (opts.infer === false) payload.infer = false;
 		if (opts.expires) payload.expiration_date = opts.expires;
 		if (opts.categories) payload.categories = opts.categories;
-		payload.source = "CLI";
+		if (opts.enableGraph) payload.enable_graph = true;
 
-		return (await this._request("POST", "/v3/memories/add/", {
+		return (await this._request("POST", "/v1/memories/", {
 			json: payload,
 		})) as Record<string, unknown>;
 	}
@@ -207,9 +175,9 @@ export class PlatformBackend implements Backend {
 		if (opts.rerank) payload.rerank = true;
 		if (opts.keyword) payload.keyword_search = true;
 		if (opts.fields) payload.fields = opts.fields;
-		payload.source = "CLI";
+		if (opts.enableGraph) payload.enable_graph = true;
 
-		const result = (await this._request("POST", "/v3/memories/search/", {
+		const result = (await this._request("POST", "/v2/memories/search/", {
 			json: payload,
 		})) as unknown;
 		if (Array.isArray(result)) return result;
@@ -218,9 +186,10 @@ export class PlatformBackend implements Backend {
 	}
 
 	async get(memoryId: string): Promise<Record<string, unknown>> {
-		return (await this._request("GET", `/v1/memories/${memoryId}/`, {
-			params: { source: "CLI" },
-		})) as Record<string, unknown>;
+		return (await this._request("GET", `/v1/memories/${memoryId}/`)) as Record<
+			string,
+			unknown
+		>;
 	}
 
 	async listMemories(
@@ -257,9 +226,9 @@ export class PlatformBackend implements Backend {
 			extraFilters: Object.keys(extra).length > 0 ? extra : undefined,
 		});
 		if (apiFilters) payload.filters = apiFilters;
-		payload.source = "CLI";
+		if (opts.enableGraph) payload.enable_graph = true;
 
-		const result = (await this._request("POST", "/v3/memories/", {
+		const result = (await this._request("POST", "/v2/memories/", {
 			json: payload,
 			params,
 		})) as unknown;
@@ -276,7 +245,6 @@ export class PlatformBackend implements Backend {
 		const payload: Record<string, unknown> = {};
 		if (content) payload.text = content;
 		if (metadata) payload.metadata = metadata;
-		payload.source = "CLI";
 		return (await this._request("PUT", `/v1/memories/${memoryId}/`, {
 			json: payload,
 		})) as Record<string, unknown>;
@@ -287,7 +255,7 @@ export class PlatformBackend implements Backend {
 		opts: DeleteOptions = {},
 	): Promise<Record<string, unknown>> {
 		if (opts.all) {
-			const params: Record<string, string> = { source: "CLI" };
+			const params: Record<string, string> = {};
 			if (opts.userId) params.user_id = opts.userId;
 			if (opts.agentId) params.agent_id = opts.agentId;
 			if (opts.appId) params.app_id = opts.appId;
@@ -297,9 +265,10 @@ export class PlatformBackend implements Backend {
 			})) as Record<string, unknown>;
 		}
 		if (memoryId) {
-			return (await this._request("DELETE", `/v1/memories/${memoryId}/`, {
-				params: { source: "CLI" },
-			})) as Record<string, unknown>;
+			return (await this._request(
+				"DELETE",
+				`/v1/memories/${memoryId}/`,
+			)) as Record<string, unknown>;
 		}
 		throw new Error("Either memoryId or --all is required");
 	}
@@ -322,7 +291,6 @@ export class PlatformBackend implements Backend {
 			result = (await this._request(
 				"DELETE",
 				`/v2/entities/${entityType}/${entityId}/`,
-				{ params: { source: "CLI" } },
 			)) as Record<string, unknown>;
 		}
 		return result;

cli/node/src/branding.ts

@@ -96,7 +96,7 @@ export function printError(message: string, hint?: string): void {
 	const resolvedHint =
 		hint ??
 		(message.includes("Authentication failed")
-			? `Run ${brand("mem0 init")} to reconfigure your API key · https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-node`
+			? `Run ${brand("mem0 init")} to reconfigure your API key · https://app.mem0.ai/dashboard/api-keys`
 			: undefined);
 	if (resolvedHint) {
 		console.error(`  ${dim(resolvedHint)}`);

cli/node/src/commands/agent-mode.ts

@@ -1,285 +0,0 @@
-/**
- * Agent Mode commands — bootstrap (unattended signup) and OTP-based claim.
- */
-
-import readline from "node:readline";
-import { colors, printError, printInfo, printSuccess } from "../branding.js";
-import { type Mem0Config, saveConfig } from "../config.js";
-
-const { brand, dim } = colors;
-
-const SOURCE_HEADERS = {
-	"X-Mem0-Source": "cli",
-	"X-Mem0-Client-Language": "node",
-} as const;
-
-export interface BootstrapEnvelope {
-	api_key: string;
-	default_user_id: string;
-	org_id: string;
-	project_id: string;
-	mcp_url?: string;
-	smoke_test_url?: string;
-	claim_command?: string;
-	mem0_notice?: string;
-}
-
-function isValidEnvelope(v: unknown): v is BootstrapEnvelope {
-	return (
-		!!v &&
-		typeof v === "object" &&
-		typeof (v as BootstrapEnvelope).api_key === "string" &&
-		(v as BootstrapEnvelope).api_key.length > 0 &&
-		typeof (v as BootstrapEnvelope).default_user_id === "string" &&
-		(v as BootstrapEnvelope).default_user_id.length > 0
-	);
-}
-
-/**
- * POST /api/v1/auth/agent_mode/ and mutate config in place.
- *
- * @param config - Mem0Config mutated in place with the new platform values.
- * @param source - `--source` flag passthrough (analytics tag, free-form).
- * @param agentCaller - Self-declared agent identity passed via `--agent-caller`
- *   (e.g. `claude-code`, `cursor`). May be null when the caller omitted the
- *   flag; the agent can backfill later via `mem0 identify <name>`. Sent to the
- *   backend in the request body and saved into `platform.agentCaller` for
- *   local introspection.
- */
-export async function bootstrapViaBackend(
-	config: Mem0Config,
-	{
-		source,
-		agentCaller,
-	}: { source?: string | null; agentCaller?: string | null } = {},
-): Promise<void> {
-	const baseUrl = (config.platform.baseUrl || "https://api.mem0.ai").replace(
-		/\/+$/,
-		"",
-	);
-	const body: Record<string, unknown> = {};
-	if (source) body.source = source;
-	if (agentCaller) body.agent_caller = agentCaller;
-
-	let resp: Response;
-	try {
-		resp = await fetch(`${baseUrl}/api/v1/auth/agent_mode/`, {
-			method: "POST",
-			headers: {
-				...SOURCE_HEADERS,
-				"Content-Type": "application/json",
-			},
-			body: JSON.stringify(body),
-			signal: AbortSignal.timeout(30_000),
-		});
-	} catch (err) {
-		printError(
-			`Network error contacting Mem0: ${err instanceof Error ? err.message : String(err)}`,
-		);
-		process.exit(1);
-	}
-
-	if (resp.status === 429) {
-		printError("Rate-limited. Try again in a few minutes.");
-		process.exit(1);
-	}
-	if (resp.status === 503) {
-		printError("Agent Mode is temporarily disabled. Try again later.");
-		process.exit(1);
-	}
-	if (!resp.ok) {
-		let detail: string = resp.statusText;
-		try {
-			const errBody = (await resp.json()) as {
-				error?: string;
-				detail?: string;
-			};
-			detail = errBody.error ?? errBody.detail ?? resp.statusText;
-		} catch {
-			/* leave detail as statusText */
-		}
-		// Backend's @ratelimit decorator raises PermissionDenied, which DRF
-		// translates to a generic 403 "You do not have permission to perform
-		// this action." That's opaque — surface it as the rate-limit message
-		// it actually is.
-		if (resp.status === 403 && /permission/i.test(detail)) {
-			printError(
-				"Daily Agent Mode signup limit reached for this network (5/day). Try again from a different IP or after midnight UTC.",
-			);
-			process.exit(1);
-		}
-		printError(`Bootstrap failed: ${detail}`);
-		process.exit(1);
-	}
-
-	const envelope = (await resp.json()) as BootstrapEnvelope;
-	if (!isValidEnvelope(envelope)) {
-		// Defend against partial/malformed backend responses (e.g. {api_key: null}).
-		// Without this guard, the typed `string` field is silently set to
-		// undefined/null and persisted, producing confusing downstream errors.
-		printError(
-			"Bootstrap response missing required fields — please update the CLI.",
-		);
-		process.exit(1);
-	}
-
-	config.platform.apiKey = envelope.api_key;
-	config.platform.baseUrl = baseUrl;
-	config.platform.agentMode = true;
-	config.platform.createdVia = "agent_mode";
-	config.platform.agentCaller = agentCaller ?? "";
-	config.platform.claimedAt = "";
-	config.platform.defaultUserId = envelope.default_user_id;
-	// Adopt the slug-derived user_id as the default scope for memory ops.
-	config.defaults.userId = envelope.default_user_id;
-	saveConfig(config);
-
-	printSuccess(
-		`Agent Mode active. Default user_id: ${envelope.default_user_id}`,
-	);
-	if (envelope.mem0_notice) {
-		console.log(`\n\x1b[33m🔔 ${envelope.mem0_notice}\x1b[0m\n`);
-	} else {
-		// Fallback for older backends without the unified notice field.
-		const claimCmd = envelope.claim_command ?? "mem0 init --email <your-email>";
-		console.log(`  ${dim(`To claim this account later: ${claimCmd}`)}`);
-	}
-
-	if (!agentCaller) {
-		console.log(
-			`  ${dim("If you are an AI agent, identify yourself: `mem0 identify <your-name>` (e.g. claude-code, cursor).")}`,
-		);
-	}
-}
-
-/**
- * Claim an existing Agent Mode account via OTP — no browser, no polling.
- *
- * Hits /api/v1/auth/email_code/ to send a verification code, prompts for it
- * interactively (or accepts via `code`), then sends it to /verify/ alongside
- * `agent_mode_api_key`. Backend's verify_email_code runs upgrade-in-place
- * inline and returns the claim result.
- */
-export async function claimViaOtp(
-	config: Mem0Config,
-	{ email, code }: { email: string; code?: string },
-): Promise<void> {
-	const baseUrl = (config.platform.baseUrl || "https://api.mem0.ai").replace(
-		/\/+$/,
-		"",
-	);
-	if (!config.platform.apiKey || !config.platform.agentMode) {
-		printError(
-			"This command requires an active Agent Mode config. Run `mem0 init` first.",
-		);
-		process.exit(1);
-	}
-
-	const rawKey = config.platform.apiKey;
-
-	// Step 1: request OTP (unless --code was supplied)
-	if (!code) {
-		const sendResp = await fetch(`${baseUrl}/api/v1/auth/email_code/`, {
-			method: "POST",
-			headers: { ...SOURCE_HEADERS, "Content-Type": "application/json" },
-			body: JSON.stringify({ email }),
-			signal: AbortSignal.timeout(30_000),
-		});
-		if (sendResp.status === 429) {
-			printError("Too many attempts. Try again in a few minutes.");
-			process.exit(1);
-		}
-		if (!sendResp.ok) {
-			let detail: string = sendResp.statusText;
-			try {
-				const errBody = (await sendResp.json()) as { error?: string };
-				if (errBody.error) detail = errBody.error;
-			} catch {
-				/* leave as statusText */
-			}
-			printError(`Failed to send code: ${detail}`);
-			process.exit(1);
-		}
-
-		printSuccess(`Verification code sent to ${email}. Check your inbox.`);
-
-		if (!process.stdin.isTTY) {
-			printError(
-				"No --code provided and terminal is non-interactive.",
-				`Re-run: mem0 init --email ${email} --code <code>`,
-			);
-			process.exit(1);
-		}
-
-		console.log();
-		code = await promptLine(`  ${brand("Verification Code")}`);
-		if (!code) {
-			printError("Code is required.");
-			process.exit(1);
-		}
-	}
-
-	// Step 2: verify + claim atomically
-	const verifyResp = await fetch(`${baseUrl}/api/v1/auth/email_code/verify/`, {
-		method: "POST",
-		headers: { ...SOURCE_HEADERS, "Content-Type": "application/json" },
-		body: JSON.stringify({
-			email,
-			code: code.trim(),
-			agent_mode_api_key: rawKey,
-		}),
-		signal: AbortSignal.timeout(30_000),
-	});
-
-	if (!verifyResp.ok) {
-		let detail: string = verifyResp.statusText;
-		let errCode = "";
-		try {
-			const errBody = (await verifyResp.json()) as {
-				error?: string;
-				code?: string;
-			};
-			if (errBody.error) detail = errBody.error;
-			if (errBody.code) errCode = errBody.code;
-		} catch {
-			/* leave as statusText */
-		}
-		printError(`Claim failed: ${detail}`);
-		if (errCode === "email_already_claimed") {
-			console.log(
-				`  ${dim("Tip: this email already has a Mem0 account. Sign in at app.mem0.ai with your existing credentials.")}`,
-			);
-		}
-		process.exit(1);
-	}
-
-	const claimBody = (await verifyResp.json()) as {
-		claimed?: boolean;
-		claimed_at?: string;
-	};
-	if (!claimBody.claimed) {
-		printError(`Unexpected verify response: ${JSON.stringify(claimBody)}`);
-		process.exit(1);
-	}
-
-	config.platform.agentMode = false;
-	config.platform.claimedAt = claimBody.claimed_at ?? new Date().toISOString();
-	config.platform.userEmail = email;
-	config.platform.createdVia = "email";
-	saveConfig(config);
-
-	printSuccess(`Agent claimed to ${email}. Your API key is unchanged.`);
-}
-
-function promptLine(label: string): Promise<string> {
-	const rl = readline.createInterface({
-		input: process.stdin,
-		output: process.stdout,
-	});
-	return new Promise((resolve) => {
-		rl.question(`${label}: `, (answer) => {
-			rl.close();
-			resolve(answer.trim());
-		});
-	});
-}

cli/node/src/commands/agent-rush.ts

@@ -1,147 +0,0 @@
-/**
- * `mem0 agent-rush <add|search> "..."` — wraps the AGENTRUSH platform endpoints.
- * Project routing is implicit (server-side); zero flags needed.
- */
-
-import readline from "node:readline";
-import { colors, printError, printSuccess } from "../branding.js";
-import { loadConfig, saveConfig } from "../config.js";
-import { CLI_VERSION } from "../version.js";
-
-const PII_WARNING = [
-	"",
-	"⚠️  AGENTRUSH memories are PUBLIC — visible to any other player.",
-	"   Do not include real names, emails, secrets, work content, or PII.",
-	"",
-].join("\n");
-
-const ERROR_HINTS: Record<string, string> = {
-	agentrush_search_first:
-		"Run 3 'mem0 agent-rush search' commands before adding.",
-	agentrush_search_quota: "You've used your 3 lifetime searches.",
-	agentrush_add_quota: "You've used your 3 lifetime adds.",
-	agentrush_not_agent_mode:
-		"Re-run 'mem0 init --agent' to bootstrap an agent-mode key.",
-	agentrush_length: "Memory text must be 50-1000 characters.",
-	agentrush_no_urls: "URLs are not allowed.",
-	agentrush_blocklist: "Content contains a blocked term.",
-	agentrush_global_quota: "Event-wide cap reached. Try again later.",
-	agentrush_not_provisioned:
-		"AGENTRUSH is not provisioned in this environment.",
-};
-
-async function callEndpoint(
-	path: string,
-	body: Record<string, unknown>,
-): Promise<unknown> {
-	const config = loadConfig();
-	const baseUrl = (config.platform?.baseUrl ?? "https://api.mem0.ai").replace(
-		/\/+$/,
-		"",
-	);
-
-	if (!config.platform?.apiKey) {
-		printError("Not initialized. Run `mem0 init --agent` first.");
-		process.exit(1);
-	}
-
-	const resp = await fetch(`${baseUrl}${path}`, {
-		method: "POST",
-		headers: {
-			Authorization: `Token ${config.platform.apiKey}`,
-			"Content-Type": "application/json",
-			"X-Mem0-Source": "cli",
-			"X-Mem0-Client-Language": "node",
-			"X-Mem0-Client-Version": CLI_VERSION,
-			"X-Mem0-Mode": "agent-rush",
-		},
-		body: JSON.stringify(body),
-		signal: AbortSignal.timeout(30_000),
-	});
-
-	const json = await resp.json().catch(() => ({}));
-
-	if (!resp.ok) {
-		const code =
-			(json as { error?: { code?: string } }).error?.code ?? "unknown";
-		printError(`AGENTRUSH error: ${code}`);
-		if (ERROR_HINTS[code]) {
-			console.log(`  ${colors.dim(ERROR_HINTS[code])}`);
-		}
-		process.exit(1);
-	}
-
-	return json;
-}
-
-function promptLine(question: string): Promise<string> {
-	const rl = readline.createInterface({
-		input: process.stdin,
-		output: process.stdout,
-	});
-	return new Promise((resolve) => {
-		rl.question(question, (answer) => {
-			rl.close();
-			resolve(answer.trim());
-		});
-	});
-}
-
-/**
- * Ensure the human has acknowledged that AGENTRUSH memories are PUBLIC.
- *
- * Interactive (TTY): show the prompt; on "y" persist `agentRush.acknowledgedAt`
- * so we never ask the same machine twice. On anything else, abort.
- *
- * Non-interactive (agent invocation, no TTY): print the warning to stderr
- * for the human reading the agent's transcript and proceed — agents can't
- * answer y/N prompts.
- */
-async function ensureWarningAcknowledged(): Promise<void> {
-	const config = loadConfig();
-	if (config.agentRush?.acknowledgedAt) return;
-
-	if (!process.stdin.isTTY || !process.stdout.isTTY) {
-		// Agent context: surface the warning to stderr, don't block.
-		console.error(PII_WARNING);
-		return;
-	}
-
-	console.log(PII_WARNING);
-	const answer = (await promptLine("   Continue? [y/N]: ")).toLowerCase();
-	if (answer !== "y" && answer !== "yes") {
-		printError("Aborted.");
-		process.exit(1);
-	}
-
-	config.agentRush.acknowledgedAt = new Date().toISOString();
-	saveConfig(config);
-}
-
-export async function cmdAgentRushAdd(content: string): Promise<void> {
-	await ensureWarningAcknowledged();
-	const result = await callEndpoint("/v1/agent-rush/memories/", { content });
-	printSuccess(
-		`Memory submitted (event_id: ${(result as { event_id?: string }).event_id ?? "?"})`,
-	);
-}
-
-export async function cmdAgentRushSearch(query: string): Promise<void> {
-	const result = (await callEndpoint("/v1/agent-rush/memories/search/", {
-		query,
-	})) as {
-		results?: Array<{ memory?: string }>;
-		memories?: Array<{ memory?: string }>;
-	};
-
-	const memories = result.results ?? result.memories ?? [];
-
-	if (memories.length === 0) {
-		console.log(colors.dim("(no results)"));
-		return;
-	}
-
-	memories.slice(0, 5).forEach((m, i) => {
-		console.log(`  ${i + 1}. ${m.memory ?? JSON.stringify(m)}`);
-	});
-}

cli/node/src/commands/config.ts

@@ -29,6 +29,7 @@ export function cmdConfigShow(opts: { output?: string } = {}): void {
 					agent_id: config.defaults.agentId || null,
 					app_id: config.defaults.appId || null,
 					run_id: config.defaults.runId || null,
+					enable_graph: config.defaults.enableGraph,
 				},
 				platform: {
 					api_key: redactKey(config.platform.apiKey),
@@ -55,6 +56,7 @@ export function cmdConfigShow(opts: { output?: string } = {}): void {
 	]);
 	table.push(["defaults.app_id", config.defaults.appId || dim("(not set)")]);
 	table.push(["defaults.run_id", config.defaults.runId || dim("(not set)")]);
+	table.push(["defaults.enable_graph", String(config.defaults.enableGraph)]);
 	table.push(["", ""]);
 
 	// Platform

cli/node/src/commands/identify.ts

@@ -1,75 +0,0 @@
-/**
- * mem0 identify — declare which agent owns the current agent-mode key.
- *
- * Used when `mem0 init --agent` ran without --agent-caller, so the backend
- * saved agent_caller=NULL. The agent re-runs `mem0 identify <name>` to PATCH
- * its own row with its real identity. Idempotent.
- */
-
-import { printError, printSuccess } from "../branding.js";
-import { loadConfig, saveConfig } from "../config.js";
-
-const SOURCE_HEADERS = {
-	"X-Mem0-Source": "cli",
-	"X-Mem0-Client-Language": "node",
-} as const;
-
-export async function runIdentify(name: string): Promise<void> {
-	const config = loadConfig();
-	if (!config.platform.apiKey) {
-		printError("No API key configured. Run `mem0 init --agent` first.");
-		process.exit(1);
-	}
-	if (!config.platform.agentMode) {
-		printError("This command only works on unclaimed agent-mode keys.");
-		process.exit(1);
-	}
-
-	const clean = (name ?? "").trim();
-	if (!clean) {
-		printError("Agent name is required.");
-		process.exit(1);
-	}
-
-	const baseUrl = (config.platform.baseUrl || "https://api.mem0.ai").replace(
-		/\/+$/,
-		"",
-	);
-
-	let resp: Response;
-	try {
-		resp = await fetch(`${baseUrl}/api/v1/auth/agent_mode/caller/`, {
-			method: "PATCH",
-			headers: {
-				...SOURCE_HEADERS,
-				Authorization: `Token ${config.platform.apiKey}`,
-				"Content-Type": "application/json",
-			},
-			body: JSON.stringify({ agent_caller: clean }),
-			signal: AbortSignal.timeout(30_000),
-		});
-	} catch (err) {
-		printError(
-			`Network error: ${err instanceof Error ? err.message : String(err)}`,
-		);
-		process.exit(1);
-	}
-
-	if (!resp.ok) {
-		let detail: string = resp.statusText;
-		try {
-			const body = (await resp.json()) as { error?: string };
-			if (body.error) detail = body.error;
-		} catch {
-			/* leave as statusText */
-		}
-		printError(`Identify failed: ${detail}`);
-		process.exit(1);
-	}
-
-	const body = (await resp.json()) as { agent_caller?: string };
-	const canonical = body.agent_caller ?? clean;
-	config.platform.agentCaller = canonical;
-	saveConfig(config);
-	printSuccess(`Identified as ${canonical}.`);
-}

cli/node/src/commands/init.ts

@@ -21,8 +21,6 @@ import {
 	redactKey,
 	saveConfig,
 } from "../config.js";
-import { formatJsonEnvelope } from "../output.js";
-import { isAgentMode } from "../state.js";
 
 const { brand, dim } = colors;
 
@@ -35,65 +33,6 @@ function validateEmail(email: string): void {
 	}
 }
 
-/** @internal — exported for unit tests. */
-export async function pingKey(
-	apiKey: string,
-	baseUrl: string,
-	timeoutMs = 5000,
-): Promise<boolean> {
-	// Returns false ONLY on a definitive "invalid key" signal (HTTP 401/403).
-	// Network errors, timeouts, and 5xx responses return true so we prefer
-	// reusing an existing key over silently minting a new shadow on a transient
-	// blip (which would also clobber config + plugin-sync targets).
-	try {
-		const resp = await fetch(`${baseUrl.replace(/\/+$/, "")}/v1/ping/`, {
-			headers: { Authorization: `Token ${apiKey}` },
-			signal: AbortSignal.timeout(timeoutMs),
-		});
-		return resp.status !== 401 && resp.status !== 403;
-	} catch {
-		return true; // unknown — prefer reuse
-	}
-}
-
-async function maybeIdentify(
-	key: string,
-	baseUrl: string,
-	agentCaller: string | undefined,
-): Promise<void> {
-	// Best-effort PATCH agent_caller when --agent-caller is supplied on a
-	// reused key. Silent no-op on any failure — reuse must not break.
-	if (!agentCaller) return;
-	try {
-		const resp = await fetch(
-			`${baseUrl.replace(/\/+$/, "")}/api/v1/auth/agent_mode/caller/`,
-			{
-				method: "PATCH",
-				headers: {
-					Authorization: `Token ${key}`,
-					"Content-Type": "application/json",
-				},
-				body: JSON.stringify({ agent_caller: agentCaller }),
-				signal: AbortSignal.timeout(10_000),
-			},
-		);
-		if (resp.ok) {
-			try {
-				const body = (await resp.json()) as { agent_caller?: string };
-				if (fs.existsSync(CONFIG_FILE)) {
-					const cfg = loadConfig();
-					cfg.platform.agentCaller = body.agent_caller ?? agentCaller;
-					saveConfig(cfg);
-				}
-			} catch {
-				/* swallow — best effort */
-			}
-		}
-	} catch {
-		/* swallow — best effort */
-	}
-}
-
 async function emailLogin(
 	email: string,
 	code: string | undefined,
@@ -246,7 +185,7 @@ function promptLine(label: string, defaultValue?: string): Promise<string> {
 async function setupPlatform(config: Mem0Config): Promise<void> {
 	console.log();
 	console.log(
-		`  ${dim("Get your API key at https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-node")}`,
+		`  ${dim("Get your API key at https://app.mem0.ai/dashboard/api-keys")}`,
 	);
 	console.log();
 
@@ -257,7 +196,6 @@ async function setupPlatform(config: Mem0Config): Promise<void> {
 		process.exit(1);
 	}
 	config.platform.apiKey = apiKey;
-	config.platform.createdVia = "api_key";
 }
 
 async function setupDefaults(config: Mem0Config): Promise<void> {
@@ -296,7 +234,7 @@ async function validatePlatform(config: Mem0Config): Promise<void> {
 		} else {
 			printError(
 				`Could not connect: ${status.error ?? "Unknown error"}`,
-				"Visit https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-node to get a new key, or run mem0 init again.",
+				"Visit https://app.mem0.ai/dashboard/api-keys to get a new key, or run mem0 init again.",
 			);
 		}
 	} catch (e) {
@@ -311,35 +249,14 @@ export async function runInit(
 		email?: string;
 		code?: string;
 		force?: boolean;
-		agent?: boolean;
-		source?: string;
-		agentCaller?: string;
 	} = {},
 ): Promise<void> {
-	const { detectAgentCaller } = await import("../agent-detect.js");
-	const { bootstrapViaBackend, claimViaOtp } = await import("./agent-mode.js");
-	const { isAgentMode } = await import("../state.js");
-	const { captureEvent } = await import("../telemetry.js");
-
-	const fireInit = (
-		mode: "agent" | "email" | "api_key" | "existing_key",
-		claimed = false,
-	) => {
-		const props: Record<string, unknown> = { command: "init", mode };
-		// Self-declared via --agent-caller; not sniffed from env vars.
-		if (opts.agentCaller) props.agent_caller = opts.agentCaller;
-		if (opts.source) props.signup_source = opts.source;
-		if (claimed) props.claimed_agent_mode = true;
-		captureEvent("cli.init", props);
-	};
-
 	const config = createDefaultConfig();
 	const savedConfig = loadConfig();
 	const baseUrl =
 		process.env.MEM0_BASE_URL ||
 		savedConfig.platform.baseUrl ||
 		DEFAULT_BASE_URL;
-	config.platform.baseUrl = baseUrl;
 
 	// Guards
 	if (opts.code && !opts.email) {
@@ -351,84 +268,6 @@ export async function runInit(
 		process.exit(1);
 	}
 
-	// ── Claim flow: --email against an existing agent-mode config ───────────
-	if (
-		opts.email &&
-		fs.existsSync(CONFIG_FILE) &&
-		savedConfig.platform.agentMode &&
-		savedConfig.platform.apiKey
-	) {
-		const email = opts.email.trim().toLowerCase();
-		validateEmail(email);
-		printInfo(`Claiming Agent Mode account to ${email}...`);
-		await claimViaOtp(savedConfig, { email, code: opts.code });
-		fireInit("email", true);
-		return;
-	}
-
-	// ── Agent Mode path runs BEFORE the existing-config guard ──────────────
-	// Rule 1/2 will REUSE a valid existing key (not overwrite), so we must
-	// short-circuit before the guard prompts the user about overwriting.
-	// Rule 3 only mints when there's no valid key to reuse — in that case
-	// overwriting is what the user wants.
-	const agentCtx =
-		opts.agent === true || isAgentMode() || detectAgentCaller() !== null;
-	if (!opts.apiKey && !opts.email && agentCtx) {
-		const emitReuseEnvelope = (source: "env" | "config") => {
-			if (isAgentMode()) {
-				formatJsonEnvelope({
-					command: "init",
-					data: {
-						api_key_saved: false,
-						api_key_source: source,
-						agent_mode: false,
-						message:
-							"Existing Mem0 API key found and reused. No Agent Mode key was created.",
-					},
-				});
-			} else {
-				printSuccess(
-					source === "env"
-						? "Existing MEM0_API_KEY is valid; reusing it. No new Agent Mode key was minted."
-						: "Existing API key in config is valid; reusing it. No new Agent Mode key was minted.",
-				);
-			}
-		};
-		// Rule 1: env MEM0_API_KEY valid → reuse, no new key.
-		const envKey = (process.env.MEM0_API_KEY || "").trim();
-		if (envKey && (await pingKey(envKey, baseUrl))) {
-			await maybeIdentify(envKey, baseUrl, opts.agentCaller);
-			emitReuseEnvelope("env");
-			fireInit("existing_key");
-			return;
-		}
-		// Rule 2: existing config api_key valid → reuse.
-		if (
-			savedConfig.platform.apiKey &&
-			(await pingKey(savedConfig.platform.apiKey, baseUrl))
-		) {
-			await maybeIdentify(
-				savedConfig.platform.apiKey,
-				baseUrl,
-				opts.agentCaller,
-			);
-			emitReuseEnvelope("config");
-			fireInit("existing_key");
-			return;
-		}
-		// Rule 3: mint a fresh shadow (no valid key to reuse).
-		// agent_caller is self-declared via --agent-caller (Proof Editor-style),
-		// not derived from env-var sniffing. detectAgentCaller() above is still
-		// used as a context trigger (does this look like an agent?) but never
-		// to fill identity.
-		await bootstrapViaBackend(config, {
-			source: opts.source ?? null,
-			agentCaller: opts.agentCaller ?? null,
-		});
-		fireInit("agent");
-		return;
-	}
-
 	// Warn if an existing config with an API key would be overwritten
 	if (
 		!opts.force &&
@@ -485,7 +324,6 @@ export async function runInit(
 		config.platform.apiKey = apiKeyVal;
 		config.platform.baseUrl = baseUrl;
 		config.platform.userEmail = email;
-		config.platform.createdVia = "email";
 		config.defaults.userId =
 			opts.userId || process.env.USER || process.env.USERNAME || "mem0-cli";
 
@@ -501,15 +339,13 @@ export async function runInit(
 	}
 
 	// ── API key flow ──────────────────────────────────────────────────────────
-	// (Agent Mode branch runs earlier — see above, before the existing-config
-	// guard, so Rules 1/2 can REUSE a valid key without prompting overwrite.)
 
 	// Non-TTY: resolve defaults so partial flags work in pipelines / CI
 	if (!process.stdin.isTTY) {
 		if (!opts.apiKey) {
 			printError(
 				"Non-interactive terminal detected and --api-key is required.",
-				"Usage: mem0 init --api-key <key>, --email <addr>, or --agent for unattended Agent Mode bootstrap.",
+				"Usage: mem0 init --api-key <key> [--user-id <id>]",
 			);
 			process.exit(1);
 		}
@@ -520,7 +356,6 @@ export async function runInit(
 	// Non-interactive: both flags provided
 	if (opts.apiKey && opts.userId) {
 		config.platform.apiKey = opts.apiKey;
-		config.platform.createdVia = "api_key";
 		config.defaults.userId = opts.userId;
 		await validatePlatform(config);
 		saveConfig(config);
@@ -568,7 +403,6 @@ export async function runInit(
 			config.platform.apiKey = apiKeyVal;
 			config.platform.baseUrl = baseUrl;
 			config.platform.userEmail = email;
-			config.platform.createdVia = "email";
 			config.defaults.userId =
 				opts.userId || process.env.USER || process.env.USERNAME || "mem0-cli";
 

cli/node/src/commands/memory.ts

@@ -46,9 +46,10 @@ export async function cmdAdd(
 		file?: string;
 		metadata?: string;
 		immutable: boolean;
-		infer?: boolean;
+		noInfer: boolean;
 		expires?: string;
 		categories?: string;
+		enableGraph: boolean;
 		output: string;
 	},
 ): Promise<void> {
@@ -136,9 +137,10 @@ export async function cmdAdd(
 				runId: opts.runId,
 				metadata: meta,
 				immutable: opts.immutable,
-				infer: opts.infer !== false,
+				infer: !opts.noInfer,
 				expires: opts.expires,
 				categories: cats,
+				enableGraph: opts.enableGraph,
 			});
 		});
 	} catch (e) {
@@ -223,6 +225,7 @@ export async function cmdSearch(
 		keyword: boolean;
 		filterJson?: string;
 		fields?: string;
+		enableGraph: boolean;
 		output: string;
 	},
 ): Promise<void> {
@@ -271,6 +274,7 @@ export async function cmdSearch(
 				keyword: opts.keyword,
 				filters,
 				fields: fieldList,
+				enableGraph: opts.enableGraph,
 			});
 		});
 	} catch (e) {
@@ -364,6 +368,7 @@ export async function cmdList(
 		category?: string;
 		after?: string;
 		before?: string;
+		enableGraph: boolean;
 		output: string;
 	},
 ): Promise<void> {
@@ -391,6 +396,7 @@ export async function cmdList(
 				category: opts.category,
 				after: opts.after,
 				before: opts.before,
+				enableGraph: opts.enableGraph,
 			});
 		});
 	} catch (e) {

cli/node/src/commands/utils.ts

@@ -63,7 +63,7 @@ export async function cmdStatus(
 				`  ${dim("Run")} ${brand("mem0 init")} ${dim("to reconfigure your API key")}`,
 			);
 			lines.push(
-				`  ${dim("Get a key at")} ${brand("https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-node")}`,
+				`  ${dim("Get a key at")} ${brand("https://app.mem0.ai/dashboard/api-keys")}`,
 			);
 		}
 	}

cli/node/src/commands/whoami.ts

@@ -1,18 +0,0 @@
-/**
- * `mem0 whoami` — print the active agent's default_user_id (AGENTRUSH identifier).
- * Reads from local config; no network call.
- */
-
-import { colors, printError, printInfo } from "../branding.js";
-import { loadConfig } from "../config.js";
-
-export async function cmdWhoami(): Promise<void> {
-	const config = loadConfig();
-	const sessionId = config.platform?.defaultUserId;
-	if (!sessionId) {
-		printError("No default_user_id found. Run `mem0 init --agent` first.");
-		process.exit(1);
-	}
-	console.log(`Your AGENTRUSH identifier:  ${colors.brand(sessionId)}`);
-	printInfo("Find your row at https://mem0.ai/agentrush");
-}

cli/node/src/config.ts

@@ -21,12 +21,6 @@ export interface PlatformConfig {
 	apiKey: string;
 	baseUrl: string;
 	userEmail: string;
-	// Agent Mode (unclaimed-shadow signup)
-	agentMode: boolean; // true while the key is an unclaimed agent-mode key
-	createdVia: string; // "agent_mode" | "email" | "api_key" | "existing_key"
-	agentCaller: string; // canonical agent name when createdVia === "agent_mode" (e.g. "claude-code")
-	claimedAt: string; // ISO timestamp once the agent has been claimed
-	defaultUserId: string; // `user_<slug>` returned by bootstrap; auto-default scope
 }
 
 export interface DefaultsConfig {
@@ -34,24 +28,13 @@ export interface DefaultsConfig {
 	agentId: string;
 	appId: string;
 	runId: string;
-}
-
-export interface TelemetryConfig {
-	anonymousId: string;
-}
-
-export interface AgentRushConfig {
-	// ISO timestamp the human acknowledged the "memories are public" warning.
-	// Empty until first interactive `mem0 agent-rush add`.
-	acknowledgedAt: string;
+	enableGraph: boolean;
 }
 
 export interface Mem0Config {
 	version: number;
 	defaults: DefaultsConfig;
 	platform: PlatformConfig;
-	telemetry: TelemetryConfig;
-	agentRush: AgentRushConfig;
 }
 
 export function createDefaultConfig(): Mem0Config {
@@ -62,22 +45,12 @@ export function createDefaultConfig(): Mem0Config {
 			agentId: "",
 			appId: "",
 			runId: "",
+			enableGraph: false,
 		},
 		platform: {
 			apiKey: "",
 			baseUrl: DEFAULT_BASE_URL,
 			userEmail: "",
-			agentMode: false,
-			createdVia: "",
-			agentCaller: "",
-			claimedAt: "",
-			defaultUserId: "",
-		},
-		telemetry: {
-			anonymousId: "",
-		},
-		agentRush: {
-			acknowledgedAt: "",
 		},
 	};
 }
@@ -100,21 +73,13 @@ export function loadConfig(): Mem0Config {
 		config.platform.apiKey = plat.api_key ?? "";
 		config.platform.baseUrl = plat.base_url ?? DEFAULT_BASE_URL;
 		config.platform.userEmail = plat.user_email ?? "";
-		config.platform.agentMode = Boolean(plat.agent_mode ?? false);
-		config.platform.createdVia = plat.created_via ?? "";
-		config.platform.agentCaller = plat.agent_caller ?? "";
-		config.platform.claimedAt = plat.claimed_at ?? "";
-		config.platform.defaultUserId = plat.default_user_id ?? "";
 
 		const defaults = data.defaults ?? {};
 		config.defaults.userId = defaults.user_id ?? "";
 		config.defaults.agentId = defaults.agent_id ?? "";
 		config.defaults.appId = defaults.app_id ?? "";
 		config.defaults.runId = defaults.run_id ?? "";
-		const telemetry = data.telemetry ?? {};
-		config.telemetry.anonymousId = telemetry.anonymous_id ?? "";
-		const agentRush = data.agent_rush ?? {};
-		config.agentRush.acknowledgedAt = agentRush.acknowledged_at ?? "";
+		config.defaults.enableGraph = defaults.enable_graph ?? false;
 	}
 
 	// Environment variable overrides
@@ -128,6 +93,12 @@ export function loadConfig(): Mem0Config {
 		config.defaults.agentId = process.env.MEM0_AGENT_ID;
 	if (process.env.MEM0_APP_ID) config.defaults.appId = process.env.MEM0_APP_ID;
 	if (process.env.MEM0_RUN_ID) config.defaults.runId = process.env.MEM0_RUN_ID;
+	if (process.env.MEM0_ENABLE_GRAPH) {
+		config.defaults.enableGraph = ["true", "1", "yes"].includes(
+			process.env.MEM0_ENABLE_GRAPH.toLowerCase(),
+		);
+	}
+
 	return config;
 }
 
@@ -141,41 +112,17 @@ export function saveConfig(config: Mem0Config): void {
 			agent_id: config.defaults.agentId,
 			app_id: config.defaults.appId,
 			run_id: config.defaults.runId,
+			enable_graph: config.defaults.enableGraph,
 		},
 		platform: {
 			api_key: config.platform.apiKey,
 			base_url: config.platform.baseUrl,
 			user_email: config.platform.userEmail,
-			agent_mode: config.platform.agentMode,
-			created_via: config.platform.createdVia,
-			agent_caller: config.platform.agentCaller,
-			claimed_at: config.platform.claimedAt,
-			default_user_id: config.platform.defaultUserId,
-		},
-		telemetry: {
-			anonymous_id: config.telemetry.anonymousId,
-		},
-		agent_rush: {
-			acknowledged_at: config.agentRush.acknowledgedAt,
 		},
 	};
 
 	fs.writeFileSync(CONFIG_FILE, JSON.stringify(data, null, 2));
 	fs.chmodSync(CONFIG_FILE, 0o600);
-
-	// Propagate api_key to ecosystem touchpoints (Claude plugin env injection,
-	// shell rc exports). Idempotent — updates only EXISTING entries; never
-	// creates new ones. Best-effort: errors swallowed so config.json is
-	// always authoritative, never blocked by plugin-state issues.
-	if (config.platform.apiKey) {
-		try {
-			// eslint-disable-next-line @typescript-eslint/no-require-imports
-			const { syncApiKey } = require("./plugin-sync.js");
-			syncApiKey(config.platform.apiKey);
-		} catch {
-			/* swallow */
-		}
-	}
 }
 
 export function redactKey(key: string): string {
@@ -193,6 +140,7 @@ const KEY_MAP: Record<string, [keyof Mem0Config, string]> = {
 	"defaults.agent_id": ["defaults", "agentId"],
 	"defaults.app_id": ["defaults", "appId"],
 	"defaults.run_id": ["defaults", "runId"],
+	"defaults.enable_graph": ["defaults", "enableGraph"],
 	// Short-form aliases
 	api_key: ["platform", "apiKey"],
 	base_url: ["platform", "baseUrl"],
@@ -201,6 +149,7 @@ const KEY_MAP: Record<string, [keyof Mem0Config, string]> = {
 	agent_id: ["defaults", "agentId"],
 	app_id: ["defaults", "appId"],
 	run_id: ["defaults", "runId"],
+	enable_graph: ["defaults", "enableGraph"],
 };
 
 export function getNestedValue(config: Mem0Config, dottedKey: string): unknown {

cli/node/src/index.ts

@@ -13,12 +13,7 @@ import { colors, printError, printWarning } from "./branding.js";
 import type { Mem0Config } from "./config.js";
 import { loadConfig, saveConfig } from "./config.js";
 import { richFormatHelp } from "./help.js";
-import {
-	isAgentMode,
-	setAgentMode,
-	setCurrentCommand,
-	takeNotice,
-} from "./state.js";
+import { setAgentMode } from "./state.js";
 import { captureEvent } from "./telemetry.js";
 import { CLI_VERSION } from "./version.js";
 
@@ -139,6 +134,18 @@ function resolveIds(
 	};
 }
 
+/**
+ * Resolve graph tri-state: --no-graph > --graph > config default.
+ */
+function resolveGraph(
+	config: Mem0Config,
+	opts: { graph?: boolean; noGraph?: boolean },
+): boolean {
+	if (opts.noGraph) return false;
+	if (opts.graph) return true;
+	return config.defaults.enableGraph;
+}
+
 // ── Main program ──────────────────────────────────────────────────────────
 
 program
@@ -146,11 +153,6 @@ program
 	.description(
 		`◆ Mem0 CLI v${CLI_VERSION} · Node.js SDK\n\nThe Memory Layer for AI Agents`,
 	)
-	// Positional options: flags AFTER a subcommand name belong to that
-	// subcommand, not the global program. Without this, `mem0 init --agent`
-	// routes `--agent` to the program-level alias (for --json) and init's own
-	// `--agent` (Agent Mode bootstrap) silently never fires.
-	.enablePositionalOptions()
 	.option("--version", "Show version and exit.")
 	.on("option:version", () => {
 		console.log(`  ${colors.brand("◆ Mem0")} CLI v${CLI_VERSION}`);
@@ -159,7 +161,7 @@ program
 	.option("--json", "Output as JSON for agent/programmatic use.")
 	.option(
 		"--agent",
-		"Output as JSON for agent/programmatic use. (alias: --json) Place BEFORE the subcommand: `mem0 --agent <cmd>`. On `init`, `mem0 init --agent` is the Agent Mode bootstrap flag instead.",
+		"Output as JSON for agent/programmatic use. (alias: --json)",
 	)
 	.usage("<command> [options]")
 	.helpOption("--help", "Show this message and exit.")
@@ -176,14 +178,6 @@ program.hook("preAction", (_thisCommand, actionCommand) => {
 			parentName && parentName !== "mem0"
 				? `${parentName}.${commandName}`
 				: commandName;
-		// Stash the active command name in shared state so the JSON
-		// error envelope (printError) can report which command failed
-		// instead of an empty `"command": ""` field.
-		setCurrentCommand(fullCommand);
-		// init fires its own telemetry from runInit with full M1-M6 props
-		// (mode/agent_caller/signup_source/claimed_agent_mode); skip the
-		// auto-fire here so we don't double-count.
-		if (fullCommand === "init") return;
 		const isAgent = !!(program.opts().json || program.opts().agent);
 		captureEvent(
 			`cli.${fullCommand}`,
@@ -211,32 +205,11 @@ program
 		"Verification code (use with --email for non-interactive login).",
 	)
 	.option("--force", "Overwrite existing config without confirmation.", false)
-	.option(
-		"--agent",
-		"Bootstrap an unattended Agent Mode account (no email required).",
-		false,
-	)
-	.option(
-		"--source <channel>",
-		"Channel attribution for signup (e.g. github, hn, ph).",
-	)
-	.option(
-		"--agent-caller <name>",
-		"Self-declared agent identity (e.g. claude-code, cursor). Used with --agent to attribute Agent Mode signups.",
-	)
-	// Accept `--json` at the init level too so the PRD-documented form
-	// `mem0 init --agent --json` works without requiring users to move it
-	// before the subcommand. Effect is identical to the global `--json`:
-	// flip agent-mode output state.
-	.option("--json", "Output as JSON (alias for global `--json`).", false)
 	.addHelpText(
 		"after",
-		"\nExamples:\n  $ mem0 init\n  $ mem0 init --api-key m0-xxx --user-id alice\n  $ mem0 init --email you@example.com\n  $ mem0 init --email you@example.com --code 123456\n  $ mem0 init --agent             # Bootstrap an Agent Mode account (unattended)\n  $ mem0 init --email you@example.com  # Claims an existing Agent Mode key when one is present",
+		"\nExamples:\n  $ mem0 init\n  $ mem0 init --api-key m0-xxx --user-id alice\n  $ mem0 init --email you@example.com\n  $ mem0 init --email you@example.com --code 123456",
 	)
 	.action(async (opts) => {
-		// `--json` at init level mirrors the global flag — flip agent_mode
-		// state so downstream formatters use JSON envelopes.
-		if (opts.json) setAgentMode(true);
 		const { runInit } = await import("./commands/init.js");
 		await runInit({
 			apiKey: opts.apiKey,
@@ -244,66 +217,9 @@ program
 			email: opts.email,
 			code: opts.code,
 			force: opts.force,
-			agent: opts.agent,
-			source: opts.source,
-			agentCaller: opts.agentCaller,
 		});
 	});
 
-// ── Setup: identify (post-bootstrap agent self-tag) ──────────────────────
-
-program
-	.command("identify <name>")
-	.description(
-		"Tag your active Agent Mode key with the AI agent that's using it (e.g. claude-code, cursor).",
-	)
-	.action(async (name: string) => {
-		const { runIdentify } = await import("./commands/identify.js");
-		await runIdentify(name);
-	});
-
-// ── Setup: whoami (print active agent identifier) ────────────────────────
-
-program
-	.command("whoami")
-	.description("Print the active agent's AGENTRUSH identifier.")
-	.action(async () => {
-		const { cmdWhoami } = await import("./commands/whoami.js");
-		await cmdWhoami();
-	});
-
-// ── AGENTRUSH subcommand group ────────────────────────────────────────────
-
-const agentRush = program
-	.command("agent-rush")
-	.description("AGENTRUSH game commands.")
-	.addHelpCommand(false)
-	.configureHelp({ formatHelp: richFormatHelp });
-
-agentRush
-	.command("add <content...>")
-	.description("Submit a memory to AGENTRUSH.")
-	.addHelpText(
-		"after",
-		'\nExamples:\n  $ mem0 agent-rush add "I used mem0 to build a coding agent"\n  $ mem0 agent-rush add "Agents that remember are better agents"',
-	)
-	.action(async (parts: string[]) => {
-		const { cmdAgentRushAdd } = await import("./commands/agent-rush.js");
-		await cmdAgentRushAdd(parts.join(" "));
-	});
-
-agentRush
-	.command("search <query...>")
-	.description("Search AGENTRUSH memories.")
-	.addHelpText(
-		"after",
-		'\nExamples:\n  $ mem0 agent-rush search "agents and memory and tools"\n  $ mem0 agent-rush search "coding assistant"',
-	)
-	.action(async (parts: string[]) => {
-		const { cmdAgentRushSearch } = await import("./commands/agent-rush.js");
-		await cmdAgentRushSearch(parts.join(" "));
-	});
-
 // ── Memory: add ───────────────────────────────────────────────────────────
 
 program
@@ -320,6 +236,8 @@ program
 	.option("--no-infer", "Skip inference, store raw.")
 	.option("--expires <date>", "Expiration date (YYYY-MM-DD).")
 	.option("--categories <value>", "Categories (JSON array or comma-separated).")
+	.option("--graph", "Enable graph memory extraction.", false)
+	.option("--no-graph", "Disable graph memory extraction.")
 	.option("-o, --output <format>", "Output format: text, json, quiet.", "text")
 	.option("--api-key <key>", "Override API key.")
 	.option("--base-url <url>", "Override API base URL.")
@@ -335,8 +253,9 @@ program
 			opts.baseUrl,
 		);
 		const ids = resolveIds(config, opts);
+		const enableGraph = resolveGraph(config, opts);
 		const output = isAgent ? "agent" : opts.output;
-		await cmdAdd(backend, text, { ...ids, ...opts, output });
+		await cmdAdd(backend, text, { ...ids, ...opts, enableGraph, output });
 	});
 
 // ── Memory: search ────────────────────────────────────────────────────────
@@ -366,6 +285,8 @@ program
 	.option("--keyword", "Use keyword search.", false)
 	.option("--filter <json>", "Advanced filter expression (JSON).")
 	.option("--fields <list>", "Specific fields to return (comma-separated).")
+	.option("--graph", "Enable graph in search.", false)
+	.option("--no-graph", "Disable graph in search.")
 	.option("-o, --output <format>", "Output: text, json, table.", "text")
 	.option("--api-key <key>", "Override API key.")
 	.option("--base-url <url>", "Override API base URL.")
@@ -389,6 +310,7 @@ program
 			opts.baseUrl,
 		);
 		const ids = resolveIds(config, opts);
+		const enableGraph = resolveGraph(config, opts);
 		const output = isAgent ? "agent" : opts.output;
 		await cmdSearch(backend, resolvedQuery, {
 			...ids,
@@ -398,6 +320,7 @@ program
 			keyword: opts.keyword,
 			filterJson: opts.filter,
 			fields: opts.fields,
+			enableGraph,
 			output,
 		});
 	});
@@ -441,6 +364,8 @@ program
 	.option("--category <name>", "Filter by category.")
 	.option("--after <date>", "Created after (YYYY-MM-DD).")
 	.option("--before <date>", "Created before (YYYY-MM-DD).")
+	.option("--graph", "Enable graph in listing.", false)
+	.option("--no-graph", "Disable graph in listing.")
 	.option("-o, --output <format>", "Output: text, json, table.", "table")
 	.option("--api-key <key>", "Override API key.")
 	.option("--base-url <url>", "Override API base URL.")
@@ -456,6 +381,7 @@ program
 			opts.baseUrl,
 		);
 		const ids = resolveIds(config, opts);
+		const enableGraph = resolveGraph(config, opts);
 		const output = isAgent ? "agent" : opts.output;
 		await cmdList(backend, {
 			...ids,
@@ -464,6 +390,7 @@ program
 			category: opts.category,
 			after: opts.after,
 			before: opts.before,
+			enableGraph,
 			output,
 		});
 	});
@@ -865,16 +792,4 @@ program
 
 // ── Entrypoint ────────────────────────────────────────────────────────────
 
-// Surface any unclaimed Agent Mode notice once per command, after the primary
-// output. In JSON/agent mode the notice is folded into the envelope by
-// formatJsonEnvelope, so skip the stderr banner there to avoid duplication.
-function surfaceNotice(): void {
-	const notice = takeNotice();
-	if (notice && !isAgentMode()) {
-		process.stderr.write(`\n\x1b[33m🔔 ${notice}\x1b[0m\n\n`);
-	}
-}
-
-program.parseAsync().finally(() => {
-	surfaceNotice();
-});
+program.parse();

cli/node/src/output.ts

@@ -5,7 +5,6 @@
 import boxen from "boxen";
 import Table from "cli-table3";
 import { colors, sym } from "./branding.js";
-import { takeNotice } from "./state.js";
 
 const { brand, accent, success, error: errorColor, dim } = colors;
 
@@ -245,15 +244,6 @@ export function formatJsonEnvelope(opts: {
 	if (opts.count !== undefined) envelope.count = opts.count;
 	if (opts.error) envelope.error = opts.error;
 	envelope.data = opts.data;
-
-	// If the platform flagged this as an unclaimed Agent Mode account, surface
-	// the notice inside the JSON envelope so an agent consuming the output
-	// sees it without needing to inspect HTTP headers.
-	// eslint-disable-next-line @typescript-eslint/no-require-imports
-	const { takeNotice } = require("./state.js");
-	const notice = takeNotice();
-	if (notice) envelope.mem0_notice = notice;
-
 	console.log(JSON.stringify(envelope, null, 2));
 }
 
@@ -366,12 +356,6 @@ export function formatAgentEnvelope(opts: {
 	}
 	if (opts.count !== undefined) envelope.count = opts.count;
 	envelope.data = sanitizeAgentData(opts.command, opts.data);
-
-	// Surface the unclaimed-Agent-Mode notice (if any) in the envelope so an
-	// agent reading the JSON output sees it without inspecting HTTP headers.
-	const notice = takeNotice();
-	if (notice) envelope.mem0_notice = notice;
-
 	console.log(JSON.stringify(envelope, null, 2));
 }
 

cli/node/src/plugin-sync.ts

@@ -1,120 +0,0 @@
-/**
- * Sync the active Mem0 API key into other ecosystem touchpoints.
- *
- * Why: the CLI canonical state is ~/.mem0/config.json. MCP servers
- * (Claude Code plugin, Codex plugin) read MEM0_API_KEY from env or
- * their own config files. Without a sync, agent-mode bootstrap mints a
- * new key into config.json but the plugin's MCP keeps using the old
- * key from env — silent surprise.
- *
- * Design:
- *  - Update ONLY entries that already exist; never create new ones
- *  - Preserve surrounding content, formatting, other keys
- *  - Atomic writes (tmp + rename) so a crash mid-write doesn't corrupt
- *  - Idempotent — re-running with the same key is a no-op
- *
- * Targets:
- *  - ~/.claude/settings.json::env::MEM0_API_KEY (Claude Code env injection)
- *  - ~/.zshrc / ~/.bashrc `export MEM0_API_KEY="..."` lines
- *
- * Out of scope: Codex / Cursor MCP configs and the plugin's own
- * <plugin-dir>/.api_key file (plugin-managed, different schema).
- */
-
-import fs from "node:fs";
-import os from "node:os";
-import path from "node:path";
-
-const CLAUDE_SETTINGS = path.join(os.homedir(), ".claude", "settings.json");
-const SHELL_RCS = [
-	path.join(os.homedir(), ".zshrc"),
-	path.join(os.homedir(), ".bashrc"),
-	path.join(os.homedir(), ".bash_profile"),
-];
-
-// Use [ \t]* (not \s*) so a trailing newline at end-of-file is preserved
-// when the MEM0_API_KEY export is the last line of the rc file.
-const RC_LINE_RE =
-	/^([ \t]*export[ \t]+MEM0_API_KEY[ \t]*=[ \t]*)(["']?)([^"'\n]*)(["']?)[ \t]*$/m;
-
-export function syncApiKey(apiKey: string): string[] {
-	if (!apiKey) return [];
-	const updated: string[] = [];
-	if (updateClaudeSettings(CLAUDE_SETTINGS, apiKey)) {
-		updated.push(CLAUDE_SETTINGS);
-	}
-	for (const rc of SHELL_RCS) {
-		if (updateShellRc(rc, apiKey)) updated.push(rc);
-	}
-	return updated;
-}
-
-/** @internal — exported for unit tests; consumers should use {@link syncApiKey}. */
-export function updateClaudeSettings(
-	filePath: string,
-	apiKey: string,
-): boolean {
-	if (!fs.existsSync(filePath)) return false;
-	let raw: string;
-	let data: Record<string, unknown>;
-	try {
-		raw = fs.readFileSync(filePath, "utf-8");
-		data = JSON.parse(raw);
-	} catch {
-		return false;
-	}
-	const env = data.env;
-	if (!env || typeof env !== "object" || !("MEM0_API_KEY" in env)) {
-		return false; // no existing entry — don't create one
-	}
-	const envObj = env as Record<string, string>;
-	if (envObj.MEM0_API_KEY === apiKey) return false; // already in sync
-	envObj.MEM0_API_KEY = apiKey;
-	atomicWriteText(filePath, `${JSON.stringify(data, null, 2)}\n`);
-	return true;
-}
-
-/** @internal — exported for unit tests; consumers should use {@link syncApiKey}. */
-export function updateShellRc(filePath: string, apiKey: string): boolean {
-	if (!fs.existsSync(filePath)) return false;
-	let text: string;
-	try {
-		text = fs.readFileSync(filePath, "utf-8");
-	} catch {
-		return false;
-	}
-	const match = text.match(RC_LINE_RE);
-	if (!match) return false; // no existing line
-	if (match[3] === apiKey) return false;
-	const newText = text.replace(
-		RC_LINE_RE,
-		(_full, prefix) => `${prefix}"${apiKey}"`,
-	);
-	atomicWriteText(filePath, newText);
-	return true;
-}
-
-function atomicWriteText(filePath: string, content: string): void {
-	const dir = path.dirname(filePath);
-	const tmp = path.join(dir, `.${path.basename(filePath)}.${process.pid}.tmp`);
-	try {
-		fs.writeFileSync(tmp, content, "utf-8");
-		// Preserve permissions if original existed.
-		if (fs.existsSync(filePath)) {
-			try {
-				const mode = fs.statSync(filePath).mode & 0o777;
-				fs.chmodSync(tmp, mode);
-			} catch {
-				/* best-effort */
-			}
-		}
-		fs.renameSync(tmp, filePath);
-	} catch (err) {
-		try {
-			fs.unlinkSync(tmp);
-		} catch {
-			/* ignore */
-		}
-		throw err;
-	}
-}

cli/node/src/state.ts

@@ -5,7 +5,6 @@
 
 let _agentMode = false;
 let _currentCommand = "";
-let _pendingNotice = "";
 
 export function isAgentMode(): boolean {
 	return _agentMode;
@@ -22,19 +21,3 @@ export function getCurrentCommand(): string {
 export function setCurrentCommand(name: string): void {
 	_currentCommand = name;
 }
-
-/**
- * Stash a Mem0 backend notice (Agent Mode unclaimed reminder) for end-of-
- * command surfacing. Called from the platform backend after each response so
- * the notice prints once per command regardless of how many sub-requests
- * fired. Last-write-wins is fine — the message text is identical.
- */
-export function captureNotice(notice: string | null | undefined): void {
-	if (notice) _pendingNotice = notice;
-}
-
-export function takeNotice(): string {
-	const msg = _pendingNotice;
-	_pendingNotice = "";
-	return msg;
-}

cli/node/src/telemetry.ts

@@ -9,10 +9,10 @@
  */
 
 import { spawn } from "node:child_process";
-import { createHash, randomUUID } from "node:crypto";
+import { createHash } from "node:crypto";
 import path from "node:path";
 import { fileURLToPath } from "node:url";
-import { CONFIG_FILE, loadConfig, saveConfig } from "./config.js";
+import { CONFIG_FILE, loadConfig } from "./config.js";
 import { CLI_VERSION } from "./version.js";
 
 const POSTHOG_API_KEY = "phc_hgJkUVJFYtmaJqrvf6CYN67TIQ8yhXAkWzUn9AMU4yX";
@@ -29,34 +29,11 @@ function isTelemetryEnabled(): boolean {
 	}
 }
 
-/**
- * Return a persistent per-machine anonymous ID, generating one if needed.
- *
- * Stored in ~/.mem0/config.json under `telemetry.anonymous_id` so that
- * repeat runs on the same machine share one PostHog identity instead of
- * collapsing into a single shared fallback string.
- */
-function getOrCreateAnonymousId(): string {
-	const config = loadConfig();
-	if (config.telemetry.anonymousId) {
-		return config.telemetry.anonymousId;
-	}
-
-	const newId = `cli-anon-${randomUUID().replace(/-/g, "")}`;
-	config.telemetry.anonymousId = newId;
-	try {
-		saveConfig(config);
-	} catch {
-		/* ignore persistence failure — still return the generated ID */
-	}
-	return newId;
-}
-
 /**
  * Return a stable anonymous identifier for the current user.
  *
- * Priority: cached user_email (from /v1/ping/) > MD5(api_key) >
- * persistent per-machine anonymous ID.
+ * Priority: cached user_email (from /v1/ping/) > MD5(api_key) > fallback.
+ * Matches the SDK pattern in mem0-ts/src/client/mem0.ts.
  */
 function getDistinctId(): string {
 	try {
@@ -70,11 +47,7 @@ function getDistinctId(): string {
 	} catch {
 		/* ignore */
 	}
-	try {
-		return getOrCreateAnonymousId();
-	} catch {
-		return `cli-anon-${randomUUID().replace(/-/g, "")}`;
-	}
+	return "anonymous-cli";
 }
 
 /**
@@ -96,28 +69,6 @@ export function captureEvent(
 		const config = loadConfig();
 		const distinctId = preResolvedEmail || getDistinctId();
 
-		// Detect anonymous → identified transition. If a stored anonymous_id
-		// exists and we just resolved to a real identity, fire a one-shot
-		// $identify event so PostHog stitches the pre-signup history onto
-		// the authenticated profile. Clear the stored id so we don't re-alias.
-		let anonIdToAlias: string | null = null;
-		if (
-			distinctId &&
-			!distinctId.startsWith("cli-anon-") &&
-			config.telemetry.anonymousId
-		) {
-			anonIdToAlias = config.telemetry.anonymousId;
-			config.telemetry.anonymousId = "";
-			try {
-				saveConfig(config);
-			} catch {
-				/* ignore — alias may double-fire next run, harmless */
-			}
-		}
-
-		// M4: every cli.* event carries agent_mode based on the config flag
-		// (unclaimed Agent Mode key). This is the growth-doc property used to
-		// join init → add → search funnels in PostHog.
 		const payload = {
 			api_key: POSTHOG_API_KEY,
 			distinct_id: distinctId,
@@ -126,7 +77,6 @@ export function captureEvent(
 				source: "CLI",
 				language: "node",
 				cli_version: CLI_VERSION,
-				agent_mode: Boolean(config.platform.agentMode),
 				node_version: process.version,
 				os: process.platform,
 				...properties,
@@ -142,14 +92,13 @@ export function captureEvent(
 			mem0ApiKey: config.platform.apiKey || "",
 			mem0BaseUrl: config.platform.baseUrl || "https://api.mem0.ai",
 			configPath: CONFIG_FILE,
-			anonDistinctIdToAlias: anonIdToAlias,
 		};
 
-		const child = spawn(process.execPath, [SENDER_SCRIPT], {
-			detached: true,
-			stdio: ["pipe", "ignore", "ignore"],
-		});
-		child.stdin?.end(JSON.stringify(context));
+		const child = spawn(
+			process.execPath,
+			[SENDER_SCRIPT, JSON.stringify(context)],
+			{ detached: true, stdio: "ignore" },
+		);
 		child.unref();
 	} catch {
 		/* silently swallow */

cli/node/telemetry-sender.cjs

@@ -1,8 +1,7 @@
 /**
  * Standalone telemetry sender — runs as a detached child process.
  *
- * Usage: node telemetry-sender.cjs   (JSON context is read from stdin; a single
- * argv argument is still accepted as a legacy fallback)
+ * Usage: node telemetry-sender.cjs '<json context>'
  *
  * This script is spawned by telemetry.captureEvent() and runs independently
  * of the parent CLI process. It:
@@ -20,31 +19,6 @@
 const https = require("https");
 const fs = require("fs");
 
-function loadContext() {
-	return new Promise((resolve, reject) => {
-		if (process.argv[2]) {
-			try {
-				resolve(JSON.parse(process.argv[2]));
-			} catch (err) {
-				reject(err);
-			}
-			return;
-		}
-
-		let data = "";
-		process.stdin.setEncoding("utf8");
-		process.stdin.on("data", (chunk) => (data += chunk));
-		process.stdin.on("end", () => {
-			try {
-				resolve(JSON.parse(data));
-			} catch (err) {
-				reject(err);
-			}
-		});
-		process.stdin.on("error", reject);
-	});
-}
-
 function httpsRequest(url, method, headers, body) {
 	return new Promise((resolve, reject) => {
 		const u = new URL(url);
@@ -120,35 +94,14 @@ async function sendPosthogEvent(posthogHost, payload) {
 	}
 }
 
-async function sendIdentifyEvent(ctx, payload, anonId) {
-	const identifyPayload = {
-		api_key: payload.api_key,
-		event: "$identify",
-		distinct_id: payload.distinct_id,
-		properties: {
-			$anon_distinct_id: anonId,
-			$lib: (payload.properties && payload.properties.$lib) || "posthog-node",
-		},
-	};
-	await sendPosthogEvent(ctx.posthogHost, identifyPayload);
-}
-
 async function main() {
-	const ctx = await loadContext();
+	const ctx = JSON.parse(process.argv[2]);
 	const payload = ctx.payload;
 
 	if (ctx.needsEmail && ctx.mem0ApiKey) {
 		await resolveAndCacheEmail(ctx, payload);
 	}
 
-	// Fire $identify *after* email resolution so PostHog links the stored
-	// anonymous id directly to the final identity (email, not the api-key
-	// hash). The regular event is sent next so it lands under the merged
-	// profile.
-	if (ctx.anonDistinctIdToAlias) {
-		await sendIdentifyEvent(ctx, payload, ctx.anonDistinctIdToAlias);
-	}
-
 	await sendPosthogEvent(ctx.posthogHost, payload);
 }
 

cli/node/tests/agent-mode.test.ts

@@ -1,141 +0,0 @@
-/**
- * Parity tests for `mem0 init --agent` (Agent Mode bootstrap).
- *
- * Mirror of `cli/python/tests/test_agent_mode.py` — both files MUST stay
- * in sync so that the Python and Node CLIs expose an identical surface
- * for the Agent Mode entrypoint. If you add a flag here, add the same
- * assertion on the Python side (and vice versa).
- *
- * Network-bound bootstrap is covered by the platform-side E2E suite
- * (`backend/tests/e2e/test_05_agent_mode.py`); these tests only verify
- * the CLI surface that ships in the binary.
- */
-
-import { describe, it, expect } from "vitest";
-import { execSync } from "node:child_process";
-import fs from "node:fs";
-import os from "node:os";
-import path from "node:path";
-
-function run(
-  args: string[],
-  opts: { home?: string; env?: Record<string, string> } = {},
-): { stdout: string; stderr: string; exitCode: number } {
-  const env = { ...process.env };
-  for (const key of Object.keys(env)) {
-    if (key.startsWith("MEM0_")) delete env[key];
-  }
-  if (opts.home) env.HOME = opts.home;
-  if (opts.env) Object.assign(env, opts.env);
-
-  try {
-    const stdout = execSync(`npx tsx src/index.ts ${args.join(" ")}`, {
-      cwd: path.join(__dirname, ".."),
-      env,
-      encoding: "utf-8",
-      timeout: 15000,
-    });
-    return { stdout, stderr: "", exitCode: 0 };
-  } catch (e: any) {
-    return {
-      stdout: e.stdout ?? "",
-      stderr: e.stderr ?? "",
-      exitCode: e.status ?? 1,
-    };
-  }
-}
-
-function cleanHome(): string {
-  return fs.mkdtempSync(path.join(os.tmpdir(), "mem0-test-"));
-}
-
-describe("init flag surface", () => {
-  it("init --help lists --agent", () => {
-    const result = run(["init", "--help"]);
-    expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--agent");
-  });
-
-  it("init --help describes Agent Mode", () => {
-    const result = run(["init", "--help"]);
-    expect(result.exitCode).toBe(0);
-    // Description must mention what --agent actually does so an agent
-    // reading the help can self-discover the bootstrap entrypoint.
-    expect(
-      result.stdout.includes("Agent Mode") ||
-        result.stdout.toLowerCase().includes("unattended"),
-    ).toBe(true);
-  });
-
-  it("init --help lists --source", () => {
-    const result = run(["init", "--help"]);
-    expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--source");
-  });
-
-  it("init --help lists --email and --code", () => {
-    const result = run(["init", "--help"]);
-    expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--email");
-    expect(result.stdout).toContain("--code");
-  });
-});
-
-describe("argv preprocessing — --agent reaches init subcommand", () => {
-  // Regression for the bug where the global --agent JSON-alias swallowed
-  // the init-level --agent flag, making `mem0 init --agent` behave like
-  // the plain interactive wizard.
-
-  it("init --agent triggers bootstrap branch (not the wizard)", () => {
-    const home = cleanHome();
-    const result = run(["init", "--agent"], {
-      home,
-      env: {
-        MEM0_BASE_URL: "http://127.0.0.1:1", // blackhole
-        FORCE_COLOR: "0",
-      },
-    });
-    const combined = (result.stdout + result.stderr).toLowerCase();
-    // Either bootstrap-attempt error, or a connection/network error —
-    // both prove the --agent path executed (the wizard would prompt for
-    // input and succeed/hang, not surface a network error).
-    expect(
-      combined.includes("agent") ||
-        combined.includes("connect") ||
-        combined.includes("network") ||
-        combined.includes("fetch") ||
-        combined.includes("bootstrap"),
-    ).toBe(true);
-    fs.rmSync(home, { recursive: true, force: true });
-  });
-});
-
-describe("JSON envelope on network failure", () => {
-  it("init --agent --json does not leak a stack trace when backend is unreachable", () => {
-    const home = cleanHome();
-    const result = run(["init", "--agent", "--json"], {
-      home,
-      env: {
-        MEM0_BASE_URL: "http://127.0.0.1:1",
-        FORCE_COLOR: "0",
-      },
-    });
-    const combined = result.stdout + result.stderr;
-    // No raw Node stack should escape the agent-mode handler.
-    expect(combined).not.toMatch(/at \w+\s*\(.+\.ts:\d+/);
-    expect(combined).not.toContain("UnhandledPromiseRejection");
-    expect(result.exitCode).not.toBe(0);
-    fs.rmSync(home, { recursive: true, force: true });
-  });
-});
-
-describe("top-level help lists init", () => {
-  // `mem0 --help` must list `init` so agents walking the top-level help
-  // can discover the Agent Mode entrypoint without prior knowledge.
-
-  it("--help lists init", () => {
-    const result = run(["--help"]);
-    expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("init");
-  });
-});

cli/node/tests/cli-integration.test.ts

@@ -107,22 +107,22 @@ describe("CLI Integration — help and version", () => {
     expect(result.exitCode).toBe(0);
   });
 
-  it("add help has --output flag", () => {
+  it("add help has --graph flag", () => {
     const result = run(["add", "--help"]);
     expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--output");
+    expect(result.stdout).toContain("--graph");
   });
 
-  it("search help has --rerank flag", () => {
+  it("search help has --graph flag", () => {
     const result = run(["search", "--help"]);
     expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--rerank");
+    expect(result.stdout).toContain("--graph");
   });
 
-  it("list help has --category flag", () => {
+  it("list help has --graph flag", () => {
     const result = run(["list", "--help"]);
     expect(result.exitCode).toBe(0);
-    expect(result.stdout).toContain("--category");
+    expect(result.stdout).toContain("--graph");
   });
 });
 

cli/node/tests/commands.test.ts

@@ -3,7 +3,6 @@
  */
 
 import { describe, it, expect, vi, beforeEach } from "vitest";
-import { Command } from "commander";
 import { createMockBackend } from "./setup.js";
 import type { Backend } from "../src/backend/base.js";
 import { setAgentMode } from "../src/state.js";
@@ -42,6 +41,8 @@ describe("cmdAdd", () => {
     await cmdAdd(mockBackend, "I prefer dark mode", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "text",
     });
     expect(mockBackend.add).toHaveBeenCalledOnce();
@@ -53,6 +54,8 @@ describe("cmdAdd", () => {
       userId: "alice",
       messages: JSON.stringify([{ role: "user", content: "I love Python" }]),
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "text",
     });
     expect(mockBackend.add).toHaveBeenCalledOnce();
@@ -63,6 +66,8 @@ describe("cmdAdd", () => {
     await cmdAdd(mockBackend, "test", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "json",
     });
     expect(output).toContain("results");
@@ -73,59 +78,14 @@ describe("cmdAdd", () => {
     await cmdAdd(mockBackend, "test", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "quiet",
     });
     expect(output).not.toContain("dark mode");
   });
 });
 
-describe("cmdAdd forwards --no-infer (regression for #5261)", () => {
-  it("forwards infer: false when --no-infer is set", async () => {
-    const { cmdAdd } = await import("../src/commands/memory.js");
-    // `infer: false` is the shape Commander produces for `--no-infer`.
-    await cmdAdd(mockBackend, "store me verbatim", {
-      userId: "alice",
-      immutable: false,
-      infer: false,
-      output: "text",
-    });
-    expect(mockBackend.add).toHaveBeenCalledWith(
-      "store me verbatim",
-      undefined,
-      expect.objectContaining({ infer: false }),
-    );
-  });
-
-  it("forwards infer: true by default (flag absent)", async () => {
-    const { cmdAdd } = await import("../src/commands/memory.js");
-    await cmdAdd(mockBackend, "infer me", {
-      userId: "alice",
-      immutable: false,
-      output: "text",
-    });
-    expect(mockBackend.add).toHaveBeenCalledWith(
-      "infer me",
-      undefined,
-      expect.objectContaining({ infer: true }),
-    );
-  });
-
-  it("Commander stores --no-infer as opts.infer, not opts.noInfer", () => {
-    // Pins the assumption the fix relies on: Commander's `--no-X` option
-    // populates the positive camelCase key (`infer`), never `noInfer`.
-    const withFlag = new Command();
-    withFlag.option("--no-infer", "Skip inference, store raw.").action(() => {});
-    withFlag.parse(["--no-infer"], { from: "user" });
-    expect(withFlag.opts().infer).toBe(false);
-    expect(withFlag.opts().noInfer).toBeUndefined();
-
-    const withoutFlag = new Command();
-    withoutFlag.option("--no-infer", "Skip inference, store raw.").action(() => {});
-    withoutFlag.parse([], { from: "user" });
-    expect(withoutFlag.opts().infer).toBe(true);
-  });
-});
-
 describe("cmdAdd deduplicates PENDING", () => {
   const DUPLICATE_PENDING = {
     results: [
@@ -140,6 +100,8 @@ describe("cmdAdd deduplicates PENDING", () => {
     await cmdAdd(mockBackend, "test", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "text",
     });
     expect(output.match(/Queued/g)?.length).toBe(1);
@@ -151,6 +113,8 @@ describe("cmdAdd deduplicates PENDING", () => {
     await cmdAdd(mockBackend, "test", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "json",
     });
     const data = JSON.parse(output);
@@ -165,6 +129,8 @@ describe("cmdAdd deduplicates PENDING", () => {
     await cmdAdd(mockBackend, "test", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "agent",
     });
     const data = JSON.parse(output);
@@ -182,7 +148,7 @@ describe("cmdSearch", () => {
       threshold: 0.3,
       rerank: false,
       keyword: false,
-
+      enableGraph: false,
       output: "text",
     });
     expect(output).toContain("Found 2");
@@ -196,7 +162,7 @@ describe("cmdSearch", () => {
       threshold: 0.3,
       rerank: false,
       keyword: false,
-
+      enableGraph: false,
       output: "json",
     });
     expect(output).toContain("memory");
@@ -211,7 +177,7 @@ describe("cmdSearch", () => {
       threshold: 0.3,
       rerank: false,
       keyword: false,
-
+      enableGraph: false,
       output: "text",
     });
     expect(errOutput).toContain("No memories found");
@@ -239,7 +205,7 @@ describe("cmdList", () => {
       userId: "alice",
       page: 1,
       pageSize: 100,
-
+      enableGraph: false,
       output: "table",
     });
     expect(output).toContain("dark mode");
@@ -252,7 +218,7 @@ describe("cmdList", () => {
       userId: "alice",
       page: 1,
       pageSize: 100,
-
+      enableGraph: false,
       output: "text",
     });
     expect(errOutput).toContain("No memories found");
@@ -349,6 +315,8 @@ describe("agent mode", () => {
     await cmdAdd(mockBackend, "test preference", {
       userId: "alice",
       immutable: false,
+      noInfer: false,
+      enableGraph: false,
       output: "agent",
     });
     const parsed = JSON.parse(output.trim());
@@ -368,7 +336,7 @@ describe("agent mode", () => {
       threshold: 0.3,
       rerank: false,
       keyword: false,
-
+      enableGraph: false,
       output: "agent",
     });
     const parsed = JSON.parse(output.trim());
@@ -393,7 +361,7 @@ describe("agent mode", () => {
       userId: "alice",
       page: 1,
       pageSize: 100,
-
+      enableGraph: false,
       output: "agent",
     });
     const parsed = JSON.parse(output.trim());

cli/node/tests/config.test.ts

@@ -64,6 +64,7 @@ describe("createDefaultConfig", () => {
     expect(config.platform.baseUrl).toBe("https://api.mem0.ai");
     expect(config.platform.apiKey).toBe("");
     expect(config.defaults.userId).toBe("");
+    expect(config.defaults.enableGraph).toBe(false);
   });
 });
 
@@ -104,4 +105,9 @@ describe("setNestedValue", () => {
     expect(config.defaults.userId).toBe("bob");
   });
 
+  it("coerces boolean for enable_graph", () => {
+    const config = createDefaultConfig();
+    expect(setNestedValue(config, "defaults.enable_graph", "true")).toBe(true);
+    expect(config.defaults.enableGraph).toBe(true);
+  });
 });

cli/node/tests/init-internals.test.ts

@@ -1,168 +0,0 @@
-/**
- * Unit tests for init internals — decision tree primitives + plugin sync.
- *
- * Mirror of `cli/python/tests/test_init_internals.py`. Both files MUST stay
- * in sync — if you add a behavioral assertion here, mirror it on the Python
- * side and vice versa.
- *
- *  - `pingKey` must NOT treat network errors as "invalid key" (else a VPN
- *    flap silently mints a new shadow over a working key).
- *  - `plugin_sync` must only update entries that already exist, preserve
- *    trailing newlines, and never mangle other lines.
- */
-
-import fs from "node:fs";
-import os from "node:os";
-import path from "node:path";
-import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
-import { pingKey } from "../src/commands/init.js";
-import { updateClaudeSettings, updateShellRc } from "../src/plugin-sync.js";
-
-// ── pingKey ──────────────────────────────────────────────────────────────
-
-describe("pingKey — network vs auth distinction", () => {
-	const origFetch = globalThis.fetch;
-	afterEach(() => {
-		globalThis.fetch = origFetch;
-		vi.restoreAllMocks();
-	});
-
-	it("returns true for 200", async () => {
-		globalThis.fetch = vi.fn().mockResolvedValue({ status: 200 } as Response);
-		await expect(pingKey("k", "http://x")).resolves.toBe(true);
-	});
-
-	it("returns false for 401 (definitively invalid)", async () => {
-		globalThis.fetch = vi.fn().mockResolvedValue({ status: 401 } as Response);
-		await expect(pingKey("k", "http://x")).resolves.toBe(false);
-	});
-
-	it("returns false for 403 (definitively invalid)", async () => {
-		globalThis.fetch = vi.fn().mockResolvedValue({ status: 403 } as Response);
-		await expect(pingKey("k", "http://x")).resolves.toBe(false);
-	});
-
-	it("returns true for 5xx (transient upstream — prefer reuse)", async () => {
-		globalThis.fetch = vi.fn().mockResolvedValue({ status: 503 } as Response);
-		await expect(pingKey("k", "http://x")).resolves.toBe(true);
-	});
-
-	it("returns true on network error (prefer reuse over re-mint)", async () => {
-		globalThis.fetch = vi.fn().mockRejectedValue(new Error("ECONNREFUSED"));
-		await expect(pingKey("k", "http://x")).resolves.toBe(true);
-	});
-
-	it("returns true on timeout (prefer reuse)", async () => {
-		globalThis.fetch = vi.fn().mockRejectedValue(new Error("aborted"));
-		await expect(pingKey("k", "http://x")).resolves.toBe(true);
-	});
-});
-
-// ── updateShellRc ────────────────────────────────────────────────────────
-
-describe("updateShellRc — exists-only contract", () => {
-	let tmpDir: string;
-
-	beforeEach(() => {
-		tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), "mem0-test-"));
-	});
-	afterEach(() => {
-		fs.rmSync(tmpDir, { recursive: true, force: true });
-	});
-
-	it("updates existing export and preserves trailing newline", () => {
-		const rc = path.join(tmpDir, ".zshrc");
-		fs.writeFileSync(rc, 'export MEM0_API_KEY="old"\n');
-		expect(updateShellRc(rc, "newkey")).toBe(true);
-		expect(fs.readFileSync(rc, "utf-8")).toBe('export MEM0_API_KEY="newkey"\n');
-	});
-
-	it("does NOT create a new export when none exists", () => {
-		const rc = path.join(tmpDir, ".zshrc");
-		fs.writeFileSync(rc, "alias ll='ls -la'\n");
-		expect(updateShellRc(rc, "newkey")).toBe(false);
-		expect(fs.readFileSync(rc, "utf-8")).toBe("alias ll='ls -la'\n");
-	});
-
-	it("preserves surrounding content", () => {
-		const rc = path.join(tmpDir, ".zshrc");
-		const original =
-			"# my zshrc\n" +
-			"alias ll='ls -la'\n" +
-			"export MEM0_API_KEY='old'\n" +
-			"export OTHER=keepme\n";
-		fs.writeFileSync(rc, original);
-		updateShellRc(rc, "newkey");
-		const after = fs.readFileSync(rc, "utf-8");
-		expect(after).toContain("alias ll='ls -la'\n");
-		expect(after).toContain("export OTHER=keepme\n");
-		expect(after).toContain("# my zshrc\n");
-		expect(after).toContain('export MEM0_API_KEY="newkey"\n');
-	});
-
-	it("is idempotent when value already matches", () => {
-		const rc = path.join(tmpDir, ".zshrc");
-		fs.writeFileSync(rc, 'export MEM0_API_KEY="same"\n');
-		expect(updateShellRc(rc, "same")).toBe(false);
-	});
-
-	it("is a no-op for missing files", () => {
-		const rc = path.join(tmpDir, ".zshrc"); // does not exist
-		expect(updateShellRc(rc, "x")).toBe(false);
-	});
-});
-
-// ── updateClaudeSettings ─────────────────────────────────────────────────
-
-describe("updateClaudeSettings — never creates entries", () => {
-	let tmpDir: string;
-
-	beforeEach(() => {
-		tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), "mem0-test-"));
-	});
-	afterEach(() => {
-		fs.rmSync(tmpDir, { recursive: true, force: true });
-	});
-
-	it("does not create env block when none exists", () => {
-		const settings = path.join(tmpDir, "settings.json");
-		fs.writeFileSync(settings, JSON.stringify({ otherKey: 1 }));
-		expect(updateClaudeSettings(settings, "newkey")).toBe(false);
-		expect(JSON.parse(fs.readFileSync(settings, "utf-8"))).toEqual({
-			otherKey: 1,
-		});
-	});
-
-	it("does not create MEM0_API_KEY entry in existing env block", () => {
-		const settings = path.join(tmpDir, "settings.json");
-		fs.writeFileSync(settings, JSON.stringify({ env: { OTHER_KEY: "x" } }));
-		expect(updateClaudeSettings(settings, "newkey")).toBe(false);
-	});
-
-	it("updates existing entry and preserves siblings", () => {
-		const settings = path.join(tmpDir, "settings.json");
-		fs.writeFileSync(
-			settings,
-			JSON.stringify({ env: { MEM0_API_KEY: "old", OTHER: "y" } }, null, 2),
-		);
-		expect(updateClaudeSettings(settings, "fresh")).toBe(true);
-		const data = JSON.parse(fs.readFileSync(settings, "utf-8"));
-		expect(data.env.MEM0_API_KEY).toBe("fresh");
-		expect(data.env.OTHER).toBe("y");
-	});
-
-	it("is idempotent when value already matches", () => {
-		const settings = path.join(tmpDir, "settings.json");
-		fs.writeFileSync(
-			settings,
-			JSON.stringify({ env: { MEM0_API_KEY: "same" } }),
-		);
-		expect(updateClaudeSettings(settings, "same")).toBe(false);
-	});
-
-	it("is a no-op for malformed JSON", () => {
-		const settings = path.join(tmpDir, "settings.json");
-		fs.writeFileSync(settings, "{ this is not json");
-		expect(updateClaudeSettings(settings, "x")).toBe(false);
-	});
-});

cli/node/tests/telemetry.test.ts

@@ -1,59 +0,0 @@
-import { beforeEach, describe, expect, it, vi } from "vitest";
-
-const mockLoadConfig = vi.fn();
-const mockSaveConfig = vi.fn();
-const mockSpawn = vi.fn();
-
-vi.mock("../src/config.js", () => ({
-  CONFIG_FILE: "/tmp/mem0-config.json",
-  loadConfig: mockLoadConfig,
-  saveConfig: mockSaveConfig,
-}));
-
-vi.mock("node:child_process", () => ({
-  spawn: mockSpawn,
-}));
-
-describe("captureEvent", () => {
-  beforeEach(() => {
-    vi.resetModules();
-    mockLoadConfig.mockReset();
-    mockSaveConfig.mockReset();
-    mockSpawn.mockReset();
-    delete process.env.MEM0_TELEMETRY;
-  });
-
-  it("pipes the telemetry context through stdin instead of argv", async () => {
-    mockLoadConfig.mockReturnValue({
-      platform: {
-        apiKey: "m0-node-secret",
-        baseUrl: "https://api.mem0.ai",
-        userEmail: "",
-      },
-      telemetry: {
-        anonymousId: "cli-anon-node",
-      },
-    });
-
-    const stdin = { end: vi.fn() };
-    const child = { stdin, unref: vi.fn() };
-    mockSpawn.mockReturnValue(child);
-
-    const { captureEvent } = await import("../src/telemetry.js");
-    captureEvent("node_test_event", { case: "stdin-secret" });
-
-    expect(mockSpawn).toHaveBeenCalledTimes(1);
-    const [execPath, args, options] = mockSpawn.mock.calls[0];
-    expect(execPath).toBe(process.execPath);
-    expect(args).toHaveLength(1);
-    expect(String(args[0])).toContain("telemetry-sender.cjs");
-    expect(JSON.stringify(args)).not.toContain("m0-node-secret");
-    expect(options).toMatchObject({ detached: true, stdio: ["pipe", "ignore", "ignore"] });
-
-    expect(stdin.end).toHaveBeenCalledTimes(1);
-    const payload = JSON.parse(stdin.end.mock.calls[0][0]);
-    expect(payload.mem0ApiKey).toBe("m0-node-secret");
-    expect(payload.payload.event).toBe("node_test_event");
-    expect(child.unref).toHaveBeenCalledTimes(1);
-  });
-});

cli/node/vitest.config.ts

@@ -8,10 +8,4 @@ export default defineConfig({
 	define: {
 		__CLI_VERSION__: JSON.stringify(pkg.version),
 	},
-	test: {
-		// Integration tests spawn the CLI via `npx tsx` (15s subprocess
-		// timeout); the first spawn in a file pays a cold-start cost that can
-		// exceed vitest's 5s default on CI runners.
-		testTimeout: 30_000,
-	},
 });

cli/python/CHANGELOG.md

@@ -1,49 +0,0 @@
-# Changelog
-
-All notable changes to `mem0-cli` (Python) are documented here.
-
-The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
-and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
-
-## [0.2.8] — 2026-06-19
-
-### Security
-
-- Telemetry no longer passes the Mem0 API key to its child process via
-  command-line arguments. The context is now sent over stdin, so the key is no
-  longer visible in the process list (`ps`, `/proc/<pid>/cmdline`, Activity
-  Monitor). Fixes #4862.
-
-### Fixed
-
-- `__version__` now matches the packaged version (was stale at 0.2.4).
-
-## [0.2.7] — 2026-05-20
-
-### Added
-
-- `mem0 whoami` — print the active agent's `default_user_id` (the AGENTRUSH
-  leaderboard identifier). Reads from local config, no network call.
-- `mem0 agent-rush <add | search>` — subcommand group that wraps the new
-  `/v1/agent-rush/` platform endpoints for the 7-day AGENTRUSH game. Project
-  routing is implicit (resolved server-side); no flags exposed. Pretty-prints
-  platform error codes into actionable hints (e.g. `agentrush_search_first`
-  → "Run 3 'mem0 agent-rush search' commands before adding.").
-- PII safety prompt on first `mem0 agent-rush add`. Interactive runs require
-  explicit `y` to acknowledge that AGENTRUSH memories are public; the
-  acknowledgement is persisted in `~/.mem0/config.json` under
-  `agent_rush.acknowledged_at` so the prompt only appears once per machine.
-  Non-interactive (agent) invocations surface the warning to stderr without
-  blocking.
-- New config schema field: `agent_rush.acknowledged_at` (ISO timestamp,
-  empty until first interactive acknowledgement).
-
-### Changed
-
-- HTTP requests from the new agent-rush commands send `X-Mem0-Mode: agent-rush`
-  in addition to the existing source headers, so platform telemetry can split
-  game traffic from regular CLI usage.
-
-## [0.2.6] and earlier
-
-Unlogged historical releases. See git history under `cli/python/`.

cli/python/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "mem0-cli"
-version = "0.2.8"
+version = "0.2.2"
 description = "The official CLI for mem0 — the memory layer for AI agents"
 readme = "README.md"
 license = "Apache-2.0"

cli/python/src/mem0_cli/__init__.py

@@ -1,3 +1,3 @@
 """mem0 CLI — the command-line interface for the mem0 memory layer."""
 
-__version__ = "0.2.8"
+__version__ = "0.2.2"

cli/python/src/mem0_cli/agent_detect.py

@@ -1,36 +0,0 @@
-"""Detect whether the CLI is being invoked from inside an AI-agent context.
-
-Used by `mem0 init` to auto-enter Agent Mode (Rule 3 bootstrap) when an
-agent runtime env var is present. The return value is a context **trigger
-only** — the canonical agent identity is self-declared by the agent via
-``--agent-caller <name>`` (Proof Editor-style) and never sniffed from env
-vars to fill the ``agent_caller`` field on the APIKey row.
-
-Returns a short name or None. The list is curated, not exhaustive — env
-vars we don't recognise fall through to None (caller treated as
-non-agent). Honest reporting depends on ``--agent-caller``; this list is
-just enough to enable the zero-friction auto-bootstrap UX.
-"""
-
-from __future__ import annotations
-
-import os
-
-_AGENT_CALLER_ENV: tuple[tuple[str, tuple[str, ...]], ...] = (
-    ("claude-code", ("CLAUDECODE", "CLAUDE_CODE")),
-    ("cursor", ("CURSOR_AGENT", "CURSOR_SESSION_ID")),
-    ("codex", ("CODEX_CLI", "OPENAI_CODEX")),
-    ("cline", ("CLINE_AGENT", "CLINE")),
-    ("continue", ("CONTINUE_AGENT", "CONTINUE_SESSION")),
-    ("aider", ("AIDER_SESSION",)),
-    ("goose", ("GOOSE_AGENT",)),
-    ("windsurf", ("WINDSURF_AGENT",)),
-)
-
-
-def detect_agent_caller() -> str | None:
-    """Return a canonical agent name if any agent env var is set, else None."""
-    for name, env_vars in _AGENT_CALLER_ENV:
-        if any(os.environ.get(v) for v in env_vars):
-            return name
-    return None

cli/python/src/mem0_cli/app.py

@@ -237,14 +237,6 @@ def main_callback(
         cmd_version()
         raise typer.Exit()
     if ctx.invoked_subcommand:
-        # Stash the active subcommand name so the JSON error envelope
-        # (print_error in agent mode) can report which command failed
-        # instead of an empty `"command": ""` field.
-        from mem0_cli.state import set_current_command
-
-        set_current_command(ctx.invoked_subcommand)
-    if ctx.invoked_subcommand and ctx.invoked_subcommand != "init":
-        # init fires its own telemetry from init_cmd.run_init with full M1-M6 props.
         _fire_telemetry(ctx.invoked_subcommand)
 
 
@@ -275,6 +267,8 @@ def add(
     categories: str | None = typer.Option(
         None, "--categories", help="Categories (JSON array or comma-separated)."
     ),
+    graph: bool = typer.Option(False, "--graph", help="Enable graph memory extraction."),
+    no_graph: bool = typer.Option(False, "--no-graph", help="Disable graph memory extraction."),
     output: str = typer.Option(
         "text", "--output", "-o", help="Output format: text, json, quiet.", rich_help_panel="Output"
     ),
@@ -301,6 +295,13 @@ def add(
     backend, config = _get_backend_and_config(api_key, base_url)
     ids = _resolve_ids(config, user_id=user_id, agent_id=agent_id, app_id=app_id, run_id=run_id)
 
+    if no_graph:
+        graph_enabled = False
+    elif graph:
+        graph_enabled = True
+    else:
+        graph_enabled = config.defaults.enable_graph
+
     cmd_add(
         backend,
         text,
@@ -312,6 +313,7 @@ def add(
         no_infer=no_infer,
         expires=expires,
         categories=categories,
+        enable_graph=graph_enabled,
         output=output,
     )
 
@@ -355,6 +357,12 @@ def search(
         help="Specific fields to return (comma-separated).",
         rich_help_panel="Search",
     ),
+    graph: bool = typer.Option(
+        False, "--graph", help="Enable graph in search.", rich_help_panel="Search"
+    ),
+    no_graph: bool = typer.Option(
+        False, "--no-graph", help="Disable graph in search.", rich_help_panel="Search"
+    ),
     output: str = typer.Option(
         "text", "--output", "-o", help="Output: text, json, table.", rich_help_panel="Output"
     ),
@@ -388,6 +396,13 @@ def search(
     backend, config = _get_backend_and_config(api_key, base_url)
     ids = _resolve_ids(config, user_id=user_id, agent_id=agent_id, app_id=app_id, run_id=run_id)
 
+    if no_graph:
+        graph_enabled = False
+    elif graph:
+        graph_enabled = True
+    else:
+        graph_enabled = config.defaults.enable_graph
+
     cmd_search(
         backend,
         query,
@@ -398,6 +413,7 @@ def search(
         keyword=keyword,
         filter_json=filter_json,
         fields=fields,
+        enable_graph=graph_enabled,
         output=output,
     )
 
@@ -464,6 +480,12 @@ def list_cmd(
     before: str | None = typer.Option(
         None, "--before", help="Created before (YYYY-MM-DD).", rich_help_panel="Filters"
     ),
+    graph: bool = typer.Option(
+        False, "--graph", help="Enable graph in listing.", rich_help_panel="Filters"
+    ),
+    no_graph: bool = typer.Option(
+        False, "--no-graph", help="Disable graph in listing.", rich_help_panel="Filters"
+    ),
     output: str = typer.Option(
         "table", "--output", "-o", help="Output: text, json, table.", rich_help_panel="Output"
     ),
@@ -489,6 +511,13 @@ def list_cmd(
     backend, config = _get_backend_and_config(api_key, base_url)
     ids = _resolve_ids(config, user_id=user_id, agent_id=agent_id, app_id=app_id, run_id=run_id)
 
+    if no_graph:
+        graph_enabled = False
+    elif graph:
+        graph_enabled = True
+    else:
+        graph_enabled = config.defaults.enable_graph
+
     cmd_list(
         backend,
         **ids,
@@ -497,6 +526,7 @@ def list_cmd(
         category=category,
         after=after,
         before=before,
+        enable_graph=graph_enabled,
         output=output,
     )
 
@@ -859,19 +889,6 @@ def init(
     force: bool = typer.Option(
         False, "--force", help="Overwrite existing config without confirmation."
     ),
-    agent_signal: bool = typer.Option(
-        False, "--agent", help="Bootstrap an unattended Agent Mode account (no email required)."
-    ),
-    source: str | None = typer.Option(
-        None,
-        "--source",
-        help="Channel attribution for signup (e.g. github, hn, ph).",
-    ),
-    agent_caller: str | None = typer.Option(
-        None,
-        "--agent-caller",
-        help="Self-declared agent identity (e.g. claude-code, cursor). Used with --agent to attribute Agent Mode signups.",
-    ),
 ) -> None:
     """Interactive setup wizard for mem0 CLI.
 
@@ -880,97 +897,10 @@ def init(
       mem0 init --api-key m0-xxx --user-id alice
       mem0 init --email alice@company.com
       mem0 init --email alice@company.com --code 482901
-      mem0 init --agent --agent-caller claude-code   # AI agent self-identifies on Agent Mode bootstrap
-      mem0 init --email alice@company.com  # Claims an existing Agent Mode key when one is present
     """
     from mem0_cli.commands.init_cmd import run_init
 
-    run_init(
-        api_key=api_key,
-        user_id=user_id,
-        email=email,
-        code=code,
-        force=force,
-        source=source,
-        agent=agent_signal,
-        agent_caller=agent_caller,
-    )
-
-
-@app.command(rich_help_panel="Setup")
-def identify(
-    name: str = typer.Argument(..., help="Agent identity (e.g. claude-code, cursor, my-bot)."),
-) -> None:
-    """Tag your active Agent Mode key with the AI agent that's using it.
-
-    Run this once after `mem0 init --agent` if you didn't pass --agent-caller.
-    Idempotent — re-running just overwrites the value.
-
-    Example:
-      mem0 identify claude-code
-    """
-    from mem0_cli.commands.identify_cmd import run_identify
-
-    run_identify(name)
-
-
-@app.command(name="whoami", rich_help_panel="Setup")
-def whoami_cmd() -> None:
-    """Print your AGENTRUSH identifier (default_user_id).
-
-    Example:
-      mem0 whoami
-    """
-    from mem0_cli.commands.whoami_cmd import run_whoami
-
-    run_whoami()
-
-
-# ── AGENTRUSH sub-app ─────────────────────────────────────────────────────
-
-agent_rush_app = typer.Typer(
-    name="agent-rush",
-    help="AGENTRUSH game commands",
-    no_args_is_help=True,
-    rich_markup_mode="rich",
-)
-
-
-@agent_rush_app.callback(invoke_without_command=True)
-def _agent_rush_callback(ctx: typer.Context) -> None:
-    if ctx.invoked_subcommand:
-        _fire_telemetry(f"agent-rush.{ctx.invoked_subcommand}")
-
-
-@agent_rush_app.command(name="add")
-def agent_rush_add(
-    content: str = typer.Argument(..., help="Memory content (50-1000 characters, no URLs)."),
-) -> None:
-    """Submit a memory to AGENTRUSH.
-
-    Example:
-      mem0 agent-rush add "I enjoy solving constraint-satisfaction problems."
-    """
-    from mem0_cli.commands.agent_rush_cmd import run_agent_rush_add
-
-    run_agent_rush_add(content)
-
-
-@agent_rush_app.command(name="search")
-def agent_rush_search(
-    query: str = typer.Argument(..., help="Search query."),
-) -> None:
-    """Search AGENTRUSH memories.
-
-    Example:
-      mem0 agent-rush search "constraint satisfaction"
-    """
-    from mem0_cli.commands.agent_rush_cmd import run_agent_rush_search
-
-    run_agent_rush_search(query)
-
-
-app.add_typer(agent_rush_app, name="agent-rush", rich_help_panel="Setup")
+    run_init(api_key=api_key, user_id=user_id, email=email, code=code, force=force)
 
 
 # (entity_app registered at module level, below sub-group definitions)
@@ -1306,28 +1236,11 @@ def main() -> None:
     import sys
 
     # Allow --json/--agent anywhere in the command line (not just before subcommand).
-    # Special case: `mem0 init --agent` is a subcommand flag (Agent Mode bootstrap)
-    # consumed by init_cmd, not a global JSON-output toggle — leave it in argv.
-    argv_rest = sys.argv[1:]
-    is_init = "init" in argv_rest
-    _global_flags = {"--json"} if is_init else {"--json", "--agent"}
-    if any(a in _global_flags for a in argv_rest):
+    _json_flags = {"--json", "--agent"}
+    if any(a in _json_flags for a in sys.argv[1:]):
         from mem0_cli.state import set_agent_mode
 
         set_agent_mode(True)
-        sys.argv = [sys.argv[0]] + [a for a in argv_rest if a not in _global_flags]
+        sys.argv = [sys.argv[0]] + [a for a in sys.argv[1:] if a not in _json_flags]
 
-    try:
-        app()
-    finally:
-        # Surface any unclaimed Agent Mode notice once per command, after the
-        # primary output. In JSON/agent mode the notice is folded into the
-        # envelope by format_json_envelope, so skip the stderr banner there
-        # to avoid duplicate output.
-        from mem0_cli.state import is_agent_mode, take_notice
-
-        notice = take_notice()
-        if notice and not is_agent_mode():
-            from rich.console import Console
-
-            Console(stderr=True).print(f"\n[yellow]🔔 {notice}[/yellow]\n")
+    app()

cli/python/src/mem0_cli/backend/base.py

@@ -26,6 +26,7 @@ class Backend(ABC):
         infer: bool = True,
         expires: str | None = None,
         categories: list[str] | None = None,
+        enable_graph: bool = False,
     ) -> dict: ...
 
     @abstractmethod
@@ -43,6 +44,7 @@ class Backend(ABC):
         keyword: bool = False,
         filters: dict | None = None,
         fields: list[str] | None = None,
+        enable_graph: bool = False,
     ) -> list[dict]: ...
 
     @abstractmethod
@@ -61,6 +63,7 @@ class Backend(ABC):
         category: str | None = None,
         after: str | None = None,
         before: str | None = None,
+        enable_graph: bool = False,
     ) -> list[dict]: ...
 
     @abstractmethod

cli/python/src/mem0_cli/backend/platform.py

@@ -30,7 +30,7 @@ class PlatformBackend(Backend):
         )
 
     def _request(self, method: str, path: str, **kwargs: Any) -> Any:
-        from mem0_cli.state import capture_notice, is_agent_mode
+        from mem0_cli.state import is_agent_mode
 
         self._client.headers["X-Mem0-Caller-Type"] = "agent" if is_agent_mode() else "user"
         resp = self._client.request(method, path, **kwargs)
@@ -48,26 +48,7 @@ class PlatformBackend(Backend):
         resp.raise_for_status()
         if resp.status_code == 204:
             return {}
-        data = resp.json()
-
-        # Pull the unclaimed-Agent-Mode notice out of the body (or the header
-        # fallback for endpoints that return non-dict / non-dict-leading
-        # payloads) and stash it for end-of-command surfacing.
-        notice = None
-        if isinstance(data, dict) and "mem0_notice" in data:
-            notice = data.pop("mem0_notice")
-        elif (
-            isinstance(data, list)
-            and data
-            and isinstance(data[0], dict)
-            and "mem0_notice" in data[0]
-        ):
-            notice = data[0].pop("mem0_notice")
-        if notice is None:
-            notice = resp.headers.get("X-Mem0-Notice-Message") or None
-        capture_notice(notice)
-
-        return data
+        return resp.json()
 
     def add(
         self,
@@ -83,6 +64,7 @@ class PlatformBackend(Backend):
         infer: bool = True,
         expires: str | None = None,
         categories: list[str] | None = None,
+        enable_graph: bool = False,
     ) -> dict:
         payload: dict[str, Any] = {}
 
@@ -109,9 +91,10 @@ class PlatformBackend(Backend):
             payload["expiration_date"] = expires
         if categories:
             payload["categories"] = categories
-        payload["source"] = "CLI"
+        if enable_graph:
+            payload["enable_graph"] = True
 
-        return self._request("POST", "/v3/memories/add/", json=payload)
+        return self._request("POST", "/v1/memories/", json=payload)
 
     def _build_filters(
         self,
@@ -122,7 +105,7 @@ class PlatformBackend(Backend):
         run_id: str | None = None,
         extra_filters: dict | None = None,
     ) -> dict | None:
-        """Build a filters dict for v3 API endpoints.
+        """Build a filters dict for v2 API endpoints.
 
         Entity IDs are ANDed (all provided IDs must match).
         Extra filters (date ranges, categories) are also ANDed.
@@ -168,6 +151,7 @@ class PlatformBackend(Backend):
         keyword: bool = False,
         filters: dict | None = None,
         fields: list[str] | None = None,
+        enable_graph: bool = False,
     ) -> list[dict]:
         payload: dict[str, Any] = {"query": query, "top_k": top_k, "threshold": threshold}
 
@@ -186,9 +170,10 @@ class PlatformBackend(Backend):
             payload["keyword_search"] = True
         if fields:
             payload["fields"] = fields
-        payload["source"] = "CLI"
+        if enable_graph:
+            payload["enable_graph"] = True
 
-        result = self._request("POST", "/v3/memories/search/", json=payload)
+        result = self._request("POST", "/v2/memories/search/", json=payload)
         return (
             result
             if isinstance(result, list)
@@ -196,7 +181,7 @@ class PlatformBackend(Backend):
         )
 
     def get(self, memory_id: str) -> dict:
-        return self._request("GET", f"/v1/memories/{memory_id}/", params={"source": "CLI"})
+        return self._request("GET", f"/v1/memories/{memory_id}/")
 
     def list_memories(
         self,
@@ -210,11 +195,12 @@ class PlatformBackend(Backend):
         category: str | None = None,
         after: str | None = None,
         before: str | None = None,
+        enable_graph: bool = False,
     ) -> list[dict]:
         payload: dict[str, Any] = {}
         params = {"page": str(page), "page_size": str(page_size)}
 
-        # Build filters — entity IDs and date filters go inside "filters"
+        # Build filters for v2 API — entity IDs and date filters go inside "filters"
         extra: dict[str, Any] = {}
         if category:
             extra["categories"] = {"contains": category}
@@ -232,9 +218,10 @@ class PlatformBackend(Backend):
         )
         if api_filters:
             payload["filters"] = api_filters
-        payload["source"] = "CLI"
+        if enable_graph:
+            payload["enable_graph"] = True
 
-        result = self._request("POST", "/v3/memories/", json=payload, params=params)
+        result = self._request("POST", "/v2/memories/", json=payload, params=params)
         return (
             result
             if isinstance(result, list)
@@ -249,7 +236,6 @@ class PlatformBackend(Backend):
             payload["text"] = content
         if metadata:
             payload["metadata"] = metadata
-        payload["source"] = "CLI"
         return self._request("PUT", f"/v1/memories/{memory_id}/", json=payload)
 
     def delete(
@@ -263,7 +249,7 @@ class PlatformBackend(Backend):
         run_id: str | None = None,
     ) -> dict:
         if all:
-            params: dict[str, str] = {"source": "CLI"}
+            params: dict[str, str] = {}
             if user_id:
                 params["user_id"] = user_id
             if agent_id:
@@ -274,7 +260,7 @@ class PlatformBackend(Backend):
                 params["run_id"] = run_id
             return self._request("DELETE", "/v1/memories/", params=params)
         elif memory_id:
-            return self._request("DELETE", f"/v1/memories/{memory_id}/", params={"source": "CLI"})
+            return self._request("DELETE", f"/v1/memories/{memory_id}/")
         else:
             raise ValueError("Either memory_id or --all is required")
 
@@ -299,9 +285,7 @@ class PlatformBackend(Backend):
         # Delete each provided entity via the v2 path-based endpoint
         result: dict = {}
         for entity_type, entity_id in entities.items():
-            result = self._request(
-                "DELETE", f"/v2/entities/{entity_type}/{entity_id}/", params={"source": "CLI"}
-            )
+            result = self._request("DELETE", f"/v2/entities/{entity_type}/{entity_id}/")
         return result
 
     def ping(self, timeout: float | None = None) -> dict:

cli/python/src/mem0_cli/branding.py

@@ -87,12 +87,10 @@ def print_error(console: Console, message: str, hint: str | None = None) -> None
         }
         print(_json.dumps(envelope))
         return
-    from rich.markup import escape
-
     sym = _sym("✗", "[error]")
-    console.print(f"[{ERROR_COLOR}]{sym} Error:[/] {escape(str(message))}")
+    console.print(f"[{ERROR_COLOR}]{sym} Error:[/] {message}")
     if hint:
-        console.print(f"  [{DIM_COLOR}]{escape(str(hint))}[/]")
+        console.print(f"  [{DIM_COLOR}]{hint}[/]")
 
 
 def print_warning(console: Console, message: str) -> None:
@@ -148,7 +146,7 @@ def timed_status(console: Console, message: str):
             if "Authentication failed" in ctx.error_msg:
                 _err.print(
                     f"  [{DIM_COLOR}]Run [bold]mem0 init[/bold] to reconfigure your API key"
-                    f" · [bold]https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-python[/bold][/]"
+                    f" · [bold]https://app.mem0.ai/dashboard/api-keys[/bold][/]"
                 )
         raise
     else:

cli/python/src/mem0_cli/commands/agent_mode_cmd.py

@@ -1,239 +0,0 @@
-"""Agent Mode commands — bootstrap (unattended signup) and claim (OTP-based human upgrade)."""
-
-from __future__ import annotations
-
-import json
-import sys
-from datetime import datetime, timezone
-from typing import Any
-
-import httpx
-import typer
-from rich.console import Console
-from rich.prompt import Prompt
-
-from mem0_cli.branding import (
-    BRAND_COLOR,
-    DIM_COLOR,
-    print_error,
-    print_success,
-)
-from mem0_cli.config import Mem0Config, save_config
-
-console = Console()
-err_console = Console(stderr=True)
-
-_SOURCE_HEADERS = {
-    "X-Mem0-Source": "cli",
-    "X-Mem0-Client-Language": "python",
-}
-
-
-def _validate_envelope(envelope: Any) -> None:
-    """Defend against partial/malformed backend responses.
-
-    A backend regression that returns ``{"api_key": null}`` would otherwise be
-    silently persisted, producing confusing downstream errors far from the
-    source. Fail fast with a clear message if the required fields are missing.
-    """
-    if not isinstance(envelope, dict):
-        print_error(err_console, "Bootstrap response was not a JSON object.")
-        raise typer.Exit(1)
-    for field in ("api_key", "default_user_id"):
-        value = envelope.get(field)
-        if not isinstance(value, str) or not value:
-            print_error(
-                err_console,
-                f"Bootstrap response missing required field {field!r} — please update the CLI.",
-            )
-            raise typer.Exit(1)
-
-
-def bootstrap_via_backend(
-    config: Mem0Config,
-    *,
-    source: str | None = None,
-    agent_caller: str | None = None,
-) -> None:
-    """POST /api/v1/auth/agent_mode/ and mutate config in place.
-
-    Args:
-        config: Mem0Config mutated in place with the new platform values.
-        source: ``--source`` flag passthrough (analytics tag, free-form).
-        agent_caller: Self-declared agent identity passed via ``--agent-caller``
-            (e.g. ``claude-code``, ``cursor``). May be None when the caller
-            omitted the flag; the agent can backfill later via
-            ``mem0 identify <name>``. Sent to the backend in the request body
-            and saved into ``platform.agent_caller`` for local introspection.
-
-    Raises typer.Exit(1) on failure.
-    """
-    base_url = (config.platform.base_url or "https://api.mem0.ai").rstrip("/")
-    body: dict[str, Any] = {}
-    if source:
-        body["source"] = source
-    if agent_caller:
-        body["agent_caller"] = agent_caller
-
-    try:
-        with httpx.Client(timeout=30.0) as client:
-            resp = client.post(
-                f"{base_url}/api/v1/auth/agent_mode/",
-                headers={**_SOURCE_HEADERS, "Content-Type": "application/json"},
-                json=body,
-            )
-    except httpx.HTTPError as exc:
-        print_error(err_console, f"Network error contacting Mem0: {exc}")
-        raise typer.Exit(1) from exc
-
-    if resp.status_code == 429:
-        print_error(err_console, "Rate-limited. Try again in a few minutes.")
-        raise typer.Exit(1)
-    if resp.status_code == 503:
-        print_error(err_console, "Agent Mode is temporarily disabled. Try again later.")
-        raise typer.Exit(1)
-    if resp.status_code != 200:
-        detail = resp.text
-        try:
-            err_body = resp.json()
-            detail = err_body.get("error") or err_body.get("detail") or resp.text
-        except (json.JSONDecodeError, ValueError, AttributeError):
-            pass
-        # Backend's @ratelimit decorator raises PermissionDenied, which DRF
-        # translates to a generic 403 "You do not have permission to perform
-        # this action." That's opaque — surface as the rate-limit it actually is.
-        if resp.status_code == 403 and "permission" in str(detail).lower():
-            print_error(
-                err_console,
-                "Daily Agent Mode signup limit reached for this network (5/day). Try again from a different IP or after midnight UTC.",
-            )
-            raise typer.Exit(1)
-        print_error(err_console, f"Bootstrap failed: {detail}")
-        raise typer.Exit(1)
-
-    envelope = resp.json()
-    _validate_envelope(envelope)
-    config.platform.api_key = envelope["api_key"]
-    config.platform.base_url = base_url
-    config.platform.agent_mode = True
-    config.platform.created_via = "agent_mode"
-    config.platform.agent_caller = agent_caller or ""
-    config.platform.claimed_at = ""
-    config.platform.default_user_id = envelope["default_user_id"]
-    # Adopt the slug-derived user_id as the default scope for memory ops.
-    config.defaults.user_id = envelope["default_user_id"]
-    save_config(config)
-
-    print_success(console, f"Agent Mode active. Default user_id: {envelope['default_user_id']}")
-    notice = envelope.get("mem0_notice")
-    if notice:
-        console.print(f"\n[yellow]🔔 {notice}[/yellow]\n")
-    else:
-        # Fallback if the backend hasn't deployed the unified notice yet.
-        claim_cmd = envelope.get("claim_command", "mem0 init --email <your-email>")
-        console.print(f"  [{DIM_COLOR}]To claim this account later: {claim_cmd}[/]")
-
-    if not agent_caller:
-        console.print(
-            f"  [{DIM_COLOR}]If you are an AI agent, identify yourself: "
-            f"`mem0 identify <your-name>` (e.g. claude-code, cursor).[/]"
-        )
-
-
-def claim_via_otp(config: Mem0Config, *, email: str, code: str | None = None) -> None:
-    """Claim an existing Agent Mode account via OTP — no browser, no polling.
-
-    Reuses the standard email-code flow (`/api/v1/auth/email_code/` then
-    `/.../verify/`) and adds the local agent-mode API key in the verify body
-    as `agent_mode_api_key`. Backend's `verify_email_code` runs the
-    upgrade-in-place transaction inline and returns claim result.
-
-    On success: flips `platform.agent_mode=false`, sets `claimed_at`, stamps
-    `user_email`. The api_key value itself never changes.
-    """
-    base_url = (config.platform.base_url or "https://api.mem0.ai").rstrip("/")
-    if not config.platform.api_key or not config.platform.agent_mode:
-        print_error(
-            err_console,
-            "This command requires an active Agent Mode config. Run `mem0 init` first.",
-        )
-        raise typer.Exit(1)
-
-    raw_key = config.platform.api_key
-
-    with httpx.Client(timeout=30.0) as client:
-        # Step 1: request OTP (unless --code provided)
-        if not code:
-            send = client.post(
-                f"{base_url}/api/v1/auth/email_code/",
-                headers={**_SOURCE_HEADERS, "Content-Type": "application/json"},
-                json={"email": email},
-            )
-            if send.status_code == 429:
-                print_error(err_console, "Too many attempts. Try again in a few minutes.")
-                raise typer.Exit(1)
-            if send.status_code != 200:
-                try:
-                    detail = send.json().get("error", send.text)
-                except Exception:
-                    detail = send.text
-                print_error(err_console, f"Failed to send code: {detail}")
-                raise typer.Exit(1)
-
-            print_success(console, f"Verification code sent to {email}. Check your inbox.")
-
-            if not sys.stdin.isatty():
-                print_error(
-                    err_console,
-                    "No --code provided and terminal is non-interactive.",
-                    hint=f"Re-run: mem0 init --email {email} --code <code>",
-                )
-                raise typer.Exit(1)
-
-            console.print()
-            code = Prompt.ask(f"  [{BRAND_COLOR}]Verification Code[/]")
-            if not code:
-                print_error(err_console, "Code is required.")
-                raise typer.Exit(1)
-
-        # Step 2: verify + claim in one shot
-        verify = client.post(
-            f"{base_url}/api/v1/auth/email_code/verify/",
-            headers={**_SOURCE_HEADERS, "Content-Type": "application/json"},
-            json={
-                "email": email,
-                "code": code.strip(),
-                "agent_mode_api_key": raw_key,
-            },
-        )
-
-    if verify.status_code != 200:
-        try:
-            err_body = verify.json()
-            detail = err_body.get("error", verify.text)
-            code_str = err_body.get("code", "")
-        except (json.JSONDecodeError, ValueError, AttributeError):
-            detail = verify.text
-            code_str = ""
-        print_error(err_console, f"Claim failed: {detail}")
-        if code_str == "email_already_claimed":
-            console.print(
-                f"  [{DIM_COLOR}]Tip: this email already has a Mem0 account. Sign in at app.mem0.ai with your existing credentials.[/]"
-            )
-        raise typer.Exit(1)
-
-    claim_body = verify.json()
-    if not claim_body.get("claimed"):
-        print_error(err_console, f"Unexpected verify response: {claim_body}")
-        raise typer.Exit(1)
-
-    config.platform.agent_mode = False
-    config.platform.claimed_at = claim_body.get("claimed_at") or _utcnow_iso()
-    config.platform.user_email = email
-    config.platform.created_via = "email"
-    save_config(config)
-    print_success(console, f"Agent claimed to {email}. Your API key is unchanged.")
-
-
-def _utcnow_iso() -> str:
-    return datetime.now(timezone.utc).isoformat()

cli/python/src/mem0_cli/commands/agent_rush_cmd.py

@@ -1,132 +0,0 @@
-"""mem0 agent-rush — AGENTRUSH game commands.
-
-Wraps the platform's /v1/agent-rush/{memories/, memories/search/} endpoints.
-Hardcoded routing; no flags needed.
-"""
-
-from __future__ import annotations
-
-import sys
-from datetime import datetime, timezone
-
-import httpx
-import typer
-from rich.console import Console
-
-from mem0_cli.branding import print_error, print_success
-from mem0_cli.config import load_config, save_config
-
-console = Console()
-err_console = Console(stderr=True)
-
-_PII_WARNING_LINES = (
-    "",
-    "[yellow]⚠️  AGENTRUSH memories are PUBLIC — visible to any other player.[/yellow]",
-    "[yellow]   Do not include real names, emails, secrets, work content, or PII.[/yellow]",
-    "",
-)
-
-_SOURCE_HEADERS = {
-    "X-Mem0-Source": "cli",
-    "X-Mem0-Client-Language": "python",
-    "X-Mem0-Mode": "agent-rush",
-}
-
-_ERROR_HINTS = {
-    "agentrush_search_first": "Run 3 'mem0 agent-rush search' commands before adding.",
-    "agentrush_search_quota": "You've used your 3 lifetime searches.",
-    "agentrush_add_quota": "You've used your 3 lifetime adds.",
-    "agentrush_not_agent_mode": "Re-run 'mem0 init --agent' to bootstrap an agent-mode key.",
-    "agentrush_length": "Memory text must be 50-1000 characters.",
-    "agentrush_no_urls": "URLs are not allowed.",
-    "agentrush_blocklist": "Content contains a blocked term.",
-    "agentrush_global_quota": "Event-wide cap reached. Try again later.",
-    "agentrush_not_provisioned": "AGENTRUSH is not provisioned in this environment.",
-}
-
-
-def _call(path: str, body: dict) -> dict:
-    config = load_config()
-    if not config.platform.api_key:
-        print_error(err_console, "Not initialized. Run `mem0 init --agent` first.")
-        raise typer.Exit(1)
-    base_url = (config.platform.base_url or "https://api.mem0.ai").rstrip("/")
-    try:
-        with httpx.Client(timeout=30.0) as client:
-            resp = client.post(
-                f"{base_url}{path}",
-                headers={
-                    **_SOURCE_HEADERS,
-                    "Authorization": f"Token {config.platform.api_key}",
-                    "Content-Type": "application/json",
-                },
-                json=body,
-            )
-    except httpx.HTTPError as exc:
-        print_error(err_console, f"Network error: {exc}")
-        raise typer.Exit(1) from exc
-    try:
-        data = resp.json()
-    except Exception:
-        data = {}
-    if resp.status_code >= 400:
-        code = (
-            (data.get("error") or {}).get("code", "unknown")
-            if isinstance(data, dict)
-            else "unknown"
-        )
-        print_error(err_console, f"AGENTRUSH error: {code}")
-        hint = _ERROR_HINTS.get(code)
-        if hint:
-            console.print(f"  [dim]{hint}[/dim]")
-        raise typer.Exit(1)
-    return data
-
-
-def _ensure_warning_acknowledged() -> None:
-    """Block the first interactive add on the PII warning; pass-through for agents.
-
-    Interactive (TTY): show prompt, require explicit 'y', persist
-    `agent_rush.acknowledged_at` so we never ask the same machine twice.
-
-    Non-interactive (no TTY — typical when an agent runs the CLI): surface
-    the warning to stderr for the human reading the agent transcript and
-    proceed without prompting (agents can't answer y/N).
-    """
-    config = load_config()
-    if config.agent_rush.acknowledged_at:
-        return
-
-    is_tty = sys.stdin.isatty() and sys.stdout.isatty()
-    if not is_tty:
-        for line in _PII_WARNING_LINES:
-            err_console.print(line)
-        return
-
-    for line in _PII_WARNING_LINES:
-        console.print(line)
-    answer = typer.prompt("   Continue? [y/N]", default="N", show_default=False).strip().lower()
-    if answer not in ("y", "yes"):
-        print_error(err_console, "Aborted.")
-        raise typer.Exit(1)
-
-    config.agent_rush.acknowledged_at = datetime.now(timezone.utc).isoformat()
-    save_config(config)
-
-
-def run_agent_rush_add(content: str) -> None:
-    _ensure_warning_acknowledged()
-    result = _call("/v1/agent-rush/memories/", {"content": content})
-    event_id = result.get("event_id", "?")
-    print_success(console, f"Memory submitted (event_id: {event_id})")
-
-
-def run_agent_rush_search(query: str) -> None:
-    result = _call("/v1/agent-rush/memories/search/", {"query": query})
-    memories = result.get("results") or result.get("memories") or []
-    if not memories:
-        console.print("[dim](no results)[/dim]")
-        return
-    for i, m in enumerate(memories[:5], start=1):
-        text = m.get("memory") if isinstance(m, dict) else str(m)
-        console.print(f"  {i}. {text}")

cli/python/src/mem0_cli/commands/config_cmd.py

@@ -39,6 +39,7 @@ def cmd_config_show(*, output: str = "text") -> None:
                     "agent_id": config.defaults.agent_id or None,
                     "app_id": config.defaults.app_id or None,
                     "run_id": config.defaults.run_id or None,
+                    "enable_graph": config.defaults.enable_graph,
                 },
                 "platform": {
                     "api_key": redact_key(config.platform.api_key),
@@ -72,6 +73,10 @@ def cmd_config_show(*, output: str = "text") -> None:
         "defaults.run_id",
         config.defaults.run_id or f"[{DIM_COLOR}](not set)[/]",
     )
+    table.add_row(
+        "defaults.enable_graph",
+        str(config.defaults.enable_graph).lower(),
+    )
     table.add_row("", "")
 
     # Platform

cli/python/src/mem0_cli/commands/identify_cmd.py

@@ -1,75 +0,0 @@
-"""mem0 identify — declare which agent owns the current agent-mode key.
-
-Used when `mem0 init --agent` ran without --agent-caller, so the backend
-saved agent_caller=NULL. The agent re-runs `mem0 identify <name>` to PATCH
-its own row with its real identity. Idempotent — running it again just
-overwrites.
-"""
-
-from __future__ import annotations
-
-import httpx
-import typer
-from rich.console import Console
-
-from mem0_cli.branding import print_error, print_success
-from mem0_cli.config import load_config, save_config
-
-console = Console()
-err_console = Console(stderr=True)
-
-_SOURCE_HEADERS = {
-    "X-Mem0-Source": "cli",
-    "X-Mem0-Client-Language": "python",
-}
-
-
-def run_identify(name: str) -> None:
-    """PATCH the active agent-mode key's agent_caller field."""
-    config = load_config()
-    if not config.platform.api_key:
-        print_error(
-            err_console,
-            "No API key configured. Run `mem0 init --agent` first.",
-        )
-        raise typer.Exit(1)
-    if not config.platform.agent_mode:
-        print_error(
-            err_console,
-            "This command only works on unclaimed agent-mode keys.",
-        )
-        raise typer.Exit(1)
-
-    name = (name or "").strip()
-    if not name:
-        print_error(err_console, "Agent name is required.")
-        raise typer.Exit(1)
-
-    base_url = (config.platform.base_url or "https://api.mem0.ai").rstrip("/")
-    try:
-        with httpx.Client(timeout=30.0) as client:
-            resp = client.patch(
-                f"{base_url}/api/v1/auth/agent_mode/caller/",
-                headers={
-                    **_SOURCE_HEADERS,
-                    "Authorization": f"Token {config.platform.api_key}",
-                    "Content-Type": "application/json",
-                },
-                json={"agent_caller": name},
-            )
-    except httpx.HTTPError as exc:
-        print_error(err_console, f"Network error: {exc}")
-        raise typer.Exit(1) from exc
-
-    if resp.status_code != 200:
-        try:
-            detail = resp.json().get("error", resp.text)
-        except Exception:
-            detail = resp.text
-        print_error(err_console, f"Identify failed: {detail}")
-        raise typer.Exit(1)
-
-    canonical = resp.json().get("agent_caller", name)
-    config.platform.agent_caller = canonical
-    save_config(config)
-    print_success(console, f"Identified as {canonical}.")

cli/python/src/mem0_cli/commands/init_cmd.py

@@ -19,13 +19,7 @@ from mem0_cli.branding import (
     print_info,
     print_success,
 )
-from mem0_cli.config import (
-    CONFIG_FILE,
-    DEFAULT_BASE_URL,
-    Mem0Config,
-    load_config,
-    save_config,
-)
+from mem0_cli.config import CONFIG_FILE, DEFAULT_BASE_URL, Mem0Config, load_config, save_config
 
 console = Console()
 err_console = Console(stderr=True)
@@ -103,25 +97,6 @@ def _validate_email(email: str) -> None:
         raise typer.Exit(1)
 
 
-def _ping_key(api_key: str, base_url: str, timeout: float = 5.0) -> bool:
-    """Validate api_key against /v1/ping/.
-
-    Returns False ONLY on a definitive "invalid key" signal (HTTP 401 / 403).
-    Network errors, timeouts, and 5xx responses return True so we prefer
-    reusing an existing key over silently minting a new shadow on a transient
-    blip (which would also clobber config + plugin-sync targets).
-    """
-    try:
-        resp = httpx.get(
-            f"{base_url.rstrip('/')}/v1/ping/",
-            headers={"Authorization": f"Token {api_key}"},
-            timeout=timeout,
-        )
-    except httpx.HTTPError:
-        return True  # unknown — prefer reuse
-    return resp.status_code not in (401, 403)
-
-
 def _email_login(
     email: str,
     code: str | None,
@@ -201,143 +176,21 @@ def run_init(
     email: str | None = None,
     code: str | None = None,
     force: bool = False,
-    source: str | None = None,
-    agent: bool = False,
-    agent_caller: str | None = None,
 ) -> None:
     """Interactive setup wizard for mem0 CLI.
 
     When both *api_key* and *user_id* are supplied, all prompts are skipped
     (non-interactive mode).  When running in a non-TTY without the required
     flags, an error message is printed.
-
-    Agent Mode dispatch (no email/api-key flags):
-      - If existing config has an active API key → reuse (existing_key path).
-      - Else if any positive agent signal (--agent, --json global, agent env
-        var, or `agent` flag) → POST /api/v1/auth/agent_mode/ and write config.
-      - Else fall through to the interactive wizard.
-
-    Claim dispatch:
-      - If `--email` is set AND existing config has `agent_mode=true`, run the
-        claim device-flow against the existing key instead of minting a new
-        email-based key.
     """
-    from mem0_cli.agent_detect import detect_agent_caller
-    from mem0_cli.commands.agent_mode_cmd import bootstrap_via_backend, claim_via_otp
-    from mem0_cli.state import is_agent_mode as _global_agent_mode
-    from mem0_cli.telemetry import capture_event
-
-    def _fire_init(mode: str, *, claimed: bool = False) -> None:
-        """Fire cli.init telemetry with M1-M6 properties."""
-        props: dict = {"command": "init", "mode": mode}
-        if agent_caller:
-            # Self-declared via --agent-caller; not sniffed from env vars.
-            props["agent_caller"] = agent_caller
-        if source:
-            props["signup_source"] = source
-        if claimed:
-            props["claimed_agent_mode"] = True
-        capture_event("cli.init", props)
-
     config = Mem0Config()
 
     base_url = os.environ.get("MEM0_BASE_URL", config.platform.base_url or DEFAULT_BASE_URL)
-    config.platform.base_url = base_url
 
     if code and not email:
         print_error(err_console, "--code requires --email.")
         raise typer.Exit(1)
 
-    # ── Email + existing agent-mode config → claim flow ─────────────────
-    if email and CONFIG_FILE.exists():
-        existing = load_config()
-        if existing.platform.agent_mode and existing.platform.api_key:
-            email = email.strip().lower()
-            _validate_email(email)
-            print_info(console, f"Claiming Agent Mode account to {email}...")
-            claim_via_otp(existing, email=email, code=code)
-            _fire_init("email", claimed=True)
-            return
-
-    # ── Agent Mode path runs BEFORE the existing-config guard ──────────
-    # Rules 1/2 REUSE a valid existing key (not overwrite), so we must
-    # short-circuit before the guard prompts. Rule 3 mints only when there
-    # is no valid key to reuse — in that case overwriting is correct.
-    _agent_ctx = agent or _global_agent_mode() or (detect_agent_caller() is not None)
-    if not api_key and not email and _agent_ctx:
-        from mem0_cli.output import format_json_envelope
-        from mem0_cli.state import is_agent_mode as _is_json_mode
-
-        def _emit_reuse(source: str) -> None:
-            if _is_json_mode():
-                format_json_envelope(
-                    console,
-                    command="init",
-                    data={
-                        "api_key_saved": False,
-                        "api_key_source": source,
-                        "agent_mode": False,
-                        "message": "Existing Mem0 API key found and reused. No Agent Mode key was created.",
-                    },
-                )
-            else:
-                msg = (
-                    "Existing MEM0_API_KEY is valid; reusing it. No new Agent Mode key was minted."
-                    if source == "env"
-                    else "Existing API key in config is valid; reusing it. No new Agent Mode key was minted."
-                )
-                print_success(console, msg)
-
-        def _maybe_identify(key: str) -> None:
-            """Best-effort PATCH agent_caller when --agent-caller is supplied on a
-            reused key. Silent no-op on any failure — reuse must not break.
-            """
-            if not agent_caller:
-                return
-            try:
-                resp = httpx.patch(
-                    f"{base_url.rstrip('/')}/api/v1/auth/agent_mode/caller/",
-                    headers={
-                        "Authorization": f"Token {key}",
-                        "Content-Type": "application/json",
-                    },
-                    json={"agent_caller": agent_caller},
-                    timeout=10.0,
-                )
-                # Also reflect in local config so introspection matches backend.
-                if resp.status_code == 200 and CONFIG_FILE.exists():
-                    try:
-                        cfg = load_config()
-                        cfg.platform.agent_caller = resp.json().get("agent_caller", agent_caller)
-                        save_config(cfg)
-                    except Exception:
-                        pass
-            except httpx.HTTPError:
-                pass
-
-        # Rule 1: env MEM0_API_KEY valid → reuse, no new key.
-        _env_key = (os.environ.get("MEM0_API_KEY") or "").strip()
-        if _env_key and _ping_key(_env_key, base_url):
-            _maybe_identify(_env_key)
-            _emit_reuse("env")
-            _fire_init("existing_key")
-            return
-        # Rule 2: existing config api_key valid → reuse.
-        if CONFIG_FILE.exists():
-            _existing = load_config()
-            if _existing.platform.api_key and _ping_key(_existing.platform.api_key, base_url):
-                _maybe_identify(_existing.platform.api_key)
-                _emit_reuse("config")
-                _fire_init("existing_key")
-                return
-        # Rule 3: mint a fresh shadow (no valid key to reuse).
-        # agent_caller is the agent's self-declared identity from --agent-caller
-        # (Proof Editor-style). Env-var auto-detect is still used above to
-        # decide we're in an agent context, but never to fill identity.
-        bootstrap_via_backend(config, source=source, agent_caller=agent_caller)
-        _fire_init("agent")
-        return
-
     # Warn if an existing config with an API key would be overwritten
     if not force and CONFIG_FILE.exists():
         existing = load_config()
@@ -383,7 +236,6 @@ def run_init(
         config.platform.api_key = api_key_val
         config.platform.base_url = base_url
         config.platform.user_email = email
-        config.platform.created_via = "email"
         config.defaults.user_id = (
             user_id or os.environ.get("USER") or os.environ.get("USERNAME") or "mem0-cli"
         )
@@ -400,8 +252,6 @@ def run_init(
         return
 
     # ── API key flow (existing) ───────────────────────────────────────
-    # (Agent Mode branch runs earlier — see above, before the existing-config
-    # guard, so Rules 1/2 can REUSE a valid key without prompting overwrite.)
 
     # Non-TTY: resolve defaults so partial flags work in pipelines / CI
     if not sys.stdin.isatty():
@@ -409,7 +259,7 @@ def run_init(
             print_error(
                 err_console,
                 "Non-interactive terminal detected and --api-key is required.",
-                hint="Run: mem0 init --api-key <key>, --email <addr>, or --agent for unattended Agent Mode bootstrap.",
+                hint="Run: mem0 init --api-key <key> [--user-id <id>]",
             )
             raise typer.Exit(1)
         user_id = user_id or os.environ.get("USER") or os.environ.get("USERNAME") or "mem0-cli"
@@ -417,7 +267,6 @@ def run_init(
     # Fully non-interactive when both flags provided
     if api_key and user_id:
         config.platform.api_key = api_key
-        config.platform.created_via = "api_key"
         config.defaults.user_id = user_id
         _validate_platform(config)
         save_config(config)
@@ -458,7 +307,6 @@ def run_init(
             config.platform.api_key = api_key_val
             config.platform.base_url = base_url
             config.platform.user_email = email_addr
-            config.platform.created_via = "email"
             config.defaults.user_id = (
                 user_id or os.environ.get("USER") or os.environ.get("USERNAME") or "mem0-cli"
             )
@@ -477,7 +325,6 @@ def run_init(
     # API key flow
     if api_key:
         config.platform.api_key = api_key
-        config.platform.created_via = "api_key"
     else:
         _setup_platform(config)
 
@@ -505,9 +352,7 @@ def run_init(
 def _setup_platform(config: Mem0Config) -> None:
     """Platform setup flow."""
     console.print()
-    console.print(
-        f"  [{DIM_COLOR}]Get your API key at https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-python[/]"
-    )
+    console.print(f"  [{DIM_COLOR}]Get your API key at https://app.mem0.ai/dashboard/api-keys[/]")
     console.print()
 
     console.print(f"  [{BRAND_COLOR}]API Key[/]: ", end="")
@@ -517,7 +362,6 @@ def _setup_platform(config: Mem0Config) -> None:
         raise typer.Exit(1)
 
     config.platform.api_key = api_key
-    config.platform.created_via = "api_key"
 
 
 def _setup_defaults(config: Mem0Config) -> None:
@@ -560,7 +404,7 @@ def _validate_platform(config: Mem0Config) -> None:
             print_error(
                 err_console,
                 f"Could not connect: {status.get('error', 'Unknown error')}",
-                hint="Visit https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-python to get a new key, then run mem0 init again.",
+                hint="Visit https://app.mem0.ai/dashboard/api-keys to get a new key, then run mem0 init again.",
             )
     except Exception as e:
         print_error(err_console, f"Connection test failed: {e}")

cli/python/src/mem0_cli/commands/memory.py

@@ -62,6 +62,7 @@ def cmd_add(
     no_infer: bool,
     expires: str | None,
     categories: str | None,
+    enable_graph: bool = False,
     output: str = "text",
 ) -> None:
     """Add a memory."""
@@ -144,6 +145,7 @@ def cmd_add(
                 infer=not no_infer,
                 expires=expires,
                 categories=cats,
+                enable_graph=enable_graph,
             )
         except Exception as e:
             ts.error_msg = str(e)
@@ -224,6 +226,7 @@ def cmd_search(
     keyword: bool,
     filter_json: str | None,
     fields: str | None,
+    enable_graph: bool = False,
     output: str = "text",
 ) -> None:
     """Search memories."""
@@ -266,6 +269,7 @@ def cmd_search(
                 keyword=keyword,
                 filters=filters,
                 fields=field_list,
+                enable_graph=enable_graph,
             )
         except Exception as e:
             print_error(err_console, str(e))
@@ -352,6 +356,7 @@ def cmd_list(
     category: str | None,
     after: str | None,
     before: str | None,
+    enable_graph: bool = False,
     output: str = "table",
 ) -> None:
     """List memories."""
@@ -380,6 +385,7 @@ def cmd_list(
                 category=category,
                 after=after,
                 before=before,
+                enable_graph=enable_graph,
             )
         except Exception as e:
             print_error(err_console, str(e))

cli/python/src/mem0_cli/commands/utils.py

@@ -77,7 +77,7 @@ def cmd_status(
                 f"  [{DIM_COLOR}]Run [bold]mem0 init[/bold] to reconfigure your API key[/]"
             )
             lines.append(
-                f"  [{DIM_COLOR}]Get a key at [bold]https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=cli-python[/bold][/]"
+                f"  [{DIM_COLOR}]Get a key at [bold]https://app.mem0.ai/dashboard/api-keys[/bold][/]"
             )
     lines.append(f"  [{DIM_COLOR}]Latency:[/]  {_elapsed:.2f}s")
 

cli/python/src/mem0_cli/commands/whoami_cmd.py

@@ -1,25 +0,0 @@
-"""mem0 whoami — print the active agent's default_user_id (AGENTRUSH identifier)."""
-
-from __future__ import annotations
-
-import typer
-from rich.console import Console
-
-from mem0_cli.branding import BRAND_COLOR, print_error, print_info
-from mem0_cli.config import load_config
-
-console = Console()
-err_console = Console(stderr=True)
-
-
-def run_whoami() -> None:
-    config = load_config()
-    session_id = config.platform.default_user_id if config.platform else None
-    if not session_id:
-        print_error(
-            err_console,
-            "No default_user_id found. Run `mem0 init --agent` first.",
-        )
-        raise typer.Exit(1)
-    console.print(f"Your AGENTRUSH identifier:  [{BRAND_COLOR}]{session_id}[/{BRAND_COLOR}]")
-    print_info(console, "Find your row at https://mem0.ai/agentrush")

cli/python/src/mem0_cli/config.py

@@ -28,14 +28,6 @@ class PlatformConfig:
     api_key: str = ""
     base_url: str = DEFAULT_BASE_URL
     user_email: str = ""
-    # Agent Mode (unclaimed-shadow signup)
-    agent_mode: bool = False  # True while the key is an unclaimed agent-mode key
-    created_via: str = ""  # "agent_mode" | "email" | "api_key" | "existing_key"
-    agent_caller: str = (
-        ""  # canonical agent name when created_via == "agent_mode" (e.g. "claude-code")
-    )
-    claimed_at: str = ""  # ISO timestamp once the agent has been claimed by a human
-    default_user_id: str = ""  # `user_<slug>` returned by bootstrap; used as auto-default
 
 
 @dataclass
@@ -44,18 +36,7 @@ class DefaultsConfig:
     agent_id: str = ""
     app_id: str = ""
     run_id: str = ""
-
-
-@dataclass
-class TelemetryConfig:
-    anonymous_id: str = ""
-
-
-@dataclass
-class AgentRushConfig:
-    # ISO timestamp the human acknowledged the "memories are public" warning.
-    # Empty until first interactive `mem0 agent-rush add`.
-    acknowledged_at: str = ""
+    enable_graph: bool = False
 
 
 @dataclass
@@ -63,8 +44,6 @@ class Mem0Config:
     version: int = CONFIG_VERSION
     defaults: DefaultsConfig = field(default_factory=DefaultsConfig)
     platform: PlatformConfig = field(default_factory=PlatformConfig)
-    telemetry: TelemetryConfig = field(default_factory=TelemetryConfig)
-    agent_rush: AgentRushConfig = field(default_factory=AgentRushConfig)
 
 
 SHORT_KEY_ALIASES: dict[str, str] = {
@@ -75,6 +54,7 @@ SHORT_KEY_ALIASES: dict[str, str] = {
     "agent_id": "defaults.agent_id",
     "app_id": "defaults.app_id",
     "run_id": "defaults.run_id",
+    "enable_graph": "defaults.enable_graph",
 }
 
 
@@ -99,22 +79,13 @@ def load_config() -> Mem0Config:
         config.platform.api_key = plat.get("api_key", "")
         config.platform.base_url = plat.get("base_url", DEFAULT_BASE_URL)
         config.platform.user_email = plat.get("user_email", "")
-        config.platform.agent_mode = bool(plat.get("agent_mode", False))
-        config.platform.created_via = plat.get("created_via", "")
-        config.platform.agent_caller = plat.get("agent_caller", "")
-        config.platform.claimed_at = plat.get("claimed_at", "")
-        config.platform.default_user_id = plat.get("default_user_id", "")
 
         defaults = data.get("defaults", {})
         config.defaults.user_id = defaults.get("user_id", "")
         config.defaults.agent_id = defaults.get("agent_id", "")
         config.defaults.app_id = defaults.get("app_id", "")
         config.defaults.run_id = defaults.get("run_id", "")
-        telemetry = data.get("telemetry", {})
-        config.telemetry.anonymous_id = telemetry.get("anonymous_id", "")
-
-        agent_rush = data.get("agent_rush", {})
-        config.agent_rush.acknowledged_at = agent_rush.get("acknowledged_at", "")
+        config.defaults.enable_graph = defaults.get("enable_graph", False)
 
     # Environment variable overrides
     env_key = os.environ.get("MEM0_API_KEY")
@@ -141,6 +112,10 @@ def load_config() -> Mem0Config:
     if env_run_id:
         config.defaults.run_id = env_run_id
 
+    env_graph = os.environ.get("MEM0_ENABLE_GRAPH")
+    if env_graph:
+        config.defaults.enable_graph = env_graph.lower() in ("true", "1", "yes")
+
     return config
 
 
@@ -155,22 +130,12 @@ def save_config(config: Mem0Config) -> None:
             "agent_id": config.defaults.agent_id,
             "app_id": config.defaults.app_id,
             "run_id": config.defaults.run_id,
+            "enable_graph": config.defaults.enable_graph,
         },
         "platform": {
             "api_key": config.platform.api_key,
             "base_url": config.platform.base_url,
             "user_email": config.platform.user_email,
-            "agent_mode": config.platform.agent_mode,
-            "created_via": config.platform.created_via,
-            "agent_caller": config.platform.agent_caller,
-            "claimed_at": config.platform.claimed_at,
-            "default_user_id": config.platform.default_user_id,
-        },
-        "telemetry": {
-            "anonymous_id": config.telemetry.anonymous_id,
-        },
-        "agent_rush": {
-            "acknowledged_at": config.agent_rush.acknowledged_at,
         },
     }
 
@@ -179,19 +144,6 @@ def save_config(config: Mem0Config) -> None:
 
     os.chmod(CONFIG_FILE, stat.S_IRUSR | stat.S_IWUSR)  # 0600
 
-    # Propagate the active api_key to ecosystem touchpoints (Claude Code
-    # plugin env injection, shell rc exports). Idempotent — only updates
-    # EXISTING entries; never creates new ones. Best-effort: any IOError
-    # in the sync is swallowed so config.json is always the authoritative
-    # write, never blocked by plugin-state issues.
-    if config.platform.api_key:
-        try:
-            from mem0_cli.plugin_sync import sync_api_key
-
-            sync_api_key(config.platform.api_key)
-        except Exception:
-            pass
-
 
 def redact_key(key: str) -> str:
     """Redact an API key for display: m0-xxx...xxx"""

cli/python/src/mem0_cli/output.py

@@ -229,16 +229,6 @@ def format_json_envelope(
     if error:
         envelope["error"] = error
     envelope["data"] = data
-
-    # If the platform flagged this as an unclaimed Agent Mode account, surface
-    # the notice inside the JSON envelope so an agent consuming the output
-    # sees it without needing to inspect HTTP headers.
-    from mem0_cli.state import take_notice
-
-    notice = take_notice()
-    if notice:
-        envelope["mem0_notice"] = notice
-
     console.print_json(json.dumps(envelope, default=str))
 
 
@@ -333,15 +323,6 @@ def format_agent_envelope(
     if count is not None:
         envelope["count"] = count
     envelope["data"] = sanitize_agent_data(command, data)
-
-    # Surface the unclaimed-Agent-Mode notice (if any) in the envelope so an
-    # agent reading the JSON output sees it without inspecting HTTP headers.
-    from mem0_cli.state import take_notice
-
-    notice = take_notice()
-    if notice:
-        envelope["mem0_notice"] = notice
-
     console.print_json(json.dumps(envelope, default=str))
 
 

cli/python/src/mem0_cli/plugin_sync.py

@@ -1,119 +0,0 @@
-"""Sync the active Mem0 API key into other ecosystem touchpoints.
-
-Why this exists:
-  The CLI canonical state lives in ``~/.mem0/config.json``. But MCP servers
-  (Claude Code plugin, Codex plugin, etc.) read ``MEM0_API_KEY`` from env
-  vars or their own config files. Without a sync, an agent-mode bootstrap
-  mints a new key into config.json but the plugin's MCP keeps using the
-  old key from env — silent surprise.
-
-Design:
-  - Update ONLY entries that already exist (never create new ones)
-  - Preserve all surrounding content / formatting / other keys
-  - Atomic writes (tmpfile + rename) so a crash mid-write doesn't corrupt
-  - Idempotent — re-running with the same key is a no-op
-  - Skip on dry_run
-
-Targets currently handled:
-  - ``~/.claude/settings.json::env::MEM0_API_KEY`` (Claude Code env injection)
-  - ``~/.zshrc`` / ``~/.bashrc`` ``export MEM0_API_KEY="..."`` lines
-
-Out of scope (deliberately not touched):
-  - Codex / Cursor MCP configs — would require schema-aware edits and
-    those tools don't have mem0 entries by default
-  - Plugin's own ``<plugin-dir>/.api_key`` file — plugin-managed
-"""
-
-from __future__ import annotations
-
-import contextlib
-import json
-import os
-import re
-import tempfile
-from pathlib import Path
-
-# Files we know how to update safely.
-_CLAUDE_SETTINGS = Path.home() / ".claude" / "settings.json"
-_SHELL_RCS = [Path.home() / ".zshrc", Path.home() / ".bashrc", Path.home() / ".bash_profile"]
-
-
-def sync_api_key(api_key: str) -> list[str]:
-    """Propagate ``api_key`` into known ecosystem touchpoints.
-
-    Returns the list of paths actually updated. Empty list means nothing
-    needed updating (either targets didn't exist or already had this value).
-    """
-    if not api_key:
-        return []
-    updated: list[str] = []
-    if _update_claude_settings(_CLAUDE_SETTINGS, api_key):
-        updated.append(str(_CLAUDE_SETTINGS))
-    for rc in _SHELL_RCS:
-        if _update_shell_rc(rc, api_key):
-            updated.append(str(rc))
-    return updated
-
-
-def _update_claude_settings(path: Path, api_key: str) -> bool:
-    """Update ``env.MEM0_API_KEY`` in path. Returns True if file was changed."""
-    if not path.is_file():
-        return False
-    try:
-        with path.open("r", encoding="utf-8") as f:
-            data = json.load(f)
-    except (json.JSONDecodeError, OSError):
-        return False
-    env = data.get("env")
-    if not isinstance(env, dict) or "MEM0_API_KEY" not in env:
-        # No existing entry — don't create one.
-        return False
-    if env["MEM0_API_KEY"] == api_key:
-        return False  # already in sync
-    env["MEM0_API_KEY"] = api_key
-    _atomic_write_text(path, json.dumps(data, indent=2, ensure_ascii=False) + "\n")
-    return True
-
-
-# Match `export MEM0_API_KEY="..."` (or single quotes, or no quotes).
-# Use [ \t]* (not \s*) for trailing whitespace so a trailing newline at
-# end-of-file is preserved when MEM0_API_KEY is the last line.
-_RC_LINE = re.compile(
-    r'^([ \t]*export[ \t]+MEM0_API_KEY[ \t]*=[ \t]*)(["\']?)([^"\'\n]*)(["\']?)[ \t]*$',
-    re.MULTILINE,
-)
-
-
-def _update_shell_rc(path: Path, api_key: str) -> bool:
-    """Update an existing ``export MEM0_API_KEY=...`` line in path."""
-    if not path.is_file():
-        return False
-    try:
-        text = path.read_text(encoding="utf-8")
-    except OSError:
-        return False
-    match = _RC_LINE.search(text)
-    if not match:
-        return False  # no existing line
-    if match.group(3) == api_key:
-        return False
-    new_text = _RC_LINE.sub(lambda m: f'{m.group(1)}"{api_key}"', text, count=1)
-    _atomic_write_text(path, new_text)
-    return True
-
-
-def _atomic_write_text(path: Path, content: str) -> None:
-    """Write content to path atomically (temp + rename)."""
-    dirname = path.parent
-    fd, tmp_path = tempfile.mkstemp(prefix=f".{path.name}.", suffix=".tmp", dir=dirname)
-    try:
-        with os.fdopen(fd, "w", encoding="utf-8") as f:
-            f.write(content)
-        # Preserve mode if the original existed.
-        if path.exists():
-            os.chmod(tmp_path, path.stat().st_mode & 0o777)
-        os.replace(tmp_path, path)
-    except Exception:
-        with contextlib.suppress(OSError):
-            os.unlink(tmp_path)
-        raise

cli/python/src/mem0_cli/state.py

@@ -4,7 +4,6 @@ from __future__ import annotations
 
 _agent_mode: bool = False
 _current_command: str = ""
-_pending_notice: str = ""
 
 
 def is_agent_mode() -> bool:
@@ -23,23 +22,3 @@ def get_current_command() -> str:
 def set_current_command(name: str) -> None:
     global _current_command
     _current_command = name
-
-
-def capture_notice(notice: str | None) -> None:
-    """Stash a Mem0 backend notice for end-of-command surfacing.
-
-    Called from the platform backend after each response so the notice can
-    be printed once per command (regardless of how many sub-requests fired).
-    Last-write-wins is fine — the message text is identical across requests.
-    """
-    global _pending_notice
-    if notice:
-        _pending_notice = notice
-
-
-def take_notice() -> str:
-    """Return and clear the pending notice."""
-    global _pending_notice
-    msg = _pending_notice
-    _pending_notice = ""
-    return msg

cli/python/src/mem0_cli/telemetry.py

@@ -9,14 +9,12 @@ Disable with: MEM0_TELEMETRY=false
 
 from __future__ import annotations
 
-import contextlib
 import hashlib
 import json
 import os
 import platform
 import subprocess
 import sys
-import uuid
 from typing import Any
 
 POSTHOG_API_KEY = "phc_hgJkUVJFYtmaJqrvf6CYN67TIQ8yhXAkWzUn9AMU4yX"
@@ -28,31 +26,11 @@ def _is_telemetry_enabled() -> bool:
     return val not in ("false", "0", "no")
 
 
-def _get_or_create_anonymous_id() -> str:
-    """Return a persistent per-machine anonymous ID, generating one if needed.
-
-    Stored in ~/.mem0/config.json under `telemetry.anonymous_id` so that
-    repeat runs on the same machine share one PostHog identity instead of
-    collapsing into a single shared fallback string.
-    """
-    from mem0_cli.config import load_config, save_config
-
-    config = load_config()
-    if config.telemetry.anonymous_id:
-        return config.telemetry.anonymous_id
-
-    new_id = f"cli-anon-{uuid.uuid4().hex}"
-    config.telemetry.anonymous_id = new_id
-    with contextlib.suppress(Exception):
-        save_config(config)
-    return new_id
-
-
 def _get_distinct_id() -> str:
     """Return a stable anonymous identifier for the current user.
 
-    Priority: cached user_email (from /v1/ping/) > MD5(api_key) >
-    persistent per-machine anonymous ID.
+    Priority: cached user_email (from /v1/ping/) > MD5(api_key) > fallback.
+    Matches the SDK pattern in mem0/client/main.py.
     """
     try:
         from mem0_cli.config import load_config
@@ -64,10 +42,7 @@ def _get_distinct_id() -> str:
             return hashlib.md5(config.platform.api_key.encode()).hexdigest()
     except Exception:
         pass
-    try:
-        return _get_or_create_anonymous_id()
-    except Exception:
-        return f"cli-anon-{uuid.uuid4().hex}"
+    return "anonymous-cli"
 
 
 def capture_event(
@@ -86,29 +61,12 @@ def capture_event(
 
     try:
         from mem0_cli import __version__
-        from mem0_cli.config import CONFIG_FILE, load_config, save_config
+        from mem0_cli.config import CONFIG_FILE, load_config
+        from mem0_cli.state import is_agent_mode
 
         config = load_config()
         distinct_id = pre_resolved_email or _get_distinct_id()
 
-        # Detect anonymous → identified transition. If a stored anonymous_id
-        # exists and we just resolved to a real identity, fire a one-shot
-        # $identify event so PostHog stitches the pre-signup history onto
-        # the authenticated profile. Clear the stored id so we don't re-alias.
-        anon_id_to_alias: str | None = None
-        if (
-            distinct_id
-            and not distinct_id.startswith("cli-anon-")
-            and config.telemetry.anonymous_id
-        ):
-            anon_id_to_alias = config.telemetry.anonymous_id
-            config.telemetry.anonymous_id = ""
-            with contextlib.suppress(Exception):
-                save_config(config)
-
-        # M4: every cli.* event carries agent_mode based on the config flag
-        # (unclaimed Agent Mode key). This is the growth-doc property used to
-        # join init → add → search funnels in PostHog.
         payload = {
             "api_key": POSTHOG_API_KEY,
             "distinct_id": distinct_id,
@@ -117,7 +75,7 @@ def capture_event(
                 "source": "CLI",
                 "language": "python",
                 "cli_version": __version__,
-                "agent_mode": bool(config.platform.agent_mode),
+                "agent_mode": is_agent_mode(),
                 "python_version": sys.version,
                 "os": sys.platform,
                 "os_version": platform.version(),
@@ -134,22 +92,14 @@ def capture_event(
             "mem0_api_key": config.platform.api_key or "",
             "mem0_base_url": config.platform.base_url or "https://api.mem0.ai",
             "config_path": str(CONFIG_FILE),
-            "anon_distinct_id_to_alias": anon_id_to_alias,
         }
 
-        child = subprocess.Popen(
-            [sys.executable, "-m", "mem0_cli.telemetry_sender"],
-            stdin=subprocess.PIPE,
+        subprocess.Popen(
+            [sys.executable, "-m", "mem0_cli.telemetry_sender", json.dumps(context)],
             stdout=subprocess.DEVNULL,
             stderr=subprocess.DEVNULL,
             start_new_session=True,
             close_fds=True,
-            text=True,
         )
-        if child.stdin:
-            with contextlib.suppress(Exception):
-                child.stdin.write(json.dumps(context))
-            with contextlib.suppress(Exception):
-                child.stdin.close()
     except Exception:
         pass

cli/python/src/mem0_cli/telemetry_sender.py

@@ -1,7 +1,6 @@
 """Standalone telemetry sender — runs as a detached subprocess.
 
-Usage: python -m mem0_cli.telemetry_sender   (JSON context is read from stdin;
-a single argv argument is still accepted as a legacy fallback)
+Usage: python -m mem0_cli.telemetry_sender '<json context>'
 
 This module is spawned by telemetry.capture_event() and runs independently
 of the parent CLI process. It:
@@ -21,48 +20,16 @@ import sys
 import urllib.request
 
 
-def _load_context() -> dict:
-    """Load telemetry context from stdin, falling back to argv for compatibility."""
-    raw = ""
-    if not sys.stdin.isatty():
-        raw = sys.stdin.read().strip()
-    if not raw and len(sys.argv) > 1:
-        raw = sys.argv[1]
-    return json.loads(raw)
-
-
 def main() -> None:
-    ctx = _load_context()
+    ctx = json.loads(sys.argv[1])
     payload = ctx["payload"]
 
     if ctx.get("needs_email") and ctx.get("mem0_api_key"):
         _resolve_and_cache_email(ctx, payload)
 
-    # Fire $identify *after* email resolution so PostHog links the stored
-    # anonymous id directly to the final identity (email, not the api-key
-    # hash). The regular event is sent next so it lands under the merged
-    # profile.
-    anon_id = ctx.get("anon_distinct_id_to_alias")
-    if anon_id:
-        _send_identify_event(ctx, payload, anon_id)
-
     _send_posthog_event(ctx["posthog_host"], payload)
 
 
-def _send_identify_event(ctx: dict, payload: dict, anon_id: str) -> None:
-    """Send a PostHog $identify event aliasing anon_id → payload['distinct_id']."""
-    identify_payload = {
-        "api_key": payload["api_key"],
-        "event": "$identify",
-        "distinct_id": payload["distinct_id"],
-        "properties": {
-            "$anon_distinct_id": anon_id,
-            "$lib": payload.get("properties", {}).get("$lib", "posthog-python"),
-        },
-    }
-    _send_posthog_event(ctx["posthog_host"], identify_payload)
-
-
 def _resolve_and_cache_email(ctx: dict, payload: dict) -> None:
     """Call /v1/ping/ to get the user's email, update the payload, and cache it."""
     try:

cli/python/tests/test_agent_mode.py

@@ -1,160 +0,0 @@
-"""Parity tests for `mem0 init --agent` (Agent Mode bootstrap).
-
-Mirror of ``cli/node/tests/agent-mode.test.ts`` — both files MUST stay in
-sync so that the Python and Node CLIs expose an identical surface for the
-Agent Mode entrypoint. If you add a flag here, add the same assertion on
-the Node side (and vice versa).
-
-Network-bound bootstrap is covered by the platform-side E2E suite
-(``backend/tests/e2e/test_05_agent_mode.py``); these tests only verify
-the CLI surface that ships in the binary.
-"""
-
-from __future__ import annotations
-
-import os
-import re
-import subprocess
-import sys
-
-import pytest
-
-_ANSI_RE = re.compile(r"\x1b\[[0-9;]*[mKJHABCDfsu]")
-
-
-def _strip_ansi(text: str) -> str:
-    return _ANSI_RE.sub("", text)
-
-
-def _run(args: list[str], home_dir: str | None = None) -> subprocess.CompletedProcess:
-    env = os.environ.copy()
-    for key in list(env.keys()):
-        if key.startswith("MEM0_"):
-            del env[key]
-    env.pop("FORCE_COLOR", None)
-    env["PYTHONIOENCODING"] = "utf-8"
-    if home_dir:
-        env["HOME"] = home_dir
-    result = subprocess.run(
-        [sys.executable, "-m", "mem0_cli", *args],
-        capture_output=True,
-        encoding="utf-8",
-        env=env,
-        timeout=15,
-    )
-    return subprocess.CompletedProcess(
-        args=result.args,
-        returncode=result.returncode,
-        stdout=_strip_ansi(result.stdout),
-        stderr=_strip_ansi(result.stderr),
-    )
-
-
-@pytest.fixture
-def clean_home(tmp_path):
-    return str(tmp_path)
-
-
-class TestInitFlagSurface:
-    """`mem0 init --help` must expose the Agent Mode flags."""
-
-    def test_init_help_lists_agent_flag(self):
-        result = _run(["init", "--help"])
-        assert result.returncode == 0
-        assert "--agent" in result.stdout
-
-    def test_init_help_describes_agent_mode(self):
-        result = _run(["init", "--help"])
-        assert result.returncode == 0
-        # Description must mention what --agent actually does so an agent
-        # reading the help can self-discover the bootstrap entrypoint.
-        assert "Agent Mode" in result.stdout or "unattended" in result.stdout.lower()
-
-    def test_init_help_lists_source_flag(self):
-        result = _run(["init", "--help"])
-        assert result.returncode == 0
-        assert "--source" in result.stdout
-
-    def test_init_help_lists_email_and_code(self):
-        # Claim flow flags must remain present alongside Agent Mode flags.
-        result = _run(["init", "--help"])
-        assert result.returncode == 0
-        assert "--email" in result.stdout
-        assert "--code" in result.stdout
-
-
-class TestArgvPreprocessing:
-    """`--agent` on `init` must reach init_cmd, not be eaten by the global preprocessor.
-
-    Regression for the bug where the top-level `--agent` JSON-alias was
-    stripped from ``sys.argv`` before Typer could bind it to the init
-    subcommand, making ``mem0 init --agent`` indistinguishable from a
-    plain ``mem0 init`` (interactive wizard).
-    """
-
-    def test_init_with_agent_reaches_subcommand(self, clean_home):
-        # We can't hit a real backend in unit tests, so we point the CLI at
-        # a guaranteed-dead URL and assert the failure is the bootstrap
-        # request failing — proving the --agent flag was honored and the
-        # bootstrap branch ran, not the interactive wizard.
-        result = subprocess.run(
-            [sys.executable, "-m", "mem0_cli", "init", "--agent"],
-            capture_output=True,
-            encoding="utf-8",
-            env={
-                **{k: v for k, v in os.environ.items() if not k.startswith("MEM0_")},
-                "HOME": clean_home,
-                "MEM0_BASE_URL": "http://127.0.0.1:1",  # blackhole
-                "FORCE_COLOR": "0",
-                "PYTHONIOENCODING": "utf-8",
-            },
-            timeout=15,
-        )
-        combined = _strip_ansi(result.stdout + result.stderr).lower()
-        # Either we got a connection/network error from the bootstrap POST,
-        # or the CLI surfaced an Agent Mode-specific failure message.
-        assert (
-            "agent" in combined
-            or "connect" in combined
-            or "network" in combined
-            or "fetch" in combined
-            or "bootstrap" in combined
-        ), f"Expected bootstrap attempt, got: {combined!r}"
-
-
-class TestJsonEnvelopeParity:
-    """`mem0 init --agent --json` should produce a JSON envelope on success.
-
-    Without a live backend we can only assert the failure shape: when the
-    backend is unreachable, the CLI must still exit non-zero AND not crash
-    on a Python traceback (which would mean we leaked an exception past
-    the agent-mode handler).
-    """
-
-    def test_init_agent_json_no_traceback_on_network_failure(self, clean_home):
-        result = subprocess.run(
-            [sys.executable, "-m", "mem0_cli", "init", "--agent", "--json"],
-            capture_output=True,
-            encoding="utf-8",
-            env={
-                **{k: v for k, v in os.environ.items() if not k.startswith("MEM0_")},
-                "HOME": clean_home,
-                "MEM0_BASE_URL": "http://127.0.0.1:1",
-                "FORCE_COLOR": "0",
-                "PYTHONIOENCODING": "utf-8",
-            },
-            timeout=15,
-        )
-        combined = _strip_ansi(result.stdout + result.stderr)
-        assert "Traceback (most recent call last)" not in combined
-        assert result.returncode != 0
-
-
-class TestInitInCommandList:
-    """`mem0 --help` must list `init` so agents walking the top-level help
-    can discover the Agent Mode entrypoint without prior knowledge."""
-
-    def test_top_level_help_lists_init(self):
-        result = _run(["--help"])
-        assert result.returncode == 0
-        assert "init" in result.stdout

cli/python/tests/test_cli_integration.py

@@ -49,7 +49,6 @@ def _run(
         if key.startswith("MEM0_"):
             del env[key]
     env.pop("FORCE_COLOR", None)
-    env["PYTHONIOENCODING"] = "utf-8"
     if home_dir:
         env["HOME"] = home_dir
     if env_override:
@@ -57,7 +56,7 @@ def _run(
     result = subprocess.run(
         [sys.executable, "-m", "mem0_cli", *args],
         capture_output=True,
-        encoding="utf-8",
+        text=True,
         env=env,
     )
     return subprocess.CompletedProcess(
@@ -225,13 +224,24 @@ class TestCLIIsolated:
 
 
 class TestCLINewFeatures:
-    """Tests for MCP parity features: --limit, entities delete."""
+    """Tests for MCP parity features: --graph, --limit, entities delete."""
 
-    def test_search_help_has_limit(self):
+    def test_add_help_has_graph(self):
+        result = _run(["add", "--help"])
+        assert result.returncode == 0
+        assert "--graph" in result.stdout
+
+    def test_search_help_has_graph_and_limit(self):
         result = _run(["search", "--help"])
         assert result.returncode == 0
+        assert "--graph" in result.stdout
         assert "--limit" in result.stdout
 
+    def test_list_help_has_graph(self):
+        result = _run(["list", "--help"])
+        assert result.returncode == 0
+        assert "--graph" in result.stdout
+
     def test_delete_entity_via_delete_flag(self):
         """delete --entity should appear in help output."""
         result = _run(["delete", "--help"])

cli/python/tests/test_commands.py

@@ -8,8 +8,8 @@ from io import StringIO
 from unittest.mock import patch
 
 import pytest
+from click.exceptions import Exit as ClickExit
 from rich.console import Console
-from typer import Exit as TyperExit
 
 from mem0_cli.commands.config_cmd import (
     cmd_config_get,
@@ -181,7 +181,7 @@ class TestAddCommand:
             patch("mem0_cli.commands.memory.console", console),
             patch("mem0_cli.commands.memory.err_console", err_console),
             patch("mem0_cli.commands.memory._stdin_is_piped", return_value=False),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_add(
                 mock_backend,
@@ -206,7 +206,7 @@ class TestAddCommand:
         with (
             patch("mem0_cli.commands.memory.console", console),
             patch("mem0_cli.commands.memory.err_console", err_console),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_add(
                 mock_backend,
@@ -764,7 +764,7 @@ class TestImportCommand:
         with (
             patch("mem0_cli.commands.utils.console", console),
             patch("mem0_cli.commands.utils.err_console", err_console),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_import(mock_backend, "/nonexistent/file.json", user_id=None, agent_id=None)
 
@@ -801,7 +801,7 @@ class TestEntitiesListCommand:
         with (
             patch("mem0_cli.commands.entities.console", console),
             patch("mem0_cli.commands.entities.err_console", err_console),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_entities_list(mock_backend, "invalid", output="table")
 
@@ -944,7 +944,7 @@ class TestEntitiesDeleteCommand:
         with (
             patch("mem0_cli.commands.entities.console", console),
             patch("mem0_cli.commands.entities.err_console", err_console),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_entities_delete(
                 mock_backend,
@@ -997,6 +997,85 @@ class TestEntitiesDeleteCommand:
         mock_backend.delete_entities.assert_not_called()
 
 
+class TestEnableGraph:
+    def test_add_with_graph(self, mock_backend):
+        console, _buf = _make_console()
+        err_console, _err_buf = _make_err_console()
+        with (
+            patch("mem0_cli.commands.memory.console", console),
+            patch("mem0_cli.commands.memory.err_console", err_console),
+        ):
+            cmd_add(
+                mock_backend,
+                "test",
+                user_id="alice",
+                agent_id=None,
+                app_id=None,
+                run_id=None,
+                messages=None,
+                file=None,
+                metadata=None,
+                immutable=False,
+                no_infer=False,
+                expires=None,
+                categories=None,
+                enable_graph=True,
+                output="text",
+            )
+        call_kwargs = mock_backend.add.call_args
+        assert call_kwargs.kwargs.get("enable_graph") is True
+
+    def test_search_with_graph(self, mock_backend):
+        console, _buf = _make_console()
+        err_console, _err_buf = _make_err_console()
+        with (
+            patch("mem0_cli.commands.memory.console", console),
+            patch("mem0_cli.commands.memory.err_console", err_console),
+        ):
+            cmd_search(
+                mock_backend,
+                "test",
+                user_id="alice",
+                agent_id=None,
+                app_id=None,
+                run_id=None,
+                top_k=10,
+                threshold=0.3,
+                rerank=False,
+                keyword=False,
+                filter_json=None,
+                fields=None,
+                enable_graph=True,
+                output="text",
+            )
+        call_kwargs = mock_backend.search.call_args
+        assert call_kwargs.kwargs.get("enable_graph") is True
+
+    def test_list_with_graph(self, mock_backend):
+        console, _buf = _make_console()
+        err_console, _err_buf = _make_err_console()
+        with (
+            patch("mem0_cli.commands.memory.console", console),
+            patch("mem0_cli.commands.memory.err_console", err_console),
+        ):
+            cmd_list(
+                mock_backend,
+                user_id="alice",
+                agent_id=None,
+                app_id=None,
+                run_id=None,
+                page=1,
+                page_size=100,
+                category=None,
+                after=None,
+                before=None,
+                enable_graph=True,
+                output="table",
+            )
+        call_kwargs = mock_backend.list_memories.call_args
+        assert call_kwargs.kwargs.get("enable_graph") is True
+
+
 class TestEventCommands:
     def test_event_list_table(self, mock_backend):
         console, buf = _make_console()
@@ -1308,7 +1387,7 @@ class TestAgentMode:
             patch("mem0_cli.commands.memory.console", console),
             patch("mem0_cli.commands.memory.err_console", err_console),
             patch("sys.stdout", captured_stdout),
-            pytest.raises((SystemExit, TyperExit)),
+            pytest.raises((SystemExit, ClickExit)),
         ):
             cmd_get(mock_backend, "bad-id", output="text")
 

cli/python/tests/test_config.py

@@ -67,8 +67,7 @@ class TestConfig:
         from mem0_cli.config import CONFIG_FILE
 
         mode = os.stat(CONFIG_FILE).st_mode & 0o777
-        if os.name != "nt":
-            assert mode == 0o600
+        assert mode == 0o600
 
     def test_defaults_save_and_load(self, isolate_config):
         config = Mem0Config()
@@ -122,6 +121,46 @@ class TestConfig:
         assert config.defaults.agent_id == ""
         assert config.defaults.app_id == ""
         assert config.defaults.run_id == ""
+        assert config.defaults.enable_graph is False
+
+    def test_enable_graph_save_and_load(self, isolate_config):
+        config = Mem0Config()
+        config.defaults.enable_graph = True
+        save_config(config)
+        loaded = load_config()
+        assert loaded.defaults.enable_graph is True
+
+    def test_enable_graph_env_var_true(self, isolate_config, monkeypatch):
+        monkeypatch.setenv("MEM0_ENABLE_GRAPH", "true")
+        loaded = load_config()
+        assert loaded.defaults.enable_graph is True
+
+    def test_enable_graph_env_var_false(self, isolate_config, monkeypatch):
+        config = Mem0Config()
+        config.defaults.enable_graph = True
+        save_config(config)
+        monkeypatch.setenv("MEM0_ENABLE_GRAPH", "false")
+        loaded = load_config()
+        assert loaded.defaults.enable_graph is False
+
+    def test_backward_compat_no_enable_graph_key(self, isolate_config):
+        """Old config files without 'enable_graph' key should default to False."""
+        import json
+
+        from mem0_cli.config import CONFIG_FILE, ensure_config_dir
+
+        ensure_config_dir()
+        data = {
+            "version": 1,
+            "defaults": {"user_id": "alice"},
+            "platform": {"api_key": "m0-test", "base_url": "https://api.mem0.ai"},
+        }
+        with open(CONFIG_FILE, "w") as f:
+            json.dump(data, f)
+
+        loaded = load_config()
+        assert loaded.defaults.enable_graph is False
+        assert loaded.defaults.user_id == "alice"
 
 
 class TestNestedAccess:
@@ -153,6 +192,11 @@ class TestNestedAccess:
         assert set_nested_value(config, "defaults.user_id", "bob")
         assert config.defaults.user_id == "bob"
 
+    def test_set_defaults_enable_graph(self):
+        config = Mem0Config()
+        assert set_nested_value(config, "defaults.enable_graph", "true")
+        assert config.defaults.enable_graph is True
+
 
 class TestResolveIds:
     def test_cli_flag_overrides_default(self):

cli/python/tests/test_init_internals.py

@@ -1,206 +0,0 @@
-"""Unit tests for init internals — decision tree primitives + plugin sync.
-
-These tests exercise the units that the high-level subprocess parity tests in
-``test_agent_mode.py`` deliberately can't reach:
-
-  - ``_ping_key`` must NOT treat network errors as "invalid key" (else a VPN
-    flap silently mints a new shadow over a working key).
-  - ``plugin_sync`` must only update entries that already exist, preserve
-    trailing newlines, and never mangle other lines.
-  - The 403→ratelimit translation in ``bootstrap_via_backend`` surfaces the
-    real cause instead of DRF's opaque "You do not have permission" string.
-
-Mirror surface lives in ``cli/node/tests/agent-mode.test.ts``; if you add a
-behavioral assertion here, mirror it on the Node side and vice versa.
-"""
-
-from __future__ import annotations
-
-from unittest.mock import MagicMock
-
-import httpx
-import pytest
-
-from mem0_cli.commands.init_cmd import _ping_key
-from mem0_cli.plugin_sync import _update_claude_settings, _update_shell_rc
-
-# ── _ping_key ──────────────────────────────────────────────────────────────
-
-
-class _Resp:
-    def __init__(self, status_code: int) -> None:
-        self.status_code = status_code
-
-
-def test_ping_key_200_is_valid(monkeypatch: pytest.MonkeyPatch) -> None:
-    monkeypatch.setattr(httpx, "get", lambda *a, **kw: _Resp(200))
-    assert _ping_key("k", "http://x") is True
-
-
-def test_ping_key_401_is_invalid(monkeypatch: pytest.MonkeyPatch) -> None:
-    monkeypatch.setattr(httpx, "get", lambda *a, **kw: _Resp(401))
-    assert _ping_key("k", "http://x") is False
-
-
-def test_ping_key_403_is_invalid(monkeypatch: pytest.MonkeyPatch) -> None:
-    monkeypatch.setattr(httpx, "get", lambda *a, **kw: _Resp(403))
-    assert _ping_key("k", "http://x") is False
-
-
-def test_ping_key_5xx_is_not_definitively_invalid(monkeypatch: pytest.MonkeyPatch) -> None:
-    # Transient upstream failure must NOT cause a shadow to be minted.
-    monkeypatch.setattr(httpx, "get", lambda *a, **kw: _Resp(503))
-    assert _ping_key("k", "http://x") is True
-
-
-def test_ping_key_connect_error_prefers_reuse(monkeypatch: pytest.MonkeyPatch) -> None:
-    # Network blip (DNS, captive portal, etc.) — must NOT trigger a re-mint.
-    def boom(*a, **kw):
-        raise httpx.ConnectError("nope")
-
-    monkeypatch.setattr(httpx, "get", boom)
-    assert _ping_key("k", "http://x") is True
-
-
-def test_ping_key_timeout_prefers_reuse(monkeypatch: pytest.MonkeyPatch) -> None:
-    def boom(*a, **kw):
-        raise httpx.ReadTimeout("slow")
-
-    monkeypatch.setattr(httpx, "get", boom)
-    assert _ping_key("k", "http://x") is True
-
-
-# ── plugin_sync._update_shell_rc ──────────────────────────────────────────
-
-
-def test_shell_rc_updates_existing_export_preserves_trailing_newline(tmp_path) -> None:
-    rc = tmp_path / ".zshrc"
-    rc.write_text('export MEM0_API_KEY="old"\n', encoding="utf-8")
-    changed = _update_shell_rc(rc, "newkey")
-    assert changed is True
-    assert rc.read_text(encoding="utf-8") == 'export MEM0_API_KEY="newkey"\n'
-
-
-def test_shell_rc_does_not_create_new_export(tmp_path) -> None:
-    rc = tmp_path / ".zshrc"
-    rc.write_text("alias ll='ls -la'\n", encoding="utf-8")
-    changed = _update_shell_rc(rc, "newkey")
-    assert changed is False
-    assert rc.read_text(encoding="utf-8") == "alias ll='ls -la'\n"
-
-
-def test_shell_rc_preserves_surrounding_content(tmp_path) -> None:
-    rc = tmp_path / ".zshrc"
-    original = "# my zshrc\nalias ll='ls -la'\nexport MEM0_API_KEY='old'\nexport OTHER=keepme\n"
-    rc.write_text(original, encoding="utf-8")
-    _update_shell_rc(rc, "newkey")
-    after = rc.read_text(encoding="utf-8")
-    assert "alias ll='ls -la'\n" in after
-    assert "export OTHER=keepme\n" in after
-    assert "# my zshrc\n" in after
-    assert 'export MEM0_API_KEY="newkey"\n' in after
-
-
-def test_shell_rc_idempotent_when_already_matching(tmp_path) -> None:
-    rc = tmp_path / ".zshrc"
-    rc.write_text('export MEM0_API_KEY="same"\n', encoding="utf-8")
-    assert _update_shell_rc(rc, "same") is False
-
-
-def test_shell_rc_missing_file_is_noop(tmp_path) -> None:
-    rc = tmp_path / ".zshrc"  # does not exist
-    assert _update_shell_rc(rc, "x") is False
-
-
-# ── plugin_sync._update_claude_settings ────────────────────────────────────
-
-
-def test_claude_settings_does_not_create_env_block(tmp_path) -> None:
-    import json
-
-    settings = tmp_path / "settings.json"
-    settings.write_text(json.dumps({"otherKey": 1}), encoding="utf-8")
-    changed = _update_claude_settings(settings, "newkey")
-    assert changed is False
-    # Original content unchanged.
-    assert json.loads(settings.read_text(encoding="utf-8")) == {"otherKey": 1}
-
-
-def test_claude_settings_does_not_create_mem0_entry_in_existing_env(tmp_path) -> None:
-    import json
-
-    settings = tmp_path / "settings.json"
-    settings.write_text(json.dumps({"env": {"OTHER_KEY": "x"}}), encoding="utf-8")
-    changed = _update_claude_settings(settings, "newkey")
-    assert changed is False
-
-
-def test_claude_settings_updates_existing_entry(tmp_path) -> None:
-    import json
-
-    settings = tmp_path / "settings.json"
-    settings.write_text(
-        json.dumps({"env": {"MEM0_API_KEY": "old", "OTHER": "y"}}, indent=2),
-        encoding="utf-8",
-    )
-    changed = _update_claude_settings(settings, "fresh")
-    assert changed is True
-    data = json.loads(settings.read_text(encoding="utf-8"))
-    assert data["env"]["MEM0_API_KEY"] == "fresh"
-    assert data["env"]["OTHER"] == "y"  # other keys preserved
-
-
-def test_claude_settings_idempotent(tmp_path) -> None:
-    import json
-
-    settings = tmp_path / "settings.json"
-    settings.write_text(json.dumps({"env": {"MEM0_API_KEY": "same"}}), encoding="utf-8")
-    assert _update_claude_settings(settings, "same") is False
-
-
-def test_claude_settings_malformed_json_is_noop(tmp_path) -> None:
-    settings = tmp_path / "settings.json"
-    settings.write_text("{ this is not json", encoding="utf-8")
-    assert _update_claude_settings(settings, "x") is False
-
-
-# ── bootstrap rate-limit translation ──────────────────────────────────────
-
-
-def test_bootstrap_403_permission_surfaces_ratelimit(monkeypatch, capsys) -> None:
-    """DRF 403 'You do not have permission' must be translated to the daily limit message."""
-    from mem0_cli.commands.agent_mode_cmd import bootstrap_via_backend
-    from mem0_cli.config import Mem0Config
-
-    fake_resp = MagicMock()
-    fake_resp.status_code = 403
-    fake_resp.text = '{"detail": "You do not have permission to perform this action."}'
-    fake_resp.json = MagicMock(
-        return_value={"detail": "You do not have permission to perform this action."}
-    )
-
-    class _Client:
-        def __init__(self, *a, **kw):
-            pass
-
-        def __enter__(self):
-            return self
-
-        def __exit__(self, *a):
-            return False
-
-        def post(self, *a, **kw):
-            return fake_resp
-
-    monkeypatch.setattr(httpx, "Client", _Client)
-    cfg = Mem0Config()
-    cfg.platform.base_url = "https://api.mem0.ai"
-    import typer
-
-    with pytest.raises(typer.Exit):
-        bootstrap_via_backend(cfg)
-
-    captured = capsys.readouterr()
-    combined = captured.out + captured.err
-    assert "Daily Agent Mode signup limit reached" in combined
-    assert "permission to perform this action" not in combined

cli/python/tests/test_telemetry.py

@@ -1,80 +0,0 @@
-"""Tests for telemetry subprocess secret handling."""
-
-from __future__ import annotations
-
-import io
-import json
-import subprocess
-import sys
-
-from mem0_cli.config import Mem0Config, save_config
-from mem0_cli.telemetry import capture_event
-from mem0_cli.telemetry_sender import _load_context
-
-
-class _CaptureStdin:
-    def __init__(self):
-        self.buffer = ""
-        self.closed = False
-
-    def write(self, value: str) -> None:
-        self.buffer += value
-
-    def close(self) -> None:
-        self.closed = True
-
-
-class _DummyProcess:
-    def __init__(self):
-        self.stdin = _CaptureStdin()
-
-
-def test_capture_event_writes_context_to_stdin_not_argv(isolate_config, monkeypatch):
-    config = Mem0Config()
-    config.platform.api_key = "m0-test-secret"
-    config.telemetry.anonymous_id = "cli-anon-test"
-    save_config(config)
-
-    captured: dict[str, object] = {}
-    proc = _DummyProcess()
-
-    def fake_popen(args, **kwargs):
-        captured["args"] = args
-        captured["kwargs"] = kwargs
-        return proc
-
-    monkeypatch.setattr("mem0_cli.telemetry.subprocess.Popen", fake_popen)
-
-    capture_event("unit_test_event", {"case": "stdin-secret"})
-
-    argv = captured["args"]
-    assert argv == [sys.executable, "-m", "mem0_cli.telemetry_sender"]
-    assert all("m0-test-secret" not in arg for arg in argv)
-
-    kwargs = captured["kwargs"]
-    assert kwargs["stdin"] == subprocess.PIPE
-    assert kwargs["text"] is True
-
-    ctx = json.loads(proc.stdin.buffer)
-    assert ctx["mem0_api_key"] == "m0-test-secret"
-    assert ctx["payload"]["event"] == "unit_test_event"
-
-    assert proc.stdin.closed
-
-
-def test_load_context_reads_from_stdin(monkeypatch):
-    monkeypatch.setattr("sys.argv", ["telemetry_sender"])
-    monkeypatch.setattr("sys.stdin", io.StringIO('{"payload": {"event": "stdin"}}'))
-
-    ctx = _load_context()
-
-    assert ctx["payload"]["event"] == "stdin"
-
-
-def test_load_context_falls_back_to_argv(monkeypatch):
-    monkeypatch.setattr("sys.argv", ["telemetry_sender", '{"payload": {"event": "argv"}}'])
-    monkeypatch.setattr("sys.stdin", io.StringIO(""))
-
-    ctx = _load_context()
-
-    assert ctx["payload"]["event"] == "argv"

cookbooks/helper/mem0_teachability.py

@@ -56,7 +56,7 @@ class Mem0Teachability(AgentCapability):
 
     def process_last_received_message(self, text: Union[Dict, str]):
         expanded_text = text
-        if self.memory.get_all(filters={"agent_id": self.agent_id}):
+        if self.memory.get_all(agent_id=self.agent_id):
             expanded_text = self._consider_memo_retrieval(text)
         self._consider_memo_storage(text)
         return expanded_text
@@ -139,7 +139,7 @@ class Mem0Teachability(AgentCapability):
         return comment + self._concatenate_memo_texts(memo_list)
 
     def _retrieve_relevant_memos(self, input_text: str) -> list:
-        search_results = self.memory.search(input_text, filters={"agent_id": self.agent_id}, top_k=self.max_num_retrievals)
+        search_results = self.memory.search(input_text, agent_id=self.agent_id, limit=self.max_num_retrievals)
         memo_list = [result["memory"] for result in search_results if result["score"] <= self.recall_threshold]
 
         if self.verbosity >= 1 and not memo_list:

cookbooks/mem0-autogen.ipynb

@@ -555,7 +555,7 @@
     "# - Enables creation of AI agents with long-term memory and learning abilities.\n",
     "# - Improves consistency and reduces repetition in user-agent interactions.\n",
     "\n",
-    "from helper.mem0_teachability import Mem0Teachability\n",
+    "from cookbooks.helper.mem0_teachability import Mem0Teachability\n",
     "\n",
     "teachability = Mem0Teachability(\n",
     "    verbosity=2,  # for visibility of what's happening\n",

docs/_snippets/paper-release.mdx

@@ -0,0 +1,3 @@
+<Note type="info">
+  <strong>🎉 Mem0 1.0.0 is here!</strong> Enhanced filtering, reranking, and smarter memory management.
+</Note>

docs/api-reference.mdx

@@ -10,7 +10,7 @@ description: "REST APIs for memory management, search, and entity operations"
 Mem0 provides a comprehensive REST API for integrating advanced memory capabilities into your applications. Create, search, update, and manage memories across users, agents, and custom entities with simple HTTP requests.
 
 <Info>
-**Quick start:** Get your API key from the <a href="https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=api-reference" rel="nofollow">Mem0 Dashboard</a> and make your first memory operation in minutes.
+**Quick start:** Get your API key from the [Mem0 Dashboard](https://app.mem0.ai/dashboard/api-keys) and make your first memory operation in minutes.
 </Info>
 
 ---
@@ -87,7 +87,7 @@ All API requests require authentication using Token-based authentication. Includ
 Authorization: Token <your-api-key>
 ```
 
-Get your API key from the <a href="https://app.mem0.ai/dashboard/api-keys?utm_source=oss&utm_medium=api-reference" rel="nofollow">Mem0 Dashboard</a>.
+Get your API key from the [Mem0 Dashboard](https://app.mem0.ai/dashboard/api-keys).
 
 <Warning>
 **Keep your API key secure.** Never expose it in client-side code or public repositories. Use environment variables and server-side requests only.

docs/api-reference/events/get-event.mdx

@@ -5,5 +5,3 @@ openapi: get /v1/event/{event_id}/
 ---
 
 Retrieve details about a specific event by passing its `event_id`. This endpoint is particularly helpful for tracking the status, payload, and completion details of asynchronous memory operations.
-
-For `POST /v3/memories/add/`, the event confirms that the write pipeline completed. Temporal reasoning enrichment runs asynchronously by default, so the event may be `SUCCEEDED` slightly before temporal ranking signals are available to subsequent `search` calls.

docs/api-reference/memory/add-memories.mdx

@@ -1,18 +1,18 @@
 ---
-title: Add Memories
-description: "Add facts, messages, or metadata to a user memory store with async processing and event tracking via the V3 additive pipeline."
-openapi: post /v3/memories/add/
+title: 'Add Memories'
+description: "Add facts, messages, or metadata to a user memory store with support for async processing and event tracking."
+openapi: post /v1/memories/
 ---
 
-Extract and store memories from a conversation using the V3 additive pipeline. The endpoint uses single-pass ADD-only extraction — one LLM call, no UPDATE/DELETE. Memories accumulate over time; nothing is overwritten.
+Add new facts, messages, or metadata to a user’s memory store. The Add Memories endpoint accepts either raw text or conversational turns and commits them asynchronously so the memory is ready for later search, retrieval, and graph queries.
 
 ## Endpoint
 
 - **Method**: `POST`
-- **URL**: `/v3/memories/add/`
+- **URL**: `/v1/memories/`
 - **Content-Type**: `application/json`
 
-Processing is asynchronous. The response returns an `event_id` you can poll via `GET /v1/event/{event_id}/`.
+Memories are processed asynchronously by default. The response contains queued events you can track while the platform finalizes enrichment.
 
 ## Required headers
 
@@ -23,7 +23,7 @@ Processing is asynchronous. The response returns an `event_id` you can poll via
 
 ## Request body
 
-Provide conversation messages for Mem0 to extract memories from. At least one entity ID (`user_id`, `agent_id`, `app_id`, or `run_id`) is required so the memory is scoped to a session. Entity IDs are accepted at the top level.
+Provide at least one message or direct memory string. Most callers supply `messages` so Mem0 can infer structured memories as part of ingestion.
 
 <CodeGroup>
 ```json Basic request
@@ -43,15 +43,14 @@ Provide conversation messages for Mem0 to extract memories from. At least one en
 
 | Field | Type | Required | Description |
 | --- | --- | --- | --- |
-| `messages` | array | Yes | Conversation turns for Mem0 to extract memories from. Each object should include `role` and `content`. |
-| `user_id` | string | No* | Associates the memory with a user. |
-| `agent_id` | string | No* | Associates the memory with an agent. |
-| `run_id` | string | No* | Associates the memory with a run. |
-| `app_id` | string | No* | Associates the memory with an app. |
+| `user_id` | string | No* | Associates the memory with a user. Provide when you want the memory scoped to a specific identity. |
+| `messages` | array | No* | Conversation turns for Mem0 to infer memories from. Each object should include `role` and `content`. |
 | `metadata` | object | Optional | Custom key/value metadata (e.g., `{"topic": "preferences"}`). |
 | `infer` | boolean (default `true`) | Optional | Set to `false` to skip inference and store the provided text as-is. |
+| `async_mode` | boolean (default `true`) | Optional | Controls asynchronous processing. Most clients leave this enabled. |
+| `output_format` | string (default `v1.1`) | Optional | Response format. `v1.1` wraps results in a `results` array. |
 
-> \* At least one entity ID (`user_id`, `agent_id`, `app_id`, or `run_id`) is required.
+> \* Provide at least one `messages` entry to describe what you are storing. For scoped memories, include `user_id`. You can also attach `agent_id`, `app_id`, `run_id`, `project_id`, or `org_id` to refine ownership.
 
 <Tip>
   Need more details? See [all request parameters](#body-messages) below for complete field descriptions, types, and constraints.
@@ -59,15 +58,19 @@ Provide conversation messages for Mem0 to extract memories from. At least one en
 
 ## Response
 
-The request is queued for background processing. The response contains an `event_id` for tracking status.
+Successful requests return an array of events queued for processing. Each event includes the generated memory text and an identifier you can persist for auditing.
 
 <CodeGroup>
 ```json 200 response
-{
-  "message": "Memory processing has been queued for background execution",
-  "status": "PENDING",
-  "event_id": "evt-uuid"
-}
+[
+  {
+    "id": "mem_01JF8ZS4Y0R0SPM13R5R6H32CJ",
+    "event": "ADD",
+    "data": {
+      "memory": "The user moved to Austin in 2025."
+    }
+  }
+]
 ```
 
 ```json 400 response
@@ -80,6 +83,20 @@ The request is queued for background processing. The response contains an `event
 ```
 </CodeGroup>
 
-<Info>
-Poll the event status via `GET /v1/event/{event_id}/`. Status will be `SUCCEEDED` or `FAILED` once processing completes.
-</Info>
+## Graph relationships
+
+Add Memories can enrich the knowledge graph on write. Set `enable_graph: true` to create entity nodes and relationships for the stored memory. Use this when you want downstream `get_all` or search calls to traverse connected entities.
+
+<CodeGroup>
+```json Graph-aware request
+{
+  "user_id": "alice",
+  "messages": [
+    { "role": "user", "content": "I met with Dr. Lee at General Hospital." }
+  ],
+  "enable_graph": true
+}
+```
+</CodeGroup>
+
+The response follows the same format, and related entities become available in [Graph Memory](/platform/features/graph-memory) queries.

docs/api-reference/memory/create-memory-export.mdx

@@ -4,4 +4,4 @@ description: "Submit an export job to create a structured memory export using a
 openapi: post /v1/exports/
 ---
 
-Submit a job to create a structured export of memories using a customizable Pydantic schema. This process may take some time to complete, especially if you're exporting a large number of memories. You can tailor the export by applying various filters (e.g., `user_id`, `agent_id`, `app_id`, or `run_id`) and by modifying the Pydantic schema to ensure the final data matches your exact needs.
+Submit a job to create a structured export of memories using a customizable Pydantic schema. This process may take some time to complete, especially if you're exporting a large number of memories. You can tailor the export by applying various filters (e.g., `user_id`, `agent_id`, `run_id`, or `session_id`) and by modifying the Pydantic schema to ensure the final data matches your exact needs.

docs/api-reference/memory/get-memories.mdx

@@ -1,12 +1,10 @@
 ---
 title: "Get Memories"
-description: "Retrieve memories with paginated results and advanced filtering using logical operators like AND, OR, NOT, and comparison queries."
-openapi: post /v3/memories/
+description: "Retrieve memories with advanced filtering using logical operators like AND, OR, NOT, and comparison queries."
+openapi: post /v2/memories/
 ---
 
-List memories scoped by filters with paginated results. Entity IDs (`user_id`, `agent_id`, `app_id`, `run_id`) **must** be passed inside the `filters` object — top-level entity IDs are rejected with 400.
-
-The `filters` object supports complex logical operations (AND, OR, NOT) and comparison operators:
+The v2 get memories API is powerful and flexible, allowing for more precise memory listing without the need for a search query. It supports complex logical operations (AND, OR, NOT) and comparison operators for advanced filtering capabilities. The comparison operators include:
 
 - `in`: Matches any of the values specified
 - `gte`: Greater than or equal to
@@ -17,8 +15,6 @@ The `filters` object supports complex logical operations (AND, OR, NOT) and comp
 - `icontains`: Case-insensitive containment check
 - `*`: Wildcard character that matches everything
 
-Pass `page` and `page_size` as query parameters to paginate through results.
-
 <CodeGroup>
 ```python Code
 memories = client.get_all(
@@ -31,17 +27,12 @@ memories = client.get_all(
                 "created_at": {"gte": "2024-07-01", "lte": "2024-07-31"}
             }
         ]
-    },
-    page=1,
-    page_size=50
+    }
 )
 ```
 
 ```python Output
 {
-    "count": 2,
-    "next": null,
-    "previous": null,
     "results": [
         {
             "id": "f4cbdb08-7062-4f3e-8eb2-9f5c80dfe64c",
@@ -55,12 +46,55 @@ memories = client.get_all(
             "created_at": "2024-07-05T15:30:00Z",
             "updated_at": "2024-07-05T15:30:00Z"
         }
-    ]
+    ],
+    "total": 2
 }
 ```
 
 </CodeGroup>
 
-<Info>
-The response is a paginated envelope with `count`, `next`, `previous`, and `results`. Use `page` and `page_size` query params to step through results.
-</Info>
+## Graph Memory
+
+To retrieve graph memory relationships between entities, pass `output_format="v1.1"` in your request. This will return memories with entity and relationship information from the knowledge graph.
+
+<CodeGroup>
+```python Code
+memories = client.get_all(
+    filters={
+        "user_id": "alex"
+    },
+    output_format="v1.1"
+)
+```
+
+```python Output
+{
+    "results": [
+        {
+            "id": "f4cbdb08-7062-4f3e-8eb2-9f5c80dfe64c",
+            "memory": "Alex is planning a trip to San Francisco",
+            "entities": [
+                {
+                    "id": "entity-1",
+                    "name": "Alex",
+                    "type": "person"
+                },
+                {
+                    "id": "entity-2",
+                    "name": "San Francisco",
+                    "type": "location"
+                }
+            ],
+            "relations": [
+                {
+                    "source": "entity-1",
+                    "target": "entity-2",
+                    "relationship": "traveling_to"
+                }
+            ]
+        }
+    ]
+}
+```
+
+</CodeGroup>

docs/api-reference/memory/get-memory-export.mdx

@@ -4,4 +4,4 @@ description: "Retrieve the latest structured memory export after submitting an e
 openapi: post /v1/exports/get
 ---
 
-Retrieve the latest structured memory export after submitting an export job. You can filter the export by `user_id`, `agent_id`, `app_id`, `run_id`, `created_at`, or `updated_at` to get the most recent export matching your filters.
+Retrieve the latest structured memory export after submitting an export job. You can filter the export by `user_id`, `run_id`, `session_id`, or `app_id` to get the most recent export matching your filters.